DragonOS-Community/DragonOS
4
1
Fork 0
mirror of https://github.com/DragonOS-Community/DragonOS.git synced 2025-06-25 10:03:23 +00:00
Code Issues Releases Wiki Activity

fmt

Browse Source
This commit is contained in:
longjin
2024-11-29 13:06:04 +00:00
parent b9c07e0be2
commit 0e6201779a
1 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
kernel/src/net/socket/inet/stream/mod.rs
View File

@ -328,24 +328,21 @@ impl Socket for TcpSocket {
.recv_buffer_size() .recv_buffer_size()
} }
fn shutdown(&self, how: ShutdownTemp) -> Result<(), SystemError> { fn shutdown(&self, how: ShutdownTemp) -> Result<(), SystemError> {
let self_shutdown = self.shutdown.get().bits(); let self_shutdown = self.shutdown.get().bits();
let diff = how.bits().difference(self_shutdown); let diff = how.bits().difference(self_shutdown);
match diff.is_empty(){ match diff.is_empty() {
true => { true => return Ok(()),
return Ok(())
},
false => { false => {
if diff.contains(ShutdownBit::SHUT_RD){ if diff.contains(ShutdownBit::SHUT_RD) {
self.shutdown.recv_shutdown(); self.shutdown.recv_shutdown();
// TODO 协议栈处理 // TODO 协议栈处理
} }
if diff.contains(ShutdownBit::SHUT_WR){ if diff.contains(ShutdownBit::SHUT_WR) {
self.shutdown.send_shutdown(); self.shutdown.send_shutdown();
// TODO 协议栈处理 // TODO 协议栈处理
} }
}, }
} }
Ok(()) Ok(())
} }