Lines Matching refs:robj
41 void listTypePush(robj *subject, robj *value, int where) { in listTypePush()
57 robj *listTypePop(robj *subject, int where) { in listTypePop()
59 robj *value = NULL; in listTypePop()
74 unsigned long listTypeLength(robj *subject) { in listTypeLength()
83 listTypeIterator *listTypeInitIterator(robj *subject, long index, in listTypeInitIterator()
126 robj *listTypeGet(listTypeEntry *entry) { in listTypeGet()
127 robj *value = NULL; in listTypeGet()
141 void listTypeInsert(listTypeEntry *entry, robj *value, int where) { in listTypeInsert()
160 int listTypeEqual(listTypeEntry *entry, robj *o) { in listTypeEqual()
179 void listTypeConvert(robj *subject, int enc) { in listTypeConvert()
199 robj *lobj = lookupKeyWrite(c->db,c->argv[1]); in pushGenericCommand()
235 void pushxGenericCommand(client *c, robj *refval, robj *val, int where) { in pushxGenericCommand()
236 robj *subject; in pushxGenericCommand()
300 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.czero); in llenCommand()
306 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk); in lindexCommand()
309 robj *value = NULL; in lindexCommand()
333 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nokeyerr); in lsetCommand()
336 robj *value = c->argv[3]; in lsetCommand()
359 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk); in popGenericCommand()
362 robj *value = listTypePop(o,where); in popGenericCommand()
390 robj *o; in lrangeCommand()
436 robj *o; in ltrimCommand()
482 robj *subject, *obj; in lremCommand()
541 void rpoplpushHandlePush(client *c, robj *dstkey, robj *dstobj, robj *value) { in rpoplpushHandlePush()
557 robj *sobj, *value; in rpoplpushCommand()
566 robj *dobj = lookupKeyWrite(c->db,c->argv[2]); in rpoplpushCommand()
567 robj *touchedkey = c->argv[1]; in rpoplpushCommand()
616 void blockForKeys(client *c, robj **keys, int numkeys, mstime_t timeout, robj *target) { in blockForKeys()
660 robj *key = dictGetKey(de); in unblockClientWaitingData()
687 void signalListAsReady(redisDb *db, robj *key) { in signalListAsReady()
729 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList()
731 robj *argv[3]; in serveClientBlockedOnList()
748 robj *dstobj = in serveClientBlockedOnList()
810 robj *o = lookupKeyWrite(rl->db,rl->key); in handleClientsBlockedOnLists()
824 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnLists()
828 robj *value = listTypePop(o,where); in handleClientsBlockedOnLists()
872 robj *o; in blockingPopGenericCommand()
889 robj *value = listTypePop(o,where); in blockingPopGenericCommand()
941 robj *key = lookupKeyWrite(c->db, c->argv[1]); in brpoplpushCommand()