| Index: content/browser/loader/upload_data_stream_builder_unittest.cc
|
| diff --git a/content/browser/loader/upload_data_stream_builder_unittest.cc b/content/browser/loader/upload_data_stream_builder_unittest.cc
|
| index 57161eaf4caf1a281d91b2c5fd020e2c192f5f39..174a89bff0d43928cc57c42cced202d5cca5ab94 100644
|
| --- a/content/browser/loader/upload_data_stream_builder_unittest.cc
|
| +++ b/content/browser/loader/upload_data_stream_builder_unittest.cc
|
| @@ -9,9 +9,8 @@
|
|
|
| #include "base/files/file_path.h"
|
| #include "base/files/file_util.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/message_loop/message_loop_proxy.h"
|
| #include "base/run_loop.h"
|
| +#include "base/thread_task_runner_handle.h"
|
| #include "base/time/time.h"
|
| #include "content/common/resource_request_body.h"
|
| #include "net/base/io_buffer.h"
|
| @@ -78,7 +77,8 @@ TEST(UploadDataStreamBuilderTest, CreateUploadDataStreamWithoutBlob) {
|
| request_body->set_identifier(kIdentifier);
|
|
|
| scoped_ptr<net::UploadDataStream> upload(UploadDataStreamBuilder::Build(
|
| - request_body.get(), NULL, NULL, base::MessageLoopProxy::current().get()));
|
| + request_body.get(), NULL, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get()));
|
|
|
| EXPECT_EQ(kIdentifier, upload->identifier());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| @@ -146,12 +146,9 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| upload_element2.length(),
|
| upload_element2.expected_modification_time());
|
|
|
| - scoped_ptr<net::UploadDataStream> upload(
|
| - UploadDataStreamBuilder::Build(
|
| - request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get()));
|
| + scoped_ptr<net::UploadDataStream> upload(UploadDataStreamBuilder::Build(
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get()));
|
|
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(2U, upload->GetElementReaders()->size());
|
| @@ -165,10 +162,8 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| request_body->AppendBlob(blob_id0);
|
|
|
| upload = UploadDataStreamBuilder::Build(
|
| - request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(0U, upload->GetElementReaders()->size());
|
|
|
| @@ -177,10 +172,8 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| request_body->AppendBlob(blob_id1);
|
|
|
| upload = UploadDataStreamBuilder::Build(
|
| - request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(2U, upload->GetElementReaders()->size());
|
| EXPECT_TRUE(AreElementsEqual(
|
| @@ -201,10 +194,8 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| upload_element2.expected_modification_time());
|
|
|
| upload = UploadDataStreamBuilder::Build(
|
| - request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(4U, upload->GetElementReaders()->size());
|
| EXPECT_TRUE(AreElementsEqual(
|
| @@ -228,11 +219,9 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| upload_element2.expected_modification_time());
|
| request_body->AppendBlob(blob_id1);
|
|
|
| - upload =
|
| - UploadDataStreamBuilder::Build(request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + upload = UploadDataStreamBuilder::Build(
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(4U, upload->GetElementReaders()->size());
|
| EXPECT_TRUE(AreElementsEqual(
|
| @@ -257,10 +246,8 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| upload_element2.expected_modification_time());
|
|
|
| upload = UploadDataStreamBuilder::Build(
|
| - request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(4U, upload->GetElementReaders()->size());
|
| EXPECT_TRUE(AreElementsEqual(
|
| @@ -287,10 +274,8 @@ TEST(UploadDataStreamBuilderTest, ResolveBlobAndCreateUploadDataStream) {
|
| upload_element2.expected_modification_time());
|
|
|
| upload = UploadDataStreamBuilder::Build(
|
| - request_body.get(),
|
| - &blob_storage_context,
|
| - NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + request_body.get(), &blob_storage_context, NULL,
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| ASSERT_EQ(8U, upload->GetElementReaders()->size());
|
| EXPECT_TRUE(AreElementsEqual(
|
| @@ -341,7 +326,7 @@ TEST(UploadDataStreamBuilderTest,
|
| scoped_refptr<ResourceRequestBody> request_body(new ResourceRequestBody());
|
| scoped_ptr<net::UploadDataStream> upload(UploadDataStreamBuilder::Build(
|
| request_body.get(), &blob_storage_context, NULL,
|
| - base::MessageLoopProxy::current().get()));
|
| + base::ThreadTaskRunnerHandle::Get().get()));
|
|
|
| request_body = new ResourceRequestBody();
|
| request_body->AppendBlob(blob_id);
|
| @@ -350,7 +335,7 @@ TEST(UploadDataStreamBuilderTest,
|
|
|
| upload = UploadDataStreamBuilder::Build(
|
| request_body.get(), &blob_storage_context, NULL,
|
| - base::MessageLoopProxy::current().get());
|
| + base::ThreadTaskRunnerHandle::Get().get());
|
| ASSERT_TRUE(upload->GetElementReaders());
|
| const auto& readers = *upload->GetElementReaders();
|
| ASSERT_EQ(3U, readers.size());
|
|
|