test: Fix atomic ordering for arm

qingstor · Aug 29, 2023 · 2b287d5 · 2b287d5
1 parent 7d4e826
commit 2b287d5
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/src/channel/mod.rs b/src/channel/mod.rs
@@ -73,7 +73,7 @@ macro_rules! clear_sender_wakers_common {
         if $seq & 15 != 0 {
             return;
         }
-        let limit = $self.tx_count.load(Ordering::Relaxed) as u64 + 200;
+        let limit = $self.tx_count.load(Ordering::Acquire) as u64 + 200;
         if $self.send_waker_rx_seq.load(Ordering::Acquire) + limit >= $seq {
             return;
         }
@@ -104,7 +104,7 @@ macro_rules! clear_recv_wakers_common {
         if $seq & 15 != 0 {
             return;
         }
-        let limit = $self.rx_count.load(Ordering::Relaxed) as u64 + 500;
+        let limit = $self.rx_count.load(Ordering::Acquire) as u64 + 500;
         if $self.recv_waker_rx_seq.load(Ordering::Acquire) + limit >= $seq {
             return;
         }

diff --git a/src/mpmc/bounded.rs b/src/mpmc/bounded.rs
@@ -735,7 +735,7 @@ mod tests {
                     None => break,
                 }
             }
-            assert_eq!(counter.as_ref().load(Ordering::Relaxed), round * (tx_count as i32));
+            assert_eq!(counter.as_ref().load(Ordering::Acquire), round * (tx_count as i32));
         });
     }
 
@@ -800,7 +800,7 @@ mod tests {
                     None => break,
                 }
             }
-            assert_eq!(counter.as_ref().load(Ordering::Relaxed), round as i32);
+            assert_eq!(counter.as_ref().load(Ordering::Acquire), round as i32);
         });
         for th in tx_ths {
             let _ = th.join();
@@ -878,7 +878,7 @@ mod tests {
         for th in rx_ths {
             let _ = th.join();
         }
-        assert_eq!(counter.as_ref().load(Ordering::Relaxed), round * (tx_count as i32));
+        assert_eq!(counter.as_ref().load(Ordering::Acquire), round * (tx_count as i32));
     }
 
     #[test]

diff --git a/src/mpsc/bounded.rs b/src/mpsc/bounded.rs
@@ -749,7 +749,7 @@ mod tests {
                     None => break,
                 }
             }
-            assert_eq!(counter.as_ref().load(Ordering::Relaxed), round * (tx_count as i32));
+            assert_eq!(counter.as_ref().load(Ordering::Acquire), round * (tx_count as i32));
         });
     }
 
@@ -787,7 +787,7 @@ mod tests {
                     Err(_) => break 'A,
                 }
             }
-            assert_eq!(counter.as_ref().load(Ordering::Relaxed), round * (tx_count as i32));
+            assert_eq!(counter.as_ref().load(Ordering::Acquire), round * (tx_count as i32));
         });
         for th in tx_ths {
             let _ = th.join();
@@ -860,7 +860,7 @@ mod tests {
         for th in rx_ths {
             let _ = th.join();
         }
-        assert_eq!(counter.as_ref().load(Ordering::Relaxed), round * (tx_count as i32));
+        assert_eq!(counter.as_ref().load(Ordering::Acquire), round * (tx_count as i32));
     }
 
     #[test]