Home
last modified time | relevance | path

Searched refs:argv (Results 1 – 25 of 82) sorted by relevance

1234

/redis-3.2.3/src/
H A Dt_string.c138 c->argv[2] = tryObjectEncoding(c->argv[2]); in setCommand()
143 c->argv[2] = tryObjectEncoding(c->argv[2]); in setnxCommand()
148 c->argv[3] = tryObjectEncoding(c->argv[3]); in setexCommand()
149 setGenericCommand(c,OBJ_SET_NO_FLAGS,c->argv[1],c->argv[3],c->argv[2],UNIT_SECONDS,NULL,NULL); in setexCommand()
153 c->argv[3] = tryObjectEncoding(c->argv[3]); in psetexCommand()
178 c->argv[2] = tryObjectEncoding(c->argv[2]); in getsetCommand()
179 setKey(c->db,c->argv[1],c->argv[2]); in getsetCommand()
325 c->argv[j+1] = tryObjectEncoding(c->argv[j+1]); in msetGenericCommand()
326 setKey(c->db,c->argv[j],c->argv[j+1]); in msetGenericCommand()
442 c->argv[2] = tryObjectEncoding(c->argv[2]); in appendCommand()
[all …]
H A Dconfig.c165 sds *argv; in loadServerConfigFromString() local
176 if (argv == NULL) { in loadServerConfigFromString()
186 sdstolower(argv[0]); in loadServerConfigFromString()
624 sdsfreesplitres(argv,argc); in loadServerConfigFromString()
721 serverAssertWithInfo(c,c->argv[2],sdsEncodedObject(c->argv[2]));
722 serverAssertWithInfo(c,c->argv[3],sdsEncodedObject(c->argv[3]));
723 o = c->argv[3];
1052 robj *o = c->argv[2];
1342 sds *argv; local
1357 if (argv == NULL) {
[all …]
H A Dslowlog.c54 se->argv = zmalloc(sizeof(robj*)*slargc); in slowlogCreateEntry()
60 se->argv[j] = createObject(OBJ_STRING, in slowlogCreateEntry()
65 if (argv[j]->type == OBJ_STRING && in slowlogCreateEntry()
66 sdsEncodedObject(argv[j]) && in slowlogCreateEntry()
74 se->argv[j] = createObject(OBJ_STRING,s); in slowlogCreateEntry()
76 se->argv[j] = argv[j]; in slowlogCreateEntry()
77 incrRefCount(argv[j]); in slowlogCreateEntry()
96 decrRefCount(se->argv[j]); in slowlogFreeEntry()
97 zfree(se->argv); in slowlogFreeEntry()
137 !strcasecmp(c->argv[1]->ptr,"get")) in slowlogCommand()
[all …]
H A Dt_list.c207 c->argv[j] = tryObjectEncoding(c->argv[j]); in pushGenericCommand()
279 c->argv[2] = tryObjectEncoding(c->argv[2]); in lpushxCommand()
284 c->argv[2] = tryObjectEncoding(c->argv[2]); in rpushxCommand()
289 c->argv[4] = tryObjectEncoding(c->argv[4]); in linsertCommand()
291 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_TAIL); in linsertCommand()
293 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_HEAD); in linsertCommand()
483 obj = c->argv[3]; in lremCommand()
731 robj *argv[3]; in serveClientBlockedOnList() local
737 argv[1] = key; in serveClientBlockedOnList()
755 argv[1] = key; in serveClientBlockedOnList()
[all …]
H A Dt_hash.c46 if (sdsEncodedObject(argv[i]) && in hashTypeTryConversion()
492 hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]); in hsetCommand()
493 update = hashTypeSet(o,c->argv[2],c->argv[3]); in hsetCommand()
495 signalModifiedKey(c->db,c->argv[1]); in hsetCommand()
505 if (hashTypeExists(o, c->argv[2])) { in hsetnxCommand()
508 hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]); in hsetnxCommand()
509 hashTypeSet(o,c->argv[2],c->argv[3]); in hsetnxCommand()
529 hashTypeTryObjectEncoding(o,&c->argv[i], &c->argv[i+1]); in hmsetCommand()
530 hashTypeSet(o,c->argv[i],c->argv[i+1]); in hmsetCommand()
564 hashTypeSet(o,c->argv[2],new); in hincrbyCommand()
[all …]
H A Dredis-cli.c211 sds *argv; member
378 if (strcasecmp(argv[j],entry->argv[j]) != 0) break; in cliOutputHelp()
873 if (!strcasecmp(argv[2],"yes") || !strcasecmp(argv[2],"sync")) { in cliSendCommand()
1053 } else if (!strcmp(argv[i],"-v") || !strcmp(argv[i], "--version")) { in parseOptions()
1217 return argv; in cliSplitArgs()
1238 argv[0]); in cliSetPreferences()
1251 sds *argv; in cliLoadPreferences() local
1267 sds *argv; in repl() local
1361 argv = zrealloc(argv, (argc+1)*sizeof(char*)); in noninteractive()
1423 if (!got_comma && argv[j][0] == ',' && argv[j][1] == 0) { in evalMode()
[all …]
H A Dt_set.c279 dbAdd(c->db,c->argv[1],set); in saddCommand()
288 c->argv[j] = tryObjectEncoding(c->argv[j]); in saddCommand()
331 ele = c->argv[3] = tryObjectEncoding(c->argv[3]); in smoveCommand()
359 dbDelete(c->db,c->argv[1]); in smoveCommand()
387 c->argv[2] = tryObjectEncoding(c->argv[2]); in sismemberCommand()
451 dbDelete(c->db,c->argv[1]); in spopWithCountCommand()
466 propargv[1] = c->argv[1]; in spopWithCountCommand()
605 dbDelete(c->db,c->argv[1]); in spopCommand()
932 sinterGenericCommand(c,c->argv+2,c->argc-2,c->argv[1]); in sinterstoreCommand()
1103 sunionDiffGenericCommand(c,c->argv+2,c->argc-2,c->argv[1],SET_OP_UNION); in sunionstoreCommand()
[all …]
H A Dredis-benchmark.c488 if (!strcmp(argv[i],"-c")) { in parseOptions()
491 } else if (!strcmp(argv[i],"-n")) { in parseOptions()
494 } else if (!strcmp(argv[i],"-k")) { in parseOptions()
648 int main(int argc, const char **argv) { in main() argument
683 i = parseOptions(argc,argv); in main()
685 argv += i; in main()
703 sds title = sdsnew(argv[0]); in main()
706 title = sdscatlen(title, (char*)argv[i], strlen(argv[i])); in main()
824 const char *argv[21]; in main() local
825 argv[0] = "MSET"; in main()
[all …]
H A Dsetproctitle.c130 static int spt_copyargs(int argc, char *argv[]) { in spt_copyargs() argument
134 for (i = 1; i < argc || (i >= argc && argv[i]); i++) { in spt_copyargs()
135 if (!argv[i]) in spt_copyargs()
138 if (!(tmp = strdup(argv[i]))) in spt_copyargs()
141 argv[i] = tmp; in spt_copyargs()
148 void spt_init(int argc, char *argv[]) { in spt_init() argument
153 if (!(base = argv[0])) in spt_init()
160 if (!argv[i] || argv[i] < end) in spt_init()
163 end = argv[i] + strlen(argv[i]) + 1; in spt_init()
173 if (!(SPT.arg0 = strdup(argv[0]))) in spt_init()
[all …]
H A Ddb.c738 if (sdscmp(c->argv[1]->ptr,c->argv[2]->ptr) == 0) samekey = 1; in renameGenericCommand()
826 dbAdd(dst,c->argv[1],o); in moveCommand()
881 robj *argv[2]; in propagateExpire() local
883 argv[0] = shared.del; in propagateExpire()
884 argv[1] = key; in propagateExpire()
885 incrRefCount(argv[0]); in propagateExpire()
886 incrRefCount(argv[1]); in propagateExpire()
892 decrRefCount(argv[0]); in propagateExpire()
893 decrRefCount(argv[1]); in propagateExpire()
944 robj *key = c->argv[1], *param = c->argv[2]; in expireGenericCommand()
[all …]
H A Dscripting.c385 argv = zrealloc(argv,sizeof(robj*)*argc); in luaRedisGenericCommand()
436 c->argv = argv; in luaRedisGenericCommand()
616 if (c->argv != argv) { in luaRedisGenericCommand()
618 argv = NULL; in luaRedisGenericCommand()
1247 sha1hex(funcname+2,c->argv[1]->ptr,sdslen(c->argv[1]->ptr)); in evalGenericCommand()
1446 sha1hex(funcname+2,c->argv[2]->ptr,sdslen(c->argv[2]->ptr)); in scriptCommand()
1768 sds *argv = NULL; in ldbReplParseCommand() local
1805 return argv; in ldbReplParseCommand()
2177 lua_pushlstring(lua,argv[j],sdslen(argv[j])); in ldbRedis()
2227 sds *argv; in ldbRepl() local
[all …]
H A Dgeo.c395 robj **argv = zcalloc(argc*sizeof(robj*)); in geoaddCommand() local
397 argv[1] = c->argv[1]; /* key */ in geoaddCommand()
398 incrRefCount(argv[1]); in geoaddCommand()
409 if (argv[i]) decrRefCount(argv[i]); in geoaddCommand()
410 zfree(argv); in geoaddCommand()
419 robj *val = c->argv[2 + i * 3 + 2]; in geoaddCommand()
420 argv[2+i*2] = score; in geoaddCommand()
421 argv[3+i*2] = val; in geoaddCommand()
426 replaceClientCommandVector(c,argc,argv); in geoaddCommand()
441 robj *key = c->argv[1]; in georadiusGeneric()
[all …]
H A Ddebug.c269 if (!strcasecmp(c->argv[1]->ptr,"help")) { in debugCommand()
332 if (c->argc >= 3) c->argv[2] = tryObjectEncoding(c->argv[2]); in debugCommand()
333 serverAssertWithInfo(c,c->argv[0],1 == 2); in debugCommand()
487 errstr = sdscatsds(errstr,c->argv[2]->ptr); in debugCommand()
549 (char*)c->argv[1]->ptr); in debugCommand()
580 if (c->argv[j]->type == OBJ_STRING && sdsEncodedObject(c->argv[j])) { in _serverAssertPrintClientInfo()
581 arg = (char*) c->argv[j]->ptr; in _serverAssertPrintClientInfo()
584 c->argv[j]->type, c->argv[j]->encoding); in _serverAssertPrintClientInfo()
588 j, arg, c->argv[j]->refcount); in _serverAssertPrintClientInfo()
886 decoded = getDecodedObject(cc->argv[j]); in logCurrentClient()
[all …]
H A Dmulti.c49 decrRefCount(mc->argv[i]); in freeClientMultiState()
50 zfree(mc->argv); in freeClientMultiState()
65 mc->argv = zmalloc(sizeof(robj*)*c->argc); in queueMultiCommand()
66 memcpy(mc->argv,c->argv,sizeof(robj*)*c->argc); in queueMultiCommand()
68 incrRefCount(mc->argv[j]); in queueMultiCommand()
141 orig_argv = c->argv; in execCommand()
147 c->argv = c->mstate.commands[j].argv; in execCommand()
163 c->mstate.commands[j].argv = c->argv; in execCommand()
166 c->argv = orig_argv; in execCommand()
181 replicationFeedMonitors(c,server.monitors,c->db->id,c->argv,c->argc); in execCommand()
[all …]
H A Dnetworking.c94 c->argv = NULL; in createClient()
873 zfree(c->argv); in freeClient()
1051 sds *argv, aux; in processInlineBuffer() local
1092 if (c->argv) zfree(c->argv); in processInlineBuffer()
1099 c->argv[c->argc] = createObject(OBJ_STRING,argv[j]); in processInlineBuffer()
1105 zfree(argv); in processInlineBuffer()
1164 if (c->argv) zfree(c->argv); in processMultibulkBuffer()
1661 zfree(c->argv); in rewriteClientCommandVector()
1663 c->argv = argv; in rewriteClientCommandVector()
1674 c->argv = argv; in replaceClientCommandVector()
[all …]
H A Dsentinel.c661 while(sj->argv[j]) sdsfree(sj->argv[j++]); in sentinelReleaseScriptJob()
662 zfree(sj->argv); in sentinelReleaseScriptJob()
677 argv[argc] = sdsnew(argv[argc]); /* Copy the string. */ in sentinelScheduleScriptExecution()
681 argv[0] = sdsnew(path); in sentinelScheduleScriptExecution()
689 memcpy(sj->argv,argv,sizeof(char*)*(argc+1)); in sentinelScheduleScriptExecution()
766 execve(sj->argv[0],sj->argv,environ); in sentinelRunPendingScripts()
878 while (sj->argv[j]) addReplyBulkCString(c,sj->argv[j++]); in sentinelPendingScriptsCommand()
1580 if (createSentinelRedisInstance(argv[1],SRI_MASTER,argv[2], in sentinelHandleConfiguration()
1672 if ((si = createSentinelRedisInstance(argv[4],SRI_SENTINEL,argv[2], in sentinelHandleConfiguration()
1682 if (strlen(argv[1])) in sentinelHandleConfiguration()
[all …]
H A Dpubsub.c281 pubsubSubscribeChannel(c,c->argv[j]); in subscribeCommand()
292 pubsubUnsubscribeChannel(c,c->argv[j],1); in unsubscribeCommand()
301 pubsubSubscribePattern(c,c->argv[j]); in psubscribeCommand()
312 pubsubUnsubscribePattern(c,c->argv[j],1); in punsubscribeCommand()
318 int receivers = pubsubPublishMessage(c->argv[1],c->argv[2]); in publishCommand()
320 clusterPropagatePublish(c->argv[1],c->argv[2]); in publishCommand()
328 if (!strcasecmp(c->argv[1]->ptr,"channels") && in pubsubCommand()
332 sds pat = (c->argc == 2) ? NULL : c->argv[2]->ptr; in pubsubCommand()
352 } else if (!strcasecmp(c->argv[1]->ptr,"numsub") && c->argc >= 2) { in pubsubCommand()
360 addReplyBulk(c,c->argv[j]); in pubsubCommand()
[all …]
H A Dredis-trib.rb971 def check_cluster_cmd(argv,opt) argument
976 def info_cluster_cmd(argv,opt) argument
1135 def fix_cluster_cmd(argv,opt) argument
1278 def create_cluster_cmd(argv,opt) argument
1283 argv[0..-1].each{|n|
1312 xputs ">>> Adding node #{argv[0]} to cluster #{argv[1]}"
1356 id = argv[1].downcase
1394 timeout = argv[1].to_i
1421 def call_cluster_cmd(argv,opt) argument
1422 cmd = argv[1..-1]
[all …]
H A Dcluster.c125 sds *argv; in clusterLoadConfig() local
151 argv[j]); 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()
3899 (char*)c->argv[2]->ptr, (char*)c->argv[3]->ptr); in clusterCommand()
4503 if (verifyDumpPayload(c->argv[3]->ptr,sdslen(c->argv[3]->ptr)) == C_ERR) in restoreCommand()
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()
[all …]
H A Dserver.c1329 robj *argv[3]; in beforeSleep() local
1335 decrRefCount(argv[0]); in beforeSleep()
1336 decrRefCount(argv[1]); in beforeSleep()
1337 decrRefCount(argv[2]); in beforeSleep()
2060 op->argv = argv; in redisOpArrayAppend()
2076 zfree(op->argv); in redisOpArrayFree()
2152 argvcopy[j] = argv[j]; in alsoPropagate()
3964 spt_init(argc, argv); in main()
4018 if (argv[j][0] != '-' || argv[j][1] != '-') { in main()
4033 if (argv[j][0] == '-' && argv[j][1] == '-') { in main()
[all …]
/redis-3.2.3/deps/lua/src/
H A Dlua.c124 lua_pushstring(L, argv[i]); in getargs()
127 lua_pushstring(L, argv[i]); in getargs()
244 fname = argv[n]; in handle_script()
268 notail(argv[i]); in collectargs()
273 notail(argv[i]); in collectargs()
276 notail(argv[i]); in collectargs()
282 if (argv[i][2] == '\0') { in collectargs()
335 char **argv; member
342 char **argv = s->argv; in pmain() local
346 if (argv[0] && argv[0][0]) progname = argv[0]; in pmain()
[all …]
H A Dluac.c68 #define IS(s) (strcmp(argv[i],s)==0)
74 if (argv[0]!=NULL && *argv[0]!=0) progname=argv[0]; in doargs()
91 output=argv[++i]; in doargs()
102 usage(argv[i]); in doargs()
107 argv[--i]=Output; in doargs()
155 char** argv; member
162 char** argv=s->argv; in pmain() local
186 int main(int argc, char* argv[]) in main() argument
190 int i=doargs(argc,argv); in main()
191 argc-=i; argv+=i; in main()
[all …]
/redis-3.2.3/deps/linenoise/
H A Dexample.c23 int main(int argc, char **argv) { in main() argument
25 char *prgname = argv[0]; in main()
30 argv++; in main()
31 if (!strcmp(*argv,"--multiline")) { in main()
34 } else if (!strcmp(*argv,"--keycodes")) { in main()
/redis-3.2.3/tests/helpers/
H A Dbg_complex_data.tcl10 bg_complex_data [lindex $argv 0] [lindex $argv 1] [lindex $argv 2] [lindex $argv 3]
/redis-3.2.3/deps/hiredis/
H A Dtest.c200 const char *argv[3]; in test_format_commands() local
201 argv[0] = "SET"; in test_format_commands()
202 argv[1] = "foo\0xxx"; in test_format_commands()
203 argv[2] = "bar"; in test_format_commands()
663 int main(int argc, char **argv) { in main() argument
680 argv++; argc--; in main()
683 argv++; argc--; in main()
684 cfg.tcp.host = argv[0]; in main()
686 argv++; argc--; in main()
689 argv++; argc--; in main()
[all …]

1234