reactor
/
lookaround
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

oops that wasn't it

main
_ 2021-12-05 20:22:12 +00:00
parent 570458c72c
commit be43b3ab55
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main.rs
View File

@ -137,8 +137,9 @@ fn server () -> Result <(), AppError> {
let params = CommonParams::default (); let params = CommonParams::default ();
let socket = UdpSocket::bind (SocketAddrV4::new (Ipv4Addr::UNSPECIFIED, params.server_port)).unwrap (); let socket = UdpSocket::bind (SocketAddrV4::new (Ipv4Addr::UNSPECIFIED, params.server_port)).unwrap ();
loop {
socket.join_multicast_v4 (&params.multicast_addr, &([0u8, 0, 0, 0].into ())).unwrap (); socket.join_multicast_v4 (&params.multicast_addr, &([0u8, 0, 0, 0].into ())).unwrap ();
loop {
println! ("Waiting for messages..."); println! ("Waiting for messages...");
let (req, remote_addr) = recv_msg_from (&socket)?; let (req, remote_addr) = recv_msg_from (&socket)?;