Home
last modified time | relevance | path

Searched refs:events (Results 1 – 25 of 38) sorted by relevance

12

/libevent-2.1.12/
H A Depoll.c272 int op, events = 0; in epoll_apply_one_change() local
277 events = epoll_op_table[idx].events; in epoll_apply_one_change()
279 if (!events) { in epoll_apply_one_change()
285 events |= EPOLLET; in epoll_apply_one_change()
289 epev.events = events; in epoll_apply_one_change()
308 (int)epev.events, in epoll_apply_one_change()
329 (int)epev.events, in epoll_apply_one_change()
341 (int)epev.events, in epoll_apply_one_change()
420 struct epoll_event *events = epollop->events; in epoll_dispatch() local
482 int what = events[i].events; in epoll_dispatch()
[all …]
H A Ddevpoll.c57 struct pollfd *events; member
114 pfd->events = events; in devpoll_queue()
156 mm_free(devpollop->events); in devpoll_init()
171 struct pollfd *events = devpollop->events; in devpoll_dispatch() local
204 int what = events[i].revents; in devpoll_dispatch()
242 if (events & EV_READ) in devpoll_add()
244 if (events & EV_WRITE) in devpoll_add()
261 if (events & EV_READ) in devpoll_del()
263 if (events & EV_WRITE) in devpoll_del()
300 if (devpollop->events) in devpoll_dealloc()
[all …]
H A Dpoll.c271 pfd->events = 0; in poll_add()
277 if (events & EV_WRITE) in poll_add()
278 pfd->events |= POLLOUT; in poll_add()
279 if (events & EV_READ) in poll_add()
280 pfd->events |= POLLIN; in poll_add()
281 if (events & EV_CLOSED) in poll_add()
311 if (events & EV_READ) in poll_del()
312 pfd->events &= ~POLLIN; in poll_del()
313 if (events & EV_WRITE) in poll_del()
315 if (events & EV_CLOSED) in poll_del()
[all …]
H A Dkqueue.c81 struct kevent *events; member
145 if (kqueueop->events == NULL) in kq_init()
258 kqop->events = newresult; in kq_grow_events()
270 struct kevent *events = kqop->events; in kq_dispatch() local
310 events = kqop->events; in kq_dispatch()
337 if (events[i].flags & EV_ERROR) { in kq_dispatch()
338 switch (events[i].data) { in kq_dispatch()
384 if (events[i].udata) { in kq_dispatch()
397 errno = events[i].data; in kq_dispatch()
436 if (kqop->events) in kqop_free()
[all …]
H A Devmap.c60 struct event_dlist events; member
69 struct event_dlist events; member
613 short events = 0; local
619 events |= EV_READ;
621 events |= EV_WRITE;
623 events |= EV_CLOSED;
626 if (events &&
629 events |= EV_ET;
886 if (events & EV_WRITE)
888 if (events & EV_CLOSED)
[all …]
H A Dselect.c89 static int select_add(struct event_base *, int, short old, short events, void*);
90 static int select_del(struct event_base *, int, short old, short events, void*);
252 select_add(struct event_base *base, int fd, short old, short events, void *p) in select_add() argument
257 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in select_add()
285 if (events & EV_READ) in select_add()
287 if (events & EV_WRITE) in select_add()
299 select_del(struct event_base *base, int fd, short old, short events, void *p) in select_del() argument
304 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in select_del()
312 if (events & EV_READ) in select_del()
315 if (events & EV_WRITE) in select_del()
H A Dmake_epoll_table.py8 events = []
10 events.append("EPOLLIN")
12 events.append("EPOLLOUT")
14 events.append("EPOLLRDHUP")
20 return "|".join(events), op
H A Dwin32select.c84 static int win32_add(struct event_base *, evutil_socket_t, short old, short events, void *idx_);
85 static int win32_del(struct event_base *, evutil_socket_t, short old, short events, void *idx_);
221 short old, short events, void *idx_) in win32_add() argument
226 if ((events & EV_SIGNAL) && win32op->signals_are_broken) in win32_add()
229 if (!(events & (EV_READ|EV_WRITE))) in win32_add()
233 if (events & EV_READ) { in win32_add()
237 if (events & EV_WRITE) { in win32_add()
245 win32_del(struct event_base *base, evutil_socket_t fd, short old, short events, in win32_del() argument
253 if (events & EV_READ) in win32_del()
255 if (events & EV_WRITE) in win32_del()
H A Dbufferevent_pair.c225 be_pair_enable(struct bufferevent *bufev, short events) in be_pair_enable() argument
232 if (events & EV_READ) { in be_pair_enable()
235 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
239 if ((events & EV_READ) && partner && in be_pair_enable()
244 if ((events & EV_WRITE) && partner && in be_pair_enable()
253 be_pair_disable(struct bufferevent *bev, short events) in be_pair_disable() argument
255 if (events & EV_READ) { in be_pair_disable()
258 if (events & EV_WRITE) { in be_pair_disable()
H A Depoll_sub.c59 epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout) in epoll_wait() argument
62 return (syscall(__NR_epoll_pwait, epfd, events, maxevents, timeout, NULL, 0)); in epoll_wait()
64 return (syscall(__NR_epoll_wait, epfd, events, maxevents, timeout)); in epoll_wait()
H A Devport.c118 static int evport_add(struct event_base *, int fd, short old, short events, void *);
119 static int evport_del(struct event_base *, int fd, short old, short events, void *);
379 evport_add(struct event_base *base, int fd, short old, short events, void *p) in evport_add() argument
386 fdi->fdi_what |= events; in evport_add()
396 evport_del(struct event_base *base, int fd, short old, short events, void *p) in evport_del() argument
404 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
H A Devent.c965 short events, void *fdinfo) in nil_backend_del() argument
1471 ev = TAILQ_FIRST(&ctl->events); in common_timeout_callback()
1539 TAILQ_INIT(&new_ctl->events); in event_base_init_common_timeout()
2120 if (!(events & EV_SIGNAL)) in event_assign()
2129 ev->ev_events = events; in event_assign()
2135 if (events & EV_SIGNAL) { in event_assign()
2143 if (events & EV_PERSIST) { in event_assign()
3281 TAILQ_REMOVE(&ctl->events, ev, in event_queue_remove_timeout()
3303 TAILQ_REMOVE(&ctl->events, ev, in event_queue_reinsert_timeout()
3310 TAILQ_REMOVE(&ctl->events, ev, in event_queue_reinsert_timeout()
[all …]
H A Dchangelist-internal.h96 int event_changelist_add_(struct event_base *base, evutil_socket_t fd, short old, short events,
99 int event_changelist_del_(struct event_base *base, evutil_socket_t fd, short old, short events,
H A Dbufferevent_openssl.c1157 be_openssl_enable(struct bufferevent *bev, short events) in be_openssl_enable() argument
1162 if (events & EV_READ) in be_openssl_enable()
1164 if (events & EV_WRITE) in be_openssl_enable()
1168 if (events & EV_READ) in be_openssl_enable()
1170 if (events & EV_WRITE) in be_openssl_enable()
1173 if (events & EV_READ) in be_openssl_enable()
1175 if (events & EV_WRITE) in be_openssl_enable()
1186 if (events & EV_READ) in be_openssl_disable()
1188 if (events & EV_WRITE) in be_openssl_disable()
1192 if (events & EV_READ) in be_openssl_disable()
[all …]
H A Dwhatsnew-2.1.txt70 1.2. New functions for events and the event loop
75 checking for new high-priority events. You can now use the
77 loop checks for new events either every N microseconds, every M
89 event_base_loop() will exit as soon as no events are pending.)
97 like events, bufferevents, and so on; and it doesn't free anything
138 active event callbacks, and re-scan for new events right away.
153 number of events active or pending on an event_base. To find the
232 program where events are only used from one thread.
248 1.3.3. Safely finalizing events
260 callback must not add events, activate events, or attempt to
[all …]
H A Devent-internal.h103 int (*add)(struct event_base *, evutil_socket_t fd, short old, short events, void *fdinfo);
105 int (*del)(struct event_base *, evutil_socket_t fd, short old, short events, void *fdinfo);
165 struct event_list events; member
H A DChangeLog-1.433 …stead, start out accepting 32 events at a time, and double the queue's size when it seems that the…
46 …o Activate fd events in a pseudorandom order with O(N) backends, so that we don't systematically f…
95 …o Support multiple events listening on the same signal; make signals regular events that go on the…
169 o set the correct event base for HTTP close events
170 …xecuting and return. Unlike event_loopexit, it keeps subsequent pending events from getting execu…
195 o Recalculate pending events properly when reallocating event array on Solaris; from Trond Norbye
203 …o Skip calling gettime() in timeout_process if we are not in fact waiting for any events. (Patch f…
210 …o Fix evport implementation: port_disassociate called on unassociated events resulting in bogus er…
222 …o Make event_base_free() succeed even if there are pending non-internal events on a base. This ma…
230 o Make the logic for active events work better with internal events; patch from Christopher Layne.
H A Dbufferevent.c594 bufferevent_setwatermark(struct bufferevent *bufev, short events, in bufferevent_setwatermark() argument
600 if (events & EV_WRITE) { in bufferevent_setwatermark()
605 if (events & EV_READ) { in bufferevent_setwatermark()
641 bufferevent_getwatermark(struct bufferevent *bufev, short events, in bufferevent_getwatermark() argument
644 if (events == EV_WRITE) { in bufferevent_getwatermark()
654 if (events == EV_READ) { in bufferevent_getwatermark()
/libevent-2.1.12/test/
H A Dbench_cascade.c64 static struct event *events; variable
87 events = (struct event *)calloc(num_pipes, sizeof(struct event)); in run_once()
90 if (events == NULL || pipes == NULL) { in run_once()
111 event_set(&events[i], cp[0], EV_READ, read_cb, in run_once()
113 event_add(&events[i], &tv_timeout); in run_once()
128 event_del(&events[i]); in run_once()
134 free(events); in run_once()
H A Dbench.c72 static struct event *events; variable
107 if (event_initialized(&events[i])) in run_once()
108 event_del(&events[i]); in run_once()
109 event_assign(&events[i], base, cp[0], EV_READ | EV_PERSIST, read_cb, (void *)(ev_intptr_t) i); in run_once()
110 event_add(&events[i], NULL); in run_once()
197 events = calloc(num_pipes, sizeof(struct event));
199 if (events == NULL || pipes == NULL) {
H A Dtest-fdleak.c93 server_event_cb(struct bufferevent *bev, short events, void *ctx) in server_event_cb() argument
95 if (events & BEV_EVENT_ERROR) { in server_event_cb()
98 } else if (events & BEV_EVENT_EOF) { in server_event_cb()
193 client_event_cb(struct bufferevent *bev, short events, void *ctx) in client_event_cb() argument
195 if (events & BEV_EVENT_CONNECTED) { in client_event_cb()
198 } else if (events & BEV_EVENT_ERROR) { in client_event_cb()
H A Dtest-ratelim.c125 static void check_bucket_levels_cb(evutil_socket_t fd, short events, void *arg);
215 check_bucket_levels_cb(evutil_socket_t fd, short events, void *arg) in check_bucket_levels_cb() argument
245 check_group_bucket_levels_cb(evutil_socket_t fd, short events, void *arg) in check_group_bucket_levels_cb() argument
257 group_drain_cb(evutil_socket_t fd, short events, void *arg) in group_drain_cb() argument
264 timer_bias_cb(evutil_socket_t fd, short events, void *arg) in timer_bias_cb() argument
H A Dtest-dumpevents.c52 callback1(evutil_socket_t fd, short events, void *arg) in callback1() argument
56 callback2(evutil_socket_t fd, short events, void *arg) in callback2() argument
/libevent-2.1.12/sample/
H A Dhello-world.c118 conn_eventcb(struct bufferevent *bev, short events, void *user_data) in conn_eventcb() argument
120 if (events & BEV_EVENT_EOF) { in conn_eventcb()
122 } else if (events & BEV_EVENT_ERROR) { in conn_eventcb()
132 signal_cb(evutil_socket_t sig, short events, void *user_data) in signal_cb() argument
/libevent-2.1.12/include/event2/
H A Dbufferevent.h537 void bufferevent_setwatermark(struct bufferevent *bufev, short events,
551 int bufferevent_getwatermark(struct bufferevent *bufev, short events,

12