76d4e53ea0
Implement Reset method on audit task manager that cleans task queue. Extended TaskManager interface with Reset method on IR side. Call Reset method in audit processor before new audit start. Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
8 lines
122 B
Go
8 lines
122 B
Go
package audittask
|
|
|
|
// Reset pops all tasks from the queue.
|
|
func (m *Manager) Reset() {
|
|
for len(m.ch) > 0 {
|
|
<-m.ch
|
|
}
|
|
}
|