| /libevent-2.1.12/ |
| H A D | event.c | 298 __func__, ev, ev->ev_events, in event_debug_note_add_() 324 __func__, ev, ev->ev_events, in event_debug_note_del_() 348 __func__, ev, ev->ev_events, in event_debug_assert_is_setup_() 369 __func__, ev, ev->ev_events, in event_debug_assert_not_added_() 799 ev->ev_evcallback.evcb_cb_union.evcb_evfinalize(ev, ev->ev_arg); in event_base_cancel_single_callback_() 1369 (*ev->ev_callback)(ev->ev_fd, ev->ev_res, ev->ev_arg); in event_signal_closure() 1710 evcb_evfinalize(ev, ev->ev_arg); in event_process_active_single_queue() 2816 ev, EV_SOCK_ARG(ev->ev_fd), ev->ev_callback)); in event_del_nolock_() 2924 ev, EV_SOCK_ARG(ev->ev_fd), (int)res, ev->ev_callback)); in event_active_nolock_() 3201 ev, ev->ev_callback)); in timeout_process() [all …]
|
| H A D | evmap.c | 414 LIST_REMOVE(ev, ev_io_next); in evmap_io_del_() 424 struct event *ev; in evmap_io_active_() local 436 event_active_nolock_(ev, ev->ev_events & events, 1); in evmap_io_active_() 505 struct event *ev; in evmap_signal_active_() local 614 struct event *ev; local 670 struct event *ev; local 672 event_del(ev); 955 struct event *ev; local 988 struct event *ev; local 1025 struct event *ev; local [all …]
|
| H A D | evmap-internal.h | 62 int evmap_io_add_(struct event_base *base, evutil_socket_t fd, struct event *ev); 71 int evmap_io_del_(struct event_base *base, evutil_socket_t fd, struct event *ev); 84 int evmap_signal_add_(struct event_base *base, int signum, struct event *ev); 85 int evmap_signal_del_(struct event_base *base, int signum, struct event *ev);
|
| H A D | make_epoll_table.py | 50 def fmt(op, ev, old, wc, rc, cc): argument 51 entry = "{ %s, %s },"%(op, ev) 61 op,ev = get(old,wc,rc,cc) variable 63 fmt(op, ev, old, wc, rc, cc)
|
| H A D | event-internal.h | 202 struct event ev; member 408 int event_add_nolock_(struct event *ev, 424 int event_del_nolock_(struct event *ev, int blocking); 425 int event_remove_timer_nolock_(struct event *ev); 427 void event_active_nolock_(struct event *ev, int res, short count); 441 void event_active_later_(struct event *ev, int res); 442 void event_active_later_nolock_(struct event *ev, int res);
|
| H A D | epoll.c | 483 short ev = 0; in epoll_dispatch() local 490 ev = EV_READ | EV_WRITE; in epoll_dispatch() 492 ev = EV_READ | EV_WRITE; in epoll_dispatch() 495 ev |= EV_READ; in epoll_dispatch() 497 ev |= EV_WRITE; in epoll_dispatch() 499 ev |= EV_CLOSED; in epoll_dispatch() 502 if (!ev) in epoll_dispatch() 505 evmap_io_active_(base, events[i].data.fd, ev | EV_ET); in epoll_dispatch()
|
| H A D | whatsnew-2.1.txt | 109 struct event ev; 110 event_assign(&ev, base, fd, EV_READ, callback, &ev); 177 struct connection *conn = event_get_callback_arg(ev); 178 event_del(ev); 227 promising not to use the "event_del(ev); free(event_get_callback_arg(ev));" 237 event_del_noblock(ev) 238 event_del_block(ev) 553 void func(int operation, struct event *ev) { 560 void func_op1(struct event *ev) { ... } 561 void func_op2(struct event *ev) { ... } [all …]
|
| H A D | configure.ac | 565 struct kevent ev; 580 memset(&ev, 0, sizeof(ev)); 581 ev.ident = fd[1]; 582 ev.filter = EVFILT_WRITE; 583 ev.flags = EV_ADD | EV_ENABLE; 584 n = kevent(kq, &ev, 1, NULL, 0, NULL); 592 n = kevent(kq, NULL, 0, &ev, 1, &ts);
|
| H A D | whatsnew-2.0.txt | 115 struct event *ev = malloc(sizeof(struct event)); 118 event_set(ev, fd, EV_READ, cb, NULL); 121 event_set_base(ev, base); 127 struct event *ev; 128 ev = event_new(base, fd, EV_READ, cb, NULL); 196 struct event *ev; 198 ev = event_new(base, fd, EV_READ|EV_PERSIST, cb, NULL); 201 event_add(ev, &tv);
|
| /libevent-2.1.12/test/ |
| H A D | test-dumpevents.c | 71 struct event *ev[N_EVENTS]; in main() local 130 event_add(ev[0], NULL); in main() 131 event_add(ev[1], &tv_onesec); in main() 132 event_add(ev[2], tv_onesec_common); in main() 135 event_add(ev[4], tv_onesec_common); in main() 137 event_add(ev[6], &tv_onesec); in main() 140 event_add(ev[9], &tv_two5sec); in main() 142 event_active(ev[10], EV_READ, 1); in main() 144 event_active(ev[1], EV_READ, 1); in main() 146 event_add(ev[12], NULL); in main() [all …]
|
| H A D | regress_finalize.c | 61 (void)ev; in event_finalize_callback_1() 78 struct event *ev; in test_fin_cb_invoked() local 133 event_add(ev, &ten_sec); in test_fin_cb_invoked() 145 event_add(ev, &ten_sec); in test_fin_cb_invoked() 150 event_del(ev); in test_fin_cb_invoked() 195 struct event *ev, *ev2; in test_fin_free_finalize() 208 tfff_p1 = ev; in test_fin_free_finalize() 232 struct event *ev; member 241 event_free(ev); in event_finalize_callback_2() 303 free(ev); in event_finalize_callback_free() [all …]
|
| H A D | regress.c | 519 if (ev) in test_simpleclose() 1105 event_set(&ev, -1, EV_READ, null_cb, &ev); in test_del_notify() 1141 evsignal_set(&ev, SIGALRM, signal_cb, &ev); in test_simplesignal_impl() 1214 evsignal_set(&ev, SIGUSR1, signal_cb, &ev); in test_immediatesignal() 1228 evsignal_set(&ev, SIGUSR1, signal_cb, &ev); in test_signal_dealloc() 3106 memset(ev, 0, sizeof(ev)); in test_many_events() 3196 h->ev = ev; in foreach_count_cb() 3250 tt_ptr_op(ev[0], ==, visited[0].ev); in test_event_foreach() 3251 tt_ptr_op(ev[1], ==, visited[1].ev); in test_event_foreach() 3252 tt_ptr_op(ev[2], ==, visited[2].ev); in test_event_foreach() [all …]
|
| H A D | regress_et.c | 84 struct event *ev = NULL; in test_edgetriggered() local 106 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered() 107 tt_assert(ev != NULL); in test_edgetriggered() 108 tt_int_op(event_add(ev, NULL), ==, 0); in test_edgetriggered() 129 if (ev) { in test_edgetriggered() 130 event_del(ev); in test_edgetriggered() 131 event_free(ev); in test_edgetriggered()
|
| H A D | test-time.c | 50 struct event *ev[NEVENT]; variable 74 evtimer_add(ev[j], &tv); in time_cb() 76 evtimer_del(ev[j]); in time_cb() 106 ev[i] = evtimer_new(base, time_cb, event_self_cbarg()); in main() 109 evtimer_add(ev[i], &tv); in main()
|
| H A D | test-weof.c | 83 struct event ev; in main() local 106 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); in main() 108 event_add(&ev, NULL); in main()
|
| H A D | test-closed.c | 76 struct event *ev; in main() local 102 ev = event_new(base, pair[1], EV_CLOSED | EV_TIMEOUT, closed_cb, event_self_cbarg()); in main() 103 event_add(ev, &timeout); in main() 107 event_free(ev); in main()
|
| H A D | test-eof.c | 84 struct event ev; in main() local 109 event_set(&ev, pair[1], EV_READ | EV_TIMEOUT, read_cb, &ev); in main() 111 event_add(&ev, &timeout); in main()
|
| H A D | regress_minheap.c | 36 set_random_timeout(struct event *ev) in set_random_timeout() argument 38 ev->ev_timeout.tv_sec = test_weakrand(); in set_random_timeout() 39 ev->ev_timeout.tv_usec = test_weakrand() & 0xfffff; in set_random_timeout() 40 ev->ev_timeout_pos.min_heap_idx = -1; in set_random_timeout()
|
| H A D | test-changelist.c | 164 struct event* ev; in main() local 192 ev = event_new(base,pair[1],EV_WRITE | EV_PERSIST, write_cb, &ev); in main() 199 event_add(ev, NULL); in main() 205 event_free(ev); in main()
|
| H A D | regress_thread.c | 103 struct event ev; in basic_thread() local 111 evtimer_assign(&ev, base, wake_all_timeout, &cw); in basic_thread() 121 assert(evtimer_add(&ev, &tv) == 0); in basic_thread() 170 struct event ev; in thread_basic() local 231 evtimer_assign(&ev, base, NULL, NULL); in thread_basic() 234 event_add(&ev, &tv); in thread_basic() 241 event_del(&ev); in thread_basic()
|
| /libevent-2.1.12/include/event2/ |
| H A D | event_compat.h | 186 #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument 198 #define timeout_add(ev, tv) event_add((ev), (tv)) argument 199 #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument 200 #define timeout_del(ev) event_del(ev) argument 202 #define timeout_initialized(ev) event_initialized(ev) argument 212 #define signal_add(ev, tv) event_add((ev), (tv)) argument 215 #define signal_del(ev) event_del(ev) argument 216 #define signal_pending(ev, tv) event_pending((ev), EV_SIGNAL, (tv)) argument 217 #define signal_initialized(ev) event_initialized(ev) argument 222 #define EVENT_FD(ev) ((int)event_get_fd(ev)) argument [all …]
|
| H A D | event.h | 967 #define evtimer_add(ev, tv) event_add((ev), (tv)) argument 968 #define evtimer_del(ev) event_del(ev) argument 970 #define evtimer_initialized(ev) event_initialized(ev) argument 979 #define evsignal_add(ev, tv) event_add((ev), (tv)) argument 984 #define evsignal_del(ev) event_del(ev) argument 986 #define evsignal_initialized(ev) event_initialized(ev) argument 997 #define evuser_del(ev) event_del(ev) argument 998 #define evuser_pending(ev, tv) event_pending((ev), 0, (tv)) argument 999 #define evuser_initialized(ev) event_initialized(ev) argument 1000 #define evuser_trigger(ev) event_active((ev), 0, 0) argument [all …]
|
| /libevent-2.1.12/cmake/ |
| H A D | CheckWorkingKqueue.cmake | 18 struct kevent ev; 33 memset(&ev, 0, sizeof(ev)); 34 ev.ident = fd[1]; 35 ev.filter = EVFILT_WRITE; 36 ev.flags = EV_ADD | EV_ENABLE; 37 n = kevent(kq, &ev, 1, NULL, 0, NULL); 45 n = kevent(kq, NULL, 0, &ev, 1, &ts);
|
| /libevent-2.1.12/sample/ |
| H A D | event-read-fifo.c | 38 struct event *ev = arg; in fifo_read() local 51 event_del(ev); in fifo_read() 64 event_del(ev); in fifo_read() 65 event_base_loopbreak(event_get_base(ev)); in fifo_read()
|
| /libevent-2.1.12/include/ |
| H A D | include.am | 41 ## With nobase_ the installed path is $(includedir)/include/event2/ev*.h.
|