Home
last modified time | relevance | path

Searched refs:ctx (Results 1 – 19 of 19) sorted by relevance

/memcached-1.6.32/
Dlinux_priv.c61 scmp_filter_ctx ctx = seccomp_init(DENY_ACTION); in drop_privileges() local
62 if (ctx == NULL) { in drop_privileges()
86 rc |= seccomp_rule_add(ctx, SCMP_ACT_ALLOW, SCMP_SYS(brk), 0); in drop_privileges()
116 rc = seccomp_load(ctx); in drop_privileges()
121 seccomp_release(ctx); in drop_privileges()
125 seccomp_release(ctx); in drop_privileges()
131 scmp_filter_ctx ctx = seccomp_init(DENY_ACTION); in drop_worker_privileges() local
132 if (ctx == NULL) { in drop_worker_privileges()
203 rc = seccomp_load(ctx); in drop_worker_privileges()
208 seccomp_release(ctx); in drop_worker_privileges()
[all …]
Dproxy_config.c77 STAT_L(ctx); in proxy_first_confload()
79 STAT_UL(ctx); in proxy_first_confload()
96 pthread_cond_wait(&ctx->manager_cond, &ctx->manager_lock); in _proxy_manager_thread()
148 STAT_L(ctx); in proxy_config_stats_prep()
203 STAT_UL(ctx); in proxy_config_stats_prep()
247 pthread_cond_wait(&ctx->worker_cond, &ctx->worker_lock); in proxy_config_reload()
261 STAT_L(ctx); in proxy_config_reload()
265 STAT_UL(ctx); in proxy_config_reload()
386 pthread_cond_wait(&ctx->config_cond, &ctx->config_lock); in _start_proxy_config_threads()
689 STAT_L(ctx); in proxy_thread_loadconf()
[all …]
Dproxy_lua.c960 proxy_ctx_t *ctx = p->ctx; in mcplib_pool_proxy_gc() local
993 STAT_L(ctx); in mcplib_backend_use_iothread()
1009 STAT_L(ctx); in mcplib_backend_use_tls()
1033 STAT_L(ctx); in mcplib_tcp_keepalive()
1049 STAT_L(ctx); in mcplib_backend_failure_limit()
1065 STAT_L(ctx); in mcplib_backend_depth_limit()
1078 STAT_L(ctx); in mcplib_backend_connect_timeout()
1091 STAT_L(ctx); in mcplib_backend_retry_waittime()
1110 STAT_L(ctx); in mcplib_backend_read_timeout()
1124 STAT_L(ctx); in mcplib_backend_flap_time()
[all …]
Dproto_proxy.c157 proxy_ctx_t *ctx = arg; in proxy_stats() local
159 STAT_L(ctx); 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()
244 STAT_UL(ctx); in process_proxy_stats()
384 if (ctx->memprofile) { in proxy_init()
391 ctx->proxy_state = L; in proxy_init()
421 return ctx; in proxy_init()
426 assert(ctx != NULL); in proxy_thread_init()
[all …]
Dproxy_ustats.c10 proxy_ctx_t *ctx = PROXY_GET_CTX(L); in mcplib_add_stat() local
16 if (idx > ctx->tunables.max_ustats) { in mcplib_add_stat()
17 proxy_lua_ferror(L, "stat index must be %d or less", ctx->tunables.max_ustats); in mcplib_add_stat()
34 STAT_L(ctx); in mcplib_add_stat()
35 int stats_num = ctx->user_stats_num; in mcplib_add_stat()
36 struct proxy_user_stats_entry *entries = ctx->user_stats; in mcplib_add_stat()
47 ctx->user_stats = nentries; in mcplib_add_stat()
48 ctx->user_stats_num = idx; in mcplib_add_stat()
63 char *oldname = ctx->user_stats_namebuf + entries[idx].cname; in mcplib_add_stat()
71 STAT_UL(ctx); in mcplib_add_stat()
Drestart.c92 restart_cb_ctx ctx; in restart_check() local
94 ctx.f = f; in restart_check()
95 ctx.cb = NULL; in restart_check()
96 ctx.line = NULL; in restart_check()
97 ctx.done = false; in restart_check()
105 if (ctx.cb == NULL) { in restart_check()
112 while (!ctx.done) { in restart_check()
120 if (ctx.line) in restart_check()
121 free(ctx.line); in restart_check()
244 restart_cb_ctx ctx; in restart_save() local
[all …]
Drestart.h17 typedef int (*restart_check_cb)(const char *tag, void *ctx, void *data);
18 typedef int (*restart_save_cb)(const char *tag, void *ctx, void *data);
21 void restart_set_kv(void *ctx, const char *key, const char *fmt, ...);
22 enum restart_get_kv_ret restart_get_kv(void *ctx, char **key, char **val);
Dproxy_tls.h18 int mcp_tls_init(proxy_ctx_t *ctx);
19 int mcp_tls_backend_init(proxy_ctx_t *ctx, struct mcp_backendconn_s *be);
28 #define mcp_tls_init(ctx) argument
29 #define mcp_tls_backend_init(ctx, be) argument
Dproxy.h56 #define STAT_L(ctx) pthread_mutex_lock(&ctx->stats_lock); argument
57 #define STAT_UL(ctx) pthread_mutex_unlock(&ctx->stats_lock); argument
58 #define STAT_INCR(ctx, stat, amount) { \ argument
59 pthread_mutex_lock(&ctx->stats_lock); \
60 ctx->global_stats.stat += amount; \
64 #define STAT_DECR(ctx, stat, amount) { \ argument
65 pthread_mutex_lock(&ctx->stats_lock); \
66 ctx->global_stats.stat -= amount; \
299 void *ctx; member
481 proxy_ctx_t *ctx; // main context. member
[all …]
Dproxy_jump_hash.c10 static uint32_t mcplib_dist_jump_hash_get_server(uint64_t hash, void *ctx) { in mcplib_dist_jump_hash_get_server() argument
11 mcplib_jump_hash_t *jh = ctx; in mcplib_dist_jump_hash_get_server()
33 jh->phc.ctx = jh; in mcplib_dist_jump_hash_new()
Dproxy_tls.c24 int mcp_tls_init(proxy_ctx_t *ctx) { in mcp_tls_init() argument
25 if (ctx->tls_ctx) { in mcp_tls_init()
40 ctx->tls_ctx = tctx; in mcp_tls_init()
44 int mcp_tls_backend_init(proxy_ctx_t *ctx, struct mcp_backendconn_s *be) { in mcp_tls_backend_init() argument
49 SSL *ssl = SSL_new(ctx->tls_ctx); in mcp_tls_backend_init()
Dproto_proxy.h13 void proxy_thread_init(void *ctx, LIBEVENT_THREAD *thr);
27 int proxy_register_libs(void *ctx, LIBEVENT_THREAD *t, void *state);
Dproxy_network.c198 mcp_sharedvm_delta(bec->event_thread->ctx, SHAREDVM_BACKEND_IDX, in _cleanup_backend()
326 proxy_ctx_t *ctx = bec->event_thread->ctx; in proxy_run_backend_queue() local
327 STAT_INCR(ctx, request_failed_depth, be->depth); in proxy_run_backend_queue()
809 STAT_INCR(be->event_thread->ctx, backend_marked_bad, 1); in _backend_reschedule()
810 mcp_sharedvm_delta(be->event_thread->ctx, SHAREDVM_BACKEND_IDX, in _backend_reschedule()
818 STAT_INCR(be->event_thread->ctx, backend_failed, 1); in _backend_reschedule()
1147 mcp_sharedvm_delta(be->event_thread->ctx, SHAREDVM_BACKEND_IDX, in proxy_bevalidate_tls_handler()
1317 mcp_sharedvm_delta(be->event_thread->ctx, SHAREDVM_BACKEND_IDX, in proxy_beconn_handler()
1444 void proxy_init_event_thread(proxy_event_thread_t *t, proxy_ctx_t *ctx, struct event_base *base) { in proxy_init_event_thread() argument
1445 t->ctx = ctx; in proxy_init_event_thread()
[all …]
Dproxy_ratelim.c35 proxy_ctx_t *ctx = PROXY_GET_THR_CTX(L); in mcplib_ratelim_proxy_tbf_gc() local
36 mcp_gobj_unref(ctx, &lim->g); in mcplib_ratelim_proxy_tbf_gc()
Dproxy_ring_hash.c89 static uint32_t ketama_get_server(uint64_t hash, void *ctx) { in ketama_get_server() argument
90 ketama_t *kt = (ketama_t *)ctx; in ketama_get_server()
349 kt->phc.ctx = kt; in ketama_new()
Dmemcached.c574 q->ctx = ctx; in thread_io_queue_add()
584 q->ctx = qcb->ctx; in conn_io_queue_setup()
4450 static int _mc_meta_save_cb(const char *tag, void *ctx, void *data) { argument
4462 restart_set_kv(ctx, "slab_config", "%s", meta->slab_config);
4464 restart_set_kv(ctx, "chunk_size", "%d", settings.chunk_size);
4478 restart_set_kv(ctx, "current_time", "%u", current_time);
4485 restart_set_kv(ctx, "stop_time", "%lu", tv.tv_sec);
4491 restart_set_kv(ctx, "logger_gid", "%llu", logger_get_gid());
4496 restart_set_kv(ctx, "oldest_live", "%u", settings.oldest_live);
4498 restart_set_kv(ctx, "mmap_oldbase", "%p", meta->mmap_base);
[all …]
Dmemcached.h695 void *ctx; // duplicated from io_queue_cb_t member
702 void *ctx; // untouched ptr for specific context member
956 void thread_io_queue_add(LIBEVENT_THREAD *t, int type, void *ctx, io_queue_stack_cb cb);
Dstorage.c386 extstore_submit(q->ctx, q->stack_ctx); in storage_submit_cb()
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c759 mcmc_ctx_t *ctx = (mcmc_ctx_t *)c; in mcmc_fd() local
760 return ctx->fd; in mcmc_fd()
780 mcmc_ctx_t *ctx = (mcmc_ctx_t *)c; in mcmc_check_nonblock_connect() local
801 mcmc_ctx_t *ctx = (mcmc_ctx_t *)c; in mcmc_connect() local
815 ctx->fd = 0; in mcmc_connect()
824 ctx->gai_status = s; in mcmc_connect()
881 ctx->fd = sock; in mcmc_connect()
913 ctx->sent_bytes_partial = 0; in mcmc_send_request()
1067 if (ctx->fd != 0) { in mcmc_disconnect()
1068 close(ctx->fd); in mcmc_disconnect()
[all …]