Home
last modified time | relevance | path

Searched refs:ev_base (Results 1 – 18 of 18) sorted by relevance

/netbsd-src/external/bsd/unbound/dist/util/
H A Dmini_event.c289 ev->ev_base = base; in event_base_set()
299 if(ev->ev_fd != -1 && ev->ev_fd >= ev->ev_base->capfd) in event_add()
302 ev->ev_base->fds[ev->ev_fd] = ev; in event_add()
304 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->reads); in event_add()
307 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->writes); in event_add()
309 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->content); in event_add()
310 FD_CLR(FD_SET_T ev->ev_fd, &ev->ev_base->ready); in event_add()
311 if(ev->ev_fd > ev->ev_base->maxfd) in event_add()
312 ev->ev_base->maxfd = ev->ev_fd; in event_add()
316 struct timeval *now = ev->ev_base->time_tv; in event_add()
[all …]
H A Dwinsock_event.c484 ev->ev_base = base; in event_base_set()
501 log_assert(ev->ev_fd==-1 || find_fd(ev->ev_base, ev->ev_fd) == -1); in event_add()
511 if(ev->ev_base->max == ev->ev_base->cap) in event_add()
513 ev->idx = ev->ev_base->max++; in event_add()
514 ev->ev_base->items[ev->idx] = ev; in event_add()
552 ev->ev_base->tcp_reinvigorated = 1; in event_add()
558 struct timeval *now = ev->ev_base->time_tv; in event_add()
566 (void)rbtree_insert(ev->ev_base->times, &ev->node); in event_add()
585 (void)rbtree_delete(ev->ev_base->times, &ev->node); in event_del()
587 log_assert(ev->ev_base->max > 0); in event_del()
[all …]
H A Dmini_event.h142 struct event_base *ev_base; member
H A Dwinsock_event.h177 struct event_base *ev_base; member
/netbsd-src/external/bsd/nsd/dist/
H A Dmini_event.c338 ev->ev_base = base; in event_base_set()
349 if(ev->ev_fd != -1 && ev->ev_fd >= ev->ev_base->capfd) in event_add()
352 ev->ev_base->fds[ev->ev_fd] = ev; in event_add()
354 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->reads); in event_add()
357 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->writes); in event_add()
359 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->content); in event_add()
360 FD_CLR(FD_SET_T ev->ev_fd, &ev->ev_base->ready); in event_add()
361 if(ev->ev_fd > ev->ev_base->maxfd) in event_add()
362 ev->ev_base->maxfd = ev->ev_fd; in event_add()
366 struct timeval* now = ev->ev_base->time_tv; in event_add()
[all …]
H A Dmini_event.h129 struct event_base *ev_base; member
H A Dserver.c3941 struct event_base* ev_base; in tcp_handler_setup_event() local
3946 ev_base = data->event.ev_base; in tcp_handler_setup_event()
3950 if(event_base_set(ev_base, &data->event) != 0) in tcp_handler_setup_event()
4032 struct event_base* ev_base; in handle_tcp_reading() local
4293 ev_base = data->event.ev_base; in handle_tcp_reading()
4298 if(event_base_set(ev_base, &data->event) != 0) in handle_tcp_reading()
4313 struct event_base* ev_base; in handle_tcp_writing() local
4430 ev_base = data->event.ev_base; in handle_tcp_writing()
4435 if(event_base_set(ev_base, &data->event) != 0) in handle_tcp_writing()
4464 ev_base = data->event.ev_base; in handle_tcp_writing()
[all …]
/netbsd-src/external/bsd/libevent/dist/
H A Dbufferevent_async.c172 event_base_del_virtual_(bev->ev_base); in bev_async_del_write()
183 event_base_del_virtual_(bev->ev_base); in bev_async_del_read()
194 event_base_add_virtual_(bev->ev_base); in bev_async_add_write()
205 event_base_add_virtual_(bev->ev_base); in bev_async_add_read()
458 event_base_del_virtual_(bev->ev_base); in connect_complete()
614 event_base_get_iocp_(bev->ev_base) && in bufferevent_async_can_connect_()
654 event_base_add_virtual_(bev->ev_base); in bufferevent_async_connect_()
661 event_base_del_virtual_(bev->ev_base); in bufferevent_async_connect_()
681 if (!(iocp = event_base_get_iocp_(bev->ev_base))) in be_async_ctrl()
H A Devent.c2038 EVBASE_ACQUIRE_LOCK(eonce->ev.ev_base, th_base_lock); in event_once_cb()
2040 EVBASE_RELEASE_LOCK(eonce->ev.ev_base, th_base_lock); in event_once_cb()
2129 ev->ev_base = base; in event_assign()
2177 ev->ev_base = base; in event_base_set()
2269 struct event_base *base = ev->ev_base; in event_finalize_impl_()
2367 if (pri < 0 || pri >= ev->ev_base->nactivequeues) in event_priority_set()
2384 if (EVUTIL_FAILURE_CHECK(ev->ev_base == NULL)) { in event_pending()
2389 EVBASE_ACQUIRE_LOCK(ev->ev_base, th_base_lock); in event_pending()
2406 evutil_timeradd(&ev->ev_base->tv_clock_diff, &tmp, tv); in event_pending()
2409 EVBASE_RELEASE_LOCK(ev->ev_base, th_base_lock); in event_pending()
[all …]
H A Dbufferevent_sock.c369 event_assign(&bufev->ev_read, bufev->ev_base, fd, in bufferevent_socket_new()
371 event_assign(&bufev->ev_write, bufev->ev_base, fd, in bufferevent_socket_new()
426 event_assign(&bev->ev_write, bev->ev_base, fd, in bufferevent_socket_connect()
635 event_assign(&bufev->ev_read, bufev->ev_base, fd, in be_socket_setfd()
637 event_assign(&bufev->ev_write, bufev->ev_base, fd, in be_socket_setfd()
682 bufev->ev_base = base; in bufferevent_base_set()
H A Dbufferevent.c238 (bevp)->bev.ev_base, \
331 bufev->ev_base = base; in bufferevent_init_common_()
442 return bufev->ev_base; in bufferevent_get_base()
451 return event_base_get_npriorities(bufev->ev_base) / 2; in bufferevent_get_priority()
741 event_callback_finalize_many_(bufev->ev_base, n_cbs, cbs, in bufferevent_decref_and_unlock_()
967 event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
969 event_assign(&bev->ev_write, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
H A Dbufferevent_ratelim.c121 event_base_gettimeofday_cached(bev->bev.ev_base, &now); in bufferevent_update_buckets()
409 event_base_gettimeofday_cached(bev->bev.ev_base, &now); in bev_refill_callback_()
588 event_base_gettimeofday_cached(bev->ev_base, &now); in bufferevent_set_rate_limit()
613 event_assign(&rlim->refill_bucket_event, bev->ev_base, in bufferevent_set_rate_limit()
751 event_assign(&rlim->refill_bucket_event, bev->ev_base, in bufferevent_add_to_rate_limit_group()
H A Dbufferevent_openssl.c1005 event_assign(&bev->ev_read, bev->ev_base, fd, in set_open_callbacks()
1008 event_assign(&bev->ev_write, bev->ev_base, fd, in set_open_callbacks()
1110 event_assign(&bev->ev_read, bev->ev_base, fd, in set_handshake_callbacks()
1113 event_assign(&bev->ev_write, bev->ev_base, fd, in set_handshake_callbacks()
H A Dbufferevent_filter.c195 if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base, in bufferevent_filter_new()
/netbsd-src/external/bsd/libevent/dist/include/event2/
H A Dbufferevent_struct.h73 struct event_base *ev_base; member
H A Devent_struct.h134 struct event_base *ev_base; member
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/include/event2/
H A Dbufferevent_struct.h74 struct event_base *ev_base; member
H A Devent_struct.h135 struct event_base *ev_base; member