diff options
Diffstat (limited to 'boost/log/detail/event.hpp')
-rw-r--r-- | boost/log/detail/event.hpp | 142 |
1 files changed, 142 insertions, 0 deletions
diff --git a/boost/log/detail/event.hpp b/boost/log/detail/event.hpp new file mode 100644 index 0000000000..741ab3c9bd --- /dev/null +++ b/boost/log/detail/event.hpp @@ -0,0 +1,142 @@ +/* + * Copyright Andrey Semashev 2007 - 2014. + * 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) + */ +/*! + * \file detail/event.hpp + * \author Andrey Semashev + * \date 24.07.2011 + */ + +#ifndef BOOST_LOG_DETAIL_EVENT_HPP_INCLUDED_ +#define BOOST_LOG_DETAIL_EVENT_HPP_INCLUDED_ + +#include <boost/log/detail/config.hpp> + +#ifdef BOOST_HAS_PRAGMA_ONCE +#pragma once +#endif + +#ifndef BOOST_LOG_NO_THREADS + +#if defined(BOOST_THREAD_PLATFORM_PTHREAD) +# if defined(_POSIX_SEMAPHORES) && (_POSIX_SEMAPHORES + 0) > 0 +# if defined(__GNUC__) && defined(__GCC_HAVE_SYNC_COMPARE_AND_SWAP_4) +# include <semaphore.h> +# include <boost/cstdint.hpp> +# define BOOST_LOG_EVENT_USE_POSIX_SEMAPHORE +# endif +# endif +#elif defined(BOOST_THREAD_PLATFORM_WIN32) +# include <boost/cstdint.hpp> +# define BOOST_LOG_EVENT_USE_WINAPI +#endif + +#if !defined(BOOST_LOG_EVENT_USE_POSIX_SEMAPHORE) && !defined(BOOST_LOG_EVENT_USE_WINAPI) +# include <boost/thread/mutex.hpp> +# include <boost/thread/condition_variable.hpp> +# define BOOST_LOG_EVENT_USE_BOOST_CONDITION +#endif + +#include <boost/log/detail/header.hpp> + +namespace boost { + +BOOST_LOG_OPEN_NAMESPACE + +namespace aux { + +#if defined(BOOST_LOG_EVENT_USE_POSIX_SEMAPHORE) + +class sem_based_event +{ +private: + boost::uint32_t m_state; + sem_t m_semaphore; + +public: + //! Default constructor + BOOST_LOG_API sem_based_event(); + //! Destructor + BOOST_LOG_API ~sem_based_event(); + + //! Waits for the object to become signalled + BOOST_LOG_API void wait(); + //! Sets the object to a signalled state + BOOST_LOG_API void set_signalled(); + + // Copying prohibited + BOOST_DELETED_FUNCTION(sem_based_event(sem_based_event const&)) + BOOST_DELETED_FUNCTION(sem_based_event& operator= (sem_based_event const&)) +}; + +typedef sem_based_event event; + +#elif defined(BOOST_LOG_EVENT_USE_WINAPI) + +class winapi_based_event +{ +private: + boost::uint32_t m_state; + void* m_event; + +public: + //! Default constructor + BOOST_LOG_API winapi_based_event(); + //! Destructor + BOOST_LOG_API ~winapi_based_event(); + + //! Waits for the object to become signalled + BOOST_LOG_API void wait(); + //! Sets the object to a signalled state + BOOST_LOG_API void set_signalled(); + + // Copying prohibited + BOOST_DELETED_FUNCTION(winapi_based_event(winapi_based_event const&)) + BOOST_DELETED_FUNCTION(winapi_based_event& operator= (winapi_based_event const&)) +}; + +typedef winapi_based_event event; + +#else + +class generic_event +{ +private: + boost::mutex m_mutex; + boost::condition_variable m_cond; + bool m_state; + +public: + //! Default constructor + BOOST_LOG_API generic_event(); + //! Destructor + BOOST_LOG_API ~generic_event(); + + //! Waits for the object to become signalled + BOOST_LOG_API void wait(); + //! Sets the object to a signalled state + BOOST_LOG_API void set_signalled(); + + // Copying prohibited + BOOST_DELETED_FUNCTION(generic_event(generic_event const&)) + BOOST_DELETED_FUNCTION(generic_event& operator= (generic_event const&)) +}; + +typedef generic_event event; + +#endif + +} // namespace aux + +BOOST_LOG_CLOSE_NAMESPACE // namespace log + +} // namespace boost + +#include <boost/log/detail/footer.hpp> + +#endif // BOOST_LOG_NO_THREADS + +#endif // BOOST_LOG_DETAIL_EVENT_HPP_INCLUDED_ |