Home
last modified time | relevance | path

Searched refs:arg (Results 1 – 25 of 33) sorted by relevance

12

/memcached-1.6.32/t/
Dproxyfuncgen.lua67 o.wait = arg.wait
156 local t = arg.t
172 local t = arg.t
207 local t = arg.t
229 local t = arg.t
279 local t = arg.t
319 local t = arg.t
367 local t = arg.t
389 local t = arg.t
420 local t = arg.t
[all …]
Dproxyantiflap.lua14 local arg = { label = 'b1', host = '127.0.0.1', port = 11799 }
17 return mcp.pool({mcp.backend(arg)})
20 return mcp.pool({mcp.backend(arg)})
Dproxymut.lua43 { t = "valcopy", idx = 2, arg = "string" }
/memcached-1.6.32/
Dproto_proxy.h4 void proxy_stats(void *arg, ADD_STAT add_stats, void *c);
5 void process_proxy_stats(void *arg, ADD_STAT add_stats, void *c);
6 void process_proxy_funcstats(void *arg, ADD_STAT add_stats, void *c);
7 void process_proxy_bestats(void *arg, ADD_STAT add_stats, void *c);
17 void proxy_start_reload(void *arg);
18 int proxy_first_confload(void *arg);
19 int proxy_load_config(void *arg);
20 void proxy_worker_reload(void *arg, LIBEVENT_THREAD *thr);
Dslab_automove.h6 void slab_automove_free(void *arg);
7 void slab_automove_run(void *arg, int *src, int *dst);
10 typedef void (*slab_automove_free_func)(void *arg);
11 typedef void (*slab_automove_run_func)(void *arg, int *src, int *dst);
Dproxy_inspector.c203 mcp_request_t *rq = arg; in mcp_inspector_sepkey_r()
267 mcp_request_t *rq = arg; in mcp_inspector_keybegin_r()
284 mcp_request_t *rq = arg; in mcp_inspector_keyis_r()
303 mcp_request_t *rq = arg; in mcp_inspector_hasflag_r()
311 mcp_resp_t *res = arg; in mcp_inspector_hasflag_r()
333 mcp_request_t *rq = arg; in mcp_inspector_flagtoken_r()
344 mcp_resp_t *res = arg; in mcp_inspector_flagtoken_r()
367 mcp_request_t *rq = arg; in mcp_inspector_flagint_r()
380 mcp_resp_t *res = arg; in mcp_inspector_flagint_r()
439 mcp_request_t *rq = arg; in mcp_inspector_flagis_r()
[all …]
Dstorage.h24 int start_storage_write_thread(void *arg);
27 int start_storage_compact_thread(void *arg);
32 struct extstore_conf_file *storage_conf_parse(char *arg, unsigned int page_size);
Dslab_automove_extstore.h5 void slab_automove_extstore_free(void *arg);
6 void slab_automove_extstore_run(void *arg, int *src, int *dst);
Dproxy_network.c251 proxy_event_thread_t *t = arg; in proxy_event_beconn()
363 proxy_event_thread_t *t = arg; in proxy_event_handler()
392 void *proxy_event_thread(void *arg) { in proxy_event_thread() argument
393 proxy_event_thread_t *t = arg; in proxy_event_thread()
768 struct mcp_backendconn_s *be = arg; in proxy_backend_retry_handler()
1068 assert(arg != NULL); in proxy_bevalidate_tls_handler()
1069 struct mcp_backendconn_s *be = arg; in proxy_bevalidate_tls_handler()
1158 assert(arg != NULL); in proxy_beconn_tls_handler()
1159 struct mcp_backendconn_s *be = arg; in proxy_beconn_tls_handler()
1210 assert(arg != NULL); in proxy_beconn_handler()
[all …]
Dproxy_config.c50 void proxy_start_reload(void *arg) { in proxy_start_reload() argument
51 proxy_ctx_t *ctx = arg; in proxy_start_reload()
59 int proxy_first_confload(void *arg) { in proxy_first_confload() argument
60 proxy_ctx_t *ctx = arg; in proxy_first_confload()
88 static void *_proxy_manager_thread(void *arg) { in _proxy_manager_thread() argument
89 proxy_ctx_t *ctx = arg; in _proxy_manager_thread()
349 static void *_proxy_config_thread(void *arg) { in _proxy_config_thread() argument
350 proxy_ctx_t *ctx = arg; in _proxy_config_thread()
483 int proxy_load_config(void *arg) { in proxy_load_config() argument
484 proxy_ctx_t *ctx = arg; in proxy_load_config()
[all …]
Dslab_automove.c55 void slab_automove_free(void *arg) { in slab_automove_free() argument
56 slab_automove *a = (slab_automove *)arg; in slab_automove_free()
74 void slab_automove_run(void *arg, int *src, int *dst) { in slab_automove_run() argument
75 slab_automove *a = (slab_automove *)arg; in slab_automove_run()
Dthread.c106 static void thread_libevent_process(evutil_socket_t fd, short which, void *arg);
107 static void thread_libevent_ionotify(evutil_socket_t fd, short which, void *arg);
375 static void create_worker(void *(*func)(void *), void *arg) { in create_worker() argument
381 if ((ret = pthread_create(&((LIBEVENT_THREAD*)arg)->thread_id, &attr, func, arg)) != 0) { in create_worker()
387 thread_setname(((LIBEVENT_THREAD*)arg)->thread_id, "mc-worker"); in create_worker()
507 static void *worker_libevent(void *arg) { in worker_libevent() argument
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()
1082 void memcached_thread_init(int nthreads, void *arg) { in memcached_thread_init() argument
[all …]
Dslab_automove_extstore.c68 void slab_automove_extstore_free(void *arg) { in slab_automove_extstore_free() argument
69 slab_automove *a = (slab_automove *)arg; in slab_automove_extstore_free()
133 void slab_automove_extstore_run(void *arg, int *src, int *dst) { in slab_automove_extstore_run() argument
134 slab_automove *a = (slab_automove *)arg; in slab_automove_extstore_run()
Dtestapp.c523 int arg = 0; in start_server() local
535 argv[arg++] = tmo; in start_server()
538 argv[arg++] = "-A"; in start_server()
539 argv[arg++] = "-p"; in start_server()
540 argv[arg++] = "-1"; in start_server()
541 argv[arg++] = "-U"; in start_server()
542 argv[arg++] = "0"; in start_server()
545 argv[arg++] = "-Z"; in start_server()
563 argv[arg++] = "-vvv"; in start_server()
566 argv[arg++] = "-o"; in start_server()
[all …]
Dproxy_mutator.c95 enum mcp_mut_step_arg arg; // common: type of input argument member
126 void *arg; member
751 s->arg = mcp_mut_step_arg_request; in mut_step_i()
753 s->arg = mcp_mut_step_arg_response; in mut_step_i()
755 s->arg = mcp_mut_step_arg_string; in mut_step_i()
757 s->arg = mcp_mut_step_arg_int; in mut_step_i()
776 switch (s->arg) { in mut_step_n()
1002 mcp_request_t *rq = run->arg; in mcp_mut_run()
1034 mcp_resp_t *rs = run->arg; in mcp_mut_run()
1133 void *arg = lua_touserdata(L, 2); in mcplib_mutator_call() local
[all …]
Dproto_proxy.c117 LIBEVENT_THREAD *t = arg; in proxy_gc_timerpoke()
153 void proxy_stats(void *arg, ADD_STAT add_stats, void *c) { in proxy_stats() argument
154 if (arg == NULL) { in proxy_stats()
157 proxy_ctx_t *ctx = arg; in proxy_stats()
171 void process_proxy_stats(void *arg, ADD_STAT add_stats, void *c) { in process_proxy_stats() argument
178 if (!arg) { in process_proxy_stats()
181 proxy_ctx_t *ctx = arg; in process_proxy_stats()
287 if (!arg) { in process_proxy_funcstats()
290 proxy_ctx_t *ctx = arg; in process_proxy_funcstats()
323 if (!arg) { in process_proxy_bestats()
[all …]
Dcrawler.h34 int init_lru_crawler(void *arg);
Dslabs.h66 void slabs_set_storage(void *arg);
Dstorage.c591 static void *storage_write_thread(void *arg) { in storage_write_thread() argument
592 void *storage = arg; in storage_write_thread()
729 int start_storage_write_thread(void *arg) { in start_storage_write_thread() argument
734 storage_write_thread, arg)) != 0) { in start_storage_write_thread()
1056 static void *storage_compact_thread(void *arg) { in storage_compact_thread() argument
1057 void *storage = arg; in storage_compact_thread()
1171 int start_storage_compact_thread(void *arg) { in start_storage_compact_thread() argument
1177 storage_compact_thread, arg)) != 0) { in start_storage_compact_thread()
1190 struct extstore_conf_file *storage_conf_parse(char *arg, unsigned int page_size) { in storage_conf_parse() argument
1193 char *p = strtok_r(arg, ":", &b); in storage_conf_parse()
Dproxy_luafgen.c45 static void mcp_funcgen_wait_handler(const int fd, const short which, void *arg) { in mcp_funcgen_wait_handler() argument
46 mcp_rcontext_t *rctx = arg; in mcp_funcgen_wait_handler()
1162 static inline void _mcplib_set_rctx_alarm(lua_State *L, mcp_rcontext_t *rctx, int arg) { in _mcplib_set_rctx_alarm() argument
1164 lua_Number secondsf = lua_tonumberx(L, arg, &isnum); in _mcplib_set_rctx_alarm()
1690 static const char *_mcplib_router_new_check(lua_State *L, const char *arg, size_t *len) { in _mcplib_router_new_check() argument
1691 int type = lua_getfield(L, 1, arg); in _mcplib_router_new_check()
1695 proxy_lua_ferror(L, "must pass a non-zero length string to %s in mcp.router_new", arg); in _mcplib_router_new_check()
1697 proxy_lua_ferror(L, "%s is too long in mcp.router_new", arg); in _mcplib_router_new_check()
1702 proxy_lua_ferror(L, "must pass a string to %s in mcp.router_new", arg); in _mcplib_router_new_check()
Ditems.h79 int start_lru_maintainer_thread(void *arg);
Dcrawler.c523 static void *item_crawler_thread(void *arg) { in item_crawler_thread() argument
891 int init_lru_crawler(void *arg) { in init_lru_crawler() argument
894 storage = arg; in init_lru_crawler()
Dmemcached.c68 static ssize_t tcp_read(conn *arg, void *buf, size_t count);
69 static ssize_t tcp_sendmsg(conn *arg, struct msghdr *msg, int flags);
70 static ssize_t tcp_write(conn *arg, void *buf, size_t count);
95 static void event_handler(const evutil_socket_t fd, const short which, void *arg);
292 static void *conn_timeout_thread(void *arg) { in conn_timeout_thread() argument
3399 c = (conn *)arg;
4297 struct memcntl_mha arg = {0}; local
4306 arg.mha_flags = 0;
4307 arg.mha_pagesize = max;
4308 arg.mha_cmd = MHA_MAPSIZE_BSSBRK;
[all …]
/memcached-1.6.32/scripts/
Dstart-memcached73 my ($directive, $arg) = $line =~ /^(.*?)\s+(.*)/;
74 $conf_directives->{$directive}->($arg);
Dmemcached-tool43 my $arg = shift;
44 if ($arg eq '-u') {
47 $limit = $arg;

12