Skip to content

Commit

Permalink
refactor(state-sync): Rename module: syncing -> state_sync (#9594)
Browse files Browse the repository at this point in the history
Co-authored-by: Jakob Meier <mail@jakobmeier.ch>
Co-authored-by: Shreyan Gupta <shreyan@near.org>
  • Loading branch information
3 people authored and Nikolay Kurtov committed Oct 2, 2023
1 parent 0fcafb0 commit 6ef2dca
Show file tree
Hide file tree
Showing 21 changed files with 26 additions and 26 deletions.
4 changes: 2 additions & 2 deletions chain/chain/src/chain.rs
Original file line number Diff line number Diff line change
Expand Up @@ -56,11 +56,11 @@ use near_primitives::sharding::{
ShardChunkHeader, ShardInfo, ShardProof, StateSyncInfo,
};
use near_primitives::state_part::PartId;
use near_primitives::static_clock::StaticClock;
use near_primitives::syncing::{
use near_primitives::state_sync::{
get_num_state_parts, ReceiptProofResponse, RootProof, ShardStateSyncResponseHeader,
ShardStateSyncResponseHeaderV1, ShardStateSyncResponseHeaderV2, StateHeaderKey, StatePartKey,
};
use near_primitives::static_clock::StaticClock;
use near_primitives::transaction::{ExecutionOutcomeWithIdAndProof, SignedTransaction};
use near_primitives::types::chunk_extra::ChunkExtra;
use near_primitives::types::{
Expand Down
2 changes: 1 addition & 1 deletion chain/chain/src/resharding.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ use near_primitives::hash::CryptoHash;
use near_primitives::shard_layout::{account_id_to_shard_uid, ShardLayout};
use near_primitives::state::FlatStateValue;
use near_primitives::state_part::PartId;
use near_primitives::syncing::get_num_state_parts;
use near_primitives::state_sync::get_num_state_parts;
use near_primitives::types::chunk_extra::ChunkExtra;
use near_primitives::types::{AccountId, ShardId, StateRoot};
use near_store::flat::{
Expand Down
2 changes: 1 addition & 1 deletion chain/chain/src/store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ use near_primitives::sharding::{
ChunkHash, EncodedShardChunk, PartialEncodedChunk, ReceiptProof, ShardChunk, ShardChunkHeader,
StateSyncInfo,
};
use near_primitives::syncing::{
use near_primitives::state_sync::{
get_num_state_parts, ReceiptProofResponse, ShardStateSyncResponseHeader, StateHeaderKey,
StatePartKey, StateSyncDumpProgress,
};
Expand Down
2 changes: 1 addition & 1 deletion chain/chain/src/store_validator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use near_primitives::epoch_manager::epoch_info::EpochInfo;
use near_primitives::epoch_manager::AGGREGATOR_KEY;
use near_primitives::hash::CryptoHash;
use near_primitives::sharding::{ChunkHash, ShardChunk, StateSyncInfo};
use near_primitives::syncing::{ShardStateSyncResponseHeader, StateHeaderKey, StatePartKey};
use near_primitives::state_sync::{ShardStateSyncResponseHeader, StateHeaderKey, StatePartKey};
use near_primitives::transaction::ExecutionOutcomeWithProof;
use near_primitives::types::chunk_extra::ChunkExtra;
use near_primitives::types::{AccountId, BlockHeight, EpochId};
Expand Down
2 changes: 1 addition & 1 deletion chain/chain/src/store_validator/validate.rs
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ use near_primitives::epoch_manager::epoch_info::EpochInfo;
use near_primitives::hash::CryptoHash;
use near_primitives::shard_layout::{get_block_shard_uid, ShardUId};
use near_primitives::sharding::{ChunkHash, ShardChunk, StateSyncInfo};
use near_primitives::syncing::{
use near_primitives::state_sync::{
get_num_state_parts, ShardStateSyncResponseHeader, StateHeaderKey, StatePartKey,
};
use near_primitives::transaction::{ExecutionOutcomeWithProof, SignedTransaction};
Expand Down
4 changes: 2 additions & 2 deletions chain/client/src/debug.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,11 @@ use near_client_primitives::{
use near_epoch_manager::EpochManagerAdapter;
use near_o11y::{handler_debug_span, log_assert, OpenTelemetrySpanExt, WithSpanContext};
use near_performance_metrics_macros::perf;
use near_primitives::syncing::get_num_state_parts;
use near_primitives::state_sync::get_num_state_parts;
use near_primitives::types::{AccountId, BlockHeight, ShardId, ValidatorInfoIdentifier};
use near_primitives::{
hash::CryptoHash,
syncing::{ShardStateSyncResponseHeader, StateHeaderKey},
state_sync::{ShardStateSyncResponseHeader, StateHeaderKey},
types::EpochId,
views::ValidatorInfo,
};
Expand Down
4 changes: 2 additions & 2 deletions chain/client/src/sync/state.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,8 +46,8 @@ use near_network::types::{
use near_primitives::hash::CryptoHash;
use near_primitives::shard_layout::ShardUId;
use near_primitives::state_part::PartId;
use near_primitives::state_sync::{get_num_state_parts, ShardStateSyncResponse};
use near_primitives::static_clock::StaticClock;
use near_primitives::syncing::{get_num_state_parts, ShardStateSyncResponse};
use near_primitives::types::{AccountId, EpochHeight, EpochId, ShardId, StateRoot};
use rand::seq::SliceRandom;
use rand::{thread_rng, Rng};
Expand Down Expand Up @@ -1400,7 +1400,7 @@ mod test {
use near_epoch_manager::EpochManagerAdapter;
use near_network::test_utils::MockPeerManagerAdapter;
use near_primitives::{
syncing::{ShardStateSyncResponseHeader, ShardStateSyncResponseV2},
state_sync::{ShardStateSyncResponseHeader, ShardStateSyncResponseV2},
test_utils::TestBlockBuilder,
types::EpochId,
};
Expand Down
2 changes: 1 addition & 1 deletion chain/client/src/sync_jobs_actor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ use near_chain::Chain;
use near_o11y::{handler_debug_span, OpenTelemetrySpanExt, WithSpanContext, WithSpanContextExt};
use near_performance_metrics_macros::perf;
use near_primitives::state_part::PartId;
use near_primitives::syncing::StatePartKey;
use near_primitives::state_sync::StatePartKey;
use near_primitives::types::ShardId;
use near_store::DBCol;

Expand Down
4 changes: 2 additions & 2 deletions chain/client/src/view_client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -42,11 +42,11 @@ use near_primitives::merkle::{merklize, PartialMerkleTree};
use near_primitives::network::AnnounceAccount;
use near_primitives::receipt::Receipt;
use near_primitives::sharding::ShardChunk;
use near_primitives::static_clock::StaticClock;
use near_primitives::syncing::{
use near_primitives::state_sync::{
ShardStateSyncResponse, ShardStateSyncResponseHeader, ShardStateSyncResponseV1,
ShardStateSyncResponseV2,
};
use near_primitives::static_clock::StaticClock;
use near_primitives::types::{
AccountId, BlockHeight, BlockId, BlockReference, EpochReference, Finality, MaybeBlockId,
ShardId, SyncCheckpoint, TransactionOrReceiptId, ValidatorInfoIdentifier,
Expand Down
2 changes: 1 addition & 1 deletion chain/network/src/network_protocol/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ use near_primitives::network::{AnnounceAccount, PeerId};
use near_primitives::sharding::{
ChunkHash, PartialEncodedChunk, PartialEncodedChunkPart, ReceiptProof, ShardChunkHeader,
};
use near_primitives::syncing::{ShardStateSyncResponse, ShardStateSyncResponseV1};
use near_primitives::state_sync::{ShardStateSyncResponse, ShardStateSyncResponseV1};
use near_primitives::transaction::SignedTransaction;
use near_primitives::types::AccountId;
use near_primitives::types::{BlockHeight, ShardId};
Expand Down
2 changes: 1 addition & 1 deletion chain/network/src/testonly/fake_client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ use near_primitives::challenge::Challenge;
use near_primitives::hash::CryptoHash;
use near_primitives::network::{AnnounceAccount, PeerId};
use near_primitives::sharding::{ChunkHash, PartialEncodedChunkPart};
use near_primitives::syncing::{ShardStateSyncResponse, ShardStateSyncResponseV2};
use near_primitives::state_sync::{ShardStateSyncResponse, ShardStateSyncResponseV2};
use near_primitives::transaction::SignedTransaction;
use near_primitives::types::{AccountId, EpochId, ShardId};
use near_primitives::views::FinalExecutionOutcomeView;
Expand Down
2 changes: 1 addition & 1 deletion core/primitives/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@ pub mod signable_message;
pub mod state;
pub mod state_part;
pub mod state_record;
pub mod state_sync;
pub mod static_clock;
pub mod syncing;
pub mod telemetry;
pub mod test_utils;
pub mod transaction;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ pub enum StateSyncDumpProgress {

#[cfg(test)]
mod tests {
use crate::syncing::{get_num_state_parts, STATE_PART_MEMORY_LIMIT};
use crate::state_sync::{get_num_state_parts, STATE_PART_MEMORY_LIMIT};

#[test]
fn test_get_num_state_parts() {
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/src/tests/client/process_blocks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ use near_primitives::sharding::{
ShardChunkHeaderV3,
};
use near_primitives::state_part::PartId;
use near_primitives::syncing::{get_num_state_parts, StatePartKey};
use near_primitives::state_sync::{get_num_state_parts, StatePartKey};
use near_primitives::test_utils::create_test_signer;
use near_primitives::test_utils::TestBlockBuilder;
use near_primitives::transaction::{
Expand Down
4 changes: 2 additions & 2 deletions integration-tests/src/tests/client/state_dump.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,8 +14,8 @@ use near_primitives::block::Tip;
use near_primitives::shard_layout::ShardUId;
use near_primitives::state::FlatStateValue;
use near_primitives::state_part::PartId;
use near_primitives::syncing::get_num_state_parts;
use near_primitives::syncing::StatePartKey;
use near_primitives::state_sync::get_num_state_parts;
use near_primitives::state_sync::StatePartKey;
use near_primitives::transaction::SignedTransaction;
use near_primitives::types::BlockHeight;
use near_primitives::views::{QueryRequest, QueryResponseKind};
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/src/tests/client/sync_state_nodes.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ use near_o11y::testonly::{init_integration_logger, init_test_logger};
use near_o11y::WithSpanContextExt;
use near_primitives::shard_layout::ShardUId;
use near_primitives::state_part::PartId;
use near_primitives::syncing::{get_num_state_parts, StatePartKey};
use near_primitives::state_sync::{get_num_state_parts, StatePartKey};
use near_primitives::transaction::SignedTransaction;
use near_primitives::utils::MaybeValidated;
use near_primitives_core::types::ShardId;
Expand Down
2 changes: 1 addition & 1 deletion nearcore/src/state_sync.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ use near_epoch_manager::shard_tracker::ShardTracker;
use near_epoch_manager::EpochManagerAdapter;
use near_primitives::hash::CryptoHash;
use near_primitives::state_part::PartId;
use near_primitives::syncing::{get_num_state_parts, StatePartKey, StateSyncDumpProgress};
use near_primitives::state_sync::{get_num_state_parts, StatePartKey, StateSyncDumpProgress};
use near_primitives::types::{AccountId, EpochHeight, EpochId, ShardId, StateRoot};
use near_store::DBCol;
use rand::{thread_rng, Rng};
Expand Down
2 changes: 1 addition & 1 deletion tools/mock-node/src/setup.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ use near_network::tcp;
use near_network::types::PeerInfo;
use near_primitives::network::PeerId;
use near_primitives::state_part::PartId;
use near_primitives::syncing::get_num_state_parts;
use near_primitives::state_sync::get_num_state_parts;
use near_primitives::types::{BlockHeight, ShardId};
use near_store::test_utils::create_test_store;
use nearcore::{NearConfig, NightshadeRuntime};
Expand Down
2 changes: 1 addition & 1 deletion tools/state-viewer/src/apply_chunk.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ use near_primitives::merkle::combine_hash;
use near_primitives::receipt::Receipt;
use near_primitives::shard_layout;
use near_primitives::sharding::{ChunkHash, ReceiptProof};
use near_primitives::syncing::ReceiptProofResponse;
use near_primitives::state_sync::ReceiptProofResponse;
use near_primitives::types::{BlockHeight, ShardId};
use near_primitives_core::hash::hash;
use near_primitives_core::types::Gas;
Expand Down
2 changes: 1 addition & 1 deletion tools/state-viewer/src/scan_db.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ use near_primitives::receipt::Receipt;
use near_primitives::shard_layout::{get_block_shard_uid_rev, ShardUId};
use near_primitives::sharding::{ChunkHash, ReceiptProof, ShardChunk, StateSyncInfo};
use near_primitives::state::FlatStateValue;
use near_primitives::syncing::{
use near_primitives::state_sync::{
ShardStateSyncResponseHeader, StateHeaderKey, StatePartKey, StateSyncDumpProgress,
};
use near_primitives::transaction::{ExecutionOutcomeWithProof, SignedTransaction};
Expand Down
2 changes: 1 addition & 1 deletion tools/state-viewer/src/state_parts.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ use near_primitives::challenge::PartialState;
use near_primitives::epoch_manager::epoch_info::EpochInfo;
use near_primitives::state_part::PartId;
use near_primitives::state_record::StateRecord;
use near_primitives::syncing::get_num_state_parts;
use near_primitives::state_sync::get_num_state_parts;
use near_primitives::types::{EpochId, StateRoot};
use near_primitives_core::hash::CryptoHash;
use near_primitives_core::types::{BlockHeight, EpochHeight, ShardId};
Expand Down

0 comments on commit 6ef2dca

Please sign in to comment.