File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
crates/apollo_l1_provider/src Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 1+ use std:: sync:: atomic:: { AtomicU64 , Ordering } ;
12use std:: sync:: { Arc , Mutex } ;
23
34use apollo_l1_provider_types:: errors:: L1ProviderError ;
@@ -121,13 +122,13 @@ async fn latest_block_number_goes_down() {
121122
122123 let initial_block_reference = L1BlockReference { number : 0 , hash : L1_BLOCK_HASH } ;
123124
124- let latest_l1_block_number_response = Arc :: new ( Mutex :: new ( L1_LATEST_BLOCK_NUMBER ) ) ;
125+ let latest_l1_block_number_response = Arc :: new ( AtomicU64 :: new ( L1_LATEST_BLOCK_NUMBER ) ) ;
125126 let latest_l1_block_number_response_clone = latest_l1_block_number_response. clone ( ) ;
126127
127128 dummy_base_layer
128129 . expect_latest_l1_block_number ( )
129130 . times ( 2 )
130- . returning ( move || Ok ( * latest_l1_block_number_response_clone. lock ( ) . unwrap ( ) ) ) ;
131+ . returning ( move || Ok ( latest_l1_block_number_response_clone. load ( Ordering :: Relaxed ) ) ) ;
131132
132133 dummy_base_layer. expect_events ( ) . times ( 1 ) . returning ( |_, _| Ok ( vec ! [ ] ) ) ;
133134
@@ -145,7 +146,7 @@ async fn latest_block_number_goes_down() {
145146 assert_eq ! ( scraper. send_events_to_l1_provider( ) . await , Ok ( ( ) ) ) ;
146147
147148 // Simulate a base layer returning a lower block number.
148- * latest_l1_block_number_response. lock ( ) . unwrap ( ) = L1_BAD_LATEST_NUMBER ;
149+ latest_l1_block_number_response. store ( L1_BAD_LATEST_NUMBER , Ordering :: Relaxed ) ;
149150
150151 // Make sure we don't hit the reorg error in this scenario.
151152 scraper. assert_no_l1_reorgs ( ) . await . unwrap ( ) ;
You can’t perform that action at this time.
0 commit comments