| /memcached-1.6.32/t/ |
| D | metaget.t | 256 $res = mget($sock, $k, 'c');
347 $ttl = get_flag($res, 't');
444 my $res = <$sock>;
445 my $r = parse_res($res);
506 $ttl = get_flag($res, 't');
528 $cas = get_flag($res, 'c');
537 $ttl = get_flag($res, 't');
540 is($res->{val}, "zuuu", "value matches: " . $res->{val});
631 my ($ttl, $cas, $res);
955 my $res = shift;
[all …]
|
| D | watcher.t | 21 my $res = <$watcher>;
25 $res = <$client>;
34 $res = <$client>;
46 $res = <$client>;
52 $res = <$client>;
55 $res = <$watcher>;
67 $res = <$client>;
124 $res = <$client>;
128 $res = <$mwatcher>;
132 $res = <$watcher2>;
[all …]
|
| D | proxyunits.lua | 63 if res:ok() then
197 local newReq = mcp.request("ms /request/a " .. res:vlen() .. "\r\n", res)
212 return res
220 return res
233 return res
239 return res
286 return res
351 return res
362 return res
410 return res
[all …]
|
| D | watcher_connid.t | 34 my $res = <$watcher>;
35 is($res, "OK\r\n", "watching enabled for fetchers and mutations");
41 $res = <$watcher>;
42 print $res;
43 like($res, qr/ts=\d+\.\d+\ gid=\d+ type=item_get key=foo status=not_found clsid=\d+ cfd=$cfd_first/,
45 $res = <$watcher>;
46 print $res;
47 like($res, qr/ts=\d+\.\d+\ gid=\d+ type=item_store key=foo status=stored cmd=set ttl=\d+ clsid=\d+ …
64 $res = <$watcher>;
65 print $res;
[all …]
|
| D | error-extstore.t | 57 my $res = <$sock>;
58 is($res, "STORED\r\n", "stored some big items");
83 my $res = <$sock>;
87 $res = <$sock>;
88 if ($res =~ m/NOSPARE/) {
106 my $res = <$sock>;
107 $res =~ s/[\r\n]//g;
108 is($res, 'SERVER_ERROR out of memory writing get response', 'can no longer read back item');
120 my $res = <$sock>;
121 if ($res =~ m/BUSY/) {
[all …]
|
| D | startfile.lua | 121 local res, detail = nr(r)
123 return res
139 local res = near_zone(r)
175 local res = near_zone(r)
177 return res
185 local res = near_zone(r)
191 return res
208 local res = near_zone(r)
209 if res:ok() == true then
300 if res:ok() then
[all …]
|
| D | proxylimits.t | 156 my $res;
158 $res = scalar <$be>;
224 my $res = scalar <$be>;
228 my $res = scalar <$ps>;
229 $res = scalar <$ps>;
230 $res = scalar <$ps>;
247 $res = scalar <$ps>;
250 my $res = scalar <$ps>;
265 my $res = scalar <$ps>;
266 $res = scalar <$ps>;
[all …]
|
| D | proxyfuncgen.lua | 187 if res ~= nil then
189 return res
198 return res
222 return res
233 local cb = function(res)
235 if res:hit() then
292 return res
294 final = res
324 local cb = function(res)
328 if res:hit() then
[all …]
|
| D | chunked-extstore.t | 27 my $res = <$sock>;
67 my $res = <$sock>;
68 is($res, "STORED\r\n", "stored some big items");
146 my $res = <$sock>;
147 is($res, "OK\r\n", 'set compact_under');
149 $res = <$sock>;
150 is($res, "OK\r\n", 'set drop_under');
152 $res = <$sock>;
153 is($res, "OK\r\n", 'set max_frag');
|
| D | udp.t | 44 my $res = send_udp_request($usock, $req, "get foo\r\n");
45 ok($res, "got result");
46 is(keys %$res, 1, "one key (one packet)");
47 ok($res->{0}, "only got seq number 0");
48 is(substr($res->{0}, 8), "VALUE foo 0 6\r\nfooval\r\nEND\r\n");
67 my $res = send_udp_request($usock, 53, "get bigvalue\r\n");
68 ok($res, "got result");
69 my $resp = construct_udp_message($res);
257 my $res;
258 my $sender = $sock->recv($res, 1500, 0);
[all …]
|
| D | proxyrctxtimeout.lua | 30 local res = rctx:res_any(all[x])
31 if res then
32 return res
59 local res = rctx:res_any(all[x])
60 if res then
61 return res
89 local res = rctx:res_any(all[x])
90 if res then
91 return res
|
| D | proxyratelim.t | 26 my $res = scalar <$ps>;
27 last if $res =~ m/SERVER_ERROR/;
42 my $res = scalar <$ps>;
43 last if $res =~ m/SERVER_ERROR/;
|
| D | restart.t | 55 my $res = <$sock>;
56 $good = 0 if ($res !~ m/STORED/);
71 my $res = <$sock>;
72 $good = 0 if ($res !~ m/DELETED/);
110 my $res = <$wsock>;
111 is($res, "OK\r\n", "watcher enabled");
|
| D | extstore-overdel.t | 69 my $res = <$sock>;
71 $res = <$sock>;
81 my $res = <$sock>;
105 $res = <$sock>;
|
| D | proxyins.lua | 96 local res = rctx:enqueue_and_wait(r, mgreshasfh)
98 local exists, matches = mgresflagis_ins(res)
101 local has_O, O, has_t, t = mgresflaga_ins(res)
109 local f, t = mgreshasf_ins(res)
141 local res = mcp.internal(r)
142 local has_O, O, has_t, t = mgresflaga_ins(res)
|
| D | extstore.t | 150 my $res = <$sock>;
152 $res = <$sock>;
154 $res = <$sock>;
156 $res = <$sock>;
168 $res = <$sock>;
|
| D | proxymatch.lua | 15 local res = rctx:enqueue_and_wait(r, h)
16 local match, token = r:match_res(res)
26 return res
|
| D | slabhang.t | 58 my $res = scalar <$sock>;
59 while ($res =~ m/^BUSY/) {
68 $res = scalar <$sock>;
|
| D | slabs-reassign-chunked.t | 33 my $res;
62 my $res = scalar <$sock>;
63 chomp $res;
|
| D | proxyinternal2.lua | 15 local res <close> = mcp.internal(r)
19 table.insert(result_leak, res)
|
| D | 64bit.t | 38 my $res = <$sock>;
39 $hit_limit = 1 if $res ne "STORED\r\n";
|
| /memcached-1.6.32/ |
| D | proxy_inspector.c | 311 mcp_resp_t *res = arg; in mcp_inspector_hasflag_r() local
316 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_hasflag_r()
344 mcp_resp_t *res = arg; in mcp_inspector_flagtoken_r() local
346 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_flagtoken_r()
350 const char *tok = mcmc_token_get_flag(res_buf(res), &res->tok, c->f, &tlen); in mcp_inspector_flagtoken_r()
380 mcp_resp_t *res = arg; in mcp_inspector_flagint_r() local
382 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_flagint_r()
386 if (mcmc_token_get_flag_64(res_buf(res), &res->tok, c->f, &tok) == MCMC_OK) { in mcp_inspector_flagint_r()
454 mcp_resp_t *res = arg; in mcp_inspector_flagis_r() local
456 mcmc_tokenize_res(res_buf(res), res->resp.reslen, &res->tok); in mcp_inspector_flagis_r()
[all …]
|
| D | proxy_config.c | 308 if (res != LUA_OK) { in proxy_run_crons()
453 int res; in proxy_load_files() local
458 res = luaL_loadfile(L, db->fname); in proxy_load_files()
459 if (res != LUA_OK) { in proxy_load_files()
472 if (res != LUA_OK) { in proxy_load_files()
486 int res = 0; in proxy_load_config() local
490 if (res != 0) { in proxy_load_config()
491 return res; in proxy_load_config()
496 res = proxy_load_files(ctx); in proxy_load_config()
648 if (res != LUA_OK) { in proxy_thread_loadconf()
[all …]
|
| D | memcached.c | 2272 int res; local
2338 memset(ITEM_data(it) + res, ' ', it->nbytes - res - 2);
2419 int res; local
2427 if (res > 8) {
2442 res -= 8;
2466 int res; local
2735 ssize_t res; local
2738 if (res >= 0) {
2870 ssize_t res; local
2917 int res; local
[all …]
|
| D | proxy_network.c | 74 if (res == -1) { in _beconn_send_validate()
80 if (res < len) { in _beconn_send_validate()
1125 if (res == -1) { in proxy_bevalidate_tls_handler()
1242 if (res == -1) { in proxy_beconn_handler()
1246 flags |= res; in proxy_beconn_handler()
1295 if (res == -1) { in proxy_beconn_handler()
1299 if (res & EV_WRITE) { in proxy_beconn_handler()
1337 if (res == -1) { in proxy_backend_tls_handler()
1354 if (res != 0) { in proxy_backend_tls_handler()
1397 if (res == -1) { in proxy_backend_handler()
[all …]
|