231 lines
7.1 KiB
C++
231 lines
7.1 KiB
C++
//////////////////////////////////////////////////////////////////////////////
|
|
//
|
|
// (C) Copyright Ion Gaztanaga 2011-2012. 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_WINDOWS_NAMED_SEMAPHORE_HPP
|
|
#define BOOST_INTERPROCESS_WINDOWS_NAMED_SEMAPHORE_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/creation_tags.hpp>
|
|
#include <boost/interprocess/permissions.hpp>
|
|
#include <boost/interprocess/detail/interprocess_tester.hpp>
|
|
#include <boost/interprocess/sync/windows/named_sync.hpp>
|
|
#include <boost/interprocess/sync/windows/winapi_semaphore_wrapper.hpp>
|
|
|
|
namespace boost {
|
|
namespace interprocess {
|
|
namespace ipcdetail {
|
|
|
|
|
|
|
|
class winapi_named_semaphore
|
|
{
|
|
#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
|
|
|
//Non-copyable
|
|
winapi_named_semaphore();
|
|
winapi_named_semaphore(const winapi_named_semaphore &);
|
|
winapi_named_semaphore &operator=(const winapi_named_semaphore &);
|
|
#endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
|
|
|
|
public:
|
|
winapi_named_semaphore(create_only_t, const char *name, unsigned int initialCount, const permissions &perm = permissions());
|
|
|
|
winapi_named_semaphore(open_or_create_t, const char *name, unsigned int initialCount, const permissions &perm = permissions());
|
|
|
|
winapi_named_semaphore(open_only_t, const char *name);
|
|
|
|
winapi_named_semaphore(create_only_t, const wchar_t *name, unsigned int initialCount, const permissions &perm = permissions());
|
|
|
|
winapi_named_semaphore(open_or_create_t, const wchar_t *name, unsigned int initialCount, const permissions &perm = permissions());
|
|
|
|
winapi_named_semaphore(open_only_t, const wchar_t *name);
|
|
|
|
~winapi_named_semaphore();
|
|
|
|
void post();
|
|
void wait();
|
|
bool try_wait();
|
|
template<class TimePoint> bool timed_wait(const TimePoint &abs_time);
|
|
|
|
static bool remove(const char *name);
|
|
static bool remove(const wchar_t *name);
|
|
|
|
#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
|
|
private:
|
|
friend class interprocess_tester;
|
|
void dont_close_on_destruction();
|
|
winapi_semaphore_wrapper m_sem_wrapper;
|
|
windows_named_sync m_named_sync;
|
|
|
|
class named_sem_callbacks : public windows_named_sync_interface
|
|
{
|
|
public:
|
|
typedef __int64 sem_count_t;
|
|
named_sem_callbacks(winapi_semaphore_wrapper &sem_wrapper, sem_count_t sem_cnt)
|
|
: m_sem_wrapper(sem_wrapper), m_sem_count(sem_cnt)
|
|
{}
|
|
|
|
virtual std::size_t get_data_size() const BOOST_OVERRIDE
|
|
{ return sizeof(sem_count_t); }
|
|
|
|
virtual const void *buffer_with_final_data_to_file() BOOST_OVERRIDE
|
|
{ return &m_sem_count; }
|
|
|
|
virtual const void *buffer_with_init_data_to_file() BOOST_OVERRIDE
|
|
{ return &m_sem_count; }
|
|
|
|
virtual void *buffer_to_store_init_data_from_file() BOOST_OVERRIDE
|
|
{ return &m_sem_count; }
|
|
|
|
virtual bool open(create_enum_t, const char *id_name) BOOST_OVERRIDE
|
|
{
|
|
std::string aux_str = "Global\\bipc.sem.";
|
|
aux_str += id_name;
|
|
//
|
|
permissions sem_perm;
|
|
sem_perm.set_unrestricted();
|
|
bool created;
|
|
return m_sem_wrapper.open_or_create
|
|
( aux_str.c_str(), static_cast<long>(m_sem_count)
|
|
, winapi_semaphore_wrapper::MaxCount, sem_perm, created);
|
|
}
|
|
|
|
virtual bool open(create_enum_t, const wchar_t *id_name) BOOST_OVERRIDE
|
|
{
|
|
std::wstring aux_str = L"Global\\bipc.sem.";
|
|
aux_str += id_name;
|
|
//
|
|
permissions sem_perm;
|
|
sem_perm.set_unrestricted();
|
|
bool created;
|
|
return m_sem_wrapper.open_or_create
|
|
( aux_str.c_str(), static_cast<long>(m_sem_count)
|
|
, winapi_semaphore_wrapper::MaxCount, sem_perm, created);
|
|
}
|
|
|
|
virtual void close() BOOST_OVERRIDE
|
|
{
|
|
m_sem_wrapper.close();
|
|
}
|
|
|
|
virtual ~named_sem_callbacks() BOOST_OVERRIDE
|
|
{}
|
|
|
|
private:
|
|
winapi_semaphore_wrapper& m_sem_wrapper;
|
|
sem_count_t m_sem_count;
|
|
};
|
|
|
|
#endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED
|
|
};
|
|
|
|
inline winapi_named_semaphore::~winapi_named_semaphore()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, m_sem_wrapper.value());
|
|
m_named_sync.close(callbacks);
|
|
}
|
|
|
|
inline void winapi_named_semaphore::dont_close_on_destruction()
|
|
{}
|
|
|
|
inline winapi_named_semaphore::winapi_named_semaphore
|
|
(create_only_t, const char *name, unsigned int initial_count, const permissions &perm)
|
|
: m_sem_wrapper()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, initial_count);
|
|
m_named_sync.open_or_create(DoCreate, name, perm, callbacks);
|
|
}
|
|
|
|
inline winapi_named_semaphore::winapi_named_semaphore
|
|
(open_or_create_t, const char *name, unsigned int initial_count, const permissions &perm)
|
|
: m_sem_wrapper()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, initial_count);
|
|
m_named_sync.open_or_create(DoOpenOrCreate, name, perm, callbacks);
|
|
}
|
|
|
|
inline winapi_named_semaphore::winapi_named_semaphore(open_only_t, const char *name)
|
|
: m_sem_wrapper()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, 0);
|
|
m_named_sync.open_or_create(DoOpen, name, permissions(), callbacks);
|
|
}
|
|
|
|
inline winapi_named_semaphore::winapi_named_semaphore
|
|
(create_only_t, const wchar_t *name, unsigned int initial_count, const permissions &perm)
|
|
: m_sem_wrapper()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, initial_count);
|
|
m_named_sync.open_or_create(DoCreate, name, perm, callbacks);
|
|
}
|
|
|
|
inline winapi_named_semaphore::winapi_named_semaphore
|
|
(open_or_create_t, const wchar_t *name, unsigned int initial_count, const permissions &perm)
|
|
: m_sem_wrapper()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, initial_count);
|
|
m_named_sync.open_or_create(DoOpenOrCreate, name, perm, callbacks);
|
|
}
|
|
|
|
inline winapi_named_semaphore::winapi_named_semaphore(open_only_t, const wchar_t *name)
|
|
: m_sem_wrapper()
|
|
{
|
|
named_sem_callbacks callbacks(m_sem_wrapper, 0);
|
|
m_named_sync.open_or_create(DoOpen, name, permissions(), callbacks);
|
|
}
|
|
|
|
inline void winapi_named_semaphore::post()
|
|
{
|
|
m_sem_wrapper.post();
|
|
}
|
|
|
|
inline void winapi_named_semaphore::wait()
|
|
{
|
|
m_sem_wrapper.wait();
|
|
}
|
|
|
|
inline bool winapi_named_semaphore::try_wait()
|
|
{
|
|
return m_sem_wrapper.try_wait();
|
|
}
|
|
|
|
template<class TimePoint>
|
|
inline bool winapi_named_semaphore::timed_wait(const TimePoint &abs_time)
|
|
{
|
|
return m_sem_wrapper.timed_wait(abs_time);
|
|
}
|
|
|
|
inline bool winapi_named_semaphore::remove(const char *name)
|
|
{
|
|
return windows_named_sync::remove(name);
|
|
}
|
|
|
|
inline bool winapi_named_semaphore::remove(const wchar_t *name)
|
|
{
|
|
return windows_named_sync::remove(name);
|
|
}
|
|
|
|
} //namespace ipcdetail {
|
|
} //namespace interprocess {
|
|
} //namespace boost {
|
|
|
|
#include <boost/interprocess/detail/config_end.hpp>
|
|
|
|
#endif //BOOST_INTERPROCESS_WINDOWS_NAMED_SEMAPHORE_HPP
|