register name changes as updates

This commit is contained in:
soruh 2023-03-28 14:21:47 +02:00
parent 1e7b10bc6d
commit 0aab8b16c7
3 changed files with 6 additions and 6 deletions

View File

@ -333,7 +333,9 @@ pub async fn handler(
{ {
if let Some(name) = peer_query(&config.dyn_ip_server, number).await? { if let Some(name) = peer_query(&config.dyn_ip_server, number).await? {
info!(%name, "found client name"); info!(%name, "found client name");
port_handler.lock().await.names.insert(number, name); let mut port_handler = port_handler.lock().await;
port_handler.names.insert(number, name);
port_handler.register_update();
} }
} }

View File

@ -272,11 +272,6 @@ async fn connection_handler(
if let Some(port) = handler_metadata.port { if let Some(port) = handler_metadata.port {
let mut port_handler = port_handler.lock().await; let mut port_handler = port_handler.lock().await;
#[cfg(feature = "debug_server")]
if let Some(number) = handler_metadata.number {
port_handler.names.remove(&number);
}
if let Some(port_state) = port_handler.port_state.get_mut(&port) { if let Some(port_state) = port_handler.port_state.get_mut(&port) {
port_state.new_state(PortStatus::Disconnected); port_state.new_state(PortStatus::Disconnected);
port_handler.register_update(); port_handler.register_update();

View File

@ -533,6 +533,9 @@ impl PortHandler {
self.register_update(); self.register_update();
info!(port, old_number, "reused port"); info!(port, old_number, "reused port");
assert!(self.allocated_ports.remove(&old_number).is_some()); assert!(self.allocated_ports.remove(&old_number).is_some());
#[cfg(feature = "debug_server")]
self.names.remove(&old_number);
return Some(port); return Some(port);
} }