From c0dcd67427950b68ba64c5fd0f9436cd5b0df93d Mon Sep 17 00:00:00 2001 From: Prem Chaitanya Prathi Date: Wed, 18 Dec 2024 18:07:40 +0530 Subject: [PATCH] chore_: add logs for debugging --- .../waku-org/go-waku/waku/v2/api/missing/missing_messages.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/vendor/github.com/waku-org/go-waku/waku/v2/api/missing/missing_messages.go b/vendor/github.com/waku-org/go-waku/waku/v2/api/missing/missing_messages.go index 927ffb9c93..c0f3ba8624 100644 --- a/vendor/github.com/waku-org/go-waku/waku/v2/api/missing/missing_messages.go +++ b/vendor/github.com/waku-org/go-waku/waku/v2/api/missing/missing_messages.go @@ -130,7 +130,7 @@ func (m *MissingMessageVerifier) Start(ctx context.Context) { for { select { case <-t.C: - m.logger.Debug("checking for missing messages...") + m.logger.Debug("checking for missing messages...", zap.Int("criteria-len", len(m.criteriaInterest))) m.criteriaInterestMu.RLock() critIntList := make([]criteriaInterest, 0, len(m.criteriaInterest)) for _, value := range m.criteriaInterest { @@ -146,7 +146,9 @@ func (m *MissingMessageVerifier) Start(ctx context.Context) { semaphore <- struct{}{} go func(interest criteriaInterest) { defer utils.LogOnPanic() + m.logger.Debug("fetching history ", zap.Stringer("content-filter", interest.contentFilter), zap.Time("last-checked", interest.lastChecked)) m.fetchHistory(m.C, interest) + m.logger.Debug("finished fetching history ", zap.Stringer("content-filter", interest.contentFilter), zap.Time("last-checked", interest.lastChecked)) <-semaphore }(interest) }