Method mainLoop

pkg/devspace/sync/sync.go:209–230

(onInitUploadDone chan struct{}, onInitDownloadDone chan struct{})

}

func (s *Sync) mainLoop(onInitUploadDone chan struct{}, onInitDownloadDone chan struct{}) {
	s.log.Info("Start syncing")

	// Start upstream as early as possible
	if !s.Options.UpstreamDisabled {
		go s.startUpstream()
	}

	// Start downstream and do initial sync
	go func() {
		err := s.initialSync(onInitUploadDone, onInitDownloadDone)
		if err != nil {
			s.Stop(errors.Wrap(err, "initial sync"))
			return
		}

		if !s.Options.DownstreamDisabled {
			s.startDownstream()
			s.Stop(nil)
		}
	}()
}

func (s *Sync) startUpstream() {
	defer s.Stop(nil)