| /redis-3.2.3/src/ |
| H A D | t_list.c | 222 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushGenericCommand()
258 notifyKeyspaceEvent(NOTIFY_LIST,"linsert", in pushxGenericCommand()
271 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushxGenericCommand()
370 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in popGenericCommand()
372 notifyKeyspaceEvent(NOTIFY_GENERIC,"del", in popGenericCommand()
471 notifyKeyspaceEvent(NOTIFY_LIST,"ltrim",c->argv[1],c->db->id); in ltrimCommand()
551 notifyKeyspaceEvent(NOTIFY_LIST,"lpush",dstkey,c->db->id); in rpoplpushHandlePush()
581 notifyKeyspaceEvent(NOTIFY_LIST,"rpop",touchedkey,c->db->id); in rpoplpushCommand()
584 notifyKeyspaceEvent(NOTIFY_GENERIC,"del", in rpoplpushCommand()
896 notifyKeyspaceEvent(NOTIFY_LIST,event, in blockingPopGenericCommand()
[all …]
|
| H A D | t_set.c | 293 notifyKeyspaceEvent(NOTIFY_SET,"sadd",c->argv[1],c->db->id); in saddCommand()
318 notifyKeyspaceEvent(NOTIFY_SET,"srem",c->argv[1],c->db->id); in sremCommand()
320 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1], in sremCommand()
355 notifyKeyspaceEvent(NOTIFY_SET,"srem",c->argv[1],c->db->id); in smoveCommand()
376 notifyKeyspaceEvent(NOTIFY_SET,"sadd",c->argv[2],c->db->id); in smoveCommand()
440 notifyKeyspaceEvent(NOTIFY_SET,"spop",c->argv[1],c->db->id); in spopWithCountCommand()
592 notifyKeyspaceEvent(NOTIFY_SET,"spop",c->argv[1],c->db->id); in spopCommand()
910 notifyKeyspaceEvent(NOTIFY_SET,"sinterstore", in sinterGenericCommand()
916 notifyKeyspaceEvent(NOTIFY_GENERIC,"del", in sinterGenericCommand()
1082 notifyKeyspaceEvent(NOTIFY_SET, in sunionDiffGenericCommand()
[all …]
|
| H A D | t_string.c | 89 notifyKeyspaceEvent(NOTIFY_STRING,"set",key,c->db->id); in setGenericCommand()
90 if (expire) notifyKeyspaceEvent(NOTIFY_GENERIC, in setGenericCommand()
180 notifyKeyspaceEvent(NOTIFY_STRING,"set",c->argv[1],c->db->id); in getsetCommand()
237 notifyKeyspaceEvent(NOTIFY_STRING, in setrangeCommand()
327 notifyKeyspaceEvent(NOTIFY_STRING,"set",c->argv[j],c->db->id); in msetGenericCommand()
372 notifyKeyspaceEvent(NOTIFY_STRING,"incrby",c->argv[1],c->db->id); in incrDecrCommand()
422 notifyKeyspaceEvent(NOTIFY_STRING,"incrbyfloat",c->argv[1],c->db->id); in incrbyfloatCommand()
463 notifyKeyspaceEvent(NOTIFY_STRING,"append",c->argv[1],c->db->id); in appendCommand()
|
| H A D | t_hash.c | 496 notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id); in hsetCommand()
512 notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id); in hsetnxCommand()
534 notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id); in hmsetCommand()
568 notifyKeyspaceEvent(NOTIFY_HASH,"hincrby",c->argv[1],c->db->id); in hincrbyCommand()
595 notifyKeyspaceEvent(NOTIFY_HASH,"hincrbyfloat",c->argv[1],c->db->id); in hincrbyfloatCommand()
693 notifyKeyspaceEvent(NOTIFY_HASH,"hdel",c->argv[1],c->db->id); in hdelCommand()
695 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1], in hdelCommand()
|
| H A D | notify.c | 95 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid) { in notifyKeyspaceEvent() function
|
| H A D | db.c | 351 notifyKeyspaceEvent(NOTIFY_GENERIC, in delCommand()
765 notifyKeyspaceEvent(NOTIFY_GENERIC,"rename_from", in renameGenericCommand()
767 notifyKeyspaceEvent(NOTIFY_GENERIC,"rename_to", in renameGenericCommand()
927 notifyKeyspaceEvent(NOTIFY_EXPIRED, in expireIfNeeded()
976 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in expireGenericCommand()
983 notifyKeyspaceEvent(NOTIFY_GENERIC,"expire",key,c->db->id); in expireGenericCommand()
|
| H A D | bitops.c | 551 notifyKeyspaceEvent(NOTIFY_STRING,"setbit",c->argv[1],c->db->id); in setbitCommand()
747 notifyKeyspaceEvent(NOTIFY_STRING,"set",targetkey,c->db->id); in bitopCommand()
751 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",targetkey,c->db->id); in bitopCommand()
1109 notifyKeyspaceEvent(NOTIFY_STRING,"setbit",c->argv[1],c->db->id); in bitfieldCommand()
|
| H A D | sort.c | 567 notifyKeyspaceEvent(NOTIFY_LIST,"sortstore",storekey, in sortCommand()
572 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",storekey,c->db->id); in sortCommand()
|
| H A D | geo.c | 637 notifyKeyspaceEvent(NOTIFY_LIST,"georadiusstore",storekey, in georadiusGeneric()
642 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",storekey,c->db->id); in georadiusGeneric()
|
| H A D | t_zset.c | 1398 notifyKeyspaceEvent(NOTIFY_ZSET, in zaddGenericCommand()
1462 notifyKeyspaceEvent(NOTIFY_ZSET,"zrem",key,c->db->id); in zremCommand()
1464 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in zremCommand()
1564 notifyKeyspaceEvent(NOTIFY_ZSET,event[rangetype],key,c->db->id); in zremrangeGenericCommand()
1566 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in zremrangeGenericCommand()
2158 notifyKeyspaceEvent(NOTIFY_ZSET, in zunionInterGenericCommand()
2167 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",dstkey,c->db->id); in zunionInterGenericCommand()
|
| H A D | hyperloglog.c | 1187 notifyKeyspaceEvent(NOTIFY_STRING,"pfadd",c->argv[1],c->db->id); in pfaddCommand()
1340 notifyKeyspaceEvent(NOTIFY_STRING,"pfadd",c->argv[1],c->db->id); in pfmergeCommand()
|
| H A D | server.h | 1387 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid);
|
| H A D | server.c | 735 notifyKeyspaceEvent(NOTIFY_EXPIRED, in activeExpireCycleTryExpire()
3590 notifyKeyspaceEvent(NOTIFY_EVICTED, "evicted", in freeMemoryIfNeeded()
|