fix: cleanup

ethersphere · Jan 23, 2024 · be41e7c · be41e7c
1 parent be73f23
commit be41e7c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/pkg/storer/reserve.go b/pkg/storer/reserve.go
@@ -42,7 +42,6 @@ func threshold(capacity int) int { return capacity * 5 / 10 }
 
 func (db *DB) startReserveWorkers(
 	ctx context.Context,
-	warmupDur, wakeUpDur time.Duration,
 	radius func() (uint8, error),
 ) {
 	ctx, cancel := context.WithCancel(ctx)
@@ -57,7 +56,7 @@ func (db *DB) startReserveWorkers(
 	go db.evictionWorker(ctx)
 
 	select {
-	case <-time.After(warmupDur):
+	case <-time.After(db.opts.warmupDuration):
 	case <-db.quit:
 		return
 	}

diff --git a/pkg/storer/storer.go b/pkg/storer/storer.go
@@ -618,7 +618,7 @@ func (db *DB) SetRetrievalService(r retrieval.Interface) {
 func (db *DB) StartReserveWorker(ctx context.Context, s Syncer, radius func() (uint8, error)) {
 	db.setSyncerOnce.Do(func() {
 		db.syncer = s
-		go db.startReserveWorkers(ctx, db.opts.warmupDuration, db.opts.wakeupDuration, radius)
+		go db.startReserveWorkers(ctx, radius)
 	})
 }