@@ -1026,13 +1026,10 @@ async fn start_ldk() {
10261026 }
10271027 } ;
10281028
1029- // Step 21: Persist ChannelManager and NetworkGraph
1030- let persister = Arc :: new ( FilesystemStore :: new ( ldk_data_dir. clone ( ) . into ( ) ) ) ;
1031-
1032- // Step 22: Background Processing
1029+ // Step 21: Background Processing
10331030 let ( bp_exit, bp_exit_check) = tokio:: sync:: watch:: channel ( ( ) ) ;
10341031 let mut background_processor = tokio:: spawn ( process_events_async (
1035- Arc :: clone ( & persister ) ,
1032+ Arc :: clone ( & fs_store ) ,
10361033 event_handler,
10371034 Arc :: clone ( & chain_monitor) ,
10381035 Arc :: clone ( & channel_manager) ,
@@ -1132,14 +1129,14 @@ async fn start_ldk() {
11321129 ldk_data_dir. clone ( ) ,
11331130 Arc :: clone ( & keys_manager) ,
11341131 Arc :: clone ( & logger) ,
1135- Arc :: clone ( & persister ) ,
1132+ Arc :: clone ( & fs_store ) ,
11361133 Arc :: clone ( & output_sweeper) ,
11371134 ) ) ;
11381135
11391136 // Start the CLI.
11401137 let cli_channel_manager = Arc :: clone ( & channel_manager) ;
11411138 let cli_chain_monitor = Arc :: clone ( & chain_monitor) ;
1142- let cli_persister = Arc :: clone ( & persister ) ;
1139+ let cli_fs_store = Arc :: clone ( & fs_store ) ;
11431140 let cli_peer_manager = Arc :: clone ( & peer_manager) ;
11441141 let cli_poll = tokio:: task:: spawn (
11451142 cli:: poll_for_user_input (
@@ -1150,7 +1147,7 @@ async fn start_ldk() {
11501147 network_graph,
11511148 inbound_payments,
11521149 outbound_payments,
1153- cli_persister ,
1150+ cli_fs_store ,
11541151 )
11551152 ) ;
11561153
@@ -1170,7 +1167,7 @@ async fn start_ldk() {
11701167 peer_manager. disconnect_all_peers ( ) ;
11711168
11721169 if let Err ( e) = bg_res {
1173- let persist_res = persister
1170+ let persist_res = fs_store
11741171 . write (
11751172 persist:: CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE ,
11761173 persist:: CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE ,
0 commit comments