75 lines
2 KiB
Rust
75 lines
2 KiB
Rust
//!
|
|
|
|
use {
|
|
super::{message::Message, protocol::Protocol},
|
|
crossbeam_queue::{ArrayQueue, SegQueue},
|
|
};
|
|
pub enum BufferTypes {
|
|
Unbound(SegQueue<Message>),
|
|
Bound(ArrayQueue<Message>),
|
|
}
|
|
/// Interproccess buffer
|
|
pub struct IpcBuffer<'a> {
|
|
pub protocol: Protocol<'a>,
|
|
pub buffer: BufferTypes,
|
|
}
|
|
|
|
impl<'a> IpcBuffer<'a> {
|
|
pub fn new(bounded: bool, length: u64) -> Self {
|
|
log::debug!(
|
|
"New IPCBuffer\r
|
|
bounded: {}\r
|
|
length: {:?}\r",
|
|
bounded,
|
|
length
|
|
);
|
|
match (bounded, length) {
|
|
(false, ..) => {
|
|
let buftype = BufferTypes::Unbound(SegQueue::new());
|
|
|
|
Self {
|
|
protocol: Protocol::void(),
|
|
buffer: buftype,
|
|
}
|
|
}
|
|
(true, length) => {
|
|
let buftype = BufferTypes::Bound(ArrayQueue::new(length as usize));
|
|
Self {
|
|
protocol: Protocol::void(),
|
|
buffer: buftype,
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Validate a message to match the `IPC.protocol`
|
|
pub fn validate_messages(&mut self) -> Result<(), IpcError> {
|
|
Ok(())
|
|
}
|
|
pub fn push(&mut self, msg: Message) {
|
|
match &self.buffer {
|
|
BufferTypes::Unbound(buff) => buff.push(msg),
|
|
BufferTypes::Bound(buff) => {
|
|
let _ = buff.push(msg);
|
|
}
|
|
};
|
|
}
|
|
pub fn pop(&mut self) -> Result<Message, IpcError> {
|
|
let msg = match &self.buffer {
|
|
BufferTypes::Unbound(buff) => buff.pop(),
|
|
BufferTypes::Bound(buff) => buff.pop(),
|
|
};
|
|
match msg {
|
|
Some(msg) => return Ok(msg),
|
|
None => return Err(IpcError::NoMessagesInBuffer),
|
|
}
|
|
}
|
|
}
|
|
/// Interprocess Communication Errors
|
|
#[derive(Debug)]
|
|
pub enum IpcError {
|
|
/// An invalid message error returned to the sender
|
|
InvalidMessage,
|
|
NoMessagesInBuffer,
|
|
}
|