Skip to content

Commit d243fc4

Browse files
foriequal0majecty
authored andcommitted
Do not convert to Bytes until it is necessary
1 parent 91f6389 commit d243fc4

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

core/src/consensus/tendermint/worker.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -571,7 +571,8 @@ impl Worker {
571571
self.validators.check_enough_votes(&self.prev_block_hash(), &votes).is_ok()
572572
}
573573

574-
fn broadcast_message(&self, message: Bytes) {
574+
fn broadcast_message(&self, message: ConsensusMessage) {
575+
let message = message.rlp_bytes().to_vec();
575576
self.extension
576577
.send(network::Event::BroadcastMessage {
577578
message,
@@ -831,7 +832,7 @@ impl Worker {
831832
}
832833
}
833834

834-
fn generate_message(&mut self, block_hash: Option<BlockHash>, is_restoring: bool) -> Option<Bytes> {
835+
fn generate_message(&mut self, block_hash: Option<BlockHash>, is_restoring: bool) -> Option<ConsensusMessage> {
835836
let height = self.height;
836837
let r = self.view;
837838
let on = VoteOn {
@@ -860,7 +861,7 @@ impl Worker {
860861
cinfo!(ENGINE, "Generated {:?} as {}th validator.", message, signer_index);
861862
self.handle_valid_message(&message, is_restoring);
862863

863-
Some(message.rlp_bytes().into_vec())
864+
Some(message)
864865
}
865866

866867
fn handle_valid_message(&mut self, message: &ConsensusMessage, is_restoring: bool) {

0 commit comments

Comments
 (0)