Home
last modified time | relevance | path

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

/openbsd-src/usr.sbin/unbound/util/
H A Dmini_event.c286 ev->ev_base = base; in event_base_set()
296 if(ev->ev_fd != -1 && ev->ev_fd >= ev->ev_base->capfd) in event_add()
299 ev->ev_base->fds[ev->ev_fd] = ev; in event_add()
301 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->reads); in event_add()
304 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->writes); in event_add()
306 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->content); in event_add()
307 FD_CLR(FD_SET_T ev->ev_fd, &ev->ev_base->ready); in event_add()
308 if(ev->ev_fd > ev->ev_base->maxfd) in event_add()
309 ev->ev_base->maxfd = ev->ev_fd; in event_add()
313 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
/openbsd-src/sbin/unwind/libunbound/util/
H A Dmini_event.c286 ev->ev_base = base; in event_base_set()
296 if(ev->ev_fd != -1 && ev->ev_fd >= ev->ev_base->capfd) in event_add()
299 ev->ev_base->fds[ev->ev_fd] = ev; in event_add()
301 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->reads); in event_add()
304 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->writes); in event_add()
306 FD_SET(FD_SET_T ev->ev_fd, &ev->ev_base->content); in event_add()
307 FD_CLR(FD_SET_T ev->ev_fd, &ev->ev_base->ready); in event_add()
308 if(ev->ev_fd > ev->ev_base->maxfd) in event_add()
309 ev->ev_base->maxfd = ev->ev_fd; in event_add()
313 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
/openbsd-src/usr.sbin/nsd/
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.c4088 struct event_base* ev_base; in tcp_handler_setup_event() local
4093 ev_base = data->event.ev_base; in tcp_handler_setup_event()
4097 if(event_base_set(ev_base, &data->event) != 0) in tcp_handler_setup_event()
4179 struct event_base* ev_base; in handle_tcp_reading() local
4440 ev_base = data->event.ev_base; in handle_tcp_reading()
4445 if(event_base_set(ev_base, &data->event) != 0) in handle_tcp_reading()
4460 struct event_base* ev_base; in handle_tcp_writing() local
4577 ev_base = data->event.ev_base; in handle_tcp_writing()
4582 if(event_base_set(ev_base, &data->event) != 0) in handle_tcp_writing()
4611 ev_base = data->event.ev_base; in handle_tcp_writing()
[all …]
/openbsd-src/lib/libevent/
H A Dsignal.c93 base->sig.ev_signal.ev_base = base; in evsignal_init()
157 struct event_base *base = ev->ev_base; in evsignal_add()
158 struct evsignal_info *sig = &ev->ev_base->sig; in evsignal_add()
208 struct event_base *base = ev->ev_base; in evsignal_del()
222 return (_evsignal_restore_handler(ev->ev_base, EVENT_SIGNAL(ev))); in evsignal_del()
H A Devent.c577 ev->ev_base = current_base; in event_set()
602 ev->ev_base = base; in event_base_set()
618 if (pri < 0 || pri >= ev->ev_base->nactivequeues) in event_priority_set()
647 gettime(ev->ev_base, &now); in event_pending()
660 struct event_base *base = ev->ev_base; in event_add()
746 if (ev->ev_base == NULL) in event_del()
749 base = ev->ev_base; in event_del()
787 event_queue_insert(ev->ev_base, ev, EVLIST_ACTIVE); in event_active()
H A Devbuffer.c267 if (bufev->ev_base != NULL) { in bufferevent_setfd()
268 event_base_set(bufev->ev_base, &bufev->ev_read); in bufferevent_setfd()
269 event_base_set(bufev->ev_base, &bufev->ev_write); in bufferevent_setfd()
427 bufev->ev_base = base; in bufferevent_base_set()
H A Devent.h201 struct event_base *ev_base; member
758 struct event_base *ev_base; member
H A Dkqueue.c312 if (_evsignal_set_handler(ev->ev_base, nsignal, in kq_add()
386 if (_evsignal_restore_handler(ev->ev_base, in kq_del()
/openbsd-src/usr.sbin/vmd/
H A Dproc.c686 imsg_event_add2(struct imsgev *iev, struct event_base *ev_base) in imsg_event_add2()
699 if (ev_base != NULL)
700 event_base_set(ev_base, &iev->ev); in imsg_compose_event()
714 pid_t pid, int fd, void *data, uint16_t datalen, struct event_base *ev_base) in imsg_compose_event2()
721 imsg_event_add2(iev, ev_base); in imsg_composev_event()
681 imsg_event_add2(struct imsgev * iev,struct event_base * ev_base) imsg_event_add2() argument
709 imsg_compose_event2(struct imsgev * iev,uint16_t type,uint32_t peerid,pid_t pid,int fd,void * data,uint16_t datalen,struct event_base * ev_base) imsg_compose_event2() argument
H A Dvirtio.c1545 struct event_base *ev_base) in virtio_dispatch_dev()
1559 imsg_event_add2(iev, ev_base); in virtio_dispatch_dev()
1505 vm_device_pipe(struct virtio_dev * dev,void (* cb)(int,short,void *),struct event_base * ev_base) vm_device_pipe() argument
/openbsd-src/sbin/unwind/
H A Dresolver.c222 struct event_base *ev_base; variable
404 ev_base = event_init(); in resolver()
1277 if ((res->ctx = ub_ctx_create_event(ev_base)) == NULL) { in create_resolver()
1451 if ((ctx = ub_ctx_create_event(ev_base)) == NULL) in setup_unified_caches()