| /memcached-1.6.32/t/ |
| D | proxyunits.t | 82 print $ps $cmd;
345 my $cmd;
398 print $ps $cmd;
410 print $ps $cmd;
420 print $ps $cmd;
428 print $ps $cmd;
438 print $ps $cmd;
448 print $ps $cmd;
456 print $ps $cmd;
502 print $ps $cmd;
[all …]
|
| D | proxymatch.t | 34 $t->c_send($cmd);
45 $t->c_send($cmd);
55 $t->c_send($cmd);
65 $t->c_send($cmd);
75 $t->c_send($cmd);
86 $t->c_send($cmd);
97 $t->c_send($cmd);
107 $t->c_send($cmd);
117 $t->c_send($cmd);
127 $t->c_send($cmd);
[all …]
|
| D | proxyintstats.lua | 1 function check_stats(cmd, min)
3 if cmd then
4 s = mcp.server_stats(cmd)
7 cmd = "basic"
16 mcp.log("ERROR: ["..cmd.."] count too low: " .. count)
18 mcp.log("SUCCESS: " .. cmd)
22 function check_stats_sections(cmd, minsec, minval)
23 local s = mcp.server_stats(cmd)
39 mcp.log("ERROR: ["..cmd.."] section count too low: " .. count)
44 mcp.log("ERROR: ["..cmd.."] value count too low: " .. count)
[all …]
|
| D | proxylimits.t | 85 my $cmd = '';
89 print $ps $cmd;
119 $cmd = '';
123 print $ps $cmd;
147 print $ps $cmd;
154 print $sps $cmd;
183 print $ps $cmd;
188 print $sps $cmd;
222 print $ps $cmd;
239 print $ps $cmd;
[all …]
|
| D | binary-extstore.t | 270 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
297 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
327 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
338 my ($cmd, $key, $value) = @_;
391 my ($cmd, $key, $val, $extra_header, $cas) = @_;
418 my ($cmd, $key, $amt, $init, $exp) = @_;
420 my ($data, $rcas) = $self->_do_command($cmd, $key, '',
438 my ($cmd, $key, $amt, $init, $exp) = @_;
441 $mc->send_silent($cmd, $key, '', $opaque,
553 my ($cmd, $key, $val, $cas) = @_;
[all …]
|
| D | binary-sasl.t | 340 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
367 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
387 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
398 my ($cmd, $key, $value) = @_;
402 $mc->send_silent($cmd, $key, $value, 7278552, $extra, 0);
441 my ($cmd, $key, $val, $extra_header, $cas) = @_;
468 my ($cmd, $key, $amt, $init, $exp) = @_;
482 my ($cmd, $key, $amt, $init, $exp) = @_;
485 $mc->send_silent($cmd, $key, '', $opaque,
581 my ($cmd, $key, $val, $cas) = @_;
[all …]
|
| D | proxyfuncgen.t | 69 my $cmd = "md failgen/a\r\n";
70 $t->c_send("$cmd$cmd");
94 my $cmd = '';
96 $cmd .= "mg all/$k O$k\r\n";
98 $t->c_send("$cmd");
126 my $cmd = "mg locality/a\r\n";
127 $t->c_send("$cmd$cmd$cmd");
129 $t->be_recv([0], $cmd, "backend 0 received locaity req");
|
| D | proxyslotcache.t | 47 my $cmd = "mg $prefix/go N50\r\n";
51 $fcmd .= $cmd;
57 $t->be_recv(0, $cmd, "received request $_");
152 my $cmd = "mg three/go N50\r\n";
156 $fcmd .= $cmd;
160 $t->be_recv(0, $cmd, "received request $_");
|
| D | proxyinternal2.lua | 9 local cmd = r:command()
10 if cmd == mcp.CMD_GET or cmd == mcp.CMD_MG then
|
| D | proxydepthlim.t | 31 my $cmd = "mg foo s t v\r\n";
34 $todo .= $cmd;
39 $t->c_send($cmd);
|
| D | proxyconfig.t | 61 my $cmd = shift;
63 print $fh $cmd;
137 my $cmd = "mg foo v\r\n";
138 print $ps $cmd;
142 is(scalar <$be>, $cmd, "metaget passthrough");
226 my $cmd = "mg foo$_ v\r\n";
227 print $ps $cmd;
230 is(scalar <$be>, $cmd, "get passthrough");
|
| D | binary.t | 550 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
577 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
606 my ($cmd, $key, $val, $opaque, $extra_header, $cas) = @_;
617 my ($cmd, $key, $value) = @_;
670 my ($cmd, $key, $val, $extra_header, $cas) = @_;
697 my ($cmd, $key, $amt, $init, $exp) = @_;
699 my ($data, $rcas) = $self->_do_command($cmd, $key, '',
717 my ($cmd, $key, $amt, $init, $exp) = @_;
720 $mc->send_silent($cmd, $key, '', $opaque,
832 my ($cmd, $key, $val, $cas) = @_;
[all …]
|
| D | conn-limits.t | 40 my $cmd = join('', @keys);
41 print $s $cmd;
|
| D | proxytags.t | 63 my $cmd = shift;
65 print $fh $cmd;
|
| D | issue_67.t | 66 my $cmd = "$builddir/timedrun 10 $exe $root $args";
69 exec $cmd;
|
| D | proxymut.lua | 21 { t = "cmdset", cmd = "mg" },
27 { t = "cmdset", cmd = "mg" },
|
| D | proxyustats.t | 57 my $cmd = shift;
59 print $fh $cmd;
|
| /memcached-1.6.32/ |
| D | testapp.c | 1109 uint8_t cmd, in ext_command() argument
1241 switch (cmd) { in validate_response_header()
1257 switch (cmd) { in validate_response_header()
1581 if (cmd == PROTOCOL_BINARY_CMD_GAT || cmd == PROTOCOL_BINARY_CMD_GATK) in test_binary_get_impl()
1653 if (cmd == PROTOCOL_BINARY_CMD_GATQ || cmd == PROTOCOL_BINARY_CMD_GATKQ) in test_binary_getq_impl()
1909 if (cmd == PROTOCOL_BINARY_CMD_APPEND || cmd == PROTOCOL_BINARY_CMD_PREPEND) { in test_binary_concat_impl()
1988 uint8_t cmd = 0x25; in test_binary_illegal() local
1989 while (cmd != 0x00) { in test_binary_illegal()
2001 ++cmd; in test_binary_illegal()
2040 switch (cmd) { in test_binary_pipeline_hickup_chunk()
[all …]
|
| D | proto_bin.c | 30 assert(c->cmd >= 0); in complete_nread_binary()
390 switch (c->cmd) { in complete_update_bin()
802 switch (c->cmd) { in process_bin_complete_sasl_auth()
867 switch (c->cmd) { in authenticated()
915 switch (c->cmd) { in dispatch_bin_command()
962 switch (c->cmd) { in dispatch_bin_command()
1156 switch (c->cmd) { in process_bin_update()
1158 c->cmd = NREAD_ADD; in process_bin_update()
1161 c->cmd = NREAD_SET; in process_bin_update()
1171 c->cmd = NREAD_CAS; in process_bin_update()
[all …]
|
| D | proxy_request.c | 320 int cmd = -1; in process_request() local
377 cmd = CMD_SET; in process_request()
380 cmd = CMD_ADD; in process_request()
383 cmd = CMD_CAS; in process_request()
389 cmd = CMD_GETS; in process_request()
394 cmd = CMD_INCR; in process_request()
397 cmd = CMD_DECR; in process_request()
400 cmd = CMD_GATS; in process_request()
404 cmd = CMD_QUIT; in process_request()
409 cmd = CMD_TOUCH; in process_request()
[all …]
|
| D | logger.c | 126 le->cmd = comm; in _logger_log_item_store()
145 le->cmd = comm; in _logger_log_item_deleted()
215 const char *cmd = "na"; in _logger_parse_ise() local
223 if (le->cmd <= 8) in _logger_parse_ise()
224 cmd = cmd_map[le->cmd]; in _logger_parse_ise()
230 keybuf, status_map[le->status], cmd, le->ttl, le->clsid, le->sfd, in _logger_parse_ise()
268 const char *cmd = "na"; in _logger_parse_ide() local
275 if (le->cmd <= 2) in _logger_parse_ide()
276 cmd = cmd_map[le->cmd]; in _logger_parse_ide()
281 keybuf, cmd, le->clsid, in _logger_parse_ide()
|
| D | logger.h | 105 int cmd; member
116 int cmd; member
|
| D | proxy_lua.c | 89 const char *cmd = luaL_checkstring(L, 1); in mcplib_server_stats() local
90 if (strcmp(cmd, "settings") == 0) { in mcplib_server_stats()
92 } else if (strcmp(cmd, "conns") == 0) { in mcplib_server_stats()
95 } else if (strcmp(cmd, "extstore") == 0) { in mcplib_server_stats()
98 } else if (strcmp(cmd, "proxy") == 0) { in mcplib_server_stats()
100 } else if (strcmp(cmd, "proxyfuncs") == 0) { in mcplib_server_stats()
102 } else if (strcmp(cmd, "proxybe") == 0) { in mcplib_server_stats()
105 if (get_stats(cmd, strlen(cmd), &_mcplib_append_section_stats, &c)) { in mcplib_server_stats()
|
| /memcached-1.6.32/t/lib/ |
| D | MemcachedTest.pm | 360 exec $cmd;
639 my $cmd = shift;
641 print $c $cmd;
642 $self->{_cmd} = $cmd;
676 my $cmd = $self->{_cmd};
677 my @cmds = split(/(?<=\r\n)/, $cmd);
717 $self->{_becmd} = $cmd;
720 print $be $cmd;
730 my $cmd = $self->{_becmd};
732 Test::More::is(scalar <$c>, $cmd, $detail);
[all …]
|
| /memcached-1.6.32/scripts/ |
| D | damemtop | 219 for my $cmd (@$cmds) {
220 $con->push_write('stats ' . $cmd . "\n");
221 $stats->{$cmd} = {};
|