Debug #1914.

Author: arik-so

lightning/src/routing/gossip.rs

@@ -2524,31 +2524,33 @@ mod tests {
 		{
 			use std::time::{SystemTime, UNIX_EPOCH};
 
-			let tracking_time = SystemTime::now().duration_since(UNIX_EPOCH).expect("Time must be > 1970").as_secs();
-
-			// Clear tracked nodes and channels for clean slate
-			network_graph.removed_channels.lock().unwrap().clear();
-			network_graph.removed_nodes.lock().unwrap().clear();
-
-			// Add a channel and nodes from channel announcement. So our network graph will
-			// now only consist of two nodes and one channel between them.
-			assert!(network_graph.update_channel_from_announcement(
-				&valid_channel_announcement, &chain_source).is_ok());
-
-			// Mark the channel as permanently failed. This will also remove the two nodes
-			// and all of the entries will be tracked as removed.
-			network_graph.channel_failed(short_channel_id, true);
-
-			// Should not remove from tracking if insufficient time has passed
-			network_graph.remove_stale_channels_and_tracking_with_time(
-				tracking_time + REMOVED_ENTRIES_TRACKING_AGE_LIMIT_SECS - 1);
-			assert_eq!(network_graph.removed_channels.lock().unwrap().len(), 1);
-
-			// Provide a later time so that sufficient time has passed
-			network_graph.remove_stale_channels_and_tracking_with_time(
-				tracking_time + REMOVED_ENTRIES_TRACKING_AGE_LIMIT_SECS);
-			assert!(network_graph.removed_channels.lock().unwrap().is_empty());
-			assert!(network_graph.removed_nodes.lock().unwrap().is_empty());
+			for _ in 0..500 {
+				let tracking_time = SystemTime::now().duration_since(UNIX_EPOCH).expect("Time must be > 1970").as_secs();
+
+				// Clear tracked nodes and channels for clean slate
+				network_graph.removed_channels.lock().unwrap().clear();
+				network_graph.removed_nodes.lock().unwrap().clear();
+
+				// Add a channel and nodes from channel announcement. So our network graph will
+				// now only consist of two nodes and one channel between them.
+				assert!(network_graph.update_channel_from_announcement(
+					&valid_channel_announcement, &chain_source).is_ok());
+
+				// Mark the channel as permanently failed. This will also remove the two nodes
+				// and all of the entries will be tracked as removed.
+				network_graph.channel_failed(short_channel_id, true);
+
+				// Should not remove from tracking if insufficient time has passed
+				network_graph.remove_stale_channels_and_tracking_with_time(
+					tracking_time + REMOVED_ENTRIES_TRACKING_AGE_LIMIT_SECS - 1);
+				assert_eq!(network_graph.removed_channels.lock().unwrap().len(), 1, "Removed channel count ≠ 1 with tracking_time {}", tracking_time);
+
+				// Provide a later time so that sufficient time has passed
+				network_graph.remove_stale_channels_and_tracking_with_time(
+					tracking_time + REMOVED_ENTRIES_TRACKING_AGE_LIMIT_SECS);
+				assert!(network_graph.removed_channels.lock().unwrap().is_empty(), "Unexpectedly removed channels with tracking_time {}", tracking_time);
+				assert!(network_graph.removed_nodes.lock().unwrap().is_empty(), "Unexpectedly removed nodes with tracking_time {}", tracking_time);
+			}
 		}
 
 		#[cfg(not(feature = "std"))]