X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Flib.rs;h=37bbe4cb0338170998acef7ae0032c7056f7ea86;hb=58d677c291607bfed62ccdfbaf592cead530ed6c;hp=1115568025e213885af30372a93cc652b8e40494;hpb=e004a953d43654c14fef698d14e5aee2497dbcc4;p=rapid-gossip-sync-server diff --git a/src/lib.rs b/src/lib.rs index 1115568..37bbe4c 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -136,7 +136,7 @@ fn serialize_empty_blob(current_timestamp: u64) -> Vec { blob } -async fn serialize_delta(network_graph: Arc>, last_sync_timestamp: u32, consider_intermediate_updates: bool) -> SerializedResponse { +async fn serialize_delta(network_graph: Arc>, last_sync_timestamp: u32) -> SerializedResponse { let (client, connection) = lookup::connect_to_db().await; network_graph.remove_stale_channels_and_tracking(); @@ -172,7 +172,7 @@ async fn serialize_delta(network_graph: Arc>, last_sync let mut delta_set = DeltaSet::new(); lookup::fetch_channel_announcements(&mut delta_set, network_graph, &client, last_sync_timestamp).await; println!("announcement channel count: {}", delta_set.len()); - lookup::fetch_channel_updates(&mut delta_set, &client, last_sync_timestamp, consider_intermediate_updates).await; + lookup::fetch_channel_updates(&mut delta_set, &client, last_sync_timestamp).await; println!("update-fetched channel count: {}", delta_set.len()); lookup::filter_delta_set(&mut delta_set); println!("update-filtered channel count: {}", delta_set.len());