Files
@ 75e767adaaf7
Branch filter:
Location: CSY/reowolf/src/runtime2/communication.rs - annotation
75e767adaaf7
585 B
application/rls-services+xml
Add a new RawArray implementation
Needed to implement ringbuffer queues in a neat way. Will deprecate the
old RawVec implementation
Needed to implement ringbuffer queues in a neat way. Will deprecate the
old RawVec implementation
0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 0e1a76667937 | use super::runtime::*;
#[derive(Copy, Clone)]
pub struct PortId(pub u32);
impl PortId {
pub fn new_invalid() -> Self {
return Self(u32::MAX);
}
}
pub struct Peer {
pub id: CompId,
pub(crate) handle: CompHandle,
}
pub enum PortKind {
Putter,
Getter,
}
pub enum PortState {
Open,
Closed,
}
pub struct Port {
pub self_id: PortId,
pub peer_id: PortId,
pub kind: PortKind,
pub state: PortState,
pub local_peer_index: u32,
}
/// Public inbox: accessible by all threads. Essentially a MPSC channel
pub struct InboxPublic {
}
|