Struct UdpTcServer 

pub struct UdpTcServer<E> {
    pub socket: UdpSocket,
    /* private fields */
}

Available on crate feature std only.

This UDP server can be used to receive CCSDS space packet telecommands or any other telecommand format.

It caches all received telecomands into a vector. The maximum expected telecommand size should be declared upfront. This avoids dynamic allocation during run-time. The user can specify a TC receiver in form of a special trait object which implements ReceivesTc. Please note that the receiver should copy out the received data if it the data is required past the ReceivesTcCore::pass_tc call.

Examples

use std::net::{IpAddr, Ipv4Addr, SocketAddr, UdpSocket};
use spacepackets::ecss::WritablePusPacket;
use satrs_core::hal::std::udp_server::UdpTcServer;
use satrs_core::tmtc::{ReceivesTc, ReceivesTcCore};
use spacepackets::SpHeader;
use spacepackets::ecss::tc::PusTcCreator;

#[derive (Default)]
struct PingReceiver {}
impl ReceivesTcCore for PingReceiver {
   type Error = ();
   fn pass_tc(&mut self, tc_raw: &[u8]) -> Result<(), Self::Error> {
        assert_eq!(tc_raw.len(), 13);
        Ok(())
    }
}

let mut buf = [0; 32];
let dest_addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 7777);
let ping_receiver = PingReceiver::default();
let mut udp_tc_server = UdpTcServer::new(dest_addr, 2048, Box::new(ping_receiver))
      .expect("Creating UDP TMTC server failed");
let mut sph = SpHeader::tc_unseg(0x02, 0, 0).unwrap();
let pus_tc = PusTcCreator::new_simple(&mut sph, 17, 1, None, true);
let len = pus_tc
    .write_to_bytes(&mut buf)
    .expect("Error writing PUS TC packet");
assert_eq!(len, 13);
let client = UdpSocket::bind("127.0.0.1:7778").expect("Connecting to UDP server failed");
client
    .send_to(&buf[0..len], dest_addr)
    .expect("Error sending PUS TC via UDP");

The satrs-example crate server code also includes example code on how to use this TC server. It uses the server to receive PUS telecommands on a specific port and then forwards them to a generic CCSDS packet receiver.

Fields

socket: UdpSocket

Implementations

impl<E: 'static> UdpTcServer<E>

pub fn new<A: ToSocketAddrs>( addr: A, max_recv_size: usize, tc_receiver: Box<dyn ReceivesTc<Error = E>>, ) -> Result<Self, Error>

pub fn try_recv_tc(&mut self) -> Result<(usize, SocketAddr), ReceiveResult<E>>

pub fn last_sender(&self) -> Option<SocketAddr>

Trait Implementations

impl<E: 'static> ReceivesTcCore for UdpTcServer<E>

type Error = E

fn pass_tc(&mut self, tc_raw: &[u8]) -> Result<(), Self::Error>