diff options
| author | Will Hawkins <[email protected]> | 2023-07-14 11:01:32 -0400 |
|---|---|---|
| committer | Will Hawkins <[email protected]> | 2023-07-14 11:05:44 -0400 |
| commit | 0a4cc0474df9854851a95e1b283468d6d62344b8 (patch) | |
| tree | 362af09620017f5f4700359847eabf008aa83451 /rpm | |
| parent | f2b7e719543408650fef7e3290f77962654453a9 (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.go | 15 |
1 files changed, 14 insertions, 1 deletions
@@ -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, |
