ros_trud_1.5.11 v1.5.15
Sergey Kisil 1 year ago
parent 0183f50cc8
commit 10d6e90dfe

@ -147,12 +147,10 @@ func (dc *DecortClient) do(req *http.Request) (*http.Response, error) {
req.Close = true req.Close = true
if err != nil || resp == nil { if err != nil || resp == nil {
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) { 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++ { for i := uint64(0); i < dc.cfg.Retries; i++ {
time.Sleep(5 * time.Second) time.Sleep(5 * time.Second)
resp, err = dc.client.Do(req) resp, err = dc.client.Do(req)
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) { if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
resp.Body.Close()
continue continue
} else if err == nil { } else if err == nil {
break break

@ -148,12 +148,10 @@ func (ldc *LegacyDecortClient) do(req *http.Request) (*http.Response, error) {
req.Close = true req.Close = true
if err != nil || resp == nil { if err != nil || resp == nil {
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) { 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++ { for i := uint64(0); i < ldc.cfg.Retries; i++ {
time.Sleep(5 * time.Second) time.Sleep(5 * time.Second)
resp, err = ldc.client.Do(req) resp, err = ldc.client.Do(req)
if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) { if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
resp.Body.Close()
continue continue
} else if err == nil { } else if err == nil {
break break

Loading…
Cancel
Save