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

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

Issue 1220943003: [Background Sync] Use Mojo IPC to fire background sync events (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@mek
Patch Set: Addressing post-lgtm review comments Created 5 years, 5 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 9
10 #include "base/atomic_sequence_num.h" 10 #include "base/atomic_sequence_num.h"
(...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after
128 int thread_id, 128 int thread_id,
129 int embedded_worker_id, 129 int embedded_worker_id,
130 const IPC::Message& message) { 130 const IPC::Message& message) {
131 bool handled = true; 131 bool handled = true;
132 current_embedded_worker_id_ = embedded_worker_id; 132 current_embedded_worker_id_ = embedded_worker_id;
133 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message) 133 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message)
134 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_ActivateEvent, OnActivateEventStub) 134 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_ActivateEvent, OnActivateEventStub)
135 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_InstallEvent, OnInstallEventStub) 135 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_InstallEvent, OnInstallEventStub)
136 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_FetchEvent, OnFetchEventStub) 136 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_FetchEvent, OnFetchEventStub)
137 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_PushEvent, OnPushEventStub) 137 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_PushEvent, OnPushEventStub)
138 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_SyncEvent, OnSyncEventStub)
139 IPC_MESSAGE_UNHANDLED(handled = false) 138 IPC_MESSAGE_UNHANDLED(handled = false)
140 IPC_END_MESSAGE_MAP() 139 IPC_END_MESSAGE_MAP()
141 // Record all messages directed to inner script context. 140 // Record all messages directed to inner script context.
142 inner_sink_.OnMessageReceived(message); 141 inner_sink_.OnMessageReceived(message);
143 return handled; 142 return handled;
144 } 143 }
145 144
146 void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id, 145 void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id,
147 int request_id) { 146 int request_id) {
148 SimulateSend( 147 SimulateSend(
(...skipping 27 matching lines...) Expand all
176 } 175 }
177 176
178 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id, 177 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id,
179 int request_id, 178 int request_id,
180 const std::string& data) { 179 const std::string& data) {
181 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished( 180 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished(
182 embedded_worker_id, request_id, 181 embedded_worker_id, request_id,
183 blink::WebServiceWorkerEventResultCompleted)); 182 blink::WebServiceWorkerEventResultCompleted));
184 } 183 }
185 184
186 void EmbeddedWorkerTestHelper::OnSyncEvent(int embedded_worker_id,
187 int request_id) {
188 SimulateSend(new ServiceWorkerHostMsg_SyncEventFinished(
189 embedded_worker_id, request_id,
190 blink::WebServiceWorkerEventResultCompleted));
191 }
192
193 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( 185 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection(
194 int embedded_worker_id) { 186 int embedded_worker_id) {
195 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); 187 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
196 ASSERT_TRUE(worker != NULL); 188 ASSERT_TRUE(worker != NULL);
197 registry()->OnWorkerReadyForInspection(worker->process_id(), 189 registry()->OnWorkerReadyForInspection(worker->process_id(),
198 embedded_worker_id); 190 embedded_worker_id);
199 } 191 }
200 192
201 void EmbeddedWorkerTestHelper::SimulateWorkerScriptCached( 193 void EmbeddedWorkerTestHelper::SimulateWorkerScriptCached(
202 int embedded_worker_id) { 194 int embedded_worker_id) {
(...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after
324 } 316 }
325 317
326 void EmbeddedWorkerTestHelper::OnPushEventStub(int request_id, 318 void EmbeddedWorkerTestHelper::OnPushEventStub(int request_id,
327 const std::string& data) { 319 const std::string& data) {
328 base::ThreadTaskRunnerHandle::Get()->PostTask( 320 base::ThreadTaskRunnerHandle::Get()->PostTask(
329 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, 321 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent,
330 weak_factory_.GetWeakPtr(), 322 weak_factory_.GetWeakPtr(),
331 current_embedded_worker_id_, request_id, data)); 323 current_embedded_worker_id_, request_id, data));
332 } 324 }
333 325
334 void EmbeddedWorkerTestHelper::OnSyncEventStub(int request_id) {
335 base::ThreadTaskRunnerHandle::Get()->PostTask(
336 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnSyncEvent,
337 weak_factory_.GetWeakPtr(),
338 current_embedded_worker_id_, request_id));
339 }
340
341 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { 326 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() {
342 DCHECK(context()); 327 DCHECK(context());
343 return context()->embedded_worker_registry(); 328 return context()->embedded_worker_registry();
344 } 329 }
345 330
346 MessagePortMessageFilter* 331 MessagePortMessageFilter*
347 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { 332 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() {
348 scoped_refptr<MessagePortMessageFilter> filter( 333 scoped_refptr<MessagePortMessageFilter> filter(
349 new MockMessagePortMessageFilter); 334 new MockMessagePortMessageFilter);
350 message_port_message_filters_.push_back(filter); 335 message_port_message_filters_.push_back(filter);
351 return filter.get(); 336 return filter.get();
352 } 337 }
353 338
354 } // namespace content 339 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698