From 896f47b391472a6324b6c38a69892dc963f39fc0 Mon Sep 17 00:00:00 2001 From: Elias Rohrer Date: Mon, 25 Jul 2022 09:13:19 +0200 Subject: [PATCH] f `copy`, not `loop` --- lightning/src/routing/gossip.rs | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/lightning/src/routing/gossip.rs b/lightning/src/routing/gossip.rs index f5e96a9a784..37bf1ea5a6f 100644 --- a/lightning/src/routing/gossip.rs +++ b/lightning/src/routing/gossip.rs @@ -34,6 +34,7 @@ use util::events::{Event, EventHandler, MessageSendEvent, MessageSendEventsProvi use util::scid_utils::{block_from_scid, scid_from_parts, MAX_SCID_BLOCK}; use io; +use io_extras::{copy, sink}; use prelude::*; use alloc::collections::{BTreeMap, btree_map::Entry as BtreeEntry}; use core::{cmp, fmt}; @@ -1108,13 +1109,13 @@ struct NodeAnnouncementInfoDeserWrapper(NodeAnnouncementInfo); impl MaybeReadable for NodeAnnouncementInfoDeserWrapper { fn read(reader: &mut R) -> Result, DecodeError> { - loop { - match ::util::ser::Readable::read(reader) { - Ok(node_announcement_info) => return Ok(Some(Self(node_announcement_info))), - Err(DecodeError::ShortRead) => return Ok(None), - Err(_) => {}, - }; - } + match ::util::ser::Readable::read(reader) { + Ok(node_announcement_info) => return Ok(Some(Self(node_announcement_info))), + Err(_) => { + copy(reader, &mut sink()).unwrap(); + return Ok(None) + }, + }; } }