From f4d8070bda421e2bfb0763cc5a83c0390f8411ff Mon Sep 17 00:00:00 2001 From: arkpar Date: Thu, 11 Feb 2016 18:36:26 +0100 Subject: [PATCH] Fixed one extra block/header being requested --- sync/src/chain.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sync/src/chain.rs b/sync/src/chain.rs index 63dc47024..76884a586 100644 --- a/sync/src/chain.rs +++ b/sync/src/chain.rs @@ -607,7 +607,7 @@ impl ChainSync { if self.have_common_block && !self.headers.is_empty() && self.headers.range_iter().next().unwrap().0 == self.current_base_block() + 1 { for (start, ref items) in self.headers.range_iter() { - if needed_bodies.len() > MAX_BODIES_TO_REQUEST { + if needed_bodies.len() >= MAX_BODIES_TO_REQUEST { break; } let mut index: BlockNumber = 0; @@ -654,7 +654,7 @@ impl ChainSync { continue; } let mut block = prev; - while block < next && headers.len() <= MAX_HEADERS_TO_REQUEST { + while block < next && headers.len() < MAX_HEADERS_TO_REQUEST { if !self.downloading_headers.contains(&(block as BlockNumber)) { headers.push(block as BlockNumber); self.downloading_headers.insert(block as BlockNumber); @@ -1478,4 +1478,4 @@ mod tests { let result = sync.on_peer_new_block(&mut io, 0, &UntrustedRlp::new(&data)); assert!(result.is_ok()); } -} \ No newline at end of file +}