Merge pull request #577 from sinbad/queue-error-race-condition
Fix race condition meaning TransferQueue might not report errors in time
This commit is contained in:
commit
3f2a526bf2
@ -100,8 +100,8 @@ func (q *TransferQueue) individualApiRoutine(apiWaiter chan interface{}) {
|
||||
for t := range q.apic {
|
||||
obj, err := t.Check()
|
||||
if err != nil {
|
||||
q.wait.Done()
|
||||
q.errorc <- err
|
||||
q.wait.Done()
|
||||
continue
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user