/openbsd/lib/libutil/ |
H A D | imsg.h | 31 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 D | imsg-buffer.c | 40 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 D | scheduler_proc.c | 25 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 D | queue_proc.c | 26 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 D | vis_test.c | 14 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 D | imsg_util.c | 39 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 D | iked.h | 993 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 D | dh.h | 52 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 D | ospfctl.c | 46 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 D | imsgev.c | 40 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 D | ikectl.c | 70 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 D | ractl.c | 46 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 D | convert.c | 64 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 D | io.c | 37 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 D | dvmrpd.c | 238 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 D | dvmrpe.c | 146 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 D | quit.c | 218 (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 D | lex.c | 57 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 D | radiusd_bsdauth.c | 45 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 D | imsg_subr.c | 36 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 D | control.c | 140 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 D | ripd.c | 240 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 D | ripctl.c | 55 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 D | ldpctl.c | 61 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 D | eigrpd.c | 259 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 …]
|