Method execTar

pkg/sync/sync.go:172–238

(cmd []string, st Stream)

}

func (s *Sync) execTar(cmd []string, st Stream) error {
	retries := 0
	success := false

	for {
		exec, err := s.docker.CreateExec(docker.CreateExecOptions{
			AttachStdout: true,
			Container:    s.Container,
			Cmd:          cmd,
		})
		if err != nil {
			return err
		}

		r, w := io.Pipe()

		cw, err := s.docker.StartExecNonBlocking(exec.ID, docker.StartExecOptions{
			OutputStream: w,
		})
		if err != nil {
			if cw != nil {
				cw.Close()
			}
			return err
		}

		done := make(chan struct{})
		state := make(chan execState)
		wait := make(chan error)

		go func() {
			wait <- cw.Wait()
		}()
		go tgzReader(s, r, st)
		go inspectExec(exec.ID, s, state, done)

		select {
		case err := <-wait:
			if err != nil {
				return err
			}

			close(done)
			success = true

		case es := <-state:
			cw.Close()

			if retries < 3 {
				retries++
				if es.Error == nil && es.ExitCode == 0 {
					success = true
				}
			} else {
				if es.Error != nil {
					return es.Error
				}
				return fmt.Errorf("failed to sync after retries")