import quincy beta 17.1.0

[ceph.git] / ceph / src / boost / boost / asio / detail / atomic_count.hpp

diff --git a/ceph/src/boost/boost/asio/detail/atomic_count.hpp b/ceph/src/boost/boost/asio/detail/atomic_count.hpp
index d12443dd85e12766ddbd4419d8a74fc2956a051e..bd6643b5881c7e1724a5fb8ec86ba0b2e2b99b7f 100644 (file)
--- a/ceph/src/boost/boost/asio/detail/atomic_count.hpp
+++ b/ceph/src/boost/boost/asio/detail/atomic_count.hpp
@@ -32,12 +32,31 @@ namespace detail {
 #if !defined(BOOST_ASIO_HAS_THREADS)
 typedef long atomic_count;
 inline void increment(atomic_count& a, long b) { a += b; }
+inline void ref_count_up(atomic_count& a) { ++a; }
+inline bool ref_count_down(atomic_count& a) { return --a == 0; }
 #elif defined(BOOST_ASIO_HAS_STD_ATOMIC)
 typedef std::atomic<long> atomic_count;
 inline void increment(atomic_count& a, long b) { a += b; }
+
+inline void ref_count_up(atomic_count& a)
+{
+  a.fetch_add(1, std::memory_order_relaxed);
+}
+
+inline bool ref_count_down(atomic_count& a)
+{
+  if (a.fetch_sub(1, std::memory_order_release) == 1)
+  {
+    std::atomic_thread_fence(std::memory_order_acquire);
+    return true;
+  }
+  return false;
+}
 #else // defined(BOOST_ASIO_HAS_STD_ATOMIC)
 typedef boost::detail::atomic_count atomic_count;
 inline void increment(atomic_count& a, long b) { while (b > 0) ++a, --b; }
+inline void ref_count_up(atomic_count& a) { ++a; }
+inline bool ref_count_down(atomic_count& a) { return --a == 0; }
 #endif // defined(BOOST_ASIO_HAS_STD_ATOMIC)
 
 } // namespace detail