CCSDS TCP Server #79

Merged
muellerr merged 9 commits from tcp-ccsds-server into main 2023-09-26 15:59:56 +02:00
9 changed files with 369 additions and 147 deletions
Showing only changes of commit f0ccc35e80 - Show all commits

View File

@@ -187,8 +187,12 @@ mod tests {
let tm_source = SyncTmSource::default(); let tm_source = SyncTmSource::default();
let mut packet_id_lookup = HashSet::new(); let mut packet_id_lookup = HashSet::new();
packet_id_lookup.insert(TEST_PACKET_ID_0); packet_id_lookup.insert(TEST_PACKET_ID_0);
let mut tcp_server = let mut tcp_server = generic_tmtc_server(
generic_tmtc_server(&auto_port_addr, tc_receiver.clone(), tm_source, packet_id_lookup); &auto_port_addr,
tc_receiver.clone(),
tm_source,
packet_id_lookup,
);
let dest_addr = tcp_server let dest_addr = tcp_server
.local_addr() .local_addr()
.expect("retrieving dest addr failed"); .expect("retrieving dest addr failed");

View File

@@ -172,7 +172,10 @@ mod tests {
use crate::{ use crate::{
encoding::tests::{INVERTED_PACKET, SIMPLE_PACKET}, encoding::tests::{INVERTED_PACKET, SIMPLE_PACKET},
hal::std::tcp_server::{ServerConfig, tests::{SyncTcCacher, SyncTmSource}}, hal::std::tcp_server::{
tests::{SyncTcCacher, SyncTmSource},
ServerConfig,
},
}; };
use alloc::{boxed::Box, sync::Arc}; use alloc::{boxed::Box, sync::Arc};
use cobs::encode; use cobs::encode;