Lines Matching refs:where
41 void listTypePush(robj *subject, robj *value, int where) { in listTypePush() argument
43 int pos = (where == LIST_HEAD) ? QUICKLIST_HEAD : QUICKLIST_TAIL; in listTypePush()
57 robj *listTypePop(robj *subject, int where) { in listTypePop() argument
61 int ql_where = where == LIST_HEAD ? QUICKLIST_HEAD : QUICKLIST_TAIL; in listTypePop()
141 void listTypeInsert(listTypeEntry *entry, robj *value, int where) { in listTypeInsert() argument
146 if (where == LIST_TAIL) { in listTypeInsert()
149 } else if (where == LIST_HEAD) { in listTypeInsert()
197 void pushGenericCommand(client *c, int where) { in pushGenericCommand() argument
214 listTypePush(lobj,c->argv[j],where); in pushGenericCommand()
219 char *event = (where == LIST_HEAD) ? "lpush" : "rpush"; in pushGenericCommand()
235 void pushxGenericCommand(client *c, robj *refval, robj *val, int where) { in pushxGenericCommand() argument
249 listTypeInsert(&entry,val,where); in pushxGenericCommand()
267 char *event = (where == LIST_HEAD) ? "lpush" : "rpush"; in pushxGenericCommand()
269 listTypePush(subject,val,where); in pushxGenericCommand()
358 void popGenericCommand(client *c, int where) { in popGenericCommand() argument
362 robj *value = listTypePop(o,where); in popGenericCommand()
366 char *event = (where == LIST_HEAD) ? "lpop" : "rpop"; in popGenericCommand()
729 …ClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, int where) in serveClientBlockedOnList() argument
735 argv[0] = (where == LIST_HEAD) ? shared.lpop : in serveClientBlockedOnList()
738 propagate((where == LIST_HEAD) ? in serveClientBlockedOnList()
825 int where = (receiver->lastcmd && in handleClientsBlockedOnLists() local
828 robj *value = listTypePop(o,where); in handleClientsBlockedOnLists()
839 where) == C_ERR) in handleClientsBlockedOnLists()
843 listTypePush(o,value,where); in handleClientsBlockedOnLists()
871 void blockingPopGenericCommand(client *c, int where) { in blockingPopGenericCommand() argument
888 char *event = (where == LIST_HEAD) ? "lpop" : "rpop"; in blockingPopGenericCommand()
889 robj *value = listTypePop(o,where); in blockingPopGenericCommand()
908 (where == LIST_HEAD) ? shared.lpop : shared.rpop, in blockingPopGenericCommand()