wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-26 13:37:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

Just die on signal (#5842)

Browse Source
This commit is contained in:
Edward Oakes
2019-10-03 18:21:21 -07:00
committed by GitHub
parent 8ca7fab581
commit 17c6835c3f
1 changed files with 3 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/core_worker/core_worker.cc
+3 -12
View File
@@ -28,20 +28,11 @@ CoreWorker::CoreWorker(
RayLog::InstallFailureSignalHandler();
}
boost::asio::signal_set sigint(io_service_, SIGINT);
sigint.async_wait(
boost::asio::signal_set signals(io_service_, SIGINT, SIGTERM);
signals.async_wait(
[](const boost::system::error_code &error, int signal_number) -> void {
if (!error) {
RAY_LOG(WARNING) << "Got SIGINT " << signal_number << ", ignoring it.";
}
});
boost::asio::signal_set sigterm(io_service_, SIGTERM);
sigterm.async_wait(
[this](const boost::system::error_code &error, int signal_number) -> void {
if (!error) {
RAY_LOG(WARNING) << "Got SIGTERM " << signal_number << ", shutting down.";
io_service_.stop();
exit(signal_number);
}
});