Lines Matching refs:argv
125 sds *argv; in clusterLoadConfig() local
135 argv = sdssplitargs(line,&argc); in clusterLoadConfig()
136 if (argv == NULL) goto fmterr; in clusterLoadConfig()
140 if (strcasecmp(argv[0],"vars") == 0) { in clusterLoadConfig()
142 if (strcasecmp(argv[j],"currentEpoch") == 0) { in clusterLoadConfig()
144 strtoull(argv[j+1],NULL,10); in clusterLoadConfig()
145 } else if (strcasecmp(argv[j],"lastVoteEpoch") == 0) { in clusterLoadConfig()
147 strtoull(argv[j+1],NULL,10); in clusterLoadConfig()
151 argv[j]); in clusterLoadConfig()
154 sdsfreesplitres(argv,argc); in clusterLoadConfig()
162 n = clusterLookupNode(argv[0]); in clusterLoadConfig()
164 n = createClusterNode(argv[0],0); in clusterLoadConfig()
168 if ((p = strrchr(argv[1],':')) == NULL) goto fmterr; in clusterLoadConfig()
170 memcpy(n->ip,argv[1],strlen(argv[1])+1); in clusterLoadConfig()
174 p = s = argv[2]; in clusterLoadConfig()
205 if (argv[3][0] != '-') { in clusterLoadConfig()
206 master = clusterLookupNode(argv[3]); in clusterLoadConfig()
208 master = createClusterNode(argv[3],0); in clusterLoadConfig()
216 if (atoi(argv[4])) n->ping_sent = mstime(); in clusterLoadConfig()
217 if (atoi(argv[5])) n->pong_received = mstime(); in clusterLoadConfig()
220 n->configEpoch = strtoull(argv[6],NULL,10); in clusterLoadConfig()
226 if (argv[j][0] == '[') { in clusterLoadConfig()
232 p = strchr(argv[j],'-'); in clusterLoadConfig()
236 slot = atoi(argv[j]+1); in clusterLoadConfig()
249 } else if ((p = strchr(argv[j],'-')) != NULL) { in clusterLoadConfig()
251 start = atoi(argv[j]); in clusterLoadConfig()
254 start = stop = atoi(argv[j]); in clusterLoadConfig()
259 sdsfreesplitres(argv,argc); in clusterLoadConfig()
3886 if (!strcasecmp(c->argv[1]->ptr,"meet") && c->argc == 4) { in clusterCommand()
3889 if (getLongLongFromObject(c->argv[3], &port) != C_OK) { in clusterCommand()
3891 (char*)c->argv[3]->ptr); in clusterCommand()
3895 if (clusterStartHandshake(c->argv[2]->ptr,port) == 0 && in clusterCommand()
3899 (char*)c->argv[2]->ptr, (char*)c->argv[3]->ptr); in clusterCommand()
3903 } else if (!strcasecmp(c->argv[1]->ptr,"nodes") && c->argc == 2) { in clusterCommand()
3911 } else if (!strcasecmp(c->argv[1]->ptr,"myid") && c->argc == 2) { in clusterCommand()
3914 } else if (!strcasecmp(c->argv[1]->ptr,"slots") && c->argc == 2) { in clusterCommand()
3917 } else if (!strcasecmp(c->argv[1]->ptr,"flushslots") && c->argc == 2) { in clusterCommand()
3926 } else if ((!strcasecmp(c->argv[1]->ptr,"addslots") || in clusterCommand()
3927 !strcasecmp(c->argv[1]->ptr,"delslots")) && c->argc >= 3) in clusterCommand()
3933 int del = !strcasecmp(c->argv[1]->ptr,"delslots"); in clusterCommand()
3939 if ((slot = getSlotOrReply(c,c->argv[j])) == -1) { in clusterCommand()
3976 } else if (!strcasecmp(c->argv[1]->ptr,"setslot") && c->argc >= 4) { in clusterCommand()
3989 if ((slot = getSlotOrReply(c,c->argv[2])) == -1) return; in clusterCommand()
3991 if (!strcasecmp(c->argv[3]->ptr,"migrating") && c->argc == 5) { in clusterCommand()
3996 if ((n = clusterLookupNode(c->argv[4]->ptr)) == NULL) { in clusterCommand()
3998 (char*)c->argv[4]->ptr); in clusterCommand()
4002 } else if (!strcasecmp(c->argv[3]->ptr,"importing") && c->argc == 5) { in clusterCommand()
4008 if ((n = clusterLookupNode(c->argv[4]->ptr)) == NULL) { in clusterCommand()
4010 (char*)c->argv[3]->ptr); in clusterCommand()
4014 } else if (!strcasecmp(c->argv[3]->ptr,"stable") && c->argc == 4) { in clusterCommand()
4018 } else if (!strcasecmp(c->argv[3]->ptr,"node") && c->argc == 5) { in clusterCommand()
4020 clusterNode *n = clusterLookupNode(c->argv[4]->ptr); in clusterCommand()
4024 (char*)c->argv[4]->ptr); in clusterCommand()
4073 } else if (!strcasecmp(c->argv[1]->ptr,"bumpepoch") && c->argc == 2) { in clusterCommand()
4080 } else if (!strcasecmp(c->argv[1]->ptr,"info") && c->argc == 2) { in clusterCommand()
4132 } else if (!strcasecmp(c->argv[1]->ptr,"saveconfig") && c->argc == 2) { in clusterCommand()
4140 } else if (!strcasecmp(c->argv[1]->ptr,"keyslot") && c->argc == 3) { in clusterCommand()
4142 sds key = c->argv[2]->ptr; in clusterCommand()
4145 } else if (!strcasecmp(c->argv[1]->ptr,"countkeysinslot") && c->argc == 3) { in clusterCommand()
4149 if (getLongLongFromObjectOrReply(c,c->argv[2],&slot,NULL) != C_OK) in clusterCommand()
4156 } else if (!strcasecmp(c->argv[1]->ptr,"getkeysinslot") && c->argc == 4) { in clusterCommand()
4162 if (getLongLongFromObjectOrReply(c,c->argv[2],&slot,NULL) != C_OK) in clusterCommand()
4164 if (getLongLongFromObjectOrReply(c,c->argv[3],&maxkeys,NULL) in clusterCommand()
4177 } else if (!strcasecmp(c->argv[1]->ptr,"forget") && c->argc == 3) { in clusterCommand()
4179 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4182 addReplyErrorFormat(c,"Unknown node %s", (char*)c->argv[2]->ptr); in clusterCommand()
4196 } else if (!strcasecmp(c->argv[1]->ptr,"replicate") && c->argc == 3) { in clusterCommand()
4198 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4202 addReplyErrorFormat(c,"Unknown node %s", (char*)c->argv[2]->ptr); in clusterCommand()
4233 } else if (!strcasecmp(c->argv[1]->ptr,"slaves") && c->argc == 3) { in clusterCommand()
4235 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4240 addReplyErrorFormat(c,"Unknown node %s", (char*)c->argv[2]->ptr); in clusterCommand()
4255 } else if (!strcasecmp(c->argv[1]->ptr,"count-failure-reports") && in clusterCommand()
4259 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4262 addReplyErrorFormat(c,"Unknown node %s", (char*)c->argv[2]->ptr); in clusterCommand()
4267 } else if (!strcasecmp(c->argv[1]->ptr,"failover") && in clusterCommand()
4274 if (!strcasecmp(c->argv[2]->ptr,"force")) { in clusterCommand()
4276 } else if (!strcasecmp(c->argv[2]->ptr,"takeover")) { in clusterCommand()
4322 } else if (!strcasecmp(c->argv[1]->ptr,"set-config-epoch") && c->argc == 3) in clusterCommand()
4333 if (getLongLongFromObjectOrReply(c,c->argv[2],&epoch,NULL) != C_OK) in clusterCommand()
4358 } else if (!strcasecmp(c->argv[1]->ptr,"reset") && in clusterCommand()
4366 if (!strcasecmp(c->argv[2]->ptr,"hard")) { in clusterCommand()
4368 } else if (!strcasecmp(c->argv[2]->ptr,"soft")) { in clusterCommand()
4456 if ((o = lookupKeyRead(c->db,c->argv[1])) == NULL) { in dumpCommand()
4480 if (!strcasecmp(c->argv[j]->ptr,"replace")) { in restoreCommand()
4489 if (!replace && lookupKeyWrite(c->db,c->argv[1]) != NULL) { in restoreCommand()
4495 if (getLongLongFromObjectOrReply(c,c->argv[2],&ttl,NULL) != C_OK) { in restoreCommand()
4503 if (verifyDumpPayload(c->argv[3]->ptr,sdslen(c->argv[3]->ptr)) == C_ERR) in restoreCommand()
4509 rioInitWithBuffer(&payload,c->argv[3]->ptr); in restoreCommand()
4518 if (replace) dbDelete(c->db,c->argv[1]); in restoreCommand()
4521 dbAdd(c->db,c->argv[1],obj); in restoreCommand()
4522 if (ttl) setExpire(c->db,c->argv[1],mstime()+ttl); in restoreCommand()
4523 signalModifiedKey(c->db,c->argv[1]); in restoreCommand()
4581 fd = anetTcpNonBlockConnect(server.neterr,c->argv[1]->ptr, in migrateGetSocket()
4582 atoi(c->argv[2]->ptr)); in migrateGetSocket()
4674 if (!strcasecmp(c->argv[j]->ptr,"copy")) { in migrateCommand()
4676 } else if (!strcasecmp(c->argv[j]->ptr,"replace")) { in migrateCommand()
4678 } else if (!strcasecmp(c->argv[j]->ptr,"keys")) { in migrateCommand()
4679 if (sdslen(c->argv[3]->ptr) != 0) { in migrateCommand()
4695 if (getLongFromObjectOrReply(c,c->argv[5],&timeout,NULL) != C_OK || in migrateCommand()
4696 getLongFromObjectOrReply(c,c->argv[4],&dbid,NULL) != C_OK) in migrateCommand()
4712 if ((ov[oi] = lookupKeyRead(c->db,c->argv[first_key+j])) != NULL) { in migrateCommand()
4713 kv[oi] = c->argv[first_key+j]; in migrateCommand()
4728 cs = migrateGetSocket(c,c->argv[1],c->argv[2],timeout); in migrateCommand()
4877 if (socket_error) migrateCloseSocket(c->argv[1],c->argv[2]); in migrateCommand()
4887 migrateCloseSocket(c->argv[1],c->argv[2]); in migrateCommand()
4974 clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashsl… in getNodeByQuery() argument
4999 mc.argv = argv; in getNodeByQuery()
5013 margv = ms->commands[i].argv; in getNodeByQuery()