Lines Matching refs:value
41 void listTypePush(robj *subject, robj *value, int where) { in listTypePush() argument
44 value = getDecodedObject(value); in listTypePush()
45 size_t len = sdslen(value->ptr); in listTypePush()
46 quicklistPush(subject->ptr, value->ptr, len, pos); in listTypePush()
47 decrRefCount(value); in listTypePush()
59 robj *value = NULL; in listTypePop() local
63 if (quicklistPopCustom(subject->ptr, ql_where, (unsigned char **)&value, in listTypePop()
65 if (!value) in listTypePop()
66 value = createStringObjectFromLongLong(vlong); in listTypePop()
71 return value; in listTypePop()
127 robj *value = NULL; in listTypeGet() local
129 if (entry->entry.value) { in listTypeGet()
130 value = createStringObject((char *)entry->entry.value, in listTypeGet()
133 value = createStringObjectFromLongLong(entry->entry.longval); in listTypeGet()
138 return value; in listTypeGet()
141 void listTypeInsert(listTypeEntry *entry, robj *value, int where) { in listTypeInsert() argument
143 value = getDecodedObject(value); in listTypeInsert()
144 sds str = value->ptr; in listTypeInsert()
153 decrRefCount(value); in listTypeInsert()
309 robj *value = NULL; in lindexCommand() local
317 if (entry.value) { in lindexCommand()
318 value = createStringObject((char*)entry.value,entry.sz); in lindexCommand()
320 value = createStringObjectFromLongLong(entry.longval); in lindexCommand()
322 addReplyBulk(c,value); in lindexCommand()
323 decrRefCount(value); in lindexCommand()
336 robj *value = c->argv[3]; in lsetCommand() local
344 value->ptr, sdslen(value->ptr)); in lsetCommand()
362 robj *value = listTypePop(o,where); in popGenericCommand() local
363 if (value == NULL) { in popGenericCommand()
368 addReplyBulk(c,value); in popGenericCommand()
369 decrRefCount(value); in popGenericCommand()
423 if (qe->value) { in lrangeCommand()
424 addReplyBulkCBuffer(c,qe->value,qe->sz); in lrangeCommand()
541 void rpoplpushHandlePush(client *c, robj *dstkey, robj *dstobj, robj *value) { in rpoplpushHandlePush() argument
550 listTypePush(dstobj,value,LIST_HEAD); in rpoplpushHandlePush()
553 addReplyBulk(c,value); in rpoplpushHandlePush()
557 robj *sobj, *value; in rpoplpushCommand() local
570 value = listTypePop(sobj,LIST_TAIL); in rpoplpushCommand()
575 rpoplpushHandlePush(c,c->argv[2],dobj,value); in rpoplpushCommand()
578 decrRefCount(value); in rpoplpushCommand()
729 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList() argument
745 addReplyBulk(receiver,value); in serveClientBlockedOnList()
761 value); in serveClientBlockedOnList()
765 argv[2] = value; in serveClientBlockedOnList()
802 readyList *rl = ln->value; in handleClientsBlockedOnLists()
823 client *receiver = clientnode->value; in handleClientsBlockedOnLists()
828 robj *value = listTypePop(o,where); in handleClientsBlockedOnLists() local
830 if (value) { in handleClientsBlockedOnLists()
838 rl->key,dstkey,rl->db,value, in handleClientsBlockedOnLists()
843 listTypePush(o,value,where); in handleClientsBlockedOnLists()
847 decrRefCount(value); in handleClientsBlockedOnLists()
889 robj *value = listTypePop(o,where); in blockingPopGenericCommand() local
890 serverAssert(value != NULL); in blockingPopGenericCommand()
894 addReplyBulk(c,value); in blockingPopGenericCommand()
895 decrRefCount(value); in blockingPopGenericCommand()