MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-04-01 10:13:42 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix: replace context by timeout-context from parent-context when selfSpeedTest ()

Browse Source
This commit is contained in:
jiuker 2023-08-25 22:58:38 +08:00 committed by GitHub
parent 124e28578c
commit 6aeca54ece
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 11 deletions

13
cmd/perf-tests.go

@ -85,14 +85,9 @@ func selfSpeedTest(ctx context.Context, opts speedTestOpts) (SpeedTestResult, er
objCountPerThread := make([]uint64, opts.concurrency) objCountPerThread := make([]uint64, opts.concurrency)
uploadsCtx, uploadsCancel := context.WithCancel(context.Background()) uploadsCtx, uploadsCancel := context.WithTimeout(ctx, opts.duration)
defer uploadsCancel() defer uploadsCancel()
go func() {
time.Sleep(opts.duration)
uploadsCancel()
}()
objNamePrefix := pathJoin(speedTest, mustGetUUID()) objNamePrefix := pathJoin(speedTest, mustGetUUID())
userMetadata := make(map[string]string) userMetadata := make(map[string]string)
@ -144,12 +139,8 @@ func selfSpeedTest(ctx context.Context, opts speedTestOpts) (SpeedTestResult, er
}, nil }, nil
} }
downloadsCtx, downloadsCancel := context.WithCancel(context.Background()) downloadsCtx, downloadsCancel := context.WithTimeout(ctx, opts.duration)
defer downloadsCancel() defer downloadsCancel()
go func() {
time.Sleep(opts.duration)
downloadsCancel()
}()
gopts := minio.GetObjectOptions{} gopts := minio.GetObjectOptions{}
gopts.Set(globalObjectPerfUserMetadata, "true") // Bypass S3 API freeze gopts.Set(globalObjectPerfUserMetadata, "true") // Bypass S3 API freeze