File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -799,7 +799,7 @@ mod tests {
799
799
let payment_preimage_1 = route_payment ( & nodes[ 0 ] , & [ & nodes[ 1 ] ] , 1_000_000 ) . 0 ;
800
800
let payment_preimage_2 = route_payment ( & nodes[ 0 ] , & [ & nodes[ 1 ] ] , 1_000_000 ) . 0 ;
801
801
802
- chanmon_cfgs[ 1 ] . persister . offchain_sync_monitor_persistences . lock ( ) . unwrap ( ) . clear ( ) ;
802
+ chanmon_cfgs[ 1 ] . persister . offchain_monitor_updates . lock ( ) . unwrap ( ) . clear ( ) ;
803
803
chanmon_cfgs[ 1 ] . persister . set_update_ret ( Err ( ChannelMonitorUpdateErr :: TemporaryFailure ) ) ;
804
804
805
805
nodes[ 1 ] . node . claim_funds ( payment_preimage_1) ;
@@ -809,7 +809,7 @@ mod tests {
809
809
810
810
chanmon_cfgs[ 1 ] . persister . set_update_ret ( Ok ( ( ) ) ) ;
811
811
812
- let persistences = chanmon_cfgs[ 1 ] . persister . offchain_sync_monitor_persistences . lock ( ) . unwrap ( ) . clone ( ) ;
812
+ let persistences = chanmon_cfgs[ 1 ] . persister . offchain_monitor_updates . lock ( ) . unwrap ( ) . clone ( ) ;
813
813
assert_eq ! ( persistences. len( ) , 1 ) ;
814
814
let ( funding_txo, updates) = persistences. iter ( ) . next ( ) . unwrap ( ) ;
815
815
assert_eq ! ( updates. len( ) , 2 ) ;
Original file line number Diff line number Diff line change @@ -174,15 +174,15 @@ pub struct TestPersister {
174
174
pub chain_sync_monitor_persistences : Mutex < HashMap < OutPoint , HashSet < MonitorUpdateId > > > ,
175
175
/// When we get an update_persisted_channel call *with* a ChannelMonitorUpdate, we insert the
176
176
/// MonitorUpdateId here.
177
- pub offchain_sync_monitor_persistences : Mutex < HashMap < OutPoint , HashSet < MonitorUpdateId > > > ,
177
+ pub offchain_monitor_updates : Mutex < HashMap < OutPoint , HashSet < MonitorUpdateId > > > ,
178
178
}
179
179
impl TestPersister {
180
180
pub fn new ( ) -> Self {
181
181
Self {
182
182
update_ret : Mutex :: new ( Ok ( ( ) ) ) ,
183
183
next_update_ret : Mutex :: new ( None ) ,
184
184
chain_sync_monitor_persistences : Mutex :: new ( HashMap :: new ( ) ) ,
185
- offchain_sync_monitor_persistences : Mutex :: new ( HashMap :: new ( ) ) ,
185
+ offchain_monitor_updates : Mutex :: new ( HashMap :: new ( ) ) ,
186
186
}
187
187
}
188
188
@@ -211,7 +211,7 @@ impl<Signer: keysinterface::Sign> chainmonitor::Persist<Signer> for TestPersiste
211
211
if update. is_none ( ) {
212
212
self . chain_sync_monitor_persistences . lock ( ) . unwrap ( ) . entry ( funding_txo) . or_insert ( HashSet :: new ( ) ) . insert ( update_id) ;
213
213
} else {
214
- self . offchain_sync_monitor_persistences . lock ( ) . unwrap ( ) . entry ( funding_txo) . or_insert ( HashSet :: new ( ) ) . insert ( update_id) ;
214
+ self . offchain_monitor_updates . lock ( ) . unwrap ( ) . entry ( funding_txo) . or_insert ( HashSet :: new ( ) ) . insert ( update_id) ;
215
215
}
216
216
ret
217
217
}
You can’t perform that action at this time.
0 commit comments