/openbsd/lib/libevent/ |
H A D | evbuffer.c | 234 event_set(&bufev->ev_write, fd, EV_WRITE, bufferevent_writecb, bufev); in bufferevent_new() 243 bufev->enabled = EV_WRITE; in bufferevent_new() 266 event_set(&bufev->ev_write, fd, EV_WRITE, bufferevent_writecb, bufev); in bufferevent_setfd() 316 if (size > 0 && (bufev->enabled & EV_WRITE)) in bufferevent_write() 358 if (event & EV_WRITE) { in bufferevent_enable() 374 if (event & EV_WRITE) { in bufferevent_disable() 395 if (event_pending(&bufev->ev_write, EV_WRITE, NULL)) in bufferevent_settimeout() 412 if (events & EV_WRITE) { in bufferevent_setwatermark()
|
H A D | event.c | 551 } else if (events & (EV_READ|EV_WRITE)) { in event_base_once() 552 events &= EV_READ|EV_WRITE; in event_base_once() 637 flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)); in event_pending() 643 event &= (EV_TIMEOUT|EV_READ|EV_WRITE|EV_SIGNAL); in event_pending() 669 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ", in event_add() 685 if ((ev->ev_events & (EV_READ|EV_WRITE|EV_SIGNAL)) && in event_add() 950 ar.ar_cond == ASR_WANT_READ ? EV_READ : EV_WRITE, in event_asr_dispatch()
|
H A D | event.h | 189 #define EV_WRITE 0x04 macro
|
H A D | kqueue.c | 259 which |= EV_WRITE; in kq_dispatch() 340 if (ev->ev_events & EV_WRITE) { in kq_add() 422 if (ev->ev_events & EV_WRITE) { in kq_del()
|
H A D | poll.c | 116 assert(ev->ev_events & EV_WRITE); in poll_check_ok() 181 res |= EV_WRITE; in poll_dispatch() 207 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_add() 286 if (ev->ev_events & EV_WRITE) { in poll_add() 313 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_del() 327 if (ev->ev_events & EV_WRITE) { in poll_del()
|
H A D | select.c | 113 assert(sop->event_w_by_fd[i]->ev_events & EV_WRITE); in check_selectop() 171 res |= EV_WRITE; in select_dispatch() 282 if (ev->ev_events & EV_WRITE) { in select_add() 314 if (ev->ev_events & EV_WRITE) { in select_del()
|
H A D | signal.c | 160 if (ev->ev_events & (EV_READ|EV_WRITE)) in evsignal_add()
|
/openbsd/regress/lib/libevent/ |
H A D | event_regress.c | 337 EV_WRITE|EV_PERSIST, simple_write_cb, NULL); in test_registerfds() 393 event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev); in test_simplewrite() 416 event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev); in test_multiple() 445 event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev); in test_persistent() 474 event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1); in test_combined() 476 event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2); in test_combined() 1483 else if (event & EV_WRITE) in test_multiple_cb() 1496 event_set(&e2, pair[0], EV_WRITE, test_multiple_cb, NULL); in test_multiple_events_for_same_fd()
|
H A D | test-weof.c | 76 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); in main()
|
/openbsd/regress/sys/kern/kqueue/ |
H A D | kqueue-tun.c | 151 event_set(&tunwev[0], tunfd[0], EV_WRITE, tunnel_write, NULL); in do_tun() 158 event_set(&tunwev[1], tunfd[1], EV_WRITE, tunnel_write, NULL); in do_tun()
|
/openbsd/regress/sys/net/pflow/ |
H A D | gen_traffic.c | 132 event_set(&sender->ev, s, EV_WRITE | EV_PERSIST, gen_traffic_write, in main()
|
/openbsd/sbin/dhcpleased/ |
H A D | control.c | 240 if (event & EV_WRITE) { in control_dispatch_imsg()
|
H A D | dhcpleased.c | 452 if (event & EV_WRITE) { in main_dispatch_frontend() 530 if (event & EV_WRITE) { in main_dispatch_engine() 655 iev->events |= EV_WRITE; in imsg_event_add()
|
H A D | engine.c | 297 if (event & EV_WRITE) { in engine_dispatch_frontend() 411 if (event & EV_WRITE) { in engine_dispatch_main()
|
H A D | frontend.c | 249 if (event & EV_WRITE) { in frontend_dispatch_main() 476 if (event & EV_WRITE) { in frontend_dispatch_engine()
|
/openbsd/sbin/iked/ |
H A D | control.c | 271 if (event & EV_WRITE) { in control_dispatch_imsg()
|
H A D | ocsp.c | 164 event_set(&oc->oc_sock.sock_ev, fd, EV_WRITE, in ocsp_connect() 421 event_set(&sock->sock_ev, sock->sock_fd, EV_WRITE, ocsp_callback, ocsp); in ocsp_receive_fd() 493 (!BIO_should_write(ocsp->ocsp_cbio) || (event & EV_WRITE)) && in ocsp_callback() 502 event_set(&sock->sock_ev, sock->sock_fd, EV_WRITE, in ocsp_callback()
|
H A D | proc.c | 629 if (event & EV_WRITE) { in proc_dispatch() 735 iev->events |= EV_WRITE; in imsg_event_add()
|
/openbsd/sbin/slaacd/ |
H A D | control.c | 241 if (event & EV_WRITE) { in control_dispatch_imsg()
|
H A D | engine.c | 473 if (event & EV_WRITE) { in engine_dispatch_frontend() 640 if (event & EV_WRITE) { in engine_dispatch_main()
|
H A D | frontend.c | 293 if (event & EV_WRITE) { in frontend_dispatch_main() 400 if (event & EV_WRITE) { in frontend_dispatch_engine()
|
H A D | slaacd.c | 398 if (event & EV_WRITE) { in main_dispatch_frontend() 476 if (event & EV_WRITE) { in main_dispatch_engine() 575 iev->events |= EV_WRITE; in imsg_event_add()
|
/openbsd/sbin/unwind/ |
H A D | control.c | 242 if (event & EV_WRITE) { in control_dispatch_imsg()
|
H A D | frontend.c | 319 if (event & EV_WRITE) { in frontend_dispatch_main() 498 if (event & EV_WRITE) { in frontend_dispatch_resolver() 1042 event_set(&pq->resp_ev, pq->fd, EV_WRITE | EV_PERSIST, in resend_dns64_query() 1666 event_set(&pq->resp_ev, s, EV_WRITE | EV_PERSIST, tcp_response, pq); in tcp_accept()
|
/openbsd/sbin/unwind/libunbound/util/ |
H A D | mini_event.c | 213 bits |= EV_WRITE; in handle_select() 298 if( (ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add() 303 if(ev->ev_events&EV_WRITE) { in event_add() 334 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_del()
|