mirror of
https://github.com/griffi-gh/kubi.git
synced 2024-11-14 11:28:42 -06:00
serializable trait
This commit is contained in:
parent
b44e08e954
commit
c8ff99e98c
|
@ -2,6 +2,7 @@ pub mod client;
|
||||||
pub mod server;
|
pub mod server;
|
||||||
pub(crate) mod packet;
|
pub(crate) mod packet;
|
||||||
pub(crate) mod common;
|
pub(crate) mod common;
|
||||||
|
pub(crate) mod serializable;
|
||||||
pub use common::ClientId;
|
pub use common::ClientId;
|
||||||
|
|
||||||
//pub(crate) trait Serializable: bincode::Encode + bincode::Decode {}
|
//pub(crate) trait Serializable: bincode::Encode + bincode::Decode {}
|
||||||
|
|
22
kubi-udp/src/serializable.rs
Normal file
22
kubi-udp/src/serializable.rs
Normal file
|
@ -0,0 +1,22 @@
|
||||||
|
use anyhow::Result;
|
||||||
|
use crate::BINCODE_CONFIG;
|
||||||
|
|
||||||
|
pub trait Serializable: bincode::Encode + bincode::Decode {
|
||||||
|
fn serialize(&self, buf: &mut [u8]) -> Result<()>;
|
||||||
|
fn deserialize(buf: &[u8]) -> Result<Self>;
|
||||||
|
|
||||||
|
fn serialize_to_vec(&self) -> Result<Vec<u8>> {
|
||||||
|
let mut buf = Vec::new();
|
||||||
|
self.serialize(&mut buf)?;
|
||||||
|
Ok(buf)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
impl<T: bincode::Encode + bincode::Decode> Serializable for T {
|
||||||
|
fn serialize(&self, buf: &mut [u8]) -> Result<()> {
|
||||||
|
bincode::encode_into_slice(self, buf, BINCODE_CONFIG)?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
fn deserialize(buf: &[u8]) -> Result<Self> {
|
||||||
|
bincode::decode_from_slice(buf, BINCODE_CONFIG)?.0
|
||||||
|
}
|
||||||
|
}
|
|
@ -39,7 +39,7 @@ impl Server {
|
||||||
clients: HashMap::with_capacity_and_hasher(MAX_CLIENTS, BuildNoHashHasher::default())
|
clients: HashMap::with_capacity_and_hasher(MAX_CLIENTS, BuildNoHashHasher::default())
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
fn connect_client(&mut self, addr: SocketAddr) -> Result<ClientId> {
|
fn add_client(&mut self, addr: SocketAddr) -> Result<ClientId> {
|
||||||
let Some(id) = (1..=self.config.max_clients)
|
let Some(id) = (1..=self.config.max_clients)
|
||||||
.map(|x| ClientId::new(x as _).unwrap())
|
.map(|x| ClientId::new(x as _).unwrap())
|
||||||
.find(|i| self.clients.contains_key(i)) else {
|
.find(|i| self.clients.contains_key(i)) else {
|
||||||
|
|
Loading…
Reference in a new issue