summaryrefslogtreecommitdiff
path: root/rpm/rpm.go
diff options
context:
space:
mode:
authorWill Hawkins <[email protected]>2023-12-13 19:56:03 -0500
committerWill Hawkins <[email protected]>2024-01-04 19:10:37 -0500
commitf3990f950277c2f61e0e1811b4b8a81fc0219da4 (patch)
tree6969e4ac2c4e94e75fe2e0c5581da5c07785dce8 /rpm/rpm.go
parent552f01ad73248474553ce471695745db58c862ea (diff)
[Feature] Support for testing upload/download in parallel
Use the `--rpm.parallel` to test in parallel mode. The default testing mode is serial. Signed-off-by: Will Hawkins <[email protected]>
Diffstat (limited to 'rpm/rpm.go')
-rw-r--r--rpm/rpm.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/rpm/rpm.go b/rpm/rpm.go
index 902e5bb..905e578 100644
--- a/rpm/rpm.go
+++ b/rpm/rpm.go
@@ -148,9 +148,8 @@ func ResponsivenessProber[BucketType utilities.Number](
)
}
- currentBucketId := bucketGenerator.Generate()
-
dataPointsLock.Lock()
+ currentBucketId := bucketGenerator.Generate()
if dataPoints != nil {
dataPoints <- series.SeriesMessage[ResponsivenessProbeResult, BucketType]{
Type: series.SeriesMessageReserve, Bucket: currentBucketId,