We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0c6244c commit ad9d357Copy full SHA for ad9d357
1 file changed
src/servers/udp_tunnel.rs
@@ -298,6 +298,11 @@ impl Tunnel {
298
let buffer = read_buffer.filled();
299
let mut reader = MessageReader::new(buffer);
300
301
+ let header = match MessageHeader::read(&mut reader) {
302
+ Ok(value) => value,
303
+ Err(_) => return Poll::Ready(TunnelReadState::Stop),
304
+ };
305
+
306
let message = match TunnelMessage::read(&mut reader) {
307
Ok(value) => value,
308
Err(_) => return Poll::Ready(TunnelReadState::Stop),
@@ -706,6 +711,7 @@ mod codec {
706
711
}
707
712
708
713
714
+ #[derive(Debug)]
709
715
pub enum TunnelMessage {
710
716
/// Client is requesting to initiate a connection
717
Initiate {
0 commit comments