增加日志
This commit is contained in:
@@ -320,26 +320,22 @@ impl<Call: VntCallback> ServerPacketHandler<Call> {
|
|||||||
self.set_device_info_list(response.device_info_list, response.epoch as _);
|
self.set_device_info_list(response.device_info_list, response.epoch as _);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
service_packet::Protocol::RegistrationRequest => {
|
|
||||||
//不处理注册包
|
|
||||||
}
|
|
||||||
service_packet::Protocol::PollDeviceList => {}
|
|
||||||
service_packet::Protocol::PushDeviceList => {
|
service_packet::Protocol::PushDeviceList => {
|
||||||
let response = DeviceList::parse_from_bytes(net_packet.payload()).map_err(|e| {
|
let response = DeviceList::parse_from_bytes(net_packet.payload()).map_err(|e| {
|
||||||
io::Error::new(io::ErrorKind::Other, format!("PushDeviceList {:?}", e))
|
io::Error::new(io::ErrorKind::Other, format!("PushDeviceList {:?}", e))
|
||||||
})?;
|
})?;
|
||||||
self.set_device_info_list(response.device_info_list, response.epoch as _);
|
self.set_device_info_list(response.device_info_list, response.epoch as _);
|
||||||
}
|
}
|
||||||
service_packet::Protocol::HandshakeRequest => {}
|
|
||||||
service_packet::Protocol::HandshakeResponse => {}
|
|
||||||
service_packet::Protocol::SecretHandshakeRequest => {}
|
|
||||||
service_packet::Protocol::SecretHandshakeResponse => {
|
service_packet::Protocol::SecretHandshakeResponse => {
|
||||||
log::info!("SecretHandshakeResponse");
|
log::info!("SecretHandshakeResponse");
|
||||||
//加密握手结束,发送注册数据
|
//加密握手结束,发送注册数据
|
||||||
self.register(current_device, context)?;
|
self.register(current_device, context)?;
|
||||||
}
|
}
|
||||||
service_packet::Protocol::Unknown(e) => {
|
_ => {
|
||||||
log::warn!("service_packet::Protocol::Unknown = {}", e);
|
log::warn!(
|
||||||
|
"service_packet::Protocol::Unknown = {:?}",
|
||||||
|
net_packet.head()
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Ok(())
|
Ok(())
|
||||||
@@ -370,7 +366,10 @@ impl<Call: VntCallback> ServerPacketHandler<Call> {
|
|||||||
let device_id = self.config_info.device_id.clone();
|
let device_id = self.config_info.device_id.clone();
|
||||||
let name = self.config_info.name.clone();
|
let name = self.config_info.name.clone();
|
||||||
let client_secret = self.config_info.client_secret;
|
let client_secret = self.config_info.client_secret;
|
||||||
let ip = self.config_info.ip;
|
let mut ip = self.config_info.ip;
|
||||||
|
if ip.is_none() {
|
||||||
|
ip = Some(current_device.virtual_ip)
|
||||||
|
}
|
||||||
let response = registrar::registration_request_packet(
|
let response = registrar::registration_request_packet(
|
||||||
&self.server_cipher,
|
&self.server_cipher,
|
||||||
token,
|
token,
|
||||||
|
|||||||
@@ -29,12 +29,7 @@ impl PacketHandler for TurnPacketHandler {
|
|||||||
if let Some(route) = context.route_table.route_one(&destination) {
|
if let Some(route) = context.route_table.route_one(&destination) {
|
||||||
if route.addr == route_key.addr {
|
if route.addr == route_key.addr {
|
||||||
//防止环路
|
//防止环路
|
||||||
log::warn!(
|
log::warn!("来源和目标相同 {:?},{:?}", route_key, net_packet.head());
|
||||||
"来源和目标相同 {:?},{},{}",
|
|
||||||
route_key,
|
|
||||||
net_packet.source(),
|
|
||||||
net_packet.destination()
|
|
||||||
);
|
|
||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
if route.metric <= ttl {
|
if route.metric <= ttl {
|
||||||
|
|||||||
Reference in New Issue
Block a user