X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Flib.rs;h=1115568025e213885af30372a93cc652b8e40494;hb=f739c3112576469fe79f77c9777936608b1cfebc;hp=c6f266db0590fbf0e327a28fe019d3b6364e75f4;hpb=60ad4958a2144b229ed09359afbb3711c192053b;p=rapid-gossip-sync-server diff --git a/src/lib.rs b/src/lib.rs index c6f266d..1115568 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -20,7 +20,7 @@ use tokio::sync::mpsc; use crate::lookup::DeltaSet; use crate::persistence::GossipPersister; -use crate::serialization::UpdateSerializationMechanism; +use crate::serialization::UpdateSerialization; use crate::snapshot::Snapshotter; use crate::types::TestLogger; @@ -209,11 +209,11 @@ async fn serialize_delta(network_graph: Arc>, last_sync let mut update_count_full = 0; let mut update_count_incremental = 0; for current_update in serialization_details.updates { - match ¤t_update.mechanism { - UpdateSerializationMechanism::Full => { + match ¤t_update { + UpdateSerialization::Full(_) => { update_count_full += 1; } - UpdateSerializationMechanism::Incremental(_) | UpdateSerializationMechanism::Reminder => { + UpdateSerialization::Incremental(_, _) | UpdateSerialization::Reminder(_, _) => { update_count_incremental += 1; } }; @@ -221,7 +221,7 @@ async fn serialize_delta(network_graph: Arc>, last_sync let mut stripped_update = serialization::serialize_stripped_channel_update(¤t_update, &default_update_values, previous_update_scid); output.append(&mut stripped_update); - previous_update_scid = current_update.update.short_channel_id; + previous_update_scid = current_update.scid(); } // some stats