Method mainLoop

pkg/devspace/sync/upstream.go:201–267

()

}

func (u *upstream) mainLoop() error {
	doneChan := make(chan struct{})
	defer close(doneChan)

	// start collecting events
	u.startEventsLoop(doneChan)

	for {
		var (
			changes      []*FileInformation
			changeAmount = 0
			changeTimer  time.Time
		)

		// gather changes
		for {
			select {
			case <-u.sync.ctx.Done():
				return nil
			case <-time.After(time.Millisecond * 600):
				break
			}

			// retrieve the newest events
			events := u.getEvents()
			if len(events) > 0 {
				fileInformation, err := u.getFileInformationFromEvent(events)
				if err != nil {
					return errors.Wrap(err, "get file information from event")
				}

				changes = append(changes, fileInformation...)
			}

			// start waiting timer
			if len(changes) > 0 && changeAmount == 0 {
				changeTimer = time.Now().Add(waitForMoreChangesTimeout)
			}

			// We gather changes till there are no more changes or
			// a certain amount of changes is reached
			if changeAmount > 0 && (time.Now().After(changeTimer) || len(changes) > 25000 || changeAmount == len(changes)) {
				break
			}

			changeAmount = len(changes)
			if changeAmount == 0 && len(u.events) == 0 {
				u.isBusyMutex.Lock()
				if len(u.events) == 0 {
					u.isBusy = false
				}
				u.isBusyMutex.Unlock()
			}

			err := u.execCommandsAfterInitialSync()
			if err != nil {
				return errors.Wrap(err, "exec after initial sync")
			}