| 1657 | } |
| 1658 | |
| 1659 | LogSystemConfig TagPartitionedLogSystem::getLogSystemConfig() const { |
| 1660 | LogSystemConfig logSystemConfig(epoch); |
| 1661 | logSystemConfig.logSystemType = logSystemType; |
| 1662 | logSystemConfig.expectedLogSets = expectedLogSets; |
| 1663 | logSystemConfig.logRouterTags = logRouterTags; |
| 1664 | logSystemConfig.txsTags = txsTags; |
| 1665 | logSystemConfig.recruitmentID = recruitmentID; |
| 1666 | logSystemConfig.stopped = stopped; |
| 1667 | logSystemConfig.recoveredAt = recoveredAt; |
| 1668 | logSystemConfig.pseudoLocalities = pseudoLocalities; |
| 1669 | logSystemConfig.oldestBackupEpoch = oldestBackupEpoch; |
| 1670 | for (const Reference<LogSet>& logSet : tLogs) { |
| 1671 | if (logSet->isLocal || remoteLogsWrittenToCoreState) { |
| 1672 | logSystemConfig.tLogs.emplace_back(*logSet); |
| 1673 | } |
| 1674 | } |
| 1675 | |
| 1676 | if (!recoveryCompleteWrittenToCoreState.get()) { |
| 1677 | for (const auto& oldData : oldLogData) { |
| 1678 | logSystemConfig.oldTLogs.emplace_back(oldData); |
| 1679 | } |
| 1680 | } |
| 1681 | return logSystemConfig; |
| 1682 | } |
| 1683 | |
| 1684 | Standalone<StringRef> TagPartitionedLogSystem::getLogsValue() const { |
| 1685 | std::vector<std::pair<UID, NetworkAddress>> logs; |
no test coverage detected