44#![ deny( rustdoc:: broken_intra_doc_links) ]
55#![ deny( rustdoc:: private_intra_doc_links) ]
66#![ deny( missing_docs) ]
7- #![ cfg_attr( not( feature = "futures" ) , deny( unsafe_code) ) ]
87#![ cfg_attr( docsrs, feature( doc_auto_cfg) ) ]
98#![ cfg_attr( all( not( feature = "std" ) , not( test) ) , no_std) ]
109
@@ -25,7 +24,6 @@ use lightning::chain::chainmonitor::{ChainMonitor, Persist};
2524use lightning:: events:: EventHandler ;
2625#[ cfg( feature = "std" ) ]
2726use lightning:: events:: EventsProvider ;
28- #[ cfg( feature = "futures" ) ]
2927use lightning:: events:: ReplayEvent ;
3028use lightning:: events:: { Event , PathFailure } ;
3129
@@ -36,14 +34,12 @@ use lightning::onion_message::messenger::AOnionMessenger;
3634use lightning:: routing:: gossip:: { NetworkGraph , P2PGossipSync } ;
3735use lightning:: routing:: scoring:: { ScoreUpdate , WriteableScore } ;
3836use lightning:: routing:: utxo:: UtxoLookup ;
39- #[ cfg( feature = "futures" ) ]
4037use lightning:: sign:: ChangeDestinationSource ;
4138#[ cfg( feature = "std" ) ]
4239use lightning:: sign:: ChangeDestinationSourceSync ;
4340use lightning:: sign:: OutputSpender ;
4441use lightning:: util:: logger:: Logger ;
4542use lightning:: util:: persist:: { KVStore , Persister } ;
46- #[ cfg( feature = "futures" ) ]
4743use lightning:: util:: sweep:: OutputSweeper ;
4844#[ cfg( feature = "std" ) ]
4945use lightning:: util:: sweep:: OutputSweeperSync ;
@@ -146,7 +142,6 @@ const SWEEPER_TIMER: u64 = 30;
146142#[ cfg( test) ]
147143const SWEEPER_TIMER : u64 = 1 ;
148144
149- #[ cfg( feature = "futures" ) ]
150145/// core::cmp::min is not currently const, so we define a trivial (and equivalent) replacement
151146const fn min_u64 ( a : u64 , b : u64 ) -> u64 {
152147 if a < b {
@@ -155,7 +150,6 @@ const fn min_u64(a: u64, b: u64) -> u64 {
155150 b
156151 }
157152}
158- #[ cfg( feature = "futures" ) ]
159153const FASTEST_TIMER : u64 = min_u64 (
160154 min_u64 ( FRESHNESS_TIMER , PING_TIMER ) ,
161155 min_u64 ( SCORER_PERSIST_TIMER , min_u64 ( FIRST_NETWORK_PRUNE_TIMER , REBROADCAST_TIMER ) ) ,
@@ -508,7 +502,6 @@ macro_rules! define_run_body {
508502 } }
509503}
510504
511- #[ cfg( feature = "futures" ) ]
512505pub ( crate ) mod futures_util {
513506 use core:: future:: Future ;
514507 use core:: marker:: Unpin ;
@@ -622,9 +615,7 @@ pub(crate) mod futures_util {
622615 unsafe { Waker :: from_raw ( RawWaker :: new ( core:: ptr:: null ( ) , & DUMMY_WAKER_VTABLE ) ) }
623616 }
624617}
625- #[ cfg( feature = "futures" ) ]
626618use core:: task;
627- #[ cfg( feature = "futures" ) ]
628619use futures_util:: { dummy_waker, OptionalSelector , Selector , SelectorOutput } ;
629620
630621/// Processes background events in a future.
@@ -775,7 +766,6 @@ use futures_util::{dummy_waker, OptionalSelector, Selector, SelectorOutput};
775766#[ cfg_attr( feature = "std" , doc = " handle.await.unwrap()" ) ]
776767/// # }
777768///```
778- #[ cfg( feature = "futures" ) ]
779769pub async fn process_events_async <
780770 ' a ,
781771 UL : ' static + Deref ,
@@ -2096,7 +2086,6 @@ mod tests {
20962086 }
20972087
20982088 #[ tokio:: test]
2099- #[ cfg( feature = "futures" ) ]
21002089 async fn test_channel_manager_persist_error_async ( ) {
21012090 // Test that if we encounter an error during manager persistence, the thread panics.
21022091 let ( _, nodes) = create_nodes ( 2 , "test_persist_error_sync" ) ;
@@ -2605,7 +2594,6 @@ mod tests {
26052594 }
26062595
26072596 #[ tokio:: test]
2608- #[ cfg( feature = "futures" ) ]
26092597 async fn test_not_pruning_network_graph_until_graph_sync_completion_async ( ) {
26102598 let ( sender, receiver) = std:: sync:: mpsc:: sync_channel ( 1 ) ;
26112599
@@ -2808,7 +2796,6 @@ mod tests {
28082796 }
28092797
28102798 #[ tokio:: test]
2811- #[ cfg( feature = "futures" ) ]
28122799 async fn test_payment_path_scoring_async ( ) {
28132800 let ( sender, mut receiver) = tokio:: sync:: mpsc:: channel ( 1 ) ;
28142801 let event_handler = move |event : Event | {
0 commit comments