/usr/include/simgrid/s4u/ConditionVariable.hpp is in libsimgrid-dev 3.18+dfsg-1.
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 | /* Copyright (c) 2006-2017. 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/chrono.hpp>
#include <simgrid/s4u/Mutex.hpp>
#include <simgrid/simix.h>
namespace simgrid {
namespace s4u {
/** @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_t;
smx_cond_t cond_;
explicit 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(MutexPtr lock);
void wait(std::unique_lock<Mutex> & lock);
template <class P> void wait(std::unique_lock<Mutex> & lock, P pred)
{
while (not 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 (not 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_v319("Use notify_one(): v3.19 will change this warning into an error.") void notify()
{
notify_one();
}
};
using ConditionVariablePtr = ConditionVariable::Ptr;
}
} // namespace simgrid::s4u
#endif
|