Method ChangesCount

helper/server/downstream.go:232–263

ChangesCount returns the amount of changes on the remote side

(context.Context, *remote.Empty)

// ChangesCount returns the amount of changes on the remote side
func (d *Downstream) ChangesCount(context.Context, *remote.Empty) (*remote.ChangeAmount, error) {
	newState := make(map[string]*remote.Change)
	throttle := time.Duration(d.options.Throttle) * time.Millisecond

	// Walk through the dir
	if d.options.Polling {
		walkDir(d.options.RemotePath, d.options.RemotePath, d.ignoreMatcher, newState, d.options.NoRecursiveWatch, throttle)
	}

	changeAmount := int64(0)
	if d.options.Polling {
		var err error
		changeAmount, err = streamChanges(d.options.RemotePath, d.watchedFiles, newState, nil, throttle)
		if err != nil {
			return nil, errors.Wrap(err, "count changes")
		}
	} else {
		d.changesMutex.Lock()
		// if rescan is not set we make sure that we say that there
		// are changes
		if d.lastRescan == nil {
			changeAmount = int64(1)
		} else {
			changeAmount = int64(len(d.changes))
		}
		d.changesMutex.Unlock()
	}

	return &remote.ChangeAmount{
		Amount: changeAmount,
	}, nil
}

func (d *Downstream) getWatchState() map[string]*remote.Change {
	d.changesMutex.Lock()