Chris@16: //////////////////////////////////////////////////////////////////////////////
Chris@16: //
Chris@16: // (C) Copyright Ion Gaztanaga 2005-2012. Distributed under the Boost
Chris@16: // Software License, Version 1.0. (See accompanying file
Chris@16: // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Chris@16: //
Chris@16: // See http://www.boost.org/libs/interprocess for documentation.
Chris@16: //
Chris@16: //////////////////////////////////////////////////////////////////////////////
Chris@16: 
Chris@16: #ifndef BOOST_INTERPROCESS_DETAIL_WINDOWS_CONDITION_HPP
Chris@16: #define BOOST_INTERPROCESS_DETAIL_WINDOWS_CONDITION_HPP
Chris@16: 
Chris@101: #ifndef BOOST_CONFIG_HPP
Chris@101: #  include <boost/config.hpp>
Chris@101: #endif
Chris@101: #
Chris@101: #if defined(BOOST_HAS_PRAGMA_ONCE)
Chris@101: #  pragma once
Chris@101: #endif
Chris@101: 
Chris@16: #include <boost/interprocess/detail/config_begin.hpp>
Chris@16: #include <boost/interprocess/detail/workaround.hpp>
Chris@16: #include <boost/interprocess/detail/posix_time_types_wrk.hpp>
Chris@16: 
Chris@16: #include <boost/interprocess/sync/interprocess_mutex.hpp>
Chris@16: #include <boost/interprocess/sync/scoped_lock.hpp>
Chris@16: #include <boost/interprocess/exceptions.hpp>
Chris@16: #include <boost/interprocess/sync/windows/semaphore.hpp>
Chris@16: #include <boost/interprocess/sync/windows/mutex.hpp>
Chris@16: #include <boost/interprocess/sync/detail/condition_algorithm_8a.hpp>
Chris@16: 
Chris@16: 
Chris@16: namespace boost {
Chris@16: namespace interprocess {
Chris@16: namespace ipcdetail {
Chris@16: 
Chris@16: class windows_condition
Chris@16: {
Chris@16:    windows_condition(const windows_condition &);
Chris@16:    windows_condition &operator=(const windows_condition &);
Chris@16: 
Chris@16:    public:
Chris@16:    windows_condition()
Chris@16:       : m_condition_data()
Chris@16:    {}
Chris@16: 
Chris@16:    ~windows_condition()
Chris@101:    {
Chris@101:       //Notify all waiting threads
Chris@101:       //to allow POSIX semantics on condition destruction
Chris@101:       this->notify_all();
Chris@101:    }
Chris@16: 
Chris@16:    void notify_one()
Chris@16:    {  m_condition_data.notify_one();   }
Chris@16: 
Chris@16:    void notify_all()
Chris@16:    {  m_condition_data.notify_all();   }
Chris@16: 
Chris@16:    template <typename L>
Chris@16:    bool timed_wait(L& lock, const boost::posix_time::ptime &abs_time)
Chris@16:    {  return m_condition_data.timed_wait(lock, abs_time);   }
Chris@16: 
Chris@16:    template <typename L, typename Pr>
Chris@16:    bool timed_wait(L& lock, const boost::posix_time::ptime &abs_time, Pr pred)
Chris@16:    {  return m_condition_data.timed_wait(lock, abs_time, pred);   }
Chris@16: 
Chris@16:    template <typename L>
Chris@16:    void wait(L& lock)
Chris@16:    {  m_condition_data.wait(lock);   }
Chris@16: 
Chris@16:    template <typename L, typename Pr>
Chris@16:    void wait(L& lock, Pr pred)
Chris@16:    {  m_condition_data.wait(lock, pred);   }
Chris@16: 
Chris@16:    private:
Chris@16: 
Chris@16:    struct condition_data
Chris@16:    {
Chris@16:       typedef boost::int32_t     integer_type;
Chris@16:       typedef windows_semaphore  semaphore_type;
Chris@16:       typedef windows_mutex      mutex_type;
Chris@16: 
Chris@16:       condition_data()
Chris@16:          : m_nwaiters_blocked(0)
Chris@16:          , m_nwaiters_gone(0)
Chris@16:          , m_nwaiters_to_unblock(0)
Chris@16:          , m_sem_block_queue(0)
Chris@16:          , m_sem_block_lock(1)
Chris@16:          , m_mtx_unblock_lock()
Chris@16:       {}
Chris@16: 
Chris@16:       integer_type    &get_nwaiters_blocked()
Chris@16:       {  return m_nwaiters_blocked;  }
Chris@16: 
Chris@16:       integer_type    &get_nwaiters_gone()
Chris@16:       {  return m_nwaiters_gone;  }
Chris@16: 
Chris@16:       integer_type    &get_nwaiters_to_unblock()
Chris@16:       {  return m_nwaiters_to_unblock;  }
Chris@16: 
Chris@16:       semaphore_type  &get_sem_block_queue()
Chris@16:       {  return m_sem_block_queue;  }
Chris@16: 
Chris@16:       semaphore_type  &get_sem_block_lock()
Chris@16:       {  return m_sem_block_lock;  }
Chris@16: 
Chris@16:       mutex_type      &get_mtx_unblock_lock()
Chris@16:       {  return m_mtx_unblock_lock;  }
Chris@16: 
Chris@16:       boost::int32_t    m_nwaiters_blocked;
Chris@16:       boost::int32_t    m_nwaiters_gone;
Chris@16:       boost::int32_t    m_nwaiters_to_unblock;
Chris@16:       windows_semaphore m_sem_block_queue;
Chris@16:       windows_semaphore m_sem_block_lock;
Chris@16:       windows_mutex     m_mtx_unblock_lock;
Chris@16:    };
Chris@16: 
Chris@16:    ipcdetail::condition_8a_wrapper<condition_data> m_condition_data;
Chris@16: };
Chris@16: 
Chris@16: }  //namespace ipcdetail
Chris@16: }  //namespace interprocess
Chris@16: }  //namespace boost
Chris@16: 
Chris@16: #include <boost/interprocess/detail/config_end.hpp>
Chris@16: 
Chris@16: #endif   //BOOST_INTERPROCESS_DETAIL_WINDOWS_CONDITION_HPP