wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-11 21:25:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fatal check if object store dies (#4763)

Browse Source
This commit is contained in:
Stephanie Wang
2019-05-13 11:59:12 -07:00
committed by Robert Nishihara
parent 62c949bbd5
commit 1622fc21fc
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/object_manager/object_store_notification_manager.cc
+6 -1
View File
@@ -42,6 +42,11 @@ void ObjectStoreNotificationManager::NotificationWait() {
void ObjectStoreNotificationManager::ProcessStoreLength(
const boost::system::error_code &error) {
notification_.resize(length_);
if (error) {
RAY_LOG(FATAL)
<< "Problem communicating with the object store from raylet, check logs or "
<< "dmesg for previous errors: " << boost_to_ray_status(error).ToString();
}
boost::asio::async_read(
socket_, boost::asio::buffer(notification_),
boost::bind(&ObjectStoreNotificationManager::ProcessStoreNotification, this,
@@ -50,7 +55,7 @@ void ObjectStoreNotificationManager::ProcessStoreLength(
void ObjectStoreNotificationManager::ProcessStoreNotification(
const boost::system::error_code &error) {
if (error.value() != boost::system::errc::success) {
if (error) {
RAY_LOG(FATAL)
<< "Problem communicating with the object store from raylet, check logs or "
<< "dmesg for previous errors: " << boost_to_ray_status(error).ToString();