Lines Matching refs:cmd
2051 int redisOpArrayAppend(redisOpArray *oa, struct redisCommand *cmd, int dbid, in redisOpArrayAppend() argument
2058 op->cmd = cmd; in redisOpArrayAppend()
2088 struct redisCommand *cmd; in lookupCommandByCString() local
2091 cmd = dictFetchValue(server.commands, name); in lookupCommandByCString()
2093 return cmd; in lookupCommandByCString()
2104 struct redisCommand *cmd = dictFetchValue(server.commands, name); in lookupCommandOrOriginal() local
2106 if (!cmd) cmd = dictFetchValue(server.orig_commands,name); in lookupCommandOrOriginal()
2107 return cmd; in lookupCommandOrOriginal()
2121 void propagate(struct redisCommand *cmd, int dbid, robj **argv, int argc, in propagate() argument
2125 feedAppendOnlyFile(cmd,dbid,argv,argc); in propagate()
2142 void alsoPropagate(struct redisCommand *cmd, int dbid, robj **argv, int argc, in alsoPropagate() argument
2155 redisOpArrayAppend(&server.also_propagate,cmd,dbid,argvcopy,argc,target); in alsoPropagate()
2228 !(c->cmd->flags & (CMD_SKIP_MONITOR|CMD_ADMIN))) in call()
2241 c->cmd->proc(c); in call()
2263 if (flags & CMD_CALL_SLOWLOG && c->cmd->proc != execCommand) { in call()
2264 char *latency_event = (c->cmd->flags & CMD_FAST) ? in call()
2302 propagate(c->cmd,c->db->id,c->argv,c->argc,propagate_flags); in call()
2326 propagate(rop->cmd,rop->dbid,rop->argv,rop->argc,target); in call()
2355 c->cmd = c->lastcmd = lookupCommand(c->argv[0]->ptr); in processCommand()
2356 if (!c->cmd) { in processCommand()
2361 } else if ((c->cmd->arity > 0 && c->cmd->arity != c->argc) || in processCommand()
2362 (c->argc < -c->cmd->arity)) { in processCommand()
2365 c->cmd->name); in processCommand()
2370 if (server.requirepass && !c->authenticated && c->cmd->proc != authCommand) in processCommand()
2385 !(c->cmd->getkeys_proc == NULL && c->cmd->firstkey == 0 && in processCommand()
2386 c->cmd->proc != execCommand)) in processCommand()
2390 clusterNode *n = getNodeByQuery(c,c->cmd,c->argv,c->argc, in processCommand()
2393 if (c->cmd->proc == execCommand) { in processCommand()
2416 if ((c->cmd->flags & CMD_DENYOOM) && retval == C_ERR) { in processCommand()
2430 (c->cmd->flags & CMD_WRITE || in processCommand()
2431 c->cmd->proc == pingCommand)) in processCommand()
2449 c->cmd->flags & CMD_WRITE && in processCommand()
2461 c->cmd->flags & CMD_WRITE) in processCommand()
2469 c->cmd->proc != pingCommand && in processCommand()
2470 c->cmd->proc != subscribeCommand && in processCommand()
2471 c->cmd->proc != unsubscribeCommand && in processCommand()
2472 c->cmd->proc != psubscribeCommand && in processCommand()
2473 c->cmd->proc != punsubscribeCommand) { in processCommand()
2482 !(c->cmd->flags & CMD_STALE)) in processCommand()
2491 if (server.loading && !(c->cmd->flags & CMD_LOADING)) { in processCommand()
2498 c->cmd->proc != authCommand && in processCommand()
2499 c->cmd->proc != replconfCommand && in processCommand()
2500 !(c->cmd->proc == shutdownCommand && in processCommand()
2503 !(c->cmd->proc == scriptCommand && in processCommand()
2514 c->cmd->proc != execCommand && c->cmd->proc != discardCommand && in processCommand()
2515 c->cmd->proc != multiCommand && c->cmd->proc != watchCommand) in processCommand()
2676 c->cmd->name); in pingCommand()
2711 int addReplyCommandFlag(client *c, struct redisCommand *cmd, int f, char *reply) { in addReplyCommandFlag() argument
2712 if (cmd->flags & f) { in addReplyCommandFlag()
2720 void addReplyCommand(client *c, struct redisCommand *cmd) { in addReplyCommand() argument
2721 if (!cmd) { in addReplyCommand()
2726 addReplyBulkCString(c, cmd->name); in addReplyCommand()
2727 addReplyLongLong(c, cmd->arity); in addReplyCommand()
2731 flagcount += addReplyCommandFlag(c,cmd,CMD_WRITE, "write"); in addReplyCommand()
2732 flagcount += addReplyCommandFlag(c,cmd,CMD_READONLY, "readonly"); in addReplyCommand()
2733 flagcount += addReplyCommandFlag(c,cmd,CMD_DENYOOM, "denyoom"); in addReplyCommand()
2734 flagcount += addReplyCommandFlag(c,cmd,CMD_ADMIN, "admin"); in addReplyCommand()
2735 flagcount += addReplyCommandFlag(c,cmd,CMD_PUBSUB, "pubsub"); in addReplyCommand()
2736 flagcount += addReplyCommandFlag(c,cmd,CMD_NOSCRIPT, "noscript"); in addReplyCommand()
2737 flagcount += addReplyCommandFlag(c,cmd,CMD_RANDOM, "random"); in addReplyCommand()
2738 flagcount += addReplyCommandFlag(c,cmd,CMD_SORT_FOR_SCRIPT,"sort_for_script"); in addReplyCommand()
2739 flagcount += addReplyCommandFlag(c,cmd,CMD_LOADING, "loading"); in addReplyCommand()
2740 flagcount += addReplyCommandFlag(c,cmd,CMD_STALE, "stale"); in addReplyCommand()
2741 flagcount += addReplyCommandFlag(c,cmd,CMD_SKIP_MONITOR, "skip_monitor"); in addReplyCommand()
2742 flagcount += addReplyCommandFlag(c,cmd,CMD_ASKING, "asking"); in addReplyCommand()
2743 flagcount += addReplyCommandFlag(c,cmd,CMD_FAST, "fast"); in addReplyCommand()
2744 if (cmd->getkeys_proc) { in addReplyCommand()
2750 addReplyLongLong(c, cmd->firstkey); in addReplyCommand()
2751 addReplyLongLong(c, cmd->lastkey); in addReplyCommand()
2752 addReplyLongLong(c, cmd->keystep); in addReplyCommand()
2777 struct redisCommand *cmd = lookupCommand(c->argv[2]->ptr); in commandCommand() local
2780 if (!cmd) { in commandCommand()
2783 } else if ((cmd->arity > 0 && cmd->arity != c->argc-2) || in commandCommand()
2784 ((c->argc-2) < -cmd->arity)) in commandCommand()
2790 keys = getKeysFromCommand(cmd,c->argv+2,c->argc-2,&numkeys); in commandCommand()