Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
taiki-e committed Sep 4, 2019
1 parent 46a1a4f commit 5e8b798
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions tokio-timer/src/atomic.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,33 +15,33 @@ mod imp {
use std::sync::Mutex;

#[derive(Debug)]
pub(crate) struct AtomicU64 {
pub(crate) struct AtomicU64 {
inner: Mutex<u64>,
}

impl AtomicU64 {
pub(crate) fn new(val: u64) -> AtomicU64 {
pub(crate) fn new(val: u64) -> AtomicU64 {
AtomicU64 {
inner: Mutex::new(val),
}
}

pub(crate) fn load(&self, _: Ordering) -> u64 {
pub(crate) fn load(&self, _: Ordering) -> u64 {
*self.inner.lock().unwrap()
}

pub(crate) fn store(&self, val: u64, _: Ordering) {
pub(crate) fn store(&self, val: u64, _: Ordering) {
*self.inner.lock().unwrap() = val;
}

pub(crate) fn fetch_or(&self, val: u64, _: Ordering) -> u64 {
pub(crate) fn fetch_or(&self, val: u64, _: Ordering) -> u64 {
let mut lock = self.inner.lock().unwrap();
let prev = *lock;
*lock = prev | val;
prev
}

pub(crate) fn compare_and_swap(&self, old: u64, new: u64, _: Ordering) -> u64 {
pub(crate) fn compare_and_swap(&self, old: u64, new: u64, _: Ordering) -> u64 {
let mut lock = self.inner.lock().unwrap();
let prev = *lock;

Expand Down

0 comments on commit 5e8b798

Please sign in to comment.