Home
last modified time | relevance | path

Searched refs:notifyKeyspaceEvent (Results 1 – 16 of 16) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dt_list.c221 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 Dt_string.c89 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 Dt_set.c284 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 Dexpire.c65 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 Dt_hash.c525 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 Dnotify.c97 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid) { in notifyKeyspaceEvent() function
H A Dbitops.c558 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 Dt_stream.c1237 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 Dsort.c567 notifyKeyspaceEvent(NOTIFY_LIST,"sortstore",storekey, in sortCommand()
572 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",storekey,c->db->id); in sortCommand()
H A Ddb.c477 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 Dt_zset.c1650 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 Dgeo.c662 notifyKeyspaceEvent(NOTIFY_ZSET,"georadiusstore",storekey, in georadiusGeneric()
667 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",storekey,c->db->id); in georadiusGeneric()
H A Devict.c577 notifyKeyspaceEvent(NOTIFY_EVICTED, "evicted", in freeMemoryIfNeeded()
H A Dblocked.c321 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",rl->key,rl->db->id); in handleClientsBlockedOnKeys()
H A Dhyperloglog.c1213 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 Dserver.h1804 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid);