Recreate timer for cleaning up completed transfer tasks
Summary:
This fixes the bug in transfer queue processor where upddateAckTimer
only fired once and never created again.  This caused us to not move ack level
and delete transfer tasks from the executions table.
Reviewers: sivakk
Subscribers: aravindv, venkat
@@ -140,6 +140,7 @@ func (t *transferQueueProcessorImpl) processorPump() {
pollTimer = time.NewTimer(pollInterval)
case <-updateAckTimer.C:
t.ackMgr.updateAckLevel()
+ updateAckTimer = time.NewTimer(transferProcessorUpdateAckInterval)
}
}
}
