Method acceptLoop

server-source-code/internal/rdpproxy/session.go:165–190

(ctx context.Context)

}

func (s *Session) acceptLoop(ctx context.Context) {
	for {
		conn, err := s.Listener.Accept()
		if err != nil {
			if ctx.Err() != nil {
				return
			}
			if s.log != nil {
				s.log.Debug("rdp proxy accept error", "session_id", s.SessionID, "error", err)
			}
			return
		}

		s.mu.Lock()
		if s.guacdConn != nil {
			_ = conn.Close()
			s.mu.Unlock()
			continue
		}
		s.guacdConn = conn
		s.mu.Unlock()

		go s.bridgeGuacdToAgent(conn)
		return
	}
}

func (s *Session) bridgeGuacdToAgent(conn net.Conn) {
	defer func() {