diff options
| author | Will Hawkins <[email protected]> | 2023-07-14 11:06:08 -0400 |
|---|---|---|
| committer | Will Hawkins <[email protected]> | 2023-07-14 11:06:08 -0400 |
| commit | c59943a12da4845ccaf7b93ec4b293b19dedea76 (patch) | |
| tree | 317d504f0e90d4504c8f241bce54398fc52d7565 /rpm | |
| parent | d27187215da1930c43a22c542d18f7578671ed74 (diff) | |
Probe direction is unnused in probe.Probe -- remove it
Signed-off-by: Will Hawkins <[email protected]>
Diffstat (limited to 'rpm')
| -rw-r--r-- | rpm/rpm.go | 7 |
1 files changed, 3 insertions, 4 deletions
@@ -190,7 +190,6 @@ func ResponsivenessProber[BucketType utilities.Number]( foreignProbeClient, foreignProbeConfiguration.URL, foreignProbeConfiguration.Host, - probeDirection, probe.Foreign, probeCount, captureExtendedStats, @@ -210,7 +209,7 @@ func ResponsivenessProber[BucketType utilities.Number]( fmt.Printf( "(%s) Failed to get a random %s load-generating connection on which to send a probe: %v.\n", debugging.Prefix, - utilities.Conditional(probeDirection == lgc.LGC_DOWN, "download", "upload"), + probeDirection, err, ) } @@ -229,7 +228,7 @@ func ResponsivenessProber[BucketType utilities.Number]( fmt.Printf( "(%s) The selected random %s load-generating connection on which to send a probe was not running.\n", debugging.Prefix, - utilities.Conditional(probeDirection == lgc.LGC_DOWN, "download", "upload"), + probeDirection, ) } return @@ -239,7 +238,7 @@ func ResponsivenessProber[BucketType utilities.Number]( fmt.Printf( "(%s) Selected %s load-generating connection with ID %d to send a self probe with Id %d.\n", debugging.Prefix, - utilities.Conditional(probeDirection == lgc.LGC_DOWN, "download", "upload"), + probeDirection, (*selfProbeConnection).ClientId(), probeCount, ) |
