pub struct CuRuntime<CT, CB, P: CopperListTuple, M: CuMonitor, const NBCL: usize> {
pub clock: RobotClock,
pub instance_id: u32,
pub tasks: CT,
pub bridges: CB,
pub resources: ResourceManager,
pub monitor: M,
pub execution_probe: ExecutionProbeHandle,
pub copperlists_manager: CopperListsManager<P, NBCL>,
pub keyframes_manager: KeyFramesManager,
pub runtime_config: RuntimeConfig,
/* private fields */
}Expand description
This is the main structure that will be injected as a member of the Application struct. CT is the tuple of all the tasks in order of execution. CL is the type of the copper list, representing the input/output messages for all the tasks.
Fields§
§clock: RobotClockThe base clock the runtime will be using to record time.
instance_id: u32Deployment/runtime instance identity for this Copper process.
tasks: CTThe tuple of all the tasks in order of execution.
bridges: CBTuple of all instantiated bridges.
resources: ResourceManagerResource registry kept alive for tasks borrowing shared handles.
monitor: MThe runtime monitoring.
execution_probe: ExecutionProbeHandleRuntime-side execution progress probe for watchdog/diagnostic monitors.
This probe is written from the generated execution plan before each component step. Monitors consume it asynchronously (typically from watchdog threads) to report the last known component/step/culist when the runtime appears stalled.
copperlists_manager: CopperListsManager<P, NBCL>The logger for the copper lists (messages between tasks)
keyframes_manager: KeyFramesManagerThe logger for the state of the tasks (frozen tasks)
runtime_config: RuntimeConfigThe runtime configuration controlling the behavior of the run loop
Implementations§
Source§impl<CT, CB, P, M, const NBCL: usize> CuRuntime<CT, CB, P, M, NBCL>
Helper methods injected for simulation-only builds.
impl<CT, CB, P, M, const NBCL: usize> CuRuntime<CT, CB, P, M, NBCL>
Helper methods injected for simulation-only builds.
pub fn set_forced_keyframe_timestamp(&mut self, ts: CuTime)
Sourcepub fn lock_keyframe(&mut self, keyframe: &KeyFrame)
pub fn lock_keyframe(&mut self, keyframe: &KeyFrame)
Reuse a recorded keyframe verbatim (used during deterministic replay).
pub fn captures_keyframe(&self, culistid: u64) -> bool
Source§impl<CT, CB, P: CopperListTuple, M: CuMonitor, const NBCL: usize> CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P: CopperListTuple, M: CuMonitor, const NBCL: usize> CuRuntime<CT, CB, P, M, NBCL>
Sourcepub fn clock(&self) -> RobotClock
pub fn clock(&self) -> RobotClock
Returns a clone of the runtime clock handle.
Sourcepub fn subsystem_code(&self) -> u16
pub fn subsystem_code(&self) -> u16
Returns the compile-time subsystem code for this process.
Sourcepub fn instance_id(&self) -> u32
pub fn instance_id(&self) -> u32
Returns the configured runtime instance id for this process.
Source§impl<CT, CB, P: CopperListTuple + CuListZeroedInit + Default + AsyncCopperListPayload + 'static, M: CuMonitor, const NBCL: usize> CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P: CopperListTuple + CuListZeroedInit + Default + AsyncCopperListPayload + 'static, M: CuMonitor, const NBCL: usize> CuRuntime<CT, CB, P, M, NBCL>
Sourcepub fn record_execution_marker(&self, marker: ExecutionMarker)
pub fn record_execution_marker(&self, marker: ExecutionMarker)
Records runtime execution progress in the shared probe.
This is intentionally lightweight and does not call monitor callbacks.
Sourcepub fn execution_probe_ref(&self) -> &RuntimeExecutionProbe
pub fn execution_probe_ref(&self) -> &RuntimeExecutionProbe
Returns a shared reference to the concrete runtime execution probe.
The generated runtime uses this when it needs a uniform
&RuntimeExecutionProbe view across std and no_std builds.
pub fn new( clock: RobotClock, subsystem_code: u16, config: &CuConfig, mission: &str, resources_instanciator: impl Fn(&CuConfig) -> CuResult<ResourceManager>, tasks_instanciator: impl for<'c> Fn(Vec<Option<&'c ComponentConfig>>, &mut ResourceManager) -> CuResult<CT>, monitored_components: &'static [MonitorComponentMetadata], culist_component_mapping: &'static [ComponentId], monitor_instanciator: impl Fn(&CuConfig, CuMonitoringMetadata, CuMonitoringRuntime) -> M, bridges_instanciator: impl Fn(&CuConfig, &mut ResourceManager) -> CuResult<CB>, copperlists_logger: impl WriteStream<CopperList<P>> + 'static, keyframes_logger: impl WriteStream<KeyFrame> + 'static, ) -> CuResult<Self>
Use CuRuntimeBuilder instead of CuRuntime::new(…).
pub fn new_with_resources( clock: RobotClock, subsystem_code: u16, config: &CuConfig, mission: &str, resources: ResourceManager, tasks_instanciator: impl for<'c> Fn(Vec<Option<&'c ComponentConfig>>, &mut ResourceManager) -> CuResult<CT>, monitored_components: &'static [MonitorComponentMetadata], culist_component_mapping: &'static [ComponentId], monitor_instanciator: impl Fn(&CuConfig, CuMonitoringMetadata, CuMonitoringRuntime) -> M, bridges_instanciator: impl Fn(&CuConfig, &mut ResourceManager) -> CuResult<CB>, copperlists_logger: impl WriteStream<CopperList<P>> + 'static, keyframes_logger: impl WriteStream<KeyFrame> + 'static, ) -> CuResult<Self>
Use CuRuntimeBuilder instead of CuRuntime::new_with_resources(…).
Trait Implementations§
Source§impl<CT, CB, P: CopperListTuple + CuListZeroedInit + Default + AsyncCopperListPayload, M: CuMonitor, const NBCL: usize> ClockProvider for CuRuntime<CT, CB, P, M, NBCL>
To be able to share the clock we make the runtime a clock provider.
impl<CT, CB, P: CopperListTuple + CuListZeroedInit + Default + AsyncCopperListPayload, M: CuMonitor, const NBCL: usize> ClockProvider for CuRuntime<CT, CB, P, M, NBCL>
To be able to share the clock we make the runtime a clock provider.
fn get_clock(&self) -> RobotClock
Auto Trait Implementations§
impl<CT, CB, P, M, const NBCL: usize> Freeze for CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P, M, const NBCL: usize> !RefUnwindSafe for CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P, M, const NBCL: usize> Send for CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P, M, const NBCL: usize> Sync for CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P, M, const NBCL: usize> Unpin for CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P, M, const NBCL: usize> UnsafeUnpin for CuRuntime<CT, CB, P, M, NBCL>
impl<CT, CB, P, M, const NBCL: usize> !UnwindSafe for CuRuntime<CT, CB, P, M, NBCL>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more