OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/child/shared_memory_data_consumer_handle.h" | 5 #include "content/child/shared_memory_data_consumer_handle.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <string.h> | 8 #include <string.h> |
9 | 9 |
10 #include <string> | 10 #include <string> |
11 #include <utility> | 11 #include <utility> |
12 #include <vector> | 12 #include <vector> |
13 | 13 |
14 #include "base/bind.h" | 14 #include "base/bind.h" |
15 #include "base/callback.h" | 15 #include "base/callback.h" |
16 #include "base/location.h" | 16 #include "base/location.h" |
17 #include "base/macros.h" | 17 #include "base/macros.h" |
18 #include "base/memory/ptr_util.h" | 18 #include "base/memory/ptr_util.h" |
19 #include "base/message_loop/message_loop.h" | 19 #include "base/message_loop/message_loop.h" |
20 #include "base/run_loop.h" | 20 #include "base/run_loop.h" |
| 21 #include "base/single_thread_task_runner.h" |
21 #include "base/task_runner.h" | 22 #include "base/task_runner.h" |
22 #include "base/threading/thread.h" | 23 #include "base/threading/thread.h" |
23 #include "base/threading/thread_task_runner_handle.h" | 24 #include "base/threading/thread_task_runner_handle.h" |
24 #include "content/public/child/fixed_received_data.h" | 25 #include "content/public/child/fixed_received_data.h" |
25 #include "testing/gmock/include/gmock/gmock.h" | 26 #include "testing/gmock/include/gmock/gmock.h" |
26 #include "testing/gtest/include/gtest/gtest.h" | 27 #include "testing/gtest/include/gtest/gtest.h" |
27 | 28 |
28 namespace content { | 29 namespace content { |
29 | 30 |
30 namespace { | 31 namespace { |
(...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
159 return; | 160 return; |
160 } | 161 } |
161 | 162 |
162 if (rv != kDone) { | 163 if (rv != kDone) { |
163 // Something is wrong. | 164 // Something is wrong. |
164 result_ = "error"; | 165 result_ = "error"; |
165 } | 166 } |
166 | 167 |
167 // The operation is done. | 168 // The operation is done. |
168 reader_.reset(); | 169 reader_.reset(); |
169 main_message_loop_->PostTask(FROM_HERE, on_done_); | 170 main_message_loop_->task_runner()->PostTask(FROM_HERE, on_done_); |
170 } | 171 } |
171 | 172 |
172 private: | 173 private: |
173 std::unique_ptr<SharedMemoryDataConsumerHandle> handle_; | 174 std::unique_ptr<SharedMemoryDataConsumerHandle> handle_; |
174 std::unique_ptr<WebDataConsumerHandle::Reader> reader_; | 175 std::unique_ptr<WebDataConsumerHandle::Reader> reader_; |
175 std::unique_ptr<WebDataConsumerHandle::Client> client_; | 176 std::unique_ptr<WebDataConsumerHandle::Client> client_; |
176 base::MessageLoop* main_message_loop_; | 177 base::MessageLoop* main_message_loop_; |
177 base::Closure on_done_; | 178 base::Closure on_done_; |
178 std::string result_; | 179 std::string result_; |
179 }; | 180 }; |
(...skipping 824 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1004 | 1005 |
1005 TEST_F(ThreadedSharedMemoryDataConsumerHandleTest, Read) { | 1006 TEST_F(ThreadedSharedMemoryDataConsumerHandleTest, Read) { |
1006 base::RunLoop run_loop; | 1007 base::RunLoop run_loop; |
1007 auto operation = base::WrapUnique(new ReadDataOperation( | 1008 auto operation = base::WrapUnique(new ReadDataOperation( |
1008 std::move(handle_), &loop_, run_loop.QuitClosure())); | 1009 std::move(handle_), &loop_, run_loop.QuitClosure())); |
1009 scoped_refptr<Logger> logger(new Logger); | 1010 scoped_refptr<Logger> logger(new Logger); |
1010 | 1011 |
1011 base::Thread t("DataConsumerHandle test thread"); | 1012 base::Thread t("DataConsumerHandle test thread"); |
1012 ASSERT_TRUE(t.Start()); | 1013 ASSERT_TRUE(t.Start()); |
1013 | 1014 |
1014 t.message_loop()->PostTask(FROM_HERE, | 1015 t.task_runner()->PostTask(FROM_HERE, |
1015 base::Bind(&ReadDataOperation::ReadData, | 1016 base::Bind(&ReadDataOperation::ReadData, |
1016 base::Unretained(operation.get()))); | 1017 base::Unretained(operation.get()))); |
1017 | 1018 |
1018 logger->Add("1"); | 1019 logger->Add("1"); |
1019 writer_->AddData( | 1020 writer_->AddData( |
1020 base::WrapUnique(new LoggingFixedReceivedData("data1", "Once ", logger))); | 1021 base::WrapUnique(new LoggingFixedReceivedData("data1", "Once ", logger))); |
1021 writer_->AddData( | 1022 writer_->AddData( |
1022 base::WrapUnique(new LoggingFixedReceivedData("data2", "upon ", logger))); | 1023 base::WrapUnique(new LoggingFixedReceivedData("data2", "upon ", logger))); |
1023 writer_->AddData(base::WrapUnique( | 1024 writer_->AddData(base::WrapUnique( |
1024 new LoggingFixedReceivedData("data3", "a time ", logger))); | 1025 new LoggingFixedReceivedData("data3", "a time ", logger))); |
1025 writer_->AddData(base::WrapUnique( | 1026 writer_->AddData(base::WrapUnique( |
1026 new LoggingFixedReceivedData("data4", "there ", logger))); | 1027 new LoggingFixedReceivedData("data4", "there ", logger))); |
(...skipping 17 matching lines...) Expand all Loading... |
1044 logger->log()); | 1045 logger->log()); |
1045 } | 1046 } |
1046 | 1047 |
1047 INSTANTIATE_TEST_CASE_P(SharedMemoryDataConsumerHandleTest, | 1048 INSTANTIATE_TEST_CASE_P(SharedMemoryDataConsumerHandleTest, |
1048 SharedMemoryDataConsumerHandleTest, | 1049 SharedMemoryDataConsumerHandleTest, |
1049 ::testing::Values(kApplyBackpressure, | 1050 ::testing::Values(kApplyBackpressure, |
1050 kDoNotApplyBackpressure)); | 1051 kDoNotApplyBackpressure)); |
1051 } // namespace | 1052 } // namespace |
1052 | 1053 |
1053 } // namespace content | 1054 } // namespace content |
OLD | NEW |