diff --git a/src/runtime2/component/component_ip.rs b/src/runtime2/component/component_ip.rs index c4f438ed4c93990fd82b1e16345ed6f1c78d5a73..a3a83aa59df50bf6bb336fd7cbd53aaaf66551b8 100644 --- a/src/runtime2/component/component_ip.rs +++ b/src/runtime2/component/component_ip.rs @@ -13,11 +13,21 @@ pub struct ComponentRandomU32 { impl Component for ComponentRandomU32 { fn adopt_message(&mut self, _comp_ctx: &mut CompCtx, _message: DataMessage) { - unreachable!("should not adopt messages"); + // Impossible since this component does not have any input ports in its + // signature. + unreachable!(); } fn handle_message(&mut self, sched_ctx: &mut SchedulerCtx, comp_ctx: &mut CompCtx, message: Message) { - todo!() + match message { + Message::Data(message) => unreachable!(), + Message::Sync(message) => { + + }, + Message::Control(message) => { + + } + } } fn run(&mut self, sched_ctx: &mut SchedulerCtx, comp_ctx: &mut CompCtx) -> Result { @@ -33,7 +43,7 @@ impl ComponentRandomU32 { let minimum = arguments.values[1].as_uint32(); let maximum = arguments.values[2].as_uint32(); - return ComponentRandomU32{ + return Self{ output_port_id: port_id, random_minimum: minimum, random_maximum: maximum,