Commit 5ce7363b authored by zhujiashun's avatar zhujiashun

health_check_using_rpc: refine interface name

parent 26c9f944
...@@ -229,7 +229,7 @@ void HealthCheckTask::OnDestroyingTask() { ...@@ -229,7 +229,7 @@ void HealthCheckTask::OnDestroyingTask() {
delete this; delete this;
} }
void StartHealthCheckWithDelayMS(SocketId id, int64_t delay_ms) { void StartHealthCheck(SocketId id, int64_t delay_ms) {
PeriodicTaskManager::StartTaskAt(new HealthCheckTask(id), PeriodicTaskManager::StartTaskAt(new HealthCheckTask(id),
butil::milliseconds_from_now(delay_ms)); butil::milliseconds_from_now(delay_ms));
} }
......
...@@ -837,7 +837,7 @@ int Socket::SetFailed(int error_code, const char* error_fmt, ...) { ...@@ -837,7 +837,7 @@ int Socket::SetFailed(int error_code, const char* error_fmt, ...) {
// comes online. // comes online.
if (_health_check_interval_s > 0) { if (_health_check_interval_s > 0) {
GetOrNewSharedPart()->circuit_breaker.MarkAsBroken(); GetOrNewSharedPart()->circuit_breaker.MarkAsBroken();
StartHealthCheckWithDelayMS(id(), StartHealthCheck(id(),
GetOrNewSharedPart()->circuit_breaker.isolation_duration_ms()); GetOrNewSharedPart()->circuit_breaker.isolation_duration_ms());
} }
// Wake up all threads waiting on EPOLLOUT when closing fd // Wake up all threads waiting on EPOLLOUT when closing fd
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment