max/flood-rs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixed things

Browse source
This commit is contained in:
0m.ax 2025-07-20 16:46:54 +02:00
parent fa4cfcd7b8
commit 237e4534bf
1 changed files with 3 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/main.rs
View file

@ -327,17 +327,11 @@ fn main() {
let bind_address = format!("0.0.0.0:12345"); let bind_address = format!("0.0.0.0:12345");
let socket = Socket::new(Domain::IPV4, Type::DGRAM, None).unwrap(); let socket = Socket::new(Domain::IPV4, Type::DGRAM, None).unwrap();
socket.set_reuse_address(true).unwrap(); socket.set_reuse_address(true).unwrap();
socket.set_nonblocking(true).unwrap(); //socket.set_nonblocking(true).unwrap();
socket.join_multicast_v4(&Ipv4Addr::new(239, 1, 1, 1), &Ipv4Addr::new(0, 0, 0, 0)).unwrap(); socket.join_multicast_v4(&Ipv4Addr::new(239, 1, 1, 1), &Ipv4Addr::new(0, 0, 0, 0)).unwrap();
socket.bind(&"0.0.0.0:12345".parse::<SocketAddr>().unwrap().into()).unwrap(); socket.bind(&"0.0.0.0:1234".parse::<SocketAddr>().unwrap().into()).unwrap();
// Bind the UDP socket to the specified address and port. // Bind the UDP socket to the specified address and port.
let socket = match UdpSocket::bind(&bind_address) { let socket: UdpSocket = socket.into();
Ok(s) => s,
Err(e) => {
eprintln!("Error: Could not bind to address {}: {}", bind_address, e);
panic!("aaaa");
}
};
println!("Listening for UDP packets on {}", bind_address); println!("Listening for UDP packets on {}", bind_address);