|
@@ -297,6 +297,7 @@ func (w *worker) newWorkLoop(recommit time.Duration) {
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
timer := time.NewTimer(0)
|
|
timer := time.NewTimer(0)
|
|
|
|
|
+ defer timer.Stop()
|
|
|
<-timer.C // discard the initial tick
|
|
<-timer.C // discard the initial tick
|
|
|
|
|
|
|
|
// commit aborts in-flight transaction execution with given signal and resubmits a new one.
|
|
// commit aborts in-flight transaction execution with given signal and resubmits a new one.
|