Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: CalvinNeo <calvinneo1995@gmail.com>
  • Loading branch information
CalvinNeo committed Nov 9, 2023
1 parent 44af9e6 commit 4385482
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ impl<T: Simulator<TiFlashEngine>> MixedCluster for Cluster<T> {
panic!(
"can't get value {:?} for key {}",
value.map(tikv_util::escape),
log_wrappers::hex_encode_upper(key)
log_wrappers::hex_encode_upper(key),
)
}
fn run_node(&mut self, node_id: u64) {
Expand Down
6 changes: 4 additions & 2 deletions proxy_tests/proxy/shared/fast_add_peer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -275,21 +275,23 @@ fn test_overlap_apply_legacy_in_the_middle() {
states.in_disk_region_state.get_region().get_peers().len() == 3
},
);
std::thread::sleep(std::time::Duration::from_millis(1000));
std::thread::sleep(std::time::Duration::from_millis(500));
fail::cfg("fap_ffi_pause_after_fap_call", "pause").unwrap();
std::thread::sleep(std::time::Duration::from_millis(500));
fail::remove("fap_ffi_pause");

iter_ffi_helpers(&cluster, Some(vec![3]), &mut |_, ffi: &mut FFIHelperSet| {
assert!(!ffi.engine_store_server.kvstore.contains_key(&1000));
});

// The snapshot for new_one_1000_k1 is in `tmp_fap_regions`.
// Raftstore v1 is mono store, so there could be v1 written by old_one_1_k3.
check_key_ex(
&cluster,
b"k1",
b"v1",
None,
Some(false),
None,
Some(vec![3]),
Some(new_one_1000_k1.get_id()),
true,
Expand Down

0 comments on commit 4385482

Please sign in to comment.