Merge pull request #6658 from sunday527/master

Fix: precommit_batch method used the wrong cfg.CommitBatchWait
filecoin-project · Jul 2, 2021 · 35c0e3c · 35c0e3c
2 parents 60ecbde + 71e1577
commit 35c0e3c
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))
 	}
 }