@@ -1018,13 +1018,10 @@ async fn start_ldk() {
10181018 }
10191019 } ;
10201020
1021- // Step 21: Persist ChannelManager and NetworkGraph
1022- let persister = Arc :: new ( FilesystemStore :: new ( ldk_data_dir. clone ( ) . into ( ) ) ) ;
1023-
1024- // Step 22: Background Processing
1021+ // Step 21: Background Processing
10251022 let ( bp_exit, bp_exit_check) = tokio:: sync:: watch:: channel ( ( ) ) ;
10261023 let mut background_processor = tokio:: spawn ( process_events_async (
1027- Arc :: clone ( & persister ) ,
1024+ Arc :: clone ( & fs_store ) ,
10281025 event_handler,
10291026 Arc :: clone ( & chain_monitor) ,
10301027 Arc :: clone ( & channel_manager) ,
@@ -1124,14 +1121,14 @@ async fn start_ldk() {
11241121 ldk_data_dir. clone ( ) ,
11251122 Arc :: clone ( & keys_manager) ,
11261123 Arc :: clone ( & logger) ,
1127- Arc :: clone ( & persister ) ,
1124+ Arc :: clone ( & fs_store ) ,
11281125 Arc :: clone ( & output_sweeper) ,
11291126 ) ) ;
11301127
11311128 // Start the CLI.
11321129 let cli_channel_manager = Arc :: clone ( & channel_manager) ;
11331130 let cli_chain_monitor = Arc :: clone ( & chain_monitor) ;
1134- let cli_persister = Arc :: clone ( & persister ) ;
1131+ let cli_fs_store = Arc :: clone ( & fs_store ) ;
11351132 let cli_peer_manager = Arc :: clone ( & peer_manager) ;
11361133 let cli_poll = tokio:: task:: spawn (
11371134 cli:: poll_for_user_input (
@@ -1142,7 +1139,7 @@ async fn start_ldk() {
11421139 network_graph,
11431140 inbound_payments,
11441141 outbound_payments,
1145- cli_persister ,
1142+ cli_fs_store ,
11461143 )
11471144 ) ;
11481145
@@ -1162,7 +1159,7 @@ async fn start_ldk() {
11621159 peer_manager. disconnect_all_peers ( ) ;
11631160
11641161 if let Err ( e) = bg_res {
1165- let persist_res = persister
1162+ let persist_res = fs_store
11661163 . write (
11671164 persist:: CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE ,
11681165 persist:: CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE ,
0 commit comments