From 72723c8a9f1340ca23aba1cec7dcab171af341c5 Mon Sep 17 00:00:00 2001 From: Robert Klotzner Date: Mon, 30 May 2022 22:04:12 +0200 Subject: [PATCH] Request backed candidates unbounded. (#5610) We are awaiting on the oneshot anyways, so we have back pressure. By using the unbounded channel make log messages like the following less likely (due to higher priority): 2022-05-30 13:46:38 2022-05-30 11:46:38.565 WARN tokio-runtime-worker parachain::provisioner: failed to assemble or send inherent data err=CanceledBackedCandidates(Canceled) --- polkadot/node/core/provisioner/src/lib.rs | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/polkadot/node/core/provisioner/src/lib.rs b/polkadot/node/core/provisioner/src/lib.rs index 4c41eb8256..66602ac605 100644 --- a/polkadot/node/core/provisioner/src/lib.rs +++ b/polkadot/node/core/provisioner/src/lib.rs @@ -505,13 +505,11 @@ async fn select_candidates( // now get the backed candidates corresponding to these candidate receipts let (tx, rx) = oneshot::channel(); - sender - .send_message(CandidateBackingMessage::GetBackedCandidates( - relay_parent, - selected_candidates.clone(), - tx, - )) - .await; + sender.send_unbounded_message(CandidateBackingMessage::GetBackedCandidates( + relay_parent, + selected_candidates.clone(), + tx, + )); let mut candidates = rx.await.map_err(|err| Error::CanceledBackedCandidates(err))?; // `selected_candidates` is generated in ascending order by core index, and `GetBackedCandidates`