Definitions for RTSP streaming. More...

#include <moonlight-common-c/src/Limelight-internal.h>
#include <moonlight-common-c/src/Rtsp.h>
#include <array>
#include <cctype>
#include <format>
#include <set>
#include <unordered_map>
#include <utility>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include "audio.h"
#include "config.h"
#include "globals.h"
#include "input.h"
#include "logging.h"
#include "network.h"
#include "rtsp.h"
#include "stream.h"
#include "sync.h"
#include "video.h"

Include dependency graph for rtsp.cpp:

Classes
class	rtsp_stream::rtsp_server_t
	RTSP listener that matches incoming clients to pending launch sessions. More...
class	rtsp_stream::socket_t
	RTSP client socket state and receive buffer parser. More...

Typedefs
using	rtsp_stream::cmd_func_t = std::function<void(rtsp_server_t *server, tcp::socket &, launch_session_t &, msg_t &&)>
	RTSP command handler signature used by the server dispatch table.
using	rtsp_stream::msg_t = util::safe_ptr<RTSP_MESSAGE, &free_msg>
	Owning pointer for an RTSP message allocated by moonlight-common-c.

Functions
void	rtsp_stream::cmd_announce (rtsp_server_t *rtsp_server, tcp::socket &sock, launch_session_t &session, msg_t &&req)
	Handle RTSP ANNOUNCE requests from the client.
void	rtsp_stream::cmd_describe (rtsp_server_t *, tcp::socket &sock, launch_session_t &session, msg_t &&req)
	Handle RTSP DESCRIBE requests.
void	rtsp_stream::cmd_describe_impl (tcp::socket &sock, launch_session_t &session, msg_t req)
	Build the RTSP DESCRIBE response, including any supported Dolby codec offer.
void	rtsp_stream::cmd_not_found (tcp::socket &sock, launch_session_t &, msg_t &&req)
	Send the RTSP response used for unsupported commands.
void	rtsp_stream::cmd_option (rtsp_server_t *, tcp::socket &sock, launch_session_t &session, msg_t &&req)
	Handle RTSP OPTIONS requests.
void	rtsp_stream::cmd_option_impl (tcp::socket &sock, launch_session_t &session, msg_t req)
	Handle the RTSP OPTIONS response without the unused server parameter.
void	rtsp_stream::cmd_play (rtsp_server_t *, tcp::socket &sock, launch_session_t &session, msg_t &&req)
	Handle RTSP PLAY requests and start streaming.
void	rtsp_stream::cmd_play_impl (tcp::socket &sock, launch_session_t &session, msg_t req)
	Build the RTSP PLAY response without the unused server parameter.
void	rtsp_stream::cmd_setup (rtsp_server_t *rtsp_server, tcp::socket &sock, launch_session_t &session, msg_t &&req)
	Handle RTSP SETUP requests and prepare transport state.
void	rtsp_stream::free_msg (PRTSP_MESSAGE msg)
	Release msg resources.
void	rtsp_stream::launch_session_clear (uint32_t launch_session_id)
	Clear state for the specified launch session.
void	rtsp_stream::launch_session_raise (std::shared_ptr< launch_session_t > launch_session)
	Queue a launch session until the RTSP client connects.
void	rtsp_stream::print_msg (PRTSP_MESSAGE msg)
	Write msg details to the log.
void	rtsp_stream::respond (tcp::socket &sock, launch_session_t &session, msg_t &resp)
	Send the protocol response for the current request.
void	rtsp_stream::respond (tcp::socket &sock, launch_session_t &session, POPTION_ITEM options, int statuscode, const char *status_msg, int seqn, const std::string_view &payload)
	Send the protocol response for the current request.
int	rtsp_stream::send (tcp::socket &sock, const std::string_view &sv)
	Send the serialized response over the active socket.
int	rtsp_stream::session_count ()
	Get the number of active sessions.
void	rtsp_stream::start ()
	Runs the RTSP server loop.
void	rtsp_stream::terminate_sessions ()
	Terminates all running streaming sessions.
void	rtsp_stream::terminate_sessions_by_cert (std::string_view cert)
	Terminate active sessions associated with a client certificate.

Variables
rtsp_server_t	rtsp_stream::server {}
	Singleton RTSP server used by GameStream launch sessions.

Detailed Description

Definitions for RTSP streaming.

Function Documentation

◆ cmd_announce()

void rtsp_stream::cmd_announce	(	rtsp_server_t *	rtsp_server,
		tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &&	req )

Handle RTSP ANNOUNCE requests from the client.

Parameters

rtsp_server	RTSP server instance handling the request.
sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ cmd_describe()

void rtsp_stream::cmd_describe	(	rtsp_server_t *	,
		tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &&	req )

Handle RTSP DESCRIBE requests.

The common command signature supplies a server pointer that this handler does not need.

Parameters

sock	Client socket.
session	Launch session.
req	RTSP request message.

◆ cmd_describe_impl()

void rtsp_stream::cmd_describe_impl	(	tcp::socket &	sock,
		launch_session_t &	session,
		msg_t	req )

Build the RTSP DESCRIBE response, including any supported Dolby codec offer.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

GFE advertises incorrect mapping for normal quality configurations, as a result, Moonlight rotates all channels from index '3' to the right To work around this, rotate channels to the left from index '3'

◆ cmd_not_found()

void rtsp_stream::cmd_not_found	(	tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &&	req )

Send the RTSP response used for unsupported commands.

Handle an unsupported RTSP command.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ cmd_option()

void rtsp_stream::cmd_option	(	rtsp_server_t *	,
		tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &&	req )

Handle RTSP OPTIONS requests.

The common command signature supplies a server pointer that this handler does not need.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ cmd_option_impl()

void rtsp_stream::cmd_option_impl	(	tcp::socket &	sock,
		launch_session_t &	session,
		msg_t	req )

Handle the RTSP OPTIONS response without the unused server parameter.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ cmd_play()

void rtsp_stream::cmd_play	(	rtsp_server_t *	,
		tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &&	req )

Handle RTSP PLAY requests and start streaming.

The common command signature supplies a server pointer that this handler does not need.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ cmd_play_impl()

void rtsp_stream::cmd_play_impl	(	tcp::socket &	sock,
		launch_session_t &	session,
		msg_t	req )

Build the RTSP PLAY response without the unused server parameter.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ cmd_setup()

void rtsp_stream::cmd_setup	(	rtsp_server_t *	rtsp_server,
		tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &&	req )

Handle RTSP SETUP requests and prepare transport state.

Parameters

rtsp_server	RTSP server instance handling the request.
sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
req	Parsed RTSP request being handled.

◆ free_msg()

void rtsp_stream::free_msg ( PRTSP_MESSAGE msg )

Release msg resources.

Parameters

msg	Raw RTSP message buffer being parsed or encrypted.

◆ launch_session_clear()

void rtsp_stream::launch_session_clear ( uint32_t launch_session_id )

Clear state for the specified launch session.

Parameters

launch_session_id The ID of the session to clear.

◆ launch_session_raise()

void rtsp_stream::launch_session_raise ( std::shared_ptr< launch_session_t > launch_session )

Queue a launch session until the RTSP client connects.

Parameters

launch_session Session state prepared by the GameStream launch handler.

◆ print_msg()

void rtsp_stream::print_msg ( PRTSP_MESSAGE msg )

Write msg details to the log.

Parameters

msg	Raw RTSP message buffer being parsed or encrypted.

◆ respond() [1/2]

void rtsp_stream::respond	(	tcp::socket &	sock,
		launch_session_t &	session,
		msg_t &	resp )

Send the protocol response for the current request.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
resp	RTSP response string to send to the client.

◆ respond() [2/2]

void rtsp_stream::respond	(	tcp::socket &	sock,
		launch_session_t &	session,
		POPTION_ITEM	options,
		int	statuscode,
		const char *	status_msg,
		int	seqn,
		const std::string_view &	payload )

Send the protocol response for the current request.

Parameters

sock	Socket used to read or write the protocol message.
session	Active streaming or pairing session for the request.
options	Request options or socket options to apply.
statuscode	RTSP status code to send in the response.
status_msg	Status msg.
seqn	RTSP CSeq value associated with the request.
payload	Optional payload body to include in the response.

◆ send()

int rtsp_stream::send	(	tcp::socket &	sock,
		const std::string_view &	sv )

Send the serialized response over the active socket.

Parameters

sock	Socket used to read or write the protocol message.
sv	String view containing the text to inspect.

Returns: Network operation status.

◆ session_count()

int rtsp_stream::session_count ( )

Get the number of active sessions.

Returns: Count of active sessions.

◆ terminate_sessions_by_cert()

void rtsp_stream::terminate_sessions_by_cert ( std::string_view cert )

Terminate active sessions associated with a client certificate.

Parameters

cert	Certificate data or object used by the operation.

Sunshine 0.0.5917 Self-hosted game stream host for Moonlight.

Classes

Typedefs

Functions

Variables

Detailed Description

Function Documentation

◆ cmd_announce()

◆ cmd_describe()

◆ cmd_describe_impl()

◆ cmd_not_found()

◆ cmd_option()

◆ cmd_option_impl()

◆ cmd_play()

◆ cmd_play_impl()

◆ cmd_setup()

◆ free_msg()

◆ launch_session_clear()

◆ launch_session_raise()

◆ print_msg()

◆ respond() [1/2]

◆ respond() [2/2]

◆ send()

◆ session_count()

◆ terminate_sessions_by_cert()