Broadcast transaction after Status
@@ -359,11 +359,6 @@ impl<S> NodeHandler<S>
(propose_round, txs_count, txs)
};
- for tx in new_txs {
- assert!(tx.verify());
- self.handle_incoming_tx(tx);
- }
-
let height = self.state.height();
let proposer = self.state.leader(propose_round);
@@ -383,6 +378,12 @@ impl<S> NodeHandler<S>
self.broadcast_status();
self.add_status_timeout();
+ // Handle queued transactions from services
+ for tx in new_txs {
+ assert!(tx.verify());
+ self.handle_incoming_tx(tx);
+ }
+
// Add timeout for first round
self.add_round_timeout();
// Send propose we is leader
