1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/ossrv/ossrv_pub/boost_apis/boost/thread/detail/lock.hpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,209 @@
1.4 +// Copyright (C) 2001-2003
1.5 +// William E. Kempf
1.6 +//
1.7 +// Distributed under the Boost Software License, Version 1.0. (See accompanying
1.8 +// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
1.9 +
1.10 +#ifndef BOOST_XLOCK_WEK070601_HPP
1.11 +#define BOOST_XLOCK_WEK070601_HPP
1.12 +
1.13 +#include <boost/thread/detail/config.hpp>
1.14 +
1.15 +#include <boost/utility.hpp>
1.16 +#include <boost/thread/exceptions.hpp>
1.17 +
1.18 +namespace boost {
1.19 +
1.20 +class condition;
1.21 +struct xtime;
1.22 +
1.23 +namespace detail { namespace thread {
1.24 +
1.25 +template <typename Mutex>
1.26 +class lock_ops : private noncopyable
1.27 +{
1.28 +private:
1.29 + lock_ops() { }
1.30 +
1.31 +public:
1.32 + typedef typename Mutex::cv_state lock_state;
1.33 +
1.34 + static void lock(Mutex& m)
1.35 + {
1.36 + m.do_lock();
1.37 + }
1.38 + static bool trylock(Mutex& m)
1.39 + {
1.40 + return m.do_trylock();
1.41 + }
1.42 + static bool timedlock(Mutex& m, const xtime& xt)
1.43 + {
1.44 + return m.do_timedlock(xt);
1.45 + }
1.46 + static void unlock(Mutex& m)
1.47 + {
1.48 + m.do_unlock();
1.49 + }
1.50 + static void lock(Mutex& m, lock_state& state)
1.51 + {
1.52 + m.do_lock(state);
1.53 + }
1.54 + static void unlock(Mutex& m, lock_state& state)
1.55 + {
1.56 + m.do_unlock(state);
1.57 + }
1.58 +};
1.59 +
1.60 +template <typename Mutex>
1.61 +class scoped_lock : private noncopyable
1.62 +{
1.63 +public:
1.64 + typedef Mutex mutex_type;
1.65 +
1.66 + explicit scoped_lock(Mutex& mx, bool initially_locked=true)
1.67 + : m_mutex(mx), m_locked(false)
1.68 + {
1.69 + if (initially_locked) lock();
1.70 + }
1.71 + ~scoped_lock()
1.72 + {
1.73 + if (m_locked) unlock();
1.74 + }
1.75 +
1.76 + void lock()
1.77 + {
1.78 + if (m_locked) throw lock_error();
1.79 + lock_ops<Mutex>::lock(m_mutex);
1.80 + m_locked = true;
1.81 + }
1.82 + void unlock()
1.83 + {
1.84 + if (!m_locked) throw lock_error();
1.85 + lock_ops<Mutex>::unlock(m_mutex);
1.86 + m_locked = false;
1.87 + }
1.88 +
1.89 + bool locked() const { return m_locked; }
1.90 + operator const void*() const { return m_locked ? this : 0; }
1.91 +
1.92 +private:
1.93 + friend class boost::condition;
1.94 +
1.95 + Mutex& m_mutex;
1.96 + bool m_locked;
1.97 +};
1.98 +
1.99 +template <typename TryMutex>
1.100 +class scoped_try_lock : private noncopyable
1.101 +{
1.102 +public:
1.103 + typedef TryMutex mutex_type;
1.104 +
1.105 + explicit scoped_try_lock(TryMutex& mx)
1.106 + : m_mutex(mx), m_locked(false)
1.107 + {
1.108 + try_lock();
1.109 + }
1.110 + scoped_try_lock(TryMutex& mx, bool initially_locked)
1.111 + : m_mutex(mx), m_locked(false)
1.112 + {
1.113 + if (initially_locked) lock();
1.114 + }
1.115 + ~scoped_try_lock()
1.116 + {
1.117 + if (m_locked) unlock();
1.118 + }
1.119 +
1.120 + void lock()
1.121 + {
1.122 + if (m_locked) throw lock_error();
1.123 + lock_ops<TryMutex>::lock(m_mutex);
1.124 + m_locked = true;
1.125 + }
1.126 + bool try_lock()
1.127 + {
1.128 + if (m_locked) throw lock_error();
1.129 + return (m_locked = lock_ops<TryMutex>::trylock(m_mutex));
1.130 + }
1.131 + void unlock()
1.132 + {
1.133 + if (!m_locked) throw lock_error();
1.134 + lock_ops<TryMutex>::unlock(m_mutex);
1.135 + m_locked = false;
1.136 + }
1.137 +
1.138 + bool locked() const { return m_locked; }
1.139 + operator const void*() const { return m_locked ? this : 0; }
1.140 +
1.141 +private:
1.142 + friend class boost::condition;
1.143 +
1.144 + TryMutex& m_mutex;
1.145 + bool m_locked;
1.146 +};
1.147 +
1.148 +template <typename TimedMutex>
1.149 +class scoped_timed_lock : private noncopyable
1.150 +{
1.151 +public:
1.152 + typedef TimedMutex mutex_type;
1.153 +
1.154 + scoped_timed_lock(TimedMutex& mx, const xtime& xt)
1.155 + : m_mutex(mx), m_locked(false)
1.156 + {
1.157 + timed_lock(xt);
1.158 + }
1.159 + scoped_timed_lock(TimedMutex& mx, bool initially_locked)
1.160 + : m_mutex(mx), m_locked(false)
1.161 + {
1.162 + if (initially_locked) lock();
1.163 + }
1.164 + ~scoped_timed_lock()
1.165 + {
1.166 + if (m_locked) unlock();
1.167 + }
1.168 +
1.169 + void lock()
1.170 + {
1.171 + if (m_locked) throw lock_error();
1.172 + lock_ops<TimedMutex>::lock(m_mutex);
1.173 + m_locked = true;
1.174 + }
1.175 + bool try_lock()
1.176 + {
1.177 + if (m_locked) throw lock_error();
1.178 + return (m_locked = lock_ops<TimedMutex>::trylock(m_mutex));
1.179 + }
1.180 + bool timed_lock(const xtime& xt)
1.181 + {
1.182 + if (m_locked) throw lock_error();
1.183 + return (m_locked = lock_ops<TimedMutex>::timedlock(m_mutex, xt));
1.184 + }
1.185 + void unlock()
1.186 + {
1.187 + if (!m_locked) throw lock_error();
1.188 + lock_ops<TimedMutex>::unlock(m_mutex);
1.189 + m_locked = false;
1.190 + }
1.191 +
1.192 + bool locked() const { return m_locked; }
1.193 + operator const void*() const { return m_locked ? this : 0; }
1.194 +
1.195 +private:
1.196 + friend class boost::condition;
1.197 +
1.198 + TimedMutex& m_mutex;
1.199 + bool m_locked;
1.200 +};
1.201 +
1.202 +} // namespace thread
1.203 +} // namespace detail
1.204 +} // namespace boost
1.205 +
1.206 +#endif // BOOST_XLOCK_WEK070601_HPP
1.207 +
1.208 +// Change Log:
1.209 +// 8 Feb 01 WEKEMPF Initial version.
1.210 +// 22 May 01 WEKEMPF Modified to use xtime for time outs.
1.211 +// 30 Jul 01 WEKEMPF Moved lock types into boost::detail::thread. Renamed
1.212 +// some types. Added locked() methods.