TM sender abstractions have ID and name now

satrs-core/src/pus/verification.rs

@@ -29,7 +29,7 @@
 //! let pool_cfg = PoolCfg::new(vec![(10, 32), (10, 64), (10, 128), (10, 1024)]);
 //! let shared_tm_pool: SharedPool = Arc::new(RwLock::new(Box::new(LocalPool::new(pool_cfg.clone()))));
 //! let (verif_tx, verif_rx) = mpsc::channel();
-//! let sender = MpscVerifSender::new(shared_tm_pool.clone(), verif_tx);
+//! let sender = MpscVerifSender::new(0, "verif_tm", shared_tm_pool.clone(), verif_tx);
 //! let cfg = VerificationReporterCfg::new(TEST_APID, Box::new(SeqCountProviderSimple::default()), 1, 2, 8).unwrap();
 //! let mut  reporter = VerificationReporterWithSender::new(&cfg , Box::new(sender));
 //!
@@ -1252,6 +1252,7 @@ mod stdmod {
     use super::*;
     use crate::pool::{ShareablePoolProvider, SharedPool, StoreAddr};
     use crate::pus::MpscPusInStoreSendError;
+    use crate::SenderId;
     use delegate::delegate;
     use spacepackets::tm::PusTm;
     use std::sync::{mpsc, Arc, Mutex, RwLockWriteGuard};
@@ -1265,17 +1266,21 @@ mod stdmod {
 
     #[derive(Clone)]
     struct StdSenderBase<S> {
-        pub ignore_poison_error: bool,
+        id: SenderId,
+        name: &'static str,
         tm_store: SharedPool,
         tx: S,
+        pub ignore_poison_error: bool,
     }
 
     impl<S: SendBackend> StdSenderBase<S> {
-        pub fn new(tm_store: SharedPool, tx: S) -> Self {
+        pub fn new(id: SenderId, name: &'static str, tm_store: SharedPool, tx: S) -> Self {
             Self {
-                ignore_poison_error: false,
+                id,
+                name,
                 tm_store,
                 tx,
+                ignore_poison_error: false,
             }
         }
     }
@@ -1297,9 +1302,14 @@ mod stdmod {
     /// Verification sender with a [mpsc::Sender] backend.
     /// It implements the [EcssTmSenderCore] trait to be used as PUS Verification TM sender.
     impl MpscVerifSender {
-        pub fn new(tm_store: SharedPool, tx: mpsc::Sender<StoreAddr>) -> Self {
+        pub fn new(
+            id: SenderId,
+            name: &'static str,
+            tm_store: SharedPool,
+            tx: mpsc::Sender<StoreAddr>,
+        ) -> Self {
             Self {
-                base: StdSenderBase::new(tm_store, tx),
+                base: StdSenderBase::new(id, name, tm_store, tx),
             }
         }
     }
@@ -1310,6 +1320,8 @@ mod stdmod {
 
         delegate!(
             to self.base {
+                fn id(&self) -> SenderId;
+                fn name(&self) -> &'static str;
                 fn send_tm(&mut self, tm: PusTm) -> Result<(), Self::Error>;
             }
         );
@@ -1331,9 +1343,14 @@ mod stdmod {
 
     #[cfg(feature = "crossbeam")]
     impl CrossbeamVerifSender {
-        pub fn new(tm_store: SharedPool, tx: crossbeam_channel::Sender<StoreAddr>) -> Self {
+        pub fn new(
+            id: SenderId,
+            name: &'static str,
+            tm_store: SharedPool,
+            tx: crossbeam_channel::Sender<StoreAddr>,
+        ) -> Self {
             Self {
-                base: StdSenderBase::new(tm_store, tx),
+                base: StdSenderBase::new(id, name, tm_store, tx),
             }
         }
     }
@@ -1345,6 +1362,8 @@ mod stdmod {
 
         delegate!(
             to self.base {
+                fn id(&self) -> SenderId;
+                fn name(&self) -> &'static str;
                 fn send_tm(&mut self, tm: PusTm) -> Result<(), Self::Error>;
             }
         );
@@ -1352,6 +1371,11 @@ mod stdmod {
 
     impl<S: SendBackend + Clone + 'static> EcssTmSenderCore for StdSenderBase<S> {
         type Error = MpscPusInStoreSendError;
+
+        fn id(&self) -> SenderId {
+            self.id
+        }
+
         fn send_tm(&mut self, tm: PusTm) -> Result<(), Self::Error> {
             let operation = |mut mg: RwLockWriteGuard<ShareablePoolProvider>| {
                 let (addr, buf) = mg.free_element(tm.len_packed())?;
@@ -1374,6 +1398,10 @@ mod stdmod {
                 }
             }
         }
+
+        fn name(&self) -> &'static str {
+            self.name
+        }
     }
 }
 
@@ -1403,6 +1431,7 @@ mod tests {
     };
     use crate::pus::EcssTmErrorWithSend;
     use crate::seq_count::SeqCountProviderSimple;
+    use crate::SenderId;
     use alloc::boxed::Box;
     use alloc::format;
     use spacepackets::ecss::{EcssEnumU16, EcssEnumU32, EcssEnumU8, EcssEnumeration, PusPacket};
@@ -1435,6 +1464,11 @@ mod tests {
 
     impl EcssTmSenderCore for TestSender {
         type Error = ();
+
+        fn id(&self) -> SenderId {
+            0
+        }
+
         fn send_tm(&mut self, tm: PusTm) -> Result<(), Self::Error> {
             assert_eq!(PusPacket::service(&tm), 1);
             assert!(tm.source_data().is_some());
@@ -1456,6 +1490,10 @@ mod tests {
             });
             Ok(())
         }
+
+        fn name(&self) -> &'static str {
+            "test_sender"
+        }
     }
 
     #[derive(Debug, Copy, Clone, Eq, PartialEq)]
@@ -1465,6 +1503,9 @@ mod tests {
 
     impl EcssTmSenderCore for FallibleSender {
         type Error = DummyError;
+        fn id(&self) -> SenderId {
+            0
+        }
         fn send_tm(&mut self, _: PusTm) -> Result<(), Self::Error> {
             Err(DummyError {})
         }
@@ -1559,7 +1600,7 @@ mod tests {
         let pool = LocalPool::new(PoolCfg::new(vec![(8, 8)]));
         let shared_pool: SharedPool = Arc::new(RwLock::new(Box::new(pool)));
         let (tx, _) = mpsc::channel();
-        let mpsc_verif_sender = MpscVerifSender::new(shared_pool, tx);
+        let mpsc_verif_sender = MpscVerifSender::new(0, "verif_sender", shared_pool, tx);
         is_send(&mpsc_verif_sender);
     }