Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dmulti.c241 listRewind(c->watched_keys,&li); in watchForKey()
248 clients = dictFetchValue(c->db->watched_keys,key); in watchForKey()
251 dictAdd(c->db->watched_keys,key,clients); in watchForKey()
260 listAddNodeTail(c->watched_keys,wk); in watchForKey()
269 if (listLength(c->watched_keys) == 0) return; in unwatchAllKeys()
270 listRewind(c->watched_keys,&li); in unwatchAllKeys()
283 dictDelete(wk->db->watched_keys, wk->key); in unwatchAllKeys()
285 listDelNode(c->watched_keys,ln); in unwatchAllKeys()
298 if (dictSize(db->watched_keys) == 0) return; in touchWatchedKey()
299 clients = dictFetchValue(db->watched_keys, key); in touchWatchedKey()
[all …]
H A Daof.c671 c->watched_keys = listCreate(); in createFakeClient()
690 listRelease(c->watched_keys); in freeFakeClient()
H A Dnetworking.c152 c->watched_keys = listCreate(); in createClient()
890 listRelease(c->watched_keys); in freeClient()
H A Dserver.h644 dict *watched_keys; /* WATCHED keys for MULTI/EXEC CAS */ member
763 list *watched_keys; /* Keys WATCHED for MULTI/EXEC CAS */ member
H A Dserver.c2089 server.db[j].watched_keys = dictCreate(&keylistDictType,NULL); in initServer()