| 40 | : ExecutorGroup(desc.name(), desc.min_size()) {} |
| 41 | |
| 42 | ExecutorGroup* ExecutorGroup::GetFilteredExecutorGroup(const ExecutorGroup* group, |
| 43 | const std::unordered_set<NetworkAddressPB>& blacklisted_executor_addresses) { |
| 44 | ExecutorGroup* filtered_group = new ExecutorGroup(*group); |
| 45 | for (const NetworkAddressPB& be_address : blacklisted_executor_addresses) { |
| 46 | const BackendDescriptorPB* be_desc = filtered_group->LookUpBackendDesc(be_address); |
| 47 | if (be_desc != nullptr) { |
| 48 | filtered_group->RemoveExecutor(BackendDescriptorPB(*be_desc)); |
| 49 | } |
| 50 | } |
| 51 | return filtered_group; |
| 52 | } |
| 53 | |
| 54 | const ExecutorGroup::Executors& ExecutorGroup::GetExecutorsForHost( |
| 55 | const IpAddr& ip) const { |
nothing calls this directly
no test coverage detected