pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-05-10 01:47:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bump futures from 0.3.7 to 0.3.8 (#507)

Browse Source 
* Bump futures from 0.3.7 to 0.3.8

Bumps [futures](https://github.com/rust-lang/futures-rs) from 0.3.7 to 0.3.8.
- [Release notes](https://github.com/rust-lang/futures-rs/releases)
- [Changelog](https://github.com/rust-lang/futures-rs/blob/master/CHANGELOG.md)
- [Commits](https://github.com/rust-lang/futures-rs/compare/0.3.7...0.3.8)

Signed-off-by: dependabot-preview[bot] <support@dependabot.com>

* Fix clippy.

* Fix more clippy.

* Fix clippy again?

* Cliipy yet again.

Co-authored-by: dependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>
Co-authored-by: Tomasz Drwięga <tomasz@parity.io>
This commit is contained in:
dependabot-preview[bot]
2020-11-23 16:56:42 +01:00
committed by Bastian Köcher
parent a0261757f9
commit be56ee51d0
5 changed files with 20 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bridges/relays/ethereum/Cargo.toml
+1 -1
View File
@@ -15,7 +15,7 @@ env_logger = "0.8.2"
ethabi = "12.0"
ethabi-contract = "11.0"
ethabi-derive = "12.0"
futures = "0.3.7"
futures = "0.3.8"
hex = "0.4"
hex-literal = "0.3"
log = "0.4.11"
bridges/relays/headers-relay/src/sync_loop.rs
+12 -11
View File
@@ -126,6 +126,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
metrics_params: Option<MetricsParams>,
exit_signal: impl Future<Output = ()>,
) {
#![allow(unused_variables)] // this is to suppress weird errors from clippy
let mut local_pool = futures::executor::LocalPool::new();
let mut progress_context = (Instant::now(), None, None);
@@ -203,7 +204,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut source_retry_backoff,
|source_best_block_number| sync.source_best_header_number_response(source_best_block_number),
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving best header number from {}", P::SOURCE_NAME),
).is_ok();
},
@@ -213,7 +214,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut source_retry_backoff,
|source_new_header| sync.headers_mut().header_response(source_new_header),
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving header from {} node", P::SOURCE_NAME),
).is_ok();
},
@@ -223,7 +224,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut source_retry_backoff,
|source_orphan_header| sync.headers_mut().header_response(source_orphan_header),
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving orphan header from {} node", P::SOURCE_NAME),
).is_ok();
},
@@ -233,7 +234,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut source_retry_backoff,
|(header, extra)| sync.headers_mut().extra_response(&header, extra),
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving extra data from {} node", P::SOURCE_NAME),
).is_ok();
},
@@ -243,7 +244,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut source_retry_backoff,
|(header, completion)| sync.headers_mut().completion_response(&header, completion),
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving completion data from {} node", P::SOURCE_NAME),
).is_ok();
},
@@ -294,7 +295,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
}
},
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving best known {} header from {} node", P::SOURCE_NAME, P::TARGET_NAME),
).is_ok();
},
@@ -306,7 +307,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut target_retry_backoff,
|incomplete_headers_ids| sync.headers_mut().incomplete_headers_response(incomplete_headers_ids),
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving incomplete headers from {} node", P::TARGET_NAME),
).is_ok();
},
@@ -318,7 +319,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
.headers_mut()
.maybe_orphan_response(&target_header, target_existence_status),
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving existence status from {} node", P::TARGET_NAME),
).is_ok();
},
@@ -346,7 +347,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut target_retry_backoff,
|_| {},
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error submitting headers to {} node", P::TARGET_NAME),
).is_ok();
@@ -367,7 +368,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
&mut target_retry_backoff,
|completed_header| sync.headers_mut().header_completed(&completed_header),
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error completing headers at {}", P::TARGET_NAME),
).is_ok();
},
@@ -379,7 +380,7 @@ pub fn run<P: HeadersSyncPipeline, TC: TargetClient<P>>(
.headers_mut()
.maybe_extra_response(&header, extra_check_result),
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving receipts requirement from {} node", P::TARGET_NAME),
).is_ok();
},
bridges/relays/messages-relay/src/message_lane_loop.rs
+2 -2
View File
@@ -374,7 +374,7 @@ async fn run_until_connection_lost<P: MessageLane, SC: SourceClient<P>, TC: Targ
}
},
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving state from {} node", P::SOURCE_NAME),
).fail_if_connection_error(FailedClient::Source)?;
},
@@ -405,7 +405,7 @@ async fn run_until_connection_lost<P: MessageLane, SC: SourceClient<P>, TC: Targ
}
},
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving state from {} node", P::TARGET_NAME),
).fail_if_connection_error(FailedClient::Target)?;
},
bridges/relays/messages-relay/src/message_race_loop.rs
+4 -4
View File
@@ -269,7 +269,7 @@ pub async fn run<P: MessageRace, SC: SourceClient<P>>(
strategy.source_nonces_updated(at_block, nonces);
},
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving nonces from {}", P::source_name()),
).fail_if_connection_error(FailedClient::Source)?;
},
@@ -290,7 +290,7 @@ pub async fn run<P: MessageRace, SC: SourceClient<P>>(
strategy.target_nonces_updated(nonces, &mut race_state);
},
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error retrieving nonces from {}", P::target_name()),
).fail_if_connection_error(FailedClient::Target)?;
},
@@ -311,7 +311,7 @@ pub async fn run<P: MessageRace, SC: SourceClient<P>>(
race_state.nonces_to_submit = Some((at_block, nonces_range, proof));
},
&mut source_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error generating proof at {}", P::source_name()),
).fail_if_connection_error(FailedClient::Source)?;
},
@@ -331,7 +331,7 @@ pub async fn run<P: MessageRace, SC: SourceClient<P>>(
race_state.nonces_submitted = Some(nonces_range);
},
&mut target_go_offline_future,
|delay| async_std::task::sleep(delay),
async_std::task::sleep,
|| format!("Error submitting proof {}", P::target_name()),
).fail_if_connection_error(FailedClient::Target)?;
}
bridges/relays/substrate/Cargo.toml
+1 -1
View File
@@ -9,7 +9,7 @@ license = "GPL-3.0-or-later WITH Classpath-exception-2.0"
async-std = "1.7.0"
async-trait = "0.1.42"
codec = { package = "parity-scale-codec", version = "1.3.4" }
futures = "0.3.7"
futures = "0.3.8"
hex = "0.4"
log = "0.4.11"
num-traits = "0.2"