56 … mcp_backendconn_s *be, struct event_base *base, int flags, struct timeval *t, event_callback_fn c…
142 static void _proxy_event_handler_dequeue(proxy_event_thread_t *t) {  in _proxy_event_handler_dequeue()  argument
146     STAILQ_INIT(&t->be_head);  in _proxy_event_handler_dequeue()
149     pthread_mutex_lock(&t->mutex);  in _proxy_event_handler_dequeue()
150     STAILQ_CONCAT(&head, &t->io_head_in);  in _proxy_event_handler_dequeue()
151     pthread_mutex_unlock(&t->mutex);  in _proxy_event_handler_dequeue()
168             STAILQ_INSERT_TAIL(&t->be_head, be, be_next);  in _proxy_event_handler_dequeue()
251     proxy_event_thread_t *t = arg;  in proxy_event_beconn()  local
270     pthread_mutex_lock(&t->mutex);  in proxy_event_beconn()
271     STAILQ_CONCAT(&head, &t->beconn_head_in);  in proxy_event_beconn()
272     pthread_mutex_unlock(&t->mutex);  in proxy_event_beconn()
363     proxy_event_thread_t *t = arg;  in proxy_event_handler()  local
386     _proxy_event_handler_dequeue(t);  in proxy_event_handler()
389     proxy_run_backend_queue(&t->be_head);  in proxy_event_handler()
393     proxy_event_thread_t *t = arg;  in proxy_event_thread()  local
396     event_base_loop(t->base, 0);  in proxy_event_thread()
397     event_base_free(t->base);  in proxy_event_thread()
404 … mcp_backendconn_s *be, struct event_base *base, int flags, struct timeval *t, event_callback_fn c…  in _set_main_event()  argument
417     event_add(&be->main_event, t);  in _set_main_event()
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
1445     t->ctx = ctx;  in proxy_init_event_thread()
1447     t->event_fd = eventfd(0, EFD_NONBLOCK);  in proxy_init_event_thread()
1448     if (t->event_fd == -1) {  in proxy_init_event_thread()
1452     t->be_event_fd = eventfd(0, EFD_NONBLOCK);  in proxy_init_event_thread()
1453     if (t->be_event_fd == -1) {  in proxy_init_event_thread()
1464     t->notify_receive_fd = fds[0];  in proxy_init_event_thread()
1465     t->notify_send_fd = fds[1];  in proxy_init_event_thread()
1471     t->be_notify_receive_fd = fds[0];  in proxy_init_event_thread()
1472     t->be_notify_send_fd = fds[1];  in proxy_init_event_thread()
1476     STAILQ_INIT(&t->io_head_in);  in proxy_init_event_thread()
1477     STAILQ_INIT(&t->beconn_head_in);  in proxy_init_event_thread()
1478     pthread_mutex_init(&t->mutex, NULL);  in proxy_init_event_thread()
1479     pthread_cond_init(&t->cond, NULL);  in proxy_init_event_thread()
1484     if (t->ctx->use_uring) {  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()
1509     event_set(&t->notify_event, t->event_fd,  in proxy_init_event_thread()
1510           EV_READ | EV_PERSIST, proxy_event_handler, t);  in proxy_init_event_thread()
1511     event_set(&t->beconn_event, t->be_event_fd,  in proxy_init_event_thread()
1512           EV_READ | EV_PERSIST, proxy_event_beconn, t);  in proxy_init_event_thread()
1514     event_set(&t->notify_event, t->notify_receive_fd,  in proxy_init_event_thread()
1515           EV_READ | EV_PERSIST, proxy_event_handler, t);  in proxy_init_event_thread()
1516     event_set(&t->beconn_event, t->be_notify_receive_fd,  in proxy_init_event_thread()
1517           EV_READ | EV_PERSIST, proxy_event_beconn, t);  in proxy_init_event_thread()
1520     event_base_set(t->base, &t->notify_event);  in proxy_init_event_thread()
1521     if (event_add(&t->notify_event, 0) == -1) {  in proxy_init_event_thread()
1525     event_base_set(t->base, &t->beconn_event);  in proxy_init_event_thread()
1526     if (event_add(&t->beconn_event, 0) == -1) {  in proxy_init_event_thread()