Skip to content

Commit 7889b58

Browse files
committed
f fix no-std
1 parent d8175ce commit 7889b58

File tree

2 files changed

+24
-6
lines changed

2 files changed

+24
-6
lines changed

lightning/src/ln/functional_test_utils.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
//! A bunch of useful utilities for building networks of nodes and exchanging messages between
1111
//! nodes for functional tests.
1212
13-
use crate::chain::{BestBlock, ChannelMonitorUpdateStatus, Confirm, Listen, Watch, chainmonitor::Persist};
13+
use crate::chain::{BestBlock, ChannelMonitorUpdateStatus, Confirm, Listen, Watch};
1414
use crate::chain::channelmonitor::ChannelMonitor;
1515
use crate::chain::transaction::OutPoint;
1616
use crate::events::{ClaimedHTLC, ClosureReason, Event, HTLCDestination, PathFailure, PaymentPurpose, PaymentFailureReason};
@@ -3286,7 +3286,7 @@ pub fn create_node_cfgs<'a>(node_count: usize, chanmon_cfgs: &'a Vec<TestChanMon
32863286
create_node_cfgs_with_persisters(node_count, chanmon_cfgs, chanmon_cfgs.iter().map(|c| &c.persister).collect())
32873287
}
32883288

3289-
pub fn create_node_cfgs_with_persisters<'a>(node_count: usize, chanmon_cfgs: &'a Vec<TestChanMonCfg>, persisters: Vec<&'a (impl Persist<TestChannelSigner> + Sync)>) -> Vec<NodeCfg<'a>> {
3289+
pub fn create_node_cfgs_with_persisters<'a>(node_count: usize, chanmon_cfgs: &'a Vec<TestChanMonCfg>, persisters: Vec<&'a impl test_utils::SyncPersist>) -> Vec<NodeCfg<'a>> {
32903290
let mut nodes = Vec::new();
32913291

32923292
for i in 0..node_count {

lightning/src/util/test_utils.rs

Lines changed: 22 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -378,17 +378,35 @@ impl SignerProvider for OnlyReadsKeysInterface {
378378
}
379379
}
380380

381+
#[cfg(feature = "std")]
382+
pub trait SyncBroadcaster : chaininterface::BroadcasterInterface + Sync {}
383+
#[cfg(feature = "std")]
384+
pub trait SyncPersist : Persist<TestChannelSigner> + Sync {}
385+
#[cfg(feature = "std")]
386+
impl<T: chaininterface::BroadcasterInterface + Sync> SyncBroadcaster for T {}
387+
#[cfg(feature = "std")]
388+
impl<T: Persist<TestChannelSigner> + Sync> SyncPersist for T {}
389+
390+
#[cfg(not(feature = "std"))]
391+
pub trait SyncBroadcaster : chaininterface::BroadcasterInterface {}
392+
#[cfg(not(feature = "std"))]
393+
pub trait SyncPersist : Persist<TestChannelSigner> {}
394+
#[cfg(not(feature = "std"))]
395+
impl<T: chaininterface::BroadcasterInterface> SyncBroadcaster for T {}
396+
#[cfg(not(feature = "std"))]
397+
impl<T: Persist<TestChannelSigner>> SyncPersist for T {}
398+
381399
pub struct TestChainMonitor<'a> {
382400
pub added_monitors: Mutex<Vec<(ChannelId, ChannelMonitor<TestChannelSigner>)>>,
383401
pub monitor_updates: Mutex<HashMap<ChannelId, Vec<ChannelMonitorUpdate>>>,
384402
pub latest_monitor_update_id: Mutex<HashMap<ChannelId, (u64, u64)>>,
385403
pub chain_monitor: ChainMonitor<
386404
TestChannelSigner,
387405
&'a TestChainSource,
388-
&'a (dyn chaininterface::BroadcasterInterface + Sync),
406+
&'a dyn SyncBroadcaster,
389407
&'a TestFeeEstimator,
390408
&'a TestLogger,
391-
&'a (dyn Persist<TestChannelSigner> + Sync),
409+
&'a dyn SyncPersist,
392410
>,
393411
pub keys_manager: &'a TestKeysInterface,
394412
/// If this is set to Some(), the next update_channel call (not watch_channel) must be a
@@ -402,8 +420,8 @@ pub struct TestChainMonitor<'a> {
402420
impl<'a> TestChainMonitor<'a> {
403421
pub fn new(
404422
chain_source: Option<&'a TestChainSource>,
405-
broadcaster: &'a (dyn chaininterface::BroadcasterInterface + Sync), logger: &'a TestLogger,
406-
fee_estimator: &'a TestFeeEstimator, persister: &'a (dyn Persist<TestChannelSigner> + Sync),
423+
broadcaster: &'a dyn SyncBroadcaster, logger: &'a TestLogger,
424+
fee_estimator: &'a TestFeeEstimator, persister: &'a dyn SyncPersist,
407425
keys_manager: &'a TestKeysInterface,
408426
) -> Self {
409427
Self {

0 commit comments

Comments
 (0)