Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dreplication.c2438 long numreplicas, ackreplicas; in waitCommand() local
2447 if (getLongFromObjectOrReply(c,c->argv[1],&numreplicas,NULL) != C_OK) in waitCommand()
2454 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
2463 c->bpop.numreplicas = numreplicas; in waitCommand()
2500 last_numreplicas > c->bpop.numreplicas) in processClientsWaitingReplicas()
2505 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas() local
2507 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()
2509 last_numreplicas = numreplicas; in processClientsWaitingReplicas()
2511 addReplyLongLong(c,numreplicas); in processClientsWaitingReplicas()
H A Dnetworking.c149 c->bpop.numreplicas = 0; in createClient()
H A Dserver.h688 int numreplicas; /* Number of replicas we are waiting for ACK. */ member