diff --git a/src/runtime2/component/component_pdl.rs b/src/runtime2/component/component_pdl.rs index 8fdb556af27fe536f23f6d19a592551b097e4450..a698dbff39a72205436cb435ab9cd0bf7709cb84 100644 --- a/src/runtime2/component/component_pdl.rs +++ b/src/runtime2/component/component_pdl.rs @@ -255,11 +255,11 @@ impl CompPDL { self.handle_sync_start(sched_ctx, comp_ctx); return Ok(CompScheduling::Immediate); }, - EC::NewComponent(definition_id, monomorph_idx, arguments) => { + EC::NewComponent(definition_id, type_id, arguments) => { debug_assert_eq!(self.mode, Mode::NonSync); self.create_component_and_transfer_ports( sched_ctx, comp_ctx, - definition_id, monomorph_idx, arguments + definition_id, type_id, arguments ); return Ok(CompScheduling::Requeue); }, @@ -311,7 +311,7 @@ impl CompPDL { /// Handles decision from the consensus round. This will cause a change in /// the internal `Mode`, such that the next call to `run` can take the /// appropriate next steps. - fn handle_sync_decision(&mut self, sched_ctx: &SchedulerCtx, comp_ctx: &mut CompCtx, decision: SyncRoundDecision) { + fn handle_sync_decision(&mut self, sched_ctx: &SchedulerCtx, _comp_ctx: &mut CompCtx, decision: SyncRoundDecision) { sched_ctx.log(&format!("Handling sync decision: {:?} (in mode {:?})", decision, self.mode)); let is_success = match decision { SyncRoundDecision::None => { @@ -598,7 +598,7 @@ impl CompPDL { fn create_component_and_transfer_ports( &mut self, sched_ctx: &SchedulerCtx, creator_ctx: &mut CompCtx, - definition_id: DefinitionId, monomorph_index: i32, mut arguments: ValueGroup + definition_id: DefinitionId, type_id: TypeId, mut arguments: ValueGroup ) { struct PortPair{ creator_handle: LocalPortHandle, @@ -692,7 +692,7 @@ impl CompPDL { // to message exchanges between remote peers. let prompt = Prompt::new( &sched_ctx.runtime.protocol.types, &sched_ctx.runtime.protocol.heap, - definition_id, monomorph_index, arguments, + definition_id, type_id, arguments, ); let component = CompPDL::new(prompt, port_id_pairs.len()); let (created_key, component) = sched_ctx.runtime.finish_create_pdl_component(