From d50d8c7d5842c0cf25a4a44939312373d446f802 Mon Sep 17 00:00:00 2001 From: quake wang Date: Mon, 4 Feb 2019 15:10:47 +0900 Subject: [PATCH] test: skip verification in sync testing code --- sync/src/synchronizer/mod.rs | 14 +++++++------- sync/src/tests/relayer.rs | 4 +++- sync/src/tests/synchronizer.rs | 4 +++- 3 files changed, 13 insertions(+), 9 deletions(-) diff --git a/sync/src/synchronizer/mod.rs b/sync/src/synchronizer/mod.rs index 92aaf5ce64..0fb7fdb24c 100644 --- a/sync/src/synchronizer/mod.rs +++ b/sync/src/synchronizer/mod.rs @@ -766,7 +766,9 @@ mod tests { let shared = builder.build(); let notify = notify.unwrap_or_else(|| NotifyService::default().start::<&str>(None)); - let chain_service = ChainBuilder::new(shared.clone(), notify.clone()).build(); + let chain_service = ChainBuilder::new(shared.clone(), notify.clone()) + .verification(false) + .build(); let chain_controller = chain_service.start::<&str>(None); (chain_controller, shared, notify) @@ -995,18 +997,16 @@ mod tests { chain_controller1 .process_block(Arc::new(new_block.clone())) .expect("process block ok"); - blocks.push(new_block.clone()); parent = new_block.header().clone(); + blocks.push(new_block); } - let synchronizer = gen_synchronizer(chain_controller2.clone(), shared2.clone()); - - blocks.clone().into_iter().for_each(|block| { + let chain1_last_block = blocks.last().cloned().unwrap(); + blocks.into_iter().for_each(|block| { synchronizer.insert_new_block(peer, block); }); - assert_eq!( - blocks.last().unwrap().header(), + chain1_last_block.header(), shared2.chain_state().read().tip_header() ); } diff --git a/sync/src/tests/relayer.rs b/sync/src/tests/relayer.rs index cb4abdca8f..f0b21a1163 100644 --- a/sync/src/tests/relayer.rs +++ b/sync/src/tests/relayer.rs @@ -323,7 +323,9 @@ fn setup_node( TransactionPoolService::new(PoolConfig::default(), shared.clone(), notify.clone()); let tx_pool_controller = tx_pool_service.start(Some(thread_name)); - let chain_service = ChainBuilder::new(shared.clone(), notify).build(); + let chain_service = ChainBuilder::new(shared.clone(), notify) + .verification(false) + .build(); let chain_controller = chain_service.start::<&str>(None); for _i in 0..height { diff --git a/sync/src/tests/synchronizer.rs b/sync/src/tests/synchronizer.rs index e39dfb19bb..5562c50a2c 100644 --- a/sync/src/tests/synchronizer.rs +++ b/sync/src/tests/synchronizer.rs @@ -77,7 +77,9 @@ fn setup_node( .build(); let notify = NotifyService::default().start(Some(thread_name)); - let chain_service = ChainBuilder::new(shared.clone(), notify).build(); + let chain_service = ChainBuilder::new(shared.clone(), notify) + .verification(false) + .build(); let chain_controller = chain_service.start::<&str>(None); for _i in 0..height {