diff options
Diffstat (limited to 'src/base/mutex_test.cc')
-rw-r--r-- | src/base/mutex_test.cc | 173 |
1 files changed, 0 insertions, 173 deletions
diff --git a/src/base/mutex_test.cc b/src/base/mutex_test.cc deleted file mode 100644 index 1af8e0ab99..0000000000 --- a/src/base/mutex_test.cc +++ /dev/null @@ -1,173 +0,0 @@ -/* - * Copyright (C) 2012 The Android Open Source Project - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include "mutex.h" - -#include "common_test.h" - -namespace art { - -class MutexTest : public CommonTest {}; - -struct MutexTester { - static void AssertDepth(Mutex& mu, uint32_t expected_depth) { - ASSERT_EQ(expected_depth, mu.GetDepth()); - - // This test is single-threaded, so we also know _who_ should hold the lock. - if (expected_depth == 0) { - mu.AssertNotHeld(Thread::Current()); - } else { - mu.AssertHeld(Thread::Current()); - } - } -}; - -TEST_F(MutexTest, LockUnlock) { - Mutex mu("test mutex"); - MutexTester::AssertDepth(mu, 0U); - mu.Lock(Thread::Current()); - MutexTester::AssertDepth(mu, 1U); - mu.Unlock(Thread::Current()); - MutexTester::AssertDepth(mu, 0U); -} - -// GCC has trouble with our mutex tests, so we have to turn off thread safety analysis. -static void TryLockUnlockTest() NO_THREAD_SAFETY_ANALYSIS { - Mutex mu("test mutex"); - MutexTester::AssertDepth(mu, 0U); - ASSERT_TRUE(mu.TryLock(Thread::Current())); - MutexTester::AssertDepth(mu, 1U); - mu.Unlock(Thread::Current()); - MutexTester::AssertDepth(mu, 0U); -} - -TEST_F(MutexTest, TryLockUnlock) { - TryLockUnlockTest(); -} - -// GCC has trouble with our mutex tests, so we have to turn off thread safety analysis. -static void RecursiveLockUnlockTest() NO_THREAD_SAFETY_ANALYSIS { - Mutex mu("test mutex", kDefaultMutexLevel, true); - MutexTester::AssertDepth(mu, 0U); - mu.Lock(Thread::Current()); - MutexTester::AssertDepth(mu, 1U); - mu.Lock(Thread::Current()); - MutexTester::AssertDepth(mu, 2U); - mu.Unlock(Thread::Current()); - MutexTester::AssertDepth(mu, 1U); - mu.Unlock(Thread::Current()); - MutexTester::AssertDepth(mu, 0U); -} - -TEST_F(MutexTest, RecursiveLockUnlock) { - RecursiveLockUnlockTest(); -} - -// GCC has trouble with our mutex tests, so we have to turn off thread safety analysis. -static void RecursiveTryLockUnlockTest() NO_THREAD_SAFETY_ANALYSIS { - Mutex mu("test mutex", kDefaultMutexLevel, true); - MutexTester::AssertDepth(mu, 0U); - ASSERT_TRUE(mu.TryLock(Thread::Current())); - MutexTester::AssertDepth(mu, 1U); - ASSERT_TRUE(mu.TryLock(Thread::Current())); - MutexTester::AssertDepth(mu, 2U); - mu.Unlock(Thread::Current()); - MutexTester::AssertDepth(mu, 1U); - mu.Unlock(Thread::Current()); - MutexTester::AssertDepth(mu, 0U); -} - -TEST_F(MutexTest, RecursiveTryLockUnlock) { - RecursiveTryLockUnlockTest(); -} - - -struct RecursiveLockWait { - explicit RecursiveLockWait() - : mu("test mutex", kDefaultMutexLevel, true), cv("test condition variable", mu) { - } - - static void* Callback(void* arg) { - RecursiveLockWait* state = reinterpret_cast<RecursiveLockWait*>(arg); - state->mu.Lock(Thread::Current()); - state->cv.Signal(Thread::Current()); - state->mu.Unlock(Thread::Current()); - return NULL; - } - - Mutex mu; - ConditionVariable cv; -}; - -// GCC has trouble with our mutex tests, so we have to turn off thread safety analysis. -static void RecursiveLockWaitTest() NO_THREAD_SAFETY_ANALYSIS { - RecursiveLockWait state; - state.mu.Lock(Thread::Current()); - state.mu.Lock(Thread::Current()); - - pthread_t pthread; - int pthread_create_result = pthread_create(&pthread, NULL, RecursiveLockWait::Callback, &state); - ASSERT_EQ(0, pthread_create_result); - - state.cv.Wait(Thread::Current()); - - state.mu.Unlock(Thread::Current()); - state.mu.Unlock(Thread::Current()); - EXPECT_EQ(pthread_join(pthread, NULL), 0); -} - -// This ensures we don't hang when waiting on a recursively locked mutex, -// which is not supported with bare pthread_mutex_t. -TEST_F(MutexTest, RecursiveLockWait) { - RecursiveLockWaitTest(); -} - -TEST_F(MutexTest, SharedLockUnlock) { - ReaderWriterMutex mu("test rwmutex"); - mu.AssertNotHeld(Thread::Current()); - mu.AssertNotExclusiveHeld(Thread::Current()); - mu.SharedLock(Thread::Current()); - mu.AssertSharedHeld(Thread::Current()); - mu.AssertNotExclusiveHeld(Thread::Current()); - mu.SharedUnlock(Thread::Current()); - mu.AssertNotHeld(Thread::Current()); -} - -TEST_F(MutexTest, ExclusiveLockUnlock) { - ReaderWriterMutex mu("test rwmutex"); - mu.AssertNotHeld(Thread::Current()); - mu.ExclusiveLock(Thread::Current()); - mu.AssertSharedHeld(Thread::Current()); - mu.AssertExclusiveHeld(Thread::Current()); - mu.ExclusiveUnlock(Thread::Current()); - mu.AssertNotHeld(Thread::Current()); -} - -// GCC has trouble with our mutex tests, so we have to turn off thread safety analysis. -static void SharedTryLockUnlockTest() NO_THREAD_SAFETY_ANALYSIS { - ReaderWriterMutex mu("test rwmutex"); - mu.AssertNotHeld(Thread::Current()); - ASSERT_TRUE(mu.SharedTryLock(Thread::Current())); - mu.AssertSharedHeld(Thread::Current()); - mu.SharedUnlock(Thread::Current()); - mu.AssertNotHeld(Thread::Current()); -} - -TEST_F(MutexTest, SharedTryLockUnlock) { - SharedTryLockUnlockTest(); -} - -} // namespace art |