TransactionScheduler: MultiIteratorConsumeScheduler

core/src/banking_stage/read_write_account_set.rs

@@ -49,7 +49,7 @@ impl ReadWriteAccountSet {
     }
 
     /// Check if a sanitized message's account locks are available.
-    fn check_sanitized_message_account_locks(&self, message: &SanitizedMessage) -> bool {
+    pub(crate) fn check_sanitized_message_account_locks(&self, message: &SanitizedMessage) -> bool {
         !message
             .account_keys()
             .iter()
@@ -64,7 +64,7 @@ impl ReadWriteAccountSet {
     }
 
     /// Insert the read and write locks for a sanitized message.
-    fn add_sanitized_message_account_locks(&mut self, message: &SanitizedMessage) {
+    pub(crate) fn add_sanitized_message_account_locks(&mut self, message: &SanitizedMessage) {
         message
             .account_keys()
             .iter()

core/src/banking_stage/transaction_scheduler/mod.rs

@@ -1,14 +1,14 @@
+mod batch_id_generator;
+#[allow(dead_code)]
+mod in_flight_tracker;
 #[allow(dead_code)]
+mod multi_iterator_consume_scheduler;
+mod scheduler_error;
 mod thread_aware_account_locks;
-
+#[allow(dead_code)]
+mod transaction_id_generator;
 mod transaction_priority_id;
 #[allow(dead_code)]
 mod transaction_state;
 #[allow(dead_code)]
 mod transaction_state_container;
-
-mod batch_id_generator;
-#[allow(dead_code)]
-mod in_flight_tracker;
-#[allow(dead_code)]
-mod transaction_id_generator;