+ macro_rules! reload_node {
+ ($ser: expr, $node_id: expr, $old_monitors: expr) => { {
+ let logger: Arc<Logger> = Arc::new(test_logger::TestLogger::new($node_id.to_string()));
+ let watch = Arc::new(ChainWatchInterfaceUtil::new(Network::Bitcoin, Arc::clone(&logger)));
+ let monitor = Arc::new(TestChannelMonitor::new(watch.clone(), broadcast.clone(), logger.clone(), fee_est.clone()));
+
+ let keys_manager = Arc::new(KeyProvider { node_id: $node_id, session_id: atomic::AtomicU8::new(0), channel_id: atomic::AtomicU8::new(0) });
+ let mut config = UserConfig::new();
+ config.channel_options.fee_proportional_millionths = 0;
+ config.channel_options.announced_channel = true;
+ config.peer_channel_config_limits.min_dust_limit_satoshis = 0;
+
+ let mut monitors = HashMap::new();
+ let mut old_monitors = $old_monitors.latest_good_update.lock().unwrap();
+ for (outpoint, monitor_ser) in old_monitors.drain() {
+ monitors.insert(outpoint, <(Sha256d, ChannelMonitor)>::read(&mut Cursor::new(&monitor_ser), Arc::clone(&logger)).expect("Failed to read monitor").1);
+ monitor.latest_good_update.lock().unwrap().insert(outpoint, monitor_ser);
+ }
+ let mut monitor_refs = HashMap::new();
+ for (outpoint, monitor) in monitors.iter() {
+ monitor_refs.insert(*outpoint, monitor);
+ }
+
+ let read_args = ChannelManagerReadArgs {
+ keys_manager,
+ fee_estimator: fee_est.clone(),
+ monitor: monitor.clone(),
+ chain_monitor: watch,
+ tx_broadcaster: broadcast.clone(),
+ logger,
+ default_config: config,
+ channel_monitors: &monitor_refs,
+ };
+
+ let res = (<(Sha256d, ChannelManager)>::read(&mut Cursor::new(&$ser.0), read_args).expect("Failed to read manager").1, monitor);
+ for (_, was_good) in $old_monitors.latest_updates_good_at_last_ser.lock().unwrap().iter() {
+ if !was_good {
+ // If the last time we updated a monitor we didn't successfully update (and we
+ // have sense updated our serialized copy of the ChannelManager) we may
+ // force-close the channel on our counterparty cause we know we're missing
+ // something. Thus, we just return here since we can't continue to test.
+ return;
+ }
+ }
+ res
+ } }
+ }
+
+