This goroutine collects errors returned from transfers
()
| 1012 | |
| 1013 | // This goroutine collects errors returned from transfers |
| 1014 | func (q *TransferQueue) errorCollector() { |
| 1015 | for err := range q.errorc { |
| 1016 | q.errors = append(q.errors, err) |
| 1017 | } |
| 1018 | q.errorwait.Done() |
| 1019 | } |
| 1020 | |
| 1021 | // run begins the transfer queue. It transfers files sequentially or |
| 1022 | // concurrently depending on the Config.ConcurrentTransfers() value. |