| 1633 | } |
| 1634 | |
| 1635 | Future<Reference<ILogSystem>> TagPartitionedLogSystem::newEpoch( |
| 1636 | RecruitFromConfigurationReply const& recr, |
| 1637 | Future<RecruitRemoteFromConfigurationReply> const& fRemoteWorkers, |
| 1638 | UID clusterId, |
| 1639 | DatabaseConfiguration const& config, |
| 1640 | LogEpoch recoveryCount, |
| 1641 | Version recoveryTransactionVersion, |
| 1642 | int8_t primaryLocality, |
| 1643 | int8_t remoteLocality, |
| 1644 | std::vector<Tag> const& allTags, |
| 1645 | Reference<AsyncVar<bool>> const& recruitmentStalled) { |
| 1646 | return newEpoch(Reference<TagPartitionedLogSystem>::addRef(this), |
| 1647 | recr, |
| 1648 | fRemoteWorkers, |
| 1649 | clusterId, |
| 1650 | config, |
| 1651 | recoveryCount, |
| 1652 | recoveryTransactionVersion, |
| 1653 | primaryLocality, |
| 1654 | remoteLocality, |
| 1655 | allTags, |
| 1656 | recruitmentStalled); |
| 1657 | } |
| 1658 | |
| 1659 | LogSystemConfig TagPartitionedLogSystem::getLogSystemConfig() const { |
| 1660 | LogSystemConfig logSystemConfig(epoch); |
no test coverage detected