@@ -13,15 +13,15 @@ use std::sync::Mutex;
1313
1414use lightning:: events:: ClosureReason ;
1515use lightning:: ln:: functional_test_utils:: {
16- check_closed_event, connect_block, create_announced_chan_between_nodes, create_chanmon_cfgs ,
17- create_dummy_block, create_network, create_node_cfgs, create_node_chanmgrs, send_payment ,
18- TestChanMonCfg ,
16+ check_added_monitors , check_closed_event, connect_block, create_announced_chan_between_nodes,
17+ create_chanmon_cfgs , create_dummy_block, create_network, create_node_cfgs, create_node_chanmgrs,
18+ send_payment , TestChanMonCfg ,
1919} ;
2020use lightning:: util:: persist:: {
2121 KVStore , KVStoreSync , MonitorUpdatingPersister , KVSTORE_NAMESPACE_KEY_MAX_LEN ,
2222} ;
2323use lightning:: util:: test_utils;
24- use lightning:: { check_added_monitors , check_closed_broadcast, io} ;
24+ use lightning:: { check_closed_broadcast, io} ;
2525use rand:: distr:: Alphanumeric ;
2626use rand:: { rng, Rng } ;
2727
@@ -333,7 +333,7 @@ pub(crate) fn do_test_store<K: KVStoreSync + Sync>(store_0: &K, store_1: &K) {
333333 100000 ,
334334 ) ;
335335 check_closed_broadcast ! ( nodes[ 0 ] , true ) ;
336- check_added_monitors ! ( nodes[ 0 ] , 1 ) ;
336+ check_added_monitors ( & nodes[ 0 ] , 1 ) ;
337337
338338 let node_txn = nodes[ 0 ] . tx_broadcaster . txn_broadcast ( ) ;
339339 assert_eq ! ( node_txn. len( ) , 1 ) ;
@@ -345,7 +345,7 @@ pub(crate) fn do_test_store<K: KVStoreSync + Sync>(store_0: &K, store_1: &K) {
345345 let reason = ClosureReason :: CommitmentTxConfirmed ;
346346 let node_id_0 = nodes[ 0 ] . node . get_our_node_id ( ) ;
347347 check_closed_event ( & nodes[ 1 ] , 1 , reason, & [ node_id_0] , 100000 ) ;
348- check_added_monitors ! ( nodes[ 1 ] , 1 ) ;
348+ check_added_monitors ( & nodes[ 1 ] , 1 ) ;
349349
350350 // Make sure everything is persisted as expected after close.
351351 check_persisted_data ! ( persister_0_max_pending_updates * 2 * EXPECTED_UPDATES_PER_PAYMENT + 1 ) ;
0 commit comments