Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 30) sorted by relevance

12

/redis-3.2.3/deps/jemalloc/test/include/test/
H A Dmq.h65 a_mq_msg_type *msg; \
68 msg = ql_first(&mq->msgs); \
69 if (msg != NULL) { \
74 return (msg); \
79 a_mq_msg_type *msg; \
82 msg = a_prefix##tryget(mq); \
83 if (msg != NULL) \
84 return (msg); \
90 if (msg != NULL) \
91 return (msg); \
[all …]
/redis-3.2.3/deps/jemalloc/test/unit/
H A Dmq.c15 mq_msg_t msg; in mq_gen() local
22 mq_put(&mq, &msg); in mq_gen()
24 assert_ptr_eq(mq_tryget(&mq), &msg, "mq_tryget() should return msg"); in mq_gen()
26 mq_put(&mq, &msg); in mq_gen()
27 assert_ptr_eq(mq_get(&mq), &msg, "mq_get() should return msg"); in mq_gen()
40 mq_msg_t *msg = mq_get(mq); in thd_receiver_start() local
41 assert_ptr_not_null(msg, "mq_get() should never return NULL"); in thd_receiver_start()
42 dallocx(msg, 0); in thd_receiver_start()
54 mq_msg_t *msg; in thd_sender_start() local
58 msg = (mq_msg_t *)p; in thd_sender_start()
[all …]
/redis-3.2.3/tests/support/
H A Dtest.tcl6 proc fail {msg} { argument
7 error "assertion:$msg"
97 set msg [string range $error 10 end]
98 lappend details $msg
112 set msg "Expected '$okpattern' to equal or match '$retval'"
113 lappend details $msg
/redis-3.2.3/src/
H A Dredis-check-rdb.c101 char msg[1024]; in rdbCheckError() local
105 vsnprintf(msg, sizeof(msg), fmt, ap); in rdbCheckError()
111 rdbstate.rio->processed_bytes : 0), msg); in rdbCheckError()
128 char msg[1024]; in rdbCheckInfo() local
132 vsnprintf(msg, sizeof(msg), fmt, ap); in rdbCheckInfo()
137 rdbstate.rio->processed_bytes : 0), msg); in rdbCheckInfo()
H A Dobject.c565 int getDoubleFromObjectOrReply(client *c, robj *o, double *target, const char *msg) { in getDoubleFromObjectOrReply() argument
568 if (msg != NULL) { in getDoubleFromObjectOrReply()
569 addReplyError(c,(char*)msg); in getDoubleFromObjectOrReply()
606 if (msg != NULL) { in getLongDoubleFromObjectOrReply()
607 addReplyError(c,(char*)msg); in getLongDoubleFromObjectOrReply()
639 if (msg != NULL) { in getLongLongFromObjectOrReply()
640 addReplyError(c,(char*)msg); in getLongLongFromObjectOrReply()
650 int getLongFromObjectOrReply(client *c, robj *o, long *target, const char *msg) { in getLongFromObjectOrReply() argument
653 if (getLongLongFromObjectOrReply(c, o, &value, msg) != C_OK) return C_ERR; in getLongFromObjectOrReply()
655 if (msg != NULL) { in getLongFromObjectOrReply()
[all …]
H A Drdb.c56 char msg[1024]; in rdbCheckThenExit() local
59 len = snprintf(msg,sizeof(msg), in rdbCheckThenExit()
62 vsnprintf(msg+len,sizeof(msg)-len,reason,ap); in rdbCheckThenExit()
66 serverLog(LL_WARNING, "%s", msg); in rdbCheckThenExit()
70 rdbCheckError("%s",msg); in rdbCheckThenExit()
1664 void *msg = zmalloc(sizeof(uint64_t)*(1+2*numfds)); in rdbSaveToSlavesSockets() local
1665 uint64_t *len = msg; in rdbSaveToSlavesSockets()
1681 write(server.rdb_pipe_write_result_to_parent,msg,msglen) in rdbSaveToSlavesSockets()
1686 zfree(msg); in rdbSaveToSlavesSockets()
H A Dserver.c306 void serverLogRaw(int level, const char *msg) { in serverLogRaw() argument
321 fprintf(fp,"%s",msg); in serverLogRaw()
339 (int)getpid(),role_char, buf,c[level],msg); in serverLogRaw()
352 char msg[LOG_MAX_LEN]; in serverLog() local
357 vsnprintf(msg, sizeof(msg), fmt, ap); in serverLog()
360 serverLogRaw(level,msg); in serverLog()
369 void serverLogFromHandler(int level, const char *msg) { in serverLogFromHandler() argument
385 if (write(fd,msg,strlen(msg)) == -1) goto err; in serverLogFromHandler()
3732 char *msg; in sigShutdownHandler() local
3736 msg = "Received SIGINT scheduling shutdown..."; in sigShutdownHandler()
[all …]
H A Dcluster.c1582 ntohl(hdr->data.publish.msg.channel_len) + in clusterProcessPacket()
1583 ntohl(hdr->data.publish.msg.message_len); in clusterProcessPacket()
2088 link->sndbuf = sdscatlen(link->sndbuf, msg, msglen); in clusterSendMessage()
2348 hdr->data.publish.msg.channel_len = htonl(channel_len); in clusterSendPublish()
2349 hdr->data.publish.msg.message_len = htonl(message_len); in clusterSendPublish()
2361 memcpy(hdr->data.publish.msg.bulk_data+sdslen(channel->ptr), in clusterSendPublish()
2619 char *msg; in clusterLogCantFailover() local
2639 msg = "Disconnected from master for longer than allowed. " in clusterLogCantFailover()
2647 msg = "Failover attempt expired."; in clusterLogCantFailover()
2653 msg = "Unknown reason code."; in clusterLogCantFailover()
[all …]
H A Dserver.h1212 int getLongFromObjectOrReply(client *c, robj *o, long *target, const char *msg);
1214 int getLongLongFromObjectOrReply(client *c, robj *o, long long *target, const char *msg);
1215 int getDoubleFromObjectOrReply(client *c, robj *o, double *target, const char *msg);
1218 int getLongDoubleFromObjectOrReply(client *c, robj *o, long double *target, const char *msg);
1326 void serverLogRaw(int level, const char *msg);
1327 void serverLogFromHandler(int level, const char *msg);
1659 void _serverPanic(char *msg, char *file, int line);
H A Dredis-trib.rb317 def cluster_error(msg) argument
318 @errors << msg
319 xputs msg
815 def yes_or_die(msg) argument
816 print "#{msg} (type 'yes' to accept): "
H A Dcluster.h213 clusterMsgDataPublish msg; member
H A Dsentinel.c585 char msg[LOG_MAX_LEN]; in sentinelEvent() local
594 snprintf(msg, sizeof(msg), "%s %s %s %d @ %s %s %d", in sentinelEvent()
599 snprintf(msg, sizeof(msg), "%s %s %s %d", in sentinelEvent()
605 msg[0] = '\0'; in sentinelEvent()
611 vsnprintf(msg+strlen(msg), sizeof(msg)-strlen(msg), fmt, ap); in sentinelEvent()
617 serverLog(level,"%s %s",type,msg); in sentinelEvent()
622 payload = createStringObject(msg,strlen(msg)); in sentinelEvent()
634 type,msg,NULL); in sentinelEvent()
/redis-3.2.3/deps/lua/src/
H A Dlua.c58 static void l_message (const char *pname, const char *msg) { in l_message() argument
60 fprintf(stderr, "%s\n", msg); in l_message()
67 const char *msg = lua_tostring(L, -1); in report() local
68 if (msg == NULL) msg = "(error object is not a string)"; in report()
69 l_message(progname, msg); in report()
166 const char *msg = lua_tolstring(L, -1, &lmsg); in incomplete() local
167 const char *tp = msg + lmsg - (sizeof(LUA_QL("<eof>")) - 1); in incomplete()
168 if (strstr(msg, LUA_QL("<eof>")) == tp) { in incomplete()
H A Dlua_bit.c169 const char *msg = "compiled with incompatible luaconf.h"; in luaopen_bit() local
173 msg = "use D3DCREATE_FPU_PRESERVE with DirectX"; in luaopen_bit()
176 msg = "not compiled with SWAPPED_DOUBLE"; in luaopen_bit()
179 msg = "arithmetic right-shift broken"; in luaopen_bit()
180 luaL_error(L, "bit library self-test failed (%s)", msg); in luaopen_bit()
H A Dllex.c102 void luaX_lexerror (LexState *ls, const char *msg, int token) { in luaX_lexerror() argument
105 msg = luaO_pushfstring(ls->L, "%s:%d: %s", buff, ls->linenumber, msg); in luaX_lexerror()
107 luaO_pushfstring(ls->L, "%s near " LUA_QS, msg, txtToken(ls, token)); in luaX_lexerror()
112 void luaX_syntaxerror (LexState *ls, const char *msg) { in luaX_syntaxerror() argument
113 luaX_lexerror(ls, msg, ls->t.token); in luaX_syntaxerror()
H A Dlobject.c173 const char *msg; in luaO_pushfstring() local
176 msg = luaO_pushvfstring(L, fmt, argp); in luaO_pushfstring()
178 return msg; in luaO_pushfstring()
H A Dllex.h76 LUAI_FUNC void luaX_lexerror (LexState *ls, const char *msg, int token);
H A Dlua_struct.c162 const char *msg = lua_pushfstring(L, "invalid format option '%c'", opt); in controloptions() local
163 luaL_argerror(L, 1, msg); in controloptions()
H A Dlauxlib.h61 LUALIB_API void (luaL_checkstack) (lua_State *L, int sz, const char *msg);
H A Dlauxlib.c62 const char *msg = lua_pushfstring(L, "%s expected, got %s", in luaL_typerror() local
64 return luaL_argerror(L, narg, msg); in luaL_typerror()
H A Dldo.c409 static int resume_error (lua_State *L, const char *msg) { in resume_error() argument
411 setsvalue2s(L, L->top, luaS_new(L, msg)); in resume_error()
H A Dldebug.c607 static void addinfo (lua_State *L, const char *msg) { in addinfo() argument
613 luaO_pushfstring(L, "%s:%d: %s", buff, line, msg); in addinfo()
/redis-3.2.3/tests/cluster/tests/
H A D09-pubsub.tcl25 set msg [R $j read]
26 assert {$data eq [lindex $msg 2]}
/redis-3.2.3/tests/
H A Dinstances.tcl129 proc abort_sentinel_test msg { argument
132 puts ">>>>>>>> $msg"
256 set msg [string range $error 10 end]
257 puts [colorstr red $msg]
/redis-3.2.3/tests/unit/
H A Dpubsub.tcl7 set msg [$client read]
8 assert_equal $type [lindex $msg 0]
13 set idx [lsearch -exact $channels [lindex $msg 1]]
22 lappend counts [lindex $msg 2]

12