diff options
Diffstat (limited to 'cppe/include/IceE/StaticMutex.h')
| -rw-r--r-- | cppe/include/IceE/StaticMutex.h | 265 |
1 files changed, 0 insertions, 265 deletions
diff --git a/cppe/include/IceE/StaticMutex.h b/cppe/include/IceE/StaticMutex.h deleted file mode 100644 index dd622904436..00000000000 --- a/cppe/include/IceE/StaticMutex.h +++ /dev/null @@ -1,265 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved. -// -// This copy of Ice-E is licensed to you under the terms described in the -// ICEE_LICENSE file included in this distribution. -// -// ********************************************************************** - -#ifndef ICEE_STATIC_MUTEX_H -#define ICEE_STATIC_MUTEX_H - -#include <IceE/Config.h> -#include <IceE/Lock.h> -#include <IceE/ThreadException.h> - -#if defined(_MSC_VER) && (_MSC_VER < 1300) -// -// Old versions of the Platform SDK don't have InterlockedCompareExchangePointer -// -# ifndef InterlockedCompareExchangePointer -# define InterlockedCompareExchangePointer(Destination, ExChange, Comperand) \ - InterlockedCompareExchange(Destination, ExChange, Comperand) -# endif -#endif - -namespace IceUtil -{ - -// -// Forward declaration for friend. -// -class Cond; - -// -// Simple non-recursive Mutex implementation. -// These mutexes are POD types (see ISO C++ 9(4) and 8.5.1) and must be -// initialized statically using ICE_STATIC_MUTEX_INITIALIZER. -// -class StaticMutex -{ -public: - - // - // Lock & TryLock typedefs. - // - typedef LockT<StaticMutex> Lock; - typedef TryLockT<StaticMutex> TryLock; - - // - // Note that lock/tryLock & unlock in general should not be used - // directly. Instead use Lock & TryLock. - // - void lock() const; - - // - // Returns true if the lock was acquired, and false otherwise. - // - bool tryLock() const; - - void unlock() const; - -#ifdef _WIN32 -# if defined(_WIN32_WINNT) && _WIN32_WINNT >= 0x0400 - mutable CRITICAL_SECTION* _mutex; -# else -# error Ice-E for Windows requires fully functional critical sections -# endif -#else - mutable pthread_mutex_t _mutex; -#endif - -#ifndef _MSC_VER -// COMPILERBUG -// VC++ considers that aggregates should not have private members ... -// even if it's just functions. -private: -#endif - - // - // LockState and the lock/unlock variations are for use by the - // Condition variable implementation. - // -#ifdef _WIN32 - struct LockState - { - }; -#else - struct LockState - { - pthread_mutex_t* mutex; - }; -#endif - - void unlock(LockState&) const; - void lock(LockState&) const; - -#ifdef _WIN32 - inline bool initialized() const; - ICE_API void initialize() const; -#endif - -#ifndef _MSC_VER - friend class Cond; -#endif - -}; - -#ifdef _WIN32 -# define ICE_STATIC_MUTEX_INITIALIZER { false } -#else -# define ICE_STATIC_MUTEX_INITIALIZER { PTHREAD_MUTEX_INITIALIZER } -#endif - - -// -// A "shared" global mutex that can be used for very simple tasks -// which should not lock any other mutexes. -// -extern ICE_API StaticMutex globalMutex; - -// -// For performance reasons the following functions are inlined. -// - -#ifdef _WIN32 - -inline bool -StaticMutex::initialized() const -{ - // - // Read mutex and then inserts a memory barrier to ensure we can't - // see tmp != 0 before we see the initialized object - // - void* tmp = _mutex; - return InterlockedCompareExchangePointer(reinterpret_cast<void**>(&tmp), 0, 0) != 0; -} - -inline void -StaticMutex::lock() const -{ - if(!initialized()) - { - initialize(); - } - EnterCriticalSection(_mutex); -#ifndef _WIN32_WCE - assert(_mutex->RecursionCount == 1); -#endif -} - -inline bool -StaticMutex::tryLock() const -{ - if(!initialized()) - { - initialize(); - } - if(!TryEnterCriticalSection(_mutex)) - { - return false; - } -#ifndef _WIN32_WCE - if(_mutex->RecursionCount > 1) - { - LeaveCriticalSection(_mutex); - throw ThreadLockedException(__FILE__, __LINE__); - } -#endif - return true; -} - -inline void -StaticMutex::unlock() const -{ - assert(_mutex != 0); -#ifndef _WIN32_WCE - assert(_mutex->RecursionCount == 1); -#endif - LeaveCriticalSection(_mutex); -} - -inline void -StaticMutex::unlock(LockState&) const -{ - assert(_mutex != 0); -#ifndef _WIN32_WCE - assert(_mutex->RecursionCount == 1); -#endif - LeaveCriticalSection(_mutex); -} - -inline void -StaticMutex::lock(LockState&) const -{ - if(!initialized()) - { - initialize(); - } - EnterCriticalSection(_mutex); -} - -#else - -inline void -StaticMutex::lock() const -{ - int rc = pthread_mutex_lock(&_mutex); - if(rc != 0) - { - if(rc == EDEADLK) - { - throw ThreadLockedException(__FILE__, __LINE__); - } - else - { - throw ThreadSyscallException(__FILE__, __LINE__, rc); - } - } -} - -inline bool -StaticMutex::tryLock() const -{ - int rc = pthread_mutex_trylock(&_mutex); - if(rc != 0 && rc != EBUSY) - { - if(rc == EDEADLK) - { - throw ThreadLockedException(__FILE__, __LINE__); - } - else - { - throw ThreadSyscallException(__FILE__, __LINE__, rc); - } - } - return (rc == 0); -} - -inline void -StaticMutex::unlock() const -{ - int rc = pthread_mutex_unlock(&_mutex); - if(rc != 0) - { - throw ThreadSyscallException(__FILE__, __LINE__, rc); - } -} - -inline void -StaticMutex::unlock(LockState& state) const -{ - state.mutex = &_mutex; -} - -inline void -StaticMutex::lock(LockState&) const -{ -} - -#endif - -} // End namespace Ice - -#endif |