Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(61)

Side by Side Diff: content/browser/service_worker/embedded_worker_test_helper.cc

Issue 2218943002: Introduce ServiceWorker.EventDispatchingDelay UMA (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: incorporated mpearson@'s comment Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
11 #include "base/atomic_sequence_num.h" 11 #include "base/atomic_sequence_num.h"
12 #include "base/bind.h" 12 #include "base/bind.h"
13 #include "base/memory/scoped_vector.h" 13 #include "base/memory/scoped_vector.h"
14 #include "base/threading/thread_task_runner_handle.h" 14 #include "base/threading/thread_task_runner_handle.h"
15 #include "base/time/time.h"
15 #include "content/browser/message_port_message_filter.h" 16 #include "content/browser/message_port_message_filter.h"
16 #include "content/browser/service_worker/embedded_worker_instance.h" 17 #include "content/browser/service_worker/embedded_worker_instance.h"
17 #include "content/browser/service_worker/embedded_worker_registry.h" 18 #include "content/browser/service_worker/embedded_worker_registry.h"
18 #include "content/browser/service_worker/embedded_worker_status.h" 19 #include "content/browser/service_worker/embedded_worker_status.h"
19 #include "content/browser/service_worker/service_worker_context_core.h" 20 #include "content/browser/service_worker/service_worker_context_core.h"
20 #include "content/browser/service_worker/service_worker_context_wrapper.h" 21 #include "content/browser/service_worker/service_worker_context_wrapper.h"
21 #include "content/common/service_worker/embedded_worker_messages.h" 22 #include "content/common/service_worker/embedded_worker_messages.h"
22 #include "content/common/service_worker/embedded_worker_setup.mojom.h" 23 #include "content/common/service_worker/embedded_worker_setup.mojom.h"
23 #include "content/common/service_worker/service_worker_messages.h" 24 #include "content/common/service_worker/service_worker_messages.h"
24 #include "content/public/common/push_event_payload.h" 25 #include "content/public/common/push_event_payload.h"
(...skipping 180 matching lines...) Expand 10 before | Expand all | Expand 10 after
205 return handled; 206 return handled;
206 } 207 }
207 208
208 void EmbeddedWorkerTestHelper::OnSetupMojo( 209 void EmbeddedWorkerTestHelper::OnSetupMojo(
209 shell::InterfaceRegistry* interface_registry) {} 210 shell::InterfaceRegistry* interface_registry) {}
210 211
211 void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id, 212 void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id,
212 int request_id) { 213 int request_id) {
213 SimulateSend(new ServiceWorkerHostMsg_ActivateEventFinished( 214 SimulateSend(new ServiceWorkerHostMsg_ActivateEventFinished(
214 embedded_worker_id, request_id, 215 embedded_worker_id, request_id,
215 blink::WebServiceWorkerEventResultCompleted)); 216 blink::WebServiceWorkerEventResultCompleted, base::Time::Now()));
216 } 217 }
217 218
218 void EmbeddedWorkerTestHelper::OnExtendableMessageEvent(int embedded_worker_id, 219 void EmbeddedWorkerTestHelper::OnExtendableMessageEvent(int embedded_worker_id,
219 int request_id) { 220 int request_id) {
220 SimulateSend(new ServiceWorkerHostMsg_ExtendableMessageEventFinished( 221 SimulateSend(new ServiceWorkerHostMsg_ExtendableMessageEventFinished(
221 embedded_worker_id, request_id, 222 embedded_worker_id, request_id,
222 blink::WebServiceWorkerEventResultCompleted)); 223 blink::WebServiceWorkerEventResultCompleted, base::Time::Now()));
223 } 224 }
224 225
225 void EmbeddedWorkerTestHelper::OnInstallEvent(int embedded_worker_id, 226 void EmbeddedWorkerTestHelper::OnInstallEvent(int embedded_worker_id,
226 int request_id) { 227 int request_id) {
227 // The installing worker may have been doomed and terminated. 228 // The installing worker may have been doomed and terminated.
228 if (!registry()->GetWorker(embedded_worker_id)) 229 if (!registry()->GetWorker(embedded_worker_id))
229 return; 230 return;
230 SimulateSend(new ServiceWorkerHostMsg_InstallEventFinished( 231 SimulateSend(new ServiceWorkerHostMsg_InstallEventFinished(
231 embedded_worker_id, request_id, 232 embedded_worker_id, request_id,
232 blink::WebServiceWorkerEventResultCompleted, true)); 233 blink::WebServiceWorkerEventResultCompleted, true, base::Time::Now()));
233 } 234 }
234 235
235 void EmbeddedWorkerTestHelper::OnFetchEvent( 236 void EmbeddedWorkerTestHelper::OnFetchEvent(
236 int embedded_worker_id, 237 int embedded_worker_id,
237 int response_id, 238 int response_id,
238 int event_finish_id, 239 int event_finish_id,
239 const ServiceWorkerFetchRequest& request) { 240 const ServiceWorkerFetchRequest& request) {
240 SimulateSend(new ServiceWorkerHostMsg_FetchEventResponse( 241 SimulateSend(new ServiceWorkerHostMsg_FetchEventResponse(
241 embedded_worker_id, response_id, 242 embedded_worker_id, response_id,
242 SERVICE_WORKER_FETCH_EVENT_RESULT_RESPONSE, 243 SERVICE_WORKER_FETCH_EVENT_RESULT_RESPONSE,
243 ServiceWorkerResponse( 244 ServiceWorkerResponse(
244 GURL(), 200, "OK", blink::WebServiceWorkerResponseTypeDefault, 245 GURL(), 200, "OK", blink::WebServiceWorkerResponseTypeDefault,
245 ServiceWorkerHeaderMap(), std::string(), 0, GURL(), 246 ServiceWorkerHeaderMap(), std::string(), 0, GURL(),
246 blink::WebServiceWorkerResponseErrorUnknown, base::Time(), 247 blink::WebServiceWorkerResponseErrorUnknown, base::Time(),
247 false /* is_in_cache_storage */, 248 false /* is_in_cache_storage */,
248 std::string() /* cache_storage_cache_name */, 249 std::string() /* cache_storage_cache_name */,
249 ServiceWorkerHeaderList() /* cors_exposed_header_names */))); 250 ServiceWorkerHeaderList() /* cors_exposed_header_names */),
251 base::Time::Now()));
250 SimulateSend(new ServiceWorkerHostMsg_FetchEventFinished( 252 SimulateSend(new ServiceWorkerHostMsg_FetchEventFinished(
251 embedded_worker_id, event_finish_id, 253 embedded_worker_id, event_finish_id,
252 blink::WebServiceWorkerEventResultCompleted)); 254 blink::WebServiceWorkerEventResultCompleted, base::Time::Now()));
253 } 255 }
254 256
255 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id, 257 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id,
256 int request_id, 258 int request_id,
257 const PushEventPayload& payload) { 259 const PushEventPayload& payload) {
258 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished( 260 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished(
259 embedded_worker_id, request_id, 261 embedded_worker_id, request_id,
260 blink::WebServiceWorkerEventResultCompleted)); 262 blink::WebServiceWorkerEventResultCompleted, base::Time::Now()));
261 } 263 }
262 264
263 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( 265 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection(
264 int embedded_worker_id) { 266 int embedded_worker_id) {
265 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); 267 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
266 ASSERT_TRUE(worker != NULL); 268 ASSERT_TRUE(worker != NULL);
267 registry()->OnWorkerReadyForInspection(worker->process_id(), 269 registry()->OnWorkerReadyForInspection(worker->process_id(),
268 embedded_worker_id); 270 embedded_worker_id);
269 } 271 }
270 272
(...skipping 167 matching lines...) Expand 10 before | Expand all | Expand 10 after
438 440
439 MessagePortMessageFilter* 441 MessagePortMessageFilter*
440 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { 442 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() {
441 scoped_refptr<MessagePortMessageFilter> filter( 443 scoped_refptr<MessagePortMessageFilter> filter(
442 new MockMessagePortMessageFilter); 444 new MockMessagePortMessageFilter);
443 message_port_message_filters_.push_back(filter); 445 message_port_message_filters_.push_back(filter);
444 return filter.get(); 446 return filter.get();
445 } 447 }
446 448
447 } // namespace content 449 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698