Continue sync after ancestry search (#538)

arkpar · gavofyork · commit ae94cc92d3a2 · 2018-08-10T15:29:10.000+02:00
diff --git a/substrate/network/src/sync.rs b/substrate/network/src/sync.rs
@@ -237,7 +237,8 @@ impl<B: BlockT> ChainSync<B> {
 		let is_best = new_blocks.first().and_then(|b| b.block.header.as_ref()).map(|h| best_seen.as_ref().map_or(false, |n| h.number() >= n));
 		let origin = if is_best.unwrap_or_default() { BlockOrigin::NetworkBroadcast } else { BlockOrigin::NetworkInitialSync };
 		let import_queue = self.import_queue.clone();
-		import_queue.import_blocks(self, protocol, (origin, new_blocks))
+		import_queue.import_blocks(self, protocol, (origin, new_blocks));
+		self.maintain_sync(protocol);
 	}
 
 	pub fn maintain_sync(&mut self, protocol: &mut Context<B>) {

Original file line number	Diff line number	Diff line change
`@@ -237,7 +237,8 @@ impl<B: BlockT> ChainSync<B> {`
`237`	`237`	`let is_best = new_blocks.first().and_then(\|b\| b.block.header.as_ref()).map(\|h\| best_seen.as_ref().map_or(false, \|n\| h.number() >= n));`
`238`	`238`	`let origin = if is_best.unwrap_or_default() { BlockOrigin::NetworkBroadcast } else { BlockOrigin::NetworkInitialSync };`
`239`	`239`	`let import_queue = self.import_queue.clone();`
`240`		`- import_queue.import_blocks(self, protocol, (origin, new_blocks))`
	`240`	`+ import_queue.import_blocks(self, protocol, (origin, new_blocks));`
	`241`	`+ self.maintain_sync(protocol);`
`241`	`242`	`}`
`242`	`243`
`243`	`244`	`pub fn maintain_sync(&mut self, protocol: &mut Context<B>) {`