@@ -1028,13 +1028,10 @@ async fn start_ldk() {
10281028 }
10291029 } ;
10301030
1031- // Step 21: Persist ChannelManager and NetworkGraph
1032- let persister = Arc :: new ( FilesystemStore :: new ( ldk_data_dir. clone ( ) . into ( ) ) ) ;
1033-
1034- // Step 22: Background Processing
1031+ // Step 21: Background Processing
10351032 let ( bp_exit, bp_exit_check) = tokio:: sync:: watch:: channel ( ( ) ) ;
10361033 let mut background_processor = tokio:: spawn ( process_events_async (
1037- Arc :: clone ( & persister ) ,
1034+ Arc :: clone ( & fs_store ) ,
10381035 event_handler,
10391036 Arc :: clone ( & chain_monitor) ,
10401037 Arc :: clone ( & channel_manager) ,
@@ -1134,14 +1131,14 @@ async fn start_ldk() {
11341131 ldk_data_dir. clone ( ) ,
11351132 Arc :: clone ( & keys_manager) ,
11361133 Arc :: clone ( & logger) ,
1137- Arc :: clone ( & persister ) ,
1134+ Arc :: clone ( & fs_store ) ,
11381135 Arc :: clone ( & output_sweeper) ,
11391136 ) ) ;
11401137
11411138 // Start the CLI.
11421139 let cli_channel_manager = Arc :: clone ( & channel_manager) ;
11431140 let cli_chain_monitor = Arc :: clone ( & chain_monitor) ;
1144- let cli_persister = Arc :: clone ( & persister ) ;
1141+ let cli_fs_store = Arc :: clone ( & fs_store ) ;
11451142 let cli_peer_manager = Arc :: clone ( & peer_manager) ;
11461143 let cli_poll = tokio:: task:: spawn (
11471144 cli:: poll_for_user_input (
@@ -1152,7 +1149,7 @@ async fn start_ldk() {
11521149 network_graph,
11531150 inbound_payments,
11541151 outbound_payments,
1155- cli_persister ,
1152+ cli_fs_store ,
11561153 )
11571154 ) ;
11581155
@@ -1172,7 +1169,7 @@ async fn start_ldk() {
11721169 peer_manager. disconnect_all_peers ( ) ;
11731170
11741171 if let Err ( e) = bg_res {
1175- let persist_res = persister
1172+ let persist_res = fs_store
11761173 . write (
11771174 persist:: CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE ,
11781175 persist:: CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE ,
0 commit comments