Fix: precommit_batch method used the wrong cfg.PreCommitBatchWait

This commit is contained in:
zhoutian527 2021-07-02 15:53:21 +08:00
parent 20c8250872
commit 71e1577a62

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