Lines Matching defs:cb
497 event_deferred_cb_queue_init(struct deferred_cb_queue *cb)
499 memset(cb, 0, sizeof(struct deferred_cb_queue));
500 TAILQ_INIT(&cb->deferred_cb_list);
505 notify_base_cbq_callback(struct deferred_cb_queue *cb, void *baseptr)
1400 struct deferred_cb *cb;
1403 while ((cb = TAILQ_FIRST(&queue->deferred_cb_list))) {
1404 cb->queued = 0;
1405 TAILQ_REMOVE(&queue->deferred_cb_list, cb, cb_next);
1409 cb->cb(cb, cb->arg);
1662 void (*cb)(evutil_socket_t, short, void *);
1673 (*eonce->cb)(fd, events, eonce->arg);
1705 eonce->cb = callback;
1807 event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *), void *arg)
1813 if (event_assign(ev, base, fd, events, cb, arg) < 0) {
2348 event_deferred_cb_init(struct deferred_cb *cb, deferred_cb_fn fn, void *arg)
2350 memset(cb, 0, sizeof(struct deferred_cb));
2351 cb->cb = fn;
2352 cb->arg = arg;
2357 struct deferred_cb *cb)
2367 if (cb->queued) {
2368 TAILQ_REMOVE(&queue->deferred_cb_list, cb, cb_next);
2370 cb->queued = 0;
2377 struct deferred_cb *cb)
2387 if (!cb->queued) {
2388 cb->queued = 1;
2389 TAILQ_INSERT_TAIL(&queue->deferred_cb_list, cb, cb_next);
2769 void (*cb)(evutil_socket_t, short, void *) = evthread_notify_drain_default;
2787 cb = evthread_notify_drain_eventfd;
2836 EV_READ|EV_PERSIST, cb, base);
