| 1700 | } |
| 1701 | } |
| 1702 | when(wait(pollHealth)) { |
| 1703 | if (!healthyDestinations.isHealthy()) { |
| 1704 | if (!signalledTransferComplete) { |
| 1705 | signalledTransferComplete = true; |
| 1706 | self->dataTransferComplete.send(rd); |
| 1707 | } |
| 1708 | } |
| 1709 | pollHealth = signalledTransferComplete ? Never() |
| 1710 | : delay(SERVER_KNOBS->HEALTH_POLL_TIME, |
| 1711 | TaskPriority::DataDistributionLaunch); |
| 1712 | } |
| 1713 | when(wait(signalledTransferComplete ? Never() : dataMovementComplete.getFuture())) { |
| 1714 | self->fetchKeysComplete.insert(rd); |
| 1715 | if (!signalledTransferComplete) { |
no test coverage detected