#include <boost/interprocess/creation_tags.hpp>
#include <boost/interprocess/permissions.hpp>
#include <boost/interprocess/detail/interprocess_tester.hpp>
-#include <boost/interprocess/detail/posix_time_types_wrk.hpp>
#include <boost/interprocess/sync/windows/sync_utils.hpp>
#include <boost/interprocess/sync/windows/named_sync.hpp>
#include <boost/interprocess/sync/windows/winapi_mutex_wrapper.hpp>
-class windows_named_mutex
+class winapi_named_mutex
{
#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
//Non-copyable
- windows_named_mutex();
- windows_named_mutex(const windows_named_mutex &);
- windows_named_mutex &operator=(const windows_named_mutex &);
+ winapi_named_mutex();
+ winapi_named_mutex(const winapi_named_mutex &);
+ winapi_named_mutex &operator=(const winapi_named_mutex &);
#endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
public:
- windows_named_mutex(create_only_t, const char *name, const permissions &perm = permissions());
+ winapi_named_mutex(create_only_t, const char *name, const permissions &perm = permissions());
- windows_named_mutex(open_or_create_t, const char *name, const permissions &perm = permissions());
+ winapi_named_mutex(open_or_create_t, const char *name, const permissions &perm = permissions());
- windows_named_mutex(open_only_t, const char *name);
+ winapi_named_mutex(open_only_t, const char *name);
- ~windows_named_mutex();
+ winapi_named_mutex(create_only_t, const wchar_t *name, const permissions &perm = permissions());
+
+ winapi_named_mutex(open_or_create_t, const wchar_t *name, const permissions &perm = permissions());
+
+ winapi_named_mutex(open_only_t, const wchar_t *name);
+
+ ~winapi_named_mutex();
void unlock();
void lock();
bool try_lock();
- bool timed_lock(const boost::posix_time::ptime &abs_time);
+ template<class TimePoint> bool timed_lock(const TimePoint &abs_time);
+
+ template<class TimePoint> bool try_lock_until(const TimePoint &abs_time)
+ { return this->timed_lock(abs_time); }
+
+ template<class Duration> bool try_lock_for(const Duration &dur)
+ { return this->timed_lock(duration_to_ustime(dur)); }
static bool remove(const char *name);
+ static bool remove(const wchar_t *name);
+
#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
private:
friend class interprocess_tester;
: m_mtx_wrapper(mtx_wrapper)
{}
- virtual std::size_t get_data_size() const
+ virtual std::size_t get_data_size() const BOOST_OVERRIDE
{ return 0u; }
- virtual const void *buffer_with_init_data_to_file()
+ virtual const void *buffer_with_init_data_to_file() BOOST_OVERRIDE
{ return 0; }
- virtual const void *buffer_with_final_data_to_file()
+ virtual const void *buffer_with_final_data_to_file() BOOST_OVERRIDE
{ return 0; }
- virtual void *buffer_to_store_init_data_from_file()
+ virtual void *buffer_to_store_init_data_from_file() BOOST_OVERRIDE
{ return 0; }
- virtual bool open(create_enum_t, const char *id_name)
+ virtual bool open(create_enum_t, const char *id_name) BOOST_OVERRIDE
{
std::string aux_str = "Global\\bipc.mut.";
aux_str += id_name;
return m_mtx_wrapper.open_or_create(aux_str.c_str(), mut_perm);
}
- virtual void close()
+ virtual bool open(create_enum_t, const wchar_t *id_name) BOOST_OVERRIDE
+ {
+ std::wstring aux_str = L"Global\\bipc.mut.";
+ aux_str += id_name;
+ //
+ permissions mut_perm;
+ mut_perm.set_unrestricted();
+ return m_mtx_wrapper.open_or_create(aux_str.c_str(), mut_perm);
+ }
+
+ virtual void close() BOOST_OVERRIDE
{
m_mtx_wrapper.close();
}
- virtual ~named_mut_callbacks()
+ virtual ~named_mut_callbacks() BOOST_OVERRIDE
{}
private:
#endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
};
-inline windows_named_mutex::~windows_named_mutex()
+inline winapi_named_mutex::~winapi_named_mutex()
{
named_mut_callbacks callbacks(m_mtx_wrapper);
m_named_sync.close(callbacks);
}
-inline void windows_named_mutex::dont_close_on_destruction()
+inline void winapi_named_mutex::dont_close_on_destruction()
{}
-inline windows_named_mutex::windows_named_mutex
+inline winapi_named_mutex::winapi_named_mutex
(create_only_t, const char *name, const permissions &perm)
: m_mtx_wrapper()
{
m_named_sync.open_or_create(DoCreate, name, perm, callbacks);
}
-inline windows_named_mutex::windows_named_mutex
+inline winapi_named_mutex::winapi_named_mutex
(open_or_create_t, const char *name, const permissions &perm)
: m_mtx_wrapper()
{
m_named_sync.open_or_create(DoOpenOrCreate, name, perm, callbacks);
}
-inline windows_named_mutex::windows_named_mutex(open_only_t, const char *name)
+inline winapi_named_mutex::winapi_named_mutex(open_only_t, const char *name)
+ : m_mtx_wrapper()
+{
+ named_mut_callbacks callbacks(m_mtx_wrapper);
+ m_named_sync.open_or_create(DoOpen, name, permissions(), callbacks);
+}
+
+inline winapi_named_mutex::winapi_named_mutex
+ (create_only_t, const wchar_t *name, const permissions &perm)
+ : m_mtx_wrapper()
+{
+ named_mut_callbacks callbacks(m_mtx_wrapper);
+ m_named_sync.open_or_create(DoCreate, name, perm, callbacks);
+}
+
+inline winapi_named_mutex::winapi_named_mutex
+ (open_or_create_t, const wchar_t *name, const permissions &perm)
+ : m_mtx_wrapper()
+{
+ named_mut_callbacks callbacks(m_mtx_wrapper);
+ m_named_sync.open_or_create(DoOpenOrCreate, name, perm, callbacks);
+}
+
+inline winapi_named_mutex::winapi_named_mutex(open_only_t, const wchar_t *name)
: m_mtx_wrapper()
{
named_mut_callbacks callbacks(m_mtx_wrapper);
m_named_sync.open_or_create(DoOpen, name, permissions(), callbacks);
}
-inline void windows_named_mutex::unlock()
+inline void winapi_named_mutex::unlock()
{
m_mtx_wrapper.unlock();
}
-inline void windows_named_mutex::lock()
+inline void winapi_named_mutex::lock()
{
m_mtx_wrapper.lock();
}
-inline bool windows_named_mutex::try_lock()
+inline bool winapi_named_mutex::try_lock()
{
return m_mtx_wrapper.try_lock();
}
-inline bool windows_named_mutex::timed_lock(const boost::posix_time::ptime &abs_time)
+template<class TimePoint>
+inline bool winapi_named_mutex::timed_lock(const TimePoint &abs_time)
{
return m_mtx_wrapper.timed_lock(abs_time);
}
-inline bool windows_named_mutex::remove(const char *name)
+inline bool winapi_named_mutex::remove(const char *name)
+{
+ return windows_named_sync::remove(name);
+}
+
+inline bool winapi_named_mutex::remove(const wchar_t *name)
{
return windows_named_sync::remove(name);
}