source/bandwhich
1
0
Fork 0
mirror of https://github.com/imsnif/bandwhich.git synced 2026-02-09 01:59:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

Set known orphan connections max size

Browse Source
This commit is contained in:
cyqsimon
2023-10-12 20:43:14 +08:00
parent 76956cfade
commit b82383dc58
1 changed files with 24 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
src/display/ui_state.rs
View File

@@ -89,7 +89,7 @@ pub struct UIState {
pub remote_addresses_map: HashMap<IpAddr, NetworkData>,
pub connections_map: HashMap<Connection, ConnectionData>,
/// Used for reducing logging noise.
known_orphan_sockets: RefCell<HashSet<LocalSocket>>,
known_orphan_sockets: RefCell<VecDeque<LocalSocket>>,
}
impl UIState {
@@ -126,21 +126,29 @@ impl UIState {
})
});
// only log each orphan connection once
if name.is_none() && self.known_orphan_sockets.borrow_mut().insert(*local_socket) {
match connections_to_procs
.iter()
.find(|(&LocalSocket { port, protocol, .. }, _)| {
port == local_socket.port && protocol == local_socket.protocol
}) {
Some((lookalike, name)) => {
warn!(
r#""{name}" owns a similar looking connection, but its local ip doesn't match."#
);
warn!("Looking for: {local_socket}; found: {lookalike}");
}
None => warn!("Cannot determine which process owns {local_socket}."),
};
if name.is_none() {
let mut orphans = self.known_orphan_sockets.borrow_mut();
// only log each orphan connection once
if !orphans.contains(local_socket) {
// newer connections go in the front so that searches are faster
// basically recency bias
orphans.push_front(*local_socket);
orphans.truncate(10_000); // arbitrary maximum backlog
match connections_to_procs.iter().find(
|(&LocalSocket { port, protocol, .. }, _)| {
port == local_socket.port && protocol == local_socket.protocol
},
) {
Some((lookalike, name)) => {
warn!(
r#""{name}" owns a similar looking connection, but its local ip doesn't match."#
);
warn!("Looking for: {local_socket}; found: {lookalike}");
}
None => warn!("Cannot determine which process owns {local_socket}."),
};
}
}
name