Lines Matching refs:argv
199 robj *lobj = lookupKeyWrite(c->db,c->argv[1]); in pushGenericCommand()
207 c->argv[j] = tryObjectEncoding(c->argv[j]); in pushGenericCommand()
212 dbAdd(c->db,c->argv[1],lobj); in pushGenericCommand()
214 listTypePush(lobj,c->argv[j],where); in pushGenericCommand()
221 signalModifiedKey(c->db,c->argv[1]); in pushGenericCommand()
222 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushGenericCommand()
241 if ((subject = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL || in pushxGenericCommand()
257 signalModifiedKey(c->db,c->argv[1]); in pushxGenericCommand()
259 c->argv[1],c->db->id); in pushxGenericCommand()
270 signalModifiedKey(c->db,c->argv[1]); in pushxGenericCommand()
271 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushxGenericCommand()
279 c->argv[2] = tryObjectEncoding(c->argv[2]); in lpushxCommand()
280 pushxGenericCommand(c,NULL,c->argv[2],LIST_HEAD); in lpushxCommand()
284 c->argv[2] = tryObjectEncoding(c->argv[2]); in rpushxCommand()
285 pushxGenericCommand(c,NULL,c->argv[2],LIST_TAIL); in rpushxCommand()
289 c->argv[4] = tryObjectEncoding(c->argv[4]); in linsertCommand()
290 if (strcasecmp(c->argv[2]->ptr,"after") == 0) { in linsertCommand()
291 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_TAIL); in linsertCommand()
292 } else if (strcasecmp(c->argv[2]->ptr,"before") == 0) { in linsertCommand()
293 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_HEAD); in linsertCommand()
300 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.czero); in llenCommand()
306 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk); in lindexCommand()
311 if ((getLongFromObjectOrReply(c, c->argv[2], &index, NULL) != C_OK)) in lindexCommand()
333 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nokeyerr); in lsetCommand()
336 robj *value = c->argv[3]; in lsetCommand()
338 if ((getLongFromObjectOrReply(c, c->argv[2], &index, NULL) != C_OK)) in lsetCommand()
349 signalModifiedKey(c->db,c->argv[1]); in lsetCommand()
350 notifyKeyspaceEvent(NOTIFY_LIST,"lset",c->argv[1],c->db->id); in lsetCommand()
359 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk); in popGenericCommand()
370 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in popGenericCommand()
373 c->argv[1],c->db->id); in popGenericCommand()
374 dbDelete(c->db,c->argv[1]); in popGenericCommand()
376 signalModifiedKey(c->db,c->argv[1]); in popGenericCommand()
393 if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != C_OK) || in lrangeCommand()
394 (getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != C_OK)) return; in lrangeCommand()
396 if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptymultibulk)) == NULL in lrangeCommand()
439 if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != C_OK) || in ltrimCommand()
440 (getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != C_OK)) return; in ltrimCommand()
442 if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.ok)) == NULL || in ltrimCommand()
471 notifyKeyspaceEvent(NOTIFY_LIST,"ltrim",c->argv[1],c->db->id); in ltrimCommand()
473 dbDelete(c->db,c->argv[1]); in ltrimCommand()
474 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in ltrimCommand()
476 signalModifiedKey(c->db,c->argv[1]); in ltrimCommand()
483 obj = c->argv[3]; in lremCommand()
487 if ((getLongFromObjectOrReply(c, c->argv[2], &toremove, NULL) != C_OK)) in lremCommand()
490 subject = lookupKeyWriteOrReply(c,c->argv[1],shared.czero); in lremCommand()
513 signalModifiedKey(c->db,c->argv[1]); in lremCommand()
514 notifyKeyspaceEvent(NOTIFY_GENERIC,"lrem",c->argv[1],c->db->id); in lremCommand()
518 dbDelete(c->db,c->argv[1]); in lremCommand()
519 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in lremCommand()
558 if ((sobj = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk)) == NULL || in rpoplpushCommand()
566 robj *dobj = lookupKeyWrite(c->db,c->argv[2]); in rpoplpushCommand()
567 robj *touchedkey = c->argv[1]; in rpoplpushCommand()
575 rpoplpushHandlePush(c,c->argv[2],dobj,value); in rpoplpushCommand()
731 robj *argv[3]; in serveClientBlockedOnList() local
735 argv[0] = (where == LIST_HEAD) ? shared.lpop : in serveClientBlockedOnList()
737 argv[1] = key; in serveClientBlockedOnList()
740 db->id,argv,2,PROPAGATE_AOF|PROPAGATE_REPL); in serveClientBlockedOnList()
754 argv[0] = shared.rpop; in serveClientBlockedOnList()
755 argv[1] = key; in serveClientBlockedOnList()
757 db->id,argv,2, in serveClientBlockedOnList()
763 argv[0] = shared.lpush; in serveClientBlockedOnList()
764 argv[1] = dstkey; in serveClientBlockedOnList()
765 argv[2] = value; in serveClientBlockedOnList()
767 db->id,argv,3, in serveClientBlockedOnList()
876 if (getTimeoutFromObjectOrReply(c,c->argv[c->argc-1],&timeout,UNIT_SECONDS) in blockingPopGenericCommand()
880 o = lookupKeyWrite(c->db,c->argv[j]); in blockingPopGenericCommand()
893 addReplyBulk(c,c->argv[j]); in blockingPopGenericCommand()
897 c->argv[j],c->db->id); in blockingPopGenericCommand()
899 dbDelete(c->db,c->argv[j]); in blockingPopGenericCommand()
901 c->argv[j],c->db->id); in blockingPopGenericCommand()
903 signalModifiedKey(c->db,c->argv[j]); in blockingPopGenericCommand()
909 c->argv[j]); in blockingPopGenericCommand()
924 blockForKeys(c, c->argv + 1, c->argc - 2, timeout, NULL); in blockingPopGenericCommand()
938 if (getTimeoutFromObjectOrReply(c,c->argv[3],&timeout,UNIT_SECONDS) in brpoplpushCommand()
941 robj *key = lookupKeyWrite(c->db, c->argv[1]); in brpoplpushCommand()
950 blockForKeys(c, c->argv + 1, 1, timeout, c->argv[2]); in brpoplpushCommand()