Method Done

tq/transfer_queue.go:162–170

()

}

func (q *abortableWaitGroup) Done() {
	q.mu.Lock()
	defer q.mu.Unlock()

	if !q.abort {
		q.counter -= 1
		q.wq.Done()
	}
}

func (q *abortableWaitGroup) Abort() {
	q.mu.Lock()