| /memcached-1.6.32/t/ |
| D | proxyunits.t | 1167 my $msg = "SERVER_ERROR object too large for cache\r\n";
1168 print $be $msg;
1169 is(scalar <$ps>, $msg, "client received error message");
1179 $msg = "CLIENT_ERROR bad command line format\r\n";
1181 print $be $msg;
1182 is(scalar <$ps>, $msg, "client received error message");
1190 $msg = "ERROR unhappy\r\n";
1191 print $be $msg;
1192 is(scalar <$ps>, $msg, "client received error message");
1201 $msg = "ERROR\r\n";
[all …]
|
| D | udp.t | 212 my $msg = "";
219 $msg .= substr($cur_dg,8);
221 return $msg;
239 my $msg = shift;
240 warn " FAILING send_udp because: $msg\n";
|
| D | proxyrouter.lua | 28 function string_fgen(msg)
32 return msg
|
| D | metaget.t | 859 my ($o, $key, $val, $msg) = @_;
862 $msg ||= "$key == $dval";
874 Test::More::is($line, "EN\r\n", $msg);
880 Test::More::is($body, $expected, $msg);
884 Test::More::is($body, $expected, $msg);
|
| D | binary-extstore.t | 287 my $msg = pack(::REQ_PKT_FMT, ::REQ_MAGIC, $cmd, $keylen, $extralen,
290 my $full_msg = $msg . $extra_header . $key . $val;
|
| D | binary-sasl.t | 357 my $msg = pack(::REQ_PKT_FMT, ::REQ_MAGIC, $cmd, $keylen, $extralen,
360 my $full_msg = $msg . $extra_header . $key . $val;
|
| D | binary.t | 567 my $msg = pack(::REQ_PKT_FMT, ::REQ_MAGIC, $cmd, $keylen, $extralen,
570 my $full_msg = $msg . $extra_header . $key . $val;
|
| /memcached-1.6.32/t/lib/ |
| D | MemcachedTest.pm | 84 my ($sock_opts, $key, $val, $msg) = @_;
90 $msg ||= "$key == $dval";
98 Test::More::is($line, "END\r\n", $msg);
104 Test::More::is($body, $expected, $msg);
108 Test::More::is($body, $expected, $msg);
142 my ($sock_opts, $identifier, $key, $val, $msg) = @_;
148 $msg ||= "$key == $dval";
156 Test::More::is($line, "END\r\n", $msg);
162 Test::More::is($body, $expected, $msg);
166 Test::More::is($body, $expected, $msg);
|
| /memcached-1.6.32/ |
| D | tls.c | 21 static ssize_t ssl_sendmsg(conn *c, struct msghdr *msg, int flags);
234 static ssize_t ssl_sendmsg(conn *c, struct msghdr *msg, int flags) { in ssl_sendmsg() argument
252 for (i = 0; i < msg->msg_iovlen; i++) { in ssl_sendmsg()
253 size_t len = msg->msg_iov[i].iov_len; in ssl_sendmsg()
256 memcpy(bp + bytes, (void*)msg->msg_iov[i].iov_base, to_copy); in ssl_sendmsg()
|
| D | proxy.h | 866 __attribute__((unused)) void dump_stack(lua_State *L, const char *msg);
867 __attribute__((unused)) void dump_registry(lua_State *L, const char *msg);
868 __attribute__((unused)) void dump_funcgen(lua_State *L, const char *name, const char *msg);
869 __attribute__((unused)) void dump_pools(lua_State *L, const char *msg);
|
| D | proto_proxy.c | 1523 __attribute__((unused)) void dump_stack(lua_State *L, const char *msg) { in dump_stack() argument
1526 fprintf(stderr, "--TOP OF STACK [%d] | %s\n", top, msg); in dump_stack()
1559 __attribute__((unused)) void dump_registry(lua_State *L, const char *msg) { in dump_registry() argument
1561 fprintf(stderr, "--LUA REGISTRY TABLE [%d] | %s\n", ref_size, msg); in dump_registry()
1598 __attribute__((unused)) void dump_funcgen(lua_State *L, const char *name, const char *msg) { in dump_funcgen() argument
1600 fprintf(stderr, "--LUA FUNCGEN FINDER [%d] | %s\n", ref_size, msg); in dump_funcgen()
1652 __attribute__((unused)) void dump_pools(lua_State *L, const char *msg) { in dump_pools() argument
1654 fprintf(stderr, "--LUA POOL DUMPER [%d] | %s\n", ref_size, msg); in dump_pools()
|
| D | memcached.c | 138 return sendmsg(c->sfd, msg, flags); in tcp_sendmsg()
2719 struct msghdr msg; local
2723 memset(&msg, 0, sizeof(struct msghdr));
2724 msg.msg_iov = iovs;
2736 msg.msg_iovlen = iovused;
2737 res = c->sendmsg(c, &msg, 0);
2816 struct msghdr msg; local
2836 msg.msg_iov = iovs;
2839 msg.msg_name = &resp->request_addr;
2871 msg.msg_iovlen = iovused;
[all …]
|
| D | proxy_lua.c | 1349 const char *msg = luaL_checkstring(L, -1); in mcplib_ct_log() local
1351 LOGGER_LOG(NULL, LOG_PROXYUSER, LOGGER_PROXY_USER, NULL, msg); in mcplib_ct_log()
1357 const char *msg = luaL_checkstring(L, -1); in mcplib_log() local
1358 LOGGER_LOG(t->l, LOG_PROXYUSER, LOGGER_PROXY_USER, NULL, msg); in mcplib_log()
|
| D | memcached.h | 906 ssize_t (*sendmsg)(conn *c, struct msghdr *msg, int flags);
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.h | 133 void mcmc_get_error(void *c, char *code, size_t clen, char *msg, size_t mlen);
|
| D | mcmc.c | 1013 void mcmc_get_error(void *c, char *code, size_t clen, char *msg, size_t mlen) { in mcmc_get_error() argument
1015 msg[0] = '\0'; in mcmc_get_error()
|