chore: update dependencies (#288)

Fixes #281 #282 #283 #284 #285 #286

Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>

src/bastion-executor/Cargo.toml

@@ -33,9 +33,9 @@ bastion-utils = "0.3.2"
 # lightproc = { path = "../lightproc" }
 # bastion-utils = { path = "../bastion-utils" }
 
-crossbeam-utils = "0.7"
-crossbeam-channel = "0.4"
-crossbeam-epoch = "0.8"
+crossbeam-utils = "0.8"
+crossbeam-channel = "0.5"
+crossbeam-epoch = "0.9"
 lazy_static = "1.4"
 libc = "0.2"
 num_cpus = "1.13"
@@ -47,7 +47,7 @@ futures-timer = "3.0.2"
 once_cell = "1.4.0"
 lever = "0.1.1-alpha.11"
 tracing = "0.1.19"
-crossbeam-queue = "0.2.3"
+crossbeam-queue = "0.3.0"
 
 [target.'cfg(target_os = "windows")'.dependencies]
 winapi = { version = "^0.3.8", features = ["basetsd"] }

src/bastion-executor/src/thread_manager.rs

@@ -274,33 +274,21 @@ impl DynamicPoolManager {
                 trace!("parking thread {:?}", std::thread::current().id());
                 std::thread::park();
             })
-            .map_err(|e| {
-                debug!(
-                    "couldn't park thread {:?} - {}",
-                    std::thread::current().id(),
-                    e
-                );
+            .map_err(|t| {
+                debug!("couldn't park thread {:?}", t.id(),);
             });
     }
 
     /// Pops a thread from the parked_threads queue and unparks it.
     /// returns true on success.
     fn unpark_thread(&self) -> bool {
-        if self.parked_threads.is_empty() {
-            trace!("no parked threads");
-            false
+        trace!("parked_threads: len is {}", self.parked_threads.len());
+        if let Some(thread) = self.parked_threads.pop() {
+            debug!("Executor: unpark_thread: unparking {:?}", thread.id());
+            thread.unpark();
+            true
         } else {
-            trace!("parked_threads: len is {}", self.parked_threads.len());
-            self.parked_threads
-                .pop()
-                .map(|thread| {
-                    debug!("Executor: unpark_thread: unparking {:?}", thread.id());
-                    thread.unpark();
-                })
-                .map_err(|e| {
-                    debug!("Executor: unpark_thread: couldn't unpark thread - {}", e);
-                })
-                .is_ok()
+            false
         }
     }
 

src/bastion/Cargo.toml

@@ -74,13 +74,13 @@ artillery-core = { version = "0.1.2-alpha.3", optional = true }
 tracing-subscriber = "0.2.6"
 tracing = "0.1.15"
 anyhow = "1.0.31"
-crossbeam-queue = "0.2.3"
+crossbeam-queue = "0.3.0"
 
 [target.'cfg(not(windows))'.dependencies]
 nuclei = "0.1.2-alpha.1"
 
 [dev-dependencies]
-env_logger = "0.7"
+env_logger = "0.8"
 proptest = "0.10"
 snap = "1.0"
 # prime_numbers example

src/bastion/src/context.rs

@@ -677,7 +677,7 @@ impl ContextState {
     }
 
     pub(crate) fn pop_message(&self) -> Option<SignedMessage> {
-        self.messages.pop().ok()
+        self.messages.pop()
     }
 
     #[cfg(feature = "scaling")]

src/lightproc/Cargo.toml

@@ -16,10 +16,10 @@ edition = "2018"
 maintenance = { status = "actively-developed" }
 
 [dependencies]
-crossbeam-utils = "0.7"
+crossbeam-utils = "0.8"
 pin-utils = "0.1.0"
 
 [dev-dependencies]
-crossbeam = "0.7"
+crossbeam = "0.8"
 futures-executor = "0.3"
 lazy_static = "1.4.0"