devices/vsock: remove log message duplicities

Since env_logger already indicates the module emitting the message,
avoid putting it manually in the message string.

Signed-off-by: Sergio Lopez <[email protected]>

Author: slp

src/devices/src/virtio/vsock/device.rs

@@ -119,7 +119,7 @@ impl Vsock {
     /// have pending. Return `true` if descriptors have been added to the used ring, and `false`
     /// otherwise.
     pub fn process_stream_rx(&mut self) -> bool {
-        debug!("vsock: process_stream_rx()");
+        debug!("process_stream_rx()");
         let mem = match self.device_state {
             DeviceState::Activated(ref mem, _) => mem,
             // This should never happen, it's been already validated in the event handler.
@@ -128,10 +128,10 @@ impl Vsock {
 
         let mut have_used = false;
 
-        debug!("vsock: process_rx before while");
+        debug!("process_rx before while");
         let mut queue_rx = self.queue_rx.lock().unwrap();
         while let Some(head) = queue_rx.pop(mem) {
-            debug!("vsock: process_rx inside while");
+            debug!("process_rx inside while");
             let used_len = match VsockPacket::from_rx_virtq_head(&head) {
                 Ok(mut pkt) => {
                     if self.muxer.recv_pkt(&mut pkt).is_ok() {
@@ -144,12 +144,12 @@ impl Vsock {
                     }
                 }
                 Err(e) => {
-                    warn!("vsock: RX queue error: {e:?}");
+                    warn!("RX queue error: {e:?}");
                     0
                 }
             };
 
-            debug!("vsock: process_rx: something to queue");
+            debug!("process_rx: something to queue");
             have_used = true;
             if let Err(e) = queue_rx.add_used(mem, head.index, used_len) {
                 error!("failed to add used elements to the queue: {e:?}");
@@ -162,7 +162,7 @@ impl Vsock {
     /// Walk the driver-provided TX queue buffers, package them up as vsock packets, and process
     /// them. Return `true` if descriptors have been added to the used ring, and `false` otherwise.
     pub fn process_stream_tx(&mut self) -> bool {
-        debug!("vsock::process_stream_tx()");
+        debug!("process_stream_tx()");
         let mem = match self.device_state {
             DeviceState::Activated(ref mem, _) => mem,
             // This should never happen, it's been already validated in the event handler.
@@ -176,7 +176,7 @@ impl Vsock {
             let pkt = match VsockPacket::from_tx_virtq_head(&head) {
                 Ok(pkt) => pkt,
                 Err(e) => {
-                    error!("vsock: error reading TX packet: {e:?}");
+                    error!("error reading TX packet: {e:?}");
                     have_used = true;
                     if let Err(e) = queue_tx.add_used(mem, head.index, 0) {
                         error!("failed to add used elements to the queue: {e:?}");
@@ -186,13 +186,13 @@ impl Vsock {
             };
 
             if pkt.type_() == uapi::VSOCK_TYPE_DGRAM {
-                debug!("vsock::process_stream_tx() is DGRAM");
+                debug!("process_stream_tx() is DGRAM");
                 if self.muxer.send_dgram_pkt(&pkt).is_err() {
                     queue_tx.undo_pop();
                     break;
                 }
             } else {
-                debug!("vsock::process_stream_tx() is STREAM");
+                debug!("process_stream_tx() is STREAM");
                 if self.muxer.send_stream_pkt(&pkt).is_err() {
                     queue_tx.undo_pop();
                     break;
@@ -252,7 +252,7 @@ impl VirtioDevice for Vsock {
                 byte_order::write_le_u32(data, ((self.cid() >> 32) & 0xffff_ffff) as u32)
             }
             _ => warn!(
-                "vsock: virtio-vsock received invalid read request of {} bytes at offset {}",
+                "virtio-vsock received invalid read request of {} bytes at offset {}",
                 data.len(),
                 offset
             ),
@@ -261,7 +261,7 @@ impl VirtioDevice for Vsock {
 
     fn write_config(&mut self, offset: u64, data: &[u8]) {
         warn!(
-            "vsock: guest driver attempted to write device config (offset={:x}, len={:x})",
+            "guest driver attempted to write device config (offset={:x}, len={:x})",
             offset,
             data.len()
         );

src/devices/src/virtio/vsock/event_handler.rs

@@ -15,11 +15,11 @@ use crate::virtio::VirtioDevice;
 
 impl Vsock {
     pub(crate) fn handle_rxq_event(&mut self, event: &EpollEvent) -> bool {
-        debug!("vsock: RX queue event");
+        debug!("RX queue event");
 
         let event_set = event.event_set();
         if event_set != EventSet::IN {
-            warn!("vsock: rxq unexpected event {event_set:?}");
+            warn!("rxq unexpected event {event_set:?}");
             return false;
         }
 
@@ -33,11 +33,11 @@ impl Vsock {
     }
 
     pub(crate) fn handle_txq_event(&mut self, event: &EpollEvent) -> bool {
-        debug!("vsock: TX queue event");
+        debug!("TX queue event");
 
         let event_set = event.event_set();
         if event_set != EventSet::IN {
-            warn!("vsock: txq unexpected event {event_set:?}");
+            warn!("txq unexpected event {event_set:?}");
             return false;
         }
 
@@ -57,11 +57,11 @@ impl Vsock {
     }
 
     fn handle_evq_event(&mut self, event: &EpollEvent) -> bool {
-        debug!("vsock: event queue event");
+        debug!("event queue event");
 
         let event_set = event.event_set();
         if event_set != EventSet::IN {
-            warn!("vsock: evq unexpected event {event_set:?}");
+            warn!("evq unexpected event {event_set:?}");
             return false;
         }
 
@@ -72,7 +72,7 @@ impl Vsock {
     }
 
     fn handle_activate_event(&self, event_manager: &mut EventManager) {
-        debug!("vsock: activate event");
+        debug!("activate event");
         if let Err(e) = self.activate_evt.read() {
             error!("Failed to consume vsock activate event: {e:?}");
         }
@@ -147,7 +147,7 @@ impl Subscriber for Vsock {
                 self.device_state.signal_used_queue();
             }
         } else {
-            warn!("Vsock: The device is not yet activated. Spurious event received: {source:?}");
+            warn!("The device is not yet activated. Spurious event received: {source:?}");
         }
     }