Home
last modified time | relevance | path

Searched refs:dstkey (Results 1 – 5 of 5) sorted by relevance

/f-stack/app/redis-5.0.5/src/modules/
H A Dhelloworld.c139 RedisModuleKey *dstkey = RedisModule_OpenKey(ctx,argv[2], in HelloListSplice_RedisCommand() local
145 (RedisModule_KeyType(dstkey) != REDISMODULE_KEYTYPE_LIST && in HelloListSplice_RedisCommand()
146 RedisModule_KeyType(dstkey) != REDISMODULE_KEYTYPE_EMPTY)) in HelloListSplice_RedisCommand()
149 RedisModule_CloseKey(dstkey); in HelloListSplice_RedisCommand()
157 RedisModule_CloseKey(dstkey); in HelloListSplice_RedisCommand()
166 RedisModule_ListPush(dstkey,REDISMODULE_LIST_HEAD,ele); in HelloListSplice_RedisCommand()
172 RedisModule_CloseKey(dstkey); in HelloListSplice_RedisCommand()
186 RedisModuleKey *dstkey = RedisModule_OpenKey(ctx,argv[2], in HelloListSpliceAuto_RedisCommand() local
192 (RedisModule_KeyType(dstkey) != REDISMODULE_KEYTYPE_LIST && in HelloListSpliceAuto_RedisCommand()
193 RedisModule_KeyType(dstkey) != REDISMODULE_KEYTYPE_EMPTY)) in HelloListSpliceAuto_RedisCommand()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Dt_set.c804 robj *setobj = dstkey ? in sinterGenericCommand()
809 if (dstkey) { in sinterGenericCommand()
835 if (!dstkey) { in sinterGenericCommand()
876 if (!dstkey) { in sinterGenericCommand()
895 if (dstkey) { in sinterGenericCommand()
903 dstkey,c->db->id); in sinterGenericCommand()
909 dstkey,c->db->id); in sinterGenericCommand()
941 robj *setobj = dstkey ? in sunionDiffGenericCommand()
1059 if (!dstkey) { in sunionDiffGenericCommand()
1077 dstkey,c->db->id); in sunionDiffGenericCommand()
[all …]
H A Dblocked.c68 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i…
289 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnKeys() local
299 if (dstkey) incrRefCount(dstkey); in handleClientsBlockedOnKeys()
303 rl->key,dstkey,rl->db,value, in handleClientsBlockedOnKeys()
311 if (dstkey) decrRefCount(dstkey); in handleClientsBlockedOnKeys()
H A Dt_list.c550 void rpoplpushHandlePush(client *c, robj *dstkey, robj *dstobj, robj *value) { in rpoplpushHandlePush() argument
556 dbAdd(c->db,dstkey,dstobj); in rpoplpushHandlePush()
558 signalModifiedKey(c->db,dstkey); in rpoplpushHandlePush()
560 notifyKeyspaceEvent(NOTIFY_LIST,"lpush",dstkey,c->db->id); in rpoplpushHandlePush()
628 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList() argument
632 if (dstkey == NULL) { in serveClientBlockedOnList()
652 lookupKeyWrite(receiver->db,dstkey); in serveClientBlockedOnList()
663 rpoplpushHandlePush(receiver,dstkey,dstobj, in serveClientBlockedOnList()
667 argv[1] = dstkey; in serveClientBlockedOnList()
H A Dt_zset.c2176 void zunionInterGenericCommand(client *c, robj *dstkey, int op) { in zunionInterGenericCommand() argument
2380 if (dbDelete(c->db,dstkey)) in zunionInterGenericCommand()
2384 dbAdd(c->db,dstkey,dstobj); in zunionInterGenericCommand()
2386 signalModifiedKey(c->db,dstkey); in zunionInterGenericCommand()
2389 dstkey,c->db->id); in zunionInterGenericCommand()
2395 signalModifiedKey(c->db,dstkey); in zunionInterGenericCommand()
2396 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",dstkey,c->db->id); in zunionInterGenericCommand()