Function downloadToStdout

cmd/stdout.go:31–61

(dbx filesClient, src string, w io.Writer)

}

func downloadToStdout(dbx filesClient, src string, w io.Writer) error {
	ignoreBrokenPipeSignal()

	arg := files.NewDownloadArg(src)
	var bytesWritten int64

	err := retryWithBackoff(func() error {
		if bytesWritten > 0 {
			return partialStdoutError(bytesWritten)
		}

		_, contents, err := dbx.DownloadContext(currentContext(), arg)
		if err != nil {
			return err
		}
		defer func() { _ = contents.Close() }()

		n, copyErr := io.Copy(stdoutBrokenPipeWriter{w: w}, contents)
		bytesWritten += n

		if errors.Is(copyErr, errStdoutBrokenPipe) {
			return nil
		}
		if copyErr != nil && bytesWritten > 0 {
			return partialStdoutError(bytesWritten)
		}
		return copyErr
	})

	return err
}

func partialStdoutError(bytesWritten int64) error {
	return partialTransferError{bytesWritten: bytesWritten}