190 lines
5.7 KiB
C++
190 lines
5.7 KiB
C++
////////////////////////////////////////////////////////////////////////////
|
|
//
|
|
// (C) Copyright Ion Gaztanaga 2023-2024. 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)
|
|
//
|
|
// See http://www.boost.org/libs/interprocess for documentation.
|
|
//
|
|
//////////////////////////////////////////////////////////////////////////////
|
|
|
|
#ifndef BOOST_INTERPROCESS_TIMED_UTILS_HPP
|
|
#define BOOST_INTERPROCESS_TIMED_UTILS_HPP
|
|
|
|
#ifndef BOOST_CONFIG_HPP
|
|
# include <boost/config.hpp>
|
|
#endif
|
|
#
|
|
#if defined(BOOST_HAS_PRAGMA_ONCE)
|
|
# pragma once
|
|
#endif
|
|
|
|
#include <boost/interprocess/detail/config_begin.hpp>
|
|
#include <boost/interprocess/detail/workaround.hpp>
|
|
#include <boost/interprocess/detail/timed_utils.hpp>
|
|
|
|
|
|
//!\file
|
|
//!Describes some simple time-related utilities that can be used to call synchronization primitive and ipc methods that required
|
|
//!waiting until the resource is signalled or a timeout expires.
|
|
//!
|
|
//! These utilities are provided for those users that want to avoid dependence on std::chrono or boost::chrono or boost::date_time
|
|
//! and just want to implement simple portable waits.
|
|
|
|
namespace boost {
|
|
namespace interprocess {
|
|
|
|
//!Describes a simple duration type with microsecond resolution that can be used with the ustime time-point utility to call timed functions
|
|
//! of Boost.Interprocess' synchronization classes that expect a time-point (timed_wait, wait_until, timed_lock, lock_until...)
|
|
class ustime;
|
|
|
|
//!Describes a simple duration type with microsecond resolution that can be used with the ustime time-point utility to call timed functions
|
|
//! of Boost.Interprocess' synchronization classes that expect a duration type (wait_for, lock_for...)
|
|
class usduration
|
|
{
|
|
public:
|
|
friend class ustime;
|
|
|
|
//!Constructs a duration type that stores microseconds from
|
|
//!the passed count
|
|
explicit usduration(boost::uint64_t microsecs = 0u)
|
|
: m_microsecs(microsecs)
|
|
{}
|
|
|
|
//!Returns the stored microsecond
|
|
//!count
|
|
boost::uint64_t get_microsecs() const
|
|
{ return m_microsecs; }
|
|
|
|
bool operator < (const usduration &other) const
|
|
{ return m_microsecs < other.m_microsecs; }
|
|
|
|
bool operator > (const usduration &other) const
|
|
{ return m_microsecs > other.m_microsecs; }
|
|
|
|
bool operator <= (const usduration &other) const
|
|
{ return m_microsecs <= other.m_microsecs; }
|
|
|
|
bool operator >= (const usduration &other) const
|
|
{ return m_microsecs >= other.m_microsecs; }
|
|
|
|
private:
|
|
boost::uint64_t m_microsecs;
|
|
};
|
|
|
|
class ustime
|
|
{
|
|
public:
|
|
//!Constructs a time point that is "microsecs" duration away
|
|
//!from the epoch of the system
|
|
explicit ustime(boost::uint64_t microsecs = 0u)
|
|
: m_microsecs(microsecs)
|
|
{}
|
|
|
|
ustime &operator += (const usduration &other)
|
|
{ m_microsecs += other.m_microsecs; return *this; }
|
|
|
|
ustime operator + (const usduration &other)
|
|
{ ustime r(*this); r += other; return r; }
|
|
|
|
ustime &operator -= (const usduration &other)
|
|
{ m_microsecs -= other.m_microsecs; return *this; }
|
|
|
|
ustime operator - (const usduration &other)
|
|
{ ustime r(*this); r -= other; return r; }
|
|
|
|
friend usduration operator - (const ustime &l, const ustime &r)
|
|
{ return usduration(l.m_microsecs - r.m_microsecs); }
|
|
|
|
bool operator < (const ustime &other) const
|
|
{ return m_microsecs < other.m_microsecs; }
|
|
|
|
bool operator > (const ustime &other) const
|
|
{ return m_microsecs > other.m_microsecs; }
|
|
|
|
bool operator <= (const ustime &other) const
|
|
{ return m_microsecs <= other.m_microsecs; }
|
|
|
|
bool operator >= (const ustime &other) const
|
|
{ return m_microsecs >= other.m_microsecs; }
|
|
|
|
//!Returns the stored count
|
|
//!that represents microseconds from epoch
|
|
boost::uint64_t get_microsecs() const
|
|
{ return m_microsecs; }
|
|
|
|
private:
|
|
boost::uint64_t m_microsecs;
|
|
};
|
|
|
|
//!Utility that returns a duration from
|
|
//!a seconds count
|
|
inline usduration usduration_from_seconds(boost::uint64_t sec)
|
|
{ return usduration(sec*uint64_t(1000000u)); }
|
|
|
|
//!Utility that returns a duration from
|
|
//!a milliseconds count
|
|
inline usduration usduration_from_milliseconds(boost::uint64_t millisec)
|
|
{ return usduration(millisec*1000u); }
|
|
|
|
//!Utility that returns a time_point in the future that is "msecs"
|
|
//!milliseconds in the future from now.
|
|
inline ustime ustime_delay_milliseconds(unsigned msecs)
|
|
{
|
|
return ustime(ipcdetail::universal_time_u64_us()) + usduration(msecs*1000u);
|
|
}
|
|
|
|
#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
|
|
|
namespace ipcdetail {
|
|
|
|
template<>
|
|
class microsec_clock<ustime>
|
|
{
|
|
public:
|
|
typedef ustime time_point;
|
|
|
|
static ustime universal_time()
|
|
{ return ustime(universal_time_u64_us()); }
|
|
};
|
|
|
|
// duration_to_usduration
|
|
|
|
template<class Duration>
|
|
inline usduration duration_to_usduration(const Duration &d, typename enable_if_ptime_duration<Duration>::type* = 0)
|
|
{
|
|
return usduration(static_cast<boost::uint64_t>(d.total_microseconds()));
|
|
}
|
|
|
|
template<class Duration>
|
|
inline usduration duration_to_usduration(const Duration &d, typename enable_if_duration<Duration>::type* = 0)
|
|
{
|
|
const double factor = double(Duration::period::num)*1000000.0/double(Duration::period::den);
|
|
return usduration(static_cast<boost::uint64_t>(double(d.count())*factor));
|
|
}
|
|
|
|
inline usduration duration_to_usduration(const usduration &d)
|
|
{
|
|
return d;
|
|
}
|
|
|
|
// duration_to_ustime
|
|
|
|
template<class Duration>
|
|
inline ustime duration_to_ustime(const Duration &d)
|
|
{
|
|
return microsec_clock<ustime>::universal_time() + (duration_to_usduration)(d);
|
|
}
|
|
|
|
|
|
} //namespace ipcdetail {
|
|
|
|
#endif //#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
|
|
|
} //namespace interprocess {
|
|
} //namespace boost {
|
|
|
|
#include <boost/interprocess/detail/config_end.hpp>
|
|
|
|
#endif //BOOST_INTERPROCESS_TIMED_UTILS_HPP
|