| 34 | } |
| 35 | |
| 36 | LogSet::LogSet(const TLogSet& tLogSet) |
| 37 | : tLogWriteAntiQuorum(tLogSet.tLogWriteAntiQuorum), tLogReplicationFactor(tLogSet.tLogReplicationFactor), |
| 38 | tLogLocalities(tLogSet.tLogLocalities), tLogVersion(tLogSet.tLogVersion), tLogPolicy(tLogSet.tLogPolicy), |
| 39 | isLocal(tLogSet.isLocal), locality(tLogSet.locality), startVersion(tLogSet.startVersion), |
| 40 | satelliteTagLocations(tLogSet.satelliteTagLocations) { |
| 41 | for (const auto& log : tLogSet.tLogs) { |
| 42 | logServers.push_back(makeReference<AsyncVar<OptionalInterface<TLogInterface>>>(log)); |
| 43 | } |
| 44 | for (const auto& log : tLogSet.logRouters) { |
| 45 | logRouters.push_back(makeReference<AsyncVar<OptionalInterface<TLogInterface>>>(log)); |
| 46 | } |
| 47 | for (const auto& log : tLogSet.backupWorkers) { |
| 48 | backupWorkers.push_back(makeReference<AsyncVar<OptionalInterface<BackupInterface>>>(log)); |
| 49 | } |
| 50 | filterLocalityDataForPolicy(tLogPolicy, &tLogLocalities); |
| 51 | updateLocalitySet(tLogLocalities); |
| 52 | } |
| 53 | |
| 54 | LogSet::LogSet(const CoreTLogSet& coreSet) |
| 55 | : tLogWriteAntiQuorum(coreSet.tLogWriteAntiQuorum), tLogReplicationFactor(coreSet.tLogReplicationFactor), |
nothing calls this directly
no test coverage detected