diff --git a/polkadot/node/network/availability-distribution/src/pov_requester/mod.rs b/polkadot/node/network/availability-distribution/src/pov_requester/mod.rs index 5e26ae4b7a704..a0893baa411f3 100644 --- a/polkadot/node/network/availability-distribution/src/pov_requester/mod.rs +++ b/polkadot/node/network/availability-distribution/src/pov_requester/mod.rs @@ -66,7 +66,7 @@ pub async fn fetch_pov( ctx.send_message(NetworkBridgeTxMessage::SendRequests( vec![full_req], - IfDisconnected::ImmediateError, + IfDisconnected::TryConnect, )) .await; diff --git a/polkadot/node/network/availability-distribution/src/requester/fetch_task/mod.rs b/polkadot/node/network/availability-distribution/src/requester/fetch_task/mod.rs index c4654b843c447..71ce0281f2108 100644 --- a/polkadot/node/network/availability-distribution/src/requester/fetch_task/mod.rs +++ b/polkadot/node/network/availability-distribution/src/requester/fetch_task/mod.rs @@ -358,11 +358,8 @@ impl RunningTask { self.sender .send(FromFetchTask::Message( - NetworkBridgeTxMessage::SendRequests( - vec![requests], - IfDisconnected::ImmediateError, - ) - .into(), + NetworkBridgeTxMessage::SendRequests(vec![requests], IfDisconnected::TryConnect) + .into(), )) .await .map_err(|_| TaskError::ShuttingDown)?; diff --git a/polkadot/node/network/availability-recovery/src/task/strategy/full.rs b/polkadot/node/network/availability-recovery/src/task/strategy/full.rs index 1d7fbe8ea3c8d..d644c81c3ce45 100644 --- a/polkadot/node/network/availability-recovery/src/task/strategy/full.rs +++ b/polkadot/node/network/availability-recovery/src/task/strategy/full.rs @@ -86,7 +86,7 @@ impl RecoveryStrategy sender .send_message(NetworkBridgeTxMessage::SendRequests( vec![Requests::AvailableDataFetchingV1(req)], - IfDisconnected::ImmediateError, + IfDisconnected::TryConnect, )) .await; diff --git a/polkadot/node/network/collator-protocol/src/validator_side/mod.rs b/polkadot/node/network/collator-protocol/src/validator_side/mod.rs index 4ce3e2adea8f1..5974e67248f7f 100644 --- a/polkadot/node/network/collator-protocol/src/validator_side/mod.rs +++ b/polkadot/node/network/collator-protocol/src/validator_side/mod.rs @@ -746,7 +746,7 @@ async fn request_collation( sender .send_message(NetworkBridgeTxMessage::SendRequests( vec![requests], - IfDisconnected::ImmediateError, + IfDisconnected::TryConnect, )) .await; Ok(()) diff --git a/polkadot/node/network/statement-distribution/src/v2/mod.rs b/polkadot/node/network/statement-distribution/src/v2/mod.rs index 674f18aca2a5d..a9b4eff8bcaa5 100644 --- a/polkadot/node/network/statement-distribution/src/v2/mod.rs +++ b/polkadot/node/network/statement-distribution/src/v2/mod.rs @@ -2920,7 +2920,7 @@ pub(crate) async fn dispatch_requests(ctx: &mut Context, state: &mut St // Peer is supposedly connected. ctx.send_message(NetworkBridgeTxMessage::SendRequests( vec![Requests::AttestedCandidateV2(request)], - IfDisconnected::ImmediateError, + IfDisconnected::TryConnect, )) .await; } diff --git a/substrate/client/consensus/beefy/src/communication/request_response/outgoing_requests_engine.rs b/substrate/client/consensus/beefy/src/communication/request_response/outgoing_requests_engine.rs index 5408d95acf2d4..db781497008f9 100644 --- a/substrate/client/consensus/beefy/src/communication/request_response/outgoing_requests_engine.rs +++ b/substrate/client/consensus/beefy/src/communication/request_response/outgoing_requests_engine.rs @@ -128,7 +128,7 @@ impl OnDemandJustificationsEngine StateStrategy { self.protocol_name.clone(), request.encode_to_vec(), tx, - IfDisconnected::ImmediateError, + IfDisconnected::TryConnect, ); SyncingAction::StartRequest { diff --git a/substrate/client/network/sync/src/strategy/warp.rs b/substrate/client/network/sync/src/strategy/warp.rs index a4c9c0868b794..06426665713dd 100644 --- a/substrate/client/network/sync/src/strategy/warp.rs +++ b/substrate/client/network/sync/src/strategy/warp.rs @@ -685,7 +685,7 @@ where protocol_name, request.encode(), tx, - IfDisconnected::ImmediateError, + IfDisconnected::TryConnect, ); SyncingAction::StartRequest {