f also remove stale test

Author: TheBlueMatt

lightning/src/ln/chanmon_update_fail_tests.rs

@@ -3341,93 +3341,6 @@ fn test_durable_preimages_on_closed_channel() {
 	do_test_durable_preimages_on_closed_channel(false, false, false);
 }
 
-#[test]
-fn test_sync_async_persist_doesnt_hang() {
-	// Previously, we checked if a channel was a candidate for making forward progress based on if
-	// the `MonitorEvent::Completed` matched the channel's latest monitor update id. However, this
-	// could lead to a rare race when `ChannelMonitor`s were being persisted both synchronously and
-	// asynchronously leading to channel hangs.
-	//
-	// To hit this case, we need to generate a `MonitorEvent::Completed` prior to a new channel
-	// update, but which is only processed after the channel update.
-	let chanmon_cfgs = create_chanmon_cfgs(2);
-	let node_cfgs = create_node_cfgs(2, &chanmon_cfgs);
-	let node_chanmgrs = create_node_chanmgrs(2, &node_cfgs, &[None, None]);
-	let nodes = create_network(2, &node_cfgs, &node_chanmgrs);
-
-	let chan_id_ab = create_announced_chan_between_nodes(&nodes, 0, 1).2;
-
-	// Send two payments from A to B, then claim the first, marking the very last
-	// ChannelMonitorUpdate as InProgress...
-	let (payment_preimage_1, payment_hash_1, ..) = route_payment(&nodes[0], &[&nodes[1]], 1_000_000);
-	let (payment_preimage_2, payment_hash_2, ..) = route_payment(&nodes[0], &[&nodes[1]], 1_000_000);
-
-	nodes[1].node.claim_funds(payment_preimage_1);
-	check_added_monitors(&nodes[1], 1);
-	expect_payment_claimed!(nodes[1], payment_hash_1, 1_000_000);
-
-	let bs_updates = get_htlc_update_msgs(&nodes[1], &nodes[0].node.get_our_node_id());
-	nodes[0].node.handle_update_fulfill_htlc(nodes[1].node.get_our_node_id(), &bs_updates.update_fulfill_htlcs[0]);
-	expect_payment_sent(&nodes[0], payment_preimage_1, None, false, false);
-	nodes[0].node.handle_commitment_signed_batch_test(nodes[1].node.get_our_node_id(), &bs_updates.commitment_signed);
-	check_added_monitors(&nodes[0], 1);
-	let (as_raa, as_cs) = get_revoke_commit_msgs!(nodes[0], nodes[1].node.get_our_node_id());
-
-	nodes[1].node.handle_revoke_and_ack(nodes[0].node.get_our_node_id(), &as_raa);
-	check_added_monitors(&nodes[1], 1);
-	nodes[1].node.handle_commitment_signed_batch_test(nodes[0].node.get_our_node_id(), &as_cs);
-	check_added_monitors(&nodes[1], 1);
-
-	let bs_final_raa = get_event_msg!(nodes[1], MessageSendEvent::SendRevokeAndACK, nodes[0].node.get_our_node_id());
-	chanmon_cfgs[0].persister.set_update_ret(ChannelMonitorUpdateStatus::InProgress);
-	nodes[0].node.handle_revoke_and_ack(nodes[1].node.get_our_node_id(), &bs_final_raa);
-	check_added_monitors(&nodes[0], 1);
-
-	// Immediately complete the monitor update, but before the ChannelManager has a chance to see
-	// the MonitorEvent::Completed, create a channel update by receiving a claim on the second
-	// payment.
-	let (_, ab_update_id) = nodes[0].chain_monitor.latest_monitor_update_id.lock().unwrap().get(&chan_id_ab).unwrap().clone();
-	nodes[0].chain_monitor.chain_monitor.channel_monitor_updated(chan_id_ab, ab_update_id).unwrap();
-
-	nodes[1].node.claim_funds(payment_preimage_2);
-	check_added_monitors(&nodes[1], 1);
-	expect_payment_claimed!(nodes[1], payment_hash_2, 1_000_000);
-
-	let bs_updates = get_htlc_update_msgs(&nodes[1], &nodes[0].node.get_our_node_id());
-	nodes[0].node.handle_update_fulfill_htlc(nodes[1].node.get_our_node_id(), &bs_updates.update_fulfill_htlcs[0]);
-	nodes[0].node.handle_commitment_signed_batch_test(nodes[1].node.get_our_node_id(), &bs_updates.commitment_signed);
-	check_added_monitors(&nodes[0], 1);
-
-	// At this point, we have completed an extra `ChannelMonitorUpdate` but the `ChannelManager`
-	// hasn't yet seen our `MonitorEvent::Completed`. When we call
-	// `get_and_clear_pending_msg_events` here, the `ChannelManager` finally sees that event and
-	// should return the channel to normal operation.
-	let (as_raa, as_cs) = get_revoke_commit_msgs!(nodes[0], nodes[1].node.get_our_node_id());
-
-	// Now that we've completed our test, process the events we have queued up (which we were not
-	// able to check until now as they would have caused the `ChannelManager` to look at the
-	// pending `MonitorEvent`s).
-	let pending_events = nodes[0].node.get_and_clear_pending_events();
-	assert_eq!(pending_events.len(), 2);
-	if let Event::PaymentPathSuccessful { ref payment_hash, ..} = pending_events[1] {
-		assert_eq!(payment_hash.unwrap(), payment_hash_1);
-	} else { panic!(); }
-	if let Event::PaymentSent { ref payment_hash, ..} = pending_events[0] {
-		assert_eq!(*payment_hash, payment_hash_2);
-	} else { panic!(); }
-
-	// Finally, complete the claiming of the second payment
-	nodes[1].node.handle_revoke_and_ack(nodes[0].node.get_our_node_id(), &as_raa);
-	check_added_monitors(&nodes[1], 1);
-	nodes[1].node.handle_commitment_signed_batch_test(nodes[0].node.get_our_node_id(), &as_cs);
-	check_added_monitors(&nodes[1], 1);
-
-	let bs_final_raa = get_event_msg!(nodes[1], MessageSendEvent::SendRevokeAndACK, nodes[0].node.get_our_node_id());
-	nodes[0].node.handle_revoke_and_ack(nodes[1].node.get_our_node_id(), &bs_final_raa);
-	check_added_monitors(&nodes[0], 1);
-	expect_payment_path_successful!(nodes[0]);
-}
-
 fn do_test_reload_mon_update_completion_actions(close_during_reload: bool) {
 	// Test that if a `ChannelMonitorUpdate` completes but a `ChannelManager` isn't serialized
 	// before restart we run the monitor update completion action on startup.