1 files changed, 93 insertions, 0 deletions
diff --git a/boost/interprocess/sync/windows/winapi_wrapper_common.hpp b/boost/interprocess/sync/windows/winapi_wrapper_common.hpp
new file mode 100644
index 0000000000..ccf2d65cb6
--- /dev/null
+++ b/boost/interprocess/sync/windows/winapi_wrapper_common.hpp
@@ -0,0 +1,93 @@
+ //////////////////////////////////////////////////////////////////////////////
+//
+// (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
+
+#if defined(_MSC_VER)
+#  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