Add testcase for statsd in launcher, Fixes (#3589)

* add testcase for statsd in launcher

* clip

Author: domenukk

Cargo.lock

@@ -204,11 +204,11 @@ impl<CF, MT, SP> Debug for Launcher<'_, CF, MT, SP> {
 
 impl<CF, MT, SP> Launcher<'_, CF, MT, SP>
 where
-    MT: Monitor + Clone,
+    MT: Monitor,
 {
     /// Launch the broker and the clients and fuzz
     #[cfg(any(windows, not(feature = "fork"), all(unix, feature = "fork")))]
-    pub fn launch<I, S>(&mut self) -> Result<(), Error>
+    pub fn launch<I, S>(self) -> Result<(), Error>
     where
         CF: FnOnce(
             Option<S>,
@@ -225,12 +225,12 @@ where
 
 impl<CF, MT, SP> Launcher<'_, CF, MT, SP>
 where
-    MT: Monitor + Clone,
+    MT: Monitor,
     SP: ShMemProvider,
 {
     /// Launch the broker and the clients and fuzz with a user-supplied hook
     #[cfg(all(unix, feature = "fork"))]
-    pub fn launch_with_hooks<EMH, I, S>(&mut self, hooks: EMH) -> Result<(), Error>
+    pub fn launch_with_hooks<EMH, I, S>(mut self, hooks: EMH) -> Result<(), Error>
     where
         S: DeserializeOwned + Serialize,
         I: DeserializeOwned,
@@ -342,7 +342,7 @@ where
             // TODO we don't want always a broker here, think about using different laucher process to spawn different configurations
             let builder = RestartingMgr::<EMH, I, MT, S, SP>::builder()
                 .shmem_provider(self.shmem_provider.clone())
-                .monitor(Some(self.monitor.clone()))
+                .monitor(Some(self.monitor))
                 .broker_port(self.broker_port)
                 .kind(ManagerKind::Broker)
                 .remote_broker_addr(self.remote_broker_addr)
@@ -382,7 +382,7 @@ where
     /// Launch the broker and the clients and fuzz
     #[cfg(any(windows, not(feature = "fork")))]
     #[expect(clippy::too_many_lines, clippy::match_wild_err_arm)]
-    pub fn launch_with_hooks<EMH, I, S>(&mut self, hooks: EMH) -> Result<(), Error>
+    pub fn launch_with_hooks<EMH, I, S>(mut self, hooks: EMH) -> Result<(), Error>
     where
         CF: FnOnce(
             Option<S>,
@@ -511,7 +511,7 @@ where
 
             let builder = RestartingMgr::<EMH, I, MT, S, SP>::builder()
                 .shmem_provider(self.shmem_provider.clone())
-                .monitor(Some(self.monitor.clone()))
+                .monitor(Some(self.monitor))
                 .broker_port(self.broker_port)
                 .kind(ManagerKind::Broker)
                 .remote_broker_addr(self.remote_broker_addr)

crates/libafl/src/events/launcher.rs

@@ -613,7 +613,7 @@ pub fn setup_restarting_mgr_std<I, MT, S>(
 >
 where
     I: DeserializeOwned,
-    MT: Monitor + Clone,
+    MT: Monitor,
     S: Serialize + DeserializeOwned,
 {
     RestartingMgr::builder()
@@ -644,7 +644,7 @@ pub fn setup_restarting_mgr_std_adaptive<I, MT, S>(
     Error,
 >
 where
-    MT: Monitor + Clone,
+    MT: Monitor,
     S: Serialize + DeserializeOwned,
     I: DeserializeOwned,
 {
@@ -704,7 +704,7 @@ impl<EMH, I, MT, S, SP> RestartingMgr<EMH, I, MT, S, SP>
 where
     EMH: EventManagerHooksTuple<I, S> + Copy + Clone,
     I: DeserializeOwned,
-    MT: Monitor + Clone,
+    MT: Monitor,
     S: Serialize + DeserializeOwned,
     SP: ShMemProvider,
 {