| Index: third_party/mojo/src/mojo/edk/system/raw_channel_unittest.cc
|
| diff --git a/third_party/mojo/src/mojo/edk/system/raw_channel_unittest.cc b/third_party/mojo/src/mojo/edk/system/raw_channel_unittest.cc
|
| index 831d3848d919039099f05bb5b5732d83fafdb5ad..1501eea19512cdd1b6b91b32c2fcf5fffd621c20 100644
|
| --- a/third_party/mojo/src/mojo/edk/system/raw_channel_unittest.cc
|
| +++ b/third_party/mojo/src/mojo/edk/system/raw_channel_unittest.cc
|
| @@ -6,7 +6,7 @@
|
|
|
| #include <stdint.h>
|
| #include <stdio.h>
|
| -
|
| +#include <utility>
|
| #include <vector>
|
|
|
| #include "base/bind.h"
|
| @@ -194,7 +194,7 @@ class TestMessageReaderAndChecker {
|
| // Tests writing (and verifies reading using our own custom reader).
|
| TEST_F(RawChannelTest, WriteMessage) {
|
| WriteOnlyRawChannelDelegate delegate;
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| TestMessageReaderAndChecker checker(handles[1].get());
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE,
|
| @@ -280,7 +280,7 @@ class ReadCheckerRawChannelDelegate : public RawChannel::Delegate {
|
| // Tests reading (writing using our own custom writer).
|
| TEST_F(RawChannelTest, OnReadMessage) {
|
| ReadCheckerRawChannelDelegate delegate;
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE,
|
| base::Bind(&InitOnIOThread, rc.get(), base::Unretained(&delegate)));
|
| @@ -377,14 +377,14 @@ TEST_F(RawChannelTest, WriteMessageAndOnReadMessage) {
|
| static const size_t kNumWriteMessagesPerThread = 4000;
|
|
|
| WriteOnlyRawChannelDelegate writer_delegate;
|
| - scoped_ptr<RawChannel> writer_rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> writer_rc(RawChannel::Create(std::move(handles[0])));
|
| io_thread()->PostTaskAndWait(FROM_HERE,
|
| base::Bind(&InitOnIOThread, writer_rc.get(),
|
| base::Unretained(&writer_delegate)));
|
|
|
| ReadCountdownRawChannelDelegate reader_delegate(kNumWriterThreads *
|
| kNumWriteMessagesPerThread);
|
| - scoped_ptr<RawChannel> reader_rc(RawChannel::Create(handles[1].Pass()));
|
| + scoped_ptr<RawChannel> reader_rc(RawChannel::Create(std::move(handles[1])));
|
| io_thread()->PostTaskAndWait(FROM_HERE,
|
| base::Bind(&InitOnIOThread, reader_rc.get(),
|
| base::Unretained(&reader_delegate)));
|
| @@ -474,7 +474,7 @@ class ErrorRecordingRawChannelDelegate
|
| // Tests (fatal) errors.
|
| TEST_F(RawChannelTest, OnError) {
|
| ErrorRecordingRawChannelDelegate delegate(0, true, true);
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE,
|
| base::Bind(&InitOnIOThread, rc.get(), base::Unretained(&delegate)));
|
| @@ -517,7 +517,7 @@ TEST_F(RawChannelTest, ReadUnaffectedByWriteError) {
|
| // Only start up reading here. The system buffer should still contain the
|
| // messages that were written.
|
| ErrorRecordingRawChannelDelegate delegate(kMessageCount, true, true);
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE,
|
| base::Bind(&InitOnIOThread, rc.get(), base::Unretained(&delegate)));
|
| @@ -543,7 +543,7 @@ TEST_F(RawChannelTest, ReadUnaffectedByWriteError) {
|
| // correctly.
|
| TEST_F(RawChannelTest, WriteMessageAfterShutdown) {
|
| WriteOnlyRawChannelDelegate delegate;
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE,
|
| base::Bind(&InitOnIOThread, rc.get(), base::Unretained(&delegate)));
|
| @@ -603,7 +603,7 @@ TEST_F(RawChannelTest, ShutdownOnReadMessage) {
|
| for (size_t count = 0; count < 5; count++)
|
| EXPECT_TRUE(WriteTestMessageToHandle(handles[1].get(), 10));
|
|
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| ShutdownOnReadMessageRawChannelDelegate delegate(rc.get(), false);
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE,
|
| @@ -618,7 +618,7 @@ TEST_F(RawChannelTest, ShutdownAndDestroyOnReadMessage) {
|
| EXPECT_TRUE(WriteTestMessageToHandle(handles[1].get(), 10));
|
|
|
| // The delegate will destroy |rc|.
|
| - RawChannel* rc = RawChannel::Create(handles[0].Pass()).release();
|
| + RawChannel* rc = RawChannel::Create(std::move(handles[0])).release();
|
| ShutdownOnReadMessageRawChannelDelegate delegate(rc, true);
|
| io_thread()->PostTaskAndWait(
|
| FROM_HERE, base::Bind(&InitOnIOThread, rc, base::Unretained(&delegate)));
|
| @@ -675,7 +675,7 @@ class ShutdownOnErrorRawChannelDelegate : public RawChannel::Delegate {
|
| };
|
|
|
| TEST_F(RawChannelTest, ShutdownOnErrorRead) {
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| ShutdownOnErrorRawChannelDelegate delegate(
|
| rc.get(), false, RawChannel::Delegate::ERROR_READ_SHUTDOWN);
|
| io_thread()->PostTaskAndWait(
|
| @@ -690,7 +690,7 @@ TEST_F(RawChannelTest, ShutdownOnErrorRead) {
|
| }
|
|
|
| TEST_F(RawChannelTest, ShutdownAndDestroyOnErrorRead) {
|
| - RawChannel* rc = RawChannel::Create(handles[0].Pass()).release();
|
| + RawChannel* rc = RawChannel::Create(std::move(handles[0])).release();
|
| ShutdownOnErrorRawChannelDelegate delegate(
|
| rc, true, RawChannel::Delegate::ERROR_READ_SHUTDOWN);
|
| io_thread()->PostTaskAndWait(
|
| @@ -704,7 +704,7 @@ TEST_F(RawChannelTest, ShutdownAndDestroyOnErrorRead) {
|
| }
|
|
|
| TEST_F(RawChannelTest, ShutdownOnErrorWrite) {
|
| - scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc(RawChannel::Create(std::move(handles[0])));
|
| ShutdownOnErrorRawChannelDelegate delegate(rc.get(), false,
|
| RawChannel::Delegate::ERROR_WRITE);
|
| io_thread()->PostTaskAndWait(
|
| @@ -721,7 +721,7 @@ TEST_F(RawChannelTest, ShutdownOnErrorWrite) {
|
| }
|
|
|
| TEST_F(RawChannelTest, ShutdownAndDestroyOnErrorWrite) {
|
| - RawChannel* rc = RawChannel::Create(handles[0].Pass()).release();
|
| + RawChannel* rc = RawChannel::Create(std::move(handles[0])).release();
|
| ShutdownOnErrorRawChannelDelegate delegate(rc, true,
|
| RawChannel::Delegate::ERROR_WRITE);
|
| io_thread()->PostTaskAndWait(
|
| @@ -764,7 +764,8 @@ class ReadPlatformHandlesCheckerRawChannelDelegate
|
| {
|
| char buffer[100] = {};
|
|
|
| - base::ScopedFILE fp(mojo::test::FILEFromPlatformHandle(h1.Pass(), "rb"));
|
| + base::ScopedFILE fp(
|
| + mojo::test::FILEFromPlatformHandle(std::move(h1), "rb"));
|
| EXPECT_TRUE(fp);
|
| rewind(fp.get());
|
| EXPECT_EQ(1u, fread(buffer, 1, sizeof(buffer), fp.get()));
|
| @@ -773,7 +774,8 @@ class ReadPlatformHandlesCheckerRawChannelDelegate
|
|
|
| {
|
| char buffer[100] = {};
|
| - base::ScopedFILE fp(mojo::test::FILEFromPlatformHandle(h2.Pass(), "rb"));
|
| + base::ScopedFILE fp(
|
| + mojo::test::FILEFromPlatformHandle(std::move(h2), "rb"));
|
| EXPECT_TRUE(fp);
|
| rewind(fp.get());
|
| EXPECT_EQ(1u, fread(buffer, 1, sizeof(buffer), fp.get()));
|
| @@ -806,13 +808,13 @@ TEST_F(RawChannelTest, MAYBE_ReadWritePlatformHandles) {
|
| ASSERT_TRUE(temp_dir.CreateUniqueTempDir());
|
|
|
| WriteOnlyRawChannelDelegate write_delegate;
|
| - scoped_ptr<RawChannel> rc_write(RawChannel::Create(handles[0].Pass()));
|
| + scoped_ptr<RawChannel> rc_write(RawChannel::Create(std::move(handles[0])));
|
| io_thread()->PostTaskAndWait(FROM_HERE,
|
| base::Bind(&InitOnIOThread, rc_write.get(),
|
| base::Unretained(&write_delegate)));
|
|
|
| ReadPlatformHandlesCheckerRawChannelDelegate read_delegate;
|
| - scoped_ptr<RawChannel> rc_read(RawChannel::Create(handles[1].Pass()));
|
| + scoped_ptr<RawChannel> rc_read(RawChannel::Create(std::move(handles[1])));
|
| io_thread()->PostTaskAndWait(FROM_HERE,
|
| base::Bind(&InitOnIOThread, rc_read.get(),
|
| base::Unretained(&read_delegate)));
|
| @@ -830,17 +832,18 @@ TEST_F(RawChannelTest, MAYBE_ReadWritePlatformHandles) {
|
| embedder::ScopedPlatformHandleVectorPtr platform_handles(
|
| new embedder::PlatformHandleVector());
|
| platform_handles->push_back(
|
| - mojo::test::PlatformHandleFromFILE(fp1.Pass()).release());
|
| + mojo::test::PlatformHandleFromFILE(std::move(fp1)).release());
|
| platform_handles->push_back(
|
| - mojo::test::PlatformHandleFromFILE(fp2.Pass()).release());
|
| + mojo::test::PlatformHandleFromFILE(std::move(fp2)).release());
|
|
|
| scoped_ptr<MessageInTransit> message(
|
| new MessageInTransit(MessageInTransit::Type::ENDPOINT_CLIENT,
|
| MessageInTransit::Subtype::ENDPOINT_CLIENT_DATA,
|
| sizeof(kHello), kHello));
|
| - message->SetTransportData(make_scoped_ptr(new TransportData(
|
| - platform_handles.Pass(), rc_write->GetSerializedPlatformHandleSize())));
|
| - EXPECT_TRUE(rc_write->WriteMessage(message.Pass()));
|
| + message->SetTransportData(make_scoped_ptr(
|
| + new TransportData(std::move(platform_handles),
|
| + rc_write->GetSerializedPlatformHandleSize())));
|
| + EXPECT_TRUE(rc_write->WriteMessage(std::move(message)));
|
| }
|
|
|
| read_delegate.Wait();
|
|
|