@@ -1083,11 +1083,6 @@ impl MagicSock {
1083
1083
return None ;
1084
1084
}
1085
1085
1086
- if self . handle_relay_disco_message ( & dm. buf , & dm. url , dm. src ) {
1087
- // DISCO messages are handled internally in the MagicSock, do not pass to Quinn.
1088
- return None ;
1089
- }
1090
-
1091
1086
let quic_mapped_addr = self . node_map . receive_relay ( & dm. url , dm. src ) ;
1092
1087
1093
1088
// Normalize local_ip
@@ -1108,32 +1103,6 @@ impl MagicSock {
1108
1103
Some ( ( dm. src , meta, dm. buf ) )
1109
1104
}
1110
1105
1111
- fn handle_relay_disco_message (
1112
- & self ,
1113
- msg : & [ u8 ] ,
1114
- url : & RelayUrl ,
1115
- relay_node_src : PublicKey ,
1116
- ) -> bool {
1117
- match disco:: source_and_box ( msg) {
1118
- Some ( ( source, sealed_box) ) => {
1119
- if relay_node_src != source {
1120
- // TODO: return here?
1121
- warn ! ( "Received relay disco message from connection for {}, but with message from {}" , relay_node_src. fmt_short( ) , source. fmt_short( ) ) ;
1122
- }
1123
- self . handle_disco_message (
1124
- source,
1125
- sealed_box,
1126
- DiscoMessageSource :: Relay {
1127
- url : url. clone ( ) ,
1128
- key : relay_node_src,
1129
- } ,
1130
- ) ;
1131
- true
1132
- }
1133
- None => false ,
1134
- }
1135
- }
1136
-
1137
1106
/// Handles a discovery message.
1138
1107
#[ instrument( "disco_in" , skip_all, fields( node = %sender. fmt_short( ) , %src) ) ]
1139
1108
fn handle_disco_message ( & self , sender : PublicKey , sealed_box : & [ u8 ] , src : DiscoMessageSource ) {
0 commit comments