hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-08 11:31:40 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix a bug in killing unregistered workers (#2613)

Browse source
This commit is contained in:
Hao Chen 2018-08-10 08:57:25 +08:00 • committed by Philipp Moritz
parent 143a118fbf
commit 170e08cf02
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/ray/raylet/worker_pool.cc
View file

@ -65,11 +65,14 @@ WorkerPool::~WorkerPool() {
}
// Kill all the workers that have been started but not registered.
for (const auto &entry : starting_worker_processes_) {
pids_to_kill.insert(entry.second);
pids_to_kill.insert(entry.first);
}
for (const auto &pid : pids_to_kill) {
RAY_CHECK(pid > 0);
kill(pid, SIGKILL);
}
// Waiting for the workers to be killed
for (const auto &pid : pids_to_kill) {
waitpid(pid, NULL, 0);
}
}