diff --git a/src/runtime/src/comms.rs b/src/runtime/src/comms.rs index 00a2b6f9..55cfc185 100644 --- a/src/runtime/src/comms.rs +++ b/src/runtime/src/comms.rs @@ -224,7 +224,7 @@ async fn handle_run_kernel(stream: Option<&TcpStream>, control: &Rc { + kernel::Message::KernelFinished(async_errors) => { if let Some(stream) = stream { write_header(stream, Reply::KernelFinished).await?; write_i8(stream, async_errors as i8).await?; diff --git a/src/runtime/src/kernel/core1.rs b/src/runtime/src/kernel/core1.rs index ab6a428e..9084260d 100644 --- a/src/runtime/src/kernel/core1.rs +++ b/src/runtime/src/kernel/core1.rs @@ -193,7 +193,7 @@ pub extern "C" fn main_core1() { } info!("kernel finished"); let async_errors = unsafe { get_async_errors() }; - core1_tx.send(Message::KernelFinished { async_errors }); + core1_tx.send(Message::KernelFinished(async_errors)); } _ => error!("Core1 received unexpected message: {:?}", message), } diff --git a/src/runtime/src/kernel/mod.rs b/src/runtime/src/kernel/mod.rs index 3ca8bf6c..58bebf2a 100644 --- a/src/runtime/src/kernel/mod.rs +++ b/src/runtime/src/kernel/mod.rs @@ -30,9 +30,7 @@ pub enum Message { LoadCompleted, LoadFailed, StartRequest, - KernelFinished { - async_errors: u8 - }, + KernelFinished(u8), KernelException(&'static eh_artiq::Exception<'static>, &'static [usize], u8), RpcSend { is_async: bool, data: Vec }, RpcRecvRequest(*mut ()),