fix: warp concurrent crash on PUT (#354)

A regression caused by #349
minio · Dec 23, 2024 · 166e44b · 166e44b
1 parent 2bd850d
commit 166e44b
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/pkg/bench/put.go b/pkg/bench/put.go
@@ -70,7 +70,18 @@ func (u *Put) Start(ctx context.Context, wait chan struct{}) (Operations, error)
 		go func(i int) {
 			rcv := c.Receiver()
 			defer wg.Done()
+
+			// Copy usermetadata and usertags per concurrent thread.
 			opts := u.PutOpts
+			opts.UserMetadata = make(map[string]string, len(u.PutOpts.UserMetadata))
+			opts.UserTags = make(map[string]string, len(u.PutOpts.UserTags))
+			for k, v := range u.PutOpts.UserMetadata {
+				opts.UserMetadata[k] = v
+			}
+			for k, v := range u.PutOpts.UserTags {
+				opts.UserTags[k] = v
+			}
+
 			done := ctx.Done()
 
 			<-wait