OLD | NEW |
---|---|
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/browser/service_worker/embedded_worker_test_helper.h" | 5 #include "content/browser/service_worker/embedded_worker_test_helper.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <string> | 8 #include <string> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
89 ASSERT_TRUE(embedded_worker_id_); | 89 ASSERT_TRUE(embedded_worker_id_); |
90 EmbeddedWorkerInstance* worker = | 90 EmbeddedWorkerInstance* worker = |
91 helper_->registry()->GetWorker(embedded_worker_id_.value()); | 91 helper_->registry()->GetWorker(embedded_worker_id_.value()); |
92 // |worker| is possible to be null when corresponding EmbeddedWorkerInstance | 92 // |worker| is possible to be null when corresponding EmbeddedWorkerInstance |
93 // is removed right after sending StopWorker. | 93 // is removed right after sending StopWorker. |
94 if (worker) | 94 if (worker) |
95 EXPECT_EQ(EmbeddedWorkerStatus::STOPPING, worker->status()); | 95 EXPECT_EQ(EmbeddedWorkerStatus::STOPPING, worker->status()); |
96 helper_->OnStopWorkerStub(callback); | 96 helper_->OnStopWorkerStub(callback); |
97 } | 97 } |
98 | 98 |
99 void EmbeddedWorkerTestHelper::MockEmbeddedWorkerInstanceClient:: | |
100 ResumeAfterDownload() { | |
101 helper_->OnResumeAfterDownloadStub(embedded_worker_id_.value()); | |
102 } | |
103 | |
104 void EmbeddedWorkerTestHelper::MockEmbeddedWorkerInstanceClient:: | |
105 AddMessageToConsole(blink::WebConsoleMessage::Level level, | |
106 const std::string& message) { | |
107 NOTIMPLEMENTED(); | |
falken
2017/01/18 01:12:07
Do we need a TODO here? Why is it not implemented?
shimazu
2017/01/18 03:47:45
It's just because there is no test to use the resu
| |
108 } | |
109 | |
99 // static | 110 // static |
100 void EmbeddedWorkerTestHelper::MockEmbeddedWorkerInstanceClient::Bind( | 111 void EmbeddedWorkerTestHelper::MockEmbeddedWorkerInstanceClient::Bind( |
101 const base::WeakPtr<EmbeddedWorkerTestHelper>& helper, | 112 const base::WeakPtr<EmbeddedWorkerTestHelper>& helper, |
102 mojom::EmbeddedWorkerInstanceClientRequest request) { | 113 mojom::EmbeddedWorkerInstanceClientRequest request) { |
103 std::vector<std::unique_ptr<MockEmbeddedWorkerInstanceClient>>* clients = | 114 std::vector<std::unique_ptr<MockEmbeddedWorkerInstanceClient>>* clients = |
104 helper->mock_instance_clients(); | 115 helper->mock_instance_clients(); |
105 size_t next_client_index = helper->mock_instance_clients_next_index_; | 116 size_t next_client_index = helper->mock_instance_clients_next_index_; |
106 | 117 |
107 ASSERT_GE(clients->size(), next_client_index); | 118 ASSERT_GE(clients->size(), next_client_index); |
108 if (clients->size() == next_client_index) { | 119 if (clients->size() == next_client_index) { |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
222 | 233 |
223 bool EmbeddedWorkerTestHelper::Send(IPC::Message* message) { | 234 bool EmbeddedWorkerTestHelper::Send(IPC::Message* message) { |
224 OnMessageReceived(*message); | 235 OnMessageReceived(*message); |
225 delete message; | 236 delete message; |
226 return true; | 237 return true; |
227 } | 238 } |
228 | 239 |
229 bool EmbeddedWorkerTestHelper::OnMessageReceived(const IPC::Message& message) { | 240 bool EmbeddedWorkerTestHelper::OnMessageReceived(const IPC::Message& message) { |
230 bool handled = true; | 241 bool handled = true; |
231 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message) | 242 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message) |
232 IPC_MESSAGE_HANDLER(EmbeddedWorkerMsg_ResumeAfterDownload, | |
233 OnResumeAfterDownloadStub) | |
234 IPC_MESSAGE_HANDLER(EmbeddedWorkerContextMsg_MessageToWorker, | 243 IPC_MESSAGE_HANDLER(EmbeddedWorkerContextMsg_MessageToWorker, |
235 OnMessageToWorkerStub) | 244 OnMessageToWorkerStub) |
236 IPC_MESSAGE_UNHANDLED(handled = false) | 245 IPC_MESSAGE_UNHANDLED(handled = false) |
237 IPC_END_MESSAGE_MAP() | 246 IPC_END_MESSAGE_MAP() |
238 | 247 |
239 // IPC::TestSink only records messages that are not handled by filters, | 248 // IPC::TestSink only records messages that are not handled by filters, |
240 // so we just forward all messages to the separate sink. | 249 // so we just forward all messages to the separate sink. |
241 sink_.OnMessageReceived(message); | 250 sink_.OnMessageReceived(message); |
242 | 251 |
243 return handled; | 252 return handled; |
(...skipping 311 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
555 service_manager::InterfaceProviderSpec()); | 564 service_manager::InterfaceProviderSpec()); |
556 | 565 |
557 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( | 566 std::unique_ptr<service_manager::InterfaceProvider> remote_interfaces( |
558 new service_manager::InterfaceProvider); | 567 new service_manager::InterfaceProvider); |
559 remote_interfaces->Bind(std::move(interfaces)); | 568 remote_interfaces->Bind(std::move(interfaces)); |
560 rph->SetRemoteInterfaces(std::move(remote_interfaces)); | 569 rph->SetRemoteInterfaces(std::move(remote_interfaces)); |
561 return registry; | 570 return registry; |
562 } | 571 } |
563 | 572 |
564 } // namespace content | 573 } // namespace content |
OLD | NEW |