merged llmp executor

afl/src/events/llmp.rs

@@ -245,7 +245,6 @@ impl LlmpConnection {
             LlmpConnection::IsClient { client } => client.send_buf(tag, buf),
         }
     }
-
 }
 
 /// Contents of the share mem pages, used by llmp internally

afl/src/events/mod.rs

@@ -12,9 +12,7 @@ use serde::{Deserialize, Serialize};
 //pub mod shmem_translated;
 
 #[cfg(feature = "std")]
-use std::{
+use std::io::Write;
-    io::Write,
-};
 
 use crate::corpus::Corpus;
 use crate::executors::Executor;
@@ -314,7 +312,6 @@ where
                 observers_buf,
                 client_config: _,
             } => {
-
                 // TODO: here u should match client_config, if equal to the current one do not re-execute
                 // we need to pass engine to process() too, TODO
                 #[cfg(feature = "std")]
@@ -553,7 +550,8 @@ mod tests {
                 observers_buf,
                 client_config: String,
             } => {
-                let o = postcard::from_bytes(&observers_buf).unwrap()
+                let o = postcard::from_bytes(&observers_buf)
+                    .unwrap()
                     .as_ref()
                     .match_name_type::<StdMapObserver<u32>>("test")
                     .unwrap();

afl/src/stages/mutational.rs

@@ -74,7 +74,7 @@ where
             if state.is_interesting(&input_mut, observers)? > 0 {
                 // TODO decouple events manager and engine
                 manager.fire(Event::new_testcase("test".into(), input_mut, observers)?)?;
-                // let _ = corpus.add(testcase);
+            // let _ = corpus.add(testcase);
             } else {
                 state.discard_input(&input_mut)?;
             }