summaryrefslogtreecommitdiff
path: root/rpm
diff options
context:
space:
mode:
authorWill Hawkins <[email protected]>2023-07-14 11:01:32 -0400
committerWill Hawkins <[email protected]>2023-07-14 11:05:44 -0400
commit0a4cc0474df9854851a95e1b283468d6d62344b8 (patch)
tree362af09620017f5f4700359847eabf008aa83451 /rpm
parentf2b7e719543408650fef7e3290f77962654453a9 (diff)
Suppress non-error of cancelled context causing probe send to fail
It is not an error (per se) for a probe not to be able to be sent when the context of its execution is cancelled. Log the error when debugging only. Signed-off-by: Will Hawkins <[email protected]>
Diffstat (limited to 'rpm')
-rw-r--r--rpm/rpm.go15
1 files changed, 14 insertions, 1 deletions
diff --git a/rpm/rpm.go b/rpm/rpm.go
index 0f51461..ff483ff 100644
--- a/rpm/rpm.go
+++ b/rpm/rpm.go
@@ -249,13 +249,26 @@ func ResponsivenessProber[BucketType utilities.Number](
(*selfProbeConnection).Client(),
selfProbeConfiguration.URL,
selfProbeConfiguration.Host,
- probeDirection,
utilities.Conditional(probeDirection == lgc.LGC_DOWN, probe.SelfDown, probe.SelfUp),
probeCount,
captureExtendedStats,
debugging,
)
if err != nil {
+ // We may see an error here because the prober context was cancelled
+ // and requests were attempting to be sent. This situation is not an
+ // error (per se) so we will not log it as such.
+
+ if proberCtx.Err() != nil {
+ if debug.IsDebug(debugging.Level) {
+ fmt.Printf(
+ "(%s) Failed to send a probe (id: %v) because the prober context was cancelled.\n",
+ debugging.Prefix,
+ probeCount,
+ )
+ }
+ return
+ }
fmt.Printf(
"(%s) There was an error sending a self probe with Id %d: %v\n",
debugging.Prefix,