| 545 | } |
| 546 | |
| 547 | int canFeedReplicaReplBuffer(client *replica) { |
| 548 | /* Don't feed replicas that only want the RDB. */ |
| 549 | if (replica->flags & CLIENT_REPL_RDBONLY) return 0; |
| 550 | |
| 551 | /* Don't feed replicas that are still waiting for BGSAVE to start. */ |
| 552 | if (replica->replstate == SLAVE_STATE_WAIT_BGSAVE_START) return 0; |
| 553 | |
| 554 | return 1; |
| 555 | } |
| 556 | |
| 557 | /* Propagate write commands to slaves, and populate the replication backlog |
| 558 | * as well. This function is used if the instance is a master: we use |
no outgoing calls
no test coverage detected