Lines Matching refs:ctx

79     proxy_ctx_t *ctx = PROXY_GET_CTX(L);  in mcplib_server_stats()  local
99 process_proxy_stats(ctx, &_mcplib_append_stats, &c); in mcplib_server_stats()
101 process_proxy_funcstats(ctx, &_mcplib_append_stats, &c); in mcplib_server_stats()
103 process_proxy_bestats(ctx, &_mcplib_append_stats, &c); in mcplib_server_stats()
137 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_register_cron() local
148 ce->gen = ctx->config_generation; in mcplib_register_cron()
189 lua_rawgeti(L, LUA_REGISTRYINDEX, ctx->cron_ref); in mcplib_register_cron()
207 if (ctx->cron_next > ce->next) { in mcplib_register_cron()
208 ctx->cron_next = ce->next; in mcplib_register_cron()
218 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_schedule_config_reload() local
219 ctx->loading = true; in mcplib_schedule_config_reload()
250 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_wrap_gc() local
282 STAT_DECR(ctx, backend_total, 1); in mcplib_backend_wrap_gc()
301 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend() local
308 memcpy(&be->tunables, &ctx->tunables, sizeof(be->tunables)); in mcplib_backend()
522 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in _mcplib_make_backendconn() local
571 STAT_L(ctx); in _mcplib_make_backendconn()
572 if (ctx->tunables.tcp_keepalive) { in _mcplib_make_backendconn()
575 STAT_UL(ctx); in _mcplib_make_backendconn()
581 if (be->tunables.use_tls && !ctx->tls_ctx) { in _mcplib_make_backendconn()
586 mcp_tls_backend_init(ctx, bec); in _mcplib_make_backendconn()
615 STAT_INCR(ctx, backend_total, 1); in _mcplib_make_backendconn()
796 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in _mcplib_pool_make_be() local
797 _mcplib_pool_make_be_loop(L, p, 0, ctx->proxy_io_thread); in _mcplib_pool_make_be()
809 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_pool() local
821 p->use_iothread = ctx->tunables.use_iothread; in mcplib_pool()
825 p->ctx = PROXY_GET_CTX(L); in mcplib_pool()
960 proxy_ctx_t *ctx = p->ctx; in mcplib_pool_proxy_gc() local
961 pthread_mutex_lock(&ctx->manager_lock); in mcplib_pool_proxy_gc()
962 STAILQ_INSERT_TAIL(&ctx->manager_head, &p->g, next); in mcplib_pool_proxy_gc()
963 pthread_cond_signal(&ctx->manager_cond); in mcplib_pool_proxy_gc()
964 pthread_mutex_unlock(&ctx->manager_lock); in mcplib_pool_proxy_gc()
978 uint32_t lookup = p->phc.selector_func(hash, p->phc.ctx); in mcplib_pool_proxy_call_helper()
980 assert(p->phc.ctx != NULL); in mcplib_pool_proxy_call_helper()
991 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_use_iothread() local
993 STAT_L(ctx); in mcplib_backend_use_iothread()
994 ctx->tunables.use_iothread = state; in mcplib_backend_use_iothread()
995 STAT_UL(ctx); in mcplib_backend_use_iothread()
1003 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_use_tls() local
1009 STAT_L(ctx); in mcplib_backend_use_tls()
1010 ctx->tunables.use_tls = state; in mcplib_backend_use_tls()
1011 STAT_UL(ctx); in mcplib_backend_use_tls()
1021 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_init_tls()
1022 mcp_tls_init(ctx); in mcplib_init_tls()
1031 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_tcp_keepalive() local
1033 STAT_L(ctx); in mcplib_tcp_keepalive()
1034 ctx->tunables.tcp_keepalive = state; in mcplib_tcp_keepalive()
1035 STAT_UL(ctx); in mcplib_tcp_keepalive()
1042 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_failure_limit() local
1049 STAT_L(ctx); in mcplib_backend_failure_limit()
1050 ctx->tunables.backend_failure_limit = limit; in mcplib_backend_failure_limit()
1051 STAT_UL(ctx); in mcplib_backend_failure_limit()
1058 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_depth_limit() local
1065 STAT_L(ctx); in mcplib_backend_depth_limit()
1066 ctx->tunables.backend_depth_limit = limit; in mcplib_backend_depth_limit()
1067 STAT_UL(ctx); in mcplib_backend_depth_limit()
1076 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_connect_timeout() local
1078 STAT_L(ctx); in mcplib_backend_connect_timeout()
1079 ctx->tunables.connect.tv_sec = secondsi; in mcplib_backend_connect_timeout()
1080 ctx->tunables.connect.tv_usec = MICROSECONDS(subseconds); in mcplib_backend_connect_timeout()
1081 STAT_UL(ctx); in mcplib_backend_connect_timeout()
1088 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_retry_waittime() local
1091 STAT_L(ctx); in mcplib_backend_retry_waittime()
1092 ctx->tunables.retry.tv_sec = secondsi; in mcplib_backend_retry_waittime()
1093 ctx->tunables.retry.tv_usec = 0; in mcplib_backend_retry_waittime()
1094 STAT_UL(ctx); in mcplib_backend_retry_waittime()
1108 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_read_timeout() local
1110 STAT_L(ctx); in mcplib_backend_read_timeout()
1111 ctx->tunables.read.tv_sec = secondsi; in mcplib_backend_read_timeout()
1112 ctx->tunables.read.tv_usec = MICROSECONDS(subseconds); in mcplib_backend_read_timeout()
1113 STAT_UL(ctx); in mcplib_backend_read_timeout()
1122 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_flap_time() local
1124 STAT_L(ctx); in mcplib_backend_flap_time()
1125 ctx->tunables.flap.tv_sec = secondsi; in mcplib_backend_flap_time()
1126 ctx->tunables.flap.tv_usec = MICROSECONDS(subseconds); in mcplib_backend_flap_time()
1127 STAT_UL(ctx); in mcplib_backend_flap_time()
1134 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_flap_backoff_ramp() local
1139 STAT_L(ctx); in mcplib_backend_flap_backoff_ramp()
1140 ctx->tunables.flap_backoff_ramp = factor; in mcplib_backend_flap_backoff_ramp()
1141 STAT_UL(ctx); in mcplib_backend_flap_backoff_ramp()
1149 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_backend_flap_backoff_max() local
1151 STAT_L(ctx); in mcplib_backend_flap_backoff_max()
1152 ctx->tunables.flap_backoff_max = max; in mcplib_backend_flap_backoff_max()
1153 STAT_UL(ctx); in mcplib_backend_flap_backoff_max()
1159 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_stat_limit() local
1171 STAT_L(ctx); in mcplib_stat_limit()
1172 ctx->tunables.max_ustats = limit; in mcplib_stat_limit()
1173 STAT_UL(ctx); in mcplib_stat_limit()
1178 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_active_req_limit() local
1192 STAT_L(ctx); in mcplib_active_req_limit()
1193 ctx->active_req_limit = limit; in mcplib_active_req_limit()
1194 STAT_UL(ctx); in mcplib_active_req_limit()
1201 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_buffer_memory_limit() local
1214 ctx->buffer_memory_limit = limit; in mcplib_buffer_memory_limit()
1331 mcp_funcgen_dereference(L, href->ctx); in mcplib_attach()
1337 href->ctx = fgen; in mcplib_attach()
1560 int proxy_register_libs(void *ctx, LIBEVENT_THREAD *t, void *state) { in proxy_register_libs() argument
1792 *extra = ctx; in proxy_register_libs()