Lines Matching refs:thread
588 p->thread->proxy_vm_extra_kb += kb > 0 ? kb : 1; in proxy_return_rctx_cb()
607 do_cache_free(p->thread->io_cache, p); in proxy_return_rctx_cb()
706 LIBEVENT_THREAD *thr = c->thread; in complete_nread_proxy()
1008 LIBEVENT_THREAD *thr = c->thread; in proxy_process_command()
1021 WSTAT_INCR(c->thread, proxy_conn_errors, 1); in proxy_process_command()
1134 WSTAT_INCR(c->thread, proxy_conn_errors, 1); in proxy_process_command()
1152 struct proxy_int_stats *istats = c->thread->proxy_int_stats; in proxy_process_command()
1154 WSTAT_L(c->thread); in proxy_process_command()
1156 c->thread->stats.proxy_conn_requests++; in proxy_process_command()
1157 active_reqs = c->thread->stats.proxy_req_active; in proxy_process_command()
1158 WSTAT_UL(c->thread); in proxy_process_command()
1199 bool oom = proxy_bufmem_checkadd(c->thread, 0); in proxy_process_command()
1238 r->thread = t; in mcp_prep_bare_resobj()
1239 assert(r->thread != NULL); in mcp_prep_bare_resobj()
1252 r->thread = t; in mcp_set_resobj()
1253 assert(r->thread != NULL); in mcp_set_resobj()
1309 io_pending_proxy_t *p = do_cache_alloc(c->thread->io_cache); in mcp_queue_rctx_io()
1311 WSTAT_INCR(c->thread, proxy_conn_oom, 1); in mcp_queue_rctx_io()
1323 p->thread = c->thread; in mcp_queue_rctx_io()