summaryrefslogtreecommitdiff
path: root/cppe/test/IceE/thread/MutexTest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cppe/test/IceE/thread/MutexTest.cpp')
-rw-r--r--cppe/test/IceE/thread/MutexTest.cpp160
1 files changed, 0 insertions, 160 deletions
diff --git a/cppe/test/IceE/thread/MutexTest.cpp b/cppe/test/IceE/thread/MutexTest.cpp
deleted file mode 100644
index dfca515c716..00000000000
--- a/cppe/test/IceE/thread/MutexTest.cpp
+++ /dev/null
@@ -1,160 +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.
-//
-// **********************************************************************
-
-#include <IceE/IceE.h>
-
-#include <MutexTest.h>
-#include <TestCommon.h>
-
-using namespace std;
-using namespace IceUtil;
-
-static const string mutexTestName("mutex");
-
-class MutexTestThread : public Thread
-{
-public:
-
- MutexTestThread(Mutex& m) :
- _mutex(m),
- _tryLock(false)
- {
- }
-
- virtual void run()
- {
- Mutex::TryLock tlock(_mutex);
- test(!tlock.acquired());
-
- {
- Mutex::Lock lock(_tryLockMutex);
- _tryLock = true;
- }
- _tryLockCond.signal();
-
- Mutex::Lock lock(_mutex);
- }
-
- void
- waitTryLock()
- {
- Mutex::Lock lock(_tryLockMutex);
- while(!_tryLock)
- {
- _tryLockCond.wait(lock);
- }
- }
-
-private:
-
- Mutex& _mutex;
- bool _tryLock;
- //
- // Use native Condition variable here, not Monitor.
- //
- Cond _tryLockCond;
- Mutex _tryLockMutex;
-};
-
-typedef Handle<MutexTestThread> MutexTestThreadPtr;
-
-MutexTest::MutexTest() :
- TestBase(mutexTestName)
-{
-}
-
-void
-MutexTest::run()
-{
- Mutex mutex;
- MutexTestThreadPtr t;
- ThreadControl control;
-
- {
- Mutex::Lock lock(mutex);
-
- // LockT testing:
- //
-
- test(lock.acquired());
-
- try
- {
- lock.acquire();
- test(false);
- }
- catch(const ThreadLockedException&)
- {
- // Expected
- }
-
- try
- {
- lock.tryAcquire();
- test(false);
- }
- catch(const ThreadLockedException&)
- {
- // Expected
- }
-
- test(lock.acquired());
- lock.release();
- test(!lock.acquired());
-
- try
- {
- lock.release();
- test(false);
- }
- catch(const ThreadLockedException&)
- {
- // Expected
- }
-
- Mutex::TryLock lock2(mutex);
- try
- {
- test(lock.tryAcquire() == false);
- }
- catch(const IceUtil::ThreadLockedException&)
- {
- }
- lock2.release();
- test(lock.tryAcquire() == true);
- test(lock.acquired());
-
- // Deadlock testing
- //
-
-#if !defined(NDEBUG) && !defined(_WIN32)
- try
- {
- Mutex::Lock lock3(mutex);
- test(false);
- }
- catch(const ThreadLockedException&)
- {
- }
-#endif
-
- // TEST: Start thread, try to acquire the mutex.
- t = new MutexTestThread(mutex);
- control = t->start();
-
- // TEST: Wait until the tryLock has been tested.
- t->waitTryLock();
- }
-
- //
- // TEST: Once the mutex has been released, the thread should
- // acquire the mutex and then terminate.
- //
- control.join();
-}