Searched refs:replicationCountAcksByOffset (Results 1 – 3 of 3) sorted by relevance
161 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
2120 int replicationCountAcksByOffset(long long offset) { in replicationCountAcksByOffset() function2149 ackreplicas = replicationCountAcksByOffset(c->woff); in waitCommand()2201 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas()
1248 int replicationCountAcksByOffset(long long offset);