Skip to content

Commit 0edfbc4

Browse files
committed
f Account for BP taking Sweeper and LiqMan as arguments now
1 parent 0e29817 commit 0edfbc4

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

src/lib.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -551,6 +551,9 @@ impl Node {
551551
let background_chan_man = Arc::clone(&self.channel_manager);
552552
let background_gossip_sync = self.gossip_source.as_gossip_sync();
553553
let background_peer_man = Arc::clone(&self.peer_manager);
554+
let background_liquidity_man_opt =
555+
self.liquidity_source.as_ref().map(|ls| Arc::clone(&ls.liquidity_manager()));
556+
let background_sweeper = Arc::clone(&self.output_sweeper);
554557
let background_onion_messenger = Arc::clone(&self.onion_messenger);
555558
let background_logger = Arc::clone(&self.logger);
556559
let background_error_logger = Arc::clone(&self.logger);
@@ -587,6 +590,8 @@ impl Node {
587590
Some(background_onion_messenger),
588591
background_gossip_sync,
589592
background_peer_man,
593+
background_liquidity_man_opt,
594+
Some(background_sweeper),
590595
background_logger,
591596
Some(background_scorer),
592597
sleeper,

src/liquidity.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -277,8 +277,6 @@ where
277277
{
278278
pub(crate) fn set_peer_manager(&self, peer_manager: Arc<PeerManager>) {
279279
*self.peer_manager.write().unwrap() = Some(Arc::clone(&peer_manager));
280-
let process_msgs_callback = move || peer_manager.process_events();
281-
self.liquidity_manager.set_process_msgs_callback(process_msgs_callback);
282280
}
283281

284282
pub(crate) fn liquidity_manager(&self) -> &LiquidityManager {

0 commit comments

Comments
 (0)