@@ -1027,13 +1027,10 @@ async fn start_ldk() {
1027
1027
}
1028
1028
} ;
1029
1029
1030
- // Step 21: Persist ChannelManager and NetworkGraph
1031
- let persister = Arc :: new ( FilesystemStore :: new ( ldk_data_dir. clone ( ) . into ( ) ) ) ;
1032
-
1033
- // Step 22: Background Processing
1030
+ // Step 21: Background Processing
1034
1031
let ( bp_exit, bp_exit_check) = tokio:: sync:: watch:: channel ( ( ) ) ;
1035
1032
let mut background_processor = tokio:: spawn ( process_events_async (
1036
- Arc :: clone ( & persister ) ,
1033
+ Arc :: clone ( & fs_store ) ,
1037
1034
event_handler,
1038
1035
Arc :: clone ( & chain_monitor) ,
1039
1036
Arc :: clone ( & channel_manager) ,
@@ -1133,14 +1130,14 @@ async fn start_ldk() {
1133
1130
ldk_data_dir. clone ( ) ,
1134
1131
Arc :: clone ( & keys_manager) ,
1135
1132
Arc :: clone ( & logger) ,
1136
- Arc :: clone ( & persister ) ,
1133
+ Arc :: clone ( & fs_store ) ,
1137
1134
Arc :: clone ( & output_sweeper) ,
1138
1135
) ) ;
1139
1136
1140
1137
// Start the CLI.
1141
1138
let cli_channel_manager = Arc :: clone ( & channel_manager) ;
1142
1139
let cli_chain_monitor = Arc :: clone ( & chain_monitor) ;
1143
- let cli_persister = Arc :: clone ( & persister ) ;
1140
+ let cli_fs_store = Arc :: clone ( & fs_store ) ;
1144
1141
let cli_peer_manager = Arc :: clone ( & peer_manager) ;
1145
1142
let cli_poll = tokio:: task:: spawn (
1146
1143
cli:: poll_for_user_input (
@@ -1151,7 +1148,7 @@ async fn start_ldk() {
1151
1148
network_graph,
1152
1149
inbound_payments,
1153
1150
outbound_payments,
1154
- cli_persister ,
1151
+ cli_fs_store ,
1155
1152
)
1156
1153
) ;
1157
1154
@@ -1171,7 +1168,7 @@ async fn start_ldk() {
1171
1168
peer_manager. disconnect_all_peers ( ) ;
1172
1169
1173
1170
if let Err ( e) = bg_res {
1174
- let persist_res = persister
1171
+ let persist_res = fs_store
1175
1172
. write (
1176
1173
persist:: CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE ,
1177
1174
persist:: CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE ,
0 commit comments