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 dbdbb6f0dd
commit 57d70e58f3
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

@ -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))
}
}