Abseil Common Libraries (C++) (grcp 依赖)
https://abseil.io/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1532 lines
47 KiB
1532 lines
47 KiB
// Copyright 2017 The Abseil Authors. |
|
// |
|
// 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 "absl/synchronization/mutex.h" |
|
|
|
#ifdef WIN32 |
|
#include <windows.h> |
|
#endif |
|
|
|
#include <algorithm> |
|
#include <atomic> |
|
#include <cstdlib> |
|
#include <functional> |
|
#include <memory> |
|
#include <random> |
|
#include <string> |
|
#include <thread> // NOLINT(build/c++11) |
|
#include <vector> |
|
|
|
#include "gtest/gtest.h" |
|
#include "absl/base/internal/raw_logging.h" |
|
#include "absl/base/internal/sysinfo.h" |
|
#include "absl/memory/memory.h" |
|
#include "absl/synchronization/internal/thread_pool.h" |
|
#include "absl/time/clock.h" |
|
#include "absl/time/time.h" |
|
|
|
namespace { |
|
|
|
// TODO(dmauro): Replace with a commandline flag. |
|
static constexpr bool kExtendedTest = false; |
|
|
|
std::unique_ptr<absl::synchronization_internal::ThreadPool> CreatePool( |
|
int threads) { |
|
return absl::make_unique<absl::synchronization_internal::ThreadPool>(threads); |
|
} |
|
|
|
std::unique_ptr<absl::synchronization_internal::ThreadPool> |
|
CreateDefaultPool() { |
|
return CreatePool(kExtendedTest ? 32 : 10); |
|
} |
|
|
|
// Hack to schedule a function to run on a thread pool thread after a |
|
// duration has elapsed. |
|
static void ScheduleAfter(absl::synchronization_internal::ThreadPool *tp, |
|
const std::function<void()> &func, |
|
absl::Duration after) { |
|
tp->Schedule([func, after] { |
|
absl::SleepFor(after); |
|
func(); |
|
}); |
|
} |
|
|
|
struct TestContext { |
|
int iterations; |
|
int threads; |
|
int g0; // global 0 |
|
int g1; // global 1 |
|
absl::Mutex mu; |
|
absl::CondVar cv; |
|
}; |
|
|
|
// To test whether the invariant check call occurs |
|
static std::atomic<bool> invariant_checked; |
|
|
|
static bool GetInvariantChecked() { |
|
return invariant_checked.load(std::memory_order_relaxed); |
|
} |
|
|
|
static void SetInvariantChecked(bool new_value) { |
|
invariant_checked.store(new_value, std::memory_order_relaxed); |
|
} |
|
|
|
static void CheckSumG0G1(void *v) { |
|
TestContext *cxt = static_cast<TestContext *>(v); |
|
ABSL_RAW_CHECK(cxt->g0 == -cxt->g1, "Error in CheckSumG0G1"); |
|
SetInvariantChecked(true); |
|
} |
|
|
|
static void TestMu(TestContext *cxt, int c) { |
|
SetInvariantChecked(false); |
|
cxt->mu.EnableInvariantDebugging(CheckSumG0G1, cxt); |
|
for (int i = 0; i != cxt->iterations; i++) { |
|
absl::MutexLock l(&cxt->mu); |
|
int a = cxt->g0 + 1; |
|
cxt->g0 = a; |
|
cxt->g1--; |
|
} |
|
} |
|
|
|
static void TestTry(TestContext *cxt, int c) { |
|
SetInvariantChecked(false); |
|
cxt->mu.EnableInvariantDebugging(CheckSumG0G1, cxt); |
|
for (int i = 0; i != cxt->iterations; i++) { |
|
do { |
|
std::this_thread::yield(); |
|
} while (!cxt->mu.TryLock()); |
|
int a = cxt->g0 + 1; |
|
cxt->g0 = a; |
|
cxt->g1--; |
|
cxt->mu.Unlock(); |
|
} |
|
} |
|
|
|
static void TestR20ms(TestContext *cxt, int c) { |
|
for (int i = 0; i != cxt->iterations; i++) { |
|
absl::ReaderMutexLock l(&cxt->mu); |
|
absl::SleepFor(absl::Milliseconds(20)); |
|
cxt->mu.AssertReaderHeld(); |
|
} |
|
} |
|
|
|
static void TestRW(TestContext *cxt, int c) { |
|
SetInvariantChecked(false); |
|
cxt->mu.EnableInvariantDebugging(CheckSumG0G1, cxt); |
|
if ((c & 1) == 0) { |
|
for (int i = 0; i != cxt->iterations; i++) { |
|
absl::WriterMutexLock l(&cxt->mu); |
|
cxt->g0++; |
|
cxt->g1--; |
|
cxt->mu.AssertHeld(); |
|
cxt->mu.AssertReaderHeld(); |
|
} |
|
} else { |
|
for (int i = 0; i != cxt->iterations; i++) { |
|
absl::ReaderMutexLock l(&cxt->mu); |
|
ABSL_RAW_CHECK(cxt->g0 == -cxt->g1, "Error in TestRW"); |
|
cxt->mu.AssertReaderHeld(); |
|
} |
|
} |
|
} |
|
|
|
struct MyContext { |
|
int target; |
|
TestContext *cxt; |
|
bool MyTurn(); |
|
}; |
|
|
|
bool MyContext::MyTurn() { |
|
TestContext *cxt = this->cxt; |
|
return cxt->g0 == this->target || cxt->g0 == cxt->iterations; |
|
} |
|
|
|
static void TestAwait(TestContext *cxt, int c) { |
|
MyContext mc; |
|
mc.target = c; |
|
mc.cxt = cxt; |
|
absl::MutexLock l(&cxt->mu); |
|
cxt->mu.AssertHeld(); |
|
while (cxt->g0 < cxt->iterations) { |
|
cxt->mu.Await(absl::Condition(&mc, &MyContext::MyTurn)); |
|
ABSL_RAW_CHECK(mc.MyTurn(), "Error in TestAwait"); |
|
cxt->mu.AssertHeld(); |
|
if (cxt->g0 < cxt->iterations) { |
|
int a = cxt->g0 + 1; |
|
cxt->g0 = a; |
|
mc.target += cxt->threads; |
|
} |
|
} |
|
} |
|
|
|
static void TestSignalAll(TestContext *cxt, int c) { |
|
int target = c; |
|
absl::MutexLock l(&cxt->mu); |
|
cxt->mu.AssertHeld(); |
|
while (cxt->g0 < cxt->iterations) { |
|
while (cxt->g0 != target && cxt->g0 != cxt->iterations) { |
|
cxt->cv.Wait(&cxt->mu); |
|
} |
|
if (cxt->g0 < cxt->iterations) { |
|
int a = cxt->g0 + 1; |
|
cxt->g0 = a; |
|
cxt->cv.SignalAll(); |
|
target += cxt->threads; |
|
} |
|
} |
|
} |
|
|
|
static void TestSignal(TestContext *cxt, int c) { |
|
ABSL_RAW_CHECK(cxt->threads == 2, "TestSignal should use 2 threads"); |
|
int target = c; |
|
absl::MutexLock l(&cxt->mu); |
|
cxt->mu.AssertHeld(); |
|
while (cxt->g0 < cxt->iterations) { |
|
while (cxt->g0 != target && cxt->g0 != cxt->iterations) { |
|
cxt->cv.Wait(&cxt->mu); |
|
} |
|
if (cxt->g0 < cxt->iterations) { |
|
int a = cxt->g0 + 1; |
|
cxt->g0 = a; |
|
cxt->cv.Signal(); |
|
target += cxt->threads; |
|
} |
|
} |
|
} |
|
|
|
static void TestCVTimeout(TestContext *cxt, int c) { |
|
int target = c; |
|
absl::MutexLock l(&cxt->mu); |
|
cxt->mu.AssertHeld(); |
|
while (cxt->g0 < cxt->iterations) { |
|
while (cxt->g0 != target && cxt->g0 != cxt->iterations) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(100)); |
|
} |
|
if (cxt->g0 < cxt->iterations) { |
|
int a = cxt->g0 + 1; |
|
cxt->g0 = a; |
|
cxt->cv.SignalAll(); |
|
target += cxt->threads; |
|
} |
|
} |
|
} |
|
|
|
static bool G0GE2(TestContext *cxt) { return cxt->g0 >= 2; } |
|
|
|
static void TestTime(TestContext *cxt, int c, bool use_cv) { |
|
ABSL_RAW_CHECK(cxt->iterations == 1, "TestTime should only use 1 iteration"); |
|
ABSL_RAW_CHECK(cxt->threads > 2, "TestTime should use more than 2 threads"); |
|
const bool kFalse = false; |
|
absl::Condition false_cond(&kFalse); |
|
absl::Condition g0ge2(G0GE2, cxt); |
|
if (c == 0) { |
|
absl::MutexLock l(&cxt->mu); |
|
|
|
absl::Time start = absl::Now(); |
|
if (use_cv) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(1)); |
|
} else { |
|
ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), |
|
"TestTime failed"); |
|
} |
|
absl::Duration elapsed = absl::Now() - start; |
|
ABSL_RAW_CHECK( |
|
absl::Seconds(0.9) <= elapsed && elapsed <= absl::Seconds(2.0), |
|
"TestTime failed"); |
|
ABSL_RAW_CHECK(cxt->g0 == 1, "TestTime failed"); |
|
|
|
start = absl::Now(); |
|
if (use_cv) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(1)); |
|
} else { |
|
ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), |
|
"TestTime failed"); |
|
} |
|
elapsed = absl::Now() - start; |
|
ABSL_RAW_CHECK( |
|
absl::Seconds(0.9) <= elapsed && elapsed <= absl::Seconds(2.0), |
|
"TestTime failed"); |
|
cxt->g0++; |
|
if (use_cv) { |
|
cxt->cv.Signal(); |
|
} |
|
|
|
start = absl::Now(); |
|
if (use_cv) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(4)); |
|
} else { |
|
ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(4)), |
|
"TestTime failed"); |
|
} |
|
elapsed = absl::Now() - start; |
|
ABSL_RAW_CHECK( |
|
absl::Seconds(3.9) <= elapsed && elapsed <= absl::Seconds(6.0), |
|
"TestTime failed"); |
|
ABSL_RAW_CHECK(cxt->g0 >= 3, "TestTime failed"); |
|
|
|
start = absl::Now(); |
|
if (use_cv) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(1)); |
|
} else { |
|
ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), |
|
"TestTime failed"); |
|
} |
|
elapsed = absl::Now() - start; |
|
ABSL_RAW_CHECK( |
|
absl::Seconds(0.9) <= elapsed && elapsed <= absl::Seconds(2.0), |
|
"TestTime failed"); |
|
if (use_cv) { |
|
cxt->cv.SignalAll(); |
|
} |
|
|
|
start = absl::Now(); |
|
if (use_cv) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(1)); |
|
} else { |
|
ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), |
|
"TestTime failed"); |
|
} |
|
elapsed = absl::Now() - start; |
|
ABSL_RAW_CHECK(absl::Seconds(0.9) <= elapsed && |
|
elapsed <= absl::Seconds(2.0), "TestTime failed"); |
|
ABSL_RAW_CHECK(cxt->g0 == cxt->threads, "TestTime failed"); |
|
|
|
} else if (c == 1) { |
|
absl::MutexLock l(&cxt->mu); |
|
const absl::Time start = absl::Now(); |
|
if (use_cv) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Milliseconds(500)); |
|
} else { |
|
ABSL_RAW_CHECK( |
|
!cxt->mu.AwaitWithTimeout(false_cond, absl::Milliseconds(500)), |
|
"TestTime failed"); |
|
} |
|
const absl::Duration elapsed = absl::Now() - start; |
|
ABSL_RAW_CHECK( |
|
absl::Seconds(0.4) <= elapsed && elapsed <= absl::Seconds(0.9), |
|
"TestTime failed"); |
|
cxt->g0++; |
|
} else if (c == 2) { |
|
absl::MutexLock l(&cxt->mu); |
|
if (use_cv) { |
|
while (cxt->g0 < 2) { |
|
cxt->cv.WaitWithTimeout(&cxt->mu, absl::Seconds(100)); |
|
} |
|
} else { |
|
ABSL_RAW_CHECK(cxt->mu.AwaitWithTimeout(g0ge2, absl::Seconds(100)), |
|
"TestTime failed"); |
|
} |
|
cxt->g0++; |
|
} else { |
|
absl::MutexLock l(&cxt->mu); |
|
if (use_cv) { |
|
while (cxt->g0 < 2) { |
|
cxt->cv.Wait(&cxt->mu); |
|
} |
|
} else { |
|
cxt->mu.Await(g0ge2); |
|
} |
|
cxt->g0++; |
|
} |
|
} |
|
|
|
static void TestMuTime(TestContext *cxt, int c) { TestTime(cxt, c, false); } |
|
|
|
static void TestCVTime(TestContext *cxt, int c) { TestTime(cxt, c, true); } |
|
|
|
static void EndTest(int *c0, int *c1, absl::Mutex *mu, absl::CondVar *cv, |
|
const std::function<void(int)>& cb) { |
|
mu->Lock(); |
|
int c = (*c0)++; |
|
mu->Unlock(); |
|
cb(c); |
|
absl::MutexLock l(mu); |
|
(*c1)++; |
|
cv->Signal(); |
|
} |
|
|
|
// Basis for the parameterized tests configured below. |
|
static int RunTest(void (*test)(TestContext *cxt, int), int threads, |
|
int iterations, int operations) { |
|
TestContext cxt; |
|
absl::Mutex mu2; |
|
absl::CondVar cv2; |
|
int c0; |
|
int c1; |
|
|
|
// run with large thread count for full test and to get timing |
|
|
|
#if !defined(ABSL_MUTEX_ENABLE_INVARIANT_DEBUGGING_NOT_IMPLEMENTED) |
|
absl::EnableMutexInvariantDebugging(false); |
|
#endif |
|
c0 = 0; |
|
c1 = 0; |
|
cxt.g0 = 0; |
|
cxt.g1 = 0; |
|
cxt.iterations = iterations; |
|
cxt.threads = threads; |
|
absl::synchronization_internal::ThreadPool tp(threads); |
|
for (int i = 0; i != threads; i++) { |
|
tp.Schedule(std::bind(&EndTest, &c0, &c1, &mu2, &cv2, |
|
std::function<void(int)>( |
|
std::bind(test, &cxt, std::placeholders::_1)))); |
|
} |
|
mu2.Lock(); |
|
while (c1 != threads) { |
|
cv2.Wait(&mu2); |
|
} |
|
mu2.Unlock(); |
|
int saved_g0 = cxt.g0; |
|
|
|
// run again with small number of iterations to test invariant checking |
|
|
|
#if !defined(ABSL_MUTEX_ENABLE_INVARIANT_DEBUGGING_NOT_IMPLEMENTED) |
|
absl::EnableMutexInvariantDebugging(true); |
|
#endif |
|
SetInvariantChecked(true); |
|
c0 = 0; |
|
c1 = 0; |
|
cxt.g0 = 0; |
|
cxt.g1 = 0; |
|
cxt.iterations = (iterations > 10 ? 10 : iterations); |
|
cxt.threads = threads; |
|
for (int i = 0; i != threads; i++) { |
|
tp.Schedule(std::bind(&EndTest, &c0, &c1, &mu2, &cv2, |
|
std::function<void(int)>( |
|
std::bind(test, &cxt, std::placeholders::_1)))); |
|
} |
|
mu2.Lock(); |
|
while (c1 != threads) { |
|
cv2.Wait(&mu2); |
|
} |
|
mu2.Unlock(); |
|
#if !defined(ABSL_MUTEX_ENABLE_INVARIANT_DEBUGGING_NOT_IMPLEMENTED) |
|
ABSL_RAW_CHECK(GetInvariantChecked(), "Invariant not checked"); |
|
#endif |
|
|
|
return saved_g0; |
|
} |
|
|
|
// -------------------------------------------------------- |
|
// Test for fix of bug in TryRemove() |
|
struct TimeoutBugStruct { |
|
absl::Mutex mu; |
|
bool a; |
|
int a_waiter_count; |
|
}; |
|
|
|
static void WaitForA(TimeoutBugStruct *x) { |
|
x->mu.LockWhen(absl::Condition(&x->a)); |
|
x->a_waiter_count--; |
|
x->mu.Unlock(); |
|
} |
|
|
|
static bool NoAWaiters(TimeoutBugStruct *x) { return x->a_waiter_count == 0; } |
|
|
|
// Test that a CondVar.Wait(&mutex) can un-block a call to mutex.Await() in |
|
// another thread. |
|
TEST(Mutex, CondVarWaitSignalsAwait) { |
|
// Use a struct so the lock annotations apply. |
|
struct { |
|
absl::Mutex barrier_mu; |
|
bool barrier GUARDED_BY(barrier_mu) = false; |
|
|
|
absl::Mutex release_mu; |
|
bool release GUARDED_BY(release_mu) = false; |
|
absl::CondVar released_cv; |
|
} state; |
|
|
|
auto pool = CreateDefaultPool(); |
|
|
|
// Thread A. Sets barrier, waits for release using Mutex::Await, then |
|
// signals released_cv. |
|
pool->Schedule([&state] { |
|
state.release_mu.Lock(); |
|
|
|
state.barrier_mu.Lock(); |
|
state.barrier = true; |
|
state.barrier_mu.Unlock(); |
|
|
|
state.release_mu.Await(absl::Condition(&state.release)); |
|
state.released_cv.Signal(); |
|
state.release_mu.Unlock(); |
|
}); |
|
|
|
state.barrier_mu.LockWhen(absl::Condition(&state.barrier)); |
|
state.barrier_mu.Unlock(); |
|
state.release_mu.Lock(); |
|
// Thread A is now blocked on release by way of Mutex::Await(). |
|
|
|
// Set release. Calling released_cv.Wait() should un-block thread A, |
|
// which will signal released_cv. If not, the test will hang. |
|
state.release = true; |
|
state.released_cv.Wait(&state.release_mu); |
|
state.release_mu.Unlock(); |
|
} |
|
|
|
// Test that a CondVar.WaitWithTimeout(&mutex) can un-block a call to |
|
// mutex.Await() in another thread. |
|
TEST(Mutex, CondVarWaitWithTimeoutSignalsAwait) { |
|
// Use a struct so the lock annotations apply. |
|
struct { |
|
absl::Mutex barrier_mu; |
|
bool barrier GUARDED_BY(barrier_mu) = false; |
|
|
|
absl::Mutex release_mu; |
|
bool release GUARDED_BY(release_mu) = false; |
|
absl::CondVar released_cv; |
|
} state; |
|
|
|
auto pool = CreateDefaultPool(); |
|
|
|
// Thread A. Sets barrier, waits for release using Mutex::Await, then |
|
// signals released_cv. |
|
pool->Schedule([&state] { |
|
state.release_mu.Lock(); |
|
|
|
state.barrier_mu.Lock(); |
|
state.barrier = true; |
|
state.barrier_mu.Unlock(); |
|
|
|
state.release_mu.Await(absl::Condition(&state.release)); |
|
state.released_cv.Signal(); |
|
state.release_mu.Unlock(); |
|
}); |
|
|
|
state.barrier_mu.LockWhen(absl::Condition(&state.barrier)); |
|
state.barrier_mu.Unlock(); |
|
state.release_mu.Lock(); |
|
// Thread A is now blocked on release by way of Mutex::Await(). |
|
|
|
// Set release. Calling released_cv.Wait() should un-block thread A, |
|
// which will signal released_cv. If not, the test will hang. |
|
state.release = true; |
|
EXPECT_TRUE( |
|
!state.released_cv.WaitWithTimeout(&state.release_mu, absl::Seconds(10))) |
|
<< "; Unrecoverable test failure: CondVar::WaitWithTimeout did not " |
|
"unblock the absl::Mutex::Await call in another thread."; |
|
|
|
state.release_mu.Unlock(); |
|
} |
|
|
|
// Test for regression of a bug in loop of TryRemove() |
|
TEST(Mutex, MutexTimeoutBug) { |
|
auto tp = CreateDefaultPool(); |
|
|
|
TimeoutBugStruct x; |
|
x.a = false; |
|
x.a_waiter_count = 2; |
|
tp->Schedule(std::bind(&WaitForA, &x)); |
|
tp->Schedule(std::bind(&WaitForA, &x)); |
|
absl::SleepFor(absl::Seconds(1)); // Allow first two threads to hang. |
|
// The skip field of the second will point to the first because there are |
|
// only two. |
|
|
|
// Now cause a thread waiting on an always-false to time out |
|
// This would deadlock when the bug was present. |
|
bool always_false = false; |
|
x.mu.LockWhenWithTimeout(absl::Condition(&always_false), |
|
absl::Milliseconds(500)); |
|
|
|
// if we get here, the bug is not present. Cleanup the state. |
|
|
|
x.a = true; // wakeup the two waiters on A |
|
x.mu.Await(absl::Condition(&NoAWaiters, &x)); // wait for them to exit |
|
x.mu.Unlock(); |
|
} |
|
|
|
struct CondVarWaitDeadlock : testing::TestWithParam<int> { |
|
absl::Mutex mu; |
|
absl::CondVar cv; |
|
bool cond1 = false; |
|
bool cond2 = false; |
|
bool read_lock1; |
|
bool read_lock2; |
|
bool signal_unlocked; |
|
|
|
CondVarWaitDeadlock() { |
|
read_lock1 = GetParam() & (1 << 0); |
|
read_lock2 = GetParam() & (1 << 1); |
|
signal_unlocked = GetParam() & (1 << 2); |
|
} |
|
|
|
void Waiter1() { |
|
if (read_lock1) { |
|
mu.ReaderLock(); |
|
while (!cond1) { |
|
cv.Wait(&mu); |
|
} |
|
mu.ReaderUnlock(); |
|
} else { |
|
mu.Lock(); |
|
while (!cond1) { |
|
cv.Wait(&mu); |
|
} |
|
mu.Unlock(); |
|
} |
|
} |
|
|
|
void Waiter2() { |
|
if (read_lock2) { |
|
mu.ReaderLockWhen(absl::Condition(&cond2)); |
|
mu.ReaderUnlock(); |
|
} else { |
|
mu.LockWhen(absl::Condition(&cond2)); |
|
mu.Unlock(); |
|
} |
|
} |
|
}; |
|
|
|
// Test for a deadlock bug in Mutex::Fer(). |
|
// The sequence of events that lead to the deadlock is: |
|
// 1. waiter1 blocks on cv in read mode (mu bits = 0). |
|
// 2. waiter2 blocks on mu in either mode (mu bits = kMuWait). |
|
// 3. main thread locks mu, sets cond1, unlocks mu (mu bits = kMuWait). |
|
// 4. main thread signals on cv and this eventually calls Mutex::Fer(). |
|
// Currently Fer wakes waiter1 since mu bits = kMuWait (mutex is unlocked). |
|
// Before the bug fix Fer neither woke waiter1 nor queued it on mutex, |
|
// which resulted in deadlock. |
|
TEST_P(CondVarWaitDeadlock, Test) { |
|
auto waiter1 = CreatePool(1); |
|
auto waiter2 = CreatePool(1); |
|
waiter1->Schedule([this] { this->Waiter1(); }); |
|
waiter2->Schedule([this] { this->Waiter2(); }); |
|
|
|
// Wait while threads block (best-effort is fine). |
|
absl::SleepFor(absl::Milliseconds(100)); |
|
|
|
// Wake condwaiter. |
|
mu.Lock(); |
|
cond1 = true; |
|
if (signal_unlocked) { |
|
mu.Unlock(); |
|
cv.Signal(); |
|
} else { |
|
cv.Signal(); |
|
mu.Unlock(); |
|
} |
|
waiter1.reset(); // "join" waiter1 |
|
|
|
// Wake waiter. |
|
mu.Lock(); |
|
cond2 = true; |
|
mu.Unlock(); |
|
waiter2.reset(); // "join" waiter2 |
|
} |
|
|
|
INSTANTIATE_TEST_CASE_P(CondVarWaitDeadlockTest, CondVarWaitDeadlock, |
|
::testing::Range(0, 8), |
|
::testing::PrintToStringParamName()); |
|
|
|
// -------------------------------------------------------- |
|
// Test for fix of bug in DequeueAllWakeable() |
|
// Bug was that if there was more than one waiting reader |
|
// and all should be woken, the most recently blocked one |
|
// would not be. |
|
|
|
struct DequeueAllWakeableBugStruct { |
|
absl::Mutex mu; |
|
absl::Mutex mu2; // protects all fields below |
|
int unfinished_count; // count of unfinished readers; under mu2 |
|
bool done1; // unfinished_count == 0; under mu2 |
|
int finished_count; // count of finished readers, under mu2 |
|
bool done2; // finished_count == 0; under mu2 |
|
}; |
|
|
|
// Test for regression of a bug in loop of DequeueAllWakeable() |
|
static void AcquireAsReader(DequeueAllWakeableBugStruct *x) { |
|
x->mu.ReaderLock(); |
|
x->mu2.Lock(); |
|
x->unfinished_count--; |
|
x->done1 = (x->unfinished_count == 0); |
|
x->mu2.Unlock(); |
|
// make sure that both readers acquired mu before we release it. |
|
absl::SleepFor(absl::Seconds(2)); |
|
x->mu.ReaderUnlock(); |
|
|
|
x->mu2.Lock(); |
|
x->finished_count--; |
|
x->done2 = (x->finished_count == 0); |
|
x->mu2.Unlock(); |
|
} |
|
|
|
// Test for regression of a bug in loop of DequeueAllWakeable() |
|
TEST(Mutex, MutexReaderWakeupBug) { |
|
auto tp = CreateDefaultPool(); |
|
|
|
DequeueAllWakeableBugStruct x; |
|
x.unfinished_count = 2; |
|
x.done1 = false; |
|
x.finished_count = 2; |
|
x.done2 = false; |
|
x.mu.Lock(); // acquire mu exclusively |
|
// queue two thread that will block on reader locks on x.mu |
|
tp->Schedule(std::bind(&AcquireAsReader, &x)); |
|
tp->Schedule(std::bind(&AcquireAsReader, &x)); |
|
absl::SleepFor(absl::Seconds(1)); // give time for reader threads to block |
|
x.mu.Unlock(); // wake them up |
|
|
|
// both readers should finish promptly |
|
EXPECT_TRUE( |
|
x.mu2.LockWhenWithTimeout(absl::Condition(&x.done1), absl::Seconds(10))); |
|
x.mu2.Unlock(); |
|
|
|
EXPECT_TRUE( |
|
x.mu2.LockWhenWithTimeout(absl::Condition(&x.done2), absl::Seconds(10))); |
|
x.mu2.Unlock(); |
|
} |
|
|
|
struct LockWhenTestStruct { |
|
absl::Mutex mu1; |
|
bool cond = false; |
|
|
|
absl::Mutex mu2; |
|
bool waiting = false; |
|
}; |
|
|
|
static bool LockWhenTestIsCond(LockWhenTestStruct* s) { |
|
s->mu2.Lock(); |
|
s->waiting = true; |
|
s->mu2.Unlock(); |
|
return s->cond; |
|
} |
|
|
|
static void LockWhenTestWaitForIsCond(LockWhenTestStruct* s) { |
|
s->mu1.LockWhen(absl::Condition(&LockWhenTestIsCond, s)); |
|
s->mu1.Unlock(); |
|
} |
|
|
|
TEST(Mutex, LockWhen) { |
|
LockWhenTestStruct s; |
|
|
|
std::thread t(LockWhenTestWaitForIsCond, &s); |
|
s.mu2.LockWhen(absl::Condition(&s.waiting)); |
|
s.mu2.Unlock(); |
|
|
|
s.mu1.Lock(); |
|
s.cond = true; |
|
s.mu1.Unlock(); |
|
|
|
t.join(); |
|
} |
|
|
|
// -------------------------------------------------------- |
|
// The following test requires Mutex::ReaderLock to be a real shared |
|
// lock, which is not the case in all builds. |
|
#if !defined(ABSL_MUTEX_READER_LOCK_IS_EXCLUSIVE) |
|
|
|
// Test for fix of bug in UnlockSlow() that incorrectly decremented the reader |
|
// count when putting a thread to sleep waiting for a false condition when the |
|
// lock was not held. |
|
|
|
// For this bug to strike, we make a thread wait on a free mutex with no |
|
// waiters by causing its wakeup condition to be false. Then the |
|
// next two acquirers must be readers. The bug causes the lock |
|
// to be released when one reader unlocks, rather than both. |
|
|
|
struct ReaderDecrementBugStruct { |
|
bool cond; // to delay first thread (under mu) |
|
int done; // reference count (under mu) |
|
absl::Mutex mu; |
|
|
|
bool waiting_on_cond; // under mu2 |
|
bool have_reader_lock; // under mu2 |
|
bool complete; // under mu2 |
|
absl::Mutex mu2; // > mu |
|
}; |
|
|
|
// L >= mu, L < mu_waiting_on_cond |
|
static bool IsCond(void *v) { |
|
ReaderDecrementBugStruct *x = reinterpret_cast<ReaderDecrementBugStruct *>(v); |
|
x->mu2.Lock(); |
|
x->waiting_on_cond = true; |
|
x->mu2.Unlock(); |
|
return x->cond; |
|
} |
|
|
|
// L >= mu |
|
static bool AllDone(void *v) { |
|
ReaderDecrementBugStruct *x = reinterpret_cast<ReaderDecrementBugStruct *>(v); |
|
return x->done == 0; |
|
} |
|
|
|
// L={} |
|
static void WaitForCond(ReaderDecrementBugStruct *x) { |
|
absl::Mutex dummy; |
|
absl::MutexLock l(&dummy); |
|
x->mu.LockWhen(absl::Condition(&IsCond, x)); |
|
x->done--; |
|
x->mu.Unlock(); |
|
} |
|
|
|
// L={} |
|
static void GetReadLock(ReaderDecrementBugStruct *x) { |
|
x->mu.ReaderLock(); |
|
x->mu2.Lock(); |
|
x->have_reader_lock = true; |
|
x->mu2.Await(absl::Condition(&x->complete)); |
|
x->mu2.Unlock(); |
|
x->mu.ReaderUnlock(); |
|
x->mu.Lock(); |
|
x->done--; |
|
x->mu.Unlock(); |
|
} |
|
|
|
// Test for reader counter being decremented incorrectly by waiter |
|
// with false condition. |
|
TEST(Mutex, MutexReaderDecrementBug) NO_THREAD_SAFETY_ANALYSIS { |
|
ReaderDecrementBugStruct x; |
|
x.cond = false; |
|
x.waiting_on_cond = false; |
|
x.have_reader_lock = false; |
|
x.complete = false; |
|
x.done = 2; // initial ref count |
|
|
|
// Run WaitForCond() and wait for it to sleep |
|
std::thread thread1(WaitForCond, &x); |
|
x.mu2.LockWhen(absl::Condition(&x.waiting_on_cond)); |
|
x.mu2.Unlock(); |
|
|
|
// Run GetReadLock(), and wait for it to get the read lock |
|
std::thread thread2(GetReadLock, &x); |
|
x.mu2.LockWhen(absl::Condition(&x.have_reader_lock)); |
|
x.mu2.Unlock(); |
|
|
|
// Get the reader lock ourselves, and release it. |
|
x.mu.ReaderLock(); |
|
x.mu.ReaderUnlock(); |
|
|
|
// The lock should be held in read mode by GetReadLock(). |
|
// If we have the bug, the lock will be free. |
|
x.mu.AssertReaderHeld(); |
|
|
|
// Wake up all the threads. |
|
x.mu2.Lock(); |
|
x.complete = true; |
|
x.mu2.Unlock(); |
|
|
|
// TODO(delesley): turn on analysis once lock upgrading is supported. |
|
// (This call upgrades the lock from shared to exclusive.) |
|
x.mu.Lock(); |
|
x.cond = true; |
|
x.mu.Await(absl::Condition(&AllDone, &x)); |
|
x.mu.Unlock(); |
|
|
|
thread1.join(); |
|
thread2.join(); |
|
} |
|
#endif // !ABSL_MUTEX_READER_LOCK_IS_EXCLUSIVE |
|
|
|
// Test that we correctly handle the situation when a lock is |
|
// held and then destroyed (w/o unlocking). |
|
TEST(Mutex, LockedMutexDestructionBug) NO_THREAD_SAFETY_ANALYSIS { |
|
for (int i = 0; i != 10; i++) { |
|
// Create, lock and destroy 10 locks. |
|
const int kNumLocks = 10; |
|
auto mu = absl::make_unique<absl::Mutex[]>(kNumLocks); |
|
for (int j = 0; j != kNumLocks; j++) { |
|
if ((j % 2) == 0) { |
|
mu[j].WriterLock(); |
|
} else { |
|
mu[j].ReaderLock(); |
|
} |
|
} |
|
} |
|
} |
|
|
|
// -------------------------------------------------------- |
|
// Test for bug with pattern of readers using a condvar. The bug was that if a |
|
// reader went to sleep on a condition variable while one or more other readers |
|
// held the lock, but there were no waiters, the reader count (held in the |
|
// mutex word) would be lost. (This is because Enqueue() had at one time |
|
// always placed the thread on the Mutex queue. Later (CL 4075610), to |
|
// tolerate re-entry into Mutex from a Condition predicate, Enqueue() was |
|
// changed so that it could also place a thread on a condition-variable. This |
|
// introduced the case where Enqueue() returned with an empty queue, and this |
|
// case was handled incorrectly in one place.) |
|
|
|
static void ReaderForReaderOnCondVar(absl::Mutex *mu, absl::CondVar *cv, |
|
int *running) { |
|
std::random_device dev; |
|
std::mt19937 gen(dev()); |
|
std::uniform_int_distribution<int> random_millis(0, 15); |
|
mu->ReaderLock(); |
|
while (*running == 3) { |
|
absl::SleepFor(absl::Milliseconds(random_millis(gen))); |
|
cv->WaitWithTimeout(mu, absl::Milliseconds(random_millis(gen))); |
|
} |
|
mu->ReaderUnlock(); |
|
mu->Lock(); |
|
(*running)--; |
|
mu->Unlock(); |
|
} |
|
|
|
struct True { |
|
template <class... Args> |
|
bool operator()(Args...) const { |
|
return true; |
|
} |
|
}; |
|
|
|
struct DerivedTrue : True {}; |
|
|
|
TEST(Mutex, FunctorCondition) { |
|
{ // Variadic |
|
True f; |
|
EXPECT_TRUE(absl::Condition(&f).Eval()); |
|
} |
|
|
|
{ // Inherited |
|
DerivedTrue g; |
|
EXPECT_TRUE(absl::Condition(&g).Eval()); |
|
} |
|
|
|
{ // lambda |
|
int value = 3; |
|
auto is_zero = [&value] { return value == 0; }; |
|
absl::Condition c(&is_zero); |
|
EXPECT_FALSE(c.Eval()); |
|
value = 0; |
|
EXPECT_TRUE(c.Eval()); |
|
} |
|
|
|
{ // bind |
|
int value = 0; |
|
auto is_positive = std::bind(std::less<int>(), 0, std::cref(value)); |
|
absl::Condition c(&is_positive); |
|
EXPECT_FALSE(c.Eval()); |
|
value = 1; |
|
EXPECT_TRUE(c.Eval()); |
|
} |
|
|
|
{ // std::function |
|
int value = 3; |
|
std::function<bool()> is_zero = [&value] { return value == 0; }; |
|
absl::Condition c(&is_zero); |
|
EXPECT_FALSE(c.Eval()); |
|
value = 0; |
|
EXPECT_TRUE(c.Eval()); |
|
} |
|
} |
|
|
|
static bool IntIsZero(int *x) { return *x == 0; } |
|
|
|
// Test for reader waiting condition variable when there are other readers |
|
// but no waiters. |
|
TEST(Mutex, TestReaderOnCondVar) { |
|
auto tp = CreateDefaultPool(); |
|
absl::Mutex mu; |
|
absl::CondVar cv; |
|
int running = 3; |
|
tp->Schedule(std::bind(&ReaderForReaderOnCondVar, &mu, &cv, &running)); |
|
tp->Schedule(std::bind(&ReaderForReaderOnCondVar, &mu, &cv, &running)); |
|
absl::SleepFor(absl::Seconds(2)); |
|
mu.Lock(); |
|
running--; |
|
mu.Await(absl::Condition(&IntIsZero, &running)); |
|
mu.Unlock(); |
|
} |
|
|
|
// -------------------------------------------------------- |
|
struct AcquireFromConditionStruct { |
|
absl::Mutex mu0; // protects value, done |
|
int value; // times condition function is called; under mu0, |
|
bool done; // done with test? under mu0 |
|
absl::Mutex mu1; // used to attempt to mess up state of mu0 |
|
absl::CondVar cv; // so the condition function can be invoked from |
|
// CondVar::Wait(). |
|
}; |
|
|
|
static bool ConditionWithAcquire(AcquireFromConditionStruct *x) { |
|
x->value++; // count times this function is called |
|
|
|
if (x->value == 2 || x->value == 3) { |
|
// On the second and third invocation of this function, sleep for 100ms, |
|
// but with the side-effect of altering the state of a Mutex other than |
|
// than one for which this is a condition. The spec now explicitly allows |
|
// this side effect; previously it did not. it was illegal. |
|
bool always_false = false; |
|
x->mu1.LockWhenWithTimeout(absl::Condition(&always_false), |
|
absl::Milliseconds(100)); |
|
x->mu1.Unlock(); |
|
} |
|
ABSL_RAW_CHECK(x->value < 4, "should not be invoked a fourth time"); |
|
|
|
// We arrange for the condition to return true on only the 2nd and 3rd calls. |
|
return x->value == 2 || x->value == 3; |
|
} |
|
|
|
static void WaitForCond2(AcquireFromConditionStruct *x) { |
|
// wait for cond0 to become true |
|
x->mu0.LockWhen(absl::Condition(&ConditionWithAcquire, x)); |
|
x->done = true; |
|
x->mu0.Unlock(); |
|
} |
|
|
|
// Test for Condition whose function acquires other Mutexes |
|
TEST(Mutex, AcquireFromCondition) { |
|
auto tp = CreateDefaultPool(); |
|
|
|
AcquireFromConditionStruct x; |
|
x.value = 0; |
|
x.done = false; |
|
tp->Schedule( |
|
std::bind(&WaitForCond2, &x)); // run WaitForCond2() in a thread T |
|
// T will hang because the first invocation of ConditionWithAcquire() will |
|
// return false. |
|
absl::SleepFor(absl::Milliseconds(500)); // allow T time to hang |
|
|
|
x.mu0.Lock(); |
|
x.cv.WaitWithTimeout(&x.mu0, absl::Milliseconds(500)); // wake T |
|
// T will be woken because the Wait() will call ConditionWithAcquire() |
|
// for the second time, and it will return true. |
|
|
|
x.mu0.Unlock(); |
|
|
|
// T will then acquire the lock and recheck its own condition. |
|
// It will find the condition true, as this is the third invocation, |
|
// but the use of another Mutex by the calling function will |
|
// cause the old mutex implementation to think that the outer |
|
// LockWhen() has timed out because the inner LockWhenWithTimeout() did. |
|
// T will then check the condition a fourth time because it finds a |
|
// timeout occurred. This should not happen in the new |
|
// implementation that allows the Condition function to use Mutexes. |
|
|
|
// It should also succeed, even though the Condition function |
|
// is being invoked from CondVar::Wait, and thus this thread |
|
// is conceptually waiting both on the condition variable, and on mu2. |
|
|
|
x.mu0.LockWhen(absl::Condition(&x.done)); |
|
x.mu0.Unlock(); |
|
} |
|
|
|
// The deadlock detector is not part of non-prod builds, so do not test it. |
|
#if !defined(ABSL_INTERNAL_USE_NONPROD_MUTEX) |
|
|
|
TEST(Mutex, DeadlockDetector) { |
|
absl::SetMutexDeadlockDetectionMode(absl::OnDeadlockCycle::kAbort); |
|
|
|
// check that we can call ForgetDeadlockInfo() on a lock with the lock held |
|
absl::Mutex m1; |
|
absl::Mutex m2; |
|
absl::Mutex m3; |
|
absl::Mutex m4; |
|
|
|
m1.Lock(); // m1 gets ID1 |
|
m2.Lock(); // m2 gets ID2 |
|
m3.Lock(); // m3 gets ID3 |
|
m3.Unlock(); |
|
m2.Unlock(); |
|
// m1 still held |
|
m1.ForgetDeadlockInfo(); // m1 loses ID |
|
m2.Lock(); // m2 gets ID2 |
|
m3.Lock(); // m3 gets ID3 |
|
m4.Lock(); // m4 gets ID4 |
|
m3.Unlock(); |
|
m2.Unlock(); |
|
m4.Unlock(); |
|
m1.Unlock(); |
|
} |
|
|
|
// Bazel has a test "warning" file that programs can write to if the |
|
// test should pass with a warning. This class disables the warning |
|
// file until it goes out of scope. |
|
class ScopedDisableBazelTestWarnings { |
|
public: |
|
ScopedDisableBazelTestWarnings() { |
|
#ifdef WIN32 |
|
char file[MAX_PATH]; |
|
if (GetEnvironmentVariable(kVarName, file, sizeof(file)) < sizeof(file)) { |
|
warnings_output_file_ = file; |
|
SetEnvironmentVariable(kVarName, nullptr); |
|
} |
|
#else |
|
const char *file = getenv(kVarName); |
|
if (file != nullptr) { |
|
warnings_output_file_ = file; |
|
unsetenv(kVarName); |
|
} |
|
#endif |
|
} |
|
|
|
~ScopedDisableBazelTestWarnings() { |
|
if (!warnings_output_file_.empty()) { |
|
#ifdef WIN32 |
|
SetEnvironmentVariable(kVarName, warnings_output_file_.c_str()); |
|
#else |
|
setenv(kVarName, warnings_output_file_.c_str(), 0); |
|
#endif |
|
} |
|
} |
|
|
|
private: |
|
static const char kVarName[]; |
|
std::string warnings_output_file_; |
|
}; |
|
const char ScopedDisableBazelTestWarnings::kVarName[] = |
|
"TEST_WARNINGS_OUTPUT_FILE"; |
|
|
|
TEST(Mutex, DeadlockDetectorBazelWarning) { |
|
absl::SetMutexDeadlockDetectionMode(absl::OnDeadlockCycle::kReport); |
|
|
|
// Cause deadlock detection to detect something, if it's |
|
// compiled in and enabled. But turn off the bazel warning. |
|
ScopedDisableBazelTestWarnings disable_bazel_test_warnings; |
|
|
|
absl::Mutex mu0; |
|
absl::Mutex mu1; |
|
bool got_mu0 = mu0.TryLock(); |
|
mu1.Lock(); // acquire mu1 while holding mu0 |
|
if (got_mu0) { |
|
mu0.Unlock(); |
|
} |
|
if (mu0.TryLock()) { // try lock shouldn't cause deadlock detector to fire |
|
mu0.Unlock(); |
|
} |
|
mu0.Lock(); // acquire mu0 while holding mu1; should get one deadlock |
|
// report here |
|
mu0.Unlock(); |
|
mu1.Unlock(); |
|
|
|
absl::SetMutexDeadlockDetectionMode(absl::OnDeadlockCycle::kAbort); |
|
} |
|
|
|
// This test is tagged with NO_THREAD_SAFETY_ANALYSIS because the |
|
// annotation-based static thread-safety analysis is not currently |
|
// predicate-aware and cannot tell if the two for-loops that acquire and |
|
// release the locks have the same predicates. |
|
TEST(Mutex, DeadlockDetectorStessTest) NO_THREAD_SAFETY_ANALYSIS { |
|
// Stress test: Here we create a large number of locks and use all of them. |
|
// If a deadlock detector keeps a full graph of lock acquisition order, |
|
// it will likely be too slow for this test to pass. |
|
const int n_locks = 1 << 17; |
|
auto array_of_locks = absl::make_unique<absl::Mutex[]>(n_locks); |
|
for (int i = 0; i < n_locks; i++) { |
|
int end = std::min(n_locks, i + 5); |
|
// acquire and then release locks i, i+1, ..., i+4 |
|
for (int j = i; j < end; j++) { |
|
array_of_locks[j].Lock(); |
|
} |
|
for (int j = i; j < end; j++) { |
|
array_of_locks[j].Unlock(); |
|
} |
|
} |
|
} |
|
|
|
TEST(Mutex, DeadlockIdBug) NO_THREAD_SAFETY_ANALYSIS { |
|
// Test a scenario where a cached deadlock graph node id in the |
|
// list of held locks is not invalidated when the corresponding |
|
// mutex is deleted. |
|
absl::SetMutexDeadlockDetectionMode(absl::OnDeadlockCycle::kAbort); |
|
// Mutex that will be destroyed while being held |
|
absl::Mutex *a = new absl::Mutex; |
|
// Other mutexes needed by test |
|
absl::Mutex b, c; |
|
|
|
// Hold mutex. |
|
a->Lock(); |
|
|
|
// Force deadlock id assignment by acquiring another lock. |
|
b.Lock(); |
|
b.Unlock(); |
|
|
|
// Delete the mutex. The Mutex destructor tries to remove held locks, |
|
// but the attempt isn't foolproof. It can fail if: |
|
// (a) Deadlock detection is currently disabled. |
|
// (b) The destruction is from another thread. |
|
// We exploit (a) by temporarily disabling deadlock detection. |
|
absl::SetMutexDeadlockDetectionMode(absl::OnDeadlockCycle::kIgnore); |
|
delete a; |
|
absl::SetMutexDeadlockDetectionMode(absl::OnDeadlockCycle::kAbort); |
|
|
|
// Now acquire another lock which will force a deadlock id assignment. |
|
// We should end up getting assigned the same deadlock id that was |
|
// freed up when "a" was deleted, which will cause a spurious deadlock |
|
// report if the held lock entry for "a" was not invalidated. |
|
c.Lock(); |
|
c.Unlock(); |
|
} |
|
#endif // !defined(ABSL_INTERNAL_USE_NONPROD_MUTEX) |
|
|
|
// -------------------------------------------------------- |
|
// Test for timeouts/deadlines on condition waits that are specified using |
|
// absl::Duration and absl::Time. For each waiting function we test with |
|
// a timeout/deadline that has already expired/passed, one that is infinite |
|
// and so never expires/passes, and one that will expire/pass in the near |
|
// future. |
|
|
|
// Encapsulate a Mutex-protected bool with its associated Condition/CondVar. |
|
class Cond { |
|
public: |
|
explicit Cond(bool use_deadline) : use_deadline_(use_deadline), c_(&b_) {} |
|
|
|
void Set(bool v) { |
|
absl::MutexLock lock(&mu_); |
|
b_ = v; |
|
} |
|
|
|
bool AwaitWithTimeout(absl::Duration timeout) { |
|
absl::MutexLock lock(&mu_); |
|
return use_deadline_ ? mu_.AwaitWithDeadline(c_, absl::Now() + timeout) |
|
: mu_.AwaitWithTimeout(c_, timeout); |
|
} |
|
|
|
bool LockWhenWithTimeout(absl::Duration timeout) { |
|
bool b = use_deadline_ ? mu_.LockWhenWithDeadline(c_, absl::Now() + timeout) |
|
: mu_.LockWhenWithTimeout(c_, timeout); |
|
mu_.Unlock(); |
|
return b; |
|
} |
|
|
|
bool ReaderLockWhenWithTimeout(absl::Duration timeout) { |
|
bool b = use_deadline_ |
|
? mu_.ReaderLockWhenWithDeadline(c_, absl::Now() + timeout) |
|
: mu_.ReaderLockWhenWithTimeout(c_, timeout); |
|
mu_.ReaderUnlock(); |
|
return b; |
|
} |
|
|
|
void Await() { |
|
absl::MutexLock lock(&mu_); |
|
mu_.Await(c_); |
|
} |
|
|
|
void Signal(bool v) { |
|
absl::MutexLock lock(&mu_); |
|
b_ = v; |
|
cv_.Signal(); |
|
} |
|
|
|
bool WaitWithTimeout(absl::Duration timeout) { |
|
absl::MutexLock lock(&mu_); |
|
absl::Time deadline = absl::Now() + timeout; |
|
if (use_deadline_) { |
|
while (!b_ && !cv_.WaitWithDeadline(&mu_, deadline)) { |
|
} |
|
} else { |
|
while (!b_ && !cv_.WaitWithTimeout(&mu_, timeout)) { |
|
timeout = deadline - absl::Now(); // recompute timeout |
|
} |
|
} |
|
return b_; |
|
} |
|
|
|
void Wait() { |
|
absl::MutexLock lock(&mu_); |
|
while (!b_) cv_.Wait(&mu_); |
|
} |
|
|
|
private: |
|
const bool use_deadline_; |
|
|
|
bool b_; |
|
absl::Condition c_; |
|
absl::CondVar cv_; |
|
absl::Mutex mu_; |
|
}; |
|
|
|
class OperationTimer { |
|
public: |
|
OperationTimer() : start_(absl::Now()) {} |
|
absl::Duration Get() const { return absl::Now() - start_; } |
|
|
|
private: |
|
const absl::Time start_; |
|
}; |
|
|
|
static void CheckResults(bool exp_result, bool act_result, |
|
absl::Duration exp_duration, |
|
absl::Duration act_duration) { |
|
ABSL_RAW_CHECK(exp_result == act_result, "CheckResults failed"); |
|
// Allow for some worse-case scheduling delay and clock skew. |
|
ABSL_RAW_CHECK(exp_duration - absl::Milliseconds(40) <= act_duration, |
|
"CheckResults failed"); |
|
ABSL_RAW_CHECK(exp_duration + absl::Milliseconds(150) >= act_duration, |
|
"CheckResults failed"); |
|
} |
|
|
|
static void TestAwaitTimeout(Cond *cp, absl::Duration timeout, bool exp_result, |
|
absl::Duration exp_duration) { |
|
OperationTimer t; |
|
bool act_result = cp->AwaitWithTimeout(timeout); |
|
CheckResults(exp_result, act_result, exp_duration, t.Get()); |
|
} |
|
|
|
static void TestLockWhenTimeout(Cond *cp, absl::Duration timeout, |
|
bool exp_result, absl::Duration exp_duration) { |
|
OperationTimer t; |
|
bool act_result = cp->LockWhenWithTimeout(timeout); |
|
CheckResults(exp_result, act_result, exp_duration, t.Get()); |
|
} |
|
|
|
static void TestReaderLockWhenTimeout(Cond *cp, absl::Duration timeout, |
|
bool exp_result, |
|
absl::Duration exp_duration) { |
|
OperationTimer t; |
|
bool act_result = cp->ReaderLockWhenWithTimeout(timeout); |
|
CheckResults(exp_result, act_result, exp_duration, t.Get()); |
|
} |
|
|
|
static void TestWaitTimeout(Cond *cp, absl::Duration timeout, bool exp_result, |
|
absl::Duration exp_duration) { |
|
OperationTimer t; |
|
bool act_result = cp->WaitWithTimeout(timeout); |
|
CheckResults(exp_result, act_result, exp_duration, t.Get()); |
|
} |
|
|
|
// Tests with a negative timeout (deadline in the past), which should |
|
// immediately return the current state of the condition. |
|
static void TestNegativeTimeouts(absl::synchronization_internal::ThreadPool *tp, |
|
Cond *cp) { |
|
const absl::Duration negative = -absl::InfiniteDuration(); |
|
const absl::Duration immediate = absl::ZeroDuration(); |
|
|
|
// The condition is already true: |
|
cp->Set(true); |
|
TestAwaitTimeout(cp, negative, true, immediate); |
|
TestLockWhenTimeout(cp, negative, true, immediate); |
|
TestReaderLockWhenTimeout(cp, negative, true, immediate); |
|
TestWaitTimeout(cp, negative, true, immediate); |
|
|
|
// The condition becomes true, but the timeout has already expired: |
|
const absl::Duration delay = absl::Milliseconds(200); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), 3 * delay); |
|
TestAwaitTimeout(cp, negative, false, immediate); |
|
TestLockWhenTimeout(cp, negative, false, immediate); |
|
TestReaderLockWhenTimeout(cp, negative, false, immediate); |
|
cp->Await(); // wait for the scheduled Set() to complete |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Signal, cp, true), delay); |
|
TestWaitTimeout(cp, negative, false, immediate); |
|
cp->Wait(); // wait for the scheduled Signal() to complete |
|
|
|
// The condition never becomes true: |
|
cp->Set(false); |
|
TestAwaitTimeout(cp, negative, false, immediate); |
|
TestLockWhenTimeout(cp, negative, false, immediate); |
|
TestReaderLockWhenTimeout(cp, negative, false, immediate); |
|
TestWaitTimeout(cp, negative, false, immediate); |
|
} |
|
|
|
// Tests with an infinite timeout (deadline in the infinite future), which |
|
// should only return when the condition becomes true. |
|
static void TestInfiniteTimeouts(absl::synchronization_internal::ThreadPool *tp, |
|
Cond *cp) { |
|
const absl::Duration infinite = absl::InfiniteDuration(); |
|
const absl::Duration immediate = absl::ZeroDuration(); |
|
|
|
// The condition is already true: |
|
cp->Set(true); |
|
TestAwaitTimeout(cp, infinite, true, immediate); |
|
TestLockWhenTimeout(cp, infinite, true, immediate); |
|
TestReaderLockWhenTimeout(cp, infinite, true, immediate); |
|
TestWaitTimeout(cp, infinite, true, immediate); |
|
|
|
// The condition becomes true before the (infinite) expiry: |
|
const absl::Duration delay = absl::Milliseconds(200); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), delay); |
|
TestAwaitTimeout(cp, infinite, true, delay); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), delay); |
|
TestLockWhenTimeout(cp, infinite, true, delay); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), delay); |
|
TestReaderLockWhenTimeout(cp, infinite, true, delay); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Signal, cp, true), delay); |
|
TestWaitTimeout(cp, infinite, true, delay); |
|
} |
|
|
|
// Tests with a (small) finite timeout (deadline soon), with the condition |
|
// becoming true both before and after its expiry. |
|
static void TestFiniteTimeouts(absl::synchronization_internal::ThreadPool *tp, |
|
Cond *cp) { |
|
const absl::Duration finite = absl::Milliseconds(400); |
|
const absl::Duration immediate = absl::ZeroDuration(); |
|
|
|
// The condition is already true: |
|
cp->Set(true); |
|
TestAwaitTimeout(cp, finite, true, immediate); |
|
TestLockWhenTimeout(cp, finite, true, immediate); |
|
TestReaderLockWhenTimeout(cp, finite, true, immediate); |
|
TestWaitTimeout(cp, finite, true, immediate); |
|
|
|
// The condition becomes true before the expiry: |
|
const absl::Duration delay1 = finite / 2; |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), delay1); |
|
TestAwaitTimeout(cp, finite, true, delay1); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), delay1); |
|
TestLockWhenTimeout(cp, finite, true, delay1); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), delay1); |
|
TestReaderLockWhenTimeout(cp, finite, true, delay1); |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Signal, cp, true), delay1); |
|
TestWaitTimeout(cp, finite, true, delay1); |
|
|
|
// The condition becomes true, but the timeout has already expired: |
|
const absl::Duration delay2 = finite * 2; |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Set, cp, true), 3 * delay2); |
|
TestAwaitTimeout(cp, finite, false, finite); |
|
TestLockWhenTimeout(cp, finite, false, finite); |
|
TestReaderLockWhenTimeout(cp, finite, false, finite); |
|
cp->Await(); // wait for the scheduled Set() to complete |
|
cp->Set(false); |
|
ScheduleAfter(tp, std::bind(&Cond::Signal, cp, true), delay2); |
|
TestWaitTimeout(cp, finite, false, finite); |
|
cp->Wait(); // wait for the scheduled Signal() to complete |
|
|
|
// The condition never becomes true: |
|
cp->Set(false); |
|
TestAwaitTimeout(cp, finite, false, finite); |
|
TestLockWhenTimeout(cp, finite, false, finite); |
|
TestReaderLockWhenTimeout(cp, finite, false, finite); |
|
TestWaitTimeout(cp, finite, false, finite); |
|
} |
|
|
|
TEST(Mutex, Timeouts) { |
|
auto tp = CreateDefaultPool(); |
|
for (bool use_deadline : {false, true}) { |
|
Cond cond(use_deadline); |
|
TestNegativeTimeouts(tp.get(), &cond); |
|
TestInfiniteTimeouts(tp.get(), &cond); |
|
TestFiniteTimeouts(tp.get(), &cond); |
|
} |
|
} |
|
|
|
TEST(Mutex, Logging) { |
|
// Allow user to look at logging output |
|
absl::Mutex logged_mutex; |
|
logged_mutex.EnableDebugLog("fido_mutex"); |
|
absl::CondVar logged_cv; |
|
logged_cv.EnableDebugLog("rover_cv"); |
|
logged_mutex.Lock(); |
|
logged_cv.WaitWithTimeout(&logged_mutex, absl::Milliseconds(20)); |
|
logged_mutex.Unlock(); |
|
logged_mutex.ReaderLock(); |
|
logged_mutex.ReaderUnlock(); |
|
logged_mutex.Lock(); |
|
logged_mutex.Unlock(); |
|
logged_cv.Signal(); |
|
logged_cv.SignalAll(); |
|
} |
|
|
|
// -------------------------------------------------------- |
|
|
|
// Generate the vector of thread counts for tests parameterized on thread count. |
|
static std::vector<int> AllThreadCountValues() { |
|
if (kExtendedTest) { |
|
return {2, 4, 8, 10, 16, 20, 24, 30, 32}; |
|
} |
|
return {2, 4, 10}; |
|
} |
|
|
|
// A test fixture parameterized by thread count. |
|
class MutexVariableThreadCountTest : public ::testing::TestWithParam<int> {}; |
|
|
|
// Instantiate the above with AllThreadCountOptions(). |
|
INSTANTIATE_TEST_CASE_P(ThreadCounts, MutexVariableThreadCountTest, |
|
::testing::ValuesIn(AllThreadCountValues()), |
|
::testing::PrintToStringParamName()); |
|
|
|
// Reduces iterations by some factor for slow platforms |
|
// (determined empirically). |
|
static int ScaleIterations(int x) { |
|
// ABSL_MUTEX_READER_LOCK_IS_EXCLUSIVE is set in the implementation |
|
// of Mutex that uses either std::mutex or pthread_mutex_t. Use |
|
// these as keys to determine the slow implementation. |
|
#if defined(ABSL_MUTEX_READER_LOCK_IS_EXCLUSIVE) |
|
return x / 10; |
|
#else |
|
return x; |
|
#endif |
|
} |
|
|
|
TEST_P(MutexVariableThreadCountTest, Mutex) { |
|
int threads = GetParam(); |
|
int iterations = ScaleIterations(10000000) / threads; |
|
int operations = threads * iterations; |
|
EXPECT_EQ(RunTest(&TestMu, threads, iterations, operations), operations); |
|
} |
|
|
|
TEST_P(MutexVariableThreadCountTest, Try) { |
|
int threads = GetParam(); |
|
int iterations = 1000000 / threads; |
|
int operations = iterations * threads; |
|
EXPECT_EQ(RunTest(&TestTry, threads, iterations, operations), operations); |
|
} |
|
|
|
TEST_P(MutexVariableThreadCountTest, R20ms) { |
|
int threads = GetParam(); |
|
int iterations = 100; |
|
int operations = iterations * threads; |
|
EXPECT_EQ(RunTest(&TestR20ms, threads, iterations, operations), 0); |
|
} |
|
|
|
TEST_P(MutexVariableThreadCountTest, RW) { |
|
int threads = GetParam(); |
|
int iterations = ScaleIterations(20000000) / threads; |
|
int operations = iterations * threads; |
|
EXPECT_EQ(RunTest(&TestRW, threads, iterations, operations), operations / 2); |
|
} |
|
|
|
TEST_P(MutexVariableThreadCountTest, Await) { |
|
int threads = GetParam(); |
|
int iterations = ScaleIterations(500000); |
|
int operations = iterations; |
|
EXPECT_EQ(RunTest(&TestAwait, threads, iterations, operations), operations); |
|
} |
|
|
|
TEST_P(MutexVariableThreadCountTest, SignalAll) { |
|
int threads = GetParam(); |
|
int iterations = 200000 / threads; |
|
int operations = iterations; |
|
EXPECT_EQ(RunTest(&TestSignalAll, threads, iterations, operations), |
|
operations); |
|
} |
|
|
|
TEST(Mutex, Signal) { |
|
int threads = 2; // TestSignal must use two threads |
|
int iterations = 200000; |
|
int operations = iterations; |
|
EXPECT_EQ(RunTest(&TestSignal, threads, iterations, operations), operations); |
|
} |
|
|
|
TEST(Mutex, Timed) { |
|
int threads = 10; // Use a fixed thread count of 10 |
|
int iterations = 1000; |
|
int operations = iterations; |
|
EXPECT_EQ(RunTest(&TestCVTimeout, threads, iterations, operations), |
|
operations); |
|
} |
|
|
|
TEST(Mutex, CVTime) { |
|
int threads = 10; // Use a fixed thread count of 10 |
|
int iterations = 1; |
|
EXPECT_EQ(RunTest(&TestCVTime, threads, iterations, 1), |
|
threads * iterations); |
|
} |
|
|
|
TEST(Mutex, MuTime) { |
|
int threads = 10; // Use a fixed thread count of 10 |
|
int iterations = 1; |
|
EXPECT_EQ(RunTest(&TestMuTime, threads, iterations, 1), threads * iterations); |
|
} |
|
|
|
} // namespace
|
|
|