Skip to content

Commit

Permalink
up
Browse files Browse the repository at this point in the history
Signed-off-by: Jiajun Yao <[email protected]>
  • Loading branch information
jjyao committed Oct 11, 2024
1 parent b072f62 commit 4bf5f52
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/ray/rpc/retryable_grpc_client.h
Original file line number Diff line number Diff line change
Expand Up @@ -250,8 +250,8 @@ class RetryableGrpcClient : public std::enable_shared_from_this<RetryableGrpcCli
if (!server_is_unavailable_) {
server_is_unavailable_ = true;
} else {
uint64_t server_unavailable_duration_seconds = static_cast<uint64_t>(
absl::ToInt64Seconds(absl::Now() - server_last_available_time_));
uint64_t server_unavailable_duration_seconds = static_cast<uint64_t>(std::max(
absl::ToInt64Seconds(absl::Now() - server_last_available_time_), 0ll));
if (server_unavailable_duration_seconds >= server_unavailable_timeout_seconds_) {
RAY_LOG(WARNING) << server_name_ << " has been unavailable for "
<< server_unavailable_duration_seconds << " seconds";
Expand Down

0 comments on commit 4bf5f52

Please sign in to comment.