|
@@ -179,15 +179,17 @@ func (b *backend) Size() int64 {
|
|
|
|
|
|
|
|
func (b *backend) run() {
|
|
func (b *backend) run() {
|
|
|
defer close(b.donec)
|
|
defer close(b.donec)
|
|
|
-
|
|
|
|
|
|
|
+ t := time.NewTimer(b.batchInterval)
|
|
|
|
|
+ defer t.Stop()
|
|
|
for {
|
|
for {
|
|
|
select {
|
|
select {
|
|
|
- case <-time.After(b.batchInterval):
|
|
|
|
|
|
|
+ case <-t.C:
|
|
|
case <-b.stopc:
|
|
case <-b.stopc:
|
|
|
b.batchTx.CommitAndStop()
|
|
b.batchTx.CommitAndStop()
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
b.batchTx.Commit()
|
|
b.batchTx.Commit()
|
|
|
|
|
+ t.Reset(b.batchInterval)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|