diff --git a/kernel/src/net/socket/ip/datagram/mod.rs b/kernel/src/net/socket/ip/datagram/mod.rs index b41c005ac..542a5a4bd 100644 --- a/kernel/src/net/socket/ip/datagram/mod.rs +++ b/kernel/src/net/socket/ip/datagram/mod.rs @@ -325,7 +325,9 @@ impl Socket for DatagramSocket { flags: SendRecvFlags, ) -> Result { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let MessageHeader { addr, @@ -361,7 +363,9 @@ impl Socket for DatagramSocket { flags: SendRecvFlags, ) -> Result<(usize, MessageHeader)> { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let (received_bytes, peer_addr) = self.recv(writer, flags)?; diff --git a/kernel/src/net/socket/ip/stream/mod.rs b/kernel/src/net/socket/ip/stream/mod.rs index a2e0c710a..6c44a9c06 100644 --- a/kernel/src/net/socket/ip/stream/mod.rs +++ b/kernel/src/net/socket/ip/stream/mod.rs @@ -567,7 +567,9 @@ impl Socket for StreamSocket { flags: SendRecvFlags, ) -> Result { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let MessageHeader { control_message, .. @@ -591,7 +593,9 @@ impl Socket for StreamSocket { flags: SendRecvFlags, ) -> Result<(usize, MessageHeader)> { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let (received_bytes, _) = self.recv(writer, flags)?; diff --git a/kernel/src/net/socket/unix/stream/socket.rs b/kernel/src/net/socket/unix/stream/socket.rs index 93eefd2a6..45ad34733 100644 --- a/kernel/src/net/socket/unix/stream/socket.rs +++ b/kernel/src/net/socket/unix/stream/socket.rs @@ -315,7 +315,9 @@ impl Socket for UnixStreamSocket { flags: SendRecvFlags, ) -> Result { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let MessageHeader { control_message, .. @@ -335,7 +337,9 @@ impl Socket for UnixStreamSocket { flags: SendRecvFlags, ) -> Result<(usize, MessageHeader)> { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let received_bytes = self.recv(writer, flags)?; diff --git a/kernel/src/net/socket/vsock/stream/connected.rs b/kernel/src/net/socket/vsock/stream/connected.rs index a8ca3cf89..98e3ab743 100644 --- a/kernel/src/net/socket/vsock/stream/connected.rs +++ b/kernel/src/net/socket/vsock/stream/connected.rs @@ -72,7 +72,10 @@ impl Connected { pub fn send(&self, reader: &mut dyn MultiRead, flags: SendRecvFlags) -> Result { let mut connection = self.connection.disable_irq().lock(); - debug_assert!(flags.is_all_supported()); + // TODO: Deal with flags + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let buf_len = reader.sum_lens(); VSOCK_GLOBAL .get() diff --git a/kernel/src/net/socket/vsock/stream/socket.rs b/kernel/src/net/socket/vsock/stream/socket.rs index 46b3aecf7..37778ef9c 100644 --- a/kernel/src/net/socket/vsock/stream/socket.rs +++ b/kernel/src/net/socket/vsock/stream/socket.rs @@ -303,7 +303,9 @@ impl Socket for VsockStreamSocket { flags: SendRecvFlags, ) -> Result { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let MessageHeader { control_message, .. @@ -323,7 +325,9 @@ impl Socket for VsockStreamSocket { flags: SendRecvFlags, ) -> Result<(usize, MessageHeader)> { // TODO: Deal with flags - debug_assert!(flags.is_all_supported()); + if !flags.is_all_supported() { + warn!("unsupported flags: {:?}", flags); + } let (received_bytes, _) = self.recv(writer, flags)?;