Method Stop

pkg/devspace/sync/sync.go:413–458

Stop stops the sync process

(fatalError error)

// Stop stops the sync process
func (s *Sync) Stop(fatalError error) {
	s.stopOnce.Do(func() {
		s.cancelCtx()
		if s.upstream != nil {
			for _, symlink := range s.upstream.symlinks {
				symlink.Stop()
			}
			if s.upstream.writer != nil {
				s.upstream.writer.Close()
			}
			if s.upstream.reader != nil {
				s.upstream.reader.Close()
			}
			if s.upstream.conn != nil {
				s.upstream.conn.Close()
			}
		}

		if s.downstream != nil {
			if s.downstream.writer != nil {
				s.downstream.writer.Close()
			}
			if s.downstream.reader != nil {
				s.downstream.reader.Close()
			}
			if s.downstream.conn != nil {
				s.downstream.conn.Close()
			}
		}

		if fatalError != nil {
			s.Error(fatalError)

			// This needs to be rethought because we do not always kill the application here, would be better to have an error channel
			// or runtime error here
			if s.onError != nil {
				s.onError <- fatalError
			}
		}

		s.log.Debugf("Sync stopped")
		if s.onDone != nil {
			close(s.onDone)
		}
	})
}