diff options
| -rw-r--r-- | probe/probe.go | 18 | ||||
| -rw-r--r-- | rpm/rpm.go | 15 |
2 files changed, 32 insertions, 1 deletions
diff --git a/probe/probe.go b/probe/probe.go index fa19411..3939076 100644 --- a/probe/probe.go +++ b/probe/probe.go @@ -108,6 +108,15 @@ func Probe( probe_resp, err := client.Do(probe_req) if err != nil { + if debug.IsDebug(debugging.Level) { + fmt.Printf( + "(%s) (%s Probe %v) An error occurred during http.Do: %v\n", + debugging.Prefix, + probeType.Value(), + probeId, + err, + ) + } return nil, err } @@ -119,6 +128,15 @@ func Probe( // TODO: Make this interruptable somehow by using _ctx_. _, err = io.ReadAll(probe_resp.Body) if err != nil { + if debug.IsDebug(debugging.Level) { + fmt.Printf( + "(%s) (%s Probe %v) An error occurred during io.ReadAll: %v\n", + debugging.Prefix, + probeType.Value(), + probeId, + err, + ) + } return nil, err } time_after_probe := time.Now() @@ -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, |