Banking worker

core/src/banking_stage.rs

@@ -48,9 +48,12 @@ pub mod consumer;
 mod decision_maker;
 mod forwarder;
 mod packet_receiver;
+
 #[allow(dead_code)]
 mod scheduler_messages;
 
+mod consume_worker;
+mod forward_worker;
 #[allow(dead_code)]
 mod thread_aware_account_locks;
 
@@ -609,6 +612,7 @@ mod tests {
             pubkey::Pubkey,
             signature::{Keypair, Signer},
             system_transaction,
+            transaction::{SanitizedTransaction, Transaction},
         },
         solana_streamer::socket::SocketAddrSpace,
         solana_vote_program::{
@@ -628,6 +632,12 @@ mod tests {
         (node, cluster_info)
     }
 
+    pub(crate) fn sanitize_transactions(txs: Vec<Transaction>) -> Vec<SanitizedTransaction> {
+        txs.into_iter()
+            .map(SanitizedTransaction::from_transaction_for_tests)
+            .collect()
+    }
+
     #[test]
     fn test_banking_stage_shutdown1() {
         let genesis_config = create_genesis_config(2).genesis_config;