| /memcached-1.6.32/t/ |
| D | proxyrequest.lua | 11 return function(r)
12 local k = r:key()
20 r:token(3, flags)
29 return function(r)
30 local k = r:key()
33 r:flag_add("F")
36 r:flag_add("F", "1234")
39 r:flag_add("F", 5678)
50 r:flag_set("F")
56 r:flag_set("F", 8765)
[all …]
|
| D | proxyunits.lua | 54 return function(r)
60 return function(r)
79 return function(r)
85 return function(r)
86 r:rtrimkey(4)
92 return function(r)
93 r:ltrimkey(10)
99 return function(r)
105 return function(r)
134 return function(r)
[all …]
|
| D | startfile.lua | 120 return function(r)
138 return function(r)
165 return function(r)
184 return function(r)
207 return function(r)
234 return function(r)
247 return route(r)
256 return function(r)
271 return function(r)
282 return f(r)
[all …]
|
| D | proxyfuncgen.lua | 101 return function(r)
122 return function(r)
142 return function(r)
159 return function(r)
176 return function(r)
212 return function(r)
247 return function(r)
283 return function(r)
339 return function(r)
380 return function(r)
[all …]
|
| D | proxyins.lua | 41 return function(r)
42 local key = r:key()
44 local idx = mgsepkey2_ins(r)
50 local idx = mgsepkey1_ins(r)
53 local idx = mgsepkey3_ins(r)
56 local idx, b = mgsepkey_ins(r)
94 return function(r)
95 local key = r:key()
127 return function(r)
139 return function(r)
[all …]
|
| D | proxyrctxtimeout.lua | 22 return function(r)
23 rctx:enqueue(r, near)
27 rctx:enqueue(r, far)
52 return function(r)
81 return function(r)
82 rctx:enqueue(r, near)
108 return function(r)
109 rctx:enqueue(r, near)
129 return function(r)
130 rctx:enqueue(r, near)
[all …]
|
| D | proxyinternal2.lua | 8 mcp.attach(mcp.CMD_ANY_STORAGE, function(r)
9 local cmd = r:command()
15 local res <close> = mcp.internal(r)
16 local res2 = mcp.internal(r)
21 return mcp.internal(r)
|
| D | proxytags.lua | 20 return function(r)
21 return rctx:enqueue_and_wait(r, h)
28 mcp.attach(mcp.CMD_MG, function(r) return "SERVER_ERROR tag A\r\n" end, "a")
30 mcp.attach(mcp.CMD_MG, function(r) return "SERVER_ERROR tag B\r\n" end, "b")
32 mcp.attach(mcp.CMD_MG, function(r) return "SERVER_ERROR tag CCCC\r\n" end, "cccc")
|
| D | proxyintext.lua | 9 return function(r)
10 rctx:enqueue(r, h_a)
11 rctx:enqueue(r, h_b)
27 return function(r)
28 return mcp.internal(r)
|
| D | proxymut.lua | 63 return function(r)
64 local key = r:key()
80 local res = rctx:enqueue_and_wait(r, mgfgh)
90 return function(r)
91 local key = r:key()
|
| D | proxymatch.lua | 14 return function(r)
15 local res = rctx:enqueue_and_wait(r, h)
16 local match, token = r:match_res(res)
|
| D | proxyslotcache.lua | 16 return function(r)
17 local k = r:key()
25 return rctx:enqueue_and_wait(r, h)
|
| D | proxyrouter.lua | 17 return function(r)
18 return rctx:enqueue_and_wait(r, h)
23 return function(r)
31 return function(r)
|
| D | proxyconfig.lua | 79 mcp.attach(mcp.CMD_MG, function(r) return "SERVER_ERROR no mg route\r\n" end)
80 mcp.attach(mcp.CMD_MS, function(r) return "SERVER_ERROR no ms route\r\n" end)
86 return function(r)
87 return rctx:enqueue_and_wait(r, h)
|
| D | proxyinternal.lua | 7 mcp.attach(mcp.CMD_ANY_STORAGE, function(r)
8 return mcp.internal(r)
|
| D | metaget.t | 925 my %r = ();
928 $r{size} = $1;
929 $r{flags} = $2;
930 $r{val} = $3;
932 $r{flags} = $1;
933 $r{hd} = 1;
940 return \%r;
945 my %r = ();
947 $r{status} = $1;
948 $r{flags} = $2;
[all …]
|
| D | proxyconfigmulti2.lua | 7 return function(r)
8 return rctx:enqueue_and_wait(r, h)
|
| D | proxyratelim.lua | 15 mcp.attach(mcp.CMD_MG, function(r)
23 mcp.attach(mcp.CMD_GET, function(r)
|
| D | proxydepthlim.lua | 16 return function(r)
17 return rctx:enqueue_and_wait(r, h)
|
| D | proxyantiflap.lua | 29 return function(r)
30 return rctx:enqueue_and_wait(r, handle)
|
| /memcached-1.6.32/ |
| D | proxy_result.c | 15 if (r->status == MCMC_OK) { in mcplib_response_ok()
27 if (r->status == MCMC_OK && r->resp.code != MCMC_CODE_END) { in mcplib_response_hit()
44 if (r->resp.vlen >= 2) { in mcplib_response_vlen()
67 lua_pushlstring(L, r->resp.rline, r->resp.rlen); in mcplib_response_line()
90 mcmc_parse_buf(r->buf, r->blen, &reresp); in mcplib_response_flag_blank()
125 if (r->buf != NULL) { in mcp_response_cleanup()
127 t->proxy_buffer_memory_used -= r->blen + r->extra; in mcp_response_cleanup()
130 free(r->buf); in mcp_response_cleanup()
131 r->buf = NULL; in mcp_response_cleanup()
133 r->tok.ntokens = 0; in mcp_response_cleanup()
[all …]
|
| D | proxy_network.c | 571 r->blen = r->resp.reslen + r->resp.vlen; in proxy_backend_drive_machine()
583 r->buf = malloc(r->blen + extra_space); in proxy_backend_drive_machine()
597 if (r->resp.vlen != r->resp.vlen_read) { in proxy_backend_drive_machine()
603 memcpy(r->buf, be->rbuf, r->resp.reslen + r->resp.vlen_read); in proxy_backend_drive_machine()
604 r->bread = r->resp.reslen + r->resp.vlen_read; in proxy_backend_drive_machine()
613 memcpy(r->buf, be->rbuf, r->resp.reslen+r->resp.vlen_read); in proxy_backend_drive_machine()
617 be->rbufused -= r->resp.reslen + r->resp.vlen_read; in proxy_backend_drive_machine()
639 memcpy(r->buf+r->blen, ENDSTR, ENDLEN); in proxy_backend_drive_machine()
668 be->rbufused : r->blen - r->bread; in proxy_backend_drive_machine()
669 memcpy(r->buf+r->bread, be->rbuf, tocopy); in proxy_backend_drive_machine()
[all …]
|
| D | proto_proxy.c | 792 switch (r->mode) { in _set_noreply_mode()
804 } else if (r->cmd != CMD_MG && r->resp.code == MCMC_CODE_OK) { in _set_noreply_mode()
921 resp_add_iov(resp, r->buf, r->blen); in proxy_run_rcontext()
923 resp->wbytes = r->blen + r->extra; in proxy_run_rcontext()
1238 r->thread = t; in mcp_prep_bare_resobj()
1245 return r; in mcp_prep_bare_resobj()
1250 r->buf = NULL; in mcp_set_resobj()
1251 r->blen = 0; in mcp_set_resobj()
1252 r->thread = t; in mcp_set_resobj()
1291 return r; in mcp_prep_resobj()
[all …]
|
| D | murmur3_hash.c | 33 static inline uint32_t rotl32 ( uint32_t x, int8_t r ) in rotl32() argument
35 return (x << r) | (x >> (32 - r)); in rotl32()
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 200 r->vlen_read = r->vlen; in _mcmc_parse_value_line()
204 r->key = key; in _mcmc_parse_value_line()
205 r->klen = keylen; in _mcmc_parse_value_line()
206 r->flags = flags; in _mcmc_parse_value_line()
207 r->cas = cas; in _mcmc_parse_value_line()
234 r->sname = sname; in _mcmc_parse_stat_line()
236 r->stat = stat; in _mcmc_parse_stat_line()
345 r->vlen_read = r->vlen; in _mcmc_parse_response()
370 r->rlen = r->reslen - (cur - buf); in _mcmc_parse_response()
739 memset(r, 0, sizeof(*r)); in mcmc_parse_buf()
[all …]
|