Rework parameter handling for PUS #174
@@ -137,7 +137,8 @@ impl<TmSender: EcssTmSender> PusEventHandler<TmSender> {
|
|||||||
self.pus_event_tm_creator.reporter.tm_hook.next_apid =
|
self.pus_event_tm_creator.reporter.tm_hook.next_apid =
|
||||||
UniqueApidTargetId::from(event_msg.sender_id()).apid;
|
UniqueApidTargetId::from(event_msg.sender_id()).apid;
|
||||||
update_time(&mut self.time_provider, &mut self.timestamp);
|
update_time(&mut self.time_provider, &mut self.timestamp);
|
||||||
self.pus_event_tm_creator
|
let generation_result = self
|
||||||
|
.pus_event_tm_creator
|
||||||
.generate_pus_event_tm_generic_with_generic_params(
|
.generate_pus_event_tm_generic_with_generic_params(
|
||||||
&self.tm_sender,
|
&self.tm_sender,
|
||||||
&self.timestamp,
|
&self.timestamp,
|
||||||
@@ -146,6 +147,12 @@ impl<TmSender: EcssTmSender> PusEventHandler<TmSender> {
|
|||||||
event_msg.params(),
|
event_msg.params(),
|
||||||
)
|
)
|
||||||
.expect("Sending TM as event failed");
|
.expect("Sending TM as event failed");
|
||||||
|
if !generation_result.params_were_propagated {
|
||||||
|
log::warn!(
|
||||||
|
"Event TM parameters were not propagated: {:?}",
|
||||||
|
event_msg.params()
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
Err(e) => match e {
|
Err(e) => match e {
|
||||||
mpsc::TryRecvError::Empty => break,
|
mpsc::TryRecvError::Empty => break,
|
||||||
|
Reference in New Issue
Block a user