this intermediate struct is not necessary #86
@ -1,4 +1,3 @@
|
|||||||
use alloc::boxed::Box;
|
|
||||||
use alloc::vec;
|
use alloc::vec;
|
||||||
use cobs::encode;
|
use cobs::encode;
|
||||||
use delegate::delegate;
|
use delegate::delegate;
|
||||||
@ -111,11 +110,23 @@ impl<TmError, TcError> TcpTmSender<TmError, TcError> for CobsTmSender {
|
|||||||
///
|
///
|
||||||
/// The [TCP integration tests](https://egit.irs.uni-stuttgart.de/rust/sat-rs/src/branch/main/satrs-core/tests/tcp_servers.rs)
|
/// The [TCP integration tests](https://egit.irs.uni-stuttgart.de/rust/sat-rs/src/branch/main/satrs-core/tests/tcp_servers.rs)
|
||||||
/// test also serves as the example application for this module.
|
/// test also serves as the example application for this module.
|
||||||
pub struct TcpTmtcInCobsServer<TmError, TcError: 'static> {
|
pub struct TcpTmtcInCobsServer<
|
||||||
generic_server: TcpTmtcGenericServer<TmError, TcError, CobsTmSender, CobsTcParser>,
|
TmError,
|
||||||
|
TcError: 'static,
|
||||||
|
TmSource: TmPacketSource<Error = TmError>,
|
||||||
|
TcReceiver: ReceivesTc<Error = TcError>,
|
||||||
|
> {
|
||||||
|
generic_server:
|
||||||
|
TcpTmtcGenericServer<TmError, TcError, TmSource, TcReceiver, CobsTmSender, CobsTcParser>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<TmError: 'static, TcError: 'static> TcpTmtcInCobsServer<TmError, TcError> {
|
impl<
|
||||||
|
TmError: 'static,
|
||||||
|
TcError: 'static,
|
||||||
|
TmSource: TmPacketSource<Error = TmError>,
|
||||||
|
TcReceiver: ReceivesTc<Error = TcError>,
|
||||||
|
> TcpTmtcInCobsServer<TmError, TcError, TmSource, TcReceiver>
|
||||||
|
{
|
||||||
/// Create a new TCP TMTC server which exchanges TMTC packets encoded with
|
/// Create a new TCP TMTC server which exchanges TMTC packets encoded with
|
||||||
/// [COBS protocol](https://en.wikipedia.org/wiki/Consistent_Overhead_Byte_Stuffing).
|
/// [COBS protocol](https://en.wikipedia.org/wiki/Consistent_Overhead_Byte_Stuffing).
|
||||||
///
|
///
|
||||||
@ -128,8 +139,8 @@ impl<TmError: 'static, TcError: 'static> TcpTmtcInCobsServer<TmError, TcError> {
|
|||||||
/// forwarded to this TC receiver.
|
/// forwarded to this TC receiver.
|
||||||
pub fn new(
|
pub fn new(
|
||||||
cfg: ServerConfig,
|
cfg: ServerConfig,
|
||||||
tm_source: Box<dyn TmPacketSource<Error = TmError>>,
|
tm_source: TmSource,
|
||||||
tc_receiver: Box<dyn ReceivesTc<Error = TcError>>,
|
tc_receiver: TcReceiver,
|
||||||
) -> Result<Self, TcpTmtcError<TmError, TcError>> {
|
) -> Result<Self, TcpTmtcError<TmError, TcError>> {
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
generic_server: TcpTmtcGenericServer::new(
|
generic_server: TcpTmtcGenericServer::new(
|
||||||
@ -177,7 +188,7 @@ mod tests {
|
|||||||
ServerConfig,
|
ServerConfig,
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
use alloc::{boxed::Box, sync::Arc};
|
use alloc::sync::Arc;
|
||||||
use cobs::encode;
|
use cobs::encode;
|
||||||
|
|
||||||
use super::TcpTmtcInCobsServer;
|
use super::TcpTmtcInCobsServer;
|
||||||
@ -202,11 +213,11 @@ mod tests {
|
|||||||
addr: &SocketAddr,
|
addr: &SocketAddr,
|
||||||
tc_receiver: SyncTcCacher,
|
tc_receiver: SyncTcCacher,
|
||||||
tm_source: SyncTmSource,
|
tm_source: SyncTmSource,
|
||||||
) -> TcpTmtcInCobsServer<(), ()> {
|
) -> TcpTmtcInCobsServer<(), (), SyncTmSource, SyncTcCacher> {
|
||||||
TcpTmtcInCobsServer::new(
|
TcpTmtcInCobsServer::new(
|
||||||
ServerConfig::new(*addr, Duration::from_millis(2), 1024, 1024),
|
ServerConfig::new(*addr, Duration::from_millis(2), 1024, 1024),
|
||||||
Box::new(tm_source),
|
tm_source,
|
||||||
Box::new(tc_receiver),
|
tc_receiver,
|
||||||
)
|
)
|
||||||
.expect("TCP server generation failed")
|
.expect("TCP server generation failed")
|
||||||
}
|
}
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
//! Generic TCP TMTC servers with different TMTC format flavours.
|
//! Generic TCP TMTC servers with different TMTC format flavours.
|
||||||
use alloc::vec;
|
use alloc::vec;
|
||||||
use alloc::{boxed::Box, vec::Vec};
|
use alloc::vec::Vec;
|
||||||
use core::time::Duration;
|
use core::time::Duration;
|
||||||
use socket2::{Domain, Socket, Type};
|
use socket2::{Domain, Socket, Type};
|
||||||
use std::io::Read;
|
use std::io::Read;
|
||||||
@ -134,26 +134,30 @@ pub trait TcpTmSender<TmError, TcError> {
|
|||||||
pub struct TcpTmtcGenericServer<
|
pub struct TcpTmtcGenericServer<
|
||||||
TmError,
|
TmError,
|
||||||
TcError,
|
TcError,
|
||||||
TmHandler: TcpTmSender<TmError, TcError>,
|
TmSource: TmPacketSource<Error = TmError>,
|
||||||
TcHandler: TcpTcParser<TmError, TcError>,
|
TcReceiver: ReceivesTc<Error = TcError>,
|
||||||
|
TmSender: TcpTmSender<TmError, TcError>,
|
||||||
|
TcParser: TcpTcParser<TmError, TcError>,
|
||||||
> {
|
> {
|
||||||
// base: TcpTmtcServerBase<TmError, TcError>,
|
// base: TcpTmtcServerBase<TmError, TcError>,
|
||||||
pub(crate) listener: TcpListener,
|
pub(crate) listener: TcpListener,
|
||||||
pub(crate) inner_loop_delay: Duration,
|
pub(crate) inner_loop_delay: Duration,
|
||||||
pub(crate) tm_source: Box<dyn TmPacketSource<Error = TmError>>,
|
pub(crate) tm_source: TmSource,
|
||||||
pub(crate) tm_buffer: Vec<u8>,
|
pub(crate) tm_buffer: Vec<u8>,
|
||||||
pub(crate) tc_receiver: Box<dyn ReceivesTc<Error = TcError>>,
|
pub(crate) tc_receiver: TcReceiver,
|
||||||
pub(crate) tc_buffer: Vec<u8>,
|
pub(crate) tc_buffer: Vec<u8>,
|
||||||
tc_handler: TcHandler,
|
tc_handler: TcParser,
|
||||||
tm_handler: TmHandler,
|
tm_handler: TmSender,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<
|
impl<
|
||||||
TmError: 'static,
|
TmError: 'static,
|
||||||
TcError: 'static,
|
TcError: 'static,
|
||||||
|
TmSource: TmPacketSource<Error = TmError>,
|
||||||
|
TcReceiver: ReceivesTc<Error = TcError>,
|
||||||
TmSender: TcpTmSender<TmError, TcError>,
|
TmSender: TcpTmSender<TmError, TcError>,
|
||||||
TcParser: TcpTcParser<TmError, TcError>,
|
TcParser: TcpTcParser<TmError, TcError>,
|
||||||
> TcpTmtcGenericServer<TmError, TcError, TmSender, TcParser>
|
> TcpTmtcGenericServer<TmError, TcError, TmSource, TcReceiver, TmSender, TcParser>
|
||||||
{
|
{
|
||||||
/// Create a new generic TMTC server instance.
|
/// Create a new generic TMTC server instance.
|
||||||
///
|
///
|
||||||
@ -171,9 +175,9 @@ impl<
|
|||||||
cfg: ServerConfig,
|
cfg: ServerConfig,
|
||||||
tc_parser: TcParser,
|
tc_parser: TcParser,
|
||||||
tm_sender: TmSender,
|
tm_sender: TmSender,
|
||||||
tm_source: Box<dyn TmPacketSource<Error = TmError>>,
|
tm_source: TmSource,
|
||||||
tc_receiver: Box<dyn ReceivesTc<Error = TcError>>,
|
tc_receiver: TcReceiver,
|
||||||
) -> Result<TcpTmtcGenericServer<TmError, TcError, TmSender, TcParser>, std::io::Error> {
|
) -> Result<Self, std::io::Error> {
|
||||||
// Create a TCP listener bound to two addresses.
|
// Create a TCP listener bound to two addresses.
|
||||||
let socket = Socket::new(Domain::IPV4, Type::STREAM, None)?;
|
let socket = Socket::new(Domain::IPV4, Type::STREAM, None)?;
|
||||||
socket.set_reuse_address(cfg.reuse_addr)?;
|
socket.set_reuse_address(cfg.reuse_addr)?;
|
||||||
@ -236,7 +240,7 @@ impl<
|
|||||||
if current_write_idx > 0 {
|
if current_write_idx > 0 {
|
||||||
self.tc_handler.handle_tc_parsing(
|
self.tc_handler.handle_tc_parsing(
|
||||||
&mut self.tc_buffer,
|
&mut self.tc_buffer,
|
||||||
self.tc_receiver.as_mut(),
|
&mut self.tc_receiver,
|
||||||
&mut connection_result,
|
&mut connection_result,
|
||||||
current_write_idx,
|
current_write_idx,
|
||||||
&mut next_write_idx,
|
&mut next_write_idx,
|
||||||
@ -250,7 +254,7 @@ impl<
|
|||||||
if current_write_idx == self.tc_buffer.capacity() {
|
if current_write_idx == self.tc_buffer.capacity() {
|
||||||
self.tc_handler.handle_tc_parsing(
|
self.tc_handler.handle_tc_parsing(
|
||||||
&mut self.tc_buffer,
|
&mut self.tc_buffer,
|
||||||
self.tc_receiver.as_mut(),
|
&mut self.tc_receiver,
|
||||||
&mut connection_result,
|
&mut connection_result,
|
||||||
current_write_idx,
|
current_write_idx,
|
||||||
&mut next_write_idx,
|
&mut next_write_idx,
|
||||||
@ -264,7 +268,7 @@ impl<
|
|||||||
std::io::ErrorKind::WouldBlock | std::io::ErrorKind::TimedOut => {
|
std::io::ErrorKind::WouldBlock | std::io::ErrorKind::TimedOut => {
|
||||||
self.tc_handler.handle_tc_parsing(
|
self.tc_handler.handle_tc_parsing(
|
||||||
&mut self.tc_buffer,
|
&mut self.tc_buffer,
|
||||||
self.tc_receiver.as_mut(),
|
&mut self.tc_receiver,
|
||||||
&mut connection_result,
|
&mut connection_result,
|
||||||
current_write_idx,
|
current_write_idx,
|
||||||
&mut next_write_idx,
|
&mut next_write_idx,
|
||||||
@ -273,7 +277,7 @@ impl<
|
|||||||
|
|
||||||
if !self.tm_handler.handle_tm_sending(
|
if !self.tm_handler.handle_tm_sending(
|
||||||
&mut self.tm_buffer,
|
&mut self.tm_buffer,
|
||||||
self.tm_source.as_mut(),
|
&mut self.tm_source,
|
||||||
&mut connection_result,
|
&mut connection_result,
|
||||||
&mut stream,
|
&mut stream,
|
||||||
)? {
|
)? {
|
||||||
@ -290,7 +294,7 @@ impl<
|
|||||||
}
|
}
|
||||||
self.tm_handler.handle_tm_sending(
|
self.tm_handler.handle_tm_sending(
|
||||||
&mut self.tm_buffer,
|
&mut self.tm_buffer,
|
||||||
self.tm_source.as_mut(),
|
&mut self.tm_source,
|
||||||
&mut connection_result,
|
&mut connection_result,
|
||||||
&mut stream,
|
&mut stream,
|
||||||
)?;
|
)?;
|
||||||
|
@ -88,16 +88,31 @@ impl<TmError, TcError> TcpTmSender<TmError, TcError> for SpacepacketsTmSender {
|
|||||||
/// [spacepackets::PacketId]s as part of the server configuration for that purpose.
|
/// [spacepackets::PacketId]s as part of the server configuration for that purpose.
|
||||||
///
|
///
|
||||||
/// ## Example
|
/// ## Example
|
||||||
///
|
|
||||||
/// The [TCP server integration tests](https://egit.irs.uni-stuttgart.de/rust/sat-rs/src/branch/main/satrs-core/tests/tcp_servers.rs)
|
/// The [TCP server integration tests](https://egit.irs.uni-stuttgart.de/rust/sat-rs/src/branch/main/satrs-core/tests/tcp_servers.rs)
|
||||||
/// also serves as the example application for this module.
|
/// also serves as the example application for this module.
|
||||||
pub struct TcpSpacepacketsServer<TmError, TcError: 'static> {
|
pub struct TcpSpacepacketsServer<
|
||||||
generic_server:
|
TmError,
|
||||||
TcpTmtcGenericServer<TmError, TcError, SpacepacketsTmSender, SpacepacketsTcParser>,
|
TcError: 'static,
|
||||||
|
TmSource: TmPacketSource<Error = TmError>,
|
||||||
|
TcReceiver: ReceivesTc<Error = TcError>,
|
||||||
|
> {
|
||||||
|
generic_server: TcpTmtcGenericServer<
|
||||||
|
TmError,
|
||||||
|
TcError,
|
||||||
|
TmSource,
|
||||||
|
TcReceiver,
|
||||||
|
SpacepacketsTmSender,
|
||||||
|
SpacepacketsTcParser,
|
||||||
|
>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<TmError: 'static, TcError: 'static> TcpSpacepacketsServer<TmError, TcError> {
|
impl<
|
||||||
/// Create a new TCP TMTC server which exchanges CCSDS space packets.
|
TmError: 'static,
|
||||||
|
TcError: 'static,
|
||||||
|
TmSource: TmPacketSource<Error = TmError>,
|
||||||
|
TcReceiver: ReceivesTc<Error = TcError>,
|
||||||
|
> TcpSpacepacketsServer<TmError, TcError, TmSource, TcReceiver>
|
||||||
|
{
|
||||||
///
|
///
|
||||||
/// ## Parameter
|
/// ## Parameter
|
||||||
///
|
///
|
||||||
@ -110,8 +125,8 @@ impl<TmError: 'static, TcError: 'static> TcpSpacepacketsServer<TmError, TcError>
|
|||||||
/// parsing. This mechanism is used to have a start marker for finding CCSDS packets.
|
/// parsing. This mechanism is used to have a start marker for finding CCSDS packets.
|
||||||
pub fn new(
|
pub fn new(
|
||||||
cfg: ServerConfig,
|
cfg: ServerConfig,
|
||||||
tm_source: Box<dyn TmPacketSource<Error = TmError>>,
|
tm_source: TmSource,
|
||||||
tc_receiver: Box<dyn ReceivesTc<Error = TcError>>,
|
tc_receiver: TcReceiver,
|
||||||
packet_id_lookup: Box<dyn PacketIdLookup + Send>,
|
packet_id_lookup: Box<dyn PacketIdLookup + Send>,
|
||||||
) -> Result<Self, TcpTmtcError<TmError, TcError>> {
|
) -> Result<Self, TcpTmtcError<TmError, TcError>> {
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
@ -179,11 +194,11 @@ mod tests {
|
|||||||
tc_receiver: SyncTcCacher,
|
tc_receiver: SyncTcCacher,
|
||||||
tm_source: SyncTmSource,
|
tm_source: SyncTmSource,
|
||||||
packet_id_lookup: HashSet<PacketId>,
|
packet_id_lookup: HashSet<PacketId>,
|
||||||
) -> TcpSpacepacketsServer<(), ()> {
|
) -> TcpSpacepacketsServer<(), (), SyncTmSource, SyncTcCacher> {
|
||||||
TcpSpacepacketsServer::new(
|
TcpSpacepacketsServer::new(
|
||||||
ServerConfig::new(*addr, Duration::from_millis(2), 1024, 1024),
|
ServerConfig::new(*addr, Duration::from_millis(2), 1024, 1024),
|
||||||
Box::new(tm_source),
|
tm_source,
|
||||||
Box::new(tc_receiver),
|
tc_receiver,
|
||||||
Box::new(packet_id_lookup),
|
Box::new(packet_id_lookup),
|
||||||
)
|
)
|
||||||
.expect("TCP server generation failed")
|
.expect("TCP server generation failed")
|
||||||
|
@ -94,8 +94,8 @@ fn test_cobs_server() {
|
|||||||
tm_source.add_tm(&INVERTED_PACKET);
|
tm_source.add_tm(&INVERTED_PACKET);
|
||||||
let mut tcp_server = TcpTmtcInCobsServer::new(
|
let mut tcp_server = TcpTmtcInCobsServer::new(
|
||||||
ServerConfig::new(AUTO_PORT_ADDR, Duration::from_millis(2), 1024, 1024),
|
ServerConfig::new(AUTO_PORT_ADDR, Duration::from_millis(2), 1024, 1024),
|
||||||
Box::new(tm_source),
|
tm_source,
|
||||||
Box::new(tc_receiver.clone()),
|
tc_receiver.clone(),
|
||||||
)
|
)
|
||||||
.expect("TCP server generation failed");
|
.expect("TCP server generation failed");
|
||||||
let dest_addr = tcp_server
|
let dest_addr = tcp_server
|
||||||
@ -176,8 +176,8 @@ fn test_ccsds_server() {
|
|||||||
packet_id_lookup.insert(TEST_PACKET_ID_0);
|
packet_id_lookup.insert(TEST_PACKET_ID_0);
|
||||||
let mut tcp_server = TcpSpacepacketsServer::new(
|
let mut tcp_server = TcpSpacepacketsServer::new(
|
||||||
ServerConfig::new(AUTO_PORT_ADDR, Duration::from_millis(2), 1024, 1024),
|
ServerConfig::new(AUTO_PORT_ADDR, Duration::from_millis(2), 1024, 1024),
|
||||||
Box::new(tm_source),
|
tm_source,
|
||||||
Box::new(tc_receiver.clone()),
|
tc_receiver.clone(),
|
||||||
Box::new(packet_id_lookup),
|
Box::new(packet_id_lookup),
|
||||||
)
|
)
|
||||||
.expect("TCP server generation failed");
|
.expect("TCP server generation failed");
|
||||||
|
Loading…
Reference in New Issue
Block a user