Update Sync start for body. Test for sysinfo

chain/Cargo.toml

@@ -25,6 +25,7 @@ lazy_static = "1"
 tokio = {version = "0.2", features = ["full"] }
 num_cpus = "1"
 crossbeam = "0.8"
+sysinfo = "0.32"
 
 mwc_core = { path = "../core", version = "5.3.6" }
 mwc_keychain = { path = "../keychain", version = "5.3.6" }

chain/src/pibd_params.rs

@@ -49,3 +49,31 @@ pub const BLOCKS_REQUEST_PER_PEER: usize = 30;
 
 /// Maxumum number of blocks that can await into the DB as orphans
 pub const BLOCKS_REQUEST_LIMIT: usize = 500;
+
+#[cfg(test)]
+mod tests {
+	use sysinfo::{
+		Components, CpuRefreshKind, Disks, MemoryRefreshKind, Networks, RefreshKind, System,
+	};
+
+	#[test]
+	fn check_sys_info() {
+		// Please note that we use "new_all" to ensure that all lists of
+		// CPUs and processes are filled!
+		let sys = System::new_with_specifics(
+			RefreshKind::new().with_memory(MemoryRefreshKind::everything()),
+		);
+
+		println!("=> system:");
+		// RAM and swap information:
+		println!("total memory: {} bytes", sys.total_memory());
+		println!("used memory : {} bytes", sys.used_memory());
+		println!("available memory : {} bytes", sys.available_memory());
+		println!("total swap  : {} bytes", sys.total_swap());
+		println!("used swap   : {} bytes", sys.used_swap());
+		println!("free swap   : {} bytes", sys.free_swap());
+
+		let num_cores = num_cpus::get();
+		println!("CPU Cores   : {} cores", num_cores);
+	}
+}

servers/src/mwc/sync/body_sync.rs

@@ -59,7 +59,8 @@ impl BodySync {
 		let head = self.chain.head()?;
 		let header_head = self.chain.header_head()?;
 
-		if head.last_block_h == header_head.last_block_h {
+		// Last few blocks no need to sync, new mined blocks will be synced regular way
+		if head.height > header_head.height.saturating_sub(3) {
 			// sync is done, we are ready.
 			return Ok(SyncRequestResponses::BodyReady);
 		}