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

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

Issue 2307543002: ServiceWorker: Mojofication of EWInstance::StopWorker (Closed)
Patch Set: Incorporated with the review Created 4 years, 3 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 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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_registry.h" 5 #include "content/browser/service_worker/embedded_worker_registry.h"
6 6
7 #include "base/bind_helpers.h" 7 #include "base/bind_helpers.h"
8 #include "base/metrics/histogram_macros.h" 8 #include "base/metrics/histogram_macros.h"
9 #include "base/stl_util.h" 9 #include "base/stl_util.h"
10 #include "content/browser/renderer_host/render_widget_helper.h" 10 #include "content/browser/renderer_host/render_widget_helper.h"
(...skipping 282 matching lines...) Expand 10 before | Expand all | Expand 10 after
293 if (found == process_sender_map_.end()) 293 if (found == process_sender_map_.end())
294 return SERVICE_WORKER_ERROR_PROCESS_NOT_FOUND; 294 return SERVICE_WORKER_ERROR_PROCESS_NOT_FOUND;
295 if (!found->second->Send(message.release())) 295 if (!found->second->Send(message.release()))
296 return SERVICE_WORKER_ERROR_IPC_FAILED; 296 return SERVICE_WORKER_ERROR_IPC_FAILED;
297 return SERVICE_WORKER_OK; 297 return SERVICE_WORKER_OK;
298 } 298 }
299 299
300 void EmbeddedWorkerRegistry::RemoveWorker(int process_id, 300 void EmbeddedWorkerRegistry::RemoveWorker(int process_id,
301 int embedded_worker_id) { 301 int embedded_worker_id) {
302 DCHECK(base::ContainsKey(worker_map_, embedded_worker_id)); 302 DCHECK(base::ContainsKey(worker_map_, embedded_worker_id));
303 DetachWorker(process_id, embedded_worker_id);
303 worker_map_.erase(embedded_worker_id); 304 worker_map_.erase(embedded_worker_id);
305 }
306
307 void EmbeddedWorkerRegistry::DetachWorker(int process_id,
308 int embedded_worker_id) {
309 DCHECK(base::ContainsKey(worker_map_, embedded_worker_id));
304 if (!base::ContainsKey(worker_process_map_, process_id)) 310 if (!base::ContainsKey(worker_process_map_, process_id))
305 return; 311 return;
306 worker_process_map_[process_id].erase(embedded_worker_id); 312 worker_process_map_[process_id].erase(embedded_worker_id);
307 if (worker_process_map_[process_id].empty()) 313 if (worker_process_map_[process_id].empty())
308 worker_process_map_.erase(process_id); 314 worker_process_map_.erase(process_id);
309 } 315 }
310 316
311 EmbeddedWorkerInstance* EmbeddedWorkerRegistry::GetWorkerForMessage( 317 EmbeddedWorkerInstance* EmbeddedWorkerRegistry::GetWorkerForMessage(
312 int process_id, 318 int process_id,
313 int embedded_worker_id) { 319 int embedded_worker_id) {
314 EmbeddedWorkerInstance* worker = GetWorker(embedded_worker_id); 320 EmbeddedWorkerInstance* worker = GetWorker(embedded_worker_id);
315 if (!worker || worker->process_id() != process_id) { 321 if (!worker || worker->process_id() != process_id) {
316 UMA_HISTOGRAM_BOOLEAN("ServiceWorker.WorkerForMessageFound", false); 322 UMA_HISTOGRAM_BOOLEAN("ServiceWorker.WorkerForMessageFound", false);
317 return nullptr; 323 return nullptr;
318 } 324 }
319 UMA_HISTOGRAM_BOOLEAN("ServiceWorker.WorkerForMessageFound", true); 325 UMA_HISTOGRAM_BOOLEAN("ServiceWorker.WorkerForMessageFound", true);
320 return worker; 326 return worker;
321 } 327 }
322 328
323 } // namespace content 329 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698