Struct veloren_network_protocol::prio::PrioManager

pub(crate) struct PrioManager {
    streams: HashMap<Sid, StreamInfo>,
    metrics: ProtocolMetricCache,
}

Responsible for queueing messages. every stream has a guaranteed bandwidth and a prio 0-7. when n Bytes are available in the buffer, first the guaranteed bandwidth is used. Then remaining bandwidth is used to fill up the prios.

Fields

streams: HashMap<Sid, StreamInfo>

metrics: ProtocolMetricCache

Implementations

impl PrioManager

pub fn new(metrics: ProtocolMetricCache) -> Self

pub fn open_stream( &mut self, sid: Sid, prio: Prio, promises: Promises, guaranteed_bandwidth: Bandwidth, )

pub fn try_close_stream(&mut self, sid: Sid) -> bool

pub fn is_empty(&self) -> bool

pub fn add(&mut self, buffer: Bytes, mid: u64, sid: Sid)

pub fn grab( &mut self, bandwidth: Bandwidth, dt: Duration, ) -> (Vec<(Sid, OTFrame)>, Bandwidth)

bandwidth might be extended, as for technical reasons guaranteed_bandwidth is used and frames are always 1400 bytes.

Trait Implementations

impl Debug for PrioManager

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

Formats the value using the given formatter.