Lines Matching refs:receiver
729 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList() argument
743 addReplyMultiBulkLen(receiver,2); in serveClientBlockedOnList()
744 addReplyBulk(receiver,key); in serveClientBlockedOnList()
745 addReplyBulk(receiver,value); in serveClientBlockedOnList()
749 lookupKeyWrite(receiver->db,dstkey); in serveClientBlockedOnList()
751 checkType(receiver,dstobj,OBJ_LIST))) in serveClientBlockedOnList()
760 rpoplpushHandlePush(receiver,dstkey,dstobj, in serveClientBlockedOnList()
823 client *receiver = clientnode->value; in handleClientsBlockedOnLists() local
824 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnLists()
825 int where = (receiver->lastcmd && in handleClientsBlockedOnLists()
826 receiver->lastcmd->proc == blpopCommand) ? in handleClientsBlockedOnLists()
835 unblockClient(receiver); in handleClientsBlockedOnLists()
837 if (serveClientBlockedOnList(receiver, in handleClientsBlockedOnLists()