Searched defs:events (Results 1 - 25 of 220) sorted by path

123456789

/freebsd-head/cddl/contrib/opensolaris/cmd/zdb/
H A Dzdb.c1299 nvlist_t **events = NULL; local
1322 if (zpool_history_unpack(buf, len, &resid, &events, &num) != 0)
1351 if (nvlist_lookup_uint64(events[i], ZPOOL_HIST_TIME,
1354 if (nvlist_lookup_string(events[i], ZPOOL_HIST_CMD,
1356 if (nvlist_lookup_uint64(events[i],
1359 verify(nvlist_lookup_uint64(events[i],
1361 verify(nvlist_lookup_string(events[i],
1383 dump_nvlist(events[i], 2);
/freebsd-head/cddl/usr.sbin/zfsd/
H A Dcase_file.cc37 * However, we only serialize to disk those events that need to be preserved
412 * Discard any tentative I/O error events for
429 * Otherwise, leave it in the unconsumed events list so that the
838 CaseFile::SerializeEvList(const EventList events, int fd, argument
841 if (events.empty())
843 for (EventList::const_iterator curEvent = events.begin();
844 curEvent != events.end(); curEvent++) {
882 * XXX: This method assumes that events may not contain embedded newlines. If
883 * ever events can contain embedded newlines, then CaseFile must switch
/freebsd-head/contrib/bmake/
H A Djob.h96 short events; member in struct:emul_pollfd
/freebsd-head/contrib/capsicum-test/
H A Dsctp.cc132 struct sctp_event_subscribe events; local
133 memset(&events, 0, sizeof(events));
134 events.sctp_association_event = 1;
135 events.sctp_data_io_event = 1;
136 EXPECT_NOTCAPABLE(setsockopt(cap_sock_rw, IPPROTO_SCTP, SCTP_EVENTS, &events, sizeof(events)));
137 len = sizeof(events);
138 EXPECT_NOTCAPABLE(getsockopt(cap_sock_rw, IPPROTO_SCTP, SCTP_EVENTS, &events, &len));
139 memset(&events,
[all...]
/freebsd-head/contrib/gdb/gdb/gdbserver/
H A Dthread-db.c153 because all events come from the manager thread
177 td_thr_events_t events; local
181 /* Set the process wide mask saying which events we're interested in. */
182 td_event_emptyset (&events);
183 td_event_addset (&events, TD_CREATE);
188 td_event_addset (&events, TD_DEATH);
191 err = td_ta_set_event (thread_agent, &events);
/freebsd-head/contrib/gdb/gdb/
H A Dthread-db.c497 td_thr_events_t events;
507 /* Set the process wide mask saying which events we're interested in. */
508 td_event_emptyset (&events);
509 td_event_addset (&events, TD_CREATE);
512 broken for TD_DEATH events in glibc 2.1.3, so don't enable it for
514 td_event_addset (&events, TD_DEATH);
517 err = td_ta_set_event_p (thread_agent, &events);
552 td_thr_events_t events;
555 events anymore. */
556 td_event_emptyset (&events);
491 td_thr_events_t events; local
546 td_thr_events_t events; local
[all...]
/freebsd-head/contrib/googletest/googletest/test/
H A Dgoogletest-listener-test.cc32 // This file verifies Google Test event listeners receive events at the
49 // Used by tests to register their events.
202 std::vector<std::string> events; local
203 g_events = &events;
213 GTEST_CHECK_(events.size() == 0)
214 << "AddGlobalTestEnvironment should not generate any events itself.";
301 VerifyResults(events,
/freebsd-head/contrib/libevent/
H A Dbufferevent.c570 bufferevent_setwatermark(struct bufferevent *bufev, short events, argument
577 if (events & EV_WRITE) {
582 if (events & EV_READ) {
618 bufferevent_getwatermark(struct bufferevent *bufev, short events, argument
621 if (events == EV_WRITE) {
631 if (events == EV_READ) {
H A Dbufferevent_openssl.c288 events here as timers only. If we have an SSL, then we use
289 the events as socket events.
1153 be_openssl_enable(struct bufferevent *bev, short events) argument
1158 if (events & EV_READ)
1160 if (events & EV_WRITE)
1164 if (events & EV_READ)
1166 if (events & EV_WRITE)
1169 if (events & EV_READ)
1171 if (events
1178 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 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;
249 #define PRINT_CHANGES(op, events, ch, status) \
251 "Old events were %d; " \
256 events, \
272 int op, events local
375 epoll_nochangelist_add(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
396 epoll_nochangelist_del(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
417 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 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;
1456 /* We have no more pending requests; stop listening for 'writeable' events. */
1469 /* if waiting is true then we ask libevent for EV_WRITE events, otherwise */
1470 /* we stop these events. */
1494 nameserver_ready_callback(evutil_socket_t fd, short events, voi argument
1514 server_port_ready_callback(evutil_socket_t fd, short events, void *arg) argument
2161 evdns_request_timeout_callback(evutil_socket_t fd, short events, void *arg) argument
[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 Devent.c278 " (events: 0x%x, fd: "EV_SOCK_FMT \
299 " (events: 0x%x, fd: "EV_SOCK_FMT \
318 " (events: 0x%x, fd: "EV_SOCK_FMT\
337 " (events: 0x%x, fd: "EV_SOCK_FMT", " \
536 event_errx(1, "%s must be called *before* creating any events "
812 /* XXX(niels) - check for internal events first */
829 /* Delete all non-internal events. */
841 for (ev = TAILQ_FIRST(&ctl->events); ev; ) {
858 * add finalizer to activequeues, and we will have events in
872 event_debug(("%s: %d events wer
921 nil_backend_del(struct event_base *b, evutil_socket_t fd, short old, short events, void *fdinfo) argument
1983 event_once_cb(evutil_socket_t fd, short events, void *arg) argument
1997 event_once(evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg, const struct timeval *tv) argument
2006 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
2065 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
2129 event_set(struct event *ev, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg) argument
2158 event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *), void *arg) argument
3774 event_base_active_by_fd(struct event_base *base, evutil_socket_t fd, short events) argument
[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 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
441 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p) argument
474 kq_sig_del(struct event_base *base, int nsignal, 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/libevent/sample/
H A Dhello-world.c119 conn_eventcb(struct bufferevent *bev, short events, void *user_data) argument
121 if (events & BEV_EVENT_EOF) {
123 } else if (events & BEV_EVENT_ERROR) {
127 /* None of the other events can happen here, since we haven't enabled
133 signal_cb(evutil_socket_t sig, short events, void *user_data) argument
/freebsd-head/contrib/libevent/test/
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) {

Completed in 231 milliseconds

123456789