Unverified Commit d3cb5942 authored by Cecile Tonglet's avatar Cecile Tonglet Committed by GitHub
Browse files

Polkadot companion for #8043 (#2382)

* WIP

* WIP

* WIP

* Revert branch change

* CLEANUP

* "Update Substrate"

* Fix build

* Revert "Fix build"

This reverts commit 2dcc3f2a.

* cargo update -p sp-io

Co-authored-by: parity-processbot <>
parent 71475c85
Pipeline #124444 passed with stages
in 33 minutes and 43 seconds
This diff is collapsed.
...@@ -53,7 +53,7 @@ use std::sync::Arc; ...@@ -53,7 +53,7 @@ use std::sync::Arc;
use prometheus_endpoint::Registry; use prometheus_endpoint::Registry;
use sc_executor::native_executor_instance; use sc_executor::native_executor_instance;
use service::RpcHandlers; use service::RpcHandlers;
use telemetry::TelemetryConnectionNotifier; use telemetry::{TelemetryConnectionNotifier, TelemetrySpan};
pub use self::client::{AbstractClient, Client, ClientHandle, ExecuteWithClient, RuntimeApiCollection}; pub use self::client::{AbstractClient, Client, ClientHandle, ExecuteWithClient, RuntimeApiCollection};
pub use chain_spec::{PolkadotChainSpec, KusamaChainSpec, WestendChainSpec, RococoChainSpec}; pub use chain_spec::{PolkadotChainSpec, KusamaChainSpec, WestendChainSpec, RococoChainSpec};
...@@ -648,6 +648,9 @@ pub fn new_full<RuntimeApi, Executor>( ...@@ -648,6 +648,9 @@ pub fn new_full<RuntimeApi, Executor>(
let availability_config = config.database.clone().try_into().map_err(Error::Availability)?; let availability_config = config.database.clone().try_into().map_err(Error::Availability)?;
let telemetry_span = TelemetrySpan::new();
let _telemetry_span_entered = telemetry_span.enter();
let (rpc_handlers, telemetry_connection_notifier) = service::spawn_tasks(service::SpawnTasksParams { let (rpc_handlers, telemetry_connection_notifier) = service::spawn_tasks(service::SpawnTasksParams {
config, config,
backend: backend.clone(), backend: backend.clone(),
...@@ -661,6 +664,7 @@ pub fn new_full<RuntimeApi, Executor>( ...@@ -661,6 +664,7 @@ pub fn new_full<RuntimeApi, Executor>(
remote_blockchain: None, remote_blockchain: None,
network_status_sinks: network_status_sinks.clone(), network_status_sinks: network_status_sinks.clone(),
system_rpc_tx, system_rpc_tx,
telemetry_span: Some(telemetry_span.clone()),
})?; })?;
let (block_import, link_half, babe_link) = import_setup; let (block_import, link_half, babe_link) = import_setup;
...@@ -965,6 +969,9 @@ fn new_light<Runtime, Dispatch>(mut config: Configuration) -> Result<( ...@@ -965,6 +969,9 @@ fn new_light<Runtime, Dispatch>(mut config: Configuration) -> Result<(
let rpc_extensions = polkadot_rpc::create_light(light_deps); let rpc_extensions = polkadot_rpc::create_light(light_deps);
let telemetry_span = TelemetrySpan::new();
let _telemetry_span_entered = telemetry_span.enter();
let (rpc_handlers, telemetry_connection_notifier) = service::spawn_tasks(service::SpawnTasksParams { let (rpc_handlers, telemetry_connection_notifier) = service::spawn_tasks(service::SpawnTasksParams {
on_demand: Some(on_demand), on_demand: Some(on_demand),
remote_blockchain: Some(backend.remote_blockchain()), remote_blockchain: Some(backend.remote_blockchain()),
...@@ -978,6 +985,7 @@ fn new_light<Runtime, Dispatch>(mut config: Configuration) -> Result<( ...@@ -978,6 +985,7 @@ fn new_light<Runtime, Dispatch>(mut config: Configuration) -> Result<(
network, network,
network_status_sinks, network_status_sinks,
system_rpc_tx, system_rpc_tx,
telemetry_span: Some(telemetry_span.clone()),
})?; })?;
network_starter.start_network(); network_starter.start_network();
......
...@@ -199,7 +199,6 @@ pub fn node_config( ...@@ -199,7 +199,6 @@ pub fn node_config(
informant_output_format: Default::default(), informant_output_format: Default::default(),
disable_log_reloading: false, disable_log_reloading: false,
telemetry_handle: None, telemetry_handle: None,
telemetry_span: None,
} }
} }
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment