[mio] 打印移除路由日志
This commit is contained in:
@@ -71,6 +71,10 @@ fn idle_gateway0<Call: VntCallback>(
|
|||||||
if let Err(e) =
|
if let Err(e) =
|
||||||
check_gateway_channel(context, cur, config, tcp_socket_sender, call, connect_count)
|
check_gateway_channel(context, cur, config, tcp_socket_sender, call, connect_count)
|
||||||
{
|
{
|
||||||
|
call.error(ErrorInfo::new_msg(
|
||||||
|
ErrorType::Disconnect,
|
||||||
|
format!("connect:{},error:{:?}", cur.connect_server, e),
|
||||||
|
));
|
||||||
log::warn!("{:?}", e);
|
log::warn!("{:?}", e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -83,7 +87,8 @@ fn idle_route0<Call: VntCallback>(
|
|||||||
let cur = current_device.load();
|
let cur = current_device.load();
|
||||||
match idle.next_idle() {
|
match idle.next_idle() {
|
||||||
IdleType::Timeout(ip, route) => {
|
IdleType::Timeout(ip, route) => {
|
||||||
context.remove_route(&ip, route);
|
log::info!("route Timeout {:?},{:?}", ip, route);
|
||||||
|
context.remove_route(&ip, route.route_key());
|
||||||
if cur.is_gateway(&ip) {
|
if cur.is_gateway(&ip) {
|
||||||
//网关路由过期,则需要改变状态
|
//网关路由过期,则需要改变状态
|
||||||
let cur = context.change_status(current_device);
|
let cur = context.change_status(current_device);
|
||||||
@@ -111,6 +116,9 @@ fn check_gateway_channel<Call: VntCallback>(
|
|||||||
.route_one(¤t_device.virtual_gateway);
|
.route_one(¤t_device.virtual_gateway);
|
||||||
if gateway_route.is_none() {
|
if gateway_route.is_none() {
|
||||||
*count += 1;
|
*count += 1;
|
||||||
|
if *count % 4 == 0 {
|
||||||
|
context.change_main_index();
|
||||||
|
}
|
||||||
//需要重连
|
//需要重连
|
||||||
call.connect(ConnectInfo::new(*count, current_device.connect_server));
|
call.connect(ConnectInfo::new(*count, current_device.connect_server));
|
||||||
let request_packet = handshaker::handshake_request_packet(config.client_secret)?;
|
let request_packet = handshaker::handshake_request_packet(config.client_secret)?;
|
||||||
|
|||||||
Reference in New Issue
Block a user