Prepare BankingStage to receive transaction indexes from PohRecorder

solana-labs · Jun 7, 2022 · ff74b86 · ff74b86
1 parent 708b03e
commit ff74b86
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/poh/src/poh_recorder.rs b/poh/src/poh_recorder.rs
@@ -84,14 +84,14 @@ pub struct Record {
     pub mixin: Hash,
     pub transactions: Vec<VersionedTransaction>,
     pub slot: Slot,
-    pub sender: Sender<Result<()>>,
+    pub sender: Sender<Result<Vec<usize>>>,
 }
 impl Record {
     pub fn new(
         mixin: Hash,
         transactions: Vec<VersionedTransaction>,
         slot: Slot,
-        sender: Sender<Result<()>>,
+        sender: Sender<Result<Vec<usize>>>,
     ) -> Self {
         Self {
             mixin,
@@ -128,7 +128,7 @@ impl TransactionRecorder {
         bank_slot: Slot,
         mixin: Hash,
         transactions: Vec<VersionedTransaction>,
-    ) -> Result<()> {
+    ) -> Result<Vec<usize>> {
         // create a new channel so that there is only 1 sender and when it goes out of scope, the receiver fails
         let (result_sender, result_receiver) = unbounded();
         let res =
@@ -742,7 +742,7 @@ impl PohRecorder {
         bank_slot: Slot,
         mixin: Hash,
         transactions: Vec<VersionedTransaction>,
-    ) -> Result<()> {
+    ) -> Result<Vec<usize>> {
         // Entries without transactions are used to track real-time passing in the ledger and
         // cannot be generated by `record()`
         assert!(!transactions.is_empty(), "No transactions provided");
@@ -787,7 +787,8 @@ impl PohRecorder {
                     "send_poh_entry",
                 );
                 self.send_entry_us += send_entry_time.as_us();
-                return Ok(send_entry_res?);
+                send_entry_res?;
+                return Ok(vec![]);
             }
 
             // record() might fail if the next PoH hash needs to be a tick.  But that's ok, tick()