Home
last modified time | relevance | path

Searched refs:LIBEVENT_THREAD (Results 1 – 18 of 18) sorted by relevance

/memcached-1.6.32/
Dproto_proxy.h13 void proxy_thread_init(void *ctx, LIBEVENT_THREAD *thr);
20 void proxy_worker_reload(void *arg, LIBEVENT_THREAD *thr);
21 void proxy_gc_poke(LIBEVENT_THREAD *t);
27 int proxy_register_libs(void *ctx, LIBEVENT_THREAD *t, void *state);
Dthread.c92 static LIBEVENT_THREAD *threads;
420 static void setup_thread(LIBEVENT_THREAD *me) { in setup_thread()
508 LIBEVENT_THREAD *me = arg; in worker_libevent()
547 LIBEVENT_THREAD *me = arg; in thread_libevent_ionotify()
588 LIBEVENT_THREAD *me = arg; in thread_libevent_process()
689 LIBEVENT_THREAD *get_worker_thread(int id) { in get_worker_thread()
710 LIBEVENT_THREAD *thread; in reset_threads_napi_id()
727 LIBEVENT_THREAD *thread; in select_thread_by_napi_id()
776 LIBEVENT_THREAD *thread; in dispatch_conn_new()
817 void proxy_reload_notify(LIBEVENT_THREAD *t) { in proxy_reload_notify()
[all …]
Dmemcached.h762 } LIBEVENT_THREAD; typedef
804 LIBEVENT_THREAD *thread;
814 LIBEVENT_THREAD *thread;
903 LIBEVENT_THREAD *thread; /* Pointer to the thread object serving this connection */
950 enum delta_result_type do_add_delta(LIBEVENT_THREAD *t, const char *key,
956 void thread_io_queue_add(LIBEVENT_THREAD *t, int type, void *ctx, io_queue_stack_cb cb);
959 io_queue_cb_t *thread_io_queue_get(LIBEVENT_THREAD *t, int type);
989 void proxy_reload_notify(LIBEVENT_THREAD *t);
997 enum delta_result_type add_delta(LIBEVENT_THREAD *t, const char *key,
1032 LIBEVENT_THREAD *get_worker_thread(int id);
[all …]
Dsizes.c23 sizeof(LIBEVENT_THREAD) - sizeof(struct thread_stats)); in main()
31 display("libevent thread cumulative", sizeof(LIBEVENT_THREAD)); in main()
Dproxy.h268 #define PROXY_GET_THR_CTX(L) ((*(LIBEVENT_THREAD **)lua_getextraspace(L))->proxy_ctx)
269 #define PROXY_GET_THR(L) (*(LIBEVENT_THREAD **)lua_getextraspace(L))
496 LIBEVENT_THREAD *thread; // cresp's owner thread needed for extstore cleanup.
515 LIBEVENT_THREAD *thread;
595 bool proxy_bufmem_checkadd(LIBEVENT_THREAD *t, int len);
609 mcp_resp_t *mcp_prep_bare_resobj(lua_State *L, LIBEVENT_THREAD *t);
651 LIBEVENT_THREAD *thread; // worker thread that created this funcgen.
811 void mcp_request_cleanup(LIBEVENT_THREAD *t, mcp_request_t *rq);
834 void mcp_response_cleanup(LIBEVENT_THREAD *t, mcp_resp_t *r);
835 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t);
[all …]
Ditems.h73 item *do_item_get(const char *key, const size_t nkey, const uint32_t hv, LIBEVENT_THREAD *t, const …
74 …touch(const char *key, const size_t nkey, uint32_t exptime, const uint32_t hv, LIBEVENT_THREAD *t);
75 void do_item_bump(LIBEVENT_THREAD *t, item *it, const uint32_t hv);
Dproxy_result.c122 void mcp_response_cleanup(LIBEVENT_THREAD *t, mcp_resp_t *r) { in mcp_response_cleanup()
149 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_response_gc()
160 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_response_close()
Dproxy_config.c239 LIBEVENT_THREAD *thr = get_worker_thread(x); in proxy_config_reload()
515 static int _copy_pool(lua_State *from, lua_State *to, LIBEVENT_THREAD *thr) { 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()
627 void proxy_worker_reload(void *arg, LIBEVENT_THREAD *thr) { in proxy_worker_reload()
640 int proxy_thread_loadconf(proxy_ctx_t *ctx, LIBEVENT_THREAD *thr) { in proxy_thread_loadconf()
Dproxy_internal.c140 static int proxy_storage_get(LIBEVENT_THREAD *t, item *it, mc_resp *resp, in proxy_storage_get()
228 static void process_get_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, bool return_cas, b… in process_get_cmd()
309 static void process_update_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, int comm, bool … in process_update_cmd()
420 static void process_arithmetic_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, const bool … in process_arithmetic_cmd()
464 static void process_delete_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_delete_cmd()
505 static void process_touch_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_touch_cmd()
747 static void process_mget_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mget_cmd()
1055 static void process_mset_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mset_cmd()
1265 static void process_mdelete_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mdelete_cmd()
1410 static void process_marithmetic_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_marithmetic_cmd()
[all …]
Dproto_proxy.c22 static inline void _proxy_advance_lastkb(lua_State *L, LIBEVENT_THREAD *t) { in _proxy_advance_lastkb()
49 void proxy_gc_poke(LIBEVENT_THREAD *t) { in proxy_gc_poke()
117 LIBEVENT_THREAD *t = arg; in proxy_gc_timerpoke()
140 bool proxy_bufmem_checkadd(LIBEVENT_THREAD *t, int len) { in proxy_bufmem_checkadd()
195 LIBEVENT_THREAD *t = get_worker_thread(x); in process_proxy_stats()
425 void proxy_thread_init(void *ctx, LIBEVENT_THREAD *thr) { in proxy_thread_init()
706 LIBEVENT_THREAD *thr = c->thread; in complete_nread_proxy()
1008 LIBEVENT_THREAD *thr = c->thread; in proxy_process_command()
1233 mcp_resp_t *mcp_prep_bare_resobj(lua_State *L, LIBEVENT_THREAD *t) { in mcp_prep_bare_resobj()
1248 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t) { in mcp_set_resobj()
[all …]
Dproxy_ustats.c77 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_stat()
Dproxy_lua.c801 LIBEVENT_THREAD *t = get_worker_thread(n); in _mcplib_pool_make_be()
1223 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_attach()
1356 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_log()
1364 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_log_req()
1423 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_log_reqsample()
1560 int proxy_register_libs(void *ctx, LIBEVENT_THREAD *t, void *state) { in proxy_register_libs()
Dproxy_luafgen.c124 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcp_rcontext_cleanup()
303 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in _mcplib_funcgen_gencall()
492 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcp_funcgen_cleanup()
604 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_funcgen_new()
1928 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_router_new()
Dproxy_request.c615 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_request()
1171 void mcp_request_cleanup(LIBEVENT_THREAD *t, mcp_request_t *rq) { in mcp_request_cleanup()
1187 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_request_gc()
Dmemcached.c568 void thread_io_queue_add(LIBEVENT_THREAD *t, int type, void *ctx, io_queue_stack_cb cb) { in thread_io_queue_add()
600 io_queue_cb_t *thread_io_queue_get(LIBEVENT_THREAD *t, int type) { in thread_io_queue_get()
997 LIBEVENT_THREAD *t = resp->bundle->thread; in resp_reset()
1038 LIBEVENT_THREAD *th = c->thread; in resp_allocate()
1099 void resp_free(LIBEVENT_THREAD *th, mc_resp *resp) { in resp_free()
1214 LIBEVENT_THREAD *t = resp->bundle->thread; in resp_finish()
1570 enum store_item_type do_store_item(item *it, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int *… in do_store_item()
2219 item* limited_get(const char *key, size_t nkey, LIBEVENT_THREAD *t, uint32_t exptime, bool should_t… in limited_get()
2240 item* limited_get_locked(const char *key, size_t nkey, LIBEVENT_THREAD *t, bool do_update, uint32_t… in limited_get_locked()
2265 enum delta_result_type do_add_delta(LIBEVENT_THREAD *t, const char *key, const size_t nkey,
Ditems.c980 item *do_item_get(const char *key, const size_t nkey, const uint32_t hv, LIBEVENT_THREAD *t, const … in do_item_get()
1065 void do_item_bump(LIBEVENT_THREAD *t, item *it, const uint32_t hv) { in do_item_bump()
1093 const uint32_t hv, LIBEVENT_THREAD *t) { in do_item_touch()
Dproxy_mutator.c992 LIBEVENT_THREAD *t = PROXY_GET_THR(run->L); in mcp_mut_run()
Dstorage.c33 LIBEVENT_THREAD *thread;