Home
last modified time | relevance | path

Searched refs:ibuf (Results 1 – 25 of 302) sorted by relevance

12345678910>>...13

/openbsd/lib/libutil/
H A Dimsg.h31 struct ibuf { struct
32 TAILQ_ENTRY(ibuf) entry;
42 TAILQ_HEAD(, ibuf) bufs; argument
76 struct ibuf *buf;
82 struct ibuf *ibuf_open(size_t);
85 int ibuf_add_buf(struct ibuf *, const struct ibuf *);
86 int ibuf_add_ibuf(struct ibuf *, const struct ibuf *);
112 void ibuf_from_ibuf(struct ibuf *, const struct ibuf *);
114 int ibuf_get_ibuf(struct ibuf *, size_t, struct ibuf *);
123 void ibuf_free(struct ibuf *);
[all …]
H A Dimsg-buffer.c40 struct ibuf *
43 struct ibuf *buf; in ibuf_open()
61 struct ibuf *
64 struct ibuf *buf; in ibuf_dynamic()
138 ibuf_add_ibuf(struct ibuf *buf, const struct ibuf *from) in ibuf_add_ibuf()
145 ibuf_add_buf(struct ibuf *buf, const struct ibuf *from) in ibuf_add_buf()
399 ibuf_from_ibuf(struct ibuf *buf, const struct ibuf *from) in ibuf_from_ibuf()
418 ibuf_get_ibuf(struct ibuf *buf, size_t len, struct ibuf *new) in ibuf_get_ibuf()
539 struct ibuf *buf; in ibuf_write()
582 struct ibuf *buf, *next; in msgbuf_drain()
[all …]
/openbsd/usr.sbin/smtpd/
H A Dscheduler_proc.c25 static struct imsgbuf ibuf; variable
107 imsg_init(&ibuf, fd); in scheduler_proc_init()
207 struct ibuf *buf; in scheduler_proc_hold()
220 imsg_close(&ibuf, buf); in scheduler_proc_hold()
233 struct ibuf *buf; in scheduler_proc_release()
248 imsg_close(&ibuf, buf); in scheduler_proc_release()
261 struct ibuf *buf; in scheduler_proc_batch()
274 imsg_close(&ibuf, buf); in scheduler_proc_batch()
292 struct ibuf *buf; in scheduler_proc_messages()
305 imsg_close(&ibuf, buf); in scheduler_proc_messages()
[all …]
H A Dqueue_proc.c26 static struct imsgbuf ibuf; variable
36 if (imsg_flush(&ibuf) == -1) { in queue_proc_call()
42 if ((n = imsg_get(&ibuf, &imsg)) == -1) { in queue_proc_call()
57 if ((n = imsg_read(&ibuf)) == -1 && errno != EAGAIN) { in queue_proc_call()
103 imsg_compose(&ibuf, PROC_QUEUE_CLOSE, 0, 0, -1, NULL, 0); in queue_proc_close()
180 struct ibuf *b; in queue_proc_envelope_create()
189 imsg_close(&ibuf, b); in queue_proc_envelope_create()
218 struct ibuf *b; in queue_proc_envelope_update()
226 imsg_close(&ibuf, b); in queue_proc_envelope_update()
294 imsg_init(&ibuf, fd); in queue_proc_init()
[all …]
/openbsd/regress/lib/libc/vis/
H A Dvis_test.c14 char ibuf[NCH]; variable
64 arc4random_buf(ibuf, sizeof(ibuf) - 1); in main()
65 ibuf[sizeof(ibuf) - 1] = '\0'; in main()
69 owant = sizeof(ibuf); in main()
70 o = strnvis(obuf, ibuf, owant, flags[j]); in main()
82 } else if (o > strlen(ibuf) * 4) { in main()
85 o, strlen(ibuf) * 4); in main()
96 } else if (r != strlen(ibuf)) { in main()
99 r, strlen(ibuf)); in main()
103 } else if (bcmp(ibuf, rbuf, r)) { in main()
[all …]
/openbsd/sbin/iked/
H A Dimsg_util.c39 struct ibuf *
42 struct ibuf *buf; in ibuf_new()
66 struct ibuf *
73 ibuf_length(struct ibuf *buf) in ibuf_length()
80 struct ibuf *
81 ibuf_getdata(struct ibuf *buf, size_t len) in ibuf_getdata()
83 struct ibuf tmp; in ibuf_getdata()
91 struct ibuf *
92 ibuf_dup(struct ibuf *buf) in ibuf_dup()
99 struct ibuf *
[all …]
H A Diked.h993 struct ibuf *
1004 struct ibuf *
1006 struct ibuf *
1028 struct ibuf *
1068 struct ibuf *
1101 struct ibuf *
1110 struct ibuf
1121 struct ibuf
1124 struct ibuf *
1126 struct ibuf *, struct ibuf *);
[all …]
H A Ddh.h52 int (*exchange2)(struct dh_group *, struct ibuf **, struct ibuf *);
54 int (*shared2)(struct dh_group *, struct ibuf **, struct ibuf *);
65 int dh_create_exchange(struct dh_group *, struct ibuf **, struct ibuf *);
66 int dh_create_shared(struct dh_group *, struct ibuf **, struct ibuf *);
/openbsd/usr.sbin/ospfctl/
H A Dospfctl.c46 struct imsgbuf *ibuf; variable
107 if ((ibuf = malloc(sizeof(struct imsgbuf))) == NULL) in main()
109 imsg_init(ibuf, ctl_sock); in main()
139 imsg_compose(ibuf, IMSG_CTL_SHOW_DATABASE, 0, 0, -1, in main()
169 imsg_compose(ibuf, IMSG_CTL_KROUTE, 0, 0, -1, in main()
172 imsg_compose(ibuf, IMSG_CTL_KROUTE_ADDR, 0, 0, -1, in main()
177 imsg_compose(ibuf, IMSG_CTL_IFINFO, 0, 0, -1, in main()
204 imsg_compose(ibuf, IMSG_CTL_LOG_VERBOSE, 0, 0, -1, in main()
216 while (ibuf->w.queued) in main()
231 if ((n = imsg_get(ibuf, &imsg)) == -1) in main()
[all …]
/openbsd/usr.sbin/ldapd/
H A Dimsgev.c40 imsg_init(&iev->ibuf, fd); in imsgev_init()
77 msgbuf_clear(&iev->ibuf.w); in imsgev_clear()
78 close(iev->ibuf.fd); in imsgev_clear()
88 if (iev->ibuf.w.queued || iev->terminate) in imsgev_add()
105 struct imsgbuf *ibuf = &iev->ibuf; in imsgev_dispatch() local
112 if ((n = imsg_read(ibuf)) == -1) { in imsgev_dispatch()
116 n = imsg_read(ibuf); in imsgev_dispatch()
131 (iev->ibuf.w.queued) ? IMSGEV_EWRITE : IMSGEV_DONE); in imsgev_dispatch()
142 if ((n = msgbuf_write(&ibuf->w)) <= 0 && errno != EAGAIN) { in imsgev_dispatch()
149 if ((n = imsg_get(ibuf, &imsg)) == -1) { in imsgev_dispatch()
[all …]
/openbsd/usr.sbin/ikectl/
H A Dikectl.c70 struct imsgbuf *ibuf; variable
248 if (res->ibuf != NULL) in main()
249 ibuf = res->ibuf; in main()
253 imsg_init(ibuf, ctl_sock); in main()
295 imsg_compose(ibuf, IMSG_CTL_RELOAD, 0, 0, -1, in main()
299 imsg_compose(ibuf, IMSG_CTL_RESET_ID, 0, 0, -1, in main()
342 while (ibuf->w.queued) in main()
343 if (msgbuf_write(&ibuf->w) <= 0 && errno != EAGAIN) in main()
347 if ((n = imsg_read(ibuf)) == -1 && errno != EAGAIN) in main()
353 if ((n = imsg_get(ibuf, &imsg)) == -1) in main()
[all …]
/openbsd/usr.sbin/ractl/
H A Dractl.c46 struct imsgbuf *ibuf; variable
101 if ((ibuf = malloc(sizeof(struct imsgbuf))) == NULL) in main()
103 imsg_init(ibuf, ctl_sock); in main()
112 imsg_compose(ibuf, IMSG_CTL_LOG_VERBOSE, 0, 0, -1, in main()
118 imsg_compose(ibuf, IMSG_CTL_RELOAD, 0, 0, -1, NULL, 0); in main()
126 while (ibuf->w.queued) in main()
127 if (msgbuf_write(&ibuf->w) <= 0 && errno != EAGAIN) in main()
131 if ((n = imsg_read(ibuf)) == -1 && errno != EAGAIN) in main()
137 if ((n = imsg_get(ibuf, &imsg)) == -1) in main()
150 free(ibuf); in main()
/openbsd/usr.sbin/dhcpd/
H A Dconvert.c64 u_int32_t ibuf; in getULong() local
66 memcpy(&ibuf, buf, sizeof(ibuf)); in getULong()
67 return (ntohl(ibuf)); in getULong()
73 u_int16_t ibuf; in getUShort() local
75 memcpy(&ibuf, buf, sizeof(ibuf)); in getUShort()
76 return (ntohs(ibuf)); in getUShort()
/openbsd/usr.sbin/rpki-client/
H A Dio.c37 struct ibuf *
40 struct ibuf *b; in io_new_buffer()
75 io_str_buffer(struct ibuf *b, const char *p) in io_str_buffer()
115 io_read_str(struct ibuf *b, char **res) in io_read_str()
149 ibuf_realloc(struct ibuf *buf, size_t len) in ibuf_realloc()
173 struct ibuf *
174 io_buf_read(int fd, struct ibuf **ib) in io_buf_read()
176 struct ibuf *b = *ib; in io_buf_read()
225 struct ibuf *
226 io_buf_recvfd(int fd, struct ibuf **ib) in io_buf_recvfd()
[all …]
/openbsd/usr.sbin/dvmrpd/
H A Ddvmrpd.c238 imsg_init(&iev_rde->ibuf, pipe_parent2rde[0]); in main()
277 msgbuf_clear(&iev_dvmrpe->ibuf.w); in dvmrpd_shutdown()
278 close(iev_dvmrpe->ibuf.fd); in dvmrpd_shutdown()
279 msgbuf_clear(&iev_rde->ibuf.w); in dvmrpd_shutdown()
280 close(iev_rde->ibuf.fd); in dvmrpd_shutdown()
314 struct imsgbuf *ibuf = &iev->ibuf; in main_dispatch_dvmrpe() local
333 if ((n = imsg_get(ibuf, &imsg)) == -1) in main_dispatch_dvmrpe()
376 struct imsgbuf *ibuf = &iev->ibuf; in main_dispatch_rde() local
395 if ((n = imsg_get(ibuf, &imsg)) == -1) in main_dispatch_rde()
450 if (iev->ibuf.w.queued) in imsg_event_add()
[all …]
H A Ddvmrpe.c146 imsg_init(&iev_rde->ibuf, pipe_dvmrpe2rde[0]); in dvmrpe()
194 msgbuf_write(&iev_rde->ibuf.w); in dvmrpe_shutdown()
195 msgbuf_clear(&iev_rde->ibuf.w); in dvmrpe_shutdown()
196 close(iev_rde->ibuf.fd); in dvmrpe_shutdown()
197 msgbuf_write(&iev_main->ibuf.w); in dvmrpe_shutdown()
198 msgbuf_clear(&iev_main->ibuf.w); in dvmrpe_shutdown()
199 close(iev_main->ibuf.fd); in dvmrpe_shutdown()
237 struct imsgbuf *ibuf = &iev->ibuf; in dvmrpe_dispatch_main() local
257 if ((n = imsg_get(ibuf, &imsg)) == -1) in dvmrpe_dispatch_main()
308 struct imsgbuf *ibuf = &iev->ibuf; in dvmrpe_dispatch_rde() local
[all …]
/openbsd/usr.bin/mail/
H A Dquit.c218 (void)Fclose(ibuf); in quit()
229 (void)Fclose(ibuf); in quit()
260 rewind(ibuf); in quit()
261 c = getc(ibuf); in quit()
266 c = getc(ibuf); in quit()
268 (void)Fclose(ibuf); in quit()
393 FILE *obuf, *ibuf; in edstop() local
410 ibuf = NULL; in edstop()
434 (void)Fclose(ibuf); in edstop()
464 if (ibuf != NULL) { in edstop()
[all …]
H A Dlex.c57 FILE *ibuf; in setfile() local
77 (void)Fclose(ibuf); in setfile()
83 (void)Fclose(ibuf); in setfile()
91 (void)Fclose(ibuf); in setfile()
141 (void)Fclose(ibuf); in setfile()
161 FILE *ibuf; in incfile() local
164 if (ibuf == NULL) in incfile()
168 (void)Fclose(ibuf); in incfile()
172 newsize = fsize(ibuf); in incfile()
175 (void)Fclose(ibuf); in incfile()
[all …]
/openbsd/usr.sbin/radiusd/
H A Dradiusd_bsdauth.c45 struct imsgbuf ibuf; member
84 struct imsgbuf ibuf; in main() local
116 imsg_init(&ibuf, pairsock[0]); in main()
159 imsg_compose(&ibuf, (authok) in main()
214 imsg_compose(&ibuf, (group_ok) in main()
221 imsg_flush(&ibuf); in main()
223 imsg_flush(&ibuf); in main()
225 imsg_clear(&ibuf); in main()
262 imsg_clear(&module_bsdauth.ibuf); in module_bsdauth_main()
349 imsg_flush(&module->ibuf); in module_bsdauth_userpass()
[all …]
H A Dimsg_subr.c36 imsg_sync_read(struct imsgbuf *ibuf, int millisec) in imsg_sync_read() argument
41 fds[0].fd = ibuf->fd; in imsg_sync_read()
49 return imsg_read(ibuf); in imsg_sync_read()
59 imsg_sync_flush(struct imsgbuf *ibuf, int millisec) in imsg_sync_flush() argument
64 if (!ibuf->w.queued) in imsg_sync_flush()
67 fds[0].fd = ibuf->fd; in imsg_sync_flush()
75 return imsg_flush(ibuf); in imsg_sync_flush()
/openbsd/usr.sbin/npppd/npppd/
H A Dcontrol.c140 control_close(c->iev.ibuf.fd, cs); in control_cleanup()
190 imsg_init(&c->iev.ibuf, connfd); in control_accept()
207 if (c->iev.ibuf.fd == fd) in control_connbyfd()
224 msgbuf_clear(&c->iev.ibuf.w); in control_close()
228 close(c->iev.ibuf.fd); in control_close()
259 if (!c->iev.ibuf.w.queued) in control_dispatch_imsg()
260 npppd_ctl_imsg_compose(c->ctx, &c->iev.ibuf); in control_dispatch_imsg()
308 imsg_compose(&c->iev.ibuf, in control_dispatch_imsg()
322 imsg_compose(&c->iev.ibuf, IMSG_CTL_OK, 0, 0, in control_dispatch_imsg()
333 if (!c->iev.ibuf.w.queued) in control_dispatch_imsg()
[all …]
/openbsd/usr.sbin/ripd/
H A Dripd.c240 imsg_init(&iev_rde->ibuf, pipe_parent2rde[0]); in main()
273 msgbuf_clear(&iev_ripe->ibuf.w); in ripd_shutdown()
274 close(iev_ripe->ibuf.fd); in ripd_shutdown()
275 msgbuf_clear(&iev_rde->ibuf.w); in ripd_shutdown()
276 close(iev_rde->ibuf.fd); in ripd_shutdown()
310 struct imsgbuf *ibuf = &iev->ibuf; in main_dispatch_ripe() local
330 if ((n = imsg_get(ibuf, &imsg)) == -1) in main_dispatch_ripe()
389 struct imsgbuf *ibuf = &iev->ibuf; in main_dispatch_rde() local
408 if ((n = imsg_get(ibuf, &imsg)) == -1) in main_dispatch_rde()
525 imsg_flush(&iev->ibuf); in imsg_event_add()
[all …]
/openbsd/usr.sbin/ripctl/
H A Dripctl.c55 struct imsgbuf *ibuf; variable
111 if ((ibuf = malloc(sizeof(struct imsgbuf))) == NULL) in main()
113 imsg_init(ibuf, ctl_sock); in main()
146 imsg_compose(ibuf, IMSG_CTL_KROUTE, 0, 0, -1, in main()
149 imsg_compose(ibuf, IMSG_CTL_KROUTE_ADDR, 0, 0, -1, in main()
155 imsg_compose(ibuf, IMSG_CTL_IFINFO, 0, 0, -1, in main()
178 imsg_compose(ibuf, IMSG_CTL_LOG_VERBOSE, 0, 0, -1, in main()
190 while (ibuf->w.queued) in main()
191 if (msgbuf_write(&ibuf->w) <= 0 && errno != EAGAIN) in main()
201 if ((n = imsg_get(ibuf, &imsg)) == -1) in main()
[all …]
/openbsd/usr.sbin/ldpctl/
H A Dldpctl.c61 struct imsgbuf *ibuf; variable
102 if ((ibuf = malloc(sizeof(struct imsgbuf))) == NULL) in main()
104 imsg_init(ibuf, ctl_sock); in main()
144 imsg_compose(ibuf, IMSG_CTL_KROUTE, 0, 0, -1, in main()
150 imsg_compose(ibuf, IMSG_CTL_KROUTE_ADDR, 0, 0, -1, in main()
157 imsg_compose(ibuf, IMSG_CTL_IFINFO, 0, 0, -1, in main()
197 imsg_compose(ibuf, IMSG_CTL_LOG_VERBOSE, 0, 0, -1, in main()
209 while (ibuf->w.queued) in main()
210 if (msgbuf_write(&ibuf->w) <= 0 && errno != EAGAIN) in main()
220 if ((n = imsg_get(ibuf, &imsg)) == -1) in main()
[all …]
/openbsd/usr.sbin/eigrpd/
H A Deigrpd.c259 if (main_imsg_send_ipc_sockets(&iev_eigrpe->ibuf, &iev_rde->ibuf)) in main()
287 msgbuf_clear(&iev_eigrpe->ibuf.w); in eigrpd_shutdown()
288 close(iev_eigrpe->ibuf.fd); in eigrpd_shutdown()
289 msgbuf_clear(&iev_rde->ibuf.w); in eigrpd_shutdown()
290 close(iev_rde->ibuf.fd); in eigrpd_shutdown()
368 struct imsgbuf *ibuf; in main_dispatch_eigrpe() local
373 ibuf = &iev->ibuf; in main_dispatch_eigrpe()
389 if ((n = imsg_get(ibuf, &imsg)) == -1) in main_dispatch_eigrpe()
444 struct imsgbuf *ibuf; in main_dispatch_rde() local
449 ibuf = &iev->ibuf; in main_dispatch_rde()
[all …]

12345678910>>...13