Decrease the waitgroup when batch errors

2015-08-17 15:21:08 -06:00 · 2015-08-17 15:21:08 -06:00 · 84a34c2415
commit 84a34c2415
parent 2005013046
1 changed files with 3 additions and 0 deletions
--- a/lfs/transfer_queue.go
+++ b/lfs/transfer_queue.go
@ -176,6 +176,9 @@ func (q *TransferQueue) batchApiRoutine() {
 				go q.legacyFallback(batch)
 				return
 			}
+
+			q.wait.Add(-len(transfers))
+
 			q.errorc <- err
 			continue
 		}