From e4c73d59a5cba3d2c2fa80ff2602d95a5cc9e618 Mon Sep 17 00:00:00 2001 From: wdvxdr Date: Sun, 5 Jun 2022 19:04:39 +0800 Subject: [PATCH] fix #1527 --- server/http.go | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/server/http.go b/server/http.go index 710610d..3fd7c37 100644 --- a/server/http.go +++ b/server/http.go @@ -363,15 +363,16 @@ func (c *HTTPClient) onBotPushEvent(e *coolq.Event) { } req.Header = header res, err = c.client.Do(req) - if err != nil { - if i < c.MaxRetries { - log.Warnf("上报 Event 数据到 %v 失败: %v 将进行第 %d 次重试", c.addr, err, i+1) - } else { - log.Warnf("上报 Event 数据 %s 到 %v 失败: %v 停止上报：已达重试上限", e.JSONBytes(), c.addr, err) - return - } - time.Sleep(time.Millisecond * time.Duration(c.RetriesInterval)) + if err == nil { + break } + if i < c.MaxRetries { + log.Warnf("上报 Event 数据到 %v 失败: %v 将进行第 %d 次重试", c.addr, err, i+1) + } else { + log.Warnf("上报 Event 数据 %s 到 %v 失败: %v 停止上报：已达重试上限", e.JSONBytes(), c.addr, err) + return + } + time.Sleep(time.Millisecond * time.Duration(c.RetriesInterval)) } defer res.Body.Close()