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

gossip-support: set last_session_index earlier (#3978)

Browse Source 
* gossip-support: set last_session_index earlier

* gossip-support: issue_connection_request never fails

* fmt
This commit is contained in:
Andronik Ordian
2021-10-01 00:04:37 +02:00
committed by GitHub
parent fb9656489a
commit 672ee582e0
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/network/gossip-support/src/lib.rs
+3 -6
View File
@@ -208,6 +208,7 @@ where
%session_index, %session_index,
"New session detected", "New session detected",
); );
self.last_session_index = Some(session_index);
} }
let all_authorities = determine_relevant_authorities(ctx, relay_parent).await?; let all_authorities = determine_relevant_authorities(ctx, relay_parent).await?;
@@ -218,10 +219,9 @@ where
authorities authorities
}; };
self.issue_connection_request(ctx, other_authorities).await?; self.issue_connection_request(ctx, other_authorities).await;
if is_new_session { if is_new_session {
self.last_session_index = Some(session_index);
update_gossip_topology(ctx, our_index, all_authorities, relay_parent).await?; update_gossip_topology(ctx, our_index, all_authorities, relay_parent).await?;
} }
} }
@@ -234,8 +234,7 @@ where
&mut self, &mut self,
ctx: &mut Context, ctx: &mut Context,
authorities: Vec<AuthorityDiscoveryId>, authorities: Vec<AuthorityDiscoveryId>,
) -> Result<(), util::Error> ) where
where
Context: SubsystemContext<Message = GossipSupportMessage>, Context: SubsystemContext<Message = GossipSupportMessage>,
Context: overseer::SubsystemContext<Message = GossipSupportMessage>, Context: overseer::SubsystemContext<Message = GossipSupportMessage>,
{ {
@@ -295,8 +294,6 @@ where
self.last_failure = None; self.last_failure = None;
self.failure_start = None; self.failure_start = None;
}; };
Ok(())
} }
fn handle_connect_disconnect(&mut self, ev: NetworkBridgeEvent<GossipSuppportNetworkMessage>) { fn handle_connect_disconnect(&mut self, ev: NetworkBridgeEvent<GossipSuppportNetworkMessage>) {