+++ /dev/null
-# - Find atomic_ops
-# Find the native ATOMIC_OPS headers and libraries.
-#
-# ATOMIC_OPS_INCLUDE_DIRS - where to find atomic_ops.h, etc.
-# ATOMIC_OPS_LIBRARIES - List of libraries when using atomic_ops.
-# ATOMIC_OPS_FOUND - True if atomic_ops found.
-
-# Look for the header file.
-FIND_PATH(ATOMIC_OPS_INCLUDE_DIR NAMES atomic_ops.h)
-
-# Look for the library.
-FIND_LIBRARY(ATOMIC_OPS_LIBRARY NAMES atomic_ops)
-
-# handle the QUIETLY and REQUIRED arguments and set ATOMIC_OPS_FOUND to TRUE if
-# all listed variables are TRUE
-INCLUDE(FindPackageHandleStandardArgs)
-FIND_PACKAGE_HANDLE_STANDARD_ARGS(atomic_ops DEFAULT_MSG ATOMIC_OPS_LIBRARY ATOMIC_OPS_INCLUDE_DIR)
-
-# Copy the results to the output variables.
-IF(ATOMIC_OPS_FOUND)
- SET(ATOMIC_OPS_LIBRARIES ${ATOMIC_OPS_LIBRARY})
- SET(ATOMIC_OPS_INCLUDE_DIRS ${ATOMIC_OPS_INCLUDE_DIR})
-ELSE(ATOMIC_OPS_FOUND)
- SET(ATOMIC_OPS_LIBRARIES)
- SET(ATOMIC_OPS_INCLUDE_DIRS)
-ENDIF(ATOMIC_OPS_FOUND)
-
-MARK_AS_ADVANCED(ATOMIC_OPS_INCLUDE_DIR ATOMIC_OPS_LIBRARY)
+++ /dev/null
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2004-2011 New Dream Network
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation. See file COPYING.
- *
- * @author Sage Weil <sage@newdream.net>
- */
-
-#ifndef CEPH_ATOMIC_H
-#define CEPH_ATOMIC_H
-
-#ifdef __CEPH__
-# include "acconfig.h"
-#endif
-
-#include <stdlib.h>
-#include "include/Spinlock.h"
-
-namespace ceph {
- template <class T>
- class atomic_spinlock_t {
- mutable ceph_spinlock_t lock;
- T val;
- public:
- atomic_spinlock_t(T i=0)
- : val(i) {
- ceph_spin_init(&lock);
- }
- ~atomic_spinlock_t() {
- ceph_spin_destroy(&lock);
- }
- void set(T v) {
- ceph_spin_lock(&lock);
- val = v;
- ceph_spin_unlock(&lock);
- }
- T inc() {
- ceph_spin_lock(&lock);
- T r = ++val;
- ceph_spin_unlock(&lock);
- return r;
- }
- T dec() {
- ceph_spin_lock(&lock);
- T r = --val;
- ceph_spin_unlock(&lock);
- return r;
- }
- void add(T d) {
- ceph_spin_lock(&lock);
- val += d;
- ceph_spin_unlock(&lock);
- }
- void sub(T d) {
- ceph_spin_lock(&lock);
- val -= d;
- ceph_spin_unlock(&lock);
- }
- T read() const {
- T ret;
- ceph_spin_lock(&lock);
- ret = val;
- ceph_spin_unlock(&lock);
- return ret;
- }
- bool compare_and_swap(T o, T n) {
- bool success = false;
- ceph_spin_lock(&lock);
- if (val == o) {
- success = true;
- val = n;
- }
- ceph_spin_unlock(&lock);
- return success;
- }
-
- private:
- // forbid copying
- atomic_spinlock_t(const atomic_spinlock_t<T> &other);
- atomic_spinlock_t &operator=(const atomic_spinlock_t<T> &rhs);
- };
-}
-
-#ifndef NO_ATOMIC_OPS
-
-// libatomic_ops implementation
-#define AO_REQUIRE_CAS
-#include <atomic_ops.h>
-
-// reinclude our assert to clobber the system one
-#include "include/assert.h"
-
-namespace ceph {
- class atomic_t {
- AO_t val;
- public:
- atomic_t(AO_t i=0) : val(i) {}
- void set(AO_t v) {
- AO_store(&val, v);
- }
- AO_t inc() {
- return AO_fetch_and_add1(&val) + 1;
- }
- AO_t dec() {
- return AO_fetch_and_sub1_write(&val) - 1;
- }
- AO_t add(AO_t add_me) {
- return AO_fetch_and_add(&val, add_me) + add_me;
- }
- AO_t sub(AO_t sub_me) {
- AO_t negsub = 0 - sub_me;
- return AO_fetch_and_add_write(&val, negsub) + negsub;
- }
- AO_t read() const {
- // cast away const on the pointer. this is only needed to build
- // on lenny, but not newer debians, so the atomic_ops.h got fixed
- // at some point. this hack can go away someday...
- return AO_load_full((AO_t *)&val);
- }
- bool compare_and_swap(AO_t o, AO_t n) {
- return AO_compare_and_swap(&val, o, n);
- }
-
- private:
- // forbid copying
- atomic_t(const atomic_t &other);
- atomic_t &operator=(const atomic_t &rhs);
- };
-
-#if SIZEOF_AO_T == 8
- typedef atomic_t atomic64_t;
-#else
- typedef atomic_spinlock_t<unsigned long long> atomic64_t;
-#endif
-
-}
-
-#else
-/*
- * crappy slow implementation that uses a pthreads spinlock.
- */
-#include "include/Spinlock.h"
-
-namespace ceph {
- typedef atomic_spinlock_t<unsigned> atomic_t;
- typedef atomic_spinlock_t<unsigned long long> atomic64_t;
-}
-
-#endif
-#endif
projects / ceph.git / commitdiff