Add basic skeleton of certificate tracking (anza-xyz#36)

Fix master errors (anza-xyz#52)

Author: carllin

core/benches/consumer.rs

@@ -2,16 +2,14 @@
 #![feature(test)]
 
 use {
-    crossbeam_channel::{unbounded, Receiver},
+    crossbeam_channel::Receiver,
     rayon::{
         iter::IndexedParallelIterator,
         prelude::{IntoParallelIterator, IntoParallelRefIterator, ParallelIterator},
     },
     solana_account::{Account, ReadableAccount},
     solana_clock::Epoch,
-    solana_core::banking_stage::{
-        committer::Committer, consumer::Consumer, qos_service::QosService,
-    },
+    solana_core::banking_stage::consumer::Consumer,
     solana_entry::entry::Entry,
     solana_keypair::Keypair,
     solana_ledger::{
@@ -80,12 +78,6 @@ fn create_transactions(bank: &Bank, num: usize) -> Vec<RuntimeTransaction<Saniti
         .collect()
 }
 
-fn create_consumer(transaction_recorder: TransactionRecorder) -> Consumer {
-    let (replay_vote_sender, _replay_vote_receiver) = unbounded();
-    let committer = Committer::new(None, replay_vote_sender, Arc::default());
-    Consumer::new(committer, transaction_recorder, QosService::new(0), None)
-}
-
 struct BenchFrame {
     bank: Arc<Bank>,
     _bank_forks: Arc<RwLock<BankForks>>,
@@ -154,7 +146,7 @@ fn bench_process_and_record_transactions(bencher: &mut Bencher, batch_size: usiz
         poh_service,
         signal_receiver: _signal_receiver,
     } = setup();
-    let consumer = create_consumer(transaction_recorder);
+    let consumer = Consumer::from(&transaction_recorder);
     let transactions = create_transactions(&bank, 2_usize.pow(20));
     let mut transaction_iter = transactions.chunks(batch_size);
 

core/benches/receive_and_buffer_utils.rs

@@ -30,7 +30,7 @@ use {
     solana_signer::Signer,
     solana_transaction::versioned::VersionedTransaction,
     std::{
-        sync::{Arc, RwLock},
+        sync::{atomic::AtomicBool, Arc, RwLock},
         time::Instant,
     },
 };
@@ -194,6 +194,7 @@ pub fn setup_receive_and_buffer<T: ReceiveAndBuffer + ReceiveAndBufferCreator>(
     let bank_start = BankStart {
         working_bank: bank.clone(),
         bank_creation_time: Arc::new(Instant::now()),
+        contains_valid_certificate: Arc::new(AtomicBool::new(false)),
     };
 
     let (sender, receiver) = unbounded();

core/src/alpenglow_consensus.rs

@@ -0,0 +1,8 @@
+pub mod certificate_pool;
+pub mod skip_pool;
+pub mod vote_certificate;
+pub mod vote_history;
+pub mod vote_history_storage;
+
+pub type Stake = u64;
+pub const SUPERMAJORITY: f64 = 2f64 / 3f64;