Fix: precommit_batch method used the wrong cfg.PreCommitBatchWait

filecoin-project · Jul 2, 2021 · 71e1577 · 71e1577
1 parent 20c8250
commit 71e1577
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/extern/storage-sealing/precommit_batch.go b/extern/storage-sealing/precommit_batch.go
@@ -88,7 +88,7 @@ func (b *PreCommitBatcher) run() {
 		panic(err)
 	}
 
-	timer := time.NewTimer(b.batchWait(cfg.CommitBatchWait, cfg.CommitBatchSlack))
+	timer := time.NewTimer(b.batchWait(cfg.PreCommitBatchWait, cfg.PreCommitBatchSlack))
 	for {
 		if forceRes != nil {
 			forceRes <- lastRes
@@ -122,7 +122,7 @@ func (b *PreCommitBatcher) run() {
 			}
 		}
 
-		timer.Reset(b.batchWait(cfg.CommitBatchWait, cfg.CommitBatchSlack))
+		timer.Reset(b.batchWait(cfg.PreCommitBatchWait, cfg.PreCommitBatchSlack))
 	}
 }