forked from smoltcp-rs/smoltcp
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Update PR smoltcp-rs#602: implement
join_multicast_group() for IPv6
This patch rebases @jgallagher's to the tip of the main branch, adding support for IPv6 multicast groups. As in the original PR, it is only possible to join groups by sending an initial MLDv2 Report packet. It is not yet possible to resend the change report, leave groups, respond to queries, etc.
- Loading branch information
Showing
17 changed files
with
559 additions
and
22 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,90 @@ | ||
| mod utils; | ||
|
|
||
| use std::os::unix::io::AsRawFd; | ||
|
|
||
| use smoltcp::iface::{Config, Interface, SocketSet}; | ||
| use smoltcp::phy::wait as phy_wait; | ||
| use smoltcp::phy::{Device, Medium}; | ||
| use smoltcp::socket::udp; | ||
| use smoltcp::time::Instant; | ||
| use smoltcp::wire::{EthernetAddress, IpAddress, IpCidr, Ipv6Address}; | ||
|
|
||
| // Note: If testing with a tap interface in linux, you may need to specify the | ||
| // interface index when addressing. E.g., | ||
| // | ||
| // ``` | ||
| // ncat -u ff02::1234%tap0 8123 | ||
| // ``` | ||
| // | ||
| // will send packets to the multicast group we join below on tap0. | ||
|
|
||
| const PORT: u16 = 8123; | ||
| const GROUP: [u16; 8] = [0xff02, 0, 0, 0, 0, 0, 0, 0x1234]; | ||
| const LOCAL_ADDR: [u16; 8] = [0xfe80, 0, 0, 0, 0, 0, 0, 0x101]; | ||
| const ROUTER_ADDR: [u16; 8] = [0xfe80, 0, 0, 0, 0, 0, 0, 0x100]; | ||
|
|
||
| fn main() { | ||
| utils::setup_logging("warn"); | ||
|
|
||
| let (mut opts, mut free) = utils::create_options(); | ||
| utils::add_tuntap_options(&mut opts, &mut free); | ||
| utils::add_middleware_options(&mut opts, &mut free); | ||
|
|
||
| let mut matches = utils::parse_options(&opts, free); | ||
| let device = utils::parse_tuntap_options(&mut matches); | ||
| let fd = device.as_raw_fd(); | ||
| let mut device = | ||
| utils::parse_middleware_options(&mut matches, device, /*loopback=*/ false); | ||
|
|
||
| // Create interface | ||
| let local_addr = Ipv6Address::from_parts(&LOCAL_ADDR); | ||
| let ethernet_addr = EthernetAddress([0x02, 0x00, 0x00, 0x00, 0x00, 0x02]); | ||
| let mut config = match device.capabilities().medium { | ||
| Medium::Ethernet => Config::new(ethernet_addr.into()), | ||
| Medium::Ip => Config::new(smoltcp::wire::HardwareAddress::Ip), | ||
| Medium::Ieee802154 => todo!(), | ||
| }; | ||
| config.random_seed = rand::random(); | ||
|
|
||
| let mut iface = Interface::new(config, &mut device, Instant::now()); | ||
| iface.update_ip_addrs(|ip_addrs| { | ||
| ip_addrs | ||
| .push(IpCidr::new(IpAddress::from(local_addr), 64)) | ||
| .unwrap(); | ||
| }); | ||
| iface | ||
| .routes_mut() | ||
| .add_default_ipv6_route(Ipv6Address::from_parts(&ROUTER_ADDR)) | ||
| .unwrap(); | ||
|
|
||
| // Create sockets | ||
| let mut sockets = SocketSet::new(vec![]); | ||
| let udp_rx_buffer = udp::PacketBuffer::new(vec![udp::PacketMetadata::EMPTY; 4], vec![0; 1024]); | ||
| let udp_tx_buffer = udp::PacketBuffer::new(vec![udp::PacketMetadata::EMPTY], vec![0; 0]); | ||
| let udp_socket = udp::Socket::new(udp_rx_buffer, udp_tx_buffer); | ||
| let udp_handle = sockets.add(udp_socket); | ||
|
|
||
| // Join a multicast group | ||
| iface | ||
| .join_multicast_group(&mut device, Ipv6Address::from_parts(&GROUP), Instant::now()) | ||
| .unwrap(); | ||
|
|
||
| loop { | ||
| let timestamp = Instant::now(); | ||
| iface.poll(timestamp, &mut device, &mut sockets); | ||
|
|
||
| let socket = sockets.get_mut::<udp::Socket>(udp_handle); | ||
| if !socket.is_open() { | ||
| socket.bind(PORT).unwrap() | ||
| } | ||
|
|
||
| if socket.can_recv() { | ||
| socket | ||
| .recv() | ||
| .map(|(data, sender)| println!("traffic: {} UDP bytes from {}", data.len(), sender)) | ||
| .unwrap_or_else(|e| println!("Recv UDP error: {:?}", e)); | ||
| } | ||
|
|
||
| phy_wait(fd, iface.poll_delay(timestamp, &sockets)).expect("wait error"); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.