t.behrendt/realDynDNS
1
0
Fork 0
Code Issues 5 Pull Requests 1 Actions Packages Releases Activity

feat: concurrently check and update all domains #24

Merged
t.behrendt merged 2 commits from feat-concurrency into main 2024-12-30 17:37:50 +01:00
Conversation 0 Commits 2 Files Changed 1 +10 -5
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 16921d41f3 - Show all commits

15
pkg/realDynDns/realDynDns.go
View File

@@ -73,7 +73,7 @@ func (c *ChangeDetector) detectAndApplyChanges() (int, error) {
var wg sync.WaitGroup var wg sync.WaitGroup
numberUpdated := make(chan int) numberUpdatedChannel := make(chan int)
for _, domain := range c.domains { for _, domain := range c.domains {
for _, subdomain := range domain.Subdomains { for _, subdomain := range domain.Subdomains {
@@ -131,7 +131,7 @@ func (c *ChangeDetector) detectAndApplyChanges() (int, error) {
return return
} }
numberUpdated <- 1 numberUpdatedChannel <- 1
} }
}(domain, subdomain) }(domain, subdomain)
} }
@@ -139,9 +139,14 @@ func (c *ChangeDetector) detectAndApplyChanges() (int, error) {
go func() { go func() {
wg.Wait() wg.Wait()
close(numberUpdated) close(numberUpdatedChannel)
}() }()
c.logger.Info("Run completed", slog.Int("number_of_changes", <-numberUpdated)) numberUpdated := 0
return <-numberUpdated, nil for v := range numberUpdatedChannel {
numberUpdated += v
}
c.logger.Info("Run completed", slog.Int("number_of_changes", numberUpdated))
return numberUpdated, nil
} }