Lines Matching refs:thr
239 LIBEVENT_THREAD *thr = get_worker_thread(x); in proxy_config_reload() local
244 proxy_reload_notify(thr); in proxy_config_reload()
515 static int _copy_pool(lua_State *from, lua_State *to, LIBEVENT_THREAD *thr) { in _copy_pool() argument
527 pp->pool = &p->pool[thr->thread_baseid * p->pool_size]; in _copy_pool()
534 static void _copy_config_table(lua_State *from, lua_State *to, LIBEVENT_THREAD *thr);
537 static void _copy_config_table(lua_State *from, lua_State *to, LIBEVENT_THREAD *thr) { in _copy_config_table() argument
553 _copy_pool(from, to, thr); in _copy_config_table()
613 _copy_config_table(from, to, thr); // push next value. in _copy_config_table()
627 void proxy_worker_reload(void *arg, LIBEVENT_THREAD *thr) { in proxy_worker_reload() argument
630 if (proxy_thread_loadconf(ctx, thr) != 0) { in proxy_worker_reload()
640 int proxy_thread_loadconf(proxy_ctx_t *ctx, LIBEVENT_THREAD *thr) { in proxy_thread_loadconf() argument
641 lua_State *L = thr->L; in proxy_thread_loadconf()
680 _copy_config_table(ctx->proxy_state, L, thr); in proxy_thread_loadconf()
694 pthread_mutex_lock(&thr->stats.mutex); in proxy_thread_loadconf()
695 if (thr->proxy_user_stats == NULL) { in proxy_thread_loadconf()
697 thr->proxy_user_stats = tus; in proxy_thread_loadconf()
699 tus = thr->proxy_user_stats; in proxy_thread_loadconf()
722 pthread_mutex_unlock(&thr->stats.mutex); in proxy_thread_loadconf()
725 thr->proxy_active_req_limit = ctx->active_req_limit; in proxy_thread_loadconf()
729 pthread_mutex_lock(&thr->proxy_limit_lock); in proxy_thread_loadconf()
730 thr->proxy_buffer_memory_limit = ctx->buffer_memory_limit; in proxy_thread_loadconf()
731 pthread_mutex_unlock(&thr->proxy_limit_lock); in proxy_thread_loadconf()