Merge pull request #76 from intergral/ret_loops

fix(compactor/retention): fix missing loop in retention and compactor

DEVELOPMENT.md

@@ -0,0 +1,8 @@
+# Development
+
+## Prerequisites
+
+ - Go : v1.20+
+   - gofumpt - `go install mvdan.cc/gofumpt@latest`
+   - goimports - `go install golang.org/x/tools/cmd/goimports@latest`
+ - Docker

pkg/deepdb/compactor.go

@@ -85,11 +85,19 @@ func (rw *readerWriter) compactionLoop(ctx context.Context) {
 	}
 
 	ticker := time.NewTicker(compactionCycle)
-	select {
-	case <-ticker.C:
-		rw.doCompaction(ctx)
-	case <-ctx.Done():
-		return
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		default:
+		}
+
+		select {
+		case <-ticker.C:
+			rw.doCompaction(ctx)
+		case <-ctx.Done():
+			return
+		}
 	}
 }
 

pkg/deepdb/retention.go

@@ -32,11 +32,19 @@ import (
 // retentionLoop watches a timer to clean up blocks that are past retention.
 func (rw *readerWriter) retentionLoop(ctx context.Context) {
 	ticker := time.NewTicker(rw.cfg.BlocklistPoll)
-	select {
-	case <-ticker.C:
-		rw.doRetention(ctx)
-	case <-ctx.Done():
-		return
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		default:
+		}
+
+		select {
+		case <-ticker.C:
+			rw.doRetention(ctx)
+		case <-ctx.Done():
+			return
+		}
 	}
 }