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

[Core] Socket creation race condition bug fixes (#9764)

Browse Source 
* fix issues

* hot fixes

* test

* test

* Always info log
This commit is contained in:
Alex Wu
2020-07-29 13:17:46 -07:00
committed by GitHub
parent b0b0463161
commit 72297dc46f
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/common/client_connection.cc
+5 -3
View File
@@ -48,9 +48,11 @@ Status ConnectSocketRetry(local_stream_socket &socket, const std::string &endpoi
break;
}
if (num_attempts > 0) {
RAY_LOG(ERROR) << "Retrying to connect to socket for endpoint " << endpoint
<< " (num_attempts = " << num_attempts
<< ", num_retries = " << num_retries << ")";
// Socket is created by the raylet. Due to a race condition it might not
// be created before we try connecting.
RAY_LOG(INFO) << "Retrying to connect to socket for endpoint " << endpoint
<< " (num_attempts = " << num_attempts
<< ", num_retries = " << num_retries << ")";
}
// Sleep for timeout milliseconds.
std::this_thread::sleep_for(std::chrono::milliseconds(timeout_in_ms));