上传访问日志发生网络错误时不提交

internal/nodes/http_access_log_queue.go

@@ -43,10 +43,14 @@ func (this *HTTPAccessLogQueue) Start() {
 	for range ticker.C {
 		err := this.loop()
 		if err != nil {
+			if rpc.IsConnError(err) {
+				remotelogs.Debug("ACCESS_LOG_QUEUE", err.Error())
+			} else {
 				remotelogs.Error("ACCESS_LOG_QUEUE", err.Error())
 			}
 		}
 	}
+}
 
 // Push 加入新访问日志
 func (this *HTTPAccessLogQueue) Push(accessLog *pb.HTTPAccessLog) {