@@ -1049,13 +1049,10 @@ async fn start_ldk() {
10491049 }
10501050 } ;
10511051
1052- // Step 21: Persist ChannelManager and NetworkGraph
1053- let persister = Arc :: new ( FilesystemStore :: new ( ldk_data_dir. clone ( ) . into ( ) ) ) ;
1054-
1055- // Step 22: Background Processing
1052+ // Step 21: Background Processing
10561053 let ( bp_exit, bp_exit_check) = tokio:: sync:: watch:: channel ( ( ) ) ;
10571054 let mut background_processor = tokio:: spawn ( process_events_async (
1058- Arc :: clone ( & persister ) ,
1055+ Arc :: clone ( & fs_store ) ,
10591056 event_handler,
10601057 Arc :: clone ( & chain_monitor) ,
10611058 Arc :: clone ( & channel_manager) ,
@@ -1156,14 +1153,14 @@ async fn start_ldk() {
11561153 ldk_data_dir. clone ( ) ,
11571154 Arc :: clone ( & keys_manager) ,
11581155 Arc :: clone ( & logger) ,
1159- Arc :: clone ( & persister ) ,
1156+ Arc :: clone ( & fs_store ) ,
11601157 Arc :: clone ( & output_sweeper) ,
11611158 ) ) ;
11621159
11631160 // Start the CLI.
11641161 let cli_channel_manager = Arc :: clone ( & channel_manager) ;
11651162 let cli_chain_monitor = Arc :: clone ( & chain_monitor) ;
1166- let cli_persister = Arc :: clone ( & persister ) ;
1163+ let cli_fs_store = Arc :: clone ( & fs_store ) ;
11671164 let cli_peer_manager = Arc :: clone ( & peer_manager) ;
11681165 let cli_poll = tokio:: task:: spawn (
11691166 cli:: poll_for_user_input (
@@ -1174,7 +1171,7 @@ async fn start_ldk() {
11741171 network_graph,
11751172 inbound_payments,
11761173 outbound_payments,
1177- cli_persister ,
1174+ cli_fs_store ,
11781175 )
11791176 ) ;
11801177
@@ -1194,7 +1191,7 @@ async fn start_ldk() {
11941191 peer_manager. disconnect_all_peers ( ) ;
11951192
11961193 if let Err ( e) = bg_res {
1197- let persist_res = persister
1194+ let persist_res = fs_store
11981195 . write (
11991196 persist:: CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE ,
12001197 persist:: CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE ,
0 commit comments