Searched refs:ready_keys (Results 1 – 3 of 3) sorted by relevance
694 if (dictFind(db->ready_keys,key) != NULL) return; in signalListAsReady()701 listAddNodeTail(server.ready_keys,rl); in signalListAsReady()707 serverAssert(dictAdd(db->ready_keys,key,NULL) == DICT_OK); in signalListAsReady()790 while(listLength(server.ready_keys) != 0) { in handleClientsBlockedOnLists()797 l = server.ready_keys; in handleClientsBlockedOnLists()798 server.ready_keys = listCreate(); in handleClientsBlockedOnLists()806 dictDelete(rl->db->ready_keys,rl->key); in handleClientsBlockedOnLists()
508 dict *ready_keys; /* Blocked keys that received a PUSH */ member917 list *ready_keys; /* List of readyList structures for BLPOP & co */ member
1872 server.ready_keys = listCreate(); in initServer()1911 server.db[j].ready_keys = dictCreate(&setDictType,NULL); in initServer()2522 if (listLength(server.ready_keys)) in processCommand()