Searched refs:numreplicas (Results 1 – 10 of 10) sorted by relevance
| /dports/databases/redis5/redis-5.0.14/src/ |
| H A D | replication.c | 2476 long numreplicas, ackreplicas; in waitCommand() local
2485 if (getLongFromObjectOrReply(c,c->argv[1],&numreplicas,NULL) != C_OK) in waitCommand()
2492 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
2501 c->bpop.numreplicas = numreplicas; in waitCommand()
2538 last_numreplicas > c->bpop.numreplicas) in processClientsWaitingReplicas()
2543 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas() local
2545 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()
2547 last_numreplicas = numreplicas; in processClientsWaitingReplicas()
2549 addReplyLongLong(c,numreplicas); in processClientsWaitingReplicas()
|
| H A D | server.h | 698 int numreplicas; /* Number of replicas we are waiting for ACK. */ member
|
| H A D | networking.c | 149 c->bpop.numreplicas = 0; in createClient()
|
| /dports/databases/redis6/redis-6.0.16/src/ |
| H A D | replication.c | 3004 long numreplicas, ackreplicas; in waitCommand() local
3013 if (getLongFromObjectOrReply(c,c->argv[1],&numreplicas,NULL) != C_OK) in waitCommand()
3020 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
3029 c->bpop.numreplicas = numreplicas; in waitCommand()
3066 last_numreplicas > c->bpop.numreplicas) in processClientsWaitingReplicas()
3071 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas() local
3073 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()
3075 last_numreplicas = numreplicas; in processClientsWaitingReplicas()
3077 addReplyLongLong(c,numreplicas); in processClientsWaitingReplicas()
|
| H A D | server.h | 723 int numreplicas; /* Number of replicas we are waiting for ACK. */ member
|
| H A D | networking.c | 173 c->bpop.numreplicas = 0; in createClient()
|
| /dports/databases/redis-devel/redis-0e5b813/src/ |
| H A D | replication.c | 3407 long numreplicas, ackreplicas; in waitCommand() local
3416 if (getLongFromObjectOrReply(c,c->argv[1],&numreplicas,NULL) != C_OK) in waitCommand()
3423 if (ackreplicas >= numreplicas || c->flags & CLIENT_MULTI) { in waitCommand()
3432 c->bpop.numreplicas = numreplicas; in waitCommand()
3469 last_numreplicas >= c->bpop.numreplicas) in processClientsWaitingReplicas()
3474 int numreplicas = replicationCountAcksByOffset(c->bpop.reploffset); in processClientsWaitingReplicas() local
3476 if (numreplicas >= c->bpop.numreplicas) { in processClientsWaitingReplicas()
3478 last_numreplicas = numreplicas; in processClientsWaitingReplicas()
3480 addReplyLongLong(c,numreplicas); in processClientsWaitingReplicas()
|
| H A D | server.h | 872 int numreplicas; /* Number of replicas we are waiting for ACK. */ member
|
| H A D | networking.c | 185 c->bpop.numreplicas = 0; in createClient()
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/test/kubemark/resources/ |
| H A D | hollow-node_template.yaml | 9 replicas: {{numreplicas}}
|