Searched refs:bpop (Results 1 – 7 of 7) sorted by relevance
621 c->bpop.timeout = timeout; in blockForKeys()622 c->bpop.target = target; in blockForKeys()628 if (dictAdd(c->bpop.keys,keys[j],NULL) != DICT_OK) continue; in blockForKeys()656 serverAssertWithInfo(c,NULL,dictSize(c->bpop.keys) != 0); in unblockClientWaitingData()657 di = dictGetIterator(c->bpop.keys); in unblockClientWaitingData()673 dictEmpty(c->bpop.keys,NULL); in unblockClientWaitingData()674 if (c->bpop.target) { in unblockClientWaitingData()675 decrRefCount(c->bpop.target); in unblockClientWaitingData()676 c->bpop.target = NULL; in unblockClientWaitingData()824 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnLists()
161 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
2157 c->bpop.timeout = timeout; in waitCommand()2158 c->bpop.reploffset = offset; in waitCommand()2159 c->bpop.numreplicas = numreplicas; in waitCommand()2195 if (last_offset && last_offset > c->bpop.reploffset && in processClientsWaitingReplicas()2196 last_numreplicas > c->bpop.numreplicas) in processClientsWaitingReplicas()2201 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas()2203 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()2204 last_offset = c->bpop.reploffset; in processClientsWaitingReplicas()
116 c->bpop.timeout = 0; in createClient()117 c->bpop.keys = dictCreate(&setDictType,NULL); in createClient()118 c->bpop.target = NULL; in createClient()119 c->bpop.numreplicas = 0; in createClient()120 c->bpop.reploffset = 0; in createClient()818 dictRelease(c->bpop.keys); in freeClient()
606 blockingState bpop; /* blocking state */ member
942 if (c->bpop.timeout != 0 && c->bpop.timeout < now_ms) { in clientsCronHandleTimeout()
5190 di = dictGetIterator(c->bpop.keys); in clusterRedirectBlockedClientIfNeeded()