diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2025-07-22 15:40:32 +0200 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2025-07-22 13:55:30 +0000 |
| commit | f4b2c8322b176a90173abb4adf6bceb703544f87 (patch) | |
| tree | bf98bac2e9e9d5fcc18d503c26ef32a6049d053f | |
| parent | 8e9d1dc158f35de43cdf83fba11bfce93ee7a227 (diff) | |
syz-cluster: improve email-reporter logging
Give more visibility into what the component is doing and why it fails.
| -rw-r--r-- | syz-cluster/email-reporter/handler.go | 3 | ||||
| -rw-r--r-- | syz-cluster/email-reporter/main.go | 4 | ||||
| -rw-r--r-- | syz-cluster/email-reporter/stream.go | 3 |
3 files changed, 9 insertions, 1 deletions
diff --git a/syz-cluster/email-reporter/handler.go b/syz-cluster/email-reporter/handler.go index 5074ad24f..c0af2e7d7 100644 --- a/syz-cluster/email-reporter/handler.go +++ b/syz-cluster/email-reporter/handler.go @@ -26,6 +26,9 @@ type Handler struct { } func (h *Handler) PollReportsLoop(ctx context.Context, pollPeriod time.Duration) { + defer log.Printf("reporter server polling aborted") + log.Printf("reporter server polling started") + for { _, err := h.PollAndReport(ctx) if err != nil { diff --git a/syz-cluster/email-reporter/main.go b/syz-cluster/email-reporter/main.go index 5ed7e8a6a..2557bbb8d 100644 --- a/syz-cluster/email-reporter/main.go +++ b/syz-cluster/email-reporter/main.go @@ -76,5 +76,7 @@ func main() { handler.PollReportsLoop(loopCtx, senderPollPeriod) return nil }) - eg.Wait() + if err = eg.Wait(); err != nil { + app.Errorf("failed: %s", err) + } } diff --git a/syz-cluster/email-reporter/stream.go b/syz-cluster/email-reporter/stream.go index 4aa035cec..a27f71d9f 100644 --- a/syz-cluster/email-reporter/stream.go +++ b/syz-cluster/email-reporter/stream.go @@ -53,6 +53,9 @@ const ( ) func (s *LKMLEmailStream) Loop(ctx context.Context, pollPeriod time.Duration) error { + defer log.Printf("lore archive polling aborted") + log.Printf("lore archive %s polling started", s.cfg.LoreArchiveURL) + last, err := s.client.LastReply(ctx, s.reporterName) if err != nil { return fmt.Errorf("failed to query the last reply: %w", err) |