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

Companion PR for #8682 (#2958)

Browse Source 
* Companion PR for #8682

* Compilation fix

* Update beefy

* update Substrate

Co-authored-by: parity-processbot <>
This commit is contained in:
Pierre Krieger
2021-05-06 16:41:28 +02:00
committed by GitHub
parent 1508024a47
commit 64c8b913c3
3 changed files with 187 additions and 157 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/Cargo.lock
Generated
+183 -156
View File
File diff suppressed because it is too large Load Diff
polkadot/node/network/bridge/src/lib.rs
+2 -1
View File
@@ -573,7 +573,7 @@ async fn handle_network_messages<AD: validator_discovery::AuthorityDiscovery>(
Some(NetworkEvent::Dht(_)) Some(NetworkEvent::Dht(_))
| Some(NetworkEvent::SyncConnected { .. }) | Some(NetworkEvent::SyncConnected { .. })
| Some(NetworkEvent::SyncDisconnected { .. }) => {} | Some(NetworkEvent::SyncDisconnected { .. }) => {}
Some(NetworkEvent::NotificationStreamOpened { remote: peer, protocol, role }) => { Some(NetworkEvent::NotificationStreamOpened { remote: peer, protocol, role, .. }) => {
let role = ObservedRole::from(role); let role = ObservedRole::from(role);
let peer_set = match PeerSet::try_from_protocol_name(&protocol) { let peer_set = match PeerSet::try_from_protocol_name(&protocol) {
None => continue, None => continue,
@@ -1287,6 +1287,7 @@ mod tests {
self.send_network_event(NetworkEvent::NotificationStreamOpened { self.send_network_event(NetworkEvent::NotificationStreamOpened {
remote: peer, remote: peer,
protocol: peer_set.into_protocol_name(), protocol: peer_set.into_protocol_name(),
negotiated_fallback: None,
role: role.into(), role: role.into(),
}).await; }).await;
} }
polkadot/node/network/protocol/src/peer_set.rs
+2
View File
@@ -53,6 +53,7 @@ impl PeerSet {
match self { match self {
PeerSet::Validation => NonDefaultSetConfig { PeerSet::Validation => NonDefaultSetConfig {
notifications_protocol: protocol, notifications_protocol: protocol,
fallback_names: Vec::new(),
max_notification_size, max_notification_size,
set_config: sc_network::config::SetConfig { set_config: sc_network::config::SetConfig {
// we allow full nodes to connect to validators for gossip // we allow full nodes to connect to validators for gossip
@@ -67,6 +68,7 @@ impl PeerSet {
}, },
PeerSet::Collation => NonDefaultSetConfig { PeerSet::Collation => NonDefaultSetConfig {
notifications_protocol: protocol, notifications_protocol: protocol,
fallback_names: Vec::new(),
max_notification_size, max_notification_size,
set_config: SetConfig { set_config: SetConfig {
// Non-authority nodes don't need to accept incoming connections on this peer set: // Non-authority nodes don't need to accept incoming connections on this peer set: