Retry net.ErrClosed (#1637)

jonjohnsonjr · web-flow · commit ed5c185df419 · 2023-04-08T21:59:03.000-07:00
diff --git a/pkg/v1/remote/options.go b/pkg/v1/remote/options.go
@@ -60,7 +60,7 @@ type Backoff = retry.Backoff
 var defaultRetryPredicate retry.Predicate = func(err error) bool {
 	// Various failure modes here, as we're often reading from and writing to
 	// the network.
-	if retry.IsTemporary(err) || errors.Is(err, io.ErrUnexpectedEOF) || errors.Is(err, io.EOF) || errors.Is(err, syscall.EPIPE) || errors.Is(err, syscall.ECONNRESET) {
+	if retry.IsTemporary(err) || errors.Is(err, io.ErrUnexpectedEOF) || errors.Is(err, io.EOF) || errors.Is(err, syscall.EPIPE) || errors.Is(err, syscall.ECONNRESET) || errors.Is(err, net.ErrClosed) {
 		logs.Warn.Printf("retrying %v", err)
 		return true
 	}

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ type Backoff = retry.Backoff`
`60`	`60`	`var defaultRetryPredicate retry.Predicate = func(err error) bool {`
`61`	`61`	`// Various failure modes here, as we're often reading from and writing to`
`62`	`62`	`// the network.`
`63`		`- if retry.IsTemporary(err) \|\| errors.Is(err, io.ErrUnexpectedEOF) \|\| errors.Is(err, io.EOF) \|\| errors.Is(err, syscall.EPIPE) \|\| errors.Is(err, syscall.ECONNRESET) {`
	`63`	`+ if retry.IsTemporary(err) \|\| errors.Is(err, io.ErrUnexpectedEOF) \|\| errors.Is(err, io.EOF) \|\| errors.Is(err, syscall.EPIPE) \|\| errors.Is(err, syscall.ECONNRESET) \|\| errors.Is(err, net.ErrClosed) {`
`64`	`64`	`logs.Warn.Printf("retrying %v", err)`
`65`	`65`	`return true`
`66`	`66`	`}`