123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286 |
- #ifndef BOOST_ATOMIC_DETAIL_CAS128STRONG_HPP
- #define BOOST_ATOMIC_DETAIL_CAS128STRONG_HPP
- // Distributed under the Boost Software License, Version 1.0.
- // See accompanying file LICENSE_1_0.txt or copy at
- // http://www.boost.org/LICENSE_1_0.txt)
- //
- // Copyright (c) 2011 Helge Bahmann
- // Copyright (c) 2013 Tim Blechmann, Andrey Semashev
- // Build 128-bit atomic operation on integers/UDTs from platform_cmpxchg128_strong
- // primitive. It is assumed that 128-bit loads/stores are not
- // atomic, so they are implemented through platform_load128/platform_store128.
- #include <string.h>
- #include <cstddef>
- #include <boost/cstdint.hpp>
- #include <boost/memory_order.hpp>
- #include <boost/atomic/detail/config.hpp>
- #include <boost/atomic/detail/base.hpp>
- #ifdef BOOST_HAS_PRAGMA_ONCE
- #pragma once
- #endif
- namespace boost {
- namespace atomics {
- namespace detail {
- /* integral types */
- template<typename T, bool Sign>
- class base_atomic<T, int, 16, Sign>
- {
- private:
- typedef base_atomic this_type;
- typedef T value_type;
- typedef T difference_type;
- protected:
- typedef value_type value_arg_type;
- public:
- BOOST_DEFAULTED_FUNCTION(base_atomic(void), {})
- BOOST_CONSTEXPR explicit base_atomic(value_type v) BOOST_NOEXCEPT : v_(v) {}
- void
- store(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- platform_fence_before_store(order);
- platform_store128(v, &v_);
- platform_fence_after_store(order);
- }
- value_type
- load(memory_order order = memory_order_seq_cst) const volatile BOOST_NOEXCEPT
- {
- value_type v = platform_load128(&v_);
- platform_fence_after_load(order);
- return v;
- }
- value_type
- exchange(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, v, order, memory_order_relaxed));
- return original;
- }
- bool
- compare_exchange_weak(
- value_type & expected,
- value_type desired,
- memory_order success_order,
- memory_order failure_order) volatile BOOST_NOEXCEPT
- {
- return compare_exchange_strong(expected, desired, success_order, failure_order);
- }
- bool
- compare_exchange_strong(
- value_type & expected,
- value_type desired,
- memory_order success_order,
- memory_order failure_order) volatile BOOST_NOEXCEPT
- {
- platform_fence_before(success_order);
- bool success = platform_cmpxchg128_strong(expected, desired, &v_);
- if (success) {
- platform_fence_after(success_order);
- } else {
- platform_fence_after(failure_order);
- }
- return success;
- }
- value_type
- fetch_add(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, original + v, order, memory_order_relaxed));
- return original;
- }
- value_type
- fetch_sub(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, original - v, order, memory_order_relaxed));
- return original;
- }
- value_type
- fetch_and(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, original & v, order, memory_order_relaxed));
- return original;
- }
- value_type
- fetch_or(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, original | v, order, memory_order_relaxed));
- return original;
- }
- value_type
- fetch_xor(value_type v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, original ^ v, order, memory_order_relaxed));
- return original;
- }
- bool
- is_lock_free(void) const volatile BOOST_NOEXCEPT
- {
- return true;
- }
- BOOST_ATOMIC_DECLARE_INTEGRAL_OPERATORS
- BOOST_DELETED_FUNCTION(base_atomic(base_atomic const&))
- BOOST_DELETED_FUNCTION(base_atomic& operator=(base_atomic const&))
- private:
- value_type v_;
- };
- /* generic types */
- #if defined(BOOST_HAS_INT128)
- typedef boost::uint128_type storage128_type;
- #else // defined(BOOST_HAS_INT128)
- struct BOOST_ALIGNMENT(16) storage128_type
- {
- uint64_t data[2];
- };
- inline bool operator== (storage128_type const& left, storage128_type const& right)
- {
- return left.data[0] == right.data[0] && left.data[1] == right.data[1];
- }
- inline bool operator!= (storage128_type const& left, storage128_type const& right)
- {
- return !(left == right);
- }
- #endif // defined(BOOST_HAS_INT128)
- template<typename T, bool Sign>
- class base_atomic<T, void, 16, Sign>
- {
- private:
- typedef base_atomic this_type;
- typedef T value_type;
- typedef storage128_type storage_type;
- protected:
- typedef value_type const& value_arg_type;
- public:
- BOOST_DEFAULTED_FUNCTION(base_atomic(void), {})
- explicit base_atomic(value_type const& v) BOOST_NOEXCEPT : v_(0)
- {
- memcpy(&v_, &v, sizeof(value_type));
- }
- void
- store(value_type const& value, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- storage_type value_s = 0;
- memcpy(&value_s, &value, sizeof(value_type));
- platform_fence_before_store(order);
- platform_store128(value_s, &v_);
- platform_fence_after_store(order);
- }
- value_type
- load(memory_order order = memory_order_seq_cst) const volatile BOOST_NOEXCEPT
- {
- storage_type value_s = platform_load128(&v_);
- platform_fence_after_load(order);
- value_type value;
- memcpy(&value, &value_s, sizeof(value_type));
- return value;
- }
- value_type
- exchange(value_type const& v, memory_order order = memory_order_seq_cst) volatile BOOST_NOEXCEPT
- {
- value_type original = load(memory_order_relaxed);
- do {
- } while (!compare_exchange_weak(original, v, order, memory_order_relaxed));
- return original;
- }
- bool
- compare_exchange_weak(
- value_type & expected,
- value_type const& desired,
- memory_order success_order,
- memory_order failure_order) volatile BOOST_NOEXCEPT
- {
- return compare_exchange_strong(expected, desired, success_order, failure_order);
- }
- bool
- compare_exchange_strong(
- value_type & expected,
- value_type const& desired,
- memory_order success_order,
- memory_order failure_order) volatile BOOST_NOEXCEPT
- {
- storage_type expected_s = 0, desired_s = 0;
- memcpy(&expected_s, &expected, sizeof(value_type));
- memcpy(&desired_s, &desired, sizeof(value_type));
- platform_fence_before(success_order);
- bool success = platform_cmpxchg128_strong(expected_s, desired_s, &v_);
- if (success) {
- platform_fence_after(success_order);
- } else {
- platform_fence_after(failure_order);
- memcpy(&expected, &expected_s, sizeof(value_type));
- }
- return success;
- }
- bool
- is_lock_free(void) const volatile BOOST_NOEXCEPT
- {
- return true;
- }
- BOOST_ATOMIC_DECLARE_BASE_OPERATORS
- BOOST_DELETED_FUNCTION(base_atomic(base_atomic const&))
- BOOST_DELETED_FUNCTION(base_atomic& operator=(base_atomic const&))
- private:
- storage_type v_;
- };
- }
- }
- }
- #endif
|