mirror of
https://github.com/tun2proxy/tun2proxy.git
synced 2025-04-22 14:59:09 +00:00
test
This commit is contained in:
parent
3363d5b12e
commit
413430f5db
1 changed files with 7 additions and 3 deletions
|
@ -978,9 +978,13 @@ impl<'a> TunToProxy<'a> {
|
||||||
}
|
}
|
||||||
|
|
||||||
if event.is_writable() {
|
if event.is_writable() {
|
||||||
let item = self.connection_map.iter().find(|(_, state)| state.continue_read);
|
let items = self
|
||||||
if let Some((conn_info, _)) = item {
|
.connection_map
|
||||||
let conn_info = conn_info.clone();
|
.iter()
|
||||||
|
.filter(|(_, state)| state.continue_read)
|
||||||
|
.map(|(info, _)| info.clone())
|
||||||
|
.collect::<Vec<_>>();
|
||||||
|
for conn_info in items {
|
||||||
let (success, len) = self.read_server_n_write_proxy_handler(&conn_info)?;
|
let (success, len) = self.read_server_n_write_proxy_handler(&conn_info)?;
|
||||||
if !success {
|
if !success {
|
||||||
return Ok(());
|
return Ok(());
|
||||||
|
|
Loading…
Add table
Reference in a new issue