From 16921d41f36603534940b54c34556d0b656aebb6 Mon Sep 17 00:00:00 2001 From: Timo Behrendt Date: Sun, 29 Dec 2024 17:10:25 +0100 Subject: [PATCH] fix: counting of performed update --- pkg/realDynDns/realDynDns.go | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/pkg/realDynDns/realDynDns.go b/pkg/realDynDns/realDynDns.go index 7ac2e57..15cd4dd 100644 --- a/pkg/realDynDns/realDynDns.go +++ b/pkg/realDynDns/realDynDns.go @@ -73,7 +73,7 @@ func (c *ChangeDetector) detectAndApplyChanges() (int, error) { var wg sync.WaitGroup - numberUpdated := make(chan int) + numberUpdatedChannel := make(chan int) for _, domain := range c.domains { for _, subdomain := range domain.Subdomains { @@ -131,7 +131,7 @@ func (c *ChangeDetector) detectAndApplyChanges() (int, error) { return } - numberUpdated <- 1 + numberUpdatedChannel <- 1 } }(domain, subdomain) } @@ -139,9 +139,14 @@ func (c *ChangeDetector) detectAndApplyChanges() (int, error) { go func() { wg.Wait() - close(numberUpdated) + close(numberUpdatedChannel) }() - c.logger.Info("Run completed", slog.Int("number_of_changes", <-numberUpdated)) - return <-numberUpdated, nil + numberUpdated := 0 + for v := range numberUpdatedChannel { + numberUpdated += v + } + + c.logger.Info("Run completed", slog.Int("number_of_changes", numberUpdated)) + return numberUpdated, nil }