Struct RoomTopology 

pub struct RoomTopology {
    instance: RoomInstanceId,
    sources: PublishedSources,
    route_graph: RouteGraph,
    router: Router,
    next_producer_id: u64,
    video_allocation_revision: u64,
}

Keeps source records and route realization beside Router so transport effects resolve from the same committed placement.

Transport-facing mutations return resolved work for execution after the room state lock is released.

Fields

instance: RoomInstanceId

sources: PublishedSources

route_graph: RouteGraph

router: Router

next_producer_id: u64

video_allocation_revision: u64

Implementations

impl RoomTopology

pub fn new( runtime_context: &RoomRuntimeContext, router_rtp_capabilities: MediaCapabilities, pending_target_limit: usize, ) -> Self

pub(in engine::room) const fn video_allocation_revision( &self, ) -> u64

fn invalidate_video_allocation(&mut self)

pub(in engine::room) fn router( &self, ) -> &Router

pub fn committed_transport_user_key( &self, user_id: impl Into<Arc<UserId>>, connection_id: ConnectionId, ) -> Option<TransportSessionKey>

Returns None unless the exact user connection remains committed.

pub fn transport_user_key( &self, user_id: impl Into<Arc<UserId>>, connection_id: ConnectionId, ) -> TransportSessionKey

Requires the exact user connection to remain committed.

Use Self::committed_transport_user_key for stale callbacks or teardown races where the placement may already be retired.

Panics

Panics when no committed router placement exists.

fn transport_session_key( &self, user_id: Arc<UserId>, connection_id: ConnectionId, media_worker_id: MediaWorkerId, ) -> TransportSessionKey

pub fn retire_committed_placement( &mut self, user_id: &UserId, connection_id: ConnectionId, ) -> Option<TransportSessionKey>

Returns None when connection_id is not the user’s committed placement.

pub fn media_counts(&self) -> RoomMediaCounts

Counts each logical subscription once while pending or committed.

pub(in engine::room) fn consumer_count( &self, ) -> usize

Counts committed consumers, including inactive selections.

pub(in engine::room) fn source_descriptor( &self, source_id: PublishedSourceId, ) -> Option<&PublishedSourceDescriptor>

pub(in engine::room) fn source_for_transport_media( &self, transport_media_id: TransportMediaId, ) -> Option<&PublishedSource>

pub(in engine::room) fn source_id_for_owner_stream( &self, owner_user_id: &UserId, stream_id: &UserStreamId, ) -> Option<PublishedSourceId>

pub(in engine::room) fn published_source_id( &self, owner: &UserId, connection: ConnectionId, stream_id: &UserStreamId, ) -> Option<PublishedSourceId>

Returns the source ID only when owner, connection and stream remain current.

pub(in engine::room) fn published_sources( &self, ) -> impl Iterator<Item = &PublishedSource>

Iterates committed sources in source-ID order.

pub(in engine::room) fn active_stream_user_counts( &self, ) -> BTreeMap<UserStreamId, u64>

Counts distinct users with active publications for each logical stream.

pub(in engine::room) fn active_speaker_detector_owner( &self, transport_media_id: TransportMediaId, ) -> Option<UserId>

Returns a detector owner with an active promotable source in the same group.

pub(in engine::room) fn committed_consumer_routes( &self, ) -> impl Iterator<Item = ConsumerRouteView<'_>>

pub(in engine::room) fn committed_consumer_routes_for_user( &self, user_id: &UserId, ) -> impl Iterator<Item = ConsumerRouteView<'_>>

pub(super) fn detach_declined_consumers( &mut self, session: &TransportSessionKey, declined: &[TransportMediaId], ) -> (Vec<TransportRelayRouteEffect>, Vec<TransportTeardown>, bool)

pub(in engine::room) fn pending_consumer_routes_for_user( &self, user_id: &UserId, ) -> impl Iterator<Item = PendingConsumerRouteView<'_>>

pub(in engine::room) fn consumer_source_selection( &self, key: &SubscriptionKey, source_id: PublishedSourceId, ) -> Option<ConsumerSourceSelection>

Returns None when the attached source differs from source_id.

pub(in engine::room) fn subscription_intent( &self, key: &SubscriptionKey, ) -> SourceSubscriptionIntent

Returns merged receiver intent or the default for a missing subscription.

pub(in engine::room) fn committed_consumer_user_ids_for_source( &self, source_id: PublishedSourceId, ) -> BTreeSet<UserId>

pub(in engine::room) fn committed_consumer_user_ids_for_owner_sources( &self, user_id: &UserId, ) -> BTreeSet<UserId>

pub(in engine::room) fn committed_consumer_route_for_key( &self, key: &SubscriptionKey, ) -> Option<ConsumerRouteView<'_>>

pub(in engine::room) fn published_source( &self, source_id: PublishedSourceId, ) -> Option<&PublishedSource>

pub(super) fn missing_consumer_targets_for_source<'a>( &mut self, source_id: PublishedSourceId, receivers: impl IntoIterator<Item = (&'a UserId, ConnectionId)>, ) -> Vec<ConsumerSetupTarget>

Attaches source_id to each eligible receiver lacking a route realization.

fn consumer_target( &mut self, user_id: &UserId, connection_id: ConnectionId, source_id: PublishedSourceId, ) -> Option<ConsumerSetupTarget>

fn attach_consumer_target( route_graph: &mut RouteGraph, consumer_session: &TransportSessionKey, source: &PublishedSource, ) -> Option<ConsumerSetupTarget>

Skips self-consumption and attaches only an absent realization.

pub(super) fn missing_consumer_targets( &mut self, user_id: &UserId, connection_id: ConnectionId, include_source: impl Fn(&PublishedSource) -> bool, ) -> Vec<ConsumerSetupTarget>

Attaches each matching source with no realization to the exact committed receiver.

Returns an empty list when connection_id is stale.

pub fn update_consumer_source_selection( &mut self, key: &SubscriptionKey, source_id: PublishedSourceId, route: &TransportConsumerRoute, update: impl FnOnce(&mut ConsumerSourceSelection), ) -> bool

Updates selection while subscription, source and exact route still match.

Returns false when async transport work refers to a displaced route.

pub(in engine::room) fn update_consumer_upgrade( &mut self, key: &SubscriptionKey, source_id: PublishedSourceId, route: &TransportConsumerRoute, pending_upgrade: Option<PendingUpgrade>, ) -> bool

Commits a hold only for the active source, subscription and exact route.

fn detach_user_sources( &mut self, user_id: &UserId, ) -> (Vec<TransportSourceKey>, RemovedRoutes)

fn remove_source( &mut self, source_id: PublishedSourceId, ) -> Option<(PublishedSource, RemovedRoutes)>

fn consumer_route<'a>( &'a self, key: &'a SubscriptionKey, current: &'a CurrentPublication, ) -> Option<ConsumerRouteView<'a>>

pub(in engine::room) fn commit_publication( &mut self, publish: ValidatedPublish, rtp: RouterRtpParameters, encodings: &[SessionUploadEncoding], media: TransportMediaId, ) -> Result<PublishedSourceId, PublicationCommitError>

Commits a negotiated source only after its router producer succeeds.

Errors

Returns PublicationCommitError::Source when descriptor allocation or validation fails. Returns PublicationCommitError::Router when the router rejects the producer dependency.

fn media_teardowns( sources: impl IntoIterator<Item = TransportSourceKey>, routes: impl IntoIterator<Item = TransportConsumerRoute>, ) -> impl Iterator<Item = TransportTeardown>

pub fn set_published_source_activity( &mut self, source_id: PublishedSourceId, connection_id: ConnectionId, active: bool, ) -> Option<SourceActivityRevision>

Advances the revision only when the exact source connection changes activity.

Returns None when the source is missing, the connection is stale or the requested activity already matches.

pub(super) fn source_activity_effects( &self, source: &TransportSourceKey, update: SourceActivityUpdate, ) -> Vec<TransportSourceActivityEffect>

pub fn commit_session_placement( &mut self, user_id: &UserId, connection_id: ConnectionId, previous_connection: Option<ConnectionId>, home_placement: RouterPlacement, ) -> Result<SessionPlacementCommit, SessionPlacementRejection>

Commits the new placement before returning cleanup for previous_connection.

Replacement joins must pass the currently committed previous_connection.

Errors

Returns SessionPlacementRejection::MissingPreviousSession when the expected replacement target is no longer committed. Returns SessionPlacementRejection::Router when the router rejects the new connection or placement.

pub fn remove_session(&mut self, user_id: &UserId) -> (RoomTransportPlan, usize)

Returns the cleanup plan even if router removal fails.

pub(super) fn commit_consumer_setup( &mut self, setup: DeclaredConsumerSetup, selection: ConsumerSourceSelection, ) -> Result<CommittedConsumerSetup, (TransportConsumerRoute, Vec<TransportRelayRouteEffect>)>

Selects MID from the transport declaration, negotiated RTP MID then the consumer identity.

Errors

Returns the declared route and relay release effects when the reservation is stale or the router rejects the consumer dependency.

pub(super) fn reserve_consumer_setup( &mut self, target: ConsumerSetupTarget, consumer: ConsumerId, selection: ConsumerSourceSelection, sender: UserOutboundSender, rtp: RouterRtpParameters, ) -> Option<PendingConsumerSetup>

Returns None unless the route realization remains absent.

A cross-worker reservation also claims relay ownership.

pub(super) fn release_consumer_setup( &mut self, setup: PendingConsumerSetup, ) -> Vec<TransportRelayRouteEffect>

A stale reservation releases no relay ownership.

pub(in engine::room) fn apply_subscription_intent( &mut self, key: &SubscriptionKey, connection_id: ConnectionId, intent: SourceSubscriptionIntent, receiver_deafened: bool, publisher_present: bool, ) -> ConsumerActivityCommit

Merges sparse intent before projecting activity to an attached route.

Empty updates have no effect. Intent survives absent publications and unready receivers. Returns no activity work for layout-only updates, missing sources, changed attachments or displaced consumer connections.

Trait Implementations

impl Debug for RoomTopology

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.