mirror of
https://github.com/wassname/ray.git
synced 2026-07-05 14:44:48 +08:00
[xray] Fix typo concerning heartbeat_timeout_milliseconds in monitor (#2586)
This commit is contained in:
committed by
Robert Nishihara
parent
bb44456f6f
commit
e7f76d7914
@@ -16,14 +16,14 @@ namespace raylet {
|
||||
Monitor::Monitor(boost::asio::io_service &io_service, const std::string &redis_address,
|
||||
int redis_port)
|
||||
: gcs_client_(),
|
||||
heartbeat_timeout_ms_(RayConfig::instance().num_heartbeats_timeout()),
|
||||
num_heartbeats_timeout_(RayConfig::instance().num_heartbeats_timeout()),
|
||||
heartbeat_timer_(io_service) {
|
||||
RAY_CHECK_OK(gcs_client_.Connect(redis_address, redis_port, /*sharding=*/true));
|
||||
RAY_CHECK_OK(gcs_client_.Attach(io_service));
|
||||
}
|
||||
|
||||
void Monitor::HandleHeartbeat(const ClientID &client_id) {
|
||||
heartbeats_[client_id] = heartbeat_timeout_ms_;
|
||||
heartbeats_[client_id] = num_heartbeats_timeout_;
|
||||
}
|
||||
|
||||
void Monitor::Start() {
|
||||
|
||||
@@ -38,8 +38,8 @@ class Monitor {
|
||||
private:
|
||||
/// A client to the GCS, through which heartbeats are received.
|
||||
gcs::AsyncGcsClient gcs_client_;
|
||||
/// The expected period between heartbeats, for an individual Raylet.
|
||||
int64_t heartbeat_timeout_ms_;
|
||||
/// The number of heartbeats that can be missed before a client is removed.
|
||||
int64_t num_heartbeats_timeout_;
|
||||
/// A timer that ticks every heartbeat_timeout_ms_ milliseconds.
|
||||
boost::asio::deadline_timer heartbeat_timer_;
|
||||
/// For each Raylet that we receive a heartbeat from, the number of ticks
|
||||
|
||||
Reference in New Issue
Block a user