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