diff options
| author | HimbeerserverDE <himbeerserverde@gmail.com> | 2023-03-04 19:56:07 +0100 |
|---|---|---|
| committer | HimbeerserverDE <himbeerserverde@gmail.com> | 2023-03-04 19:56:07 +0100 |
| commit | abc2262a3c1aac373bbb9dfb4f7b9fe712ceff3d (patch) | |
| tree | 7b63c511ad17c8ebc91af4b8dad95c010398f5a9 /src/main.rs | |
| parent | d95a5eb2d55c54425663ef8cb042809b5a552f30 (diff) | |
broadcast the responses
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/main.rs b/src/main.rs index 51468cf..cb4ae62 100644 --- a/src/main.rs +++ b/src/main.rs @@ -106,6 +106,8 @@ fn handle_request<T: LeaseManager>( remote: SocketAddrV4, link: &str, ) -> Result<()> { + let dst: SocketAddrV4 = "255.255.255.255:68".parse().unwrap(); + let msg = Message::decode(&mut Decoder::new(buf))?; let op = msg.opcode(); @@ -155,7 +157,7 @@ fn handle_request<T: LeaseManager>( let mut resp_buf = Vec::new(); resp.encode(&mut Encoder::new(&mut resp_buf))?; - let n = sock.send_to(&resp_buf, &remote.into())?; + let n = sock.send_to(&resp_buf, &dst.into())?; if n != resp_buf.len() { Err(Error::PartialResponse) } else { @@ -208,7 +210,7 @@ fn handle_request<T: LeaseManager>( let mut resp_buf = Vec::new(); resp.encode(&mut Encoder::new(&mut resp_buf))?; - let n = sock.send_to(&resp_buf, &remote.into())?; + let n = sock.send_to(&resp_buf, &dst.into())?; if n != resp_buf.len() { Err(Error::PartialResponse) } else { @@ -245,7 +247,7 @@ fn handle_request<T: LeaseManager>( let mut resp_buf = Vec::new(); resp.encode(&mut Encoder::new(&mut resp_buf))?; - let n = sock.send_to(&resp_buf, &remote.into())?; + let n = sock.send_to(&resp_buf, &dst.into())?; if n != resp_buf.len() { Err(Error::PartialResponse) } else { |