fix: race conditions in multiplexer (#486)

* fix: network wrapper to use [0u8; 32] task hash * refactor: cleanup round_based_compat fix: don't poll newly created futures * fix: race conditions, out of order delivery * chore: cleanup
tangle-network · Nov 20, 2024 · c1037b3 · c1037b3
1 parent 4ae043e
commit c1037b3
Show file tree

Hide file tree

Showing 6 changed files with 459 additions and 211 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -196,7 +196,6 @@ testcontainers = { version = "0.20.1" }
 # Symbiotic
 symbiotic-rs = { version = "0.1.0" }
 dashmap = "6.1.0"
-bincode2 = "2.0.1"
 lru-mem = "0.3.0"
 
 [profile.dev.package.backtrace]

diff --git a/sdk/Cargo.toml b/sdk/Cargo.toml
@@ -99,7 +99,6 @@ lru-mem = { workspace = true }
 sysinfo = { workspace = true }
 dashmap = { workspace = true }
 lazy_static = "1.5.0"
-bincode2 = { workspace = true }
 color-eyre = { workspace = true }
 
 

diff --git a/sdk/src/event_listener/tangle/mod.rs b/sdk/src/event_listener/tangle/mod.rs
@@ -176,7 +176,7 @@ impl<C: ThreadSafeCloneable, E: EventMatcher>
                 .filter_map(|r| r.ok().and_then(E::try_decode))
                 .collect::<VecDeque<_>>();
 
-            crate::info!("Found {} possible events ...", events.len());
+            crate::debug!("Found {} possible events ...", events.len());
             self.enqueued_events = events;
         }
     }