mirror of
https://github.com/alexgo-io/stacks-puppet-node.git
synced 2026-06-18 03:38:57 +08:00
fix: pass thru sync_comms so the relayer thread can be aware of ibd status
This commit is contained in:
@@ -828,6 +828,7 @@ fn spawn_miner_relayer(
|
||||
microblocks_processed: BlocksProcessedCounter,
|
||||
burnchain: Burnchain,
|
||||
coord_comms: CoordinatorChannels,
|
||||
sync_comms: PoxSyncWatchdogComms,
|
||||
unconfirmed_txs: Arc<Mutex<UnconfirmedTxMap>>,
|
||||
) -> Result<JoinHandle<()>, NetError> {
|
||||
// Note: the chainstate coordinator is *the* block processor, it is responsible for writes to
|
||||
@@ -873,6 +874,7 @@ fn spawn_miner_relayer(
|
||||
&mut sortdb,
|
||||
&mut chainstate,
|
||||
&mut mem_pool,
|
||||
sync_comms.get_ibd(),
|
||||
Some(&coord_comms),
|
||||
Some(&event_dispatcher),
|
||||
)
|
||||
@@ -1357,6 +1359,7 @@ impl InitializedNeonNode {
|
||||
microblocks_processed.clone(),
|
||||
burnchain,
|
||||
coord_comms,
|
||||
sync_comms.clone(),
|
||||
shared_unconfirmed_txs.clone(),
|
||||
)
|
||||
.expect("Failed to initialize mine/relay thread");
|
||||
|
||||
Reference in New Issue
Block a user