From 757b3613fe3f6d10b03da86b54acd85882131ed2 Mon Sep 17 00:00:00 2001 From: fatedier Date: Fri, 9 Aug 2019 12:47:27 +0800 Subject: [PATCH] fix health check bug, fix #1367 --- client/health/health.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/client/health/health.go b/client/health/health.go index 42924a6..91ea707 100644 --- a/client/health/health.go +++ b/client/health/health.go @@ -96,12 +96,12 @@ func (monitor *HealthCheckMonitor) Stop() { func (monitor *HealthCheckMonitor) checkWorker() { for { - ctx, cancel := context.WithDeadline(monitor.ctx, time.Now().Add(monitor.timeout)) - err := monitor.doCheck(ctx) + doCtx, cancel := context.WithDeadline(monitor.ctx, time.Now().Add(monitor.timeout)) + err := monitor.doCheck(doCtx) // check if this monitor has been closed select { - case <-ctx.Done(): + case <-monitor.ctx.Done(): cancel() return default: