X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fdownloader.rs;h=af854c8317d059444b9ee2df6598bb1edbeeccb7;hb=f525858b51ca7c8ad9b855efd92e5e04efa53ed1;hp=8d5cdb0005e7d8e3ea74f5036ee6c20220a9729e;hpb=32c175b543de5782f6615a7110b4d303620b50d0;p=rapid-gossip-sync-server diff --git a/src/downloader.rs b/src/downloader.rs index 8d5cdb0..af854c8 100644 --- a/src/downloader.rs +++ b/src/downloader.rs @@ -62,7 +62,7 @@ impl GossipRouter where L::Target: Logger { counter.channel_announcements += 1; } - let gossip_message = GossipMessage::ChannelAnnouncement(msg); + let gossip_message = GossipMessage::ChannelAnnouncement(msg, None); if let Err(err) = self.sender.try_send(gossip_message) { let gossip_message = match err { TrySendError::Full(msg)|TrySendError::Closed(msg) => msg }; tokio::task::block_in_place(move || { tokio::runtime::Handle::current().block_on(async move { @@ -73,7 +73,7 @@ impl GossipRouter where L::Target: Logger { fn new_channel_update(&self, msg: ChannelUpdate) { self.counter.write().unwrap().channel_updates += 1; - let gossip_message = GossipMessage::ChannelUpdate(msg); + let gossip_message = GossipMessage::ChannelUpdate(msg, None); if let Err(err) = self.sender.try_send(gossip_message) { let gossip_message = match err { TrySendError::Full(msg)|TrySendError::Closed(msg) => msg };