BASIS/decort-golang-sdk
8
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

v1.5.14

Browse Source
This commit is contained in:
Sergey Kisil
2023-12-01 12:58:44 +03:00
parent 888923c6ce
commit c679d79a9c
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
client.go
View File

@@ -146,12 +146,12 @@ func (dc *DecortClient) do(req *http.Request) (*http.Response, error) {
resp, err := dc.client.Do(req) resp, err := dc.client.Do(req)
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") { if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
resp.Body.Close() 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") { if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
resp.Body.Close() resp.Body.Close()
continue continue
} else if err == nil { } else if err == nil {

4
legacy-client.go
View File

@@ -147,12 +147,12 @@ func (ldc *LegacyDecortClient) do(req *http.Request) (*http.Response, error) {
resp, err := ldc.client.Do(req) resp, err := ldc.client.Do(req)
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") { if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
resp.Body.Close() 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") { if strings.Contains(err.Error(), "connection reset by peer") || errors.Is(err, io.EOF) {
resp.Body.Close() resp.Body.Close()
continue continue
} else if err == nil { } else if err == nil {