Lines Matching refs:dstkey
541 void rpoplpushHandlePush(client *c, robj *dstkey, robj *dstobj, robj *value) { in rpoplpushHandlePush() argument
547 dbAdd(c->db,dstkey,dstobj); in rpoplpushHandlePush()
549 signalModifiedKey(c->db,dstkey); in rpoplpushHandlePush()
551 notifyKeyspaceEvent(NOTIFY_LIST,"lpush",dstkey,c->db->id); in rpoplpushHandlePush()
729 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList() argument
733 if (dstkey == NULL) { in serveClientBlockedOnList()
749 lookupKeyWrite(receiver->db,dstkey); in serveClientBlockedOnList()
760 rpoplpushHandlePush(receiver,dstkey,dstobj, in serveClientBlockedOnList()
764 argv[1] = dstkey; in serveClientBlockedOnList()
824 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnLists() local
834 if (dstkey) incrRefCount(dstkey); in handleClientsBlockedOnLists()
838 rl->key,dstkey,rl->db,value, in handleClientsBlockedOnLists()
846 if (dstkey) decrRefCount(dstkey); in handleClientsBlockedOnLists()