| 1056 | } // namespace |
| 1057 | |
| 1058 | void filterLocalityDataForPolicyDcAndProcess(Reference<IReplicationPolicy> policy, LocalityData* ld) { |
| 1059 | if (!policy) |
| 1060 | return; |
| 1061 | std::set<std::string> keys = policy->attributeKeys(); |
| 1062 | keys.insert(LocalityData::keyDcId.toString()); |
| 1063 | keys.insert(LocalityData::keyProcessId.toString()); |
| 1064 | filterLocalityDataForPolicy(policy->attributeKeys(), ld); |
| 1065 | } |
| 1066 | |
| 1067 | void filterLocalityDataForPolicy(Reference<IReplicationPolicy> policy, LocalityData* ld) { |
| 1068 | if (!policy) |
no test coverage detected