FM / fiber

/usr/include/boost/fiber

Name	Size	Mode	Actions
algo/	-	0755	rm
cuda/	-	0755	rm
detail/	-	0755	rm
future/	-	0755	rm
hip/	-	0755	rm
numa/	-	0755	rm
all.hpp	1381	0644	edit dl rm
barrier.hpp	1022	0644	edit dl rm
buffered_channel.hpp	25579	0644	edit dl rm
channel_op_status.hpp	678	0644	edit dl rm
condition_variable.hpp	8712	0644	edit dl rm
context.hpp	15927	0644	edit dl rm
exceptions.hpp	3352	0644	edit dl rm
fiber.hpp	4549	0644	edit dl rm
fixedsize_stack.hpp	782	0644	edit dl rm
fss.hpp	2593	0644	edit dl rm
future.hpp	384	0644	edit dl rm
mutex.hpp	1373	0644	edit dl rm
operations.hpp	3034	0644	edit dl rm
policy.hpp	812	0644	edit dl rm
pooled_fixedsize_stack.hpp	721	0644	edit dl rm
properties.hpp	2077	0644	edit dl rm
protected_fixedsize_stack.hpp	739	0644	edit dl rm
recursive_mutex.hpp	1648	0644	edit dl rm
recursive_timed_mutex.hpp	2380	0644	edit dl rm
scheduler.hpp	5525	0644	edit dl rm
segmented_stack.hpp	817	0644	edit dl rm
timed_mutex.hpp	2105	0644	edit dl rm
type.hpp	2332	0644	edit dl rm
unbuffered_channel.hpp	26786	0644	edit dl rm

Edit: /usr/include/boost/fiber/timed_mutex.hpp (2105B)

#ifndef BOOST_FIBERS_TIMED_MUTEX_H
#define BOOST_FIBERS_TIMED_MUTEX_H

#include <chrono>

#include <boost/assert.hpp>
#include <boost/config.hpp>

#include <boost/fiber/context.hpp>
#include <boost/fiber/detail/config.hpp>
#include <boost/fiber/detail/convert.hpp>
#include <boost/fiber/detail/spinlock.hpp>

#ifdef BOOST_HAS_ABI_HEADERS
#  include BOOST_ABI_PREFIX
#endif

#ifdef _MSC_VER
# pragma warning(push)
# pragma warning(disable:4251)
#endif

namespace boost {
namespace fibers {

class condition_variable;

class BOOST_FIBERS_DECL timed_mutex {
private:
    friend class condition_variable;

using wait_queue_type = context::wait_queue_t;

detail::spinlock            wait_queue_splk_{};
    wait_queue_type             wait_queue_{};
    context                 *   owner_{ nullptr };

bool try_lock_until_( std::chrono::steady_clock::time_point const& timeout_time) noexcept;

public:
    timed_mutex() = default;

~timed_mutex() {
        BOOST_ASSERT( nullptr == owner_);
        BOOST_ASSERT( wait_queue_.empty() );
    }

timed_mutex( timed_mutex const&) = delete;
    timed_mutex & operator=( timed_mutex const&) = delete;

void lock();

bool try_lock();

template< typename Clock, typename Duration >
    bool try_lock_until( std::chrono::time_point< Clock, Duration > const& timeout_time_) {
        std::chrono::steady_clock::time_point timeout_time = detail::convert( timeout_time_);
        return try_lock_until_( timeout_time);
    }

template< typename Rep, typename Period >
    bool try_lock_for( std::chrono::duration< Rep, Period > const& timeout_duration) {
        return try_lock_until_( std::chrono::steady_clock::now() + timeout_duration);
    }

void unlock();
};

}}

#ifdef _MSC_VER
# pragma warning(pop)
#endif

#ifdef BOOST_HAS_ABI_HEADERS
#  include BOOST_ABI_SUFFIX
#endif

#endif // BOOST_FIBERS_TIMED_MUTEX_H

// Copyright Oliver Kowalke 2013. // 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) #ifndef BOOST_FIBERS_TIMED_MUTEX_H #define BOOST_FIBERS_TIMED_MUTEX_H #include #include #include #include #include #include #include #ifdef BOOST_HAS_ABI_HEADERS # include BOOST_ABI_PREFIX #endif #ifdef _MSC_VER # pragma warning(push) # pragma warning(disable:4251) #endif namespace boost { namespace fibers { class condition_variable; class BOOST_FIBERS_DECL timed_mutex { private: friend class condition_variable; using wait_queue_type = context::wait_queue_t; detail::spinlock wait_queue_splk_{}; wait_queue_type wait_queue_{}; context * owner_{ nullptr }; bool try_lock_until_( std::chrono::steady_clock::time_point const& timeout_time) noexcept; public: timed_mutex() = default; ~timed_mutex() { BOOST_ASSERT( nullptr == owner_); BOOST_ASSERT( wait_queue_.empty() ); } timed_mutex( timed_mutex const&) = delete; timed_mutex & operator=( timed_mutex const&) = delete; void lock(); bool try_lock(); template< typename Clock, typename Duration > bool try_lock_until( std::chrono::time_point< Clock, Duration > const& timeout_time_) { std::chrono::steady_clock::time_point timeout_time = detail::convert( timeout_time_); return try_lock_until_( timeout_time); } template< typename Rep, typename Period > bool try_lock_for( std::chrono::duration< Rep, Period > const& timeout_duration) { return try_lock_until_( std::chrono::steady_clock::now() + timeout_duration); } void unlock(); }; }} #ifdef _MSC_VER # pragma warning(pop) #endif #ifdef BOOST_HAS_ABI_HEADERS # include BOOST_ABI_SUFFIX #endif #endif // BOOST_FIBERS_TIMED_MUTEX_H