Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 10d6e90dfe |
@@ -147,12 +147,10 @@ func (dc *DecortClient) do(req *http.Request) (*http.Response, error) {
|
||||
req.Close = true
|
||||
if err != nil || resp == nil {
|
||||
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
|
||||
resp.Body.Close()
|
||||
for i := uint64(0); i < dc.cfg.Retries; i++ {
|
||||
time.Sleep(5 * time.Second)
|
||||
resp, err = dc.client.Do(req)
|
||||
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
|
||||
resp.Body.Close()
|
||||
continue
|
||||
} else if err == nil {
|
||||
break
|
||||
|
||||
@@ -148,12 +148,10 @@ func (ldc *LegacyDecortClient) do(req *http.Request) (*http.Response, error) {
|
||||
req.Close = true
|
||||
if err != nil || resp == nil {
|
||||
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
|
||||
resp.Body.Close()
|
||||
for i := uint64(0); i < ldc.cfg.Retries; i++ {
|
||||
time.Sleep(5 * time.Second)
|
||||
resp, err = ldc.client.Do(req)
|
||||
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
|
||||
resp.Body.Close()
|
||||
continue
|
||||
} else if err == nil {
|
||||
break
|
||||
|
||||
Reference in New Issue
Block a user