rustdds 0.3.0

Rust DDS implementation with RTPS
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use std::{
  net::{SocketAddr, IpAddr},
  io::Error,
};

use crate::structure::locator::{LocatorList, Locator};

pub fn get_local_multicast_locators(port: u16) -> LocatorList {
  let saddr = SocketAddr::new("239.255.0.1".parse().unwrap(), port);
  vec![Locator::from(saddr)]
}

pub fn get_local_unicast_socket_address(port: u16) -> LocatorList {
  let local_ips: Result<Vec<IpAddr>, Error> = get_if_addrs::get_if_addrs().map(|p| {
    p.iter()
      .filter(|ip| !ip.is_loopback())
      .map(|ip| ip.ip())
      .collect()
  });

  match local_ips {
    Ok(ips) => {
      let loc = ips
        .into_iter()
        .map(|p| SocketAddr::new(p, port))
        .map(|p| Locator::from(p))
        .next();
      match loc {
        Some(l) => vec![l],
        None => vec![],
      }
    }
    _ => vec![],
  }
}