Method NeedFolderFiles

lib/model/model.go:997–1065

NeedFolderFiles returns paginated list of currently needed files in progress, queued, and to be queued on next puller iteration.

(folder string, page, perpage int)

// NeedFolderFiles returns paginated list of currently needed files in
// progress, queued, and to be queued on next puller iteration.
func (m *model) NeedFolderFiles(folder string, page, perpage int) ([]protocol.FileInfo, []protocol.FileInfo, []protocol.FileInfo, error) {
	m.mut.RLock()
	runner, runnerOk := m.folderRunners.Get(folder)
	cfg, cfgOK := m.folderCfgs[folder]
	m.mut.RUnlock()

	if !cfgOK {
		return nil, nil, nil, ErrFolderMissing
	}

	var progress, queued, rest []protocol.FileInfo
	var seen map[string]struct{}

	p := newPager(page, perpage)

	if runnerOk {
		progressNames, queuedNames, skipped := runner.Jobs(page, perpage)

		progress = make([]protocol.FileInfo, len(progressNames))
		queued = make([]protocol.FileInfo, len(queuedNames))
		seen = make(map[string]struct{}, len(progressNames)+len(queuedNames))

		for i, name := range progressNames {
			if f, ok, err := m.sdb.GetGlobalFile(folder, name); err == nil && ok {
				progress[i] = f
				seen[name] = struct{}{}
			}
		}

		for i, name := range queuedNames {
			if f, ok, err := m.sdb.GetGlobalFile(folder, name); err == nil && ok {
				queued[i] = f
				seen[name] = struct{}{}
			}
		}

		p.get -= len(seen)
		if p.get == 0 {
			return progress, queued, nil, nil
		}
		p.toSkip -= skipped
	}

	if p.get > 0 {
		rest = make([]protocol.FileInfo, 0, p.get)
		it, errFn := m.sdb.AllNeededGlobalFiles(folder, protocol.LocalDeviceID, config.PullOrderAlphabetic, 0, 0)
		for f := range it {
			if cfg.IgnoreDelete && f.IsDeleted() {
				continue
			}

			if p.skip() {
				continue
			}
			if _, ok := seen[f.Name]; !ok {
				rest = append(rest, f)
				p.get--
			}