diff --git a/chain/src/txhashset/desegmenter.rs b/chain/src/txhashset/desegmenter.rs index db7a05b17..32843e867 100644 --- a/chain/src/txhashset/desegmenter.rs +++ b/chain/src/txhashset/desegmenter.rs @@ -176,6 +176,9 @@ impl Desegmenter { + self.rangeproof_segment_cache.get_received_segments() + self.kernel_segment_cache.get_received_segments(); + // Expected by QT wallet + info!("PIBD sync progress: {} from {}", received, required); + SyncStatus::TxHashsetPibd { recieved_segments: received, total_segments: required, diff --git a/chain/src/txhashset/txhashset.rs b/chain/src/txhashset/txhashset.rs index 7501e943a..3bb7e2378 100644 --- a/chain/src/txhashset/txhashset.rs +++ b/chain/src/txhashset/txhashset.rs @@ -1927,6 +1927,7 @@ impl<'a> Extension<'a> { kernels_total: total_kernels, }); } + // Expected by QT wallet info!( "txhashset: verify_kernel_signatures: verified {} signatures from {}", kern_count, total_kernels @@ -2070,6 +2071,7 @@ impl<'a> Extension<'a> { .map_err(|_| Error::Other("crossbeam runtime error".to_string()))?; match result { Ok(proof_count) => { + // Expected by QT wallet info!( "txhashset: verify_rangeproofs: verified {} rangeproofs from {}", proof_count, total_rproofs diff --git a/servers/src/mwc/server.rs b/servers/src/mwc/server.rs index 4480fe149..2263cc991 100644 --- a/servers/src/mwc/server.rs +++ b/servers/src/mwc/server.rs @@ -575,6 +575,7 @@ impl Server { .name("p2p-server".to_string()) .spawn(move || { if let Err(e) = p2p_inner.listen() { + // QW wallet using for tracking error!("P2P server failed with erorr: {:?}", e); } })?; diff --git a/servers/src/mwc/sync/body_sync.rs b/servers/src/mwc/sync/body_sync.rs index aefa09966..b48be602d 100644 --- a/servers/src/mwc/sync/body_sync.rs +++ b/servers/src/mwc/sync/body_sync.rs @@ -66,6 +66,14 @@ impl BodySync { // Last few blocks no need to sync, new mined blocks will be synced regular way if head.height > max_avail_height.saturating_sub(3) { + // Expected by QT wallet + info!( + "synchronized at {} @ {} [{}]", + head.total_difficulty.to_num(), + head.height, + head.last_block_h + ); + // sync is done, we are ready. return Ok(SyncResponse::new( SyncRequestResponses::BodyReady, diff --git a/servers/src/mwc/sync/header_sync.rs b/servers/src/mwc/sync/header_sync.rs index 0c70477f7..a09c0cbee 100644 --- a/servers/src/mwc/sync/header_sync.rs +++ b/servers/src/mwc/sync/header_sync.rs @@ -414,11 +414,10 @@ impl HeaderSync { // That is needed for sync tracking info!( - "Received {} block headers from {}, height {}, remaining {}", + "Received {} block headers from {}, height {}", bhs.len(), peer, bhs[0].height, - 0 ); // try to add headers to our header chain diff --git a/servers/src/mwc/sync/state_sync.rs b/servers/src/mwc/sync/state_sync.rs index 9f1a4cd53..d8a5c6a1c 100644 --- a/servers/src/mwc/sync/state_sync.rs +++ b/servers/src/mwc/sync/state_sync.rs @@ -343,9 +343,10 @@ impl StateSync { } if root_hash_peers.is_empty() { - // no peers commited to hash, resetting download process - self.chain.reset_desegmenter(); if other_hashes > 0 { + // no peers commited to hash, resetting download process if we have alternatives. + self.chain.reset_desegmenter(); + // Sinse there are other groups, treating that as attack. Banning all supporters self.ban_this_session(desegmenter, sync_peers); return SyncResponse::new( diff --git a/servers/src/mwc/sync/syncer.rs b/servers/src/mwc/sync/syncer.rs index a778789d4..8bdf51b58 100644 --- a/servers/src/mwc/sync/syncer.rs +++ b/servers/src/mwc/sync/syncer.rs @@ -136,6 +136,7 @@ impl SyncRunner { match sync_reponse.response { SyncRequestResponses::WaitingForPeers => { + info!("Waiting for the peers"); self.sync_state.update(SyncStatus::AwaitingPeers); self.peers .set_boost_peers_capabilities(sync_reponse.peers_capabilities);