shkong/go-cqhttp
1
0
Fork 0
mirror of https://github.com/Mrs4s/go-cqhttp.git synced 2025-06-19 05:55:04 +08:00
Code Issues Projects Releases Wiki Activity

fix #1527

Browse Source
This commit is contained in:
wdvxdr 2022-06-05 19:04:39 +08:00
parent d25209c366
commit e4c73d59a5
No known key found for this signature in database
GPG Key ID: 703F8C071DE7A1B6
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
server/http.go
View File

@ -363,15 +363,16 @@ func (c *HTTPClient) onBotPushEvent(e *coolq.Event) {
} }
req.Header = header req.Header = header
res, err = c.client.Do(req) res, err = c.client.Do(req)
if err != nil { if err == nil {
if i < c.MaxRetries { break
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 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() defer res.Body.Close()