Fanout: Check individual errors (#272)

minio · Jun 23, 2023 · 560cb38 · 560cb38
1 parent 802079f
commit 560cb38
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/pkg/bench/fanout.go b/pkg/bench/fanout.go
@@ -105,13 +105,28 @@ func (u *Fanout) Start(ctx context.Context, wait chan struct{}) (Operations, err
 					op.Err = err.Error()
 				}
 
+				var firstErr string
+				nErrs := 0
+				for _, r := range res {
+					if r.Error != "" {
+						if firstErr == "" {
+							firstErr = r.Error
+						}
+						nErrs++
+					}
+				}
+				if op.Err == "" && nErrs > 0 {
+					op.Err = fmt.Sprintf("%d copies failed. First error: %v", nErrs, firstErr)
+				}
+
 				if len(res) != u.Copies && op.Err == "" {
 					err := fmt.Sprint("short upload. want:", u.Copies, " copies, got:", len(res))
 					if op.Err == "" {
 						op.Err = err
 					}
 					u.Error(err)
 				}
+
 				cldone()
 				rcv <- op
 			}