| 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 |