Searched refs:dstkey (Results 1 – 3 of 3) sorted by relevance
| /redis-3.2.3/src/ |
| H A D | t_set.c | 802 robj *setobj = dstkey ? in sinterGenericCommand()
807 if (dstkey) { in sinterGenericCommand()
833 if (!dstkey) { in sinterGenericCommand()
884 if (!dstkey) { in sinterGenericCommand()
903 if (dstkey) { in sinterGenericCommand()
911 dstkey,c->db->id); in sinterGenericCommand()
917 dstkey,c->db->id); in sinterGenericCommand()
948 robj *setobj = dstkey ? in sunionDiffGenericCommand()
1066 if (!dstkey) { in sunionDiffGenericCommand()
1084 dstkey,c->db->id); in sunionDiffGenericCommand()
[all …]
|
| H A D | t_list.c | 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()
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()
[all …]
|
| H A D | t_zset.c | 1937 void zunionInterGenericCommand(client *c, robj *dstkey, int op) { in zunionInterGenericCommand() argument
2151 if (dbDelete(c->db,dstkey)) in zunionInterGenericCommand()
2155 dbAdd(c->db,dstkey,dstobj); in zunionInterGenericCommand()
2157 signalModifiedKey(c->db,dstkey); in zunionInterGenericCommand()
2160 dstkey,c->db->id); in zunionInterGenericCommand()
2166 signalModifiedKey(c->db,dstkey); in zunionInterGenericCommand()
2167 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",dstkey,c->db->id); in zunionInterGenericCommand()
|