diff --git a/servers/src/grin/sync/state_sync.rs b/servers/src/grin/sync/state_sync.rs index 66d76d93e..991ffc743 100644 --- a/servers/src/grin/sync/state_sync.rs +++ b/servers/src/grin/sync/state_sync.rs @@ -40,7 +40,6 @@ pub struct StateSync { last_logged_time: i64, last_download_size: u64, - pibd_aborted: bool, earliest_zero_pibd_peer_time: Option>, } @@ -58,16 +57,10 @@ impl StateSync { state_sync_peer: None, last_logged_time: 0, last_download_size: 0, - pibd_aborted: false, earliest_zero_pibd_peer_time: None, } } - /// Flag to abort PIBD process - pub fn set_pibd_aborted(&mut self) { - self.pibd_aborted = true; - } - /// Record earliest time at which we had no suitable /// peers for continuing PIBD pub fn set_earliest_zero_pibd_peer_time(&mut self, t: Option>) { @@ -99,20 +92,10 @@ impl StateSync { // Determine whether we're going to try using PIBD or whether we've already given up // on it - let using_pibd = - if let SyncStatus::TxHashsetPibd { aborted: true, .. } = self.sync_state.status() { - false - } else if self.pibd_aborted { - false - } else { - // Only on testing chains for now - if global::get_chain_type() != global::ChainTypes::Mainnet { - true - //false - } else { - false - } - }; + let using_pibd = !matches!( + self.sync_state.status(), + SyncStatus::TxHashsetPibd { aborted: true, .. }, + ); // Check whether we've errored and should restart pibd if using_pibd { @@ -337,7 +320,6 @@ impl StateSync { .update_pibd_progress(true, true, 0, 1, &archive_header); self.sync_state .set_sync_error(chain::Error::AbortingPIBDError); - self.set_pibd_aborted(); return false; } } else {