vfscache/downloaders/downloaders.go

57 type Downloaders struct {  struct
59 	ctx    context.Context
60 	cancel context.CancelFunc
61 	item   Item
62 	opt    *vfscommon.Options
63 	src    fs.Object // source object
64 	remote string
65 	wg     sync.WaitGroup
68 	mu         sync.Mutex
69 	dls        []*downloader
70 	waiters    []waiter
71 	errorCount int   // number of consecutive errors
72 	lastErr    error // last error received
143 func (dls *Downloaders) _countErrors(n int64, err error) {
161 func (dls *Downloaders) countErrors(n int64, err error) {
170 func (dls *Downloaders) _newDownloader(r ranges.Range) (dl *downloader, err error) {
211 func (dls *Downloaders) _removeClosed() {
223 func (dls *Downloaders) Close(inErr error) (err error) {
249 func (dls *Downloaders) Download(r ranges.Range) (err error) {
274 func (dls *Downloaders) _closeWaiters(err error) {
285 func (dls *Downloaders) _ensureDownloader(r ranges.Range) (err error) {
373 func (dls *Downloaders) EnsureDownloader(r ranges.Range) (err error) {
383 func (dls *Downloaders) _dispatchWaiters() {
401 func (dls *Downloaders) kickWaiters() (err error) {