| 1716 | return result; |
| 1717 | } |
| 1718 | bool killDataHall(Optional<Standalone<StringRef>> dataHallId, |
| 1719 | KillType kt, |
| 1720 | bool forceKill, |
| 1721 | KillType* ktFinal) override { |
| 1722 | auto processes = getAllProcesses(); |
| 1723 | std::set<Optional<Standalone<StringRef>>> dataHallMachines; |
| 1724 | for (auto& process : processes) { |
| 1725 | if (process->locality.dataHallId() == dataHallId) { |
| 1726 | dataHallMachines.insert(process->locality.machineId()); |
| 1727 | } |
| 1728 | } |
| 1729 | bool result = false; |
| 1730 | for (auto& machineId : dataHallMachines) { |
| 1731 | if (killMachine(machineId, kt, forceKill, ktFinal)) { |
| 1732 | result = true; |
| 1733 | } |
| 1734 | } |
| 1735 | return result; |
| 1736 | } |
| 1737 | bool killMachine(Optional<Standalone<StringRef>> machineId, |
| 1738 | KillType kt, |
| 1739 | bool forceKill, |
nothing calls this directly
no test coverage detected