Struct UdpServer 

pub struct UdpServer { /* private fields */ }

UDP server for receiving OpenIGTLink messages

Listens for incoming datagrams on a specific port.

Examples

use openigtlink_rust::io::UdpServer;
use openigtlink_rust::protocol::types::TransformMessage;
use openigtlink_rust::protocol::message::IgtlMessage;

let server = UdpServer::bind("0.0.0.0:18944")?;

loop {
    let (msg, sender) = server.receive::<TransformMessage>()?;
    println!("Received from {}", sender);

    // Echo back
    let response = IgtlMessage::new(msg.content, "Server")?;
    server.send_to(&response, sender)?;

}

Implementations

impl UdpServer

pub fn bind(addr: &str) -> Result<Self>

Bind server to an address

Arguments

• addr - Address to bind (e.g., “0.0.0.0:18944”)

Errors

• IgtlError::Io - Failed to bind (port in use, permission denied, etc.)

Examples

use openigtlink_rust::io::UdpServer;

let server = UdpServer::bind("0.0.0.0:18944")?;

pub fn receive<T: Message>(&self) -> Result<(IgtlMessage<T>, SocketAddr)>

Receive a message (blocking)

Returns

Tuple of (message, sender_address)

Errors

• IgtlError::Io - Network read failed or timeout
• IgtlError::InvalidHeader - Malformed header
• IgtlError::CrcMismatch - Data corruption

pub fn send_to<T: Message>( &self, msg: &IgtlMessage<T>, target: SocketAddr, ) -> Result<()>

Send a response to a specific address

Arguments

• msg - Message to send
• target - Target socket address

Errors

• IgtlError::Io - Network transmission failed
• IgtlError::BodyTooLarge - Message exceeds UDP MTU

pub fn set_read_timeout(&self, timeout: Option<Duration>) -> Result<()>

Set read timeout

Arguments

• timeout - Timeout duration (None for blocking forever)

Errors

• IgtlError::Io - Failed to set socket option

pub fn local_addr(&self) -> Result<SocketAddr>

Get local socket address

Errors

• IgtlError::Io - Failed to get socket address