diff --git a/src/ring_buffer/mod.rs b/src/ring_buffer/mod.rs index 37471944ada87a142f1e7d17aaaf53bae2c3a442..3f53646d2ad1173f93c1d8cf236cdb1bbcca0a83 100644 --- a/src/ring_buffer/mod.rs +++ b/src/ring_buffer/mod.rs @@ -29,10 +29,6 @@ impl AtomicUsize { unsafe { &mut *self.v.get() } } - pub fn load_acquire(&self) -> usize { - unsafe { intrinsics::atomic_load_acq(self.v.get()) } - } - pub fn load_relaxed(&self) -> usize { unsafe { intrinsics::atomic_load_relaxed(self.v.get()) } } diff --git a/src/ring_buffer/spsc.rs b/src/ring_buffer/spsc.rs index 0c384977615b34796b2c0653f7f8f2ffa6fd79cc..4c93f429dae84c820f7277ad90115a1f092452ff 100644 --- a/src/ring_buffer/spsc.rs +++ b/src/ring_buffer/spsc.rs @@ -43,7 +43,7 @@ where let buffer: &[T] = unsafe { rb.buffer.as_ref() }; let tail = rb.tail.load_relaxed(); - let head = rb.head.load_acquire(); + let head = rb.head.load_relaxed(); if head != tail { let item = unsafe { ptr::read(buffer.get_unchecked(head)) }; rb.head.store_release((head + 1) % n); @@ -85,7 +85,7 @@ where let buffer: &mut [T] = unsafe { rb.buffer.as_mut() }; let head = rb.head.load_relaxed(); - let tail = rb.tail.load_acquire(); + let tail = rb.tail.load_relaxed(); let next_tail = (tail + 1) % n; if next_tail != head { // NOTE(ptr::write) the memory slot that we are about to write to is uninitialized. We