diff --git a/src/tasks/motion.rs b/src/tasks/motion.rs index 6224546..e9859f9 100644 --- a/src/tasks/motion.rs +++ b/src/tasks/motion.rs @@ -17,11 +17,11 @@ pub async fn motion_task(src: DynamicReceiver<'static, Measurement>, prediction_ match next_measurement { Measurement::IMU { accel, gyro } => { states.insert_imu(accel, gyro); - states.commit(&prediction_sink).with_timeout(TIMEOUT).await.expect("Could not commit IMU data in time"); + states.commit(&prediction_sink).with_timeout(TIMEOUT).await.expect("Could not commit IMU data in time. Is the prediction bus stalled?"); }, Measurement::GPS(Some(gps_pos)) => { states.insert_gps(gps_pos); - states.commit(&prediction_sink).with_timeout(TIMEOUT).await.expect("Could not commit GPS data in time"); + states.commit(&prediction_sink).with_timeout(TIMEOUT).await.expect("Could not commit GPS data in time. Is the prediction bus stalled?"); }, Measurement::GPS(None) => { states.has_gps_fix.set(false); @@ -29,7 +29,7 @@ pub async fn motion_task(src: DynamicReceiver<'static, Measurement>, prediction_ // FIXME: This needs harmonized with the automatic data timeout from above, somehow? Measurement::SensorHardwareStatus(source, state) => { warn!("Sensor {source:?} reports {state:?}!"); - prediction_sink.publish(Prediction::SensorStatus(source, state)).with_timeout(TIMEOUT).await.expect("Could not update sensor status in time"); + prediction_sink.publish(Prediction::SensorStatus(source, state)).with_timeout(TIMEOUT).await.expect("Could not update sensor status in time. Is the prediction bus stalled?"); }, Measurement::SimulationProgress(source, duration, pct) => debug!("{source:?} simulation time: {} {} / 255", duration.as_secs(), pct), Measurement::Annotation => ()