X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=fuzz%2Fsrc%2Fchanmon_consistency.rs;h=b564e556d39f29ba493109ac53f2ccea1ba4a456;hb=8acdbaf2a450e93d77defde9164116079f8cb9e7;hp=d2848112341d912815e1625b5e7421f00a195240;hpb=68152453880777bb2ca5acd8ccdf8ab00a48e74c;p=rust-lightning

diff --git a/fuzz/src/chanmon_consistency.rs b/fuzz/src/chanmon_consistency.rs
index d2848112..b564e556 100644
--- a/fuzz/src/chanmon_consistency.rs
+++ b/fuzz/src/chanmon_consistency.rs
@@ -800,6 +800,10 @@ pub fn do_test<Out: test_logger::Output>(data: &[u8], out: Out) {
 					chan_a_disconnected = true;
 					drain_msg_events_on_disconnect!(0);
 				}
+				if monitor_a.should_update_manager.load(atomic::Ordering::Relaxed) {
+					node_a_ser.0.clear();
+					nodes[0].write(&mut node_a_ser).unwrap();
+				}
 				let (new_node_a, new_monitor_a) = reload_node!(node_a_ser, 0, monitor_a, keys_manager_a);
 				nodes[0] = new_node_a;
 				monitor_a = new_monitor_a;
@@ -827,6 +831,10 @@ pub fn do_test<Out: test_logger::Output>(data: &[u8], out: Out) {
 					chan_b_disconnected = true;
 					drain_msg_events_on_disconnect!(2);
 				}
+				if monitor_c.should_update_manager.load(atomic::Ordering::Relaxed) {
+					node_c_ser.0.clear();
+					nodes[2].write(&mut node_c_ser).unwrap();
+				}
 				let (new_node_c, new_monitor_c) = reload_node!(node_c_ser, 2, monitor_c, keys_manager_c);
 				nodes[2] = new_node_c;
 				monitor_c = new_monitor_c;