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 | 9 |
10 #include "base/atomic_sequence_num.h" | 10 #include "base/atomic_sequence_num.h" |
(...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
133 void EmbeddedWorkerTestHelper::OnStartWorker(int embedded_worker_id, | 133 void EmbeddedWorkerTestHelper::OnStartWorker(int embedded_worker_id, |
134 int64 service_worker_version_id, | 134 int64 service_worker_version_id, |
135 const GURL& scope, | 135 const GURL& scope, |
136 const GURL& script_url) { | 136 const GURL& script_url) { |
137 embedded_worker_id_service_worker_version_id_map_[embedded_worker_id] = | 137 embedded_worker_id_service_worker_version_id_map_[embedded_worker_id] = |
138 service_worker_version_id; | 138 service_worker_version_id; |
139 SimulateWorkerReadyForInspection(embedded_worker_id); | 139 SimulateWorkerReadyForInspection(embedded_worker_id); |
140 SimulateWorkerScriptCached(embedded_worker_id); | 140 SimulateWorkerScriptCached(embedded_worker_id); |
141 SimulateWorkerScriptLoaded(embedded_worker_id); | 141 SimulateWorkerScriptLoaded(embedded_worker_id); |
142 SimulateWorkerThreadStarted(next_thread_id_++, embedded_worker_id); | 142 SimulateWorkerThreadStarted(next_thread_id_++, embedded_worker_id); |
143 SimulateWorkerScriptEvaluated(embedded_worker_id); | 143 SimulateWorkerScriptEvaluated(embedded_worker_id, true /* success */); |
144 SimulateWorkerStarted(embedded_worker_id); | 144 SimulateWorkerStarted(embedded_worker_id); |
145 } | 145 } |
146 | 146 |
| 147 void EmbeddedWorkerTestHelper::OnStartWorkerFailed( |
| 148 int embedded_worker_id, |
| 149 int64 service_worker_version_id, |
| 150 const GURL& scope, |
| 151 const GURL& script_url) { |
| 152 embedded_worker_id_service_worker_version_id_map_[embedded_worker_id] = |
| 153 service_worker_version_id; |
| 154 SimulateWorkerReadyForInspection(embedded_worker_id); |
| 155 SimulateWorkerScriptCached(embedded_worker_id); |
| 156 SimulateWorkerScriptLoaded(embedded_worker_id); |
| 157 SimulateWorkerThreadStarted(next_thread_id_++, embedded_worker_id); |
| 158 SimulateWorkerScriptEvaluated(embedded_worker_id, false /* failure */); |
| 159 } |
| 160 |
147 void EmbeddedWorkerTestHelper::OnStopWorker(int embedded_worker_id) { | 161 void EmbeddedWorkerTestHelper::OnStopWorker(int embedded_worker_id) { |
148 // By default just notify the sender that the worker is stopped. | 162 // By default just notify the sender that the worker is stopped. |
149 SimulateWorkerStopped(embedded_worker_id); | 163 SimulateWorkerStopped(embedded_worker_id); |
150 } | 164 } |
151 | 165 |
152 bool EmbeddedWorkerTestHelper::OnMessageToWorker( | 166 bool EmbeddedWorkerTestHelper::OnMessageToWorker( |
153 int thread_id, | 167 int thread_id, |
154 int embedded_worker_id, | 168 int embedded_worker_id, |
155 const IPC::Message& message) { | 169 const IPC::Message& message) { |
156 bool handled = true; | 170 bool handled = true; |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
241 void EmbeddedWorkerTestHelper::SimulateWorkerThreadStarted( | 255 void EmbeddedWorkerTestHelper::SimulateWorkerThreadStarted( |
242 int thread_id, | 256 int thread_id, |
243 int embedded_worker_id) { | 257 int embedded_worker_id) { |
244 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); | 258 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
245 ASSERT_TRUE(worker != NULL); | 259 ASSERT_TRUE(worker != NULL); |
246 registry()->OnWorkerThreadStarted(worker->process_id(), thread_id, | 260 registry()->OnWorkerThreadStarted(worker->process_id(), thread_id, |
247 embedded_worker_id); | 261 embedded_worker_id); |
248 } | 262 } |
249 | 263 |
250 void EmbeddedWorkerTestHelper::SimulateWorkerScriptEvaluated( | 264 void EmbeddedWorkerTestHelper::SimulateWorkerScriptEvaluated( |
251 int embedded_worker_id) { | 265 int embedded_worker_id, |
| 266 bool success) { |
252 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); | 267 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
253 ASSERT_TRUE(worker != NULL); | 268 ASSERT_TRUE(worker != NULL); |
254 registry()->OnWorkerScriptEvaluated( | 269 registry()->OnWorkerScriptEvaluated(worker->process_id(), embedded_worker_id, |
255 worker->process_id(), embedded_worker_id, true /* success */); | 270 success); |
256 } | 271 } |
257 | 272 |
258 void EmbeddedWorkerTestHelper::SimulateWorkerStarted( | 273 void EmbeddedWorkerTestHelper::SimulateWorkerStarted( |
259 int embedded_worker_id) { | 274 int embedded_worker_id) { |
260 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); | 275 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); |
261 ASSERT_TRUE(worker != NULL); | 276 ASSERT_TRUE(worker != NULL); |
262 registry()->OnWorkerStarted( | 277 registry()->OnWorkerStarted( |
263 worker->process_id(), | 278 worker->process_id(), |
264 embedded_worker_id); | 279 embedded_worker_id); |
265 } | 280 } |
(...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
363 | 378 |
364 MessagePortMessageFilter* | 379 MessagePortMessageFilter* |
365 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { | 380 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { |
366 scoped_refptr<MessagePortMessageFilter> filter( | 381 scoped_refptr<MessagePortMessageFilter> filter( |
367 new MockMessagePortMessageFilter); | 382 new MockMessagePortMessageFilter); |
368 message_port_message_filters_.push_back(filter); | 383 message_port_message_filters_.push_back(filter); |
369 return filter.get(); | 384 return filter.get(); |
370 } | 385 } |
371 | 386 |
372 } // namespace content | 387 } // namespace content |
OLD | NEW |