Make OrderingSender use circular buffer

akoshelev · Jun 13, 2024 · 8d0d7f8 · 8d0d7f8
1 parent c256cb2
commit 8d0d7f8
Show file tree

Hide file tree

Showing 10 changed files with 417 additions and 283 deletions.
diff --git a/ipa-core/benches/oneshot/ipa.rs b/ipa-core/benches/oneshot/ipa.rs
@@ -102,7 +102,10 @@ async fn run(args: Args) -> Result<(), Error> {
 
     let _prep_time = Instant::now();
     let config = TestWorldConfig {
-        gateway_config: GatewayConfig::new(args.active()),
+        gateway_config: GatewayConfig {
+            active: args.active().try_into().unwrap(),
+            ..Default::default()
+        },
         initial_gate: Some(Gate::default().narrow(&IpaPrf)),
         ..TestWorldConfig::default()
     };

diff --git a/ipa-core/src/helpers/buffers/circular.rs b/ipa-core/src/helpers/buffers/circular.rs
@@ -412,17 +412,6 @@ mod test {
         }
     }
 
-    impl TwoBytes {
-        fn iter() -> impl Iterator<Item = Self> {
-            let mut count = 0;
-            std::iter::repeat_with(move || {
-                let next = Self::from(&count);
-                count += 1;
-                next
-            })
-        }
-    }
-
     impl Debug for TwoBytes {
         fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
             f.serialize_u16(u16::from_le_bytes(self.0))

diff --git a/ipa-core/src/helpers/buffers/mod.rs b/ipa-core/src/helpers/buffers/mod.rs
@@ -1,7 +1,6 @@
 mod ordering_sender;
 mod unordered_receiver;
 
-#[allow(dead_code)]
 mod circular;
 
 pub use ordering_sender::OrderingSender;