summaryrefslogtreecommitdiff
path: root/networkQuality.go
diff options
context:
space:
mode:
authorWill Hawkins <[email protected]>2024-01-19 19:37:11 -0500
committerWill Hawkins <[email protected]>2024-01-19 19:40:11 -0500
commit65b039e33717ee43620363704cb3daa304a5e724 (patch)
tree3cdb4c7f06147e20344a5f80bbdb0865ea0e2126 /networkQuality.go
parent00cd532f0c6860e11902240411204418db79e0d0 (diff)
[Bugfix] Continue Adding LGCs During Responsiveness Stabilization
The client was not continuing to add load-generating connections at each stability-check interval (as called for by the spec). Also, the client now properly obeys the `--rpm.id` option given on the command line. Signed-off-by: Will Hawkins <[email protected]>
Diffstat (limited to 'networkQuality.go')
-rw-r--r--networkQuality.go8
1 files changed, 1 insertions, 7 deletions
diff --git a/networkQuality.go b/networkQuality.go
index 355e1b3..f22cc32 100644
--- a/networkQuality.go
+++ b/networkQuality.go
@@ -686,18 +686,15 @@ func main() {
throughputCtx, throughputCtxCancel := context.WithCancel(operatingCtx)
direction.ThroughputActivityCtx, direction.ThroughputActivityCtxCancel = &throughputCtx, &throughputCtxCancel
- reachWorkingConditionsCtx, reachWorkingConditionsCtxCancel :=
- context.WithCancel(throughputOperatorCtx)
-
lgStabilizationCommunicationChannel := rpm.LoadGenerator(
throughputOperatorCtx,
*direction.ThroughputActivityCtx,
- reachWorkingConditionsCtx,
specParameters.EvalInterval,
direction.CreateLgdc,
&direction.Lgcc,
&globalNumericBucketGenerator,
specParameters.MaxParallelConns,
+ specParameters.EvalInterval,
*calculateExtendedStats,
direction.DirectionDebugging,
)
@@ -812,9 +809,6 @@ func main() {
)
}
- // No matter what, we will stop adding additional load-generating connections!
- reachWorkingConditionsCtxCancel()
-
direction.SelfRtts = series.NewWindowSeries[float64, uint64](series.Forever, 0)
direction.ForeignRtts = series.NewWindowSeries[float64, uint64](series.Forever, 0)