diff --git a/src/runtime/actors.rs b/src/runtime/actors.rs index 0f8cd88f76b65de172c197a066c6308719cd6230..c86044f404990f03c55c5a2ed2b9f47aa472c1ee 100644 --- a/src/runtime/actors.rs +++ b/src/runtime/actors.rs @@ -3,37 +3,37 @@ use crate::runtime::{endpoint::*, *}; #[derive(Debug, Clone)] pub(crate) struct MonoN { - pub ports: HashSet, - pub result: Option<(usize, HashMap)>, + pub ports: HashSet, + pub result: Option<(usize, HashMap)>, } #[derive(Debug)] pub(crate) struct PolyN { - pub ports: HashSet, + pub ports: HashSet, pub branches: HashMap, } #[derive(Debug, Clone)] pub(crate) struct BranchN { - pub to_get: HashSet, - pub gotten: HashMap, + pub to_get: HashSet, + pub gotten: HashMap, pub sync_batch_index: usize, } #[derive(Debug, Clone)] pub struct MonoP { pub state: ProtocolS, - pub ports: HashSet, + pub ports: HashSet, } #[derive(Debug)] pub(crate) struct PolyP { pub incomplete: HashMap, pub complete: HashMap, - pub ports: HashSet, + pub ports: HashSet, } #[derive(Debug, Clone)] pub(crate) struct BranchP { - pub blocking_on: Option, - pub outbox: HashMap, - pub inbox: HashMap, + pub blocking_on: Option, + pub outbox: HashMap, + pub inbox: HashMap, pub state: ProtocolS, } @@ -211,7 +211,7 @@ impl PolyP { &mut self, m_ctx: PolyPContext, protocol_description: &ProtocolD, - port: Port, + port: PortId, payload_predicate: Predicate, payload: Payload, ) -> Result { @@ -366,7 +366,7 @@ impl PolyP { impl PolyN { pub fn sync_recv( &mut self, - port: Port, + port: PortId, logger: &mut String, payload: Payload, payload_predicate: Predicate,