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

Gossip through all peers. (#359)

Browse Source 
* Added some traces

* Gossip for all

* Fixed formatting
This commit is contained in:
Arkadiy Paronyan
2018-07-18 12:07:05 +02:00
committed by Gav Wood
parent 14abd75369
commit be1c0a2427
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/network/src/lib.rs
+4
View File
@@ -183,6 +183,7 @@ impl CurrentConsensus {
} }
/// Polkadot-specific messages. /// Polkadot-specific messages.
#[derive(Debug)]
pub enum Message { pub enum Message {
/// signed statement and localized parent hash. /// signed statement and localized parent hash.
Statement(Hash, SignedStatement), Statement(Hash, SignedStatement),
@@ -250,6 +251,7 @@ impl Decode for Message {
} }
fn send_polkadot_message(ctx: &mut Context<Block>, to: PeerId, message: Message) { fn send_polkadot_message(ctx: &mut Context<Block>, to: PeerId, message: Message) {
trace!(target: "p_net", "Sending polkadot message to {}: {:?}", to, message);
let encoded = message.encode(); let encoded = message.encode();
ctx.send_message(to, generic_message::Message::ChainSpecific(encoded)) ctx.send_message(to, generic_message::Message::ChainSpecific(encoded))
} }
@@ -386,6 +388,7 @@ impl PolkadotProtocol {
} }
fn on_polkadot_message(&mut self, ctx: &mut Context<Block>, peer_id: PeerId, raw: Vec<u8>, msg: Message) { fn on_polkadot_message(&mut self, ctx: &mut Context<Block>, peer_id: PeerId, raw: Vec<u8>, msg: Message) {
trace!(target: "p_net", "Polkadot message from {}: {:?}", peer_id, msg);
match msg { match msg {
Message::Statement(parent_hash, _statement) => Message::Statement(parent_hash, _statement) =>
self.consensus_gossip.on_chain_specific(ctx, peer_id, raw, parent_hash), self.consensus_gossip.on_chain_specific(ctx, peer_id, raw, parent_hash),
@@ -535,6 +538,7 @@ impl Specialization<Block> for PolkadotProtocol {
fn on_message(&mut self, ctx: &mut Context<Block>, peer_id: PeerId, message: message::Message<Block>) { fn on_message(&mut self, ctx: &mut Context<Block>, peer_id: PeerId, message: message::Message<Block>) {
match message { match message {
generic_message::Message::BftMessage(msg) => { generic_message::Message::BftMessage(msg) => {
trace!(target: "p_net", "Polkadot BFT message from {}: {:?}", peer_id, msg);
// TODO: check signature here? what if relevant block is unknown? // TODO: check signature here? what if relevant block is unknown?
self.consensus_gossip.on_bft_message(ctx, peer_id, msg) self.consensus_gossip.on_bft_message(ctx, peer_id, msg)
} }