Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1490)

Unified Diff: mojo/edk/system/wait_set_dispatcher_unittest.cc

Issue 2100553002: Add Core methods for wait set. (Closed) Base URL: https://github.com/domokit/mojo.git@work790_wait_set_5.4
Patch Set: Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/edk/system/wait_set_dispatcher.cc ('k') | mojo/public/c/system/wait_set.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/edk/system/wait_set_dispatcher_unittest.cc
diff --git a/mojo/edk/system/wait_set_dispatcher_unittest.cc b/mojo/edk/system/wait_set_dispatcher_unittest.cc
index ea544e39d9023da3e92b84fc02f8b07e40bcb0db..62a8f6e35d7a85289e0eb0245d65d200e5b6b325 100644
--- a/mojo/edk/system/wait_set_dispatcher_unittest.cc
+++ b/mojo/edk/system/wait_set_dispatcher_unittest.cc
@@ -94,24 +94,24 @@ TEST(WaitSetDispatcherTest, Basic) {
// Add |d_member0|, for something not satisfied, but satisfiable.
static constexpr uint64_t kCookie0 = 0x123456789abcdef0ULL;
static constexpr auto kSignals0 = kR;
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member0.Clone(),
- kSignals0, kCookie0));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member0.Clone(), kSignals0,
+ kCookie0, NullUserPointer()));
// Add |d_member1|, for something satisfied.
static constexpr uint64_t kCookie1 = 0x23456789abcdef01ULL;
static constexpr auto kSignals1 = kR;
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member1.Clone(),
- kSignals1, kCookie1));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member1.Clone(), kSignals1,
+ kCookie1, NullUserPointer()));
// Can add |d_member0| again (satisfied), with a different cookie.
static constexpr uint64_t kCookie2 = 0x3456789abcdef012ULL;
static constexpr auto kSignals2 = kW;
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member0.Clone(),
- kSignals2, kCookie2));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member0.Clone(), kSignals2,
+ kCookie2, NullUserPointer()));
// Adding something with the same cookie yields "already exists".
EXPECT_EQ(MOJO_RESULT_ALREADY_EXISTS,
- d->WaitSetAdd(NullUserPointer(), d_member1.Clone(), kR, kCookie2));
+ d->WaitSetAdd(d_member1.Clone(), kR, kCookie2, NullUserPointer()));
// Can remove something based on a cookie.
EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetRemove(kCookie0));
@@ -121,7 +121,7 @@ TEST(WaitSetDispatcherTest, Basic) {
// Can re-add it (still not satisfied, but satisfiable).
EXPECT_EQ(MOJO_RESULT_OK,
- d->WaitSetAdd(NullUserPointer(), d_member0.Clone(), kR, kCookie0));
+ d->WaitSetAdd(d_member0.Clone(), kR, kCookie0, NullUserPointer()));
// Wait. Recall:
// - |kCookie0| is for |d_member0| and is not satisfied (but satisfiable).
@@ -292,8 +292,9 @@ TEST(WaitSetDispatcherTest, TimeOut) {
auto d_member = MakeRefCounted<test::MockSimpleDispatcher>(
MOJO_HANDLE_SIGNAL_NONE, MOJO_HANDLE_SIGNAL_READABLE);
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member.Clone(),
- MOJO_HANDLE_SIGNAL_READABLE, 123u));
+ EXPECT_EQ(MOJO_RESULT_OK,
+ d->WaitSetAdd(d_member.Clone(), MOJO_HANDLE_SIGNAL_READABLE, 123u,
+ NullUserPointer()));
// Wait with timeout with an unsatisfied (but satisfiable) entry.
{
@@ -334,20 +335,20 @@ TEST(WaitSetDispatcherTest, BasicThreaded1) {
// Add |d_member0|.
static constexpr uint64_t kCookie0 = 123u;
static constexpr auto kSignals0 = kR;
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member0.Clone(),
- kSignals0, kCookie0));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member0.Clone(), kSignals0,
+ kCookie0, NullUserPointer()));
// Add |d_member1|.
static constexpr uint64_t kCookie1 = 456u;
static constexpr auto kSignals1 = kR;
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member1.Clone(),
- kSignals1, kCookie1));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member1.Clone(), kSignals1,
+ kCookie1, NullUserPointer()));
// Can add |d_member0| again with a different cookie.
static constexpr uint64_t kCookie2 = 789u;
static constexpr auto kSignals2 = kW;
- EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(NullUserPointer(), d_member0.Clone(),
- kSignals2, kCookie2));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member0.Clone(), kSignals2,
+ kCookie2, NullUserPointer()));
// We'll wait on the main thread, and do stuff on another thread.
@@ -486,9 +487,8 @@ TEST(WaitSetDispatcherTest, BasicThreaded2) {
std::thread t0([epsilon, d, d_member]() {
// Sleep to try to ensure that waiting has started.
ThreadSleep(epsilon);
- EXPECT_EQ(MOJO_RESULT_OK,
- d->WaitSetAdd(NullUserPointer(), d_member.Clone(), kSignals0,
- kCookie0));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member.Clone(), kSignals0,
+ kCookie0, NullUserPointer()));
});
// Trigger |kCookie0| after |2 * epsilon| on another thread.
stopwatch.Start();
@@ -531,17 +531,15 @@ TEST(WaitSetDispatcherTest, BasicThreaded2) {
std::thread t1([epsilon, d, d_member]() {
// Sleep to try to ensure that waiting has started.
ThreadSleep(epsilon);
- EXPECT_EQ(MOJO_RESULT_OK,
- d->WaitSetAdd(NullUserPointer(), d_member.Clone(), kSignals1,
- kCookie1));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member.Clone(), kSignals1,
+ kCookie1, NullUserPointer()));
});
// Add |kCookie2|.
std::thread t2([epsilon, d, d_member]() {
// Sleep to try to ensure that waiting has started.
ThreadSleep(epsilon);
- EXPECT_EQ(MOJO_RESULT_OK,
- d->WaitSetAdd(NullUserPointer(), d_member.Clone(), kSignals2,
- kCookie2));
+ EXPECT_EQ(MOJO_RESULT_OK, d->WaitSetAdd(d_member.Clone(), kSignals2,
+ kCookie2, NullUserPointer()));
});
// Trigger |kCookie1| and |kCookie2| after |2 * epsilon| on another thread.
stopwatch.Start();
@@ -615,7 +613,7 @@ TEST(WaitSetDispatcherTest, BasicThreaded3) {
{
// Add an entry.
EXPECT_EQ(MOJO_RESULT_OK,
- d->WaitSetAdd(NullUserPointer(), d_member.Clone(), kR, 123u));
+ d->WaitSetAdd(d_member.Clone(), kR, 123u, NullUserPointer()));
// Wait on a bunch of threads. We'll trigger on the main thread.
std::vector<std::thread> threads;
@@ -688,8 +686,8 @@ TEST(WaitSetDispatcherTest, ThreadedStress) {
// The quit dispatcher and entry.
auto quit = MakeRefCounted<test::MockSimpleDispatcher>(kNone, kSignal);
EXPECT_EQ(MOJO_RESULT_OK,
- wait_set->WaitSetAdd(NullUserPointer(), quit.Clone(), kSignal,
- kQuitCookie));
+ wait_set->WaitSetAdd(quit.Clone(), kSignal, kQuitCookie,
+ NullUserPointer()));
std::vector<std::thread> threads;
@@ -767,10 +765,9 @@ TEST(WaitSetDispatcherTest, ThreadedStress) {
cookies.push_back(new_cookie);
}
EXPECT_NE(new_cookie, kQuitCookie);
- EXPECT_EQ(
- MOJO_RESULT_OK,
- wait_set->WaitSetAdd(NullUserPointer(), std::move(new_dispatcher),
- kSignal, new_cookie));
+ EXPECT_EQ(MOJO_RESULT_OK,
+ wait_set->WaitSetAdd(std::move(new_dispatcher), kSignal,
+ new_cookie, NullUserPointer()));
}
// Should we trigger an entry? Make the probability be (current number)
« no previous file with comments | « mojo/edk/system/wait_set_dispatcher.cc ('k') | mojo/public/c/system/wait_set.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698