From 4fe92e3dfe4bf4134cd00c8d5bcdb95d2a73db84 Mon Sep 17 00:00:00 2001 From: Simon Paitrault Date: Fri, 30 Jun 2023 15:40:21 +0200 Subject: [PATCH] chore: removing buffer Signed-off-by: Simon Paitrault --- .../src/double_echo/mod.rs | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/crates/topos-tce-broadcast/src/double_echo/mod.rs b/crates/topos-tce-broadcast/src/double_echo/mod.rs index cf7359878..2e71a9cef 100644 --- a/crates/topos-tce-broadcast/src/double_echo/mod.rs +++ b/crates/topos-tce-broadcast/src/double_echo/mod.rs @@ -411,20 +411,20 @@ impl DoubleEcho { ); } - if self.pending_certificate_count > 0 { - if let Ok(Some((pending, certificate))) = self - .storage - .next_pending_certificate(Some(self.last_pending_certificate as usize)) - .await - { - _ = self.pending_certificate_count.checked_sub(1); - self.last_pending_certificate = pending; - self.buffer.push_back((true, certificate)); - DOUBLE_ECHO_CURRENT_BUFFER_SIZE.inc(); - } else { - info!("No more certificate to broadcast"); - } - } + // if self.pending_certificate_count > 0 { + // if let Ok(Some((pending, certificate))) = self + // .storage + // .next_pending_certificate(Some(self.last_pending_certificate as usize)) + // .await + // { + // _ = self.pending_certificate_count.checked_sub(1); + // self.last_pending_certificate = pending; + // self.buffer.push_back((false, certificate)); + // DOUBLE_ECHO_CURRENT_BUFFER_SIZE.inc(); + // } else { + // info!("No more certificate to broadcast"); + // } + // } } } };