From 869f2f91857dc04a5f978a3394b683ae339ba0c3 Mon Sep 17 00:00:00 2001 From: behzad nouri Date: Tue, 6 Feb 2024 14:10:42 -0600 Subject: [PATCH] uses Merkle shreds in broadcast duplicates --- local-cluster/tests/local_cluster.rs | 10 +++++----- .../src/broadcast_stage/broadcast_duplicates_run.rs | 6 +++--- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/local-cluster/tests/local_cluster.rs b/local-cluster/tests/local_cluster.rs index f9640066345745..6f7de16df296b1 100644 --- a/local-cluster/tests/local_cluster.rs +++ b/local-cluster/tests/local_cluster.rs @@ -5608,11 +5608,11 @@ fn test_invalid_forks_persisted_on_restart() { .entries_to_shreds( &majority_keypair, &entries, - true, // is_full_slot - None, // chained_merkle_root - 0, // next_shred_index, - 0, // next_code_index - false, // merkle_variant + true, // is_full_slot + None, // chained_merkle_root + 0, // next_shred_index, + 0, // next_code_index + true, // merkle_variant &ReedSolomonCache::default(), &mut ProcessShredsStats::default(), ) diff --git a/turbine/src/broadcast_stage/broadcast_duplicates_run.rs b/turbine/src/broadcast_stage/broadcast_duplicates_run.rs index 8bee47068ac499..3190c039a116d0 100644 --- a/turbine/src/broadcast_stage/broadcast_duplicates_run.rs +++ b/turbine/src/broadcast_stage/broadcast_duplicates_run.rs @@ -176,7 +176,7 @@ impl BroadcastRun for BroadcastDuplicatesRun { None, // chained_merkle_root self.next_shred_index, self.next_code_index, - false, // merkle_variant + true, // merkle_variant &self.reed_solomon_cache, &mut ProcessShredsStats::default(), ); @@ -194,7 +194,7 @@ impl BroadcastRun for BroadcastDuplicatesRun { None, // chained_merkle_root self.next_shred_index, self.next_code_index, - false, // merkle_variant + true, // merkle_variant &self.reed_solomon_cache, &mut ProcessShredsStats::default(), ); @@ -208,7 +208,7 @@ impl BroadcastRun for BroadcastDuplicatesRun { None, // chained_merkle_root self.next_shred_index, self.next_code_index, - false, // merkle_variant + true, // merkle_variant &self.reed_solomon_cache, &mut ProcessShredsStats::default(), );