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

Unified Diff: third_party/mojo/src/mojo/edk/system/channel_unittest.cc

Issue 1676913002: [mojo] Delete third_party/mojo (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: let's try that again Created 4 years, 10 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
Index: third_party/mojo/src/mojo/edk/system/channel_unittest.cc
diff --git a/third_party/mojo/src/mojo/edk/system/channel_unittest.cc b/third_party/mojo/src/mojo/edk/system/channel_unittest.cc
deleted file mode 100644
index 0e601fdcddcef1277f2890e5e58901766c613360..0000000000000000000000000000000000000000
--- a/third_party/mojo/src/mojo/edk/system/channel_unittest.cc
+++ /dev/null
@@ -1,151 +0,0 @@
-// Copyright 2014 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "third_party/mojo/src/mojo/edk/system/channel.h"
-
-#include "third_party/mojo/src/mojo/edk/system/channel_endpoint.h"
-#include "third_party/mojo/src/mojo/edk/system/channel_endpoint_id.h"
-#include "third_party/mojo/src/mojo/edk/system/channel_test_base.h"
-#include "third_party/mojo/src/mojo/edk/system/message_pipe.h"
-#include "third_party/mojo/src/mojo/edk/system/test_utils.h"
-#include "third_party/mojo/src/mojo/edk/system/waiter.h"
-
-namespace mojo {
-namespace system {
-namespace {
-
-using ChannelTest = test::ChannelTestBase;
-
-void DoNothing() {}
-
-// ChannelTest.InitShutdown ----------------------------------------------------
-
-TEST_F(ChannelTest, InitShutdown) {
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::CreateAndInitChannelOnIOThread, 0);
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::ShutdownChannelOnIOThread, 0);
-
- // Okay to destroy |Channel| on not-the-I/O-thread.
- EXPECT_TRUE(channel(0)->HasOneRef());
- *mutable_channel(0) = nullptr;
-}
-
-// ChannelTest.CloseBeforeAttachAndRun -----------------------------------------
-
-TEST_F(ChannelTest, CloseBeforeRun) {
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::CreateAndInitChannelOnIOThread, 0);
-
- scoped_refptr<ChannelEndpoint> channel_endpoint;
- scoped_refptr<MessagePipe> mp(
- MessagePipe::CreateLocalProxy(&channel_endpoint));
-
- mp->Close(0);
-
- channel(0)->SetBootstrapEndpoint(channel_endpoint);
-
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::ShutdownChannelOnIOThread, 0);
-
- EXPECT_TRUE(channel(0)->HasOneRef());
-}
-
-// ChannelTest.ShutdownAfterAttachAndRun ---------------------------------------
-
-TEST_F(ChannelTest, ShutdownAfterAttach) {
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::CreateAndInitChannelOnIOThread, 0);
-
- scoped_refptr<ChannelEndpoint> channel_endpoint;
- scoped_refptr<MessagePipe> mp(
- MessagePipe::CreateLocalProxy(&channel_endpoint));
-
- channel(0)->SetBootstrapEndpoint(channel_endpoint);
-
- Waiter waiter;
- waiter.Init();
- ASSERT_EQ(
- MOJO_RESULT_OK,
- mp->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));
-
- // Don't wait for the shutdown to run ...
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::ShutdownChannelOnIOThread, 0);
-
- // ... since this |Wait()| should fail once the channel is shut down.
- EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
- waiter.Wait(MOJO_DEADLINE_INDEFINITE, nullptr));
- HandleSignalsState hss;
- mp->RemoveAwakable(0, &waiter, &hss);
- EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);
- EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);
-
- mp->Close(0);
-
- EXPECT_TRUE(channel(0)->HasOneRef());
-}
-
-// ChannelTest.WaitAfterAttachRunAndShutdown -----------------------------------
-
-TEST_F(ChannelTest, WaitAfterAttachRunAndShutdown) {
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::CreateAndInitChannelOnIOThread, 0);
-
- scoped_refptr<ChannelEndpoint> channel_endpoint;
- scoped_refptr<MessagePipe> mp(
- MessagePipe::CreateLocalProxy(&channel_endpoint));
-
- channel(0)->SetBootstrapEndpoint(channel_endpoint);
-
- PostMethodToIOThreadAndWait(FROM_HERE,
- &ChannelTest::ShutdownChannelOnIOThread, 0);
-
- Waiter waiter;
- waiter.Init();
- HandleSignalsState hss;
- EXPECT_EQ(
- MOJO_RESULT_FAILED_PRECONDITION,
- mp->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, &hss));
- EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);
- EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);
-
- mp->Close(0);
-
- EXPECT_TRUE(channel(0)->HasOneRef());
-}
-
-// ChannelTest.EndpointChannelShutdownRace -------------------------------------
-
-TEST_F(ChannelTest, EndpointChannelShutdownRace) {
- const size_t kIterations = 1000;
-
- for (size_t i = 0; i < kIterations; i++) {
- // Need a new set of |RawChannel|s on every iteration.
- SetUp();
- PostMethodToIOThreadAndWait(
- FROM_HERE, &ChannelTest::CreateAndInitChannelOnIOThread, 0);
-
- scoped_refptr<ChannelEndpoint> channel_endpoint;
- scoped_refptr<MessagePipe> mp(
- MessagePipe::CreateLocalProxy(&channel_endpoint));
-
- channel(0)->SetBootstrapEndpoint(channel_endpoint);
-
- io_thread()->PostTask(
- FROM_HERE, base::Bind(&ChannelTest::ShutdownAndReleaseChannelOnIOThread,
- base::Unretained(this), 0));
- mp->Close(0);
-
- // Wait for the IO thread to finish shutting down the channel.
- io_thread()->PostTaskAndWait(FROM_HERE, base::Bind(&DoNothing));
- EXPECT_FALSE(channel(0));
- }
-}
-
-// TODO(vtl): More. ------------------------------------------------------------
-
-} // namespace
-} // namespace system
-} // namespace mojo
« no previous file with comments | « third_party/mojo/src/mojo/edk/system/channel_test_base.cc ('k') | third_party/mojo/src/mojo/edk/system/configuration.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698