Function walkDir

helper/server/downstream.go:534–597

(basePath string, path string, ignoreMatcher ignoreparser.IgnoreParser, state map[string]*remote.Change, noRecursive bool, throttle time.Duration)

}

func walkDir(basePath string, path string, ignoreMatcher ignoreparser.IgnoreParser, state map[string]*remote.Change, noRecursive bool, throttle time.Duration) {
	files, err := os.ReadDir(path)
	if err != nil {
		// We ignore errors here
		return
	}

	for _, dirEntry := range files {
		f, err := dirEntry.Info()
		if err != nil {
			continue
		}

		absolutePath := filepath.Join(path, f.Name())
		if fsutil.IsRecursiveSymlink(f, absolutePath) {
			continue
		}

		// Stat is necessary here, because readdir does not follow symlinks and
		// IsDir() returns false for symlinked folders
		stat, err := os.Stat(absolutePath)
		if err != nil {
			// Woops file is not here anymore -> ignore error
			continue
		}

		// Check if ignored
		if ignoreMatcher != nil && !ignoreMatcher.RequireFullScan() && ignoreMatcher.Matches(absolutePath[len(basePath):], stat.IsDir()) {
			continue
		}

		// should throttle?
		if throttle != 0 && len(state)%100 == 0 {
			time.Sleep(throttle)
		}

		// Check if directory
		if stat.IsDir() {
			// Check if not ignored
			if ignoreMatcher == nil || !ignoreMatcher.RequireFullScan() || !ignoreMatcher.Matches(absolutePath[len(basePath):], true) {
				state[absolutePath] = &remote.Change{
					Path:  absolutePath,
					IsDir: true,
				}
			}

			if !noRecursive {
				walkDir(basePath, absolutePath, ignoreMatcher, state, noRecursive, throttle)
			}
		} else {
			// Check if not ignored
			if ignoreMatcher == nil || !ignoreMatcher.RequireFullScan() || !ignoreMatcher.Matches(absolutePath[len(basePath):], false) {
				state[absolutePath] = &remote.Change{
					Path:          absolutePath,
					Size:          stat.Size(),
					MtimeUnix:     stat.ModTime().Unix(),
					MtimeUnixNano: stat.ModTime().UnixNano(),
					Mode:          uint32(stat.Mode()),