Struct PacketProcessor 

pub(super) struct PacketProcessor {
    queued: PacketQueue<PlayerPacketLaneKey, PendingPlayPacket>,
}

Gameplay packets submitted by network tasks.

The processor runs while the game tick is idle. At each tick boundary it drains every packet submitted before that boundary, while retaining later submissions for the next packet phase. A player-replacement transition temporarily withdraws that session’s queued packets from the runnable global order and re-admits them in session FIFO order after the replacement is bound.

Fields

queued: PacketQueue<PlayerPacketLaneKey, PendingPlayPacket>

Implementations

impl PacketProcessor

pub(super) fn new() -> Self

pub(super) fn schedule( &self, player: Arc<Player>, packet: ScheduledPlayPacket, payload_bytes: usize, )

pub(super) fn run(&self, server: &Arc<Server>)

Runs the blocking packet worker until the processor is stopped.

pub(super) fn pause_player_session( &self, session: &PlayerSession, ) -> Option<PlayerPacketTransition>

Suspends one connection’s FIFO lane while its player entity is replaced.

pub(super) fn resume_player_session( &self, transition: PlayerPacketTransition, ) -> bool

Re-admits packets retained during player replacement into the runnable global order.

pub(super) fn discard_player_session(&self, session: &PlayerSession)

Drops all retained packets for a connection that can no longer own a player.

fn packet_is_runnable( player: &Player, packet: &ScheduledPlayPacket, server_cancelled: bool, ) -> bool

pub(super) fn open_after_tick(&self)

Opens the inter-tick packet phase and wakes the worker.

pub(super) async fn wait_for_overload_progress(&self)

Guarantees packet progress when a late tick leaves no normal inter-tick window.

pub(super) async fn close_for_tick(&self)

Drains packets submitted before this tick boundary, then closes packet admission.

pub(super) fn stop(&self)

Stops the packet worker and discards queued work during server shutdown.

Trait Implementations

impl Default for PacketProcessor

fn default() -> Self

Returns the “default value” for a type.