Lines Matching defs:ev
104 struct event *ev;
157 event_del(arg->ev);
181 struct event *ev = arg;
192 event_del(ev);
201 event_del(ev);
206 if (event_add(ev, NULL) == -1)
214 struct event *ev = arg;
222 event_del(ev);
228 if (event_add(ev, NULL) == -1)
240 struct event ev;
258 if (event_add(&both->ev, NULL) == -1)
284 if (event_add(&both->ev, NULL) == -1)
300 struct event ev;
311 event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev);
312 if (event_add(&ev, NULL) == -1)
322 struct event ev;
327 event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev);
328 if (event_add(&ev, NULL) == -1)
478 struct event ev, ev2;
490 event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev);
491 if (event_add(&ev, NULL) == -1)
507 struct event ev, ev2;
519 event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev);
520 if (event_add(&ev, NULL) == -1)
547 event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1);
548 event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1);
549 event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2);
550 event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2);
551 tt_assert(event_add(&r1.ev, NULL) != -1);
552 tt_assert(!event_add(&w1.ev, NULL));
553 tt_assert(!event_add(&r2.ev, NULL));
554 tt_assert(!event_add(&w2.ev, NULL));
568 struct event ev;
575 evtimer_set(&ev, timeout_cb, NULL);
576 evtimer_add(&ev, &tv);
605 struct event ev;
611 event_assign(&ev, global_base, -1, EV_TIMEOUT|EV_PERSIST,
613 event_add(&ev, &tv);
617 event_del(&ev);
624 struct event ev;
630 event_assign(&ev, data->base, -1, EV_PERSIST, periodic_timeout_cb, &count);
631 event_add(&ev, &msec100);
639 event_del(&ev);
651 struct event *ev = arg;
652 event_active(ev, EV_READ, 1);
670 struct event ev;
680 event_assign(&ev, base, -1, EV_TIMEOUT|EV_PERSIST,
682 event_add(&ev, &tv);
686 event_base_once(base, -1, EV_TIMEOUT, activate_cb, &ev, &tv2);
706 event_del(&ev);
710 struct event ev;
723 event_del(&ti->ev);
764 event_assign(&info[i].ev, base, -1, EV_TIMEOUT|EV_PERSIST,
771 event_add(&info[i].ev, ms_200);
772 event_add(&info[i].ev, &tmp_100_ms);
775 event_add(&info[i].ev, &tmp_200_ms);
776 event_add(&info[i].ev, ms_100);
779 event_add(&info[i].ev, ms_200);
780 event_add(&info[i].ev, ms_100);
782 event_add(&info[i].ev, ms_100);
785 event_add(&info[i].ev, ms_200);
807 event_add(&info[i].ev, ms_100);
809 event_add(&info[i].ev, ms_200);
856 struct event ev, sig_ev, usr_ev, existing_ev;
885 event_set(&ev, pair[1], EV_READ, simple_child_read_cb, &ev);
886 if (event_add(&ev, NULL) == -1)
1000 struct event ev;
1005 event_set(&ev, pair[1], EV_READ, del_wait_cb, &ev);
1006 event_add(&ev, NULL);
1022 event_del(&ev);
1043 struct event *ev = arg;
1045 evsignal_del(ev);
1052 struct event ev;
1055 evsignal_set(&ev, SIGALRM, signal_cb, &ev);
1056 evsignal_add(&ev, NULL);
1059 evsignal_del(&ev);
1060 evsignal_add(&ev, NULL);
1071 if (evsignal_del(&ev) == -1)
1125 struct event ev;
1128 evsignal_set(&ev, SIGUSR1, signal_cb, &ev);
1129 evsignal_add(&ev, NULL);
1132 evsignal_del(&ev);
1140 struct event ev;
1142 evsignal_set(&ev, SIGUSR1, signal_cb, &ev);
1143 evsignal_add(&ev, NULL);
1144 evsignal_del(&ev);
1233 struct event ev;
1237 evsignal_set(&ev, SIGCONT, signal_cb, &ev);
1238 evsignal_add(&ev, NULL);
1243 evsignal_del(&ev);
1268 struct event ev;
1285 evsignal_set(&ev, SIGUSR1, signal_cb, &ev);
1286 evsignal_add(&ev, NULL);
1287 evsignal_del(&ev);
1327 struct event ev, ev_timer;
1334 signal_set(&ev, SIGUSR1, signal_cb_swp, NULL);
1335 signal_add(&ev, NULL);
1398 struct event *ev = arg;
1399 struct event_base *base = event_get_base(ev);
1402 tt_want(ev == event_base_get_running_event(base));
1410 struct event *ev = event_new(base, -1, EV_READ, event_selfarg_cb,
1413 event_active(ev, EV_READ, 1);
1416 event_free(ev);
1424 struct event ev;
1426 event_assign(&ev, base, -1, EV_READ, event_selfarg_cb,
1428 event_active(&ev, EV_READ, 1);
1437 struct event ev;
1448 event_assign(&ev, base, -1, EV_READ, event_selfarg_cb,
1451 event_add(&ev, &qsec);
1477 event_active(&ev, EV_READ, 1);
1561 struct event ev;
1573 event_assign(&ev, base, -1, EV_READ, event_selfarg_cb,
1578 event_add(&ev, &qsec);
1608 event_active(&ev, EV_READ, 1);
1703 struct event ev;
1706 r = event_assign(&ev, NULL, -1, EV_SIGNAL|EV_READ, dummy_read_cb, NULL);
1734 struct event ev;
1736 event_assign(&ev, base, -1,
1739 event_active(&ev, EV_WRITE, 1);
1847 struct event **ev;
1861 if(2 == rntp->count) event_del(rntp->ev[0]);
1871 struct event *ev[5];
1877 struct read_not_timeout_param rntp = { ev, 0, 0 };
1881 ev[0] = event_new(base, data->pair[0], EV_READ|EV_PERSIST,
1883 ev[1] = evtimer_new(base, incr_arg_cb, &ev1_fired);
1884 ev[2] = evtimer_new(base, remove_timers_cb, ev);
1885 ev[3] = evtimer_new(base, send_a_byte_cb, &data->pair[1]);
1886 ev[4] = evtimer_new(base, send_a_byte_cb, &data->pair[1]);
1888 event_add(ev[2], &ms25); /* remove timers */
1889 event_add(ev[4], &ms40); /* write to test if timer re-activates */
1890 event_add(ev[0], &ms75); /* read */
1891 event_add(ev[1], &ms75); /* timer */
1892 event_add(ev[3], &ms125); /* timeout. */
1902 event_free(ev[0]);
1903 event_free(ev[1]);
1904 event_free(ev[2]);
1905 event_free(ev[3]);
1906 event_free(ev[4]);
1934 args.ev = &ev1;
1954 struct event ev;
1960 evtimer_set(&ev, timeout_cb, NULL);
1961 evtimer_add(&ev, &tv);
1971 evtimer_del(&ev);
2130 struct event ev;
2148 event_add(&pri->ev, &tv);
2164 timeout_set(&one.ev, test_priorities_cb, &one);
2165 if (event_priority_set(&one.ev, 0) == -1) {
2170 timeout_set(&two.ev, test_priorities_cb, &two);
2171 if (event_priority_set(&two.ev, npriorities - 1) == -1) {
2178 if (event_add(&one.ev, &tv) == -1)
2180 if (event_add(&two.ev, &tv) == -1)
2185 event_del(&one.ev);
2186 event_del(&two.ev);
2331 struct event ev;
2346 event_set(&ev, pair[1], EV_READ, read_once_cb, &ev);
2347 if (event_add(&ev, NULL) == -1)
3025 struct event *ev[MANY];
3035 memset(ev, 0, sizeof(ev));
3045 ev[i] = event_new(base, sock[i], EV_WRITE|evflags,
3047 event_add(ev[i], NULL);
3063 if (ev[i])
3064 event_free(ev[i]);
3112 const struct event *ev;
3116 foreach_count_cb(const struct event_base *base, const struct event *ev, void *arg)
3118 struct foreach_helper *h = event_get_callback_arg(ev);
3120 if (event_get_callback(ev) != timeout_cb)
3122 tt_ptr_op(event_get_base(ev), ==, base);
3124 h->ev = ev;
3132 foreach_find_cb(const struct event_base *base, const struct event *ev, void *arg)
3135 struct foreach_helper *h = event_get_callback_arg(ev);
3136 if (event_get_callback(ev) != timeout_cb)
3139 *ev_out = ev;
3150 struct event *ev[5];
3158 visited[i].ev = NULL;
3159 ev[i] = event_new(base, -1, 0, timeout_cb, &visited[i]);
3165 event_add(ev[0], &ten_sec);
3166 event_add(ev[1], &ten_sec);
3167 event_active(ev[1], EV_TIMEOUT, 1);
3168 event_active(ev[2], EV_TIMEOUT, 1);
3169 event_add(ev[3], &ten_sec);
3170 /* Don't touch ev[4]. */
3178 tt_ptr_op(ev[0], ==, visited[0].ev);
3179 tt_ptr_op(ev[1], ==, visited[1].ev);
3180 tt_ptr_op(ev[2], ==, visited[2].ev);
3181 tt_ptr_op(ev[3], ==, visited[3].ev);
3186 tt_ptr_op(ev_found, ==, ev[2]);
3190 event_free(ev[i]);
