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.

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.

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.