Skip to content

Commit

Permalink
Showing 1 changed file with 33 additions and 33 deletions.
66 changes: 33 additions & 33 deletions integration-tests/src/test_loop/tests/resharding_v3.rs
Original file line number Diff line number Diff line change
Expand Up @@ -605,13 +605,13 @@ fn test_resharding_v3_base(params: TestReshardingParameters) {
}

#[test]
fn test_resharding_v3() {
fn slow_test_resharding_v3() {
test_resharding_v3_base(TestReshardingParametersBuilder::default().build());
}

// TODO(resharding) Add test with double resharding (not independent) when it is supported.
#[test]
fn test_resharding_v3_two_independent_splits() {
fn slow_test_resharding_v3_two_independent_splits() {
let second_resharding_boundary_account = "account2".parse().unwrap();
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
Expand All @@ -637,7 +637,7 @@ fn shard_sequence_to_schedule(
}

#[test]
fn test_resharding_v3_two_splits_one_after_another_at_single_node() {
fn slow_test_resharding_v3_two_splits_one_after_another_at_single_node() {
let first_resharding_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let second_resharding_boundary_account: AccountId = "account2".parse().unwrap();

Expand Down Expand Up @@ -694,7 +694,7 @@ fn test_resharding_v3_two_splits_one_after_another_at_single_node() {
// Track parent shard before resharding, child shard after resharding, and then an unrelated shard forever.
// Eventually, the State column should only contain entries belonging to the last tracked shard.
#[test]
fn test_resharding_v3_state_cleanup() {
fn slow_test_resharding_v3_state_cleanup() {
let account_in_stable_shard: AccountId = "account0".parse().unwrap();
let split_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let base_shard_layout = get_base_shard_layout(DEFAULT_SHARD_LAYOUT_VERSION);
Expand Down Expand Up @@ -723,7 +723,7 @@ fn test_resharding_v3_state_cleanup() {

// Track parent shard before resharding, but do not track any child shard after resharding.
#[test]
fn test_resharding_v3_do_not_track_children_after_resharding() {
fn slow_test_resharding_v3_do_not_track_children_after_resharding() {
let account_in_stable_shard: AccountId = "account0".parse().unwrap();
let split_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let base_shard_layout = get_base_shard_layout(DEFAULT_SHARD_LAYOUT_VERSION);
Expand Down Expand Up @@ -754,7 +754,7 @@ fn test_resharding_v3_do_not_track_children_after_resharding() {
// We expect all parent state and mapping have been removed,
// then child shard was state synced without mapping.
#[test]
fn test_resharding_v3_stop_track_child_for_5_epochs() {
fn slow_test_resharding_v3_stop_track_child_for_5_epochs() {
let account_in_stable_shard: AccountId = "account0".parse().unwrap();
let split_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let base_shard_layout = get_base_shard_layout(DEFAULT_SHARD_LAYOUT_VERSION);
Expand Down Expand Up @@ -797,7 +797,7 @@ fn test_resharding_v3_stop_track_child_for_5_epochs() {
// We expect the mapping to parent to be preserved, because there were not enough
// epochs where we did not track any child for mapping to be removed.
#[test]
fn test_resharding_v3_stop_track_child_for_5_epochs_with_sibling_in_between() {
fn slow_test_resharding_v3_stop_track_child_for_5_epochs_with_sibling_in_between() {
let account_in_stable_shard: AccountId = "account0".parse().unwrap();
let split_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let base_shard_layout = get_base_shard_layout(DEFAULT_SHARD_LAYOUT_VERSION);
Expand Down Expand Up @@ -837,7 +837,7 @@ fn test_resharding_v3_stop_track_child_for_5_epochs_with_sibling_in_between() {
// Sets up an extra node that doesn't track the parent, doesn't track the child in the first post-resharding
// epoch, and then tracks a child in the epoch after that. This checks that state sync works in that case.
#[test]
fn test_resharding_v3_sync_child() {
fn slow_test_resharding_v3_sync_child() {
let account_in_stable_shard: AccountId = "account0".parse().unwrap();
let split_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let base_shard_layout = get_base_shard_layout(DEFAULT_SHARD_LAYOUT_VERSION);
Expand All @@ -864,7 +864,7 @@ fn test_resharding_v3_sync_child() {
}

#[test]
fn test_resharding_v3_track_all_shards() {
fn slow_test_resharding_v3_track_all_shards() {
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
.track_all_shards(true)
Expand All @@ -874,7 +874,7 @@ fn test_resharding_v3_track_all_shards() {
}

#[test]
fn test_resharding_v3_drop_chunks_before() {
fn slow_test_resharding_v3_drop_chunks_before() {
let chunk_ranges_to_drop = HashMap::from([(1, -2..0)]);
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
Expand All @@ -885,7 +885,7 @@ fn test_resharding_v3_drop_chunks_before() {
}

#[test]
fn test_resharding_v3_drop_chunks_after() {
fn slow_test_resharding_v3_drop_chunks_after() {
let chunk_ranges_to_drop = HashMap::from([(2, 0..2)]);
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
Expand All @@ -895,7 +895,7 @@ fn test_resharding_v3_drop_chunks_after() {
}

#[test]
fn test_resharding_v3_drop_chunks_before_and_after() {
fn slow_test_resharding_v3_drop_chunks_before_and_after() {
let chunk_ranges_to_drop = HashMap::from([(0, -2..2)]);
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
Expand All @@ -906,7 +906,7 @@ fn test_resharding_v3_drop_chunks_before_and_after() {
}

#[test]
fn test_resharding_v3_drop_chunks_all() {
fn slow_test_resharding_v3_drop_chunks_all() {
let chunk_ranges_to_drop = HashMap::from([(0, -1..2), (1, -3..0), (2, 0..3), (3, 0..1)]);
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
Expand All @@ -918,7 +918,7 @@ fn test_resharding_v3_drop_chunks_all() {

#[test]
#[cfg(feature = "test_features")]
fn test_resharding_v3_resharding_block_in_fork() {
fn slow_test_resharding_v3_resharding_block_in_fork() {
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
.num_clients(1)
Expand All @@ -937,7 +937,7 @@ fn test_resharding_v3_resharding_block_in_fork() {
// In the current scenario the real resharding happens on block B'. Low priority TODO
// since it's a very rare corner case.
#[cfg(feature = "test_features")]
fn test_resharding_v3_double_sign_resharding_block() {
fn slow_test_resharding_v3_double_sign_resharding_block() {
test_resharding_v3_base(
TestReshardingParametersBuilder::default()
.num_clients(1)
Expand All @@ -951,7 +951,7 @@ fn test_resharding_v3_double_sign_resharding_block() {
}

#[test]
fn test_resharding_v3_shard_shuffling() {
fn slow_test_resharding_v3_shard_shuffling() {
let params = TestReshardingParametersBuilder::default()
.shuffle_shard_assignment_for_chunk_producers(true)
.num_epochs_to_wait(INCREASED_TESTLOOP_NUM_EPOCHS_TO_WAIT)
Expand All @@ -964,7 +964,7 @@ fn test_resharding_v3_shard_shuffling() {
/// in the next epoch after that. In that case we don't want to state sync because we can just perform
/// the resharding and continue applying chunks for the child in the first epoch post-resharding.
#[test]
fn test_resharding_v3_shard_shuffling_untrack_then_track() {
fn slow_test_resharding_v3_shard_shuffling_untrack_then_track() {
let account_in_stable_shard: AccountId = "account0".parse().unwrap();
let split_boundary_account: AccountId = NEW_BOUNDARY_ACCOUNT.parse().unwrap();
let base_shard_layout = get_base_shard_layout(DEFAULT_SHARD_LAYOUT_VERSION);
Expand Down Expand Up @@ -993,7 +993,7 @@ fn test_resharding_v3_shard_shuffling_untrack_then_track() {
}

#[test]
fn test_resharding_v3_shard_shuffling_intense() {
fn slow_test_resharding_v3_shard_shuffling_intense() {
let chunk_ranges_to_drop = HashMap::from([(0, -1..2), (1, -3..0), (2, -3..3), (3, 0..1)]);
let params = TestReshardingParametersBuilder::default()
.num_accounts(8)
Expand All @@ -1012,7 +1012,7 @@ fn test_resharding_v3_shard_shuffling_intense() {
/// resharding. Caught a bug with invalid storage costs computed during flat
/// storage resharding.
#[test]
fn test_resharding_v3_storage_operations() {
fn slow_test_resharding_v3_storage_operations() {
let sender_account: AccountId = "account1".parse().unwrap();
let account_in_parent: AccountId = "account4".parse().unwrap();
let params = TestReshardingParametersBuilder::default()
Expand All @@ -1027,7 +1027,7 @@ fn test_resharding_v3_storage_operations() {

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_delayed_receipts_left_child() {
fn slow_test_resharding_v3_delayed_receipts_left_child() {
let account: AccountId = "account4".parse().unwrap();
let params = TestReshardingParametersBuilder::default()
.deploy_test_contract(account.clone())
Expand All @@ -1047,7 +1047,7 @@ fn test_resharding_v3_delayed_receipts_left_child() {

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_delayed_receipts_right_child() {
fn slow_test_resharding_v3_delayed_receipts_right_child() {
let account: AccountId = "account6".parse().unwrap();
let params = TestReshardingParametersBuilder::default()
.deploy_test_contract(account.clone())
Expand Down Expand Up @@ -1096,13 +1096,13 @@ fn test_resharding_v3_split_parent_buffered_receipts_base(base_shard_layout_vers

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_split_parent_buffered_receipts_v1() {
fn slow_test_resharding_v3_split_parent_buffered_receipts_v1() {
test_resharding_v3_split_parent_buffered_receipts_base(1);
}

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_split_parent_buffered_receipts_v2() {
fn slow_test_resharding_v3_split_parent_buffered_receipts_v2() {
test_resharding_v3_split_parent_buffered_receipts_base(2);
}

Expand Down Expand Up @@ -1138,13 +1138,13 @@ fn test_resharding_v3_buffered_receipts_towards_splitted_shard_base(

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_buffered_receipts_towards_splitted_shard_v1() {
fn slow_test_resharding_v3_buffered_receipts_towards_splitted_shard_v1() {
test_resharding_v3_buffered_receipts_towards_splitted_shard_base(1);
}

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_buffered_receipts_towards_splitted_shard_v2() {
fn slow_test_resharding_v3_buffered_receipts_towards_splitted_shard_v2() {
test_resharding_v3_buffered_receipts_towards_splitted_shard_base(2);
}

Expand Down Expand Up @@ -1191,7 +1191,7 @@ fn slow_test_resharding_v3_large_receipts_towards_splitted_shard_v2() {

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_outgoing_receipts_towards_splitted_shard() {
fn slow_test_resharding_v3_outgoing_receipts_towards_splitted_shard() {
let receiver_account: AccountId = "account4".parse().unwrap();
let account_1_in_stable_shard: AccountId = "account1".parse().unwrap();
let account_2_in_stable_shard: AccountId = "account2".parse().unwrap();
Expand All @@ -1209,7 +1209,7 @@ fn test_resharding_v3_outgoing_receipts_towards_splitted_shard() {

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_outgoing_receipts_from_splitted_shard() {
fn slow_test_resharding_v3_outgoing_receipts_from_splitted_shard() {
let receiver_account: AccountId = "account0".parse().unwrap();
let account_in_left_child: AccountId = "account4".parse().unwrap();
let account_in_right_child: AccountId = "account6".parse().unwrap();
Expand All @@ -1227,7 +1227,7 @@ fn test_resharding_v3_outgoing_receipts_from_splitted_shard() {
}

#[test]
fn test_resharding_v3_load_memtrie_v1() {
fn slow_test_resharding_v3_load_memtrie_v1() {
let params = TestReshardingParametersBuilder::default()
.base_shard_layout_version(1)
.load_memtries_for_tracked_shards(false)
Expand All @@ -1236,7 +1236,7 @@ fn test_resharding_v3_load_memtrie_v1() {
}

#[test]
fn test_resharding_v3_load_memtrie_v2() {
fn slow_test_resharding_v3_load_memtrie_v2() {
let params = TestReshardingParametersBuilder::default()
.base_shard_layout_version(2)
.load_memtries_for_tracked_shards(false)
Expand All @@ -1246,7 +1246,7 @@ fn test_resharding_v3_load_memtrie_v2() {

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_slower_post_processing_tasks() {
fn slow_test_resharding_v3_slower_post_processing_tasks() {
// When there's a resharding task delay and single-shard tracking, the delay might be pushed out
// even further because the resharding task might have to wait for the state snapshot to be made
// before it can proceed, which might mean that flat storage won't be ready for the child shard for a whole epoch.
Expand All @@ -1261,7 +1261,7 @@ fn test_resharding_v3_slower_post_processing_tasks() {

#[test]
#[cfg_attr(not(feature = "test_features"), ignore)]
fn test_resharding_v3_shard_shuffling_slower_post_processing_tasks() {
fn slow_test_resharding_v3_shard_shuffling_slower_post_processing_tasks() {
let params = TestReshardingParametersBuilder::default()
.shuffle_shard_assignment_for_chunk_producers(true)
.num_epochs_to_wait(INCREASED_TESTLOOP_NUM_EPOCHS_TO_WAIT)
Expand All @@ -1272,7 +1272,7 @@ fn test_resharding_v3_shard_shuffling_slower_post_processing_tasks() {
}

#[test]
fn test_resharding_v3_yield_resume() {
fn slow_test_resharding_v3_yield_resume() {
let account_in_left_child: AccountId = "account4".parse().unwrap();
let account_in_right_child: AccountId = "account6".parse().unwrap();
let params = TestReshardingParametersBuilder::default()
Expand All @@ -1296,7 +1296,7 @@ fn test_resharding_v3_yield_resume() {
}

#[test]
fn test_resharding_v3_yield_timeout() {
fn slow_test_resharding_v3_yield_timeout() {
let account_in_left_child: AccountId = "account4".parse().unwrap();
let account_in_right_child: AccountId = "account6".parse().unwrap();
let params = TestReshardingParametersBuilder::default()
Expand Down

0 comments on commit ebb9186

Please sign in to comment.