Searched refs:blocking_keys (Results 1 – 3 of 3) sorted by relevance
632 de = dictFind(c->db->blocking_keys,keys[j]); in blockForKeys()638 retval = dictAdd(c->db->blocking_keys,keys[j],l); in blockForKeys()663 l = dictFetchValue(c->db->blocking_keys,key); in unblockClientWaitingData()668 dictDelete(c->db->blocking_keys,key); in unblockClientWaitingData()691 if (dictFind(db->blocking_keys,key) == NULL) return; in signalListAsReady()816 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnLists()
507 dict *blocking_keys; /* Keys with clients waiting for data (BLPOP) */ member
1910 server.db[j].blocking_keys = dictCreate(&keylistDictType,NULL); in initServer()