Skip to content
GitLab
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
Open sidebar
parity
Mirrored projects
polkadot
Commits
15ba4efd
Unverified
Commit
15ba4efd
authored
Oct 09, 2020
by
Bastian Köcher
Committed by
GitHub
Oct 09, 2020
Browse files
Rename `node_handles` to `overseer_handler` (#1803)
They are not node handles anymore ;)
parent
6b4225f5
Pipeline
#110278
passed with stages
in 23 minutes and 29 seconds
Changes
2
Pipelines
4
Hide whitespace changes
Inline
Side-by-side
node/service/src/lib.rs
View file @
15ba4efd
...
...
@@ -301,7 +301,7 @@ fn real_overseer<S: SpawnNamed>(
pub
struct
NewFull
<
C
>
{
pub
task_manager
:
TaskManager
,
pub
client
:
C
,
pub
node
_handle
s
:
OverseerHandler
,
pub
overseer
_handle
r
:
OverseerHandler
,
pub
network
:
Arc
<
sc_network
::
NetworkService
<
Block
,
<
Block
as
BlockT
>
::
Hash
>>
,
pub
network_status_sinks
:
service
::
NetworkStatusSinks
<
Block
>
,
pub
rpc_handlers
:
RpcHandlers
,
...
...
@@ -313,7 +313,7 @@ impl<C> NewFull<C> {
NewFull
{
client
:
func
(
self
.client
),
task_manager
:
self
.task_manager
,
node
_handle
s
:
self
.
node
_handle
s
,
overseer
_handle
r
:
self
.
overseer
_handle
r
,
network
:
self
.network
,
network_status_sinks
:
self
.network_status_sinks
,
rpc_handlers
:
self
.rpc_handlers
,
...
...
@@ -415,13 +415,13 @@ pub fn new_full<RuntimeApi, Executor>(
})
.collect
();
let
(
overseer
,
handler
)
=
real_overseer
(
leaves
,
prometheus_registry
.as_ref
(),
spawner
)
?
;
let
handler_clone
=
handler
.clone
();
let
(
overseer
,
overseer_
handler
)
=
real_overseer
(
leaves
,
prometheus_registry
.as_ref
(),
spawner
)
?
;
let
overseer_
handler_clone
=
overseer_
handler
.clone
();
task_manager
.spawn_essential_handle
()
.spawn_blocking
(
"overseer"
,
Box
::
pin
(
async
move
{
use
futures
::{
pin_mut
,
select
,
FutureExt
};
let
forward
=
polkadot_overseer
::
forward_events
(
overseer_client
,
handler_clone
);
let
forward
=
polkadot_overseer
::
forward_events
(
overseer_client
,
overseer_
handler_clone
);
let
forward
=
forward
.fuse
();
let
overseer_fut
=
overseer
.run
()
.fuse
();
...
...
@@ -445,7 +445,7 @@ pub fn new_full<RuntimeApi, Executor>(
let
proposer
=
ProposerFactory
::
new
(
client
.clone
(),
transaction_pool
,
handler
.clone
(),
overseer_
handler
.clone
(),
);
let
babe_config
=
babe
::
BabeParams
{
...
...
@@ -575,7 +575,7 @@ pub fn new_full<RuntimeApi, Executor>(
Ok
(
NewFull
{
task_manager
,
client
,
node_handles
:
handler
,
overseer_
handler
,
network
,
network_status_sinks
,
rpc_handlers
,
...
...
node/test-service/src/lib.rs
View file @
15ba4efd
...
...
@@ -193,7 +193,7 @@ pub fn run_test_node(
let
config
=
node_config
(
storage_update_func
,
task_executor
,
key
,
boot_nodes
);
let
multiaddr
=
config
.network.listen_addresses
[
0
]
.clone
();
let
authority_discovery_enabled
=
false
;
let
NewFull
{
task_manager
,
client
,
network
,
rpc_handlers
,
node
_handle
s
,
..
}
=
let
NewFull
{
task_manager
,
client
,
network
,
rpc_handlers
,
overseer
_handle
r
,
..
}
=
polkadot_test_new_full
(
config
,
authority_discovery_enabled
)
.expect
(
"could not create Polkadot test service"
);
...
...
@@ -203,7 +203,7 @@ pub fn run_test_node(
PolkadotTestNode
{
task_manager
,
client
,
handles
:
node
_handle
s
,
overseer
_handle
r
,
addr
,
rpc_handlers
,
}
...
...
@@ -215,8 +215,8 @@ pub struct PolkadotTestNode<S, C> {
pub
task_manager
:
S
,
/// Client's instance.
pub
client
:
Arc
<
C
>
,
///
Node's
handle
s
.
pub
handle
s
:
OverseerHandler
,
///
The overseer
handle
r
.
pub
overseer_
handle
r
:
OverseerHandler
,
/// The `MultiaddrWithPeerId` to this node. This is useful if you want to pass it as "boot node" to other nodes.
pub
addr
:
MultiaddrWithPeerId
,
/// RPCHandlers to make RPC queries.
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment