From f298886354ca1c5cbefcfb829be3a89b3df67acc Mon Sep 17 00:00:00 2001 From: Messede Degod Date: Mon, 21 Sep 2026 22:07:05 +0530 Subject: [PATCH 1/2] fix: certHandler busy loop on entryChan close --- internal/certificatetransparency/ct-watcher.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/certificatetransparency/ct-watcher.go b/internal/certificatetransparency/ct-watcher.go index bee9e08..3749893 100644 --- a/internal/certificatetransparency/ct-watcher.go +++ b/internal/certificatetransparency/ct-watcher.go @@ -548,7 +548,11 @@ func certHandler(entryChan chan models.Entry) { var processed uint64 for { - entry := <-entryChan + entry, ok := <-entryChan + if !ok { // channel is closed, nothing else to receive, exit the look + break + } + processed++ if processed%1000 == 0 { From 9b55f7f791768778f9cbbb001c93a87424b56984 Mon Sep 17 00:00:00 2001 From: Messede Degod Date: Sat, 26 Sep 2026 06:51:45 +0000 Subject: [PATCH 2/2] fix: typo --- internal/certificatetransparency/ct-watcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/certificatetransparency/ct-watcher.go b/internal/certificatetransparency/ct-watcher.go index 3749893..3a5af79 100644 --- a/internal/certificatetransparency/ct-watcher.go +++ b/internal/certificatetransparency/ct-watcher.go @@ -549,7 +549,7 @@ func certHandler(entryChan chan models.Entry) { for { entry, ok := <-entryChan - if !ok { // channel is closed, nothing else to receive, exit the look + if !ok { // channel is closed, nothing else to receive, exit the loop break }