cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Fix: precommit_batch method used the wrong cfg.PreCommitBatchWait

Browse Source
This commit is contained in:
zhoutian527 2021-07-02 15:53:21 +08:00 committed by Łukasz Magiera
parent 4fe3ecb8fc
commit c5ea17f838
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
extern/storage-sealing/precommit_batch.go vendored
View File

@ -86,7 +86,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
@ -120,7 +120,7 @@ func (b *PreCommitBatcher) run() {
}
}
timer.Reset(b.batchWait(cfg.CommitBatchWait, cfg.CommitBatchSlack))
timer.Reset(b.batchWait(cfg.PreCommitBatchWait, cfg.PreCommitBatchSlack))
}
}