#include <server.h>

Inheritance diagram for quicr::Server:

Classes
struct	AnnounceResponse
	Response to received MOQT Announce message. More...
struct	ClientSetupResponse
	Response to received MOQT ClientSetup message. More...

Public Types
enum class	Status : uint8_t { kReady = 0 , kNotReady , kInternalError , kInvalidParams , kConnecting , kDisconnecting , kNotConnected , kFailedToConnect , kPendingServerSetup }
	Status of the transport. More...
enum class	ControlMessageStatus : uint8_t { kMessageIncomplete , kMessageComplete , kStreamBufferCannotBeZero , kStreamBufferMissingType , kUnsupportedMessageType }
	Control message status codes. More...
enum class	StreamDataMessageStatus : uint8_t
enum class	ConnectionStatus : uint8_t { kNotConnected = 0 , kConnecting , kConnected , kIdleTimeout , kClosedByRemote }
	Connection status codes. More...

Public Member Functions
	Server (const ServerConfig &cfg)
	MoQ Server constructor to create the MOQ server mode instance.
	Server (const ServerConfig &cfg, std::shared_ptr< ThreadedTickService > tick_service)
	~Server ()=default
Status	Start ()
	Starts server transport thread to listen for new connections.
void	Stop ()
void	BindPublisherTrack (ConnectionHandle connection_handle, ConnectionHandle src_id, uint64_t request_id, const std::shared_ptr< PublishTrackHandler > &track_handler, bool ephemeral=false)
	Bind a server publish track handler based on a subscribe.
void	UnbindPublisherTrack (ConnectionHandle connection_handle, ConnectionHandle src_id, const std::shared_ptr< PublishTrackHandler > &track_handler)
	Unbind a server publish track handler.
void	BindFetchTrack (TransportConnId conn_id, std::shared_ptr< PublishFetchHandler > track_handler)
	Bind a server fetch publisher track handler.
void	UnbindFetchTrack (ConnectionHandle conn_id, const std::shared_ptr< PublishFetchHandler > &track_handler)
	Unbind a server fetch publisher track handler.
virtual void	ResolveSubscribe (ConnectionHandle connection_handle, uint64_t request_id, uint64_t track_alias, const SubscribeResponse &subscribe_response)
	Accept or reject an subscribe that was received.
virtual void	ResolvePublish (ConnectionHandle connection_handle, uint64_t request_id, bool forward, messages::SubscriberPriority priority, messages::GroupOrder group_order, const PublishResponse &publish_response)
	Accept or reject publish that was received.
const std::shared_ptr< TickService > &	GetTickService () const noexcept
void	SubscribeTrack (ConnectionHandle connection_handle, std::shared_ptr< SubscribeTrackHandler > track_handler)
	Subscribe to a track.
void	UnsubscribeTrack (ConnectionHandle connection_handle, const std::shared_ptr< SubscribeTrackHandler > &track_handler)
	Unsubscribe track.
void	UpdateTrackSubscription (ConnectionHandle connection_handle, std::shared_ptr< SubscribeTrackHandler > track_handler, bool new_group_request=false)
	Update Subscription to a track.
void	PublishTrack (ConnectionHandle connection_handle, std::shared_ptr< PublishTrackHandler > track_handler)
	Publish to a track.
void	PublishTrackSub (ConnectionHandle connection_handle, std::shared_ptr< PublishTrackHandler > track_handler)
	Publish to a track and force subscribe.
void	UnpublishTrack (ConnectionHandle connection_handle, const std::shared_ptr< PublishTrackHandler > &track_handler)
	Unpublish track.
void	FetchTrack (ConnectionHandle connection_handle, std::shared_ptr< FetchTrackHandler > track_handler)
	Fetch track.
void	CancelFetchTrack (ConnectionHandle connection_handle, std::shared_ptr< FetchTrackHandler > track_handler)
	Cancel Fetch track.
uint64_t	RequestTrackStatus (ConnectionHandle connection_handle, const FullTrackName &track_full_name, const messages::SubscribeAttributes &subscribe_attributes)
	Request track status.
virtual void	ResolveTrackStatus (ConnectionHandle connection_handle, uint64_t request_id, uint64_t track_alias, const SubscribeResponse &subscribe_response)
	Accept or reject track status that was received.
Status	GetStatus () const noexcept
	Get the status of the Client.
Base Calbacks
Both client and server implement the same transport base callbacks
virtual void	StatusChanged (Status status)
	Callback notification for status/state change.
virtual void	TrackStatusReceived (ConnectionHandle connection_handle, uint64_t request_id, const FullTrackName &track_full_name, const messages::SubscribeAttributes &subscribe_attributes)
	Callback notification for track status message received.
virtual void	TrackStatusResponseReceived (ConnectionHandle connection_handle, uint64_t request_id, const SubscribeResponse &response)
	Callback notification for track status OK received.

Protected Member Functions
std::shared_ptr< Transport >	GetSharedPtr ()
ConnectionContext &	GetConnectionContext (ConnectionHandle conn)

Server Calbacks
slient transport specific callbacks
using	SubscribeAnnouncesResponse
	Callback notification for new subscribe announces received.
void	NewConnectionAccepted (ConnectionHandle connection_handle, const ConnectionRemoteInfo &remote) override
	Callback notification on new connection.
void	ConnectionStatusChanged (ConnectionHandle connection_handle, ConnectionStatus status) override
	Callback notification for connection status/state change.
void	MetricsSampled (ConnectionHandle connection_handle, const ConnectionMetrics &metrics) override
	Notification callback to provide sampled metrics.
virtual ClientSetupResponse	ClientSetupReceived (ConnectionHandle connection_handle, const ClientSetupAttributes &client_setup_attributes)=0
	Callback on client setup message.
virtual void	AnnounceReceived (ConnectionHandle connection_handle, const TrackNamespace &track_namespace, const PublishAnnounceAttributes &publish_announce_attributes)
	Callback notification for new announce received that needs to be authorized.
void	ResolveAnnounce (ConnectionHandle connection_handle, uint64_t request_id, const TrackNamespace &track_namespace, const std::vector< ConnectionHandle > &subscribers, const AnnounceResponse &announce_response)
	Accept or reject an announce that was received.
virtual std::vector< ConnectionHandle >	UnannounceReceived (ConnectionHandle connection_handle, const TrackNamespace &track_namespace)=0
	Callback notification for unannounce received.
virtual void	UnsubscribeAnnouncesReceived (ConnectionHandle connection_handle, const TrackNamespace &prefix_namespace)=0
	Callback notification for Unsubscribe announces received.
virtual SubscribeAnnouncesResponse	SubscribeAnnouncesReceived (ConnectionHandle connection_handle, const TrackNamespace &prefix_namespace, const PublishAnnounceAttributes &announce_attributes)
virtual void	SubscribeReceived (ConnectionHandle connection_handle, uint64_t request_id, messages::FilterType filter_type, const FullTrackName &track_full_name, const messages::SubscribeAttributes &subscribe_attributes)
	Callback notification for new subscribe received.
virtual void	UnsubscribeReceived (ConnectionHandle connection_handle, uint64_t request_id)=0
	Callback notification on unsubscribe received.
virtual std::optional< messages::Location >	GetLargestAvailable (const FullTrackName &track_name)
	Get the largest available location for the given track, if any.
virtual bool	FetchReceived (ConnectionHandle connection_handle, uint64_t request_id, const FullTrackName &track_full_name, const quicr::messages::FetchAttributes &attributes) override
	Event to run on receiving Fetch request.
virtual bool	OnFetchOk (ConnectionHandle connection_handle, uint64_t request_id, const FullTrackName &track_full_name, const messages::FetchAttributes &attributes)
	Event to run on sending FetchOk.
virtual void	FetchCancelReceived (ConnectionHandle connection_handle, uint64_t request_id)=0
	Callback notification on receiving a FetchCancel message.
virtual void	PublishReceived (ConnectionHandle connection_handle, uint64_t request_id, const FullTrackName &track_full_name, const messages::PublishAttributes &publish_attributes)=0
	Callback notification for new publish received.
virtual void	SubscribeDoneReceived (ConnectionHandle connection_handle, uint64_t request_id)=0
	Callback notification on Subscribe Done received.

Detailed Description

MoQ Server.

MoQ Server is the handler of the MoQ QUIC listening socket

Examples: server.cpp.

Member Typedef Documentation

◆ SubscribeAnnouncesResponse

using quicr::Server::SubscribeAnnouncesResponse

Initial value:

std::pair<std::optional<messages::SubscribeNamespaceErrorCode>, std::vector<TrackNamespace>>

Callback notification for new subscribe announces received.

Note: The caller must return the appropriate SubscribeAnnouncesErrorCode on error. If no error, nullopt is returned for error code and the vector should contain all the matching track namespaces to the prefix. Each of the returned namespaces will be announced to the subscriber.

Parameters

connection_handle	Source connection ID
prefix_namespace	Track namespace
announce_attributes	Announces attributes received

Member Enumeration Documentation

◆ ConnectionStatus

enum class quicr::Transport::ConnectionStatus : uint8_t

stronginherited

Connection status codes.

Enumerator
kNotConnected
kConnecting
kConnected
kIdleTimeout
kClosedByRemote

◆ ControlMessageStatus

enum class quicr::Transport::ControlMessageStatus : uint8_t

stronginherited

Control message status codes.

Enumerator
kMessageIncomplete	control message is incomplete and more data is needed
kMessageComplete	control message is complete and stream buffer get any has complete message
kStreamBufferCannotBeZero	stream buffer cannot be zero when parsing message type
kStreamBufferMissingType	connection context is missing message type
kUnsupportedMessageType	Unsupported MOQT message type.

◆ Status

enum class quicr::Transport::Status : uint8_t

stronginherited

Status of the transport.

Enumerator
kReady
kNotReady
kInternalError
kInvalidParams
kConnecting
kDisconnecting
kNotConnected
kFailedToConnect
kPendingServerSetup

◆ StreamDataMessageStatus

enum class quicr::Transport::StreamDataMessageStatus : uint8_t

stronginherited

Constructor & Destructor Documentation

◆ Server() [1/2]

quicr::Server::Server ( const ServerConfig & cfg )

inline

MoQ Server constructor to create the MOQ server mode instance.

Parameters

cfg	MoQ Server Configuration

◆ Server() [2/2]

quicr::Server::Server	(	const ServerConfig &	cfg,
		std::shared_ptr< ThreadedTickService >	tick_service )

inline

◆ ~Server()

quicr::Server::~Server ( )

default

Member Function Documentation

◆ AnnounceReceived()

virtual void quicr::Server::AnnounceReceived	(	ConnectionHandle	connection_handle,
		const TrackNamespace &	track_namespace,
		const PublishAnnounceAttributes &	publish_announce_attributes )

virtual

Callback notification for new announce received that needs to be authorized.

Note: The caller MUST respond to this via ResolveAnnounce(). If the caller does not override this method, the default will call ResolveAnnounce() with the status of OK

Parameters

connection_handle	Source connection ID
track_namespace	Track namespace
publish_announce_attributes	Publish announce attributes received

Examples: server.cpp.

◆ BindFetchTrack()

void quicr::Server::BindFetchTrack	(	TransportConnId	conn_id,
		std::shared_ptr< PublishFetchHandler >	track_handler )

Bind a server fetch publisher track handler.

Parameters

conn_id	Connection Id of the client/fetcher.
track_handler	The fetch publisher.

Examples: server.cpp.

◆ BindPublisherTrack()

void quicr::Server::BindPublisherTrack	(	ConnectionHandle	connection_handle,
		ConnectionHandle	src_id,
		uint64_t	request_id,
		const std::shared_ptr< PublishTrackHandler > &	track_handler,
		bool	ephemeral = false )

Bind a server publish track handler based on a subscribe.

The server will create a server publish track handler based on a received subscribe. It will use this handler to send objects to subscriber.

Parameters

connection_handle	Connection ID of the client/subscriber
src_id	Connection or peering Id for publisher origin
request_id	Request ID from the received subscribe
track_handler	Server publish track handler
ephemeral	Bool value to indicate if the state tracking is needed

Examples: server.cpp.

◆ CancelFetchTrack()

void quicr::Transport::CancelFetchTrack	(	ConnectionHandle	connection_handle,
		std::shared_ptr< FetchTrackHandler >	track_handler )

inherited

Cancel Fetch track.

Parameters

connection_handle	Connection ID to send fetch cancel.
track_handler	Fetch Track handler to cancel.

◆ ClientSetupReceived()

virtual ClientSetupResponse quicr::Server::ClientSetupReceived	(	ConnectionHandle	connection_handle,
		const ClientSetupAttributes &	client_setup_attributes )

pure virtual

Callback on client setup message.

In server mode, client will send a setup message on new connection. Server responds with server setup.

Parameters

connection_handle	Transport connection ID
client_setup_attributes	Decoded client setup message

Returns: ClientSetupResponse indicating the status of processing the setup message.

Examples: server.cpp.

◆ ConnectionStatusChanged()

void quicr::Server::ConnectionStatusChanged	(	ConnectionHandle	connection_handle,
		ConnectionStatus	status )

overridevirtual

Callback notification for connection status/state change.

Callback notification indicates state change of connection, such as disconnected

Parameters

connection_handle	Transport connection ID
status	ConnectionStatus of connection id

Reimplemented from quicr::Transport.

Examples: server.cpp.

◆ FetchCancelReceived()

virtual void quicr::Server::FetchCancelReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id )

pure virtual

Callback notification on receiving a FetchCancel message.

Parameters

connection_handle	Source connection ID.
request_id	Request ID received.

Examples: server.cpp.

◆ FetchReceived()

virtual bool quicr::Server::FetchReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		const FullTrackName &	track_full_name,
		const quicr::messages::FetchAttributes &	attributes )

overridevirtual

Event to run on receiving Fetch request.

Parameters

connection_handle	Source connection ID.
request_id	Request ID received.
track_full_name	Track full name
attributes	Fetch attributes received.

Returns: True to indicate fetch will send data, False if no data is within the requested range

Reimplemented from quicr::Transport.

Examples: server.cpp.

◆ FetchTrack()

void quicr::Transport::FetchTrack	(	ConnectionHandle	connection_handle,
		std::shared_ptr< FetchTrackHandler >	track_handler )

inherited

Fetch track.

Parameters

connection_handle	Connection ID to send fetch
track_handler	Track handler used for fetching

Examples: server.cpp.

◆ GetConnectionContext()

ConnectionContext & quicr::Transport::GetConnectionContext ( ConnectionHandle conn )

protectedinherited

◆ GetLargestAvailable()

virtual std::optional< messages::Location > quicr::Server::GetLargestAvailable ( const FullTrackName & track_name )

virtual

Get the largest available location for the given track, if any.

Parameters

track_name The track to lookup on.

Returns: The largest available location, if any.

Examples: server.cpp.

◆ GetSharedPtr()

std::shared_ptr< Transport > quicr::Transport::GetSharedPtr ( )

protectedinherited

◆ GetStatus()

Status quicr::Transport::GetStatus ( ) const

inlinenoexceptinherited

Get the status of the Client.

Returns: Status of the Client

◆ GetTickService()

const std::shared_ptr< TickService > & quicr::Transport::GetTickService ( ) const

inlinenoexceptinherited

◆ MetricsSampled()

void quicr::Server::MetricsSampled	(	ConnectionHandle	connection_handle,
		const ConnectionMetrics &	metrics )

overridevirtual

Notification callback to provide sampled metrics.

Callback will be triggered on Config::metrics_sample_ms to provide the sampled data based on the sample period. After this callback, the period/sample based metrics will reset and start over for the new period.

Parameters

connection_handle	Source connection ID
metrics	Copy of the connection metrics for the sample period

Reimplemented from quicr::Transport.

Examples: server.cpp.

◆ NewConnectionAccepted()

void quicr::Server::NewConnectionAccepted	(	ConnectionHandle	connection_handle,
		const ConnectionRemoteInfo &	remote )

overridevirtual

Callback notification on new connection.

Callback notification that a new connection has been accepted

Parameters

connection_handle	Transport connection ID
remote	Transport remote connection information

Reimplemented from quicr::Transport.

Examples: server.cpp.

◆ OnFetchOk()

virtual bool quicr::Server::OnFetchOk	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		const FullTrackName &	track_full_name,
		const messages::FetchAttributes &	attributes )

virtual

Event to run on sending FetchOk.

Parameters

connection_handle	Source connection ID.
request_id	Request ID received.
track_full_name	Track full name
attributes	Fetch attributes received.

Returns: True to indicate fetch will send data, False if no data is within the requested range

Examples: server.cpp.

◆ PublishReceived()

virtual void quicr::Server::PublishReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		const FullTrackName &	track_full_name,
		const messages::PublishAttributes &	publish_attributes )

pure virtual

Callback notification for new publish received.

Note: The caller MUST respond to this via ResolvePublish(). If the caller does not override this method, the default will call ResolvePublish() with the status of OK

Parameters

connection_handle	Source connection ID
request_id	Request ID received
track_full_name	Track full name
publish_attributes	Publish attributes received

Examples: server.cpp.

◆ PublishTrack()

void quicr::Transport::PublishTrack	(	ConnectionHandle	connection_handle,
		std::shared_ptr< PublishTrackHandler >	track_handler )

inherited

Publish to a track.

Parameters

connection_handle	Connection ID from transport for the QUIC connection context
track_handler	Track handler to use for track related functions and callbacks

◆ PublishTrackSub()

void quicr::Transport::PublishTrackSub	(	ConnectionHandle	connection_handle,
		std::shared_ptr< PublishTrackHandler >	track_handler )

inherited

Publish to a track and force subscribe.

Parameters

connection_handle	Connection ID from transport for the QUIC connection context
track_handler	Track handler to use for track related functions and callbacks

◆ RequestTrackStatus()

uint64_t quicr::Transport::RequestTrackStatus	(	ConnectionHandle	connection_handle,
		const FullTrackName &	track_full_name,
		const messages::SubscribeAttributes &	subscribe_attributes )

inherited

Request track status.

Parameters

connection_handle	Source connection ID.
track_full_name	Track full name
subscribe_attributes	Subscribe attributes for track status

Returns
Request ID that is used for the track status request

◆ ResolveAnnounce()

void quicr::Server::ResolveAnnounce	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		const TrackNamespace &	track_namespace,
		const std::vector< ConnectionHandle > &	subscribers,
		const AnnounceResponse &	announce_response )

Accept or reject an announce that was received.

Accept or reject an announce received via AnnounceReceived(). The MoQ Transport will send the protocol message based on the AnnounceResponse. Subscribers defined will be sent a copy of the announcement

Parameters

connection_handle	source connection ID
request_id	Request Id received for the announce request
track_namespace	track namespace
subscribers	Vector/list of subscriber connection handles that should be sent the announce
announce_response	response to for the announcement

Examples: server.cpp.

◆ ResolvePublish()

virtual void quicr::Server::ResolvePublish	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		bool	forward,
		messages::SubscriberPriority	priority,
		messages::GroupOrder	group_order,
		const PublishResponse &	publish_response )

virtual

Accept or reject publish that was received.

Accept or reject publish received via PublishReceived(). The MoQ Transport will send the protocol message based on the SubscribeResponse

Parameters

connection_handle	source connection ID
request_id	Request ID
forward	True indicates to forward data, False to pause forwarding
publish_response	response to for the publish

Examples: server.cpp.

◆ ResolveSubscribe()

virtual void quicr::Server::ResolveSubscribe	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		uint64_t	track_alias,
		const SubscribeResponse &	subscribe_response )

virtual

Accept or reject an subscribe that was received.

Accept or reject an subscribe received via SubscribeReceived(). The MoQ Transport will send the protocol message based on the SubscribeResponse

Parameters

connection_handle	source connection ID
request_id	Request ID
track_alias	Track alias the subscriber should use.
subscribe_response	response to for the subscribe

Examples: server.cpp.

◆ ResolveTrackStatus()

virtual void quicr::Transport::ResolveTrackStatus	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		uint64_t	track_alias,
		const SubscribeResponse &	subscribe_response )

virtualinherited

Accept or reject track status that was received.

Accept or reject track status received via TrackStatusReceived(). The MoQ Transport will send the protocol message based on the SubscribeResponse. Per MOQT draft-14, track status request, ok, and error are the same as subscribe

Parameters

connection_handle	source connection ID
request_id	Request ID that was provided by TrackStatusReceived
track_alias	Track alias for the track
subscribe_response	Response to the track status request, either Ok or Error. Largest loation should be set if kOk and there is content

Examples: server.cpp.

◆ Start()

Status quicr::Server::Start ( )

Starts server transport thread to listen for new connections.

Creates a new transport thread to listen for new connections. All control and track callbacks will be run based on events.

Returns: Status indicating state or error. If successful, status will be READY.

◆ StatusChanged()

virtual void quicr::Transport::StatusChanged ( Status status )

inlinevirtualinherited

Callback notification for status/state change.

Callback notification indicates state change of connection, such as disconnected

Parameters

status Changed Status value

Examples: client.cpp.

◆ Stop()

void quicr::Server::Stop ( )

Stop the server transport

◆ SubscribeAnnouncesReceived()

virtual SubscribeAnnouncesResponse quicr::Server::SubscribeAnnouncesReceived	(	ConnectionHandle	connection_handle,
		const TrackNamespace &	prefix_namespace,
		const PublishAnnounceAttributes &	announce_attributes )

virtual

Examples: server.cpp.

◆ SubscribeDoneReceived()

virtual void quicr::Server::SubscribeDoneReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id )

pure virtual

Callback notification on Subscribe Done received.

Parameters

connection_handle	Source connection ID
request_id	Request ID received

Examples: server.cpp.

◆ SubscribeReceived()

virtual void quicr::Server::SubscribeReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		messages::FilterType	filter_type,
		const FullTrackName &	track_full_name,
		const messages::SubscribeAttributes &	subscribe_attributes )

virtual

Callback notification for new subscribe received.

Note: The caller MUST respond to this via ResolveSubscribe(). If the caller does not override this method, the default will call ResolveSubscribe() with the status of OK

Parameters

connection_handle	Source connection ID
request_id	Request ID received
filter_type	Filter type received
track_full_name	Track full name
subscribe_attributes	Subscribe attributes received

Examples: server.cpp.

◆ SubscribeTrack()

void quicr::Transport::SubscribeTrack	(	ConnectionHandle	connection_handle,
		std::shared_ptr< SubscribeTrackHandler >	track_handler )

inherited

Subscribe to a track.

Parameters

connection_handle	Connection ID to send subscribe
track_handler	Track handler to use for track related functions and callbacks

Examples: server.cpp.

◆ TrackStatusReceived()

virtual void quicr::Transport::TrackStatusReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		const FullTrackName &	track_full_name,
		const messages::SubscribeAttributes &	subscribe_attributes )

virtualinherited

Callback notification for track status message received.

Note: The caller MUST respond to this via ResolveTrackStatus(). If the caller does not override this method, the default will call ResolveTrackStatus() with the status of OK

Parameters

connection_handle	Source connection ID
request_id	Request ID received
track_full_name	Track full name
subscribe_attributes	Subscribe attributes received

Examples: server.cpp.

◆ TrackStatusResponseReceived()

virtual void quicr::Transport::TrackStatusResponseReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id,
		const SubscribeResponse &	response )

virtualinherited

Callback notification for track status OK received.

Note: The caller is able to state track the OK based on the request Id returned from RequestTrackStatus method call

Parameters

connection_handle	Source connection ID
request_id	Request ID received
response	Track status (track_status = Subscribe) response

Examples: client.cpp.

◆ UnannounceReceived()

virtual std::vector< ConnectionHandle > quicr::Server::UnannounceReceived	(	ConnectionHandle	connection_handle,
		const TrackNamespace &	track_namespace )

pure virtual

Callback notification for unannounce received.

The callback will indicate that a new unannounce has been received. The app should return a vector of connection handler ids that should receive a copy of the unannounce. The returned list is based on subscribe announces prefix matching.

Parameters

connection_handle	Source connection ID
track_namespace	Track namespace

Returns: vector of subscribe announces connection handler ids matching prefix to the namespace being unannounced.

Examples: server.cpp.

◆ UnbindFetchTrack()

void quicr::Server::UnbindFetchTrack	(	ConnectionHandle	conn_id,
		const std::shared_ptr< PublishFetchHandler > &	track_handler )

Unbind a server fetch publisher track handler.

Parameters

conn_id	Connection ID of the client/fetcher.
track_handler	The fetch publisher.

Examples: server.cpp.

◆ UnbindPublisherTrack()

void quicr::Server::UnbindPublisherTrack	(	ConnectionHandle	connection_handle,
		ConnectionHandle	src_id,
		const std::shared_ptr< PublishTrackHandler > &	track_handler )

Unbind a server publish track handler.

Removes a server publish track handler state.

Parameters

connection_handle	Connection ID of the client/subscriber
src_id	Connect or peering Id of the receiving publisher
track_handler	Server publish track handler

◆ UnpublishTrack()

void quicr::Transport::UnpublishTrack	(	ConnectionHandle	connection_handle,
		const std::shared_ptr< PublishTrackHandler > &	track_handler )

inherited

Unpublish track.

Parameters

connection_handle	Connection ID from transport for the QUIC connection context
track_handler	Track handler used when published track

◆ UnsubscribeAnnouncesReceived()

virtual void quicr::Server::UnsubscribeAnnouncesReceived	(	ConnectionHandle	connection_handle,
		const TrackNamespace &	prefix_namespace )

pure virtual

Callback notification for Unsubscribe announces received.

Parameters

connection_handle	Source connection ID
prefix_namespace	Prefix namespace

Examples: server.cpp.

◆ UnsubscribeReceived()

virtual void quicr::Server::UnsubscribeReceived	(	ConnectionHandle	connection_handle,
		uint64_t	request_id )

pure virtual

Callback notification on unsubscribe received.

Parameters

connection_handle	Source connection ID
request_id	Request ID received

Examples: server.cpp.

◆ UnsubscribeTrack()

void quicr::Transport::UnsubscribeTrack	(	ConnectionHandle	connection_handle,
		const std::shared_ptr< SubscribeTrackHandler > &	track_handler )

inherited

Unsubscribe track.

Parameters

connection_handle	Connection ID to send subscribe
track_handler	Track handler to use for track related functions and callbacks

Examples: server.cpp.

◆ UpdateTrackSubscription()

void quicr::Transport::UpdateTrackSubscription	(	ConnectionHandle	connection_handle,
		std::shared_ptr< SubscribeTrackHandler >	track_handler,
		bool	new_group_request = false )

inherited

Update Subscription to a track.

Parameters

connection_handle	Connection ID to send subscribe
track_handler	Track handler to use for track related functions and callbacks
new_group_request	True to add new group request parameter

Examples: server.cpp.

The documentation for this class was generated from the following file:

include/quicr/server.h

Classes

Public Types

Public Member Functions

Protected Member Functions

Server Calbacks

Detailed Description

Member Typedef Documentation

◆ SubscribeAnnouncesResponse

Member Enumeration Documentation

◆ ConnectionStatus

◆ ControlMessageStatus

◆ Status

◆ StreamDataMessageStatus

Constructor & Destructor Documentation

◆ Server() [1/2]

◆ Server() [2/2]

◆ ~Server()

Member Function Documentation

◆ AnnounceReceived()

◆ BindFetchTrack()

◆ BindPublisherTrack()

◆ CancelFetchTrack()

◆ ClientSetupReceived()

◆ ConnectionStatusChanged()

◆ FetchCancelReceived()

◆ FetchReceived()

◆ FetchTrack()

◆ GetConnectionContext()

◆ GetLargestAvailable()

◆ GetSharedPtr()

◆ GetStatus()

◆ GetTickService()

◆ MetricsSampled()

◆ NewConnectionAccepted()

◆ OnFetchOk()

◆ PublishReceived()

◆ PublishTrack()

◆ PublishTrackSub()

◆ RequestTrackStatus()

◆ ResolveAnnounce()

◆ ResolvePublish()

◆ ResolveSubscribe()

◆ ResolveTrackStatus()

◆ Start()

◆ StatusChanged()

◆ Stop()

◆ SubscribeAnnouncesReceived()

◆ SubscribeDoneReceived()

◆ SubscribeReceived()

◆ SubscribeTrack()

◆ TrackStatusReceived()

◆ TrackStatusResponseReceived()

◆ UnannounceReceived()

◆ UnbindFetchTrack()

◆ UnbindPublisherTrack()

◆ UnpublishTrack()

◆ UnsubscribeAnnouncesReceived()

◆ UnsubscribeReceived()

◆ UnsubscribeTrack()

◆ UpdateTrackSubscription()