diff --git a/src/runtime2/native.rs b/src/runtime2/native.rs index 7247c23a3b1190755c7c3aa479bf699582c90771..61c761bcc1fb52194a9abfe63be452b6aee1837a 100644 --- a/src/runtime2/native.rs +++ b/src/runtime2/native.rs @@ -6,7 +6,7 @@ use crate::protocol::ComponentCreationError; use crate::protocol::eval::ValueGroup; use crate::ProtocolDescription; use crate::runtime2::connector::{Branch, find_ports_in_value_group}; -use crate::runtime2::global_store::ConnectorKey; +use crate::runtime2::global_store::{ConnectorKey, GlobalStore}; use super::RuntimeInner; use super::global_store::{ConnectorVariant, ConnectorId}; @@ -16,8 +16,8 @@ use super::inbox::{Message, DataMessage, SyncMessage}; pub trait Connector { fn insert_data_message(&mut self, message: DataMessage); - fn insert_sync_message(&mut self, message: SyncMessage, delta_state: &mut RunDeltaState); - fn run(&mut self, protocol_description: &ProtocolDescription, delta_state: &mut RunDeltaState) -> ConnectorScheduling; + fn insert_sync_message(&mut self, message: SyncMessage, global: &GlobalStore, delta_state: &mut RunDeltaState); + fn run(&mut self, protocol_description: &ProtocolDescription, global: &GlobalStore, delta_state: &mut RunDeltaState) -> ConnectorScheduling; } type SyncDone = Arc<(Mutex, Condvar)>; @@ -47,7 +47,7 @@ impl ConnectorApplication { } impl Connector for ConnectorApplication { - fn insert_sync_message(&mut self, message: SyncMessage, delta_state: &mut RunDeltaState) { + fn insert_sync_message(&mut self, message: SyncMessage, global: &GlobalStore, delta_state: &mut RunDeltaState) { todo!("handling sync messages in ApplicationConnector"); } @@ -55,7 +55,7 @@ impl Connector for ConnectorApplication { todo!("handling messages in ApplicationConnector"); } - fn run(&mut self, protocol_description: &ProtocolDescription, delta_state: &mut RunDeltaState) -> ConnectorScheduling { + fn run(&mut self, protocol_description: &ProtocolDescription, global: &GlobalStore, delta_state: &mut RunDeltaState) -> ConnectorScheduling { let mut queue = self.job_queue.lock().unwrap(); while let Some(job) = queue.pop() { match job {