fmt

kernel/src/net/socket/common/shutdown.rs

@@ -1,4 +1,5 @@
-use core::{default, sync::atomic::AtomicU8};
+#![allow(dead_code)]
+use core::sync::atomic::AtomicU8;
 
 use system_error::SystemError;
 

kernel/src/net/socket/inet/datagram/inner.rs

@@ -122,11 +122,6 @@ impl BoundUdp {
         })
     }
 
-    #[inline]
-    pub fn can_recv(&self) -> bool {
-        self.with_socket(|socket| socket.can_recv())
-    }
-
     pub fn try_send(
         &self,
         buf: &[u8],

kernel/src/net/socket/inet/stream/inner.rs

@@ -132,7 +132,7 @@ impl Init {
         } else {
             smoltcp::wire::IpListenEndpoint::from(local)
         };
-        log::debug!("listen at {:?}", listen_addr);
+        // log::debug!("listen at {:?}", listen_addr);
         let mut inners = Vec::new();
         if let Err(err) = || -> Result<(), SystemError> {
             for _ in 0..(backlog - 1) {

kernel/src/net/socket/inode.rs

@@ -30,6 +30,7 @@ impl IndexNode for Inode {
         data: crate::libs::spinlock::SpinLockGuard<crate::filesystem::vfs::FilePrivateData>,
     ) -> Result<usize, SystemError> {
         drop(data);
+        defer::defer!(log::debug!("write end."));
         self.inner.write(buf)
     }
 

kernel/src/net/socket/unix/stream/inner.rs

@@ -1,3 +1,4 @@
+#![allow(unused)]
 use core::sync::atomic::{AtomicUsize, Ordering};
 
 use log::debug;