Discard Empty Packet Batches (#299)

jito-foundation · Apr 28, 2023 · a4ab0e2 · a4ab0e2
1 parent 4bd7c2c
commit a4ab0e2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/core/src/proxy/block_engine_stage.rs b/core/src/proxy/block_engine_stage.rs
@@ -355,6 +355,11 @@ impl BlockEngineStage {
         block_engine_stats: &mut BlockEngineStageStats,
     ) -> crate::proxy::Result<()> {
         if let Some(batch) = resp.batch {
+            if batch.packets.is_empty() {
+                saturating_add_assign!(block_engine_stats.num_empty_packets, 1);
+                return Ok(());
+            }
+
             let packet_batch = PacketBatch::new(
                 batch
                     .packets

diff --git a/core/src/proxy/relayer_stage.rs b/core/src/proxy/relayer_stage.rs
@@ -328,6 +328,11 @@ impl RelayerStage {
                 saturating_add_assign!(relayer_stats.num_empty_messages, 1);
             }
             Some(relayer::subscribe_packets_response::Msg::Batch(proto_batch)) => {
+                if proto_batch.packets.is_empty() {
+                    saturating_add_assign!(relayer_stats.num_empty_messages, 1);
+                    return Ok(());
+                }
+
                 let packet_batch = PacketBatch::new(
                     proto_batch
                         .packets