projects
/
rapid-gossip-sync-server
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
8126ad4
)
Send full updates whenever the channel announcement is sent.
author
Arik Sosman
<git@arik.io>
Thu, 17 Aug 2023 04:50:43 +0000
(21:50 -0700)
committer
Arik Sosman
<git@arik.io>
Thu, 17 Aug 2023 20:21:38 +0000
(13:21 -0700)
src/serialization.rs
patch
|
blob
|
history
diff --git
a/src/serialization.rs
b/src/serialization.rs
index 4c1d82879d9b7f281eb2a1c3eaa9ca6ce6f06dd4..86e114bdb8466e9b29a8164b098eb3036aa57794 100644
(file)
--- a/
src/serialization.rs
+++ b/
src/serialization.rs
@@
-140,12
+140,12
@@
pub(super) fn serialize_delta_set(delta_set: DeltaSet, last_sync_timestamp: u32)
let current_announcement_seen = channel_announcement_delta.seen;
let is_new_announcement = current_announcement_seen >= last_sync_timestamp;
let current_announcement_seen = channel_announcement_delta.seen;
let is_new_announcement = current_announcement_seen >= last_sync_timestamp;
- let is_newly_
updat
ed_announcement = if let Some(first_update_seen) = channel_delta.first_bidirectional_updates_seen {
+ let is_newly_
includ
ed_announcement = if let Some(first_update_seen) = channel_delta.first_bidirectional_updates_seen {
first_update_seen >= last_sync_timestamp
} else {
false
};
first_update_seen >= last_sync_timestamp
} else {
false
};
- let send_announcement = is_new_announcement || is_newly_
updat
ed_announcement;
+ let send_announcement = is_new_announcement || is_newly_
includ
ed_announcement;
if send_announcement {
serialization_set.latest_seen = max(serialization_set.latest_seen, current_announcement_seen);
serialization_set.announcements.push(channel_delta.announcement.unwrap().announcement);
if send_announcement {
serialization_set.latest_seen = max(serialization_set.latest_seen, current_announcement_seen);
serialization_set.announcements.push(channel_delta.announcement.unwrap().announcement);
@@
-166,7
+166,7
@@
pub(super) fn serialize_delta_set(delta_set: DeltaSet, last_sync_timestamp: u32)
if updates.last_update_before_seen.is_some() {
let mutated_properties = updates.mutated_properties;
if updates.last_update_before_seen.is_some() {
let mutated_properties = updates.mutated_properties;
- if mutated_properties.len() == 5 {
+ if mutated_properties.len() == 5
|| send_announcement
{
// all five values have changed, it makes more sense to just
// serialize the update as a full update instead of as a change
// this way, the default values can be computed more efficiently
// all five values have changed, it makes more sense to just
// serialize the update as a full update instead of as a change
// this way, the default values can be computed more efficiently