| /f-stack/app/redis-5.0.5/src/ |
| H A D | t_list.c | 221 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushGenericCommand()
251 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushxGenericCommand()
296 notifyKeyspaceEvent(NOTIFY_LIST,"linsert", in linsertCommand()
379 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in popGenericCommand()
381 notifyKeyspaceEvent(NOTIFY_GENERIC,"del", in popGenericCommand()
480 notifyKeyspaceEvent(NOTIFY_LIST,"ltrim",c->argv[1],c->db->id); in ltrimCommand()
560 notifyKeyspaceEvent(NOTIFY_LIST,"lpush",dstkey,c->db->id); in rpoplpushHandlePush()
593 notifyKeyspaceEvent(NOTIFY_GENERIC,"del", in rpoplpushCommand()
648 notifyKeyspaceEvent(NOTIFY_LIST,event,key,receiver->db->id); in serveClientBlockedOnList()
711 notifyKeyspaceEvent(NOTIFY_LIST,event, in blockingPopGenericCommand()
[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()
325 notifyKeyspaceEvent(NOTIFY_STRING,"set",c->argv[j],c->db->id); in msetGenericCommand()
370 notifyKeyspaceEvent(NOTIFY_STRING,"incrby",c->argv[1],c->db->id); in incrDecrCommand()
420 notifyKeyspaceEvent(NOTIFY_STRING,"incrbyfloat",c->argv[1],c->db->id); in incrbyfloatCommand()
461 notifyKeyspaceEvent(NOTIFY_STRING,"append",c->argv[1],c->db->id); in appendCommand()
|
| H A D | t_set.c | 284 notifyKeyspaceEvent(NOTIFY_SET,"sadd",c->argv[1],c->db->id); in saddCommand()
309 notifyKeyspaceEvent(NOTIFY_SET,"srem",c->argv[1],c->db->id); in sremCommand()
311 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1], in sremCommand()
347 notifyKeyspaceEvent(NOTIFY_SET,"srem",c->argv[1],c->db->id); in smoveCommand()
368 notifyKeyspaceEvent(NOTIFY_SET,"sadd",c->argv[2],c->db->id); in smoveCommand()
431 notifyKeyspaceEvent(NOTIFY_SET,"spop",c->argv[1],c->db->id); in spopWithCountCommand()
584 notifyKeyspaceEvent(NOTIFY_SET,"spop",c->argv[1],c->db->id); in spopCommand()
902 notifyKeyspaceEvent(NOTIFY_SET,"sinterstore", in sinterGenericCommand()
908 notifyKeyspaceEvent(NOTIFY_GENERIC,"del", in sinterGenericCommand()
1075 notifyKeyspaceEvent(NOTIFY_SET, in sunionDiffGenericCommand()
[all …]
|
| H A D | expire.c | 65 notifyKeyspaceEvent(NOTIFY_EXPIRED, in activeExpireCycleTryExpire()
439 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in expireGenericCommand()
446 notifyKeyspaceEvent(NOTIFY_GENERIC,"expire",key,c->db->id); in expireGenericCommand()
|
| H A D | t_hash.c | 525 notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id); in hsetnxCommand()
555 notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id); in hsetCommand()
590 notifyKeyspaceEvent(NOTIFY_HASH,"hincrby",c->argv[1],c->db->id); in hincrbyCommand()
629 notifyKeyspaceEvent(NOTIFY_HASH,"hincrbyfloat",c->argv[1],c->db->id); in hincrbyfloatCommand()
725 notifyKeyspaceEvent(NOTIFY_HASH,"hdel",c->argv[1],c->db->id); in hdelCommand()
727 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1], in hdelCommand()
|
| H A D | notify.c | 97 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid) { in notifyKeyspaceEvent() function
|
| H A D | bitops.c | 558 notifyKeyspaceEvent(NOTIFY_STRING,"setbit",c->argv[1],c->db->id); in setbitCommand()
758 notifyKeyspaceEvent(NOTIFY_STRING,"set",targetkey,c->db->id); in bitopCommand()
762 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",targetkey,c->db->id); in bitopCommand()
1127 notifyKeyspaceEvent(NOTIFY_STRING,"setbit",c->argv[1],c->db->id); in bitfieldCommand()
|
| H A D | t_stream.c | 1237 notifyKeyspaceEvent(NOTIFY_STREAM,"xadd",c->argv[1],c->db->id); in xaddCommand()
1243 notifyKeyspaceEvent(NOTIFY_STREAM,"xtrim",c->argv[1],c->db->id); in xaddCommand()
1791 notifyKeyspaceEvent(NOTIFY_STREAM,"xgroup-create", in xgroupCommand()
1807 notifyKeyspaceEvent(NOTIFY_STREAM,"xgroup-setid",c->argv[2],c->db->id); in xgroupCommand()
1814 notifyKeyspaceEvent(NOTIFY_STREAM,"xgroup-destroy", in xgroupCommand()
1825 notifyKeyspaceEvent(NOTIFY_STREAM,"xgroup-delconsumer", in xgroupCommand()
1865 notifyKeyspaceEvent(NOTIFY_STREAM,"xsetid",c->argv[1],c->db->id); in xsetidCommand()
2343 notifyKeyspaceEvent(NOTIFY_STREAM,"xdel",c->argv[1],c->db->id); in xdelCommand()
2420 notifyKeyspaceEvent(NOTIFY_STREAM,"xtrim",c->argv[1],c->db->id); in xtrimCommand()
|
| 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 | db.c | 477 notifyKeyspaceEvent(NOTIFY_GENERIC, in delGenericCommand()
903 notifyKeyspaceEvent(NOTIFY_GENERIC,"rename_from", in renameGenericCommand()
905 notifyKeyspaceEvent(NOTIFY_GENERIC,"rename_to", in renameGenericCommand()
1183 notifyKeyspaceEvent(NOTIFY_EXPIRED, in expireIfNeeded()
|
| H A D | t_zset.c | 1650 notifyKeyspaceEvent(NOTIFY_ZSET, in zaddGenericCommand()
1681 notifyKeyspaceEvent(NOTIFY_ZSET,"zrem",key,c->db->id); in zremCommand()
1683 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in zremCommand()
1783 notifyKeyspaceEvent(NOTIFY_ZSET,event[rangetype],key,c->db->id); in zremrangeGenericCommand()
1785 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in zremrangeGenericCommand()
2387 notifyKeyspaceEvent(NOTIFY_ZSET, in zunionInterGenericCommand()
2396 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",dstkey,c->db->id); in zunionInterGenericCommand()
3219 notifyKeyspaceEvent(NOTIFY_ZSET,events[where],key,c->db->id); in genericZpopCommand()
3231 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",key,c->db->id); in genericZpopCommand()
|
| H A D | geo.c | 662 notifyKeyspaceEvent(NOTIFY_ZSET,"georadiusstore",storekey, in georadiusGeneric()
667 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",storekey,c->db->id); in georadiusGeneric()
|
| H A D | evict.c | 577 notifyKeyspaceEvent(NOTIFY_EVICTED, "evicted", in freeMemoryIfNeeded()
|
| H A D | blocked.c | 321 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",rl->key,rl->db->id); in handleClientsBlockedOnKeys()
|
| H A D | hyperloglog.c | 1213 notifyKeyspaceEvent(NOTIFY_STRING,"pfadd",c->argv[1],c->db->id); in pfaddCommand()
1379 notifyKeyspaceEvent(NOTIFY_STRING,"pfadd",c->argv[1],c->db->id); in pfmergeCommand()
|
| H A D | server.h | 1804 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid);
|