Skip to content

Commit f2ce650

Browse files
fix: start p2p network after engine
1 parent a385aa0 commit f2ce650

1 file changed

Lines changed: 6 additions & 4 deletions

File tree

node/src/args.rs

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -406,8 +406,6 @@ impl Command {
406406
let backfiller =
407407
network.register(BACKFILLER_CHANNEL, config.backfill_quota, MESSAGE_BACKLOG);
408408

409-
// Create network
410-
let p2p = network.start();
411409
// create engine
412410
let engine: Engine<_, _, _, _> =
413411
Engine::new(context.with_label("engine"), config).await;
@@ -417,6 +415,9 @@ impl Command {
417415
// Start engine
418416
let engine = engine.start(pending, recovered, resolver, broadcaster, backfiller);
419417

418+
// Create network
419+
let p2p = network.start();
420+
420421
// Start RPC server
421422
let key_store_path = flags.key_store_path.clone();
422423
let rpc_port = flags.rpc_port;
@@ -589,15 +590,16 @@ pub fn run_node_local(
589590
let backfiller =
590591
network.register(BACKFILLER_CHANNEL, config.backfill_quota, MESSAGE_BACKLOG);
591592

592-
// Create network
593-
let p2p = network.start();
594593
// create engine
595594
let engine: Engine<_, _, _, _> = Engine::new(context.with_label("engine"), config).await;
596595

597596
let finalizer_mailbox = engine.finalizer_mailbox.clone();
598597
// Start engine
599598
let engine = engine.start(pending, recovered, resolver, broadcaster, backfiller);
600599

600+
// Create network
601+
let p2p = network.start();
602+
601603
// Start prometheus endpoint
602604
#[cfg(feature = "prom")]
603605
{

0 commit comments

Comments
 (0)