@@ -5315,7 +5315,7 @@ pub mod tests {
5315
5315
crate :: {
5316
5316
genesis_utils:: { create_genesis_config, GenesisConfigInfo } ,
5317
5317
leader_schedule:: { FixedSchedule , IdentityKeyedLeaderSchedule } ,
5318
- shred:: { max_ticks_per_n_shreds, ShredFlags } ,
5318
+ shred:: max_ticks_per_n_shreds,
5319
5319
} ,
5320
5320
assert_matches:: assert_matches,
5321
5321
bincode:: { serialize, Options } ,
@@ -7542,18 +7542,25 @@ pub mod tests {
7542
7542
index
7543
7543
) ;
7544
7544
7545
- // Add a shred from different fec set
7545
+ let shredder = Shredder :: new ( slot, slot. saturating_sub ( 1 ) , 0 , 0 ) . unwrap ( ) ;
7546
+ let keypair = Keypair :: new ( ) ;
7547
+ let reed_solomon_cache = ReedSolomonCache :: default ( ) ;
7546
7548
let new_index = fec_set_index + 31 ;
7547
- let new_data_shred = Shred :: new_from_data (
7548
- slot,
7549
- new_index,
7550
- 1 , // parent_offset
7551
- & [ 3 , 3 , 3 ] , // data
7552
- ShredFlags :: empty ( ) ,
7553
- 0 , // reference_tick,
7554
- 0 , // version
7555
- fec_set_index + 30 ,
7556
- ) ;
7549
+ // Add a shred from different fec set
7550
+ let new_data_shred = shredder
7551
+ . make_shreds_from_data_slice (
7552
+ & keypair,
7553
+ & [ 3 , 3 , 3 ] ,
7554
+ false ,
7555
+ Some ( Hash :: default ( ) ) ,
7556
+ new_index,
7557
+ new_index,
7558
+ & reed_solomon_cache,
7559
+ & mut ProcessShredsStats :: default ( ) ,
7560
+ )
7561
+ . unwrap ( )
7562
+ . next ( )
7563
+ . unwrap ( ) ;
7557
7564
7558
7565
let mut shred_insertion_tracker =
7559
7566
ShredInsertionTracker :: new ( data_shreds. len ( ) , blockstore. db . batch ( ) . unwrap ( ) ) ;
@@ -7868,16 +7875,25 @@ pub mod tests {
7868
7875
) ;
7869
7876
7870
7877
// Insert an empty shred that won't deshred into entries
7871
- let shreds = vec ! [ Shred :: new_from_data(
7872
- slot,
7873
- next_shred_index as u32 ,
7874
- 1 ,
7875
- & [ 1 , 1 , 1 ] ,
7876
- ShredFlags :: LAST_SHRED_IN_SLOT ,
7877
- 0 ,
7878
- 0 ,
7879
- next_shred_index as u32 ,
7880
- ) ] ;
7878
+
7879
+ let shredder = Shredder :: new ( slot, slot. saturating_sub ( 1 ) , 0 , 0 ) . unwrap ( ) ;
7880
+ let keypair = Keypair :: new ( ) ;
7881
+ let reed_solomon_cache = ReedSolomonCache :: default ( ) ;
7882
+
7883
+ let shreds: Vec < Shred > = shredder
7884
+ . make_shreds_from_data_slice (
7885
+ & keypair,
7886
+ & [ 1 , 1 , 1 ] ,
7887
+ true ,
7888
+ Some ( Hash :: default ( ) ) ,
7889
+ next_shred_index as u32 ,
7890
+ next_shred_index as u32 ,
7891
+ & reed_solomon_cache,
7892
+ & mut ProcessShredsStats :: default ( ) ,
7893
+ )
7894
+ . unwrap ( )
7895
+ . take ( DATA_SHREDS_PER_FEC_BLOCK )
7896
+ . collect ( ) ;
7881
7897
7882
7898
// With the corruption, nothing should be returned, even though an
7883
7899
// earlier data block was valid
0 commit comments