Function StartTunnelServer

helper/tunnel/server.go:27–53

(reader io.Reader, writer io.Writer, exitOnClose, ping bool)

}

func StartTunnelServer(reader io.Reader, writer io.Writer, exitOnClose, ping bool) error {
	pipe := util.NewStdStreamJoint(reader, writer, exitOnClose)
	lis := util.NewStdinListener()
	done := make(chan error)

	go func() {
		s := grpc.NewServer()

		tunnel := &tunnelServer{
			ping: &pingtimeout.PingTimeout{},
		}

		if ping {
			doneChan := make(chan struct{})
			defer close(doneChan)
			tunnel.ping.Start(doneChan)
		}

		remote.RegisterTunnelServer(s, tunnel)
		reflection.Register(s)

		done <- s.Serve(lis)
	}()

	lis.Ready(pipe)
	return <-done
}

func SendData(stream remote.Tunnel_InitTunnelServer, sessions <-chan *Session, closeChan chan struct{}) {
	for {