Lines Matching refs:base
56 static void _set_main_event(struct mcp_backendconn_s *be, struct event_base *base, int flags, struc…
230 …event_assign(&bec->main_event, bec->event_thread->base, mcmc_fd(bec->client), EV_WRITE|EV_TIMEOUT,… in _setup_backend()
231 …event_assign(&bec->write_event, bec->event_thread->base, mcmc_fd(bec->client), EV_WRITE|EV_TIMEOUT… in _setup_backend()
232 … event_assign(&bec->timeout_event, bec->event_thread->base, -1, EV_TIMEOUT, _backend_handler, bec); in _setup_backend()
396 event_base_loop(t->base, 0); in proxy_event_thread()
397 event_base_free(t->base); in proxy_event_thread()
404 static void _set_main_event(struct mcp_backendconn_s *be, struct event_base *base, int flags, struc… in _set_main_event() argument
415 event_assign(&be->main_event, base, fd, in _set_main_event()
762 …event_assign(&be->write_event, be->event_thread->base, mcmc_fd(be->client), EV_WRITE|EV_TIMEOUT, _… in _backend_reconnect()
776 _set_main_event(be, be->event_thread->base, EV_WRITE, &tmp_time, _backend_handler); in proxy_backend_retry_handler()
815 … _set_main_event(be, be->event_thread->base, EV_TIMEOUT, &tmp_time, proxy_backend_retry_handler); in _backend_reschedule()
824 _set_main_event(be, be->event_thread->base, EV_WRITE, &tmp_time, _backend_handler); in _backend_reschedule()
1094 … _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_bevalidate_tls_handler); in proxy_bevalidate_tls_handler()
1115 … _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_bevalidate_tls_handler); in proxy_bevalidate_tls_handler()
1139 … _set_main_event(be, be->event_thread->base, EV_READ|EV_PERSIST, NULL, proxy_backend_tls_handler); in proxy_bevalidate_tls_handler()
1190 _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_beconn_tls_handler); in proxy_beconn_tls_handler()
1200 … _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_bevalidate_tls_handler); in proxy_beconn_tls_handler()
1236 _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_beconn_handler); in proxy_beconn_handler()
1264 … _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_beconn_handler); in proxy_beconn_handler()
1289 _set_main_event(be, be->event_thread->base, EV_READ, &tmp_time, proxy_beconn_handler); in proxy_beconn_handler()
1309 … _set_main_event(be, be->event_thread->base, EV_READ|EV_PERSIST, NULL, proxy_backend_handler); in proxy_beconn_handler()
1444 void proxy_init_event_thread(proxy_event_thread_t *t, proxy_ctx_t *ctx, struct event_base *base) { in proxy_init_event_thread() argument
1490 if (base == NULL) { in proxy_init_event_thread()
1494 t->base = event_base_new_with_config(ev_config); in proxy_init_event_thread()
1496 if (! t->base) { in proxy_init_event_thread()
1502 t->base = base; in proxy_init_event_thread()
1520 event_base_set(t->base, &t->notify_event); in proxy_init_event_thread()
1525 event_base_set(t->base, &t->beconn_event); in proxy_init_event_thread()