| /openbsd/usr.sbin/ldapd/ |
| H A D | imsgev.c | 43 iev->data = data; in imsgev_init()
49 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev); in imsgev_init()
61 imsgev_add(iev); in imsgev_compose()
70 imsgev_add(iev); in imsgev_close()
88 if (iev->ibuf.w.queued || iev->terminate) in imsgev_add()
97 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev); in imsgev_add()
109 iev->events = 0; in imsgev_dispatch()
115 iev->needfd(iev); in imsgev_dispatch()
155 iev->callback(iev, IMSGEV_IMSG, &imsg); in imsgev_dispatch()
159 if (iev->terminate && iev->ibuf.w.queued == 0) { in imsgev_dispatch()
[all …]
|
| H A D | control.c | 167 if (c->iev.ibuf.fd == fd) in control_connbyfd()
186 imsgev_clear(&c->iev); in control_close()
198 send_stats(struct imsgev *iev) in send_stats() argument
204 imsgev_compose(iev, IMSG_CTL_STATS, 0, iev->ibuf.pid, -1, in send_stats()
218 imsgev_compose(iev, IMSG_CTL_NSSTATS, 0, iev->ibuf.pid, -1, in send_stats()
222 imsgev_compose(iev, IMSG_CTL_END, 0, iev->ibuf.pid, -1, NULL, 0); in send_stats()
234 cs = iev->data; in control_imsgev()
235 fd = iev->ibuf.fd; in control_imsgev()
250 if (send_stats(iev) == -1) { in control_imsgev()
272 control_needfd(struct imsgev *iev) in control_needfd() argument
[all …]
|
| /openbsd/usr.sbin/npppd/npppd/ |
| H A D | control.c | 192 c->iev.events = EV_READ; in control_accept()
193 c->iev.data = cs; in control_accept()
194 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
195 c->iev.handler, cs); in control_accept()
207 if (c->iev.ibuf.fd == fd) in control_connbyfd()
227 event_del(&c->iev.ev); in control_close()
228 close(c->iev.ibuf.fd); in control_close()
259 if (!c->iev.ibuf.w.queued) in control_dispatch_imsg()
261 imsg_event_add(&c->iev); in control_dispatch_imsg()
333 if (!c->iev.ibuf.w.queued) in control_dispatch_imsg()
[all …]
|
| /openbsd/sbin/dhcpleased/ |
| H A D | control.c | 51 struct imsgev iev; member
161 c->iev.events = EV_READ; in control_accept()
162 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
163 c->iev.handler, &c->iev); in control_accept()
164 event_add(&c->iev.ev, NULL); in control_accept()
175 if (c->iev.ibuf.fd == fd) in control_connbyfd()
188 if (c->iev.ibuf.pid == pid) in control_connbypid()
205 msgbuf_clear(&c->iev.ibuf.w); in control_close()
208 event_del(&c->iev.ev); in control_close()
209 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/ldpd/ |
| H A D | control.c | 136 imsg_init(&c->iev.ibuf, connfd); in control_accept()
138 c->iev.events = EV_READ; in control_accept()
139 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
140 c->iev.handler, &c->iev); in control_accept()
141 event_add(&c->iev.ev, NULL); in control_accept()
152 if (c->iev.ibuf.fd == fd) in control_connbyfd()
165 if (c->iev.ibuf.pid == pid) in control_connbypid()
182 msgbuf_clear(&c->iev.ibuf.w); in control_close()
185 event_del(&c->iev.ev); in control_close()
186 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/sbin/dhcp6leased/ |
| H A D | control.c | 51 struct imsgev iev;
159 imsg_init(&c->iev.ibuf, connfd); in control_accept()
160 c->iev.handler = control_dispatch_imsg; in control_accept()
161 c->iev.events = EV_READ; in control_accept()
162 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
163 c->iev.handler, &c->iev); in control_accept()
164 event_add(&c->iev in control_accept()
50 struct imsgev iev; global() member
[all...] |
| /openbsd/usr.sbin/relayd/ |
| H A D | control.c | 167 imsg_init(&c->iev.ibuf, connfd); in control_accept()
168 c->iev.handler = control_dispatch_imsg; in control_accept()
169 c->iev.events = EV_READ; in control_accept()
171 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
172 c->iev.handler, cs); in control_accept()
173 event_add(&c->iev.ev, NULL); in control_accept()
184 if (c->iev.ibuf.fd == fd) in control_connbyfd()
201 msgbuf_clear(&c->iev.ibuf.w); in control_close()
204 event_del(&c->iev.ev); in control_close()
205 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| H A D | proc.c | 144 struct imsgev *iev; in proc_connect() local
159 event_set(&iev->ev, iev->ibuf.fd, iev->events, in proc_connect()
160 iev->handler, iev->data); in proc_connect()
246 struct imsgev *iev; in proc_accept() local
268 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in proc_accept()
601 ibuf = &iev->ibuf; in proc_dispatch()
670 imsg_event_add(iev); in proc_dispatch()
695 event_del(&iev->ev); in imsg_event_add()
696 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in imsg_event_add()
709 imsg_event_add(iev); in imsg_compose_event()
[all …]
|
| /openbsd/sbin/slaacd/ |
| H A D | control.c | 52 struct imsgev iev; member
162 c->iev.events = EV_READ; in control_accept()
163 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
164 c->iev.handler, &c->iev); in control_accept()
165 event_add(&c->iev.ev, NULL); in control_accept()
176 if (c->iev.ibuf.fd == fd) in control_connbyfd()
189 if (c->iev.ibuf.pid == pid) in control_connbypid()
206 msgbuf_clear(&c->iev.ibuf.w); in control_close()
209 event_del(&c->iev.ev); in control_close()
210 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/ripd/ |
| H A D | control.c | 146 imsg_init(&c->iev.ibuf, connfd); in control_accept()
148 c->iev.events = EV_READ; in control_accept()
149 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
150 c->iev.handler, &c->iev); in control_accept()
151 event_add(&c->iev.ev, NULL); in control_accept()
162 if (c->iev.ibuf.fd == fd) in control_connbyfd()
175 if (c->iev.ibuf.pid == pid) in control_connbypid()
192 msgbuf_clear(&c->iev.ibuf.w); in control_close()
195 event_del(&c->iev.ev); in control_close()
196 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| H A D | ripd.c | 377 imsg_event_add(iev); in main_dispatch_ripe()
380 event_del(&iev->ev); in main_dispatch_ripe()
433 imsg_event_add(iev); in main_dispatch_rde()
436 event_del(&iev->ev); in main_dispatch_rde()
525 imsg_flush(&iev->ibuf); in imsg_event_add()
529 iev->events = EV_READ; in imsg_event_add()
530 if (iev->ibuf.w.queued) in imsg_event_add()
531 iev->events |= EV_WRITE; in imsg_event_add()
533 event_del(&iev->ev); in imsg_event_add()
534 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev); in imsg_event_add()
[all …]
|
| /openbsd/usr.sbin/eigrpd/ |
| H A D | control.c | 147 imsg_init(&c->iev.ibuf, connfd); in control_accept()
149 c->iev.events = EV_READ; in control_accept()
150 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
151 c->iev.handler, &c->iev); in control_accept()
152 event_add(&c->iev.ev, NULL); in control_accept()
163 if (c->iev.ibuf.fd == fd) in control_connbyfd()
176 if (c->iev.ibuf.pid == pid) in control_connbypid()
193 msgbuf_clear(&c->iev.ibuf.w); in control_close()
196 event_del(&c->iev.ev); in control_close()
197 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/dvmrpd/ |
| H A D | control.c | 155 imsg_init(&c->iev.ibuf, connfd); in control_accept()
157 c->iev.events = EV_READ; in control_accept()
158 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
159 c->iev.handler, &c->iev); in control_accept()
160 event_add(&c->iev.ev, NULL); in control_accept()
171 if (c->iev.ibuf.fd == fd) in control_connbyfd()
184 if (c->iev.ibuf.pid == pid) in control_connbypid()
201 msgbuf_clear(&c->iev.ibuf.w); in control_close()
204 event_del(&c->iev.ev); in control_close()
205 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| H A D | dvmrpd.c | 313 struct imsgev *iev = bula; in main_dispatch_dvmrpe() local
363 imsg_event_add(iev); in main_dispatch_dvmrpe()
366 event_del(&iev->ev); in main_dispatch_dvmrpe()
426 imsg_event_add(iev); in main_dispatch_rde()
429 event_del(&iev->ev); in main_dispatch_rde()
449 iev->events = EV_READ; in imsg_event_add()
450 if (iev->ibuf.w.queued) in imsg_event_add()
451 iev->events |= EV_WRITE; in imsg_event_add()
453 event_del(&iev->ev); in imsg_event_add()
454 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev); in imsg_event_add()
[all …]
|
| /openbsd/sbin/unwind/ |
| H A D | control.c | 50 struct imsgev iev; member
161 c->iev.events = EV_READ; in control_accept()
162 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, c->iev.handler, in control_accept()
163 &c->iev); in control_accept()
164 event_add(&c->iev.ev, NULL); in control_accept()
175 if (c->iev.ibuf.fd == fd) in control_connbyfd()
188 if (c->iev.ibuf.pid == pid) in control_connbypid()
205 msgbuf_clear(&c->iev.ibuf.w); in control_close()
208 event_del(&c->iev.ev); in control_close()
209 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/rad/ |
| H A D | control.c | 50 struct imsgev iev; member
160 c->iev.events = EV_READ; in control_accept()
161 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
162 c->iev.handler, &c->iev); in control_accept()
163 event_add(&c->iev.ev, NULL); in control_accept()
174 if (c->iev.ibuf.fd == fd) in control_connbyfd()
187 if (c->iev.ibuf.pid == pid) in control_connbypid()
204 msgbuf_clear(&c->iev.ibuf.w); in control_close()
207 event_del(&c->iev.ev); in control_close()
208 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/ospfd/ |
| H A D | control.c | 179 imsg_init(&c->iev.ibuf, connfd); in control_accept()
181 c->iev.events = EV_READ; in control_accept()
182 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
183 c->iev.handler, &c->iev); in control_accept()
184 event_add(&c->iev.ev, NULL); in control_accept()
195 if (c->iev.ibuf.fd == fd) in control_connbyfd()
208 if (c->iev.ibuf.pid == pid) in control_connbypid()
225 msgbuf_clear(&c->iev.ibuf.w); in control_close()
228 event_del(&c->iev.ev); in control_close()
229 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/ospf6d/ |
| H A D | control.c | 179 imsg_init(&c->iev.ibuf, connfd); in control_accept()
181 c->iev.events = EV_READ; in control_accept()
182 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
183 c->iev.handler, &c->iev); in control_accept()
184 event_add(&c->iev.ev, NULL); in control_accept()
195 if (c->iev.ibuf.fd == fd) in control_connbyfd()
208 if (c->iev.ibuf.pid == pid) in control_connbypid()
225 msgbuf_clear(&c->iev.ibuf.w); in control_close()
228 event_del(&c->iev.ev); in control_close()
229 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| /openbsd/usr.sbin/vmd/ |
| H A D | proc.c | 144 struct imsgev *iev; in proc_connect() local
159 event_set(&iev->ev, iev->ibuf.fd, iev->events, in proc_connect()
160 iev->handler, iev->data); in proc_connect()
246 struct imsgev *iev; in proc_accept() local
268 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in proc_accept()
593 ibuf = &iev->ibuf; in proc_dispatch()
600 event_del(&iev->ev); in proc_dispatch()
662 imsg_event_add(iev); in proc_dispatch()
692 event_del(&iev->ev); in imsg_event_add2()
693 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in imsg_event_add2()
[all …]
|
| H A D | control.c | 315 c->iev.events = EV_READ; in control_accept()
316 c->iev.data = cs; in control_accept()
317 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
318 c->iev.handler, c->iev.data); in control_accept()
319 event_add(&c->iev.ev, NULL); in control_accept()
330 if (c->iev.ibuf.fd == fd) in control_connbyfd()
348 msgbuf_clear(&c->iev.ibuf.w); in control_close()
359 event_del(&c->iev.ev); in control_close()
360 close(c->iev.ibuf.fd); in control_close()
524 imsg_event_add(&c->iev); in control_dispatch_imsg()
[all …]
|
| /openbsd/usr.sbin/snmpd/ |
| H A D | proc.c | 144 struct imsgev *iev; in proc_connect() local
159 event_set(&iev->ev, iev->ibuf.fd, iev->events, in proc_connect()
160 iev->handler, iev->data); in proc_connect()
246 struct imsgev *iev; in proc_accept() local
268 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in proc_accept()
576 ibuf = &iev->ibuf; in proc_dispatch()
645 imsg_event_add(iev); in proc_dispatch()
670 event_del(&iev->ev); in imsg_event_add()
671 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in imsg_event_add()
684 imsg_event_add(iev); in imsg_compose_event()
[all …]
|
| /openbsd/sbin/iked/ |
| H A D | control.c | 194 imsg_init(&c->iev.ibuf, connfd); in control_accept()
196 c->iev.events = EV_READ; in control_accept()
197 c->iev.data = cs; in control_accept()
198 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
199 c->iev.handler, c->iev.data); in control_accept()
200 event_add(&c->iev.ev, NULL); in control_accept()
217 if (c->iev.ibuf.fd == fd) in control_connbyfd()
234 msgbuf_clear(&c->iev.ibuf.w); in control_close()
237 event_del(&c->iev.ev); in control_close()
238 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| H A D | proc.c | 146 struct imsgev *iev; in proc_connect() local
166 event_set(&iev->ev, iev->ibuf.fd, iev->events, in proc_connect()
167 iev->handler, iev->data); in proc_connect()
274 struct imsgev *iev; in proc_accept() local
296 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in proc_accept()
616 ibuf = &iev->ibuf; in proc_dispatch()
712 imsg_event_add(iev); in proc_dispatch()
737 event_del(&iev->ev); in imsg_event_add()
738 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in imsg_event_add()
751 imsg_event_add(iev); in imsg_compose_event()
[all …]
|
| /openbsd/usr.sbin/httpd/ |
| H A D | control.c | 167 imsg_init(&c->iev.ibuf, connfd); in control_accept()
168 c->iev.handler = control_dispatch_imsg; in control_accept()
169 c->iev.events = EV_READ; in control_accept()
171 event_set(&c->iev.ev, c->iev.ibuf.fd, c->iev.events, in control_accept()
172 c->iev.handler, cs); in control_accept()
173 event_add(&c->iev.ev, NULL); in control_accept()
184 if (c->iev.ibuf.fd == fd) in control_connbyfd()
201 msgbuf_clear(&c->iev.ibuf.w); in control_close()
204 event_del(&c->iev.ev); in control_close()
205 close(c->iev.ibuf.fd); in control_close()
[all …]
|
| H A D | proc.c | 144 struct imsgev *iev; in proc_connect() local
159 event_set(&iev->ev, iev->ibuf.fd, iev->events, in proc_connect()
160 iev->handler, iev->data); in proc_connect()
246 struct imsgev *iev; in proc_accept() local
268 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in proc_accept()
600 ibuf = &iev->ibuf; in proc_dispatch()
669 imsg_event_add(iev); in proc_dispatch()
694 event_del(&iev->ev); in imsg_event_add()
695 event_set(&iev->ev, iev->ibuf.fd, iev->events, iev->handler, iev->data); in imsg_event_add()
708 imsg_event_add(iev); in imsg_compose_event()
[all …]
|