From d74e10c7a8161fae712875f65c2bfe9f8dfb9268 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= <iwind.liu@gmail.com>
Date: Sat, 20 Aug 2022 08:15:16 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BC=93=E5=AD=98=E4=BB=BB=E5=8A=A1=E5=BF=BD?=
 =?UTF-8?q?=E7=95=A5=E8=BF=9E=E6=8E=A5API=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/nodes/http_cache_task_manager.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/internal/nodes/http_cache_task_manager.go b/internal/nodes/http_cache_task_manager.go
index 8ee40f8..9260781 100644
--- a/internal/nodes/http_cache_task_manager.go
+++ b/internal/nodes/http_cache_task_manager.go
@@ -106,6 +106,10 @@ func (this *HTTPCacheTaskManager) Loop() error {
 
 	resp, err := rpcClient.HTTPCacheTaskKeyRPC().FindDoingHTTPCacheTaskKeys(rpcClient.Context(), &pb.FindDoingHTTPCacheTaskKeysRequest{})
 	if err != nil {
+		// 忽略连接错误
+		if rpc.IsConnError(err) {
+			return nil
+		}
 		return err
 	}