Home
last modified time | relevance | path

Searched refs:numreplicas (Results 1 – 3 of 3) sorted by relevance

/redis-3.2.3/src/
H A Dreplication.c2139 long numreplicas, ackreplicas; in waitCommand() local
2143 if (getLongFromObjectOrReply(c,c->argv[1],&numreplicas,NULL) != C_OK) in waitCommand()
2150 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
2159 c->bpop.numreplicas = numreplicas; in waitCommand()
2196 last_numreplicas > c->bpop.numreplicas) in processClientsWaitingReplicas()
2201 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas() local
2203 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()
2205 last_numreplicas = numreplicas; in processClientsWaitingReplicas()
2207 addReplyLongLong(c,numreplicas); in processClientsWaitingReplicas()
H A Dserver.h543 int numreplicas; /* Number of replicas we are waiting for ACK. */ member
H A Dnetworking.c119 c->bpop.numreplicas = 0; in createClient()