Struct ChunkSchedulingCoordinator 

pub(crate) struct ChunkSchedulingCoordinator {
    pending_ticket_operations: SyncMutex<PendingChunkTicketOperations>,
    state: SyncMutex<ChunkSchedulingState>,
    committed_revision: AtomicU64,
}

Owns the short ticket-ingress lock and the non-blocking epoch handoff. The propagation manager moves between epochs instead of being cloned or locked by gameplay.

Fields

pending_ticket_operations: SyncMutex<PendingChunkTicketOperations>

state: SyncMutex<ChunkSchedulingState>

committed_revision: AtomicU64

Implementations

impl ChunkSchedulingCoordinator

pub fn new(ticket_manager: ChunkTicketManager) -> Self

pub fn queue_ticket_operation( &self, operation: ChunkTicketOperation, ) -> ChunkTicketRevision

pub fn queue_ticket_operations( &self, operations: impl IntoIterator<Item = ChunkTicketOperation>, ) -> Option<ChunkTicketRevision>

pub fn apply_pending_ticket_operations( &self, ticket_manager: &mut ChunkTicketManager, applied_revision: ChunkTicketRevision, ) -> ChunkTicketRevision

pub fn take_boundary_step(&self) -> ChunkSchedulingBoundaryStep

pub fn finish_epoch(&self, epoch: PreparedChunkSchedulingEpoch)

pub fn publish_committed_revision(&self, revision: ChunkTicketRevision)

pub fn is_revision_committed(&self, revision: ChunkTicketRevision) -> bool