Lines Matching refs:LIST_HEAD
43 int pos = (where == LIST_HEAD) ? QUICKLIST_HEAD : QUICKLIST_TAIL; in listTypePush()
61 int ql_where = where == LIST_HEAD ? QUICKLIST_HEAD : QUICKLIST_TAIL; in listTypePop()
93 direction == LIST_HEAD ? AL_START_TAIL : AL_START_HEAD; in listTypeInitIterator()
149 } else if (where == LIST_HEAD) { in listTypeInsert()
219 char *event = (where == LIST_HEAD) ? "lpush" : "rpush"; in pushGenericCommand()
228 pushGenericCommand(c,LIST_HEAD); in lpushCommand()
267 char *event = (where == LIST_HEAD) ? "lpush" : "rpush"; in pushxGenericCommand()
280 pushxGenericCommand(c,NULL,c->argv[2],LIST_HEAD); in lpushxCommand()
293 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_HEAD); in linsertCommand()
366 char *event = (where == LIST_HEAD) ? "lpop" : "rpop"; in popGenericCommand()
382 popGenericCommand(c,LIST_HEAD); in lpopCommand()
496 li = listTypeInitIterator(subject,-1,LIST_HEAD); in lremCommand()
550 listTypePush(dstobj,value,LIST_HEAD); in rpoplpushHandlePush()
735 argv[0] = (where == LIST_HEAD) ? shared.lpop : in serveClientBlockedOnList()
738 propagate((where == LIST_HEAD) ? in serveClientBlockedOnList()
827 LIST_HEAD : LIST_TAIL; in handleClientsBlockedOnLists()
888 char *event = (where == LIST_HEAD) ? "lpop" : "rpop"; in blockingPopGenericCommand()
908 (where == LIST_HEAD) ? shared.lpop : shared.rpop, in blockingPopGenericCommand()
928 blockingPopGenericCommand(c,LIST_HEAD); in blpopCommand()