Searched defs:events (Results 176 - 200 of 220) sorted by last modified time

123456789

/freebsd-head/contrib/ntp/sntp/libevent/test/
H A Dregress.c644 short events[16]; member in struct:persist_active_timeout_called
660 c->events[c->n] = event;
699 tt_int_op(res.events[0], ==, EV_READ);
700 tt_int_op(res.events[1], ==, EV_TIMEOUT);
701 tt_int_op(res.events[2], ==, EV_TIMEOUT);
804 /* Make sure we can free the base with some events in. */
1745 int events; member in struct:read_not_timeout_param
1756 rntp->events |= what;
1795 tt_int_op(rntp.events, ==, EV_READ);
1916 break_cb(evutil_socket_t fd, short events, voi argument
1923 fail_cb(evutil_socket_t fd, short events, void *arg) argument
[all...]
H A Dregress_http.c345 http_chunked_trickle_cb(evutil_socket_t fd, short events, void *arg) argument
3698 terminate_chunked_trickle_cb(evutil_socket_t fd, short events, void *arg) argument
H A Dtest-ratelim.c109 static void check_bucket_levels_cb(evutil_socket_t fd, short events, void *arg);
199 check_bucket_levels_cb(evutil_socket_t fd, short events, void *arg) argument
229 check_group_bucket_levels_cb(evutil_socket_t fd, short events, void *arg) argument
241 group_drain_cb(evutil_socket_t fd, short events, void *arg) argument
H A Dtest-fdleak.c93 server_event_cb(struct bufferevent *bev, short events, void *ctx) argument
95 if (events & BEV_EVENT_ERROR) {
98 } else if (events & (BEV_EVENT_EOF | BEV_EVENT_ERROR)) {
190 client_event_cb(struct bufferevent *bev, short events, void *ctx) argument
192 if (events & BEV_EVENT_CONNECTED) {
195 } else if (events & BEV_EVENT_ERROR) {
H A Dbench.c70 static struct event *events; variable in typeref:struct:event
104 if (event_initialized(&events[i]))
105 event_del(&events[i]);
106 event_set(&events[i], cp[0], EV_READ | EV_PERSIST, read_cb, (void *)(ev_intptr_t) i);
107 event_add(&events[i], NULL);
178 events = calloc(num_pipes, sizeof(struct event));
180 if (events == NULL || pipes == NULL) {
H A Dbench_cascade.c58 * events will fire subsequently until the last socket pair has been reached
64 static struct event *events; variable in typeref:struct:event
87 events = (struct event *)calloc(num_pipes, sizeof(struct event));
90 if (events == NULL || pipes == NULL) {
105 /* provide a default timeout for events */
111 event_set(&events[i], cp[0], EV_READ, read_cb,
113 event_add(&events[i], &tv_timeout);
128 event_del(&events[i]);
134 free(events);
/freebsd-head/contrib/ntp/sntp/libevent/
H A Dbufferevent.c571 bufferevent_setwatermark(struct bufferevent *bufev, short events, argument
578 if (events & EV_WRITE) {
583 if (events & EV_READ) {
619 bufferevent_getwatermark(struct bufferevent *bufev, short events, argument
622 if (events == EV_WRITE) {
632 if (events == EV_READ) {
H A Dbufferevent_openssl.c290 events here as timers only. If we have an SSL, then we use
291 the events as socket events.
1134 be_openssl_enable(struct bufferevent *bev, short events) argument
1142 if (events & EV_READ)
1144 if (events & EV_WRITE)
1148 if (events & EV_READ)
1150 if (events & EV_WRITE)
1153 if (events & EV_READ)
1155 if (events
1162 be_openssl_disable(struct bufferevent *bev, short events) argument
[all...]
H A Dbufferevent_pair.c225 be_pair_enable(struct bufferevent *bufev, short events) argument
232 if (events & EV_READ) {
235 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output))
239 if ((events & EV_READ) && partner &&
244 if ((events & EV_WRITE) && partner &&
253 be_pair_disable(struct bufferevent *bev, short events) argument
255 if (events & EV_READ) {
258 if (events & EV_WRITE) {
H A Devdns.c233 char write_waiting; /* true if we are waiting for EV_WRITE events */
395 static void nameserver_ready_callback(evutil_socket_t fd, short events, void *arg);
410 static void server_port_ready_callback(evutil_socket_t fd, short events, void *arg);
415 static void evdns_request_timeout_callback(evutil_socket_t fd, short events, void *arg);
488 nameserver_prod_callback(evutil_socket_t fd, short events, void *arg) { argument
491 (void)events;
1458 /* We have no more pending requests; stop listening for 'writeable' events. */
1471 /* if waiting is true then we ask libevent for EV_WRITE events, otherwise */
1472 /* we stop these events. */
1496 nameserver_ready_callback(evutil_socket_t fd, short events, voi argument
1516 server_port_ready_callback(evutil_socket_t fd, short events, void *arg) argument
2163 evdns_request_timeout_callback(evutil_socket_t fd, short events, void *arg) argument
[all...]
H A Devent.c262 " (events: 0x%x, fd: "EV_SOCK_FMT \
283 " (events: 0x%x, fd: "EV_SOCK_FMT \
302 " (events: 0x%x, fd: "EV_SOCK_FMT\
321 " (events: 0x%x, fd: "EV_SOCK_FMT", " \
520 event_errx(1, "%s must be called *before* creating any events "
769 /* XXX(niels) - check for internal events first */
786 /* Delete all non-internal events. */
798 for (ev = TAILQ_FIRST(&ctl->events); ev; ) {
829 event_debug(("%s: %d events were still set in base",
879 short events, voi
878 nil_backend_del(struct event_base *b, evutil_socket_t fd, short old, short events, void *fdinfo) argument
1936 event_once_cb(evutil_socket_t fd, short events, void *arg) argument
1950 event_once(evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg, const struct timeval *tv) argument
1959 event_base_once(struct event_base *base, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg, const struct timeval *tv) argument
2018 event_assign(struct event *ev, struct event_base *base, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg) argument
2082 event_set(struct event *ev, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg) argument
2111 event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *), void *arg) argument
3724 event_base_active_by_fd(struct event_base *base, evutil_socket_t fd, short events) argument
[all...]
H A Dkqueue.c76 struct kevent *events; member in struct:kqop
139 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent));
140 if (kqueueop->events == NULL)
151 * stick an error in events[0]. If kqueue is broken, then
155 kqueueop->changes, 1, kqueueop->events, NEVENT, NULL) != 1 ||
156 (int)kqueueop->events[0].ident != -1 ||
157 kqueueop->events[0].flags != EV_ERROR) {
241 newresult = mm_realloc(kqop->events,
245 kqop->events = newresult;
257 struct kevent *events local
440 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p) argument
473 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p) argument
[all...]
H A Ddevpoll.c57 struct pollfd *events; member in struct:devpollop
65 static int devpoll_add(struct event_base *, int fd, short old, short events, void *);
66 static int devpoll_del(struct event_base *, int fd, short old, short events, void *);
100 devpoll_queue(struct devpollop *devpollop, int fd, int events) { argument
114 pfd->events = events;
146 devpollop->events = mm_calloc(nfiles, sizeof(struct pollfd));
147 if (devpollop->events == NULL) {
156 mm_free(devpollop->events);
171 struct pollfd *events local
228 devpoll_add(struct event_base *base, int fd, short old, short events, void *p) argument
254 devpoll_del(struct event_base *base, int fd, short old, short events, void *p) argument
[all...]
H A Depoll.c87 struct epoll_event *events; member in struct:epollop
113 short old, short events, void *p);
115 short old, short events, void *p);
169 epollop->events = mm_calloc(INITIAL_NEVENT, sizeof(struct epoll_event));
170 if (epollop->events == NULL) {
199 epev.events = EPOLLIN;
255 int op, events = 0; local
260 events = epoll_op_table[idx].events;
262 if (!events) {
376 epoll_nochangelist_add(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
397 epoll_nochangelist_del(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
418 struct epoll_event *events = epollop->events; local
[all...]
H A Depoll_sub.c59 epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout) argument
62 return (syscall(__NR_epoll_pwait, epfd, events, maxevents, timeout, NULL, 0));
64 return (syscall(__NR_epoll_wait, epfd, events, maxevents, timeout));
H A Depolltable-internal.h44 This is impossible; Set op==-1, events=0.
46 Set events to 0.
49 Add EPOLLIN to events.
52 Add EPOLLOUT to events.
63 Set events to EPOLLIN|EPOLLOUT
65 Set events to EPOLLOUT
68 Set events to EPOLLIN
72 Set events to EPOLLIN
75 Set the events to EPOLLOUT
78 There is no read or write change; set op to 0 and events t
137 int events; member in struct:operation
[all...]
H A Devent-internal.h95 /** Enable reading/writing on a given fd or signal. 'events' will be
96 * the events that we're trying to enable: one or more of EV_READ,
97 * EV_WRITE, EV_SIGNAL, and EV_ET. 'old' will be those events that
103 int (*add)(struct event_base *, evutil_socket_t fd, short old, short events, void *fdinfo);
104 /** As "add", except 'events' contains the events we mean to disable. */
105 int (*del)(struct event_base *, evutil_socket_t fd, short old, short events, void *fdinfo);
107 added events are ready, and cause event_active to be called for each
121 has one or more active events. This information is recorded
131 use a hashtable instead of an array to map fds to events
165 struct event_list events; member in struct:common_timeout_list
[all...]
H A Devmap.c55 /** An entry for an evmap_io list: notes all the events that want to read or
59 struct event_dlist events; member in struct:evmap_io
65 /* An entry for an evmap_signal list: notes all the events that want to know
68 struct event_dlist events; member in struct:evmap_signal
256 LIST_INIT(&entry->events);
313 event_warnx("Too many events reading or writing on fd %d",
318 (old_ev = LIST_FIRST(&ctx->events)) &&
321 " events on fd %d", (int)fd);
339 LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next);
412 evmap_io_active_(struct event_base *base, evutil_socket_t fd, short events) argument
602 short events = 0; local
855 event_changelist_add_(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
890 event_changelist_del_(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
[all...]
H A Devport.c40 * The outstanding events are tracked in a data structure called evport_data.
42 * pointers to the read and write events that correspond to that fd. (That is,
85 * Per-file-descriptor information about what events we're subscribed to. These
105 int ed_port; /* event port for system events */
112 /* storage space for incoming events. */
118 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 *);
215 * We've only registered for PORT_SOURCE_FD events. The only
229 * (Re)associates the given file descriptor with the event port. The OS events
251 * Main event loop - polls port_getn for some number of events, an
379 evport_add(struct event_base *base, int fd, short old, short events, void *p) argument
396 evport_del(struct event_base *base, int fd, short old, short events, void *p) argument
[all...]
H A Dpoll.c70 static int poll_add(struct event_base *, int, short old, short events, void *idx);
71 static int poll_del(struct event_base *, int, short old, short events, void *idx);
217 poll_add(struct event_base *base, int fd, short old, short events, void *idx_) argument
224 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
225 if (!(events & (EV_READ|EV_WRITE)))
258 pfd->events = 0;
264 if (events & EV_WRITE)
265 pfd->events |= POLLOUT;
266 if (events & EV_READ)
267 pfd->events |
278 poll_del(struct event_base *base, int fd, short old, short events, void *idx_) argument
[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) argument
257 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
285 if (events & EV_READ)
287 if (events & EV_WRITE)
299 select_del(struct event_base *base, int fd, short old, short events, void *p) argument
304 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
312 if (events & EV_READ)
315 if (events
[all...]
H A Dsignal.c278 evsig_add(struct event_base *base, evutil_socket_t evsignal, short old, short events, void *p) argument
361 evsig_del(struct event_base *base, evutil_socket_t evsignal, short old, short events, void *p) argument
/freebsd-head/contrib/ntp/lib/isc/
H A Dtask_api.c167 void *tag, isc_eventlist_t *events)
171 return (task->methods->unsend(task, sender, type, tag, events));
166 isc_task_unsend(isc_task_t *task, void *sender, isc_eventtype_t type, void *tag, isc_eventlist_t *events) argument
/freebsd-head/contrib/ntp/lib/isc/unix/
H A Dsocket.c179 * during intermittent events or the kernel bug is triggered. If the next
207 * Maximum number of events communicated with the kernel. There should normally
241 * DLVL(70) -- Socket "correctness" -- including returning of events, etc.
243 * DLVL(50) -- Event tracing, including receiving/sending completion events.
322 * Internal events. Posted when a descriptor is readable or
368 struct kevent *events; member in struct:isc__socketmgr
373 struct epoll_event *events; member in struct:isc__socketmgr
378 struct pollfd *events; member in struct:isc__socketmgr
826 event.events = EPOLLIN;
828 event.events
3599 process_fds(isc__socketmgr_t *manager, struct kevent *events, int nevents) argument
3641 process_fds(isc__socketmgr_t *manager, struct epoll_event *events, int nevents) argument
3689 process_fds(isc__socketmgr_t *manager, struct pollfd *events, int nevents) argument
[all...]
/freebsd-head/contrib/ntp/lib/isc/win32/include/isc/
H A Dcondition.h40 HANDLE events[2]; member in struct:isc_condition

Completed in 1189 milliseconds

123456789