feat: ✨ change boardcast address

yixiaojiu · Nov 17, 2024 · 182ce10 · 182ce10
1 parent d369af6
commit 182ce10
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/kimika/src/request/udp.rs b/kimika/src/request/udp.rs
@@ -8,7 +8,7 @@ use tokio::time;
 
 pub async fn broadcast(mut close_rx: oneshot::Receiver<()>) -> Result<(), std::io::Error> {
     let socket = UdpSocket::bind("0.0.0.0:0").await?;
-    let broadcast_addr: SocketAddr = ([255, 255, 255, 255], CONFIG.sender.receiver_port).into();
+    let broadcast_addr: SocketAddr = ([224, 0, 0, 139], CONFIG.sender.receiver_port).into();
     socket.set_broadcast(true)?;
 
     loop {

diff --git a/kimika/src/server/udp.rs b/kimika/src/server/udp.rs
@@ -2,7 +2,7 @@ use crate::request::local as request_local;
 use crate::CONFIG;
 
 use serde::{Deserialize, Serialize};
-use std::net::{IpAddr, Ipv4Addr, SocketAddr};
+use std::net::SocketAddr;
 use tokio::net::UdpSocket;
 use tokio::sync::oneshot;
 
@@ -15,9 +15,11 @@ pub struct UDPPacket {
 }
 
 pub async fn listen_boardcast(mut close_rx: oneshot::Receiver<()>) -> Result<(), std::io::Error> {
-    let address = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)), CONFIG.receiver.port);
+    let address: SocketAddr = ([0, 0, 0, 0], CONFIG.sender.receiver_port).into();
     let socket = UdpSocket::bind(address).await?;
     socket.set_broadcast(true)?;
+
+    socket.join_multicast_v4("224.0.0.139".parse().unwrap(), "0.0.0.0".parse().unwrap())?;
     let mut buffer = vec![0u8; BUFFER_SIZE];
 
     loop {