Home
last modified time | relevance | path

Searched refs:EV_WRITE (Results 1 – 25 of 134) sorted by path

123456

/openbsd/lib/libevent/
H A Devbuffer.c234 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 Devent.c551 } 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 Devent.h189 #define EV_WRITE 0x04 macro
H A Dkqueue.c259 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 Dpoll.c116 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 Dselect.c113 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 Dsignal.c160 if (ev->ev_events & (EV_READ|EV_WRITE)) in evsignal_add()
/openbsd/regress/lib/libevent/
H A Devent_regress.c337 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 Dtest-weof.c76 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); in main()
/openbsd/regress/sys/kern/kqueue/
H A Dkqueue-tun.c151 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 Dgen_traffic.c132 event_set(&sender->ev, s, EV_WRITE | EV_PERSIST, gen_traffic_write, in main()
/openbsd/sbin/dhcpleased/
H A Dcontrol.c240 if (event & EV_WRITE) { in control_dispatch_imsg()
H A Ddhcpleased.c452 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 Dengine.c297 if (event & EV_WRITE) { in engine_dispatch_frontend()
411 if (event & EV_WRITE) { in engine_dispatch_main()
H A Dfrontend.c249 if (event & EV_WRITE) { in frontend_dispatch_main()
476 if (event & EV_WRITE) { in frontend_dispatch_engine()
/openbsd/sbin/iked/
H A Dcontrol.c271 if (event & EV_WRITE) { in control_dispatch_imsg()
H A Docsp.c164 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 Dproc.c629 if (event & EV_WRITE) { in proc_dispatch()
735 iev->events |= EV_WRITE; in imsg_event_add()
/openbsd/sbin/slaacd/
H A Dcontrol.c241 if (event & EV_WRITE) { in control_dispatch_imsg()
H A Dengine.c473 if (event & EV_WRITE) { in engine_dispatch_frontend()
640 if (event & EV_WRITE) { in engine_dispatch_main()
H A Dfrontend.c293 if (event & EV_WRITE) { in frontend_dispatch_main()
400 if (event & EV_WRITE) { in frontend_dispatch_engine()
H A Dslaacd.c398 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 Dcontrol.c242 if (event & EV_WRITE) { in control_dispatch_imsg()
H A Dfrontend.c319 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 Dmini_event.c213 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()

123456