157     proxy_ctx_t *ctx = arg;  in proxy_stats()  local
159     STAT_L(ctx);  in proxy_stats()
160 … APPEND_STAT("proxy_config_reloads", "%llu", (unsigned long long)ctx->global_stats.config_reloads);  in proxy_stats()
161 …APPEND_STAT("proxy_config_reload_fails", "%llu", (unsigned long long)ctx->global_stats.config_relo…  in proxy_stats()
162 …APPEND_STAT("proxy_config_cron_runs", "%llu", (unsigned long long)ctx->global_stats.config_cron_ru…  in proxy_stats()
163 …APPEND_STAT("proxy_config_cron_fails", "%llu", (unsigned long long)ctx->global_stats.config_cron_f…  in proxy_stats()
164     APPEND_STAT("proxy_backend_total", "%llu", (unsigned long long)ctx->global_stats.backend_total);  in proxy_stats()
165 …APPEND_STAT("proxy_backend_marked_bad", "%llu", (unsigned long long)ctx->global_stats.backend_mark…  in proxy_stats()
166 … APPEND_STAT("proxy_backend_failed", "%llu", (unsigned long long)ctx->global_stats.backend_failed);  in proxy_stats()
167 …APPEND_STAT("proxy_request_failed_depth", "%llu", (unsigned long long)ctx->global_stats.request_fa…  in proxy_stats()
168     STAT_UL(ctx);  in proxy_stats()
181     proxy_ctx_t *ctx = arg;  in process_proxy_stats()  local
182     STAT_L(ctx);  in process_proxy_stats()
183     req_limit = ctx->active_req_limit;  in process_proxy_stats()
184     buffer_memory_limit = ctx->buffer_memory_limit;  in process_proxy_stats()
187     struct proxy_user_stats_entry *us = ctx->user_stats;  in process_proxy_stats()
188     int stats_num = ctx->user_stats_num;  in process_proxy_stats()
216     if (ctx->user_stats_namebuf) {  in process_proxy_stats()
223                 char *name = ctx->user_stats_namebuf + us[x].cname;  in process_proxy_stats()
244     STAT_UL(ctx);  in process_proxy_stats()
290     proxy_ctx_t *ctx = arg;  in process_proxy_funcstats()  local
291     lua_State *L = ctx->proxy_sharedvm;  in process_proxy_funcstats()
292     pthread_mutex_lock(&ctx->sharedvm_lock);  in process_proxy_funcstats()
318     pthread_mutex_unlock(&ctx->sharedvm_lock);  in process_proxy_funcstats()
326     proxy_ctx_t *ctx = arg;  in process_proxy_bestats()  local
327     lua_State *L = ctx->proxy_sharedvm;  in process_proxy_bestats()
328     pthread_mutex_lock(&ctx->sharedvm_lock);  in process_proxy_bestats()
349     pthread_mutex_unlock(&ctx->sharedvm_lock);  in process_proxy_bestats()
354     proxy_ctx_t *ctx = calloc(1, sizeof(proxy_ctx_t));  in proxy_init()  local
355     ctx->use_uring = use_uring;  in proxy_init()
356     ctx->memprofile = proxy_memprofile;  in proxy_init()
358     pthread_mutex_init(&ctx->config_lock, NULL);  in proxy_init()
359     pthread_cond_init(&ctx->config_cond, NULL);  in proxy_init()
360     pthread_mutex_init(&ctx->worker_lock, NULL);  in proxy_init()
361     pthread_cond_init(&ctx->worker_cond, NULL);  in proxy_init()
362     pthread_mutex_init(&ctx->manager_lock, NULL);  in proxy_init()
363     pthread_cond_init(&ctx->manager_cond, NULL);  in proxy_init()
364     pthread_mutex_init(&ctx->stats_lock, NULL);  in proxy_init()
366     ctx->active_req_limit = UINT64_MAX;  in proxy_init()
367     ctx->buffer_memory_limit = UINT64_MAX;  in proxy_init()
370     ctx->tunables.tcp_keepalive = false;  in proxy_init()
371     ctx->tunables.backend_failure_limit = 3;  in proxy_init()
372     ctx->tunables.connect.tv_sec = 5;  in proxy_init()
373     ctx->tunables.retry.tv_sec = 3;  in proxy_init()
374     ctx->tunables.read.tv_sec = 3;  in proxy_init()
375     ctx->tunables.flap_backoff_ramp = 1.5;  in proxy_init()
376     ctx->tunables.flap_backoff_max = 3600;  in proxy_init()
377     ctx->tunables.backend_depth_limit = 0;  in proxy_init()
378     ctx->tunables.max_ustats = MAX_USTATS_DEFAULT;  in proxy_init()
379     ctx->tunables.use_iothread = false;  in proxy_init()
380     ctx->tunables.use_tls = false;  in proxy_init()
382     STAILQ_INIT(&ctx->manager_head);  in proxy_init()
384     if (ctx->memprofile) {  in proxy_init()
386         prof->id = ctx->memprofile_thread_counter++;  in proxy_init()
391     ctx->proxy_state = L;  in proxy_init()
394     proxy_register_libs(ctx, NULL, L);  in proxy_init()
397     ctx->cron_ref = luaL_ref(L, LUA_REGISTRYINDEX);  in proxy_init()
398     ctx->cron_next = INT_MAX;  in proxy_init()
402     pthread_mutex_init(&ctx->sharedvm_lock, NULL);  in proxy_init()
403     ctx->proxy_sharedvm = luaL_newstate();  in proxy_init()
404     luaL_openlibs(ctx->proxy_sharedvm);  in proxy_init()
407     lua_newtable(ctx->proxy_sharedvm); // fgen count  in proxy_init()
408     lua_newtable(ctx->proxy_sharedvm); // fgen slot count  in proxy_init()
409     lua_newtable(ctx->proxy_sharedvm); // backend down status  in proxy_init()
414     ctx->proxy_io_thread = t;  in proxy_init()
415     proxy_init_event_thread(t, ctx, NULL);  in proxy_init()
420     _start_proxy_config_threads(ctx);  in proxy_init()
421     return ctx;  in proxy_init()
425 void proxy_thread_init(void *ctx, LIBEVENT_THREAD *thr) {  in proxy_thread_init()  argument
426     assert(ctx != NULL);  in proxy_thread_init()
441     thr->proxy_ctx = ctx;  in proxy_thread_init()
444     proxy_ctx_t *pctx = ctx;  in proxy_thread_init()
464     proxy_register_libs(ctx, thr, L);  in proxy_thread_init()
477     proxy_init_event_thread(t, ctx, thr->base);  in proxy_thread_init()
484     proxy_event_thread_t *e = ((proxy_ctx_t *)q->ctx)->proxy_io_thread;  in proxy_submit_cb()
1011     proxy_ctx_t *ctx = thr->proxy_ctx;  in proxy_process_command()  local
1160     if (active_reqs >= ctx->active_req_limit) {  in proxy_process_command()
1170     mcp_rcontext_t *rctx = mcp_funcgen_start(L, hook_ref.ctx, &pr);  in proxy_process_command()
1362 void mcp_sharedvm_delta(proxy_ctx_t *ctx, int tidx, const char *name, int delta) {  in mcp_sharedvm_delta()  argument
1363     lua_State *L = ctx->proxy_sharedvm;  in mcp_sharedvm_delta()
1364     pthread_mutex_lock(&ctx->sharedvm_lock);  in mcp_sharedvm_delta()
1376     pthread_mutex_unlock(&ctx->sharedvm_lock);  in mcp_sharedvm_delta()
1379 void mcp_sharedvm_remove(proxy_ctx_t *ctx, int tidx, const char *name) {  in mcp_sharedvm_remove()  argument
1380     lua_State *L = ctx->proxy_sharedvm;  in mcp_sharedvm_remove()
1381     pthread_mutex_lock(&ctx->sharedvm_lock);  in mcp_sharedvm_remove()
1386     pthread_mutex_unlock(&ctx->sharedvm_lock);  in mcp_sharedvm_remove()
1397 static void mcp_gobj_enqueue(proxy_ctx_t *ctx, struct mcp_globalobj_s *g) {  in mcp_gobj_enqueue()  argument
1398     pthread_mutex_lock(&ctx->manager_lock);  in mcp_gobj_enqueue()
1399     STAILQ_INSERT_TAIL(&ctx->manager_head, g, next);  in mcp_gobj_enqueue()
1400     pthread_cond_signal(&ctx->manager_cond);  in mcp_gobj_enqueue()
1401     pthread_mutex_unlock(&ctx->manager_lock);  in mcp_gobj_enqueue()
1421         proxy_ctx_t *ctx = PROXY_GET_CTX(L);  in mcp_gobj_ref()  local
1422         mcp_gobj_enqueue(ctx, g);  in mcp_gobj_ref()
1430 void mcp_gobj_unref(proxy_ctx_t *ctx, struct mcp_globalobj_s *g) {  in mcp_gobj_unref()  argument
1434         mcp_gobj_enqueue(ctx, g);  in mcp_gobj_unref()