@@ -1460,6 +1460,7 @@ fn multiple_miners() {
1460
1460
let node_2_rpc_bind = format ! ( "{localhost}:{node_2_rpc}" ) ;
1461
1461
let mut node_2_listeners = Vec :: new ( ) ;
1462
1462
1463
+ let max_nakamoto_tenures = 30 ;
1463
1464
// partition the signer set so that ~half are listening and using node 1 for RPC and events,
1464
1465
// and the rest are using node 2
1465
1466
@@ -1481,6 +1482,7 @@ fn multiple_miners() {
1481
1482
config. node . p2p_address = format ! ( "{localhost}:{node_1_p2p}" ) ;
1482
1483
config. miner . wait_on_interim_blocks = Duration :: from_secs ( 5 ) ;
1483
1484
config. node . pox_sync_sample_secs = 30 ;
1485
+ config. burnchain . pox_reward_length = Some ( max_nakamoto_tenures) ;
1484
1486
1485
1487
config. node . seed = btc_miner_1_seed. clone ( ) ;
1486
1488
config. node . local_peer_seed = btc_miner_1_seed. clone ( ) ;
@@ -1560,8 +1562,6 @@ fn multiple_miners() {
1560
1562
1561
1563
info ! ( "------------------------- Reached Epoch 3.0 -------------------------" ) ;
1562
1564
1563
- let max_nakamoto_tenures = 20 ;
1564
-
1565
1565
// due to the random nature of mining sortitions, the way this test is structured
1566
1566
// is that we keep track of how many tenures each miner produced, and once enough sortitions
1567
1567
// have been produced such that each miner has produced 3 tenures, we stop and check the
@@ -1645,11 +1645,11 @@ fn multiple_miners() {
1645
1645
assert_eq ! ( peer_1_height, peer_2_height) ;
1646
1646
assert_eq ! (
1647
1647
peer_1_height,
1648
- pre_nakamoto_peer_1_height + btc_blocks_mined - 1
1648
+ pre_nakamoto_peer_1_height + btc_blocks_mined as u64 - 1
1649
1649
) ;
1650
1650
assert_eq ! (
1651
1651
btc_blocks_mined,
1652
- u64 :: try_from( miner_1_tenures + miner_2_tenures) . unwrap( )
1652
+ u32 :: try_from( miner_1_tenures + miner_2_tenures) . unwrap( )
1653
1653
) ;
1654
1654
1655
1655
rl2_coord_channels
@@ -1664,7 +1664,7 @@ fn multiple_miners() {
1664
1664
/// Read processed nakamoto block IDs from the test observer, and use `config` to open
1665
1665
/// a chainstate DB and returns their corresponding StacksHeaderInfos
1666
1666
fn get_nakamoto_headers ( config : & Config ) -> Vec < StacksHeaderInfo > {
1667
- let nakamoto_block_ids: Vec < _ > = test_observer:: get_blocks ( )
1667
+ let nakamoto_block_ids: HashSet < _ > = test_observer:: get_blocks ( )
1668
1668
. into_iter ( )
1669
1669
. filter_map ( |block_json| {
1670
1670
if block_json
0 commit comments