Searched refs:EV_WRITE (Results 1 - 25 of 56) sorted by relevance

123

/freebsd-11-stable/contrib/ntp/sntp/libevent/
H A Dbufferevent_pair.c188 bufferevent_trigger_nolock_(src, EV_WRITE, 0);
198 return (downcast(src)->enabled & EV_WRITE) &&
235 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output))
244 if ((events & EV_WRITE) && partner &&
258 if (events & EV_WRITE) {
322 if ((iotype & EV_WRITE) != 0)
H A Devport.c90 /* combinations of EV_READ and EV_WRITE */
99 #define FDI_HAS_WRITE(fdi) ((fdi)->fdi_what & EV_WRITE)
342 res = EV_READ | EV_WRITE;
347 res |= EV_WRITE;
354 res |= EV_READ|EV_WRITE;
404 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE));
423 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) {
H A Dbufferevent_sock.c113 (bufev->enabled & EV_WRITE) &&
114 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
217 * event==EV_TIMEOUT|EV_WRITE, we can safely ignore the
253 if (!(bufev->enabled & EV_WRITE) ||
297 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0);
309 bufferevent_disable(bufev, EV_WRITE);
342 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
401 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev);
406 if (! be_socket_enable(bev, EV_WRITE)) {
415 event_active(&bev->ev_write, EV_WRITE,
[all...]
H A Dpoll.c206 res |= EV_WRITE;
225 if (!(events & (EV_READ|EV_WRITE)))
264 if (events & EV_WRITE)
286 if (!(events & (EV_READ|EV_WRITE)))
298 if (events & EV_WRITE)
H A Dbufferevent_filter.c212 bufferevent_enable(underlying, EV_READ|EV_WRITE);
260 if (event & EV_WRITE)
275 if (event & EV_WRITE)
340 if (!(bufev->enabled & EV_WRITE) ||
372 (bufev->enabled & EV_WRITE) &&
381 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0);
384 (bufev->enabled & EV_WRITE) &&
517 if (iotype & EV_WRITE) {
H A Ddevpoll.c214 which |= EV_WRITE;
244 if (events & EV_WRITE)
263 if (events & EV_WRITE)
282 if ((res & POLLIN) && (old & EV_WRITE)) {
H A Dwin32select.c229 if (!(events & (EV_READ|EV_WRITE)))
237 if (events & EV_WRITE) {
255 if (events & EV_WRITE)
349 evmap_io_active_(base, s, EV_WRITE);
360 evmap_io_active_(base, s, EV_WRITE);
H A Devmap.c296 old |= EV_WRITE;
304 if (ev->ev_events & EV_WRITE) {
306 res |= EV_WRITE;
374 old |= EV_WRITE;
383 if (ev->ev_events & EV_WRITE) {
385 res |= EV_WRITE;
522 * for which we could have EV_READ or EV_WRITE events. For each such fd, call
593 * pending events, with the appropriate combination of EV_READ, EV_WRITE, and
610 events |= EV_WRITE;
876 if (events & EV_WRITE) {
[all...]
H A Dbufferevent_openssl.c471 if (!(bev->enabled & EV_WRITE))
487 if (bev->enabled & EV_WRITE)
717 bufferevent_trigger_nolock_(bev, EV_WRITE, 0);
868 while ((bev_ssl->bev.bev.enabled & EV_WRITE) &&
886 !(bev_ssl->bev.bev.enabled & EV_WRITE)) {
975 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL);
983 EV_WRITE|EV_PERSIST|EV_FINALIZE,
1087 EV_WRITE|EV_PERSIST|EV_FINALIZE,
1144 if (events & EV_WRITE)
1150 if (events & EV_WRITE)
[all...]
H A Dselect.c199 res |= EV_WRITE;
287 if (events & EV_WRITE)
315 if (events & EV_WRITE)
/freebsd-11-stable/contrib/unbound/util/
H A Dwinsock_event.c351 bits |= EV_WRITE;
358 bits |= EV_WRITE;
371 bits |= EV_WRITE;
377 (eventlist[i]->old_events&EV_WRITE)?"EV_WRITE":"");
389 (eventlist[i]->old_events&EV_WRITE)?"EV_WRITE":"");
403 (bits&EV_WRITE)?" EV_WRITE":"",
416 (eventlist[i]->old_events&EV_WRITE)
[all...]
H A Dwinsock_event.h113 #define EV_WRITE 0x04 macro
253 * Pass if EV_READ or EV_WRITE gave wouldblock.
H A Dmini_event.c213 bits |= EV_WRITE;
298 if( (ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) {
303 if(ev->ev_events&EV_WRITE) {
334 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) {
H A Dmini_event.h87 #define EV_WRITE 0x04 macro
/freebsd-11-stable/contrib/ntp/sntp/libevent/test/
H A Dtest-dumpevents.c110 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL);
112 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL);
143 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1);
H A Dtest-weof.c109 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev);
H A Dregress_ssl.c225 bufferevent_enable(bev, EV_WRITE);
236 bufferevent_disable(bev, EV_WRITE);
371 bufferevent_enable(bev1, EV_READ|EV_WRITE);
372 bufferevent_enable(bev2, EV_READ|EV_WRITE);
410 bufferevent_enable(bev, EV_READ|EV_WRITE);
463 bufferevent_enable(bev, EV_READ|EV_WRITE);
H A Dbench_httpclient.c109 bufferevent_disable(b, EV_READ|EV_WRITE);
172 bufferevent_enable(b, EV_READ|EV_WRITE);
H A Dregress_bufferevent.c167 tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE); local
168 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ);
407 bufferevent_getwatermark(bev2, EV_WRITE, &low, NULL);
422 bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000);
424 bufferevent_getwatermark(bev1, EV_WRITE, &low, &high);
429 int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high);
441 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL));
580 bufferevent_disable(bev,EV_READ|EV_WRITE);
906 bufferevent_setwatermark(bev1, EV_WRITE, 1024*1024+10, 0);
924 bufferevent_enable(bev1, EV_READ|EV_WRITE);
[all...]
/freebsd-11-stable/contrib/pf/libevent/
H A Devbuffer.c242 event_set(&bufev->ev_write, fd, EV_WRITE, bufferevent_writecb, bufev);
251 * Set to EV_WRITE so that using bufferevent_write is going to
255 bufev->enabled = EV_WRITE;
301 if (size > 0 && (bufev->enabled & EV_WRITE))
343 if (event & EV_WRITE) {
359 if (event & EV_WRITE) {
392 if (events & EV_WRITE) {
H A Dpoll.c137 assert(ev->ev_events & EV_WRITE);
193 res |= EV_WRITE;
223 if (!(ev->ev_events & (EV_READ|EV_WRITE)))
302 if (ev->ev_events & EV_WRITE) {
329 if (!(ev->ev_events & (EV_READ|EV_WRITE)))
343 if (ev->ev_events & EV_WRITE) {
H A Dselect.c126 assert(sop->event_w_by_fd[i]->ev_events & EV_WRITE);
194 res |= EV_WRITE;
309 if (ev->ev_events & EV_WRITE) {
341 if (ev->ev_events & EV_WRITE) {
H A Devent.c489 } else if (events & (EV_READ|EV_WRITE)) {
490 events &= EV_READ|EV_WRITE;
569 flags |= (ev->ev_events & (EV_READ|EV_WRITE));
577 event &= (EV_TIMEOUT|EV_READ|EV_WRITE|EV_SIGNAL);
602 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ",
640 if ((ev->ev_events & (EV_READ|EV_WRITE)) &&
H A Dkqueue.c263 which |= EV_WRITE;
328 if (ev->ev_events & EV_WRITE) {
385 if (ev->ev_events & EV_WRITE) {
/freebsd-11-stable/usr.sbin/bluetooth/btpand/
H A Devent.c133 if (ev->flags & EV_WRITE) {
177 (ev->flags & (EV_READ|EV_WRITE)),
199 (ev->flags & (EV_READ|EV_WRITE)),

Completed in 193 milliseconds

123