feat(core): add Bluestreak protocol

crates/orchestrator/src/benchmark.rs

@@ -38,7 +38,8 @@ pub struct BenchmarkParametersGeneric<N, C> {
     /// paying for data sent between the nodes.
     pub use_internal_ip_address: bool,
     // Consensus protocol to deploy
-    // (starfish | starfish-speed | starfish-bls | mysticeti | cordial-miners)
+    // (starfish | starfish-speed | starfish-bls | mysticeti |
+    // cordial-miners | bluestreak)
     pub consensus_protocol: String,
     /// number Byzantine nodes
     pub byzantine_nodes: usize,

crates/orchestrator/src/main.rs

@@ -115,7 +115,7 @@ pub enum Operation {
 
         /// Consensus to deploy. Available options:
         /// starfish | starfish-speed | starfish-bls | mysticeti |
-        /// cordial-miners
+        /// cordial-miners | bluestreak
         #[clap(long, value_name = "STRING", default_value = "starfish", global = true)]
         consensus: String,
 

crates/orchestrator/src/measurements.rs

@@ -926,10 +926,6 @@ utilization_timer{proc="Committer::indirect_decide"} 693165
 utilization_timer{proc="Core::add_blocks"} 5694911
 utilization_timer{proc="Core::run_block_handler"} 198119
 utilization_timer{proc="Core::try_new_block"} 1285400
-utilization_timer{proc="Core::try_new_block::build block"} 674913
-utilization_timer{proc="Core::try_new_block::encoding"} 31602
-utilization_timer{proc="Core::try_new_block::serialize block"} 11766
-utilization_timer{proc="Core::try_new_block::writing to disk"} 188706
 utilization_timer{proc="Core::try_new_commit"} 6288004
 utilization_timer{proc="Network: verify blocks"} 41800099
 utilization_timer{proc="Syncer::try_new_commit"} 8128094

crates/starfish-core/src/broadcaster.rs

@@ -85,7 +85,8 @@ impl BroadcasterParameters {
             ConsensusProtocol::Starfish
             | ConsensusProtocol::StarfishSpeed
             | ConsensusProtocol::StarfishBls
-            | ConsensusProtocol::CordialMiners => Self {
+            | ConsensusProtocol::CordialMiners
+            | ConsensusProtocol::Bluestreak => Self {
                 batch_own_block_size: committee_size,
                 batch_other_block_size: committee_size * committee_size,
                 batch_shard_size: committee_size * committee_size,
@@ -417,7 +418,8 @@ where
             }
             ConsensusProtocol::Mysticeti
             | ConsensusProtocol::CordialMiners
-            | ConsensusProtocol::SailfishPlusPlus => {
+            | ConsensusProtocol::SailfishPlusPlus
+            | ConsensusProtocol::Bluestreak => {
                 let all_blocks = self.inner.dag_state.get_storage_blocks(&block_references);
 
                 let mut blocks = Vec::new();
@@ -821,7 +823,8 @@ fn push_transport_format(consensus_protocol: ConsensusProtocol) -> PushOtherBloc
         | ConsensusProtocol::StarfishBls => PushOtherBlocksFormat::HeadersAndShards,
         ConsensusProtocol::CordialMiners
         | ConsensusProtocol::Mysticeti
-        | ConsensusProtocol::SailfishPlusPlus => PushOtherBlocksFormat::FullBlocks,
+        | ConsensusProtocol::SailfishPlusPlus
+        | ConsensusProtocol::Bluestreak => PushOtherBlocksFormat::FullBlocks,
     }
 }
 

crates/starfish-core/src/consensus/linearizer.rs

@@ -100,6 +100,7 @@ impl Linearizer {
         let mut to_commit = Vec::new();
         let leader_block_ref = *leader_block.reference();
         let min_round = leader_block_ref.round.saturating_sub(MAX_TRAVERSAL_DEPTH);
+        let follow_unprovable = dag_state.consensus_protocol == ConsensusProtocol::Bluestreak;
 
         assert!(self.committed.insert(leader_block_ref));
         let mut current_level = vec![leader_block];
@@ -115,6 +116,13 @@ impl Linearizer {
                         next_refs.push(*reference);
                     }
                 }
+                if follow_unprovable {
+                    if let Some(cert_ref) = x.unprovable_certificate() {
+                        if cert_ref.round >= min_round && self.committed.insert(*cert_ref) {
+                            next_refs.push(*cert_ref);
+                        }
+                    }
+                }
             }
             if next_refs.is_empty() {
                 break;
@@ -259,7 +267,8 @@ impl Linearizer {
                 }
                 ConsensusProtocol::Mysticeti
                 | ConsensusProtocol::CordialMiners
-                | ConsensusProtocol::SailfishPlusPlus => {
+                | ConsensusProtocol::SailfishPlusPlus
+                | ConsensusProtocol::Bluestreak => {
                     self.collect_subdag_ancestors(dag_state, leader_block)
                 }
             };