Struct CommManager 

pub struct CommManager<B, T>
where
    B: BoardIo,
    T: CommInterface<B>,
{
    pub sysid: u8,
    pub msgs: Messages,
    /* private fields */
}

Fields

sysid: u8

msgs: Messages

Implementations

impl<B, T> CommManager<B, T>

where B: BoardIo, T: CommInterface<B>,

pub fn new(comm_link: T, now_us: u64) -> Self

pub fn process_incoming_messages(&mut self, board: &mut B)

pub fn has_pending_messages(&self) -> bool

pub fn set_telemetry_rates(&mut self, telemetry_rates: TelemetryRates)

pub fn configure_telemetry_from_params(&mut self, params: &Params)

pub fn update_telemetry_param( &mut self, params: &Params, id: ParamId, now_us: u64, ) -> bool

Applies one live telemetry parameter without disturbing the deadlines of unrelated streams. The changed stream begins a new period at now_us, avoiding a catch-up burst.

pub fn named_telemetry_due<R>( &self, now_us: u64, processed_sensors: &ProcessedSensors<R>, ) -> bool

where R: FlightFloat,

pub fn send_named_telemetry_streams<S, A, R>( &mut self, ctx: TelemetryCtx<'_, B, S, A, R>, )

where S: AttitudeEstimate, A: AsRef<[R]>, R: FlightFloat,

pub fn send_one_named_telemetry_stream<S, A, R>( &mut self, ctx: TelemetryCtx<'_, B, S, A, R>, ) -> bool

where S: AttitudeEstimate, A: AsRef<[R]>, R: FlightFloat,

pub fn send_named_telemetry_stream_if_due<S, A, R>( &mut self, stream: NamedTelemetryStream, ctx: TelemetryCtx<'_, B, S, A, R>, ) -> bool

where S: AttitudeEstimate, A: AsRef<[R]>, R: FlightFloat,

pub fn send_named_telemetry_stream_with_gate<S, A, R>( &mut self, priority: RealtimeTelemetryPriority, ctx: TelemetryCtx<'_, B, S, A, R>, ) -> bool

where S: AttitudeEstimate, A: AsRef<[R]>, R: FlightFloat,

pub fn act_on_messages( &mut self, param_events: &mut ParamEventQueues, comm_events: &mut CommEventQueues, command_events: &mut CommandEventQueues, companion_events: &mut CompanionEventQueues, board: &mut B, )

pub fn send_comm_responses( &mut self, board: &mut B, comm_events: &mut CommEventQueues, )

pub fn send_comm_responses_limited( &mut self, board: &mut B, comm_events: &mut CommEventQueues, max_responses: usize, ) -> usize

pub fn send_timesync(&mut self, board: &mut B, msg: TimesyncMsg)

pub fn send_rosflight_heartbeat(&mut self, board: &mut B, msg: HeartbeatMsg)

pub fn send_rosflight_status(&mut self, board: &mut B, msg: RosflightStatusMsg)

pub fn send_rosflight_attitude_quaternion( &mut self, board: &mut B, msg: AttitudeQuaternionMsg, )

pub fn send_rosflight_small_imu(&mut self, board: &mut B, msg: SmallImuMsg)

pub fn send_rosflight_small_baro(&mut self, board: &mut B, msg: SmallBaroMsg)

pub fn send_rosflight_diff_pressure( &mut self, board: &mut B, msg: DiffPressureMsg, )

pub fn send_rosflight_small_mag(&mut self, board: &mut B, msg: SmallMagMsg)

pub fn send_rosflight_small_range(&mut self, board: &mut B, msg: SmallRangeMsg)

pub fn send_rosflight_battery_status( &mut self, board: &mut B, msg: BatteryStatusMsg, )

pub fn send_rosflight_gnss(&mut self, board: &mut B, msg: RosflightGnssMsg)

pub fn send_rosflight_rc_raw(&mut self, board: &mut B, msg: RcChannelsMsg)

pub fn send_rosflight_output_raw( &mut self, board: &mut B, msg: RosflightOutputRawMsg, )