Lines Matching refs:shared
202 addReply(c,shared.wrongtypeerr); in pushGenericCommand()
241 if ((subject = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL || in pushxGenericCommand()
263 addReply(c,shared.cnegone); in pushxGenericCommand()
295 addReply(c,shared.syntaxerr); in linsertCommand()
300 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.czero); in llenCommand()
306 robj *o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk); in lindexCommand()
325 addReply(c,shared.nullbulk); in lindexCommand()
333 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nokeyerr); in lsetCommand()
346 addReply(c,shared.outofrangeerr); in lsetCommand()
348 addReply(c,shared.ok); in lsetCommand()
359 robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk); in popGenericCommand()
364 addReply(c,shared.nullbulk); in popGenericCommand()
396 if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptymultibulk)) == NULL in lrangeCommand()
408 addReply(c,shared.emptymultibulk); in lrangeCommand()
442 if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.ok)) == NULL || in ltrimCommand()
478 addReply(c,shared.ok); in ltrimCommand()
490 subject = lookupKeyWriteOrReply(c,c->argv[1],shared.czero); in lremCommand()
558 if ((sobj = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk)) == NULL || in rpoplpushCommand()
564 addReply(c,shared.nullbulk); in rpoplpushCommand()
735 argv[0] = (where == LIST_HEAD) ? shared.lpop : in serveClientBlockedOnList()
736 shared.rpop; in serveClientBlockedOnList()
754 argv[0] = shared.rpop; in serveClientBlockedOnList()
763 argv[0] = shared.lpush; in serveClientBlockedOnList()
883 addReply(c,shared.wrongtypeerr); in blockingPopGenericCommand()
908 (where == LIST_HEAD) ? shared.lpop : shared.rpop, in blockingPopGenericCommand()
919 addReply(c,shared.nullmultibulk); in blockingPopGenericCommand()
947 addReply(c, shared.nullbulk); in brpoplpushCommand()
954 addReply(c, shared.wrongtypeerr); in brpoplpushCommand()