diff --git a/satrs-example/src/main.rs b/satrs-example/src/main.rs index 82ed30c..a96f2de 100644 --- a/satrs-example/src/main.rs +++ b/satrs-example/src/main.rs @@ -33,7 +33,7 @@ use satrs::{ hal::std::{tcp_server::ServerConfig, udp_server::UdpTcServer}, mode::{Mode, ModeAndSubmode, ModeRequest, ModeRequestHandlerMpscBounded}, mode_tree::connect_mode_nodes, - pus::{event_man::EventRequestWithToken, EcssTcInMemConverterWrapper, HandlingStatus}, + pus::{event_man::EventRequestWithToken, EcssTcCacher, HandlingStatus}, request::{GenericMessage, MessageMetadata}, spacepackets::time::{cds::CdsTime, TimeWriter}, }; @@ -57,12 +57,12 @@ use tmtc::{tc_source::TcSourceTask, tm_sink::TmSink}; cfg_if::cfg_if! { if #[cfg(feature = "heap_tmtc")] { use interface::udp::DynamicUdpTmHandler; - use satrs::pus::EcssTcInVecConverter; + use satrs::pus::EcssTcVecCacher; use tmtc::{tc_source::TcSourceTaskDynamic, tm_sink::TmSinkDynamic}; } else { use std::sync::RwLock; use interface::udp::StaticUdpTmHandler; - use satrs::pus::EcssTcInSharedPoolConverter; + use satrs::pus::EcssTcInSharedPoolCacher; use satrs::tmtc::{PacketSenderWithSharedPool, SharedPacketPool}; use satrs_example::config::pool::create_static_pools; use tmtc::{ @@ -143,9 +143,9 @@ fn main() { let tc_sender_with_shared_pool = PacketSenderWithSharedPool::new(tc_source_tx, shared_tc_pool_wrapper.clone()); let tc_in_mem_converter = - EcssTcInMemConverter::Static(EcssTcInSharedPoolConverter::new(shared_tc_pool, 4096)); + EcssTcCacher::Static(EcssTcInSharedPoolCacher::new(shared_tc_pool, 4096)); } else if #[cfg(feature = "heap_tmtc")] { - let tc_in_mem_converter = EcssTcInMemConverterWrapper::Heap(EcssTcInVecConverter::default()); + let tc_in_mem_converter = EcssTcCacher::Heap(EcssTcVecCacher::default()); } } diff --git a/satrs-example/src/pus/action.rs b/satrs-example/src/pus/action.rs index 0c0bced..b5fcc81 100644 --- a/satrs-example/src/pus/action.rs +++ b/satrs-example/src/pus/action.rs @@ -9,7 +9,7 @@ use satrs::pus::verification::{ VerificationReportingProvider, VerificationToken, }; use satrs::pus::{ - ActiveRequest, EcssTcAndToken, EcssTcInMemConverterWrapper, EcssTmSender, EcssTmtcError, + ActiveRequest, EcssTcAndToken, EcssTcCacher, EcssTmSender, EcssTmtcError, GenericConversionError, MpscTcReceiver, PusPacketHandlingError, PusReplyHandler, PusServiceHelper, PusTcToRequestConverter, }; @@ -208,7 +208,7 @@ impl PusTcToRequestConverter for Actio pub fn create_action_service( tm_sender: TmTcSender, - tc_in_mem_converter: EcssTcInMemConverterWrapper, + tc_in_mem_converter: EcssTcCacher, pus_action_rx: mpsc::Receiver, action_router: GenericRequestRouter, reply_receiver: mpsc::Receiver>, @@ -274,7 +274,7 @@ mod tests { TEST_APID, TEST_COMPONENT_ID_0, TEST_COMPONENT_ID_1, TEST_UNIQUE_ID_0, TEST_UNIQUE_ID_1, }; use satrs::pus::verification::test_util::TestVerificationReporter; - use satrs::pus::{verification, EcssTcInVecConverter}; + use satrs::pus::{verification, EcssTcVecCacher}; use satrs::request::MessageMetadata; use satrs::tmtc::PacketAsVec; use satrs::ComponentId; @@ -325,7 +325,7 @@ mod tests { pus_action_rx, TmTcSender::Heap(tm_funnel_tx.clone()), verif_reporter, - EcssTcInMemConverterWrapper::Heap(EcssTcInVecConverter::default()), + EcssTcCacher::Heap(EcssTcVecCacher::default()), ), ActionRequestConverter::default(), DefaultActiveActionRequestMap::default(), diff --git a/satrs-example/src/pus/event.rs b/satrs-example/src/pus/event.rs index 6d9a6e4..f5538a7 100644 --- a/satrs-example/src/pus/event.rs +++ b/satrs-example/src/pus/event.rs @@ -6,7 +6,7 @@ use satrs::pus::event_man::EventRequestWithToken; use satrs::pus::event_srv::PusEventServiceHandler; use satrs::pus::verification::VerificationReporter; use satrs::pus::{ - DirectPusPacketHandlerResult, EcssTcAndToken, EcssTcInMemConverterWrapper, MpscTcReceiver, + DirectPusPacketHandlerResult, EcssTcAndToken, EcssTcCacher, MpscTcReceiver, PartialPusHandlingError, PusServiceHelper, }; use satrs::spacepackets::ecss::PusServiceId; @@ -16,7 +16,7 @@ use super::{DirectPusService, HandlingStatus}; pub fn create_event_service( tm_sender: TmTcSender, - tm_in_pool_converter: EcssTcInMemConverterWrapper, + tm_in_pool_converter: EcssTcCacher, pus_event_rx: mpsc::Receiver, event_request_tx: mpsc::Sender, ) -> EventServiceWrapper { @@ -36,12 +36,8 @@ pub fn create_event_service( } pub struct EventServiceWrapper { - pub handler: PusEventServiceHandler< - MpscTcReceiver, - TmTcSender, - EcssTcInMemConverterWrapper, - VerificationReporter, - >, + pub handler: + PusEventServiceHandler, } impl DirectPusService for EventServiceWrapper { diff --git a/satrs-example/src/pus/hk.rs b/satrs-example/src/pus/hk.rs index 1f96c68..2232998 100644 --- a/satrs-example/src/pus/hk.rs +++ b/satrs-example/src/pus/hk.rs @@ -5,10 +5,9 @@ use satrs::pus::verification::{ VerificationReportingProvider, VerificationToken, }; use satrs::pus::{ - ActivePusRequestStd, ActiveRequest, DefaultActiveRequestMap, EcssTcAndToken, - EcssTcInMemConverterWrapper, EcssTmSender, EcssTmtcError, GenericConversionError, - MpscTcReceiver, PusPacketHandlingError, PusReplyHandler, PusServiceHelper, - PusTcToRequestConverter, + ActivePusRequestStd, ActiveRequest, DefaultActiveRequestMap, EcssTcAndToken, EcssTcCacher, + EcssTmSender, EcssTmtcError, GenericConversionError, MpscTcReceiver, PusPacketHandlingError, + PusReplyHandler, PusServiceHelper, PusTcToRequestConverter, }; use satrs::request::{GenericMessage, UniqueApidTargetId}; use satrs::res_code::ResultU16; @@ -243,7 +242,7 @@ impl PusTcToRequestConverter for HkRequestConver pub fn create_hk_service( tm_sender: TmTcSender, - tc_in_mem_converter: EcssTcInMemConverterWrapper, + tc_in_mem_converter: EcssTcCacher, pus_hk_rx: mpsc::Receiver, request_router: GenericRequestRouter, reply_receiver: mpsc::Receiver>, diff --git a/satrs-example/src/pus/mod.rs b/satrs-example/src/pus/mod.rs index 6e9462c..8c1060e 100644 --- a/satrs-example/src/pus/mod.rs +++ b/satrs-example/src/pus/mod.rs @@ -7,10 +7,10 @@ use satrs::pus::verification::{ VerificationReporterConfig, VerificationReportingProvider, VerificationToken, }; use satrs::pus::{ - ActiveRequest, ActiveRequestStore, CacheAndReadRawEcssTc, EcssTcAndToken, - EcssTcInMemConverterWrapper, EcssTcReceiver, EcssTmSender, EcssTmtcError, - GenericConversionError, GenericRoutingError, HandlingStatus, PusPacketHandlingError, - PusReplyHandler, PusRequestRouter, PusServiceHelper, PusTcToRequestConverter, TcInMemory, + ActiveRequest, ActiveRequestStore, CacheAndReadRawEcssTc, EcssTcAndToken, EcssTcCacher, + EcssTcReceiver, EcssTmSender, EcssTmtcError, GenericConversionError, GenericRoutingError, + HandlingStatus, PusPacketHandlingError, PusReplyHandler, PusRequestRouter, PusServiceHelper, + PusTcToRequestConverter, TcInMemory, }; use satrs::queue::{GenericReceiveError, GenericSendError}; use satrs::request::{Apid, GenericMessage, MessageMetadata}; @@ -275,7 +275,7 @@ pub struct PusTargetedRequestService< ReplyType, > { pub service_helper: - PusServiceHelper, + PusServiceHelper, pub request_router: GenericRequestRouter, pub request_converter: RequestConverter, pub active_request_map: ActiveRequestMapInstance, @@ -311,7 +311,7 @@ where service_helper: PusServiceHelper< TcReceiver, TmTcSender, - EcssTcInMemConverterWrapper, + EcssTcCacher, VerificationReporter, >, request_converter: RequestConverter, diff --git a/satrs-example/src/pus/mode.rs b/satrs-example/src/pus/mode.rs index 5c2912a..4f71195 100644 --- a/satrs-example/src/pus/mode.rs +++ b/satrs-example/src/pus/mode.rs @@ -8,8 +8,8 @@ use crate::requests::GenericRequestRouter; use crate::tmtc::sender::TmTcSender; use satrs::pus::verification::VerificationReporter; use satrs::pus::{ - DefaultActiveRequestMap, EcssTcAndToken, EcssTcInMemConverterWrapper, MpscTcReceiver, - PusPacketHandlingError, PusServiceHelper, + DefaultActiveRequestMap, EcssTcAndToken, EcssTcCacher, MpscTcReceiver, PusPacketHandlingError, + PusServiceHelper, }; use satrs::request::GenericMessage; use satrs::{ @@ -210,7 +210,7 @@ impl PusTcToRequestConverter for ModeRequestCo pub fn create_mode_service( tm_sender: TmTcSender, - tc_in_mem_converter: EcssTcInMemConverterWrapper, + tc_in_mem_converter: EcssTcCacher, pus_action_rx: mpsc::Receiver, mode_router: GenericRequestRouter, reply_receiver: mpsc::Receiver>, diff --git a/satrs-example/src/pus/scheduler.rs b/satrs-example/src/pus/scheduler.rs index fc5f957..49ffa64 100644 --- a/satrs-example/src/pus/scheduler.rs +++ b/satrs-example/src/pus/scheduler.rs @@ -9,7 +9,7 @@ use satrs::pus::scheduler::{PusScheduler, TcInfo}; use satrs::pus::scheduler_srv::PusSchedServiceHandler; use satrs::pus::verification::VerificationReporter; use satrs::pus::{ - DirectPusPacketHandlerResult, EcssTcAndToken, EcssTcInMemConverterWrapper, MpscTcReceiver, + DirectPusPacketHandlerResult, EcssTcAndToken, EcssTcCacher, MpscTcReceiver, PartialPusHandlingError, PusServiceHelper, }; use satrs::spacepackets::ecss::PusServiceId; @@ -84,7 +84,7 @@ pub struct SchedulingServiceWrapper { pub pus_11_handler: PusSchedServiceHandler< MpscTcReceiver, TmTcSender, - EcssTcInMemConverterWrapper, + EcssTcCacher, VerificationReporter, PusScheduler, >, @@ -174,7 +174,7 @@ impl SchedulingServiceWrapper { pub fn create_scheduler_service( tm_sender: TmTcSender, - tc_in_mem_converter: EcssTcInMemConverterWrapper, + tc_in_mem_converter: EcssTcCacher, tc_releaser: TcReleaser, pus_sched_rx: mpsc::Receiver, sched_tc_pool: StaticMemoryPool, diff --git a/satrs-example/src/pus/test.rs b/satrs-example/src/pus/test.rs index b914121..b7e5b5d 100644 --- a/satrs-example/src/pus/test.rs +++ b/satrs-example/src/pus/test.rs @@ -6,8 +6,8 @@ use satrs::pus::test::PusService17TestHandler; use satrs::pus::verification::{FailParams, VerificationReporter, VerificationReportingProvider}; use satrs::pus::PartialPusHandlingError; use satrs::pus::{ - CacheAndReadRawEcssTc, DirectPusPacketHandlerResult, EcssTcAndToken, - EcssTcInMemConverterWrapper, MpscTcReceiver, PusServiceHelper, + CacheAndReadRawEcssTc, DirectPusPacketHandlerResult, EcssTcAndToken, EcssTcCacher, + MpscTcReceiver, PusServiceHelper, }; use satrs::spacepackets::ecss::tc::PusTcReader; use satrs::spacepackets::ecss::{PusPacket, PusServiceId}; @@ -19,7 +19,7 @@ use super::{DirectPusService, HandlingStatus}; pub fn create_test_service( tm_sender: TmTcSender, - tc_in_mem_converter: EcssTcInMemConverterWrapper, + tc_in_mem_converter: EcssTcCacher, event_sender: mpsc::SyncSender, pus_test_rx: mpsc::Receiver, ) -> TestCustomServiceWrapper { @@ -37,12 +37,8 @@ pub fn create_test_service( } pub struct TestCustomServiceWrapper { - pub handler: PusService17TestHandler< - MpscTcReceiver, - TmTcSender, - EcssTcInMemConverterWrapper, - VerificationReporter, - >, + pub handler: + PusService17TestHandler, pub event_tx: mpsc::SyncSender, } diff --git a/satrs/src/pus/event_srv.rs b/satrs/src/pus/event_srv.rs index c811b17..8bd6794 100644 --- a/satrs/src/pus/event_srv.rs +++ b/satrs/src/pus/event_srv.rs @@ -167,7 +167,7 @@ mod tests { use crate::{ events::EventU32, pus::{ - DirectPusPacketHandlerResult, EcssTcInSharedPoolConverter, PusPacketHandlingError, + DirectPusPacketHandlerResult, EcssTcInSharedPoolCacher, PusPacketHandlingError, event_man::EventRequestWithToken, tests::PusServiceHandlerWithSharedStoreCommon, verification::{TcStateAccepted, VerificationToken}, @@ -183,7 +183,7 @@ mod tests { handler: PusEventServiceHandler< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, >, } diff --git a/satrs/src/pus/mod.rs b/satrs/src/pus/mod.rs index d9d5780..b59b177 100644 --- a/satrs/src/pus/mod.rs +++ b/satrs/src/pus/mod.rs @@ -973,12 +973,12 @@ pub mod std_mod { /// Please note that this structure is not able to convert TCs which are stored inside a /// [SharedStaticMemoryPool]. #[derive(Default, Clone)] - pub struct EcssTcInVecConverter { + pub struct EcssTcVecCacher { sender_id: Option, pub pus_tc_raw: Option>, } - impl CacheAndReadRawEcssTc for EcssTcInVecConverter { + impl CacheAndReadRawEcssTc for EcssTcVecCacher { fn cache(&mut self, tc_in_memory: &TcInMemory) -> Result<(), PusTcFromMemError> { self.pus_tc_raw = None; match tc_in_memory { @@ -1010,13 +1010,13 @@ pub mod std_mod { /// packets should be avoided. Please note that this structure is not able to convert TCs which /// are stored as a `Vec`. #[derive(Clone)] - pub struct EcssTcInSharedPoolConverter { + pub struct EcssTcInSharedPoolCacher { sender_id: Option, shared_tc_pool: SharedStaticMemoryPool, pus_buf: Vec, } - impl EcssTcInSharedPoolConverter { + impl EcssTcInSharedPoolCacher { pub fn new(shared_tc_store: SharedStaticMemoryPool, max_expected_tc_size: usize) -> Self { Self { sender_id: None, @@ -1047,7 +1047,7 @@ pub mod std_mod { } } - impl CacheAndReadRawEcssTc for EcssTcInSharedPoolConverter { + impl CacheAndReadRawEcssTc for EcssTcInSharedPoolCacher { fn cache(&mut self, tc_in_memory: &TcInMemory) -> Result<(), PusTcFromMemError> { match tc_in_memory { super::TcInMemory::Pool(packet_in_pool) => { @@ -1072,22 +1072,22 @@ pub mod std_mod { // TODO: alloc feature flag? #[derive(Clone)] - pub enum EcssTcInMemConverterWrapper { - Static(EcssTcInSharedPoolConverter), - Heap(EcssTcInVecConverter), + pub enum EcssTcCacher { + Static(EcssTcInSharedPoolCacher), + Heap(EcssTcVecCacher), } - impl EcssTcInMemConverterWrapper { - pub fn new_static(static_store_converter: EcssTcInSharedPoolConverter) -> Self { + impl EcssTcCacher { + pub fn new_static(static_store_converter: EcssTcInSharedPoolCacher) -> Self { Self::Static(static_store_converter) } - pub fn new_heap(heap_converter: EcssTcInVecConverter) -> Self { + pub fn new_heap(heap_converter: EcssTcVecCacher) -> Self { Self::Heap(heap_converter) } } - impl CacheAndReadRawEcssTc for EcssTcInMemConverterWrapper { + impl CacheAndReadRawEcssTc for EcssTcCacher { fn cache(&mut self, tc_in_memory: &TcInMemory) -> Result<(), PusTcFromMemError> { match self { Self::Static(converter) => converter.cache(tc_in_memory), @@ -1385,7 +1385,7 @@ pub mod tests { pub type PusServiceHelperStatic = PusServiceHelper< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, >; @@ -1412,7 +1412,7 @@ pub mod tests { VerificationReporter::new(TEST_COMPONENT_ID_0.id(), &verif_cfg); let test_srv_tm_sender = PacketSenderWithSharedPool::new(tm_tx, shared_tm_pool_wrapper.clone()); - let in_store_converter = EcssTcInSharedPoolConverter::new(shared_tc_pool.clone(), 2048); + let in_store_converter = EcssTcInSharedPoolCacher::new(shared_tc_pool.clone(), 2048); ( Self { pus_buf: RefCell::new([0; 2048]), @@ -1490,12 +1490,8 @@ pub mod tests { tc_sender: mpsc::Sender, tm_receiver: mpsc::Receiver, } - pub type PusServiceHelperDynamic = PusServiceHelper< - MpscTcReceiver, - MpscTmAsVecSender, - EcssTcInVecConverter, - VerificationReporter, - >; + pub type PusServiceHelperDynamic = + PusServiceHelper; impl PusServiceHandlerWithVecCommon { pub fn new_with_standard_verif_reporter( @@ -1507,7 +1503,7 @@ pub mod tests { let verif_cfg = VerificationReporterConfig::new(TEST_APID, 1, 2, 8).unwrap(); let verification_handler = VerificationReporter::new(TEST_COMPONENT_ID_0.id(), &verif_cfg); - let in_store_converter = EcssTcInVecConverter::default(); + let in_store_converter = EcssTcVecCacher::default(); ( Self { current_tm: None, @@ -1533,14 +1529,14 @@ pub mod tests { PusServiceHelper< MpscTcReceiver, MpscTmAsVecSender, - EcssTcInVecConverter, + EcssTcVecCacher, TestVerificationReporter, >, ) { let (test_srv_tc_tx, test_srv_tc_rx) = mpsc::channel(); let (tm_tx, tm_rx) = mpsc::channel(); - let in_store_converter = EcssTcInVecConverter::default(); + let in_store_converter = EcssTcVecCacher::default(); let verification_handler = TestVerificationReporter::new(id); ( Self { diff --git a/satrs/src/pus/scheduler_srv.rs b/satrs/src/pus/scheduler_srv.rs index cf9e45a..7f4658a 100644 --- a/satrs/src/pus/scheduler_srv.rs +++ b/satrs/src/pus/scheduler_srv.rs @@ -1,9 +1,9 @@ use super::scheduler::PusSchedulerProvider; use super::verification::{VerificationReporter, VerificationReportingProvider}; use super::{ - CacheAndReadRawEcssTc, DirectPusPacketHandlerResult, EcssTcInSharedPoolConverter, - EcssTcInVecConverter, EcssTcReceiver, EcssTmSender, HandlingStatus, MpscTcReceiver, - PartialPusHandlingError, PusServiceHelper, + CacheAndReadRawEcssTc, DirectPusPacketHandlerResult, EcssTcInSharedPoolCacher, EcssTcReceiver, + EcssTcVecCacher, EcssTmSender, HandlingStatus, MpscTcReceiver, PartialPusHandlingError, + PusServiceHelper, }; use crate::pool::PoolProvider; use crate::pus::PusPacketHandlingError; @@ -213,7 +213,7 @@ impl< pub type PusService11SchedHandlerDynWithMpsc = PusSchedServiceHandler< MpscTcReceiver, mpsc::Sender, - EcssTcInVecConverter, + EcssTcVecCacher, VerificationReporter, PusScheduler, >; @@ -222,7 +222,7 @@ pub type PusService11SchedHandlerDynWithMpsc = PusSchedServiceHand pub type PusService11SchedHandlerDynWithBoundedMpsc = PusSchedServiceHandler< MpscTcReceiver, mpsc::SyncSender, - EcssTcInVecConverter, + EcssTcVecCacher, VerificationReporter, PusScheduler, >; @@ -231,7 +231,7 @@ pub type PusService11SchedHandlerDynWithBoundedMpsc = PusSchedServ pub type PusService11SchedHandlerStaticWithMpsc = PusSchedServiceHandler< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, PusScheduler, >; @@ -240,7 +240,7 @@ pub type PusService11SchedHandlerStaticWithMpsc = PusSchedServiceH pub type PusService11SchedHandlerStaticWithBoundedMpsc = PusSchedServiceHandler< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, PusScheduler, >; @@ -253,7 +253,7 @@ mod tests { use crate::pus::{DirectPusPacketHandlerResult, MpscTcReceiver, PusPacketHandlingError}; use crate::pus::{ - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, scheduler::{self, PusSchedulerProvider, TcInfo}, tests::PusServiceHandlerWithSharedStoreCommon, verification::{RequestId, TcStateAccepted, VerificationToken}, @@ -278,7 +278,7 @@ mod tests { handler: PusSchedServiceHandler< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, TestScheduler, >, diff --git a/satrs/src/pus/test.rs b/satrs/src/pus/test.rs index a505995..6c1e620 100644 --- a/satrs/src/pus/test.rs +++ b/satrs/src/pus/test.rs @@ -9,8 +9,8 @@ use std::sync::mpsc; use super::verification::{VerificationReporter, VerificationReportingProvider}; use super::{ - CacheAndReadRawEcssTc, EcssTcInSharedPoolConverter, EcssTcInVecConverter, EcssTcReceiver, - EcssTmSender, GenericConversionError, HandlingStatus, MpscTcReceiver, PusServiceHelper, + CacheAndReadRawEcssTc, EcssTcInSharedPoolCacher, EcssTcReceiver, EcssTcVecCacher, EcssTmSender, + GenericConversionError, HandlingStatus, MpscTcReceiver, PusServiceHelper, }; /// This is a helper class for [std] environments to handle generic PUS 17 (test service) packets. @@ -111,7 +111,7 @@ impl< pub type PusService17TestHandlerDynWithMpsc = PusService17TestHandler< MpscTcReceiver, mpsc::Sender, - EcssTcInVecConverter, + EcssTcVecCacher, VerificationReporter, >; /// Helper type definition for a PUS 17 handler with a dynamic TMTC memory backend and bounded MPSC @@ -119,7 +119,7 @@ pub type PusService17TestHandlerDynWithMpsc = PusService17TestHandler< pub type PusService17TestHandlerDynWithBoundedMpsc = PusService17TestHandler< MpscTcReceiver, mpsc::SyncSender, - EcssTcInVecConverter, + EcssTcVecCacher, VerificationReporter, >; /// Helper type definition for a PUS 17 handler with a shared store TMTC memory backend and bounded @@ -127,7 +127,7 @@ pub type PusService17TestHandlerDynWithBoundedMpsc = PusService17TestHandler< pub type PusService17TestHandlerStaticWithBoundedMpsc = PusService17TestHandler< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, >; @@ -143,7 +143,7 @@ mod tests { }; use crate::pus::verification::{TcStateAccepted, VerificationToken}; use crate::pus::{ - DirectPusPacketHandlerResult, EcssTcInSharedPoolConverter, EcssTcInVecConverter, + DirectPusPacketHandlerResult, EcssTcInSharedPoolCacher, EcssTcVecCacher, GenericConversionError, HandlingStatus, MpscTcReceiver, MpscTmAsVecSender, PartialPusHandlingError, PusPacketHandlingError, }; @@ -162,7 +162,7 @@ mod tests { handler: PusService17TestHandler< MpscTcReceiver, PacketSenderWithSharedPool, - EcssTcInSharedPoolConverter, + EcssTcInSharedPoolCacher, VerificationReporter, >, } @@ -224,7 +224,7 @@ mod tests { handler: PusService17TestHandler< MpscTcReceiver, MpscTmAsVecSender, - EcssTcInVecConverter, + EcssTcVecCacher, VerificationReporter, >, }