Function proxyDirectWithIO

command/ssh/proxycommand.go:233–264

(host, port string, stdin io.Reader, stdout io.Writer)

}

func proxyDirectWithIO(host, port string, stdin io.Reader, stdout io.Writer) error {
	address := net.JoinHostPort(host, port)
	addr, err := net.ResolveTCPAddr("tcp", address)
	if err != nil {
		return errors.Wrap(err, "error resolving address")
	}

	conn, err := net.DialTCP("tcp", nil, addr)
	if err != nil {
		return errors.Wrapf(err, "error connecting to %s", address)
	}
	defer conn.Close()

	// Return as soon as either direction finishes. Waiting for both can
	// deadlock when the server closes the connection while stdin stays open.
	// See smallstep/cli#1641. Buffered so the slower goroutine never blocks
	// sending after we've stopped receiving.
	done := make(chan struct{}, 2)
	go func() {
		io.Copy(conn, stdin)
		conn.CloseWrite()
		done <- struct{}{}
	}()
	go func() {
		io.Copy(stdout, conn)
		conn.CloseRead()
		done <- struct{}{}
	}()

	<-done
	return nil
}

func proxyBastion(r *api.SSHBastionResponse, user, host, port string) error {
	sshPath, err := exec.LookPath("ssh")