Home
last modified time | relevance | path

Searched refs:t (Results 1 – 25 of 61) sorted by relevance

123

/memcached-1.6.32/t/
Dproxyrequest.t27 $t->set_c($ps);
35 $t->clear();
41 $t->clear();
47 $t->clear();
51 $t->clear();
59 $t->clear();
65 $t->clear();
71 $t->clear();
77 $t->clear();
83 $t->clear();
[all …]
Dproxyfuncgen.t30 $t->set_c($ps);
31 $t->accept_backends();
63 $t->clear();
73 $t->clear();
79 $t->clear();
150 $t->clear();
166 $t->clear();
190 $t->clear();
207 $t->clear();
221 $t->clear();
[all …]
Dproxyins.t25 $t->set_c($ps);
26 $t->accept_backends();
44 $t->clear();
50 $t->clear();
56 $t->clear();
63 $t->clear();
69 $t->clear();
75 $t->clear();
85 $t->clear();
91 $t->clear();
[all …]
Dproxymatch.t25 $t->set_c($ps);
39 $t->clear();
50 $t->clear();
60 $t->clear();
70 $t->clear();
80 $t->clear();
91 $t->clear();
102 $t->clear();
112 $t->clear();
122 $t->clear();
[all …]
Dproxyrctxtimeout.t27 $t->set_c($ps);
36 $t->clear();
45 $t->clear();
56 $t->clear();
68 $t->clear();
78 $t->clear();
86 $t->clear();
96 $t->clear();
107 $t->clear();
115 $t->clear();
[all …]
Dproxyrouter.t30 $t->set_c($ps);
31 $t->accept_backends();
50 $t->clear();
74 $t->clear();
99 $t->c_recv_be();
103 $t->clear();
111 $t->c_recv_be();
118 $t->clear();
125 $t->c_recv_be();
129 $t->clear();
[all …]
Dproxymut.t25 $t->set_c($ps);
26 $t->accept_backends();
43 $t->c_recv_be();
44 $t->clear();
51 $t->c_recv_be();
52 $t->clear();
57 $t->c_recv("HD\r\n");
60 $t->c_recv("HD\r\n");
61 $t->clear();
68 $t->clear();
[all …]
Dproxyintext.t41 $t->set_c($ps);
56 $t->c_send("mg top/a v f Oa2\r\n");
58 $t->c_recv("hi\r\n", "payload received");
59 $t->clear();
67 $t->c_send("mg split/b v f Ob2\r\n");
70 $t->clear();
80 $t->c_recv("HD\r\n");
86 $t->clear();
90 $t->c_send("mg top/1 f v\r\n");
92 $t->c_recv("$value\r\n", "value received");
[all …]
Dproxyslotcache.t28 $t->set_c($ps);
29 $t->accept_backends();
32 $t->c_send("mg one/collect\r\n");
53 $t->c_send($fcmd);
61 $t->be_send(0, "HD\r\n");
67 $t->clear();
79 $t->be_send(0, "HD\r\n");
91 $t->be_send(0, "HD\r\n");
104 $t->be_send(0, "HD\r\n");
158 $t->c_send($fcmd);
[all …]
Dproxytags.t19 my $t = Memcached::ProxyTest->new(servers => [12050]);
29 $t->set_c($ps);
30 $t->accept_backends();
40 $t->set_c($ps);
41 $t->c_send("mg foo t\r\n");
42 $t->be_recv_c(0, 'backend received pass-thru cmd');
43 $t->be_send(0, "HD t97\r\n");
48 $t->set_c($tagpsb);
49 $t->c_send("mg bar t\r\n");
55 $t->set_c($tagpsc);
[all …]
Dproxyfuncgen.lua156 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
468 local t = {}
[all …]
Dproxyins.lua11 { t = "sepkey", sep = "/", pos = 2, map = {
14 { t = "keybegin", str = "sepkey" }
18 { t = "sepkey", sep = "/", pos = 2 }
75 { t = "hasflag", flag = "f" },
76 { t = "hasflag", flag = "t" }
80 { t = "flagtoken", flag = "O" },
81 { t = "flagint", flag = "t" }
85 { t = "flagtoken", flag = "O" },
86 { t = "flagint", flag = "T" }
103 has_O, O, has_t, t)
[all …]
Dproxymut.lua21 { t = "cmdset", cmd = "mg" },
22 { t = "keyset", str = "override" }
27 { t = "cmdset", cmd = "mg" },
28 { t = "keyset", str = "override" },
29 { t = "flagset", flag = "s" },
30 { t = "flagset", flag = "t" },
32 { t = "flagset", flag = "N", val = 33 }
37 { t = "rescodeset", str = "HD" }
42 { t = "rescodeset", str = "VA" },
48 { t = "rescodeset", str = "HD" },
[all …]
Dproxybestats.t20 my $t = Memcached::ProxyTest->new(servers => [12131, 12132, 12133]);
26 $t->set_c($ps);
27 $t->accept_backends();
33 $t->close_backend(0);
44 while ($t->srv_accept_waiting(0, 1)) {
45 $t->accept_backend(0);
50 $t->close_backend(1);
51 $t->close_backend(2);
57 while ($t->srv_accept_waiting($_, 1)) {
58 $t->accept_backend($_);
Dproxyunits.lua37 local o = { t = {}, c = 0 }
39 o.t.z1 = fgen:new_handle(zones.z1)
40 o.t.z2 = fgen:new_handle(zones.z2)
41 o.t.z3 = fgen:new_handle(zones.z3)
42 o.t.dead = fgen:new_handle(zones.dead)
43 o.t.no_label = fgen:new_handle(zones.no_label)
55 return rctx:enqueue_and_wait(r, a.t.z1)
87 return rctx:enqueue_and_wait(r, a.t.z1)
94 return rctx:enqueue_and_wait(r, a.t.z1)
423 local z = {a.t.z1, a.t.z2, a.t.z3}
[all …]
Dproxyconfigmulti.t20 my $t = Memcached::ProxyTest->new(servers => [12111]);
26 $t->set_c($ps);
27 $t->accept_backends();
29 $t->c_send("mg foo\r\n");
30 $t->be_recv_c(0);
31 $t->be_send(0, "HD\r\n");
32 $t->c_recv_be();
Dproxydepthlim.t19 my $t = Memcached::ProxyTest->new(servers => [12161]);
25 $t->set_c($ps);
39 $t->c_send($cmd);
40 $t->c_recv("SERVER_ERROR backend failure\r\n", 'depth limit reached');
/memcached-1.6.32/vendor/mcmc/
Dmcmc.h140 int mcmc_tokenize_res(const char *l, size_t len, mcmc_tokenizer_t *t);
141 #define mcmc_token_count(t) (t->ntokens) argument
145 int mcmc_token_get_32(const char *l, mcmc_tokenizer_t *t, int idx, int32_t *val);
147 int mcmc_token_has_flag(const char *l, mcmc_tokenizer_t *t, char flag);
148 #define mcmc_token_has_flag_bit(t, f) (((t)->metaflags & f) ? MCMC_OK : MCMC_NOK) argument
154 int mcmc_token_get_flag_idx(const char *l, mcmc_tokenizer_t *t, char flag);
157 int mcmc_toktou32(const char *t, size_t len, uint32_t *out);
158 int mcmc_toktou64(const char *t, size_t len, uint64_t *out);
159 int mcmc_tokto32(const char *t, size_t len, int32_t *out);
160 int mcmc_tokto64(const char *t, size_t len, int64_t *out);
[all …]
Dmcmc.c53 #define _mcmc_tokenize(t, line, len, mstart, max) _mcmc_tokenize_meta(t, line, len, UINT8_MAX, max) argument
61 t->metaflags = 0; in _mcmc_tokenize_meta()
124 t->ntokens = curtoken; in _mcmc_tokenize_meta()
125 t->mstart = mstart; in _mcmc_tokenize_meta()
475 const char *pos = t; in mcmc_toktou32()
500 const char *pos = t; in mcmc_toktou64()
531 const char *pos = t; in mcmc_tokto32()
569 const char *pos = t; in mcmc_tokto64()
614 if (t->ntokens == 0) { in mcmc_tokenize_res()
663 for (int x = t->mstart; x < t->ntokens; x++) { in mcmc_token_get_flag()
[all …]
/memcached-1.6.32/
Dproxy_internal.c161 io->thread = t; in proxy_storage_get()
196 t->stats.get_extstore++; in proxy_storage_get()
426 assert(t != NULL); in process_arithmetic_cmd()
470 assert(t != NULL); in process_delete_cmd()
512 assert(t != NULL); in process_touch_cmd()
759 assert(t != NULL); in process_mget_cmd()
1066 assert(t != NULL); in process_mset_cmd()
1273 assert(t != NULL); in process_mdelete_cmd()
1416 assert(t != NULL); in process_marithmetic_cmd()
1748 r->thread = t; in mcplib_internal_run()
[all …]
Dproto_proxy.c29 new_kb = t->proxy_vm_last_kb + (new_kb - t->proxy_vm_last_kb) * 0.50; in _proxy_advance_lastkb()
56 WSTAT_L(t); in proxy_gc_poke()
58 WSTAT_UL(t); in proxy_gc_poke()
133 if (t->proxy_vm_gcrunning == -1 && lua_gc(t->L, LUA_GCSTEP, 0)) { in proxy_gc_timerpoke()
134 _proxy_advance_lastkb(t->L, t); in proxy_gc_timerpoke()
143 if (t->proxy_buffer_memory_used > t->proxy_buffer_memory_limit) { in proxy_bufmem_checkadd()
198 WSTAT_L(t); in process_proxy_stats()
209 WSTAT_UL(t); in process_proxy_stats()
417 pthread_create(&t->thread_id, NULL, proxy_event_thread, t); in proxy_init()
1238 r->thread = t; in mcp_prep_bare_resobj()
[all …]
Dproxy_network.c146 STAILQ_INIT(&t->be_head); in _proxy_event_handler_dequeue()
397 event_base_free(t->base); in proxy_event_thread()
1445 t->ctx = ctx; in proxy_init_event_thread()
1496 if (! t->base) { in proxy_init_event_thread()
1502 t->base = base; in proxy_init_event_thread()
1509 event_set(&t->notify_event, t->event_fd, in proxy_init_event_thread()
1511 event_set(&t->beconn_event, t->be_event_fd, in proxy_init_event_thread()
1514 event_set(&t->notify_event, t->notify_receive_fd, in proxy_init_event_thread()
1516 event_set(&t->beconn_event, t->be_notify_receive_fd, in proxy_init_event_thread()
1520 event_base_set(t->base, &t->notify_event); in proxy_init_event_thread()
[all …]
Dproxy_result.c122 void mcp_response_cleanup(LIBEVENT_THREAD *t, mcp_resp_t *r) { in mcp_response_cleanup() argument
126 pthread_mutex_lock(&t->proxy_limit_lock); in mcp_response_cleanup()
127 t->proxy_buffer_memory_used -= r->blen + r->extra; in mcp_response_cleanup()
128 pthread_mutex_unlock(&t->proxy_limit_lock); in mcp_response_cleanup()
149 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_response_gc() local
151 mcp_response_cleanup(t, r); in mcplib_response_gc()
160 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_response_close() local
162 mcp_response_cleanup(t, r); in mcplib_response_close()
Dproxy_ustats.c77 LIBEVENT_THREAD *t = PROXY_GET_THR(L); in mcplib_stat() local
78 if (t == NULL) { in mcplib_stat()
83 struct proxy_user_stats *tus = t->proxy_user_stats; in mcplib_stat()
98 WSTAT_L(t); in mcplib_stat()
100 WSTAT_UL(t); in mcplib_stat()
Dthread.c337 cq_push(t->ev_queue, item); in notify_worker()
346 if (write(t->n.notify_send_fd, buf, 1) != 1) { in notify_worker()
369 notify_worker(t, item); in notify_worker_fd()
817 void proxy_reload_notify(LIBEVENT_THREAD *t) { in proxy_reload_notify() argument
818 notify_worker_fd(t, 0, queue_proxy_reload); in proxy_reload_notify()
824 LIBEVENT_THREAD *t = io->thread; in return_io_pending() local
825 pthread_mutex_lock(&t->ion_lock); in return_io_pending()
826 if (STAILQ_EMPTY(&t->ion_head)) { in return_io_pending()
830 pthread_mutex_unlock(&t->ion_lock); in return_io_pending()
883 it = do_item_get(key, nkey, hv, t, do_update); in item_get()
[all …]

123