mirror/Easytier
1
0
Fork 0
mirror of https://github.com/EasyTier/EasyTier.git synced 2026-09-03 01:25:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Code format

Browse Source
This commit is contained in:
fanyang
2026-06-25 00:48:40 +08:00
parent bf8cff60bf
commit 2624b2740e
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
easytier/benches/counter_contention.rs
+10 -6
View File
@@ -83,9 +83,11 @@ impl Default for CasSaturating {
impl Counter for CasSaturating { impl Counter for CasSaturating {
#[inline(always)] #[inline(always)]
fn add(&self, delta: u64) { fn add(&self, delta: u64) {
let _ = self.0.fetch_update(Ordering::Relaxed, Ordering::Relaxed, |c| { let _ = self
Some(c.saturating_add(delta)) .0
}); .fetch_update(Ordering::Relaxed, Ordering::Relaxed, |c| {
Some(c.saturating_add(delta))
});
} }
#[inline(always)] #[inline(always)]
fn get(&self) -> u64 { fn get(&self) -> u64 {
@@ -257,9 +259,11 @@ impl Counter for BaselineHandle {
#[inline(always)] #[inline(always)]
fn add(&self, delta: u64) { fn add(&self, delta: u64) {
if self.use_cas { if self.use_cas {
let _ = self.counter.fetch_update(Ordering::Relaxed, Ordering::Relaxed, |c| { let _ = self
Some(c.saturating_add(delta)) .counter
}); .fetch_update(Ordering::Relaxed, Ordering::Relaxed, |c| {
Some(c.saturating_add(delta))
});
} else { } else {
self.counter.fetch_add(delta, Ordering::Relaxed); self.counter.fetch_add(delta, Ordering::Relaxed);
} }