[mio] 判断停止状态
This commit is contained in:
@@ -130,6 +130,9 @@ fn udp_proxy(
|
|||||||
return Err(e);
|
return Err(e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if stop_manager.is_stop() {
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
for event in events.iter() {
|
for event in events.iter() {
|
||||||
match event.token() {
|
match event.token() {
|
||||||
SERVER => server_handle(
|
SERVER => server_handle(
|
||||||
@@ -141,9 +144,6 @@ fn udp_proxy(
|
|||||||
&mut buf,
|
&mut buf,
|
||||||
),
|
),
|
||||||
NOTIFY => {
|
NOTIFY => {
|
||||||
if stop_manager.is_stop() {
|
|
||||||
return Ok(());
|
|
||||||
}
|
|
||||||
check = true;
|
check = true;
|
||||||
}
|
}
|
||||||
token => {
|
token => {
|
||||||
|
|||||||
Reference in New Issue
Block a user