INNER CODE UNIT · Go

connectToTarget

backube/volsync · diskrsync-tcp/main.go:121

func connectToTarget(sourceFile, targetAddress string, port int, opts *options, logger logr.Logger) error {
	f, err := os.Open(filepath.Clean(sourceFile))
	if err != nil {
		return err
	}
	logger.Info("Opened filed", "file", sourceFile)
	defer f.Close()
	var src io.ReadSeeker

	// Try to open as an spgz file
	sf, err := spgz.NewFromFile(f, os.O_RDONLY)
	if err != nil {
		if !errors.Is(err, spgz.ErrInvalidFormat) {
			return err
		}
		logger.Info("Not an spgz file")
		src = f
	} else {

View source record →