virtio-devices: vhost_user: Add VhostUserCommon::spawn_worker helper

Wrap VirtioCommon::spawn_worker() to also include vhost-user specific
backend cleanup.

Assisted-by: Claude:Opus-4.7
Signed-off-by: Rob Bradford <rbradford@meta.com>

virtio-devices/src/vhost_user/mod.rs

@@ -11,6 +11,7 @@ use std::sync::{Arc, Barrier, Mutex};
 use anyhow::anyhow;
 use event_monitor::event;
 use log::{error, info, warn};
+use seccompiler::SeccompAction;
 use serde::{Deserialize, Serialize};
 use thiserror::Error;
 use vhost::Error as VhostError;
@@ -27,6 +28,7 @@ use vm_migration::{MigratableError, Pausable, Snapshot};
 use vmm_sys_util::eventfd::EventFd;
 use vu_common_ctrl::VhostUserHandle;
 
+use crate::seccomp_filters::Thread;
 use crate::{
     ActivateError, EPOLL_HELPER_EVENT_LAST, EpollHelper, EpollHelperError, EpollHelperHandler,
     GuestMemoryMmap, GuestRegionMmap, VIRTIO_F_IN_ORDER, VIRTIO_F_NOTIFICATION_DATA,
@@ -535,6 +537,37 @@ impl VhostUserCommon {
         })
     }
 
+    /// Like `VirtioCommon::spawn_worker`, but on failure also runs
+    /// `self.reset(id)` to tear down the vhost-user backend.
+    #[expect(clippy::too_many_arguments)]
+    pub fn spawn_worker<F>(
+        &mut self,
+        id: &str,
+        seccomp_action: &SeccompAction,
+        thread_type: Thread,
+        exit_evt: &EventFd,
+        device_status: Arc<std::sync::atomic::AtomicU8>,
+        interrupt_cb: Arc<dyn VirtioInterrupt>,
+        f: F,
+    ) -> std::result::Result<(), ActivateError>
+    where
+        F: FnOnce() -> std::result::Result<(), EpollHelperError> + Send + 'static,
+    {
+        if let Err(e) = self.virtio_common.spawn_worker(
+            id,
+            seccomp_action,
+            thread_type,
+            exit_evt,
+            device_status,
+            interrupt_cb,
+            f,
+        ) {
+            self.reset(id);
+            return Err(e);
+        }
+        Ok(())
+    }
+
     pub fn reset(&mut self, id: &str) {
         // Resume the virtio thread if it was paused. Reset must always
         // converge to fresh state, so backend resume / reset failures are