diff --git a/src/ledger/ledger_sync.cpp b/src/ledger/ledger_sync.cpp index 9dc64d4c..9c12c6bd 100644 --- a/src/ledger/ledger_sync.cpp +++ b/src/ledger/ledger_sync.cpp @@ -157,4 +157,11 @@ namespace ledger candidate_hpfs_responses.splice(candidate_hpfs_responses.end(), p2p::ctx.collected_msgs.ledger_hpfs_responses); } + void ledger_sync::on_sync_abandoned() + { + // Reset these flags since we are abandoning the sync. + is_last_primary_shard_syncing = false; + is_last_blob_shard_syncing = false; + } + } // namespace ledger \ No newline at end of file diff --git a/src/ledger/ledger_sync.hpp b/src/ledger/ledger_sync.hpp index 4500b7a1..0c8f4938 100644 --- a/src/ledger/ledger_sync.hpp +++ b/src/ledger/ledger_sync.hpp @@ -13,6 +13,7 @@ namespace ledger private: void swap_collected_responses(); void on_current_sync_state_acheived(const hpfs::sync_target &synced_target); + void on_sync_abandoned(); public: std::atomic is_last_primary_shard_syncing = false;