FM / detail

/usr/include/boost/fiber/detail

Name	Size	Mode	Actions
config.hpp	1828	0644	edit dl rm
context_spinlock_queue.hpp	2677	0644	edit dl rm
context_spmc_queue.hpp	6848	0644	edit dl rm
convert.hpp	1039	0644	edit dl rm
cpu_relax.hpp	2554	0644	edit dl rm
data.hpp	1132	0644	edit dl rm
decay_copy.hpp	733	0644	edit dl rm
disable_overload.hpp	802	0644	edit dl rm
exchange.hpp	734	0644	edit dl rm
fss.hpp	1393	0644	edit dl rm
futex.hpp	1556	0644	edit dl rm
is_all_same.hpp	1022	0644	edit dl rm
rtm.hpp	1791	0644	edit dl rm
spinlock.hpp	2168	0644	edit dl rm
spinlock_rtm.hpp	4845	0644	edit dl rm
spinlock_status.hpp	457	0644	edit dl rm
spinlock_ttas.hpp	5268	0644	edit dl rm
spinlock_ttas_adaptive.hpp	5944	0644	edit dl rm
spinlock_ttas_adaptive_futex.hpp	6622	0644	edit dl rm
spinlock_ttas_futex.hpp	5879	0644	edit dl rm
thread_barrier.hpp	1540	0644	edit dl rm

Edit: /usr/include/boost/fiber/detail/futex.hpp (1556B)

#ifndef BOOST_FIBERS_DETAIL_FUTEX_H
#define BOOST_FIBERS_DETAIL_FUTEX_H

#include <boost/config.hpp>
#include <boost/predef.h>

#include <boost/fiber/detail/config.hpp>

#if BOOST_OS_LINUX
extern "C" {
#include <linux/futex.h>
#include <sys/syscall.h>
}
#elif BOOST_OS_WINDOWS
#include <windows.h>
#endif

namespace boost {
namespace fibers {
namespace detail {

#if BOOST_OS_LINUX
BOOST_FORCEINLINE
int sys_futex( void * addr, std::int32_t op, std::int32_t x) {
    return ::syscall( SYS_futex, addr, op, x, nullptr, nullptr, 0);
}

BOOST_FORCEINLINE
int futex_wake( std::atomic< std::int32_t > * addr) {
    return 0 <= sys_futex( static_cast< void * >( addr), FUTEX_WAKE_PRIVATE, 1) ? 0 : -1;
}

BOOST_FORCEINLINE
int futex_wait( std::atomic< std::int32_t > * addr, std::int32_t x) {
    return 0 <= sys_futex( static_cast< void * >( addr), FUTEX_WAIT_PRIVATE, x) ? 0 : -1;
}
#elif BOOST_OS_WINDOWS
BOOST_FORCEINLINE
int futex_wake( std::atomic< std::int32_t > * addr) {
    ::WakeByAddressSingle( static_cast< void * >( addr) );
    return 0;
}

BOOST_FORCEINLINE
int futex_wait( std::atomic< std::int32_t > * addr, std::int32_t x) {
    ::WaitOnAddress( static_cast< volatile void * >( addr), & x, sizeof( x), INFINITE);
    return 0;
}
#else
# warn "no futex support on this platform"
#endif

}}}

#endif // BOOST_FIBERS_DETAIL_FUTEX_H

// Copyright Oliver Kowalke 2016. // 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_DETAIL_FUTEX_H #define BOOST_FIBERS_DETAIL_FUTEX_H #include #include #include #if BOOST_OS_LINUX extern "C" { #include #include } #elif BOOST_OS_WINDOWS #include #endif namespace boost { namespace fibers { namespace detail { #if BOOST_OS_LINUX BOOST_FORCEINLINE int sys_futex( void * addr, std::int32_t op, std::int32_t x) { return ::syscall( SYS_futex, addr, op, x, nullptr, nullptr, 0); } BOOST_FORCEINLINE int futex_wake( std::atomic< std::int32_t > * addr) { return 0 <= sys_futex( static_cast< void * >( addr), FUTEX_WAKE_PRIVATE, 1) ? 0 : -1; } BOOST_FORCEINLINE int futex_wait( std::atomic< std::int32_t > * addr, std::int32_t x) { return 0 <= sys_futex( static_cast< void * >( addr), FUTEX_WAIT_PRIVATE, x) ? 0 : -1; } #elif BOOST_OS_WINDOWS BOOST_FORCEINLINE int futex_wake( std::atomic< std::int32_t > * addr) { ::WakeByAddressSingle( static_cast< void * >( addr) ); return 0; } BOOST_FORCEINLINE int futex_wait( std::atomic< std::int32_t > * addr, std::int32_t x) { ::WaitOnAddress( static_cast< volatile void * >( addr), & x, sizeof( x), INFINITE); return 0; } #else # warn "no futex support on this platform" #endif }}} #endif // BOOST_FIBERS_DETAIL_FUTEX_H