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

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

Issue 1171173002: [Background Sync] Use Mojo IPC to fire background sync events (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Remove Chromium IPC for Sync from unit tests' 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 133 matching lines...) Expand 10 before | Expand all | Expand 10 after
144 int thread_id, 144 int thread_id,
145 int embedded_worker_id, 145 int embedded_worker_id,
146 const IPC::Message& message) { 146 const IPC::Message& message) {
147 bool handled = true; 147 bool handled = true;
148 current_embedded_worker_id_ = embedded_worker_id; 148 current_embedded_worker_id_ = embedded_worker_id;
149 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message) 149 IPC_BEGIN_MESSAGE_MAP(EmbeddedWorkerTestHelper, message)
150 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_ActivateEvent, OnActivateEventStub) 150 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_ActivateEvent, OnActivateEventStub)
151 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_InstallEvent, OnInstallEventStub) 151 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_InstallEvent, OnInstallEventStub)
152 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_FetchEvent, OnFetchEventStub) 152 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_FetchEvent, OnFetchEventStub)
153 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_PushEvent, OnPushEventStub) 153 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_PushEvent, OnPushEventStub)
154 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_SyncEvent, OnSyncEventStub)
155 IPC_MESSAGE_UNHANDLED(handled = false) 154 IPC_MESSAGE_UNHANDLED(handled = false)
156 IPC_END_MESSAGE_MAP() 155 IPC_END_MESSAGE_MAP()
157 // Record all messages directed to inner script context. 156 // Record all messages directed to inner script context.
158 inner_sink_.OnMessageReceived(message); 157 inner_sink_.OnMessageReceived(message);
159 return handled; 158 return handled;
160 } 159 }
161 160
162 void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id, 161 void EmbeddedWorkerTestHelper::OnActivateEvent(int embedded_worker_id,
163 int request_id) { 162 int request_id) {
164 SimulateSend( 163 SimulateSend(
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
197 } 196 }
198 197
199 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id, 198 void EmbeddedWorkerTestHelper::OnPushEvent(int embedded_worker_id,
200 int request_id, 199 int request_id,
201 const std::string& data) { 200 const std::string& data) {
202 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished( 201 SimulateSend(new ServiceWorkerHostMsg_PushEventFinished(
203 embedded_worker_id, request_id, 202 embedded_worker_id, request_id,
204 blink::WebServiceWorkerEventResultCompleted)); 203 blink::WebServiceWorkerEventResultCompleted));
205 } 204 }
206 205
207 void EmbeddedWorkerTestHelper::OnSyncEvent(int embedded_worker_id,
208 int request_id) {
209 SimulateSend(new ServiceWorkerHostMsg_SyncEventFinished(
210 embedded_worker_id, request_id,
211 blink::WebServiceWorkerEventResultCompleted));
212 }
213
214 void EmbeddedWorkerTestHelper::SimulatePausedAfterDownload( 206 void EmbeddedWorkerTestHelper::SimulatePausedAfterDownload(
215 int embedded_worker_id) { 207 int embedded_worker_id) {
216 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); 208 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
217 ASSERT_TRUE(worker != NULL); 209 ASSERT_TRUE(worker != NULL);
218 registry()->OnPausedAfterDownload(worker->process_id(), embedded_worker_id); 210 registry()->OnPausedAfterDownload(worker->process_id(), embedded_worker_id);
219 } 211 }
220 212
221 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection( 213 void EmbeddedWorkerTestHelper::SimulateWorkerReadyForInspection(
222 int embedded_worker_id) { 214 int embedded_worker_id) {
223 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); 215 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id);
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after
366 } 358 }
367 359
368 void EmbeddedWorkerTestHelper::OnPushEventStub(int request_id, 360 void EmbeddedWorkerTestHelper::OnPushEventStub(int request_id,
369 const std::string& data) { 361 const std::string& data) {
370 base::ThreadTaskRunnerHandle::Get()->PostTask( 362 base::ThreadTaskRunnerHandle::Get()->PostTask(
371 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent, 363 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnPushEvent,
372 weak_factory_.GetWeakPtr(), 364 weak_factory_.GetWeakPtr(),
373 current_embedded_worker_id_, request_id, data)); 365 current_embedded_worker_id_, request_id, data));
374 } 366 }
375 367
376 void EmbeddedWorkerTestHelper::OnSyncEventStub(int request_id) {
377 base::ThreadTaskRunnerHandle::Get()->PostTask(
378 FROM_HERE, base::Bind(&EmbeddedWorkerTestHelper::OnSyncEvent,
379 weak_factory_.GetWeakPtr(),
380 current_embedded_worker_id_, request_id));
381 }
382
383 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() { 368 EmbeddedWorkerRegistry* EmbeddedWorkerTestHelper::registry() {
384 DCHECK(context()); 369 DCHECK(context());
385 return context()->embedded_worker_registry(); 370 return context()->embedded_worker_registry();
386 } 371 }
387 372
388 MessagePortMessageFilter* 373 MessagePortMessageFilter*
389 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() { 374 EmbeddedWorkerTestHelper::NewMessagePortMessageFilter() {
390 scoped_refptr<MessagePortMessageFilter> filter( 375 scoped_refptr<MessagePortMessageFilter> filter(
391 new MockMessagePortMessageFilter); 376 new MockMessagePortMessageFilter);
392 message_port_message_filters_.push_back(filter); 377 message_port_message_filters_.push_back(filter);
393 return filter.get(); 378 return filter.get();
394 } 379 }
395 380
396 } // namespace content 381 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698