diff --git a/src/runtime2/connector.rs b/src/runtime2/connector.rs index 7705f4569af80e9519147c0bce2d6a763eb7d0c6..4f5521f60edc808741ce681d6e54958fab1466c4 100644 --- a/src/runtime2/connector.rs +++ b/src/runtime2/connector.rs @@ -26,17 +26,15 @@ // - TODO: Write about handling messages, consensus wrapping data // - TODO: Write about way information is exchanged between PDL/component and scheduler through ctx -use std::collections::HashMap; use std::sync::atomic::AtomicBool; use crate::{PortId, ProtocolDescription}; -use crate::common::ComponentState; use crate::protocol::eval::{EvalContinuation, EvalError, Prompt, Value, ValueGroup}; -use crate::protocol::{RunContext, RunResult}; +use crate::protocol::RunContext; use super::branch::{BranchId, ExecTree, QueueKind, SpeculativeState, PreparedStatement}; use super::consensus::{Consensus, Consistency, RoundConclusion, find_ports_in_value_group}; -use super::inbox::{DataMessage, Message, SyncCompMessage, SyncCompContent, SyncPortMessage, SyncControlMessage, PublicInbox}; +use super::inbox::{DataMessage, Message, SyncCompMessage, SyncPortMessage, SyncControlMessage, PublicInbox}; use super::native::Connector; use super::port::{PortKind, PortIdLocal}; use super::scheduler::{ComponentCtx, SchedulerCtx, MessageTicket};