portus 0.9.0

A Congestion Control Plane
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use super::{AsRawMsg, HDR_LENGTH, RawMsg};
use crate::Result;
use std::io::prelude::*;

#[derive(Clone, Debug, PartialEq)]
pub struct Msg(pub String);

impl AsRawMsg for Msg {
    fn get_hdr(&self) -> (u8, u32, u32) {
        (0xff, HDR_LENGTH + self.0.len() as u32, 0)
    }

    fn get_bytes<W: Write>(&self, w: &mut W) -> Result<()> {
        w.write_all(self.0.clone().as_bytes())?;
        Ok(())
    }

    fn from_raw_msg(msg: RawMsg) -> Result<Self> {
        let b = msg.get_bytes()?;
        let s = std::str::from_utf8(b)?;
        let st = String::from(s);
        Ok(Msg(st))
    }
}