(opts *CreateOptions, remoteURL, branch string)
| 708 | } |
| 709 | |
| 710 | func cloneWithRetry(opts *CreateOptions, remoteURL, branch string) error { |
| 711 | // Allow injecting alternative BackOff in tests. |
| 712 | if opts.BackOff == nil { |
| 713 | opts.BackOff = backoff.NewConstantBackOff(3 * time.Second) |
| 714 | } |
| 715 | |
| 716 | var args []string |
| 717 | if branch != "" { |
| 718 | args = append(args, "--branch", branch) |
| 719 | } |
| 720 | |
| 721 | ctx := context.Background() |
| 722 | return backoff.Retry(func() error { |
| 723 | stderr := &bytes.Buffer{} |
| 724 | _, err := opts.GitClient.Clone(ctx, remoteURL, args, git.WithStderr(stderr)) |
| 725 | |
| 726 | var execError errWithExitCode |
| 727 | if errors.As(err, &execError) && execError.ExitCode() == 128 { |
| 728 | return err |
| 729 | } else { |
| 730 | _, _ = io.Copy(opts.IO.ErrOut, stderr) |
| 731 | } |
| 732 | |
| 733 | return backoff.Permanent(err) |
| 734 | }, backoff.WithContext(backoff.WithMaxRetries(opts.BackOff, 3), ctx)) |
| 735 | } |
| 736 | |
| 737 | func sourceInit(gitClient *git.Client, io *iostreams.IOStreams, remoteURL, baseRemote string) error { |
| 738 | cs := io.ColorScheme() |
no test coverage detected