Add a sleep in the defrag code

riendeau · Jul 15, 2024 · d7cf24e · d7cf24e
1 parent b433760
commit d7cf24e
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/server/storage/backend/backend.go b/server/storage/backend/backend.go
@@ -20,6 +20,7 @@ import (
 	"io"
 	"os"
 	"path/filepath"
+	"strconv"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -574,6 +575,12 @@ func (b *backend) defrag() error {
 }
 
 func defragdb(odb, tmpdb *bolt.DB, limit int) error {
+	if defragWaitStr := os.Getenv("HACK_DEFRAG_WAIT_SECONDS"); defragWaitStr != "" {
+		if defragWaitSeconds, err := strconv.Atoi(defragWaitStr); err != nil && defragWaitSeconds > 0 {
+			time.Sleep(time.Duration(defragWaitSeconds) * time.Second)
+		}
+	}
+
 	// open a tx on tmpdb for writes
 	tmptx, err := tmpdb.Begin(true)
 	if err != nil {