|
|
@@ -56,7 +56,7 @@ enum Data {
|
|
56
|
56
|
RelayServers(RelayServers),
|
|
57
|
57
|
}
|
|
58
|
58
|
|
|
59
|
|
-const REG_TIMEOUT: i32 = 30_000;
|
|
|
59
|
+const REG_TIMEOUT: i32 = 100_000; //当使用websocket时,注册间隔时间会很长,改为100
|
|
60
|
60
|
type TcpStreamSink = SplitSink<Framed<TcpStream, BytesCodec>, Bytes>;
|
|
61
|
61
|
type WsSink = SplitSink<tokio_tungstenite::WebSocketStream<TcpStream>, tungstenite::Message>;
|
|
62
|
62
|
struct SafeWsSink {
|
|
|
@@ -496,7 +496,7 @@ impl RendezvousServer {
|
|
496
|
496
|
ws: bool,
|
|
497
|
497
|
) -> bool {
|
|
498
|
498
|
if let Ok(msg_in) = RendezvousMessage::parse_from_bytes(bytes) {
|
|
499
|
|
- // log::debug!("Received TCP message from {}: {:?}", addr, msg_in);
|
|
|
499
|
+ log::debug!("Received TCP message from {}: {:?}", addr, msg_in);
|
|
500
|
500
|
match msg_in.union {
|
|
501
|
501
|
Some(rendezvous_message::Union::RegisterPeer(rp)) => {
|
|
502
|
502
|
// B registered
|