pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-05-30 23:21:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

don't acquire the lock unless, and only hold it for as long as, necessary. (#2530)

Browse Source
This commit is contained in:
Gregory Terzian
2019-05-10 20:15:36 +08:00
committed by Gavin Wood
parent 42fa5f6209
commit 363448cd01
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/core/finality-grandpa/src/communication/gossip.rs
+3 -4
View File
@@ -623,13 +623,12 @@ impl<Block: BlockT> GossipValidator<Block> {
{ {
let mut broadcast_topics = Vec::new(); let mut broadcast_topics = Vec::new();
let action = { let action = {
let mut inner = self.inner.write();
match GossipMessage::<Block>::decode(&mut data) { match GossipMessage::<Block>::decode(&mut data) {
Some(GossipMessage::VoteOrPrecommit(ref message)) Some(GossipMessage::VoteOrPrecommit(ref message))
=> inner.validate_round_message(who, message), => self.inner.write().validate_round_message(who, message),
Some(GossipMessage::Commit(ref message)) => inner.validate_commit_message(who, message), Some(GossipMessage::Commit(ref message)) => self.inner.write().validate_commit_message(who, message),
Some(GossipMessage::Neighbor(update)) => { Some(GossipMessage::Neighbor(update)) => {
let (topics, action) = inner.import_neighbor_message( let (topics, action) = self.inner.write().import_neighbor_message(
who, who,
update.into_neighbor_packet(), update.into_neighbor_packet(),
); );