| /openbsd/src/lib/libutil/ |
| D | imsg.c | 39 imsgbuf_init(struct imsgbuf *imsgbuf, int fd) in imsgbuf_init() argument
41 imsgbuf->w = msgbuf_new_reader(IMSG_HEADER_SIZE, imsg_parse_hdr, in imsgbuf_init()
42 imsgbuf); in imsgbuf_init()
43 if (imsgbuf->w == NULL) in imsgbuf_init()
45 imsgbuf->pid = getpid(); in imsgbuf_init()
46 imsgbuf->maxsize = MAX_IMSGSIZE; in imsgbuf_init()
47 imsgbuf->fd = fd; in imsgbuf_init()
48 imsgbuf->flags = 0; in imsgbuf_init()
53 imsgbuf_allow_fdpass(struct imsgbuf *imsgbuf) in imsgbuf_allow_fdpass() argument
55 imsgbuf->flags |= IMSG_ALLOW_FDPASS; in imsgbuf_allow_fdpass()
[all …]
|
| D | imsg.h | 43 struct imsgbuf { struct
125 int imsgbuf_init(struct imsgbuf *, int);
126 void imsgbuf_allow_fdpass(struct imsgbuf *imsgbuf);
127 int imsgbuf_set_maxsize(struct imsgbuf *, uint32_t);
128 int imsgbuf_read(struct imsgbuf *);
129 int imsgbuf_write(struct imsgbuf *);
130 int imsgbuf_flush(struct imsgbuf *);
131 void imsgbuf_clear(struct imsgbuf *);
132 uint32_t imsgbuf_queuelen(struct imsgbuf *);
133 ssize_t imsg_get(struct imsgbuf *, struct imsg *);
[all …]
|
| /openbsd/src/usr.sbin/bgpd/ |
| D | control.c | 147 pfd[i].fd = ctl_conn->imsgbuf.fd; in control_fill_pfds()
149 if (imsgbuf_queuelen(&ctl_conn->imsgbuf) > 0) in control_fill_pfds()
183 if (imsgbuf_init(&ctl_conn->imsgbuf, connfd) == -1 || in control_accept()
184 imsgbuf_set_maxsize(&ctl_conn->imsgbuf, MAX_BGPD_IMSGSIZE) == -1) { in control_accept()
186 imsgbuf_clear(&ctl_conn->imsgbuf); in control_accept()
204 if (c->imsgbuf.fd == fd) in control_connbyfd()
217 if (c->imsgbuf.pid == pid) in control_connbypid()
227 if (c->terminate && c->imsgbuf.pid) in control_close()
228 imsg_ctl_rde_msg(IMSG_CTL_TERMINATE, 0, c->imsgbuf.pid); in control_close()
230 imsgbuf_clear(&c->imsgbuf); in control_close()
[all …]
|
| D | rtr.c | 35 static void rtr_dispatch_imsg_parent(struct imsgbuf *);
36 static void rtr_dispatch_imsg_rde(struct imsgbuf *);
39 static struct imsgbuf *ibuf_main;
40 static struct imsgbuf *ibuf_rde;
220 if ((ibuf_main = malloc(sizeof(struct imsgbuf))) == NULL) in rtr_main()
309 rtr_dispatch_imsg_parent(struct imsgbuf *imsgbuf) in rtr_dispatch_imsg_parent() argument
320 while (imsgbuf) { in rtr_dispatch_imsg_parent()
321 if ((n = imsg_get(imsgbuf, &imsg)) == -1) in rtr_dispatch_imsg_parent()
340 if ((ibuf_rde = malloc(sizeof(struct imsgbuf))) == NULL) in rtr_dispatch_imsg_parent()
460 rtr_dispatch_imsg_rde(struct imsgbuf *imsgbuf) in rtr_dispatch_imsg_rde() argument
[all …]
|
| D | bgpd.c | 48 int send_filterset(struct imsgbuf *, struct filter_set_head *);
51 int dispatch_imsg(struct imsgbuf *, int, struct bgpd_config *);
54 int imsg_send_sockets(struct imsgbuf *, struct imsgbuf *,
55 struct imsgbuf *);
66 struct imsgbuf *ibuf_se;
67 struct imsgbuf *ibuf_rde;
68 struct imsgbuf *ibuf_rtr;
275 if ((ibuf_se = malloc(sizeof(struct imsgbuf))) == NULL || in main()
276 (ibuf_rde = malloc(sizeof(struct imsgbuf))) == NULL || in main()
277 (ibuf_rtr = malloc(sizeof(struct imsgbuf))) == NULL) in main()
[all …]
|
| D | session.h | 118 struct imsgbuf imsgbuf; member
286 int pfkey_send_conf(struct imsgbuf *, uint32_t, struct auth_config *);
|
| /openbsd/src/usr.sbin/bgpctl/ |
| D | bgpctl.c | 51 void send_filterset(struct imsgbuf *, struct filter_set_head *);
63 struct imsgbuf *imsgbuf; variable
177 if ((imsgbuf = malloc(sizeof(struct imsgbuf))) == NULL) in main()
179 if (imsgbuf_init(imsgbuf, fd) == -1 || in main()
180 imsgbuf_set_maxsize(imsgbuf, MAX_BGPD_IMSGSIZE) == -1) in main()
191 imsg_compose(imsgbuf, IMSG_CTL_SHOW_NEIGHBOR, 0, 0, -1, in main()
195 imsg_compose(imsgbuf, IMSG_CTL_SHOW_TERSE, 0, 0, -1, NULL, 0); in main()
204 imsg_compose(imsgbuf, IMSG_CTL_KROUTE, res->rtableid, in main()
207 imsg_compose(imsgbuf, IMSG_CTL_KROUTE_ADDR, in main()
212 imsg_compose(imsgbuf, IMSG_CTL_SHOW_FIB_TABLES, 0, 0, -1, in main()
[all …]
|
| /openbsd/src/usr.sbin/lpd/ |
| D | proc.c | 40 struct imsgbuf imsgbuf; member
205 close(p->imsgbuf.fd); in proc_free()
206 imsgbuf_clear(&p->imsgbuf); in proc_free()
220 if (imsgbuf_init(&p->imsgbuf, -1) == -1) { in proc_new()
224 imsgbuf_allow_fdpass(&p->imsgbuf); in proc_new()
238 p->imsgbuf.fd = sock; in proc_setsock()
247 if (imsgbuf_queuelen(&p->imsgbuf) > 0) in proc_event_add()
255 event_set(&p->ev, p->imsgbuf.fd, events, proc_dispatch, p); in proc_event_add()
285 n = imsgbuf_read(&p->imsgbuf); in proc_dispatch()
301 if (imsgbuf_write(&p->imsgbuf) == -1) { in proc_dispatch()
[all …]
|
| /openbsd/src/usr.sbin/smtpd/ |
| D | mproc.c | 68 if (imsgbuf_init(&p->imsgbuf, fd) == -1) in mproc_init()
71 imsgbuf_allow_fdpass(&p->imsgbuf); in mproc_init()
77 log_debug("debug: clearing p=%s, fd=%d, pid=%d", p->name, p->imsgbuf.fd, p->pid); in mproc_clear()
81 close(p->imsgbuf.fd); in mproc_clear()
82 imsgbuf_clear(&p->imsgbuf); in mproc_clear()
119 if (imsgbuf_queuelen(&p->imsgbuf) > 0) in mproc_event_add()
127 event_set(&p->ev, p->imsgbuf.fd, events, mproc_dispatch, p); in mproc_event_add()
143 n = imsgbuf_read(&p->imsgbuf); in mproc_dispatch()
163 if (imsgbuf_write(&p->imsgbuf) == -1) { in mproc_dispatch()
173 if ((n = imsg_get(&p->imsgbuf, &imsg)) == -1) { in mproc_dispatch()
[all …]
|
| D | smtpd.c | 67 static int imsg_wait(struct imsgbuf *, struct imsg *, int);
705 if (imsg_compose(&p_queue->imsgbuf, IMSG_SETUP_KEY, 0, in main()
709 if (imsgbuf_flush(&p_queue->imsgbuf) == -1) in main()
857 if (imsg_compose(&a->imsgbuf, IMSG_SETUP_PEER, b->proc, b->pid, sp[0], in setup_peers()
860 if (imsgbuf_flush(&a->imsgbuf) == -1) in setup_peers()
863 if (imsg_compose(&b->imsgbuf, IMSG_SETUP_PEER, a->proc, a->pid, sp[1], in setup_peers()
866 if (imsgbuf_flush(&b->imsgbuf) == -1) in setup_peers()
875 if (imsg_compose(&p->imsgbuf, IMSG_SETUP_DONE, 0, 0, -1, NULL, 0) == -1) in setup_done()
877 if (imsgbuf_flush(&p->imsgbuf) == -1) in setup_done()
880 if (imsg_wait(&p->imsgbuf, &imsg, 10000) == -1) in setup_done()
[all …]
|
| D | ca.c | 298 struct imsgbuf *ibuf; in rsae_send_imsg()
323 ibuf = &p_ca->imsgbuf; in rsae_send_imsg()
407 struct imsgbuf *ibuf; in ecdsae_send_enc_imsg()
431 ibuf = &p_ca->imsgbuf; in ecdsae_send_enc_imsg()
|
| /openbsd/src/usr.sbin/radiusd/ |
| D | imsg_subr.h | 6 struct imsgbuf;
10 int imsg_sync_read(struct imsgbuf *, int);
11 int imsg_sync_flush(struct imsgbuf *, int);
|
| D | imsg_subr.c | 36 imsg_sync_read(struct imsgbuf *ibuf, int millisec) in imsg_sync_read()
59 imsg_sync_flush(struct imsgbuf *ibuf, int millisec) in imsg_sync_flush()
|
| D | radiusd_local.h | 77 struct imsgbuf ibuf;
148 struct imsgbuf ibuf;
|
| /openbsd/src/usr.sbin/vmd/ |
| D | atomicio.c | 159 imsgbuf_read_one(struct imsgbuf *imsgbuf, struct imsg *imsg) in imsgbuf_read_one() argument
164 pfd.fd = imsgbuf->fd; in imsgbuf_read_one()
167 switch (imsg_get(imsgbuf, imsg)) { in imsgbuf_read_one()
179 switch (imsgbuf_read(imsgbuf)) { in imsgbuf_read_one()
|
| D | atomicio.h | 56 struct imsgbuf;
58 int imsgbuf_read_one(struct imsgbuf *, struct imsg *);
|
| D | proc.h | 41 struct imsgbuf ibuf;
179 struct imsgbuf *
|
| /openbsd/src/usr.sbin/ractl/ |
| D | ractl.c | 46 struct imsgbuf *ibuf;
101 if ((ibuf = malloc(sizeof(struct imsgbuf))) == NULL) in main()
|
| /openbsd/src/usr.bin/file/ |
| D | file.c | 78 static void send_message(struct imsgbuf *, void *, size_t, int);
79 static int read_message(struct imsgbuf *, struct imsg *, pid_t);
125 struct imsgbuf ibuf; in main()
288 send_message(struct imsgbuf *ibuf, void *msg, size_t msglen, int fd) in send_message()
297 read_message(struct imsgbuf *ibuf, struct imsg *imsg, pid_t from) in read_message()
367 struct imsgbuf ibuf; in child()
|
| /openbsd/src/usr.sbin/eigrpd/ |
| D | eigrpd.c | 48 static int main_imsg_send_ipc_sockets(struct imsgbuf *,
49 struct imsgbuf *);
372 struct imsgbuf *ibuf; in main_dispatch_eigrpe()
450 struct imsgbuf *ibuf; in main_dispatch_rde()
552 main_imsg_send_ipc_sockets(struct imsgbuf *eigrpe_buf, struct imsgbuf *rde_buf) in main_imsg_send_ipc_sockets()
|
| /openbsd/src/usr.sbin/rad/ |
| D | rad.c | 71 static int main_imsg_send_ipc_sockets(struct imsgbuf *, struct imsgbuf *);
379 struct imsgbuf *ibuf; in main_dispatch_frontend()
450 struct imsgbuf *ibuf; in main_dispatch_engine()
539 main_imsg_send_ipc_sockets(struct imsgbuf *frontend_buf, in main_imsg_send_ipc_sockets()
540 struct imsgbuf *engine_buf) in main_imsg_send_ipc_sockets()
|
| /openbsd/src/sbin/unwind/ |
| D | unwind.c | 69 static int main_imsg_send_ipc_sockets(struct imsgbuf *, struct imsgbuf *);
397 struct imsgbuf *ibuf; in main_dispatch_frontend()
462 struct imsgbuf *ibuf; in main_dispatch_resolver()
556 main_imsg_send_ipc_sockets(struct imsgbuf *frontend_buf, in main_imsg_send_ipc_sockets()
557 struct imsgbuf *resolver_buf) in main_imsg_send_ipc_sockets()
|
| /openbsd/src/sbin/slaacd/ |
| D | slaacd.c | 81 static int main_imsg_send_ipc_sockets(struct imsgbuf *, struct imsgbuf *);
384 struct imsgbuf *ibuf; in main_dispatch_frontend()
467 struct imsgbuf *ibuf; in main_dispatch_engine()
609 main_imsg_send_ipc_sockets(struct imsgbuf *frontend_buf, in main_imsg_send_ipc_sockets()
610 struct imsgbuf *engine_buf) in main_imsg_send_ipc_sockets()
|
| /openbsd/src/usr.sbin/ldapd/ |
| D | imsgev.h | 28 struct imsgbuf ibuf;
|
| /openbsd/src/usr.sbin/ntpd/ |
| D | ntp_dns.c | 39 static struct imsgbuf *ibuf_dns;
95 if ((ibuf_dns = malloc(sizeof(struct imsgbuf))) == NULL) in ntp_dns()
|