Searched refs:proxy_event_thread_t (Results 1 – 5 of 5) sorted by relevance
169 typedef struct proxy_event_thread_s proxy_event_thread_t; typedef232 proxy_event_thread_t *proxy_io_thread;404 proxy_event_thread_t *event_thread; // event thread owning this backend.604 void proxy_init_event_thread(proxy_event_thread_t *t, proxy_ctx_t *ctx, struct event_base *base);
204 proxy_event_thread_t *et = be->event_thread; in mcp_tls_writev()
142 static void _proxy_event_handler_dequeue(proxy_event_thread_t *t) { in _proxy_event_handler_dequeue()251 proxy_event_thread_t *t = arg; in proxy_event_beconn()363 proxy_event_thread_t *t = arg; in proxy_event_handler()393 proxy_event_thread_t *t = arg; in proxy_event_thread()1444 void proxy_init_event_thread(proxy_event_thread_t *t, proxy_ctx_t *ctx, struct event_base *base) { in proxy_init_event_thread()
413 proxy_event_thread_t *t = calloc(1, sizeof(proxy_event_thread_t)); in proxy_init()475 proxy_event_thread_t *t = calloc(1, sizeof(proxy_event_thread_t)); in proxy_thread_init()484 proxy_event_thread_t *e = ((proxy_ctx_t *)q->ctx)->proxy_io_thread; in proxy_submit_cb()
262 proxy_event_thread_t *e = be->be[0].event_thread; in mcplib_backend_wrap_gc()521 proxy_event_thread_t *e) { in _mcplib_make_backendconn()746 static void _mcplib_pool_make_be_loop(lua_State *L, mcp_pool_t *p, int offset, proxy_event_thread_t… in _mcplib_pool_make_be_loop()