]>
git.proxmox.com Git - ceph.git/blob - ceph/src/boost/libs/fiber/src/barrier.cpp
2 // Copyright Oliver Kowalke 2013.
3 // Distributed under the Boost Software License, Version 1.0.
4 // (See accompanying file LICENSE_1_0.txt or copy at
5 // http://www.boost.org/LICENSE_1_0.txt)
7 #include "boost/fiber/barrier.hpp"
10 #include <system_error>
12 #include "boost/fiber/exceptions.hpp"
14 #ifdef BOOST_HAS_ABI_HEADERS
15 # include BOOST_ABI_PREFIX
21 barrier::barrier( std::size_t initial
) :
23 current_
{ initial_
} {
24 if ( BOOST_UNLIKELY( 0 == initial
) ) {
25 throw fiber_error
{ std::make_error_code( std::errc::invalid_argument
),
26 "boost fiber: zero initial barrier count" };
32 std::unique_lock
< mutex
> lk
{ mtx_
};
33 const std::size_t cycle
= cycle_
;
34 if ( 0 == --current_
) {
37 lk
.unlock(); // no pessimization
42 cond_
.wait( lk
, [&]{ return cycle
!= cycle_
; });
48 #ifdef BOOST_HAS_ABI_HEADERS
49 # include BOOST_ABI_SUFFIX