From 76c32f5c07de8f9bb96bd4a5356ff91924c928be Mon Sep 17 00:00:00 2001
From: Lev Zakharov <l.j.zakharov@gmail.com>
Date: Fri, 26 Jul 2024 13:23:33 +0300
Subject: [PATCH] Debug periodic enqueuer loop

---
 periodic_enqueuer.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/periodic_enqueuer.go b/periodic_enqueuer.go
index 5d5259b1..2ed1cd84 100644
--- a/periodic_enqueuer.go
+++ b/periodic_enqueuer.go
@@ -79,9 +79,13 @@ func (pe *periodicEnqueuer) loop() {
 		case <-pe.stopChan:
 			pe.doneStoppingChan <- struct{}{}
 			return
-		case <-timer.C:
+		case t := <-timer.C:
 			timer.Reset(periodicEnqueuerSleep + time.Duration(rand.Intn(30))*time.Second)
-			if pe.shouldEnqueue() {
+			shouldEnqueue := pe.shouldEnqueue()
+			pe.logger.Debug("periodic_enqueuer.loop",
+				slog.Time("enqueue_time", t),
+				slog.Bool("should_enqueue", shouldEnqueue))
+			if shouldEnqueue {
 				err := pe.enqueue()
 				if err != nil {
 					pe.logger.Error("periodic_enqueuer.loop.enqueue", errAttr(err))