/usr/include/simgrid/s4u/conditionVariable.hpp is in libsimgrid-dev 3.14.159-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 | /* Copyright (c) 2006-2016. The SimGrid Team. All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
#ifndef SIMGRID_S4U_COND_VARIABLE_HPP
#define SIMGRID_S4U_COND_VARIABLE_HPP
#include <chrono>
#include <condition_variable>
#include <future>
#include <mutex>
#include <utility> // std::swap
#include <boost/intrusive_ptr.hpp>
#include <xbt/base.h>
#include <simgrid/simix.h>
#include <simgrid/chrono.hpp>
#include <simgrid/s4u/Mutex.hpp>
namespace simgrid {
namespace s4u {
class Mutex;
/** @brief A condition variable
* @ingroup s4u_api
*
* This is a drop-in replacement of `std::condition_variable` and should respect the same
* semantic. But we currently use (only) double for both durations and
* timestamp timeouts.
*/
XBT_PUBLIC_CLASS ConditionVariable {
private:
friend s_smx_cond;
smx_cond_t cond_;
ConditionVariable(smx_cond_t cond) : cond_(cond) {}
public:
ConditionVariable(ConditionVariable const&) = delete;
ConditionVariable& operator=(ConditionVariable const&) = delete;
friend XBT_PUBLIC(void) intrusive_ptr_add_ref(ConditionVariable* cond);
friend XBT_PUBLIC(void) intrusive_ptr_release(ConditionVariable* cond);
using Ptr = boost::intrusive_ptr<ConditionVariable>;
static Ptr createConditionVariable();
// Wait functions without time:
void wait(std::unique_lock<Mutex>& lock);
template<class P>
void wait(std::unique_lock<Mutex>& lock, P pred)
{
while (!pred())
wait(lock);
}
// Wait function taking a plain double as time:
std::cv_status wait_until(std::unique_lock<Mutex>& lock, double timeout_time);
std::cv_status wait_for(std::unique_lock<Mutex>& lock, double duration);
template<class P>
bool wait_until(std::unique_lock<Mutex>& lock, double timeout_time, P pred)
{
while (!pred())
if (this->wait_until(lock, timeout_time) == std::cv_status::timeout)
return pred();
return true;
}
template<class P>
bool wait_for(std::unique_lock<Mutex>& lock, double duration, P pred)
{
return this->wait_until(lock, SIMIX_get_clock() + duration, std::move(pred));
}
// Wait function taking a C++ style time:
template<class Rep, class Period, class P>
bool wait_for(
std::unique_lock<Mutex>& lock, std::chrono::duration<Rep, Period> duration,
P pred)
{
auto seconds = std::chrono::duration_cast<SimulationClockDuration>(duration);
return this->wait_for(lock, seconds.count(), pred);
}
template<class Rep, class Period>
std::cv_status wait_for(
std::unique_lock<Mutex>& lock, std::chrono::duration<Rep, Period> duration)
{
auto seconds = std::chrono::duration_cast<SimulationClockDuration>(duration);
return this->wait_for(lock, seconds.count());
}
template<class Duration>
std::cv_status wait_until(std::unique_lock<Mutex>& lock,
const SimulationTimePoint<Duration>& timeout_time)
{
auto timeout_native = std::chrono::time_point_cast<SimulationClockDuration>(timeout_time);
return this->wait_until(lock, timeout_native.time_since_epoch().count());
}
template<class Duration, class P>
bool wait_until(std::unique_lock<Mutex>& lock,
const SimulationTimePoint<Duration>& timeout_time, P pred)
{
auto timeout_native = std::chrono::time_point_cast<SimulationClockDuration>(timeout_time);
return this->wait_until(lock, timeout_native.time_since_epoch().count(),
std::move(pred));
}
// Notify functions
void notify_one();
void notify_all();
XBT_ATTRIB_DEPRECATED("Use notify_one() instead")
void notify() { notify_one(); }
};
using ConditionVariablePtr = ConditionVariable::Ptr;
}} // namespace simgrid::s4u
#endif /* SIMGRID_S4U_COND_VARIABLE_HPP */
|