Searched refs:blocking_keys (Results 1 – 4 of 4) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | blocked.c | 272 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys()
333 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys()
376 dictEntry *de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys()
524 de = dictFind(c->db->blocking_keys,keys[j]); in blockForKeys()
530 retval = dictAdd(c->db->blocking_keys,keys[j],l); in blockForKeys()
555 l = dictFetchValue(c->db->blocking_keys,key); in unblockClientWaitingData()
560 dictDelete(c->db->blocking_keys,key); in unblockClientWaitingData()
589 if (dictFind(db->blocking_keys,key) == NULL) return; in signalKeyAsReady()
|
| H A D | db.c | 980 dictIterator *di = dictGetSafeIterator(db->blocking_keys); in scanDatabaseForReadyLists()
|
| H A D | server.h | 642 dict *blocking_keys; /* Keys with clients waiting for data (BLPOP)*/ member
|
| H A D | server.c | 2087 server.db[j].blocking_keys = dictCreate(&keylistDictType,NULL); in initServer()
|