diff --git a/satrs-example/Cargo.toml b/satrs-example/Cargo.toml index bbdaa89..93b1906 100644 --- a/satrs-example/Cargo.toml +++ b/satrs-example/Cargo.toml @@ -26,16 +26,9 @@ bitbybit = "1.4" serde = { version = "1", features = ["derive"] } serde_json = "1" -[dependencies.satrs] -path = "../satrs" -features = ["test_util"] - -[dependencies.satrs-minisim] -path = "../satrs-minisim" - -[dependencies.satrs-mib] -version = "0.1.1" -path = "../satrs-mib" +satrs = { path = "../satrs", features = ["test_util"] } +satrs-minisim = { path = "../satrs-minisim" } +satrs-mib = { path = "../satrs-mib" } [features] default = ["heap_tmtc"] diff --git a/satrs-example/src/pus/action.rs b/satrs-example/src/legacy/pus/action.rs similarity index 100% rename from satrs-example/src/pus/action.rs rename to satrs-example/src/legacy/pus/action.rs diff --git a/satrs-example/src/pus/event.rs b/satrs-example/src/legacy/pus/event.rs similarity index 100% rename from satrs-example/src/pus/event.rs rename to satrs-example/src/legacy/pus/event.rs diff --git a/satrs-example/src/pus/hk.rs b/satrs-example/src/legacy/pus/hk.rs similarity index 100% rename from satrs-example/src/pus/hk.rs rename to satrs-example/src/legacy/pus/hk.rs diff --git a/satrs-example/src/pus/mod.rs b/satrs-example/src/legacy/pus/mod.rs similarity index 99% rename from satrs-example/src/pus/mod.rs rename to satrs-example/src/legacy/pus/mod.rs index 5bcdb24..61d0a0a 100644 --- a/satrs-example/src/pus/mod.rs +++ b/satrs-example/src/legacy/pus/mod.rs @@ -39,6 +39,7 @@ pub fn create_verification_reporter(owner_id: ComponentId, apid: Apid) -> Verifi VerificationReporter::new(owner_id, &verif_cfg) } +/* /// Simple router structure which forwards PUS telecommands to dedicated handlers. pub struct PusTcMpscRouter { pub test_tc_sender: mpsc::SyncSender, @@ -187,6 +188,7 @@ impl PusTcDistributor { Ok(HandlingStatus::HandledOne) } } +*/ pub trait TargetedPusService { const SERVICE_ID: u8; diff --git a/satrs-example/src/pus/mode.rs b/satrs-example/src/legacy/pus/mode.rs similarity index 100% rename from satrs-example/src/pus/mode.rs rename to satrs-example/src/legacy/pus/mode.rs diff --git a/satrs-example/src/pus/scheduler.rs b/satrs-example/src/legacy/pus/scheduler.rs similarity index 100% rename from satrs-example/src/pus/scheduler.rs rename to satrs-example/src/legacy/pus/scheduler.rs diff --git a/satrs-example/src/pus/stack.rs b/satrs-example/src/legacy/pus/stack.rs similarity index 100% rename from satrs-example/src/pus/stack.rs rename to satrs-example/src/legacy/pus/stack.rs diff --git a/satrs-example/src/pus/test.rs b/satrs-example/src/legacy/pus/test.rs similarity index 100% rename from satrs-example/src/pus/test.rs rename to satrs-example/src/legacy/pus/test.rs diff --git a/satrs-example/src/main.rs b/satrs-example/src/main.rs index 4e7577e..8486081 100644 --- a/satrs-example/src/main.rs +++ b/satrs-example/src/main.rs @@ -18,6 +18,7 @@ use interface::{ }; use log::info; use logger::setup_logger; +/* use pus::{ action::create_action_service, event::create_event_service, @@ -28,6 +29,7 @@ use pus::{ test::create_test_service, PusTcDistributor, PusTcMpscRouter, }; +*/ use requests::GenericRequestRouter; use satrs::{ hal::std::{tcp_server::ServerConfig, udp_server::UdpTcServer}, @@ -78,7 +80,7 @@ mod events; mod hk; mod interface; mod logger; -mod pus; +//mod pus; mod requests; mod spi; mod tmtc; @@ -177,6 +179,7 @@ fn main() { let tc_releaser = TcReleaser::Heap(tc_source_tx.clone()); } } + /* let pus_router = PusTcMpscRouter { test_tc_sender: pus_test_tx, event_tc_sender: pus_event_tx, @@ -233,6 +236,7 @@ fn main() { pus_scheduler_service, pus_mode_service, ); + */ cfg_if::cfg_if! { if #[cfg(not(feature = "heap_tmtc"))] { diff --git a/satrs-example/src/tmtc/tc_source.rs b/satrs-example/src/tmtc/tc_source.rs index 00b6d87..41e3560 100644 --- a/satrs-example/src/tmtc/tc_source.rs +++ b/satrs-example/src/tmtc/tc_source.rs @@ -2,8 +2,12 @@ use satrs::{ pool::PoolProvider, pus::HandlingStatus, tmtc::{PacketAsVec, PacketInPool, SharedPacketPool}, + ComponentId, +}; +use std::{ + collections::HashMap, + sync::mpsc::{self, TryRecvError}, }; -use std::sync::mpsc::{self, TryRecvError}; use crate::pus::PusTcDistributor; @@ -65,18 +69,24 @@ impl TcSourceTaskStatic { } } +pub type CcsdsDistributorDyn = HashMap>; +pub type CcsdsDistributorStatic = HashMap>; + // TC source components where the heap is the backing memory of the received telecommands. pub struct TcSourceTaskDynamic { pub tc_receiver: mpsc::Receiver, - pus_distributor: PusTcDistributor, + ccsds_distributor: CcsdsDistributorDyn, } #[allow(dead_code)] impl TcSourceTaskDynamic { - pub fn new(tc_receiver: mpsc::Receiver, pus_receiver: PusTcDistributor) -> Self { + pub fn new( + tc_receiver: mpsc::Receiver, + ccsds_distributor: CcsdsDistributorDyn, + ) -> Self { Self { tc_receiver, - pus_distributor: pus_receiver, + ccsds_distributor, } }