Lines Matching refs:event_thread

198                 mcp_sharedvm_delta(bec->event_thread->ctx, SHAREDVM_BACKEND_IDX,  in _cleanup_backend()
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()
326 proxy_ctx_t *ctx = bec->event_thread->ctx; in proxy_run_backend_queue()
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()
809 STAT_INCR(be->event_thread->ctx, backend_marked_bad, 1); in _backend_reschedule()
810 mcp_sharedvm_delta(be->event_thread->ctx, SHAREDVM_BACKEND_IDX, in _backend_reschedule()
815 … _set_main_event(be, be->event_thread->base, EV_TIMEOUT, &tmp_time, proxy_backend_retry_handler); in _backend_reschedule()
818 STAT_INCR(be->event_thread->ctx, backend_failed, 1); 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()
1147 mcp_sharedvm_delta(be->event_thread->ctx, SHAREDVM_BACKEND_IDX, 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()
1317 mcp_sharedvm_delta(be->event_thread->ctx, SHAREDVM_BACKEND_IDX, in proxy_beconn_handler()