Chris@16: #ifndef BOOST_THREAD_PTHREAD_ONCE_ATOMIC_HPP
Chris@16: #define BOOST_THREAD_PTHREAD_ONCE_ATOMIC_HPP
Chris@16: 
Chris@16: //  once.hpp
Chris@16: //
Chris@16: //  (C) Copyright 2013 Andrey Semashev
Chris@16: //  (C) Copyright 2013 Vicente J. Botet Escriba
Chris@16: //
Chris@16: //  Distributed under the Boost Software License, Version 1.0. (See
Chris@16: //  accompanying file LICENSE_1_0.txt or copy at
Chris@16: //  http://www.boost.org/LICENSE_1_0.txt)
Chris@16: 
Chris@16: #include <boost/thread/detail/config.hpp>
Chris@16: 
Chris@16: #include <boost/cstdint.hpp>
Chris@16: #include <boost/thread/detail/move.hpp>
Chris@16: #include <boost/thread/detail/invoke.hpp>
Chris@101: #include <boost/core/no_exceptions_support.hpp>
Chris@16: #include <boost/bind.hpp>
Chris@16: #include <boost/atomic.hpp>
Chris@16: 
Chris@16: #include <boost/config/abi_prefix.hpp>
Chris@16: 
Chris@16: namespace boost
Chris@16: {
Chris@16: 
Chris@16:   struct once_flag;
Chris@16: 
Chris@16:   namespace thread_detail
Chris@16:   {
Chris@16: 
Chris@16: #if BOOST_ATOMIC_INT_LOCK_FREE == 2
Chris@16:     typedef unsigned int atomic_int_type;
Chris@16: #elif BOOST_ATOMIC_SHORT_LOCK_FREE == 2
Chris@16:     typedef unsigned short atomic_int_type;
Chris@16: #elif BOOST_ATOMIC_CHAR_LOCK_FREE == 2
Chris@16:     typedef unsigned char atomic_int_type;
Chris@16: #elif BOOST_ATOMIC_LONG_LOCK_FREE == 2
Chris@16:     typedef unsigned long atomic_int_type;
Chris@16: #elif defined(BOOST_HAS_LONG_LONG) && BOOST_ATOMIC_LLONG_LOCK_FREE == 2
Chris@16:     typedef ulong_long_type atomic_int_type;
Chris@16: #else
Chris@16:     // All tested integer types are not atomic, the spinlock pool will be used
Chris@16:     typedef unsigned int atomic_int_type;
Chris@16: #endif
Chris@16: 
Chris@16:     typedef boost::atomic<atomic_int_type> atomic_type;
Chris@16: 
Chris@16:     BOOST_THREAD_DECL bool enter_once_region(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:     BOOST_THREAD_DECL void commit_once_region(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:     BOOST_THREAD_DECL void rollback_once_region(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:     inline atomic_type& get_atomic_storage(once_flag& flag)  BOOST_NOEXCEPT;
Chris@16:   }
Chris@16: 
Chris@16: #ifdef BOOST_THREAD_PROVIDES_ONCE_CXX11
Chris@16: 
Chris@16:   struct once_flag
Chris@16:   {
Chris@16:     BOOST_THREAD_NO_COPYABLE(once_flag)
Chris@16:     BOOST_CONSTEXPR once_flag() BOOST_NOEXCEPT : storage(0)
Chris@16:     {
Chris@16:     }
Chris@16: 
Chris@16:   private:
Chris@16:     thread_detail::atomic_type storage;
Chris@16: 
Chris@16:     friend BOOST_THREAD_DECL bool thread_detail::enter_once_region(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:     friend BOOST_THREAD_DECL void thread_detail::commit_once_region(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:     friend BOOST_THREAD_DECL void thread_detail::rollback_once_region(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:     friend thread_detail::atomic_type& thread_detail::get_atomic_storage(once_flag& flag) BOOST_NOEXCEPT;
Chris@16:   };
Chris@16: 
Chris@16: #define BOOST_ONCE_INIT boost::once_flag()
Chris@16: 
Chris@16:   namespace thread_detail
Chris@16:   {
Chris@16:     inline atomic_type& get_atomic_storage(once_flag& flag) BOOST_NOEXCEPT
Chris@16:     {
Chris@16:       //return reinterpret_cast< atomic_type& >(flag.storage);
Chris@16:       return flag.storage;
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16: #else // BOOST_THREAD_PROVIDES_ONCE_CXX11
Chris@16:   struct once_flag
Chris@16:   {
Chris@16:     // The thread_detail::atomic_int_type storage is marked
Chris@16:     // with this attribute in order to let the compiler know that it will alias this member
Chris@16:     // and silence compilation warnings.
Chris@16:     BOOST_THREAD_ATTRIBUTE_MAY_ALIAS thread_detail::atomic_int_type storage;
Chris@16:   };
Chris@16: 
Chris@16:   #define BOOST_ONCE_INIT {0}
Chris@16: 
Chris@16:   namespace thread_detail
Chris@16:   {
Chris@16:     inline atomic_type& get_atomic_storage(once_flag& flag) BOOST_NOEXCEPT
Chris@16:     {
Chris@16:       return reinterpret_cast< atomic_type& >(flag.storage);
Chris@16:     }
Chris@16: 
Chris@16:   }
Chris@16: 
Chris@16: #endif // BOOST_THREAD_PROVIDES_ONCE_CXX11
Chris@16: 
Chris@16: #if defined BOOST_THREAD_PROVIDES_INVOKE
Chris@16: #define BOOST_THREAD_INVOKE_RET_VOID detail::invoke
Chris@16: #define BOOST_THREAD_INVOKE_RET_VOID_CALL
Chris@16: #elif defined BOOST_THREAD_PROVIDES_INVOKE_RET
Chris@16: #define BOOST_THREAD_INVOKE_RET_VOID detail::invoke<void>
Chris@16: #define BOOST_THREAD_INVOKE_RET_VOID_CALL
Chris@16: #else
Chris@16: #define BOOST_THREAD_INVOKE_RET_VOID boost::bind
Chris@16: #define BOOST_THREAD_INVOKE_RET_VOID_CALL ()
Chris@16: #endif
Chris@16: 
Chris@16: 
Chris@101: #if !defined(BOOST_NO_CXX11_VARIADIC_TEMPLATES) && !defined(BOOST_NO_CXX11_RVALUE_REFERENCES)
Chris@16: 
Chris@16:   template<typename Function, class ...ArgTypes>
Chris@16:   inline void call_once(once_flag& flag, BOOST_THREAD_RV_REF(Function) f, BOOST_THREAD_RV_REF(ArgTypes)... args)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(
Chris@16:                         thread_detail::decay_copy(boost::forward<Function>(f)),
Chris@16:                         thread_detail::decay_copy(boost::forward<ArgTypes>(args))...
Chris@16:         ) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: #else
Chris@16:   template<typename Function>
Chris@16:   inline void call_once(once_flag& flag, Function f)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         f();
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   template<typename Function, typename T1>
Chris@16:   inline void call_once(once_flag& flag, Function f, T1 p1)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(f, p1) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   template<typename Function, typename T1, typename T2>
Chris@16:   inline void call_once(once_flag& flag, Function f, T1 p1, T2 p2)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(f, p1, p2) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   template<typename Function, typename T1, typename T2, typename T3>
Chris@16:   inline void call_once(once_flag& flag, Function f, T1 p1, T2 p2, T3 p3)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(f, p1, p2, p3) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   template<typename Function>
Chris@16:   inline void call_once(once_flag& flag, BOOST_THREAD_RV_REF(Function) f)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         f();
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16:   template<typename Function, typename T1>
Chris@16:   inline void call_once(once_flag& flag, BOOST_THREAD_RV_REF(Function) f, BOOST_THREAD_RV_REF(T1) p1)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(
Chris@16:             thread_detail::decay_copy(boost::forward<Function>(f)),
Chris@16:             thread_detail::decay_copy(boost::forward<T1>(p1))
Chris@16:         ) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16:   template<typename Function, typename T1, typename T2>
Chris@16:   inline void call_once(once_flag& flag, BOOST_THREAD_RV_REF(Function) f, BOOST_THREAD_RV_REF(T1) p1, BOOST_THREAD_RV_REF(T2) p2)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(
Chris@16:             thread_detail::decay_copy(boost::forward<Function>(f)),
Chris@16:             thread_detail::decay_copy(boost::forward<T1>(p1)),
Chris@16:             thread_detail::decay_copy(boost::forward<T1>(p2))
Chris@16:         ) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16:   template<typename Function, typename T1, typename T2, typename T3>
Chris@16:   inline void call_once(once_flag& flag, BOOST_THREAD_RV_REF(Function) f, BOOST_THREAD_RV_REF(T1) p1, BOOST_THREAD_RV_REF(T2) p2, BOOST_THREAD_RV_REF(T3) p3)
Chris@16:   {
Chris@16:     if (thread_detail::enter_once_region(flag))
Chris@16:     {
Chris@16:       BOOST_TRY
Chris@16:       {
Chris@16:         BOOST_THREAD_INVOKE_RET_VOID(
Chris@16:             thread_detail::decay_copy(boost::forward<Function>(f)),
Chris@16:             thread_detail::decay_copy(boost::forward<T1>(p1)),
Chris@16:             thread_detail::decay_copy(boost::forward<T1>(p2)),
Chris@16:             thread_detail::decay_copy(boost::forward<T1>(p3))
Chris@16:         ) BOOST_THREAD_INVOKE_RET_VOID_CALL;
Chris@16: 
Chris@16:       }
Chris@16:       BOOST_CATCH (...)
Chris@16:       {
Chris@16:         thread_detail::rollback_once_region(flag);
Chris@16:         BOOST_RETHROW
Chris@16:       }
Chris@16:       BOOST_CATCH_END
Chris@16:       thread_detail::commit_once_region(flag);
Chris@16:     }
Chris@16:   }
Chris@16: 
Chris@16: 
Chris@16: 
Chris@16: #endif
Chris@16: }
Chris@16: 
Chris@16: #include <boost/config/abi_suffix.hpp>
Chris@16: 
Chris@16: #endif
Chris@16: