| 1623 | } |
| 1624 | |
| 1625 | Future<Void> TagPartitionedLogSystem::endEpoch() { |
| 1626 | std::vector<Future<Void>> lockResults; |
| 1627 | for (auto& logSet : tLogs) { |
| 1628 | for (auto& log : logSet->logServers) { |
| 1629 | lockResults.push_back(success(lockTLog(dbgid, log))); |
| 1630 | } |
| 1631 | } |
| 1632 | return waitForAll(lockResults); |
| 1633 | } |
| 1634 | |
| 1635 | Future<Reference<ILogSystem>> TagPartitionedLogSystem::newEpoch( |
| 1636 | RecruitFromConfigurationReply const& recr, |
no test coverage detected