Searched refs:replicationCountAcksByOffset (Results 1 – 3 of 3) sorted by relevance
192 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
2419 int replicationCountAcksByOffset(long long offset) { in replicationCountAcksByOffset() function2453 ackreplicas = replicationCountAcksByOffset(c->woff); in waitCommand()2505 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas()
1600 int replicationCountAcksByOffset(long long offset);