| Index: third_party/WebKit/Source/modules/fetch/CompositeDataConsumerHandleTest.cpp
|
| diff --git a/third_party/WebKit/Source/modules/fetch/CompositeDataConsumerHandleTest.cpp b/third_party/WebKit/Source/modules/fetch/CompositeDataConsumerHandleTest.cpp
|
| index 863dd6daa6971073371a4b6e076bb9aa67908a73..0ff02a9d6609ca95c06ba44d04233b444252590a 100644
|
| --- a/third_party/WebKit/Source/modules/fetch/CompositeDataConsumerHandleTest.cpp
|
| +++ b/third_party/WebKit/Source/modules/fetch/CompositeDataConsumerHandleTest.cpp
|
| @@ -14,6 +14,8 @@
|
| #include "testing/gmock/include/gmock/gmock.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
| #include "wtf/Locker.h"
|
| +#include "wtf/PtrUtil.h"
|
| +#include <memory>
|
|
|
| namespace blink {
|
|
|
| @@ -30,7 +32,7 @@ const WebDataConsumerHandle::Flags kNone = WebDataConsumerHandle::FlagNone;
|
|
|
| class MockReader : public WebDataConsumerHandle::Reader {
|
| public:
|
| - static PassOwnPtr<StrictMock<MockReader>> create() { return adoptPtr(new StrictMock<MockReader>); }
|
| + static std::unique_ptr<StrictMock<MockReader>> create() { return wrapUnique(new StrictMock<MockReader>); }
|
|
|
| using Result = WebDataConsumerHandle::Result;
|
| using Flags = WebDataConsumerHandle::Flags;
|
| @@ -41,7 +43,7 @@ public:
|
|
|
| class MockHandle : public WebDataConsumerHandle {
|
| public:
|
| - static PassOwnPtr<StrictMock<MockHandle>> create() { return adoptPtr(new StrictMock<MockHandle>); }
|
| + static std::unique_ptr<StrictMock<MockHandle>> create() { return wrapUnique(new StrictMock<MockHandle>); }
|
|
|
| MOCK_METHOD1(obtainReaderInternal, Reader*(Client*));
|
|
|
| @@ -57,7 +59,7 @@ public:
|
| void run()
|
| {
|
| ThreadHolder holder(this);
|
| - m_waitableEvent = adoptPtr(new WaitableEvent());
|
| + m_waitableEvent = wrapUnique(new WaitableEvent());
|
|
|
| postTaskToUpdatingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::createHandle, this));
|
| postTaskToReadingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::obtainReader, this));
|
| @@ -84,7 +86,7 @@ private:
|
| postTaskToReadingThread(BLINK_FROM_HERE, threadSafeBind(&Self::signalDone, this));
|
| }
|
|
|
| - OwnPtr<WebDataConsumerHandle> m_handle;
|
| + std::unique_ptr<WebDataConsumerHandle> m_handle;
|
| CrossThreadPersistent<CompositeDataConsumerHandle::Updater> m_updater;
|
| };
|
|
|
| @@ -96,7 +98,7 @@ public:
|
| void run()
|
| {
|
| ThreadHolder holder(this);
|
| - m_waitableEvent = adoptPtr(new WaitableEvent());
|
| + m_waitableEvent = wrapUnique(new WaitableEvent());
|
|
|
| postTaskToUpdatingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::createHandle, this));
|
| postTaskToReadingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::obtainReader, this));
|
| @@ -125,7 +127,7 @@ private:
|
| postTaskToReadingThread(BLINK_FROM_HERE, threadSafeBind(&Self::signalDone, this));
|
| }
|
|
|
| - OwnPtr<WebDataConsumerHandle> m_handle;
|
| + std::unique_ptr<WebDataConsumerHandle> m_handle;
|
| CrossThreadPersistent<CompositeDataConsumerHandle::Updater> m_updater;
|
| };
|
|
|
| @@ -137,7 +139,7 @@ public:
|
| void run()
|
| {
|
| ThreadHolder holder(this);
|
| - m_waitableEvent = adoptPtr(new WaitableEvent());
|
| + m_waitableEvent = wrapUnique(new WaitableEvent());
|
|
|
| postTaskToUpdatingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::createHandle, this));
|
| postTaskToReadingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::obtainReader, this));
|
| @@ -166,7 +168,7 @@ private:
|
| postTaskToReadingThread(BLINK_FROM_HERE, threadSafeBind(&Self::signalDone, this));
|
| }
|
|
|
| - OwnPtr<WebDataConsumerHandle> m_handle;
|
| + std::unique_ptr<WebDataConsumerHandle> m_handle;
|
| CrossThreadPersistent<CompositeDataConsumerHandle::Updater> m_updater;
|
| };
|
|
|
| @@ -178,8 +180,8 @@ public:
|
| void run()
|
| {
|
| ThreadHolder holder(this);
|
| - m_waitableEvent = adoptPtr(new WaitableEvent());
|
| - m_updateEvent = adoptPtr(new WaitableEvent());
|
| + m_waitableEvent = wrapUnique(new WaitableEvent());
|
| + m_updateEvent = wrapUnique(new WaitableEvent());
|
|
|
| postTaskToUpdatingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::createHandle, this));
|
| postTaskToReadingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::obtainReader, this));
|
| @@ -217,9 +219,9 @@ private:
|
| m_reader = m_handle->obtainReader(&m_client);
|
| }
|
|
|
| - OwnPtr<WebDataConsumerHandle> m_handle;
|
| + std::unique_ptr<WebDataConsumerHandle> m_handle;
|
| CrossThreadPersistent<CompositeDataConsumerHandle::Updater> m_updater;
|
| - OwnPtr<WaitableEvent> m_updateEvent;
|
| + std::unique_ptr<WaitableEvent> m_updateEvent;
|
| };
|
|
|
| class ThreadingRegistrationUpdateTwiceAtOneTimeTest : public DataConsumerHandleTestUtil::ThreadingTestBase {
|
| @@ -230,8 +232,8 @@ public:
|
| void run()
|
| {
|
| ThreadHolder holder(this);
|
| - m_waitableEvent = adoptPtr(new WaitableEvent());
|
| - m_updateEvent = adoptPtr(new WaitableEvent());
|
| + m_waitableEvent = wrapUnique(new WaitableEvent());
|
| + m_updateEvent = wrapUnique(new WaitableEvent());
|
|
|
| postTaskToUpdatingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::createHandle, this));
|
| postTaskToReadingThreadAndWait(BLINK_FROM_HERE, threadSafeBind(&Self::obtainReader, this));
|
| @@ -263,9 +265,9 @@ private:
|
| postTaskToReadingThread(BLINK_FROM_HERE, threadSafeBind(&Self::signalDone, this));
|
| }
|
|
|
| - OwnPtr<WebDataConsumerHandle> m_handle;
|
| + std::unique_ptr<WebDataConsumerHandle> m_handle;
|
| CrossThreadPersistent<CompositeDataConsumerHandle::Updater> m_updater;
|
| - OwnPtr<WaitableEvent> m_updateEvent;
|
| + std::unique_ptr<WaitableEvent> m_updateEvent;
|
| };
|
|
|
| TEST(CompositeDataConsumerHandleTest, Read)
|
| @@ -275,10 +277,10 @@ TEST(CompositeDataConsumerHandleTest, Read)
|
| DataConsumerHandleTestUtil::NoopClient client;
|
| Checkpoint checkpoint;
|
|
|
| - OwnPtr<MockHandle> handle1 = MockHandle::create();
|
| - OwnPtr<MockHandle> handle2 = MockHandle::create();
|
| - OwnPtr<MockReader> reader1 = MockReader::create();
|
| - OwnPtr<MockReader> reader2 = MockReader::create();
|
| + std::unique_ptr<MockHandle> handle1 = MockHandle::create();
|
| + std::unique_ptr<MockHandle> handle2 = MockHandle::create();
|
| + std::unique_ptr<MockReader> reader1 = MockReader::create();
|
| + std::unique_ptr<MockReader> reader2 = MockReader::create();
|
|
|
| InSequence s;
|
| EXPECT_CALL(checkpoint, Call(0));
|
| @@ -292,13 +294,13 @@ TEST(CompositeDataConsumerHandleTest, Read)
|
| EXPECT_CALL(checkpoint, Call(4));
|
|
|
| // They are adopted by |obtainReader|.
|
| - ASSERT_TRUE(reader1.leakPtr());
|
| - ASSERT_TRUE(reader2.leakPtr());
|
| + ASSERT_TRUE(reader1.release());
|
| + ASSERT_TRUE(reader2.release());
|
|
|
| CompositeDataConsumerHandle::Updater* updater = nullptr;
|
| - OwnPtr<WebDataConsumerHandle> handle = CompositeDataConsumerHandle::create(std::move(handle1), &updater);
|
| + std::unique_ptr<WebDataConsumerHandle> handle = CompositeDataConsumerHandle::create(std::move(handle1), &updater);
|
| checkpoint.Call(0);
|
| - OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(&client);
|
| + std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(&client);
|
| checkpoint.Call(1);
|
| EXPECT_EQ(kOk, reader->read(buffer, sizeof(buffer), kNone, &size));
|
| checkpoint.Call(2);
|
| @@ -314,10 +316,10 @@ TEST(CompositeDataConsumerHandleTest, TwoPhaseRead)
|
| size_t size = 0;
|
| Checkpoint checkpoint;
|
|
|
| - OwnPtr<MockHandle> handle1 = MockHandle::create();
|
| - OwnPtr<MockHandle> handle2 = MockHandle::create();
|
| - OwnPtr<MockReader> reader1 = MockReader::create();
|
| - OwnPtr<MockReader> reader2 = MockReader::create();
|
| + std::unique_ptr<MockHandle> handle1 = MockHandle::create();
|
| + std::unique_ptr<MockHandle> handle2 = MockHandle::create();
|
| + std::unique_ptr<MockReader> reader1 = MockReader::create();
|
| + std::unique_ptr<MockReader> reader2 = MockReader::create();
|
|
|
| InSequence s;
|
| EXPECT_CALL(checkpoint, Call(0));
|
| @@ -335,13 +337,13 @@ TEST(CompositeDataConsumerHandleTest, TwoPhaseRead)
|
| EXPECT_CALL(checkpoint, Call(6));
|
|
|
| // They are adopted by |obtainReader|.
|
| - ASSERT_TRUE(reader1.leakPtr());
|
| - ASSERT_TRUE(reader2.leakPtr());
|
| + ASSERT_TRUE(reader1.release());
|
| + ASSERT_TRUE(reader2.release());
|
|
|
| CompositeDataConsumerHandle::Updater* updater = nullptr;
|
| - OwnPtr<WebDataConsumerHandle> handle = CompositeDataConsumerHandle::create(std::move(handle1), &updater);
|
| + std::unique_ptr<WebDataConsumerHandle> handle = CompositeDataConsumerHandle::create(std::move(handle1), &updater);
|
| checkpoint.Call(0);
|
| - OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
|
| + std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
|
| checkpoint.Call(1);
|
| EXPECT_EQ(kOk, reader->beginRead(&p, kNone, &size));
|
| checkpoint.Call(2);
|
| @@ -361,12 +363,12 @@ TEST(CompositeDataConsumerHandleTest, HangingTwoPhaseRead)
|
| size_t size = 0;
|
| Checkpoint checkpoint;
|
|
|
| - OwnPtr<MockHandle> handle1 = MockHandle::create();
|
| - OwnPtr<MockHandle> handle2 = MockHandle::create();
|
| - OwnPtr<MockHandle> handle3 = MockHandle::create();
|
| - OwnPtr<MockReader> reader1 = MockReader::create();
|
| - OwnPtr<MockReader> reader2 = MockReader::create();
|
| - OwnPtr<MockReader> reader3 = MockReader::create();
|
| + std::unique_ptr<MockHandle> handle1 = MockHandle::create();
|
| + std::unique_ptr<MockHandle> handle2 = MockHandle::create();
|
| + std::unique_ptr<MockHandle> handle3 = MockHandle::create();
|
| + std::unique_ptr<MockReader> reader1 = MockReader::create();
|
| + std::unique_ptr<MockReader> reader2 = MockReader::create();
|
| + std::unique_ptr<MockReader> reader3 = MockReader::create();
|
|
|
| InSequence s;
|
| EXPECT_CALL(checkpoint, Call(0));
|
| @@ -388,14 +390,14 @@ TEST(CompositeDataConsumerHandleTest, HangingTwoPhaseRead)
|
| EXPECT_CALL(checkpoint, Call(8));
|
|
|
| // They are adopted by |obtainReader|.
|
| - ASSERT_TRUE(reader1.leakPtr());
|
| - ASSERT_TRUE(reader2.leakPtr());
|
| - ASSERT_TRUE(reader3.leakPtr());
|
| + ASSERT_TRUE(reader1.release());
|
| + ASSERT_TRUE(reader2.release());
|
| + ASSERT_TRUE(reader3.release());
|
|
|
| CompositeDataConsumerHandle::Updater* updater = nullptr;
|
| - OwnPtr<WebDataConsumerHandle> handle = CompositeDataConsumerHandle::create(std::move(handle1), &updater);
|
| + std::unique_ptr<WebDataConsumerHandle> handle = CompositeDataConsumerHandle::create(std::move(handle1), &updater);
|
| checkpoint.Call(0);
|
| - OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
|
| + std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
|
| checkpoint.Call(1);
|
| EXPECT_EQ(kOk, reader->beginRead(&p, kNone, &size));
|
| checkpoint.Call(2);
|
|
|