Searched refs:ready_keys (Results 1 – 3 of 3) sorted by relevance
247 while(listLength(server.ready_keys) != 0) { in handleClientsBlockedOnKeys()254 l = server.ready_keys; in handleClientsBlockedOnKeys()255 server.ready_keys = listCreate(); in handleClientsBlockedOnKeys()263 dictDelete(rl->db->ready_keys,rl->key); in handleClientsBlockedOnKeys()592 if (dictFind(db->ready_keys,key) != NULL) return; in signalKeyAsReady()599 listAddNodeTail(server.ready_keys,rl); in signalKeyAsReady()605 serverAssert(dictAdd(db->ready_keys,key,NULL) == DICT_OK); in signalKeyAsReady()
643 dict *ready_keys; /* Blocked keys that received a PUSH */ member1203 list *ready_keys; /* List of readyList structures for BLPOP & co */ member
2043 server.ready_keys = listCreate(); in initServer()2088 server.db[j].ready_keys = dictCreate(&objectKeyPointerValueDictType,NULL); in initServer()2741 if (listLength(server.ready_keys)) in processCommand()