CSY/reowolf Changeset - 0fb83f27a238 · Centrum Wiskunde & Informatica (CWI)

Changeset - 0fb83f27a238

Parent rev.

Child rev.

[Not reviewed]

0 6 0

Christopher Esterhuyse - 5 years ago 2020-02-05 18:07:44
christopheresterhuyse@gmail.com

fixed natives sometimes choosing incomplete branches as solutions

6 files changed with 31 insertions and 20 deletions:

src/protocol/mod.rs

src/runtime/actors.rs

src/runtime/connector.rs

src/runtime/mod.rs

src/runtime/setup.rs

src/test/setup.rs

0 comments (0 inline, 0 general)

src/protocol/mod.rs

➞

Show inline comments

@@ @@ -15,7 +15,7 @@ use std::hint::unreachable_unchecked; @@
 pub struct ProtocolDescriptionImpl {
     heap: Heap,
     source: InputSource,
     root: RootId
+    root: RootId,
+}
 impl std::fmt::Debug for ProtocolDescriptionImpl {
@@ @@ -86,15 +86,13 @@ impl ProtocolDescription for ProtocolDescriptionImpl { @@
         for (&x, y) in ports.iter().zip(self.component_polarities(identifier).unwrap()) {
             match y {
                 Polarity::Getter => args.push(Value::Input(InputValue(x))),
                 Polarity::Putter => args.push(Value::Output(OutputValue(x)))
+                Polarity::Putter => args.push(Value::Output(OutputValue(x))),
+            }
+        }
         let h = &self.heap;
         let root = &h[self.root];
         let def = root.get_definition_ident(h, identifier).unwrap();
         ComponentStateImpl {
             prompt: Prompt::new(h, def, &args)
+        }
         ComponentStateImpl { prompt: Prompt::new(h, def, &args) }
+    }
+}

src/runtime/actors.rs

➞

Show inline comments

@@ @@ -384,7 +384,11 @@ impl PolyN { @@
         decision: &Predicate,
         table_row: &mut HashMap<Key, Payload>,
     ) -> MonoN {
         if let Some((_, branch)) = self.branches.drain().find(|(p, _)| decision.satisfies(p)) {
         if let Some((_, branch)) = self
             .branches
             .drain()
             .find(|(p, branch)| branch.to_get.is_empty() && decision.satisfies(p))
+        {
             let BranchN { gotten, sync_batch_index, .. } = branch;
             for (&key, payload) in gotten.iter() {
                 assert!(table_row.insert(key, payload.clone()).is_none());

src/runtime/connector.rs

➞

Show inline comments

@@ @@ -35,6 +35,7 @@ impl Connector { @@
             protocol_description,
             bindings: Default::default(),
             polarities,
             main_component: main_component.to_vec(),
         };
         *self = Connector::Configured(configured);
         Ok(())
@@ @@ -69,16 +70,22 @@ impl Connector { @@
         };
         // 1. Unwrap bindings or err
         let bound_proto_interface: Vec<(_, _)> = configured
-            .proto_maybe_bindings
+            .polarities
             .iter()
             .copied()
             .enumerate()
             .map(|(native_index, (polarity, maybe_binding))| {
                 Ok((maybe_binding.ok_or(PortNotBound { native_index })?, polarity))
             .map(|(native_index, polarity)| {
                 let binding = configured
                     .bindings
                     .get(&native_index)
                     .copied()
                     .ok_or(PortNotBound { native_index })?;
                 Ok((binding, polarity))
             })
             .collect::<Result<Vec<(_, _)>, ConnectErr>>()?;
         let (controller, native_interface) = Controller::connect(
             configured.controller_id,
             &configured.main_component,
             configured.protocol_description.clone(),
             &bound_proto_interface[..],
             deadline,

src/runtime/mod.rs

➞

Show inline comments

@@ @@ -54,6 +54,7 @@ pub struct Configured { @@
     polarities: Vec<Polarity>,
     bindings: HashMap<usize, PortBinding>,
     protocol_description: Arc<ProtocolD>,
     main_component: Vec<u8>,
+}
 #[derive(Debug)]
 pub struct Connected {

src/runtime/setup.rs

➞

Show inline comments

@@ @@ -20,6 +20,7 @@ impl Controller { @@
     // Given port bindings and a protocol config, create a connector with 1 native node
     pub fn connect(
         major: ControllerId,
         main_component: &[u8],
         protocol_description: Arc<ProtocolD>,
         bound_proto_interface: &[(PortBinding, Polarity)],
         deadline: Instant,
@@ @@ -101,7 +102,7 @@ impl Controller { @@
         let n_mono = Some(MonoN { ekeys: ekeys_native.into_iter().collect(), result: None });
         let p_monos = vec![MonoP {
             state: protocol_description.new_main_component(&ekeys_proto),
+            state: protocol_description.new_main_component(main_component, &ekeys_proto),
             ekeys: ekeys_proto.into_iter().collect(),
         }];

src/test/setup.rs

➞

Show inline comments

@@ @@ -9,7 +9,7 @@ use super::*; @@
 fn config_ok_0() {
     let pdl = b"primitive main() {}";
     let d = ProtocolD::parse(pdl).unwrap();
-    let pol = d.main_interface_polarities();
+    let pol = d.component_polarities(b"main").unwrap();
     assert_eq!(&pol[..], &[]);
+}
@@ @@ -17,8 +17,8 @@ fn config_ok_0() { @@
 fn config_ok_2() {
     let pdl = b"primitive main(in x, out y) {}";
     let d = ProtocolD::parse(pdl).unwrap();
     let pol = d.main_interface_polarities();
     assert_eq!(&pol[..], &[Polarity::Getter, Polarity::Putter]);
     let pol = d.component_polarities(b"main").unwrap();
     assert_eq!(&pol[..], &[Getter, Putter]);
+}
 #[test]
@@ @@ -37,14 +37,14 @@ fn config_and_connect_2() { @@
         //
         thread::spawn(move || {
             let mut x = Connector::Unconfigured(Unconfigured { controller_id: 0 });
             x.configure(b"primitive main(in a, out b) {}").unwrap();
+            x.configure(b"primitive main(in a, out b) {}", b"main").unwrap();
             x.bind_port(0, Passive(addrs[0])).unwrap();
             x.bind_port(1, Passive(addrs[1])).unwrap();
             x.connect(timeout).unwrap();
         }),
         thread::spawn(move || {
             let mut x = Connector::Unconfigured(Unconfigured { controller_id: 1 });
             x.configure(b"primitive main(out a, in b) {}").unwrap();
+            x.configure(b"primitive main(out a, in b) {}", b"main").unwrap();
             x.bind_port(0, Active(addrs[0])).unwrap();
             x.bind_port(1, Active(addrs[1])).unwrap();
             x.connect(timeout).unwrap();
@@ @@ -58,7 +58,7 @@ fn config_and_connect_2() { @@
 #[test]
 fn bind_too_much() {
     let mut x = Connector::Unconfigured(Unconfigured { controller_id: 0 });
     x.configure(b"primitive main(in a) {}").unwrap();
+    x.configure(b"primitive main(in a) {}", b"main").unwrap();
     x.bind_port(0, Native).unwrap();
     assert!(x.bind_port(1, Native).is_err());
+}
@@ @@ -77,14 +77,14 @@ fn config_and_connect_chain() { @@
         thread::spawn(move || {
             // PRODUCER A->
             let mut x = Connector::Unconfigured(Unconfigured { controller_id: 0 });
             x.configure(b"primitive main(out a) {}").unwrap();
+            x.configure(b"primitive main(out a) {}", b"main").unwrap();
             x.bind_port(0, Active(addrs[0])).unwrap();
             x.connect(timeout).unwrap();
         }),
         thread::spawn(move || {
             // FORWARDER ->B->
             let mut x = Connector::Unconfigured(Unconfigured { controller_id: 1 });
             x.configure(b"primitive main(in a, out b) {}").unwrap();
+            x.configure(b"primitive main(in a, out b) {}", b"main").unwrap();
             x.bind_port(0, Passive(addrs[0])).unwrap();
             x.bind_port(1, Active(addrs[1])).unwrap();
             x.connect(timeout).unwrap();
@@ @@ -92,7 +92,7 @@ fn config_and_connect_chain() { @@
         thread::spawn(move || {
             // FORWARDER ->C->
             let mut x = Connector::Unconfigured(Unconfigured { controller_id: 2 });
             x.configure(b"primitive main(in a, out b) {}").unwrap();
+            x.configure(b"primitive main(in a, out b) {}", b"main").unwrap();
             x.bind_port(0, Passive(addrs[1])).unwrap();
             x.bind_port(1, Active(addrs[2])).unwrap();
             x.connect(timeout).unwrap();
@@ @@ -100,7 +100,7 @@ fn config_and_connect_chain() { @@
         thread::spawn(move || {
             // CONSUMER ->D
             let mut x = Connector::Unconfigured(Unconfigured { controller_id: 3 });
             x.configure(b"primitive main(in a) {}").unwrap();
+            x.configure(b"primitive main(in a) {}", b"main").unwrap();
             x.bind_port(0, Passive(addrs[2])).unwrap();
             x.connect(timeout).unwrap();
         }),

0 comments (0 inline, 0 general)