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

help text examples + clean up (#2418)

Browse Source
This commit is contained in:
Sebastian Kunert
2023-04-01 16:44:32 +02:00
committed by GitHub
parent a79096f1d2
commit 59fb7ff59c
8 changed files with 59 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cumulus/client/relay-chain-minimal-node/src/collator_overseer.rs
+4 -4
View File
@@ -114,7 +114,7 @@ fn build_overseer<'a>(
.collation_generation(CollationGenerationSubsystem::new(Metrics::register(registry)?))
.collator_protocol({
let side = ProtocolSide::Collator(
network_service.local_peer_id().clone(),
network_service.local_peer_id(),
collator_pair,
collation_req_receiver,
Metrics::register(registry)?,
@@ -129,8 +129,8 @@ fn build_overseer<'a>(
peer_set_protocol_names.clone(),
))
.network_bridge_tx(NetworkBridgeTxSubsystem::new(
network_service.clone(),
authority_discovery_service.clone(),
network_service,
authority_discovery_service,
network_bridge_metrics,
req_protocol_names,
peer_set_protocol_names,
@@ -170,7 +170,7 @@ pub(crate) fn spawn_overseer(
e
})?;
let overseer_handle = Handle::new(overseer_handle.clone());
let overseer_handle = Handle::new(overseer_handle);
{
let handle = overseer_handle.clone();
task_manager.spawn_essential_handle().spawn_blocking(
cumulus/client/relay-chain-minimal-node/src/lib.rs
+5 -4
View File
@@ -69,7 +69,7 @@ fn build_authority_discovery_service<Block: BlockT>(
network.clone(),
Box::pin(dht_event_stream),
authority_discovery_role,
prometheus_registry.clone(),
prometheus_registry,
);
task_manager.spawn_handle().spawn(
@@ -150,9 +150,10 @@ async fn new_minimal_relay_chain(
let (collation_req_receiver, available_data_req_receiver) =
build_request_response_protocol_receivers(&request_protocol_names, &mut config);
let best_header = relay_chain_rpc_client.chain_get_header(None).await?.ok_or_else(|| {
RelayChainError::RpcCallError("Unable to fetch best header".to_string().into())
})?;
let best_header = relay_chain_rpc_client
.chain_get_header(None)
.await?
.ok_or_else(|| RelayChainError::RpcCallError("Unable to fetch best header".to_string()))?;
let (network, network_starter, sync_oracle) =
build_collator_network(&config, task_manager.spawn_handle(), genesis_hash, best_header)
.map_err(|e| RelayChainError::Application(Box::new(e) as Box<_>))?;