From 61dfe6e7a66f6acc9d7e20487430e0585afd6ba3 Mon Sep 17 00:00:00 2001
From: Nonoo <nonoo@nonoo.hu>
Date: Tue, 20 Oct 2020 17:40:24 +0200
Subject: [PATCH] Fix high CPU usage

---
 seqbuf.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/seqbuf.go b/seqbuf.go
index e59943e..14e7665 100644
--- a/seqbuf.go
+++ b/seqbuf.go
@@ -222,7 +222,10 @@ func (s *seqBuf) watcher() {
 
 	for {
 		retry := true
+
 		for retry {
+			retry = false
+
 			t, err := s.getNextDataAvailableRemainingTime()
 			if err == nil {
 				if t == 0 { // Do we have an entry available right now?
@@ -234,14 +237,14 @@ func (s *seqBuf) watcher() {
 					} else {
 						log.Error(err)
 					}
+
+					// We may have further available entries.
+					retry = true
 				} else if !entryAvailableTimerRunning {
 					// An entry will be available later, waiting for it.
 					entryAvailableTimer.Reset(t)
 					entryAvailableTimerRunning = true
 				}
-				retry = true
-			} else {
-				retry = false
 			}
 		}