Lines Matching refs:o

160 int listTypeEqual(listTypeEntry *entry, robj *o) {  in listTypeEqual()  argument
162 serverAssertWithInfo(NULL,o,sdsEncodedObject(o)); in listTypeEqual()
163 return quicklistCompare(entry->entry.zi,o->ptr,sdslen(o->ptr)); in listTypeEqual()
300 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.czero); in llenCommand() local
301 if (o == NULL || checkType(c,o,OBJ_LIST)) return; in llenCommand()
302 addReplyLongLong(c,listTypeLength(o)); in llenCommand()
306 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk); in lindexCommand() local
307 if (o == NULL || checkType(c,o,OBJ_LIST)) return; in lindexCommand()
314 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in lindexCommand()
316 if (quicklistIndex(o->ptr, index, &entry)) { in lindexCommand()
333 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nokeyerr); in lsetCommand() local
334 if (o == NULL || checkType(c,o,OBJ_LIST)) return; in lsetCommand()
341 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in lsetCommand()
342 quicklist *ql = o->ptr; in lsetCommand()
359 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk); in popGenericCommand() local
360 if (o == NULL || checkType(c,o,OBJ_LIST)) return; in popGenericCommand()
362 robj *value = listTypePop(o,where); in popGenericCommand()
371 if (listTypeLength(o) == 0) { in popGenericCommand()
390 robj *o; in lrangeCommand() local
396 if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptymultibulk)) == NULL in lrangeCommand()
397 || checkType(c,o,OBJ_LIST)) return; in lrangeCommand()
398 llen = listTypeLength(o); in lrangeCommand()
416 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in lrangeCommand()
417 listTypeIterator *iter = listTypeInitIterator(o, start, LIST_TAIL); in lrangeCommand()
436 robj *o; in ltrimCommand() local
442 if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.ok)) == NULL || in ltrimCommand()
443 checkType(c,o,OBJ_LIST)) return; in ltrimCommand()
444 llen = listTypeLength(o); in ltrimCommand()
464 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in ltrimCommand()
465 quicklistDelRange(o->ptr,0,ltrim); in ltrimCommand()
466 quicklistDelRange(o->ptr,-rtrim,rtrim); in ltrimCommand()
472 if (listTypeLength(o) == 0) { in ltrimCommand()
810 robj *o = lookupKeyWrite(rl->db,rl->key); in handleClientsBlockedOnLists() local
811 if (o != NULL && o->type == OBJ_LIST) { in handleClientsBlockedOnLists()
828 robj *value = listTypePop(o,where); in handleClientsBlockedOnLists()
843 listTypePush(o,value,where); in handleClientsBlockedOnLists()
854 if (listTypeLength(o) == 0) { in handleClientsBlockedOnLists()
872 robj *o; in blockingPopGenericCommand() local
880 o = lookupKeyWrite(c->db,c->argv[j]); in blockingPopGenericCommand()
881 if (o != NULL) { in blockingPopGenericCommand()
882 if (o->type != OBJ_LIST) { in blockingPopGenericCommand()
886 if (listTypeLength(o) != 0) { in blockingPopGenericCommand()
889 robj *value = listTypePop(o,where); in blockingPopGenericCommand()
898 if (listTypeLength(o) == 0) { in blockingPopGenericCommand()