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:
c5fb1c2
)
Only consider channel announcements with bidirectional updates.
author
Arik Sosman
<git@arik.io>
Fri, 10 May 2024 23:42:20 +0000
(16:42 -0700)
committer
Arik Sosman
<git@arik.io>
Fri, 10 May 2024 23:42:20 +0000
(16:42 -0700)
src/lookup.rs
patch
|
blob
|
history
diff --git
a/src/lookup.rs
b/src/lookup.rs
index fc0385c8d46ac56a107b3591006bfaa915800317..310c124d7832ef75b496faa1ae1e68613d523d8d 100644
(file)
--- a/
src/lookup.rs
+++ b/
src/lookup.rs
@@
-83,7
+83,7
@@
pub(super) async fn fetch_channel_announcements<L: Deref>(delta_set: &mut DeltaS
log_info!(logger, "Retrieved read-only network graph copy");
let channel_iterator = read_only_graph.channels().unordered_iter();
channel_iterator
log_info!(logger, "Retrieved read-only network graph copy");
let channel_iterator = read_only_graph.channels().unordered_iter();
channel_iterator
- .filter(|c| c.1.announcement_message.is_some())
+ .filter(|c| c.1.announcement_message.is_some()
&& c.1.one_to_two.is_some() && c.1.two_to_one.is_some()
)
.map(|c| c.1.announcement_message.as_ref().unwrap().contents.short_channel_id as i64)
.collect::<Vec<_>>()
};
.map(|c| c.1.announcement_message.as_ref().unwrap().contents.short_channel_id as i64)
.collect::<Vec<_>>()
};
@@
-365,7
+365,6
@@
pub(super) async fn fetch_channel_updates<L: Deref>(delta_set: &mut DeltaSet, cl
let mut previous_scid = u64::MAX;
let mut previously_seen_directions = (false, false);
let mut previous_scid = u64::MAX;
let mut previously_seen_directions = (false, false);
- // let mut previously_seen_directions = (false, false);
let mut intermediate_update_count = 0;
while let Some(row_res) = pinned_updates.next().await {
let intermediate_update = row_res.unwrap();
let mut intermediate_update_count = 0;
while let Some(row_res) = pinned_updates.next().await {
let intermediate_update = row_res.unwrap();