From 0109a27c0640df68131b8f345e4e58e9a8105761 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Tue, 1 Nov 2022 14:55:06 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E8=AE=BF=E9=97=AE=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E5=8F=91=E7=94=9F=E7=BD=91=E7=BB=9C=E9=94=99=E8=AF=AF?= =?UTF-8?q?=E6=97=B6=E4=B8=8D=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/http_access_log_queue.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/nodes/http_access_log_queue.go b/internal/nodes/http_access_log_queue.go index cfae612..1dd7439 100644 --- a/internal/nodes/http_access_log_queue.go +++ b/internal/nodes/http_access_log_queue.go @@ -43,7 +43,11 @@ func (this *HTTPAccessLogQueue) Start() { for range ticker.C { err := this.loop() if err != nil { - remotelogs.Error("ACCESS_LOG_QUEUE", err.Error()) + if rpc.IsConnError(err) { + remotelogs.Debug("ACCESS_LOG_QUEUE", err.Error()) + } else { + remotelogs.Error("ACCESS_LOG_QUEUE", err.Error()) + } } } }