Samuka007/asterinas
1
0
Fork 0
mirror of https://github.com/asterinas/asterinas.git synced 2025-06-23 01:13:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Poll iface when dropping socket

Browse Source
This commit is contained in:
Jianfeng Jiang
2023-08-28 17:37:59 +08:00
committed by Tate, Hongliang Tian
parent dbf5a423b1
commit 4fef4d9b79
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
services/libs/jinux-std/src/net/iface/any_socket.rs
View File

@ -174,6 +174,7 @@ impl AnyBoundSocket {
impl Drop for AnyBoundSocket { impl Drop for AnyBoundSocket {
fn drop(&mut self) { fn drop(&mut self) {
self.close(); self.close();
self.iface.poll();
self.iface.common().remove_socket(self.handle); self.iface.common().remove_socket(self.handle);
self.iface.common().release_port(self.port); self.iface.common().release_port(self.port);
self.iface.common().remove_bound_socket(self.weak_ref()); self.iface.common().remove_bound_socket(self.weak_ref());

5
services/libs/jinux-std/src/net/iface/common.rs
View File

@ -138,8 +138,9 @@ impl IfaceCommon {
}; };
if has_events { if has_events {
self.bound_sockets.read().iter().for_each(|bound_socket| { self.bound_sockets.read().iter().for_each(|bound_socket| {
let bound_socket = bound_socket.upgrade().unwrap(); if let Some(bound_socket) = bound_socket.upgrade() {
bound_socket.update_socket_state(); bound_socket.update_socket_state();
}
}); });
} }