Detect broken writes.

No-Issue

Signed-off-by: James Tanner <[email protected]>

profiles/insights/proxy/main.go

@@ -227,6 +227,10 @@ func isUseOfClosedNetworkConnection(err error) bool {
 	return strings.Contains(err.Error(), "use of closed network connection")
 }
 
+func isWriteBrokenPipe(err error) bool {
+	return strings.Contains(err.Error(), "write: broken pipe")
+}
+
 func retryHTTPRequest(client *http.Client, req *http.Request, maxRetries int) (*http.Response, error) {
 	for retry := 0; retry < maxRetries; retry++ {
 		resp, err := client.Do(req)
@@ -246,6 +250,11 @@ func retryHTTPRequest(client *http.Client, req *http.Request, maxRetries int) (*
 				time.Sleep(1 * time.Second) // Wait before retrying
 				continue
 			}
+			if isWriteBrokenPipe(err) {
+				fmt.Printf("Retry attempt %d: write broken pipe\n", retry+1)
+				time.Sleep(1 * time.Second) // Wait before retrying
+				continue
+			}
 
 			return nil, err
 		}