| Index: third_party/WebKit/Source/modules/fetch/FetchBlobDataConsumerHandle.cpp
|
| diff --git a/third_party/WebKit/Source/modules/fetch/FetchBlobDataConsumerHandle.cpp b/third_party/WebKit/Source/modules/fetch/FetchBlobDataConsumerHandle.cpp
|
| index d7a02544ff9fe9486794327d4073006eef2f0f37..9a860087b064d472d19c7a943e3f8f971d78bac1 100644
|
| --- a/third_party/WebKit/Source/modules/fetch/FetchBlobDataConsumerHandle.cpp
|
| +++ b/third_party/WebKit/Source/modules/fetch/FetchBlobDataConsumerHandle.cpp
|
| @@ -13,8 +13,7 @@
|
| #include "platform/blob/BlobRegistry.h"
|
| #include "platform/blob/BlobURL.h"
|
| #include "platform/network/ResourceRequest.h"
|
| -#include "wtf/PtrUtil.h"
|
| -#include <memory>
|
| +#include "wtf/OwnPtr.h"
|
|
|
| namespace blink {
|
|
|
| @@ -103,7 +102,7 @@ public:
|
| }
|
|
|
| private:
|
| - std::unique_ptr<ThreadableLoader> createLoader(ExecutionContext* executionContext, ThreadableLoaderClient* client) const
|
| + PassOwnPtr<ThreadableLoader> createLoader(ExecutionContext* executionContext, ThreadableLoaderClient* client) const
|
| {
|
| ThreadableLoaderOptions options;
|
| options.preflightPolicy = ConsiderPreflight;
|
| @@ -118,7 +117,7 @@ private:
|
| }
|
|
|
| // ThreadableLoaderClient
|
| - void didReceiveResponse(unsigned long, const ResourceResponse&, std::unique_ptr<WebDataConsumerHandle> handle) override
|
| + void didReceiveResponse(unsigned long, const ResourceResponse&, PassOwnPtr<WebDataConsumerHandle> handle) override
|
| {
|
| ASSERT(!m_receivedResponse);
|
| m_receivedResponse = true;
|
| @@ -154,14 +153,14 @@ private:
|
|
|
| RefPtr<BlobDataHandle> m_blobDataHandle;
|
| Persistent<FetchBlobDataConsumerHandle::LoaderFactory> m_loaderFactory;
|
| - std::unique_ptr<ThreadableLoader> m_loader;
|
| + OwnPtr<ThreadableLoader> m_loader;
|
|
|
| bool m_receivedResponse;
|
| };
|
|
|
| class DefaultLoaderFactory final : public FetchBlobDataConsumerHandle::LoaderFactory {
|
| public:
|
| - std::unique_ptr<ThreadableLoader> create(
|
| + PassOwnPtr<ThreadableLoader> create(
|
| ExecutionContext& executionContext,
|
| ThreadableLoaderClient* client,
|
| const ThreadableLoaderOptions& options,
|
| @@ -181,7 +180,7 @@ class FetchBlobDataConsumerHandle::ReaderContext final : public ThreadSafeRefCou
|
| public:
|
| class ReaderImpl : public FetchDataConsumerHandle::Reader {
|
| public:
|
| - ReaderImpl(Client* client, PassRefPtr<ReaderContext> readerContext, std::unique_ptr<WebDataConsumerHandle::Reader> reader)
|
| + ReaderImpl(Client* client, PassRefPtr<ReaderContext> readerContext, PassOwnPtr<WebDataConsumerHandle::Reader> reader)
|
| : m_readerContext(readerContext)
|
| , m_reader(std::move(reader))
|
| , m_notifier(client) { }
|
| @@ -239,7 +238,7 @@ public:
|
|
|
| private:
|
| RefPtr<ReaderContext> m_readerContext;
|
| - std::unique_ptr<WebDataConsumerHandle::Reader> m_reader;
|
| + OwnPtr<WebDataConsumerHandle::Reader> m_reader;
|
| NotifyOnReaderCreationHelper m_notifier;
|
| };
|
|
|
| @@ -250,12 +249,12 @@ public:
|
| {
|
| CompositeDataConsumerHandle::Updater* updater = nullptr;
|
| m_handle = CompositeDataConsumerHandle::create(createWaitingDataConsumerHandle(), &updater);
|
| - m_loaderContextHolder = CrossThreadHolder<LoaderContext>::create(executionContext, wrapUnique(new BlobLoaderContext(updater, m_blobDataHandleForDrain, loaderFactory)));
|
| + m_loaderContextHolder = CrossThreadHolder<LoaderContext>::create(executionContext, adoptPtr(new BlobLoaderContext(updater, m_blobDataHandleForDrain, loaderFactory)));
|
| }
|
|
|
| - std::unique_ptr<FetchDataConsumerHandle::Reader> obtainReader(WebDataConsumerHandle::Client* client)
|
| + PassOwnPtr<FetchDataConsumerHandle::Reader> obtainReader(WebDataConsumerHandle::Client* client)
|
| {
|
| - return wrapUnique(new ReaderImpl(client, this, m_handle->obtainReader(client)));
|
| + return adoptPtr(new ReaderImpl(client, this, m_handle->obtainReader(client)));
|
| }
|
|
|
| private:
|
| @@ -275,9 +274,9 @@ private:
|
| bool drained() const { return m_drained; }
|
| void setDrained() { m_drained = true; }
|
|
|
| - std::unique_ptr<WebDataConsumerHandle> m_handle;
|
| + OwnPtr<WebDataConsumerHandle> m_handle;
|
| RefPtr<BlobDataHandle> m_blobDataHandleForDrain;
|
| - std::unique_ptr<CrossThreadHolder<LoaderContext>> m_loaderContextHolder;
|
| + OwnPtr<CrossThreadHolder<LoaderContext>> m_loaderContextHolder;
|
|
|
| bool m_loaderStarted;
|
| bool m_drained;
|
| @@ -292,25 +291,25 @@ FetchBlobDataConsumerHandle::~FetchBlobDataConsumerHandle()
|
| {
|
| }
|
|
|
| -std::unique_ptr<FetchDataConsumerHandle> FetchBlobDataConsumerHandle::create(ExecutionContext* executionContext, PassRefPtr<BlobDataHandle> blobDataHandle, LoaderFactory* loaderFactory)
|
| +PassOwnPtr<FetchDataConsumerHandle> FetchBlobDataConsumerHandle::create(ExecutionContext* executionContext, PassRefPtr<BlobDataHandle> blobDataHandle, LoaderFactory* loaderFactory)
|
| {
|
| if (!blobDataHandle)
|
| return createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle());
|
|
|
| - return wrapUnique(new FetchBlobDataConsumerHandle(executionContext, blobDataHandle, loaderFactory));
|
| + return adoptPtr(new FetchBlobDataConsumerHandle(executionContext, blobDataHandle, loaderFactory));
|
| }
|
|
|
| -std::unique_ptr<FetchDataConsumerHandle> FetchBlobDataConsumerHandle::create(ExecutionContext* executionContext, PassRefPtr<BlobDataHandle> blobDataHandle)
|
| +PassOwnPtr<FetchDataConsumerHandle> FetchBlobDataConsumerHandle::create(ExecutionContext* executionContext, PassRefPtr<BlobDataHandle> blobDataHandle)
|
| {
|
| if (!blobDataHandle)
|
| return createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle());
|
|
|
| - return wrapUnique(new FetchBlobDataConsumerHandle(executionContext, blobDataHandle, new DefaultLoaderFactory));
|
| + return adoptPtr(new FetchBlobDataConsumerHandle(executionContext, blobDataHandle, new DefaultLoaderFactory));
|
| }
|
|
|
| FetchDataConsumerHandle::Reader* FetchBlobDataConsumerHandle::obtainReaderInternal(Client* client)
|
| {
|
| - return m_readerContext->obtainReader(client).release();
|
| + return m_readerContext->obtainReader(client).leakPtr();
|
| }
|
|
|
| } // namespace blink
|
|
|