pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-04-26 08:47:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Break cycle collator-procol - backing (#5883)

Browse Source
This commit is contained in:
Robert Klotzner
2022-08-16 17:31:12 +02:00
committed by GitHub
parent 05a7966505
commit 16a356524b
1 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/core/backing/src/lib.rs
+16 -7
View File
@@ -811,17 +811,22 @@ impl<Context> CandidateBackingJob<Context> {
.sign_import_and_distribute_statement(ctx, statement, root_span)
.await?
{
ctx.send_message(CollatorProtocolMessage::Seconded(
// Break cycle - bounded as there is only one candidate to
// second per block.
ctx.send_unbounded_message(CollatorProtocolMessage::Seconded(
self.parent,
stmt,
))
.await;
));
}
}
},
Err(candidate) => {
ctx.send_message(CollatorProtocolMessage::Invalid(self.parent, candidate))
.await;
// Break cycle - bounded as there is only one candidate to
// second per block.
ctx.send_unbounded_message(CollatorProtocolMessage::Invalid(
self.parent,
candidate,
));
},
}
},
@@ -911,8 +916,12 @@ impl<Context> CandidateBackingJob<Context> {
.as_ref()
.map_or(false, |c| c != &candidate.descriptor().collator)
{
ctx.send_message(CollatorProtocolMessage::Invalid(self.parent, candidate.clone()))
.await;
// Break cycle - bounded as there is only one candidate to
// second per block.
ctx.send_unbounded_message(CollatorProtocolMessage::Invalid(
self.parent,
candidate.clone(),
));
return Ok(())
}