This just set a flag so that we broadcast a REPLCONF GETACK command * to all the slaves in the beforeSleep() function. Note that this way * we "group" all the clients that want to wait for synchronous replication * in a given event loop iteration, and send a single GETACK for them all. */
| 3160 | * we "group" all the clients that want to wait for synchronous replication |
| 3161 | * in a given event loop iteration, and send a single GETACK for them all. */ |
| 3162 | void replicationRequestAckFromSlaves(void) { |
| 3163 | server.get_ack_from_slaves = 1; |
| 3164 | } |
| 3165 | |
| 3166 | /* Return the number of slaves that already acknowledged the specified |
| 3167 | * replication offset. */ |