98 lines
3.1 KiB
Plaintext
98 lines
3.1 KiB
Plaintext
|
//////////////////////////////////////////////////////////////////////////////
|
||
|
|
//
|
||
|
|
// (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_DETAIL_WINAPI_WRAPPER_COMMON_HPP
|
||
|
|
#define BOOST_INTERPROCESS_DETAIL_WINAPI_WRAPPER_COMMON_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/win32_api.hpp>
|
||
|
|
#include <boost/interprocess/detail/posix_time_types_wrk.hpp>
|
||
|
|
#include <boost/interprocess/errors.hpp>
|
||
|
|
#include <boost/interprocess/exceptions.hpp>
|
||
|
|
#include <limits>
|
||
|
|
|
||
|
|
namespace boost {
|
||
|
|
namespace interprocess {
|
||
|
|
namespace ipcdetail {
|
||
|
|
|
||
|
|
inline void winapi_wrapper_wait_for_single_object(void *handle)
|
||
|
|
{
|
||
|
|
unsigned long ret = winapi::wait_for_single_object(handle, winapi::infinite_time);
|
||
|
|
if(ret != winapi::wait_object_0){
|
||
|
|
if(ret != winapi::wait_abandoned){
|
||
|
|
error_info err = system_error_code();
|
||
|
|
throw interprocess_exception(err);
|
||
|
|
}
|
||
|
|
else{ //Special case for orphaned mutexes
|
||
|
|
winapi::release_mutex(handle);
|
||
|
|
throw interprocess_exception(owner_dead_error);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
inline bool winapi_wrapper_try_wait_for_single_object(void *handle)
|
||
|
|
{
|
||
|
|
unsigned long ret = winapi::wait_for_single_object(handle, 0);
|
||
|
|
if(ret == winapi::wait_object_0){
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
else if(ret == winapi::wait_timeout){
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
error_info err = system_error_code();
|
||
|
|
throw interprocess_exception(err);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
inline bool winapi_wrapper_timed_wait_for_single_object(void *handle, const boost::posix_time::ptime &abs_time)
|
||
|
|
{
|
||
|
|
//Windows does not support infinity abs_time so check it
|
||
|
|
if(abs_time == boost::posix_time::pos_infin){
|
||
|
|
winapi_wrapper_wait_for_single_object(handle);
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
const boost::posix_time::ptime cur_time = microsec_clock::universal_time();
|
||
|
|
//Windows uses relative wait times so check for negative waits
|
||
|
|
//and implement as 0 wait to allow try-semantics as POSIX mandates.
|
||
|
|
unsigned long ret = winapi::wait_for_single_object
|
||
|
|
( handle
|
||
|
|
, (abs_time <= cur_time) ? 0u
|
||
|
|
: (abs_time - cur_time).total_milliseconds()
|
||
|
|
);
|
||
|
|
if(ret == winapi::wait_object_0){
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
else if(ret == winapi::wait_timeout){
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
else{
|
||
|
|
error_info err = system_error_code();
|
||
|
|
throw interprocess_exception(err);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
} //namespace ipcdetail {
|
||
|
|
} //namespace interprocess {
|
||
|
|
} //namespace boost {
|
||
|
|
|
||
|
|
#include <boost/interprocess/detail/config_end.hpp>
|
||
|
|
|
||
|
|
#endif //BOOST_INTERPROCESS_DETAIL_WINAPI_MUTEX_WRAPPER_HPP
|