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

Side by Side Diff: content/child/service_worker/service_worker_dispatcher.cc

Issue 25008006: Flush out initial [un]registerServiceWorker roundtrip (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Address review comments Created 7 years, 1 month 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 | Annotate | Revision Log
OLDNEW
(Empty)
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
3 // found in the LICENSE file.
4
5 #include "content/child/service_worker/service_worker_dispatcher.h"
6
7 #include "base/lazy_instance.h"
8 #include "base/threading/thread_local.h"
9 #include "content/child/service_worker/web_service_worker_impl.h"
10 #include "content/child/thread_safe_sender.h"
11 #include "content/common/service_worker_messages.h"
12 #include "third_party/WebKit/public/web/WebSecurityOrigin.h"
13
14 using WebKit::WebServiceWorkerProvider;
15 using base::ThreadLocalPointer;
16 using webkit_glue::WorkerTaskRunner;
17
18 namespace content {
19
20 namespace {
kinuko 2013/10/25 15:28:00 nit: can you insert an empty line after this line
alecflett 2013/10/25 18:22:50 Done.
21 base::LazyInstance<ThreadLocalPointer<ServiceWorkerDispatcher> >::Leaky
22 g_dispatcher_tls = LAZY_INSTANCE_INITIALIZER;
23
24 ServiceWorkerDispatcher* const kHasBeenDeleted =
25 reinterpret_cast<ServiceWorkerDispatcher*>(0x1);
26
27 int CurrentWorkerId() {
28 return WorkerTaskRunner::Instance()->CurrentWorkerId();
29 }
30
31 }
kinuko 2013/10/25 15:28:00 nit: } // namespace
32
33 ServiceWorkerDispatcher::ServiceWorkerDispatcher(
34 ThreadSafeSender* thread_safe_sender)
35 : thread_safe_sender_(thread_safe_sender) {
36 g_dispatcher_tls.Pointer()->Set(this);
37 }
38
39 ServiceWorkerDispatcher::~ServiceWorkerDispatcher() {
40 g_dispatcher_tls.Pointer()->Set(kHasBeenDeleted);
41 }
42
43 void ServiceWorkerDispatcher::OnMessageReceived(const IPC::Message& msg) {
44 bool handled = true;
45 IPC_BEGIN_MESSAGE_MAP(ServiceWorkerDispatcher, msg)
46 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_ServiceWorkerRegistered,
47 OnServiceWorkerRegistered)
48 IPC_MESSAGE_HANDLER(ServiceWorkerMsg_ServiceWorkerUnregistered,
49 OnServiceWorkerUnregistered)
50 IPC_MESSAGE_UNHANDLED(handled = false)
51 IPC_END_MESSAGE_MAP()
52 DCHECK(handled) << "Unhandled message:" << msg.type();
53 }
54
55 bool ServiceWorkerDispatcher::Send(IPC::Message* msg) {
56 return thread_safe_sender_->Send(msg);
57 }
58
59 void ServiceWorkerDispatcher::RegisterServiceWorker(
60 const GURL& pattern,
61 const GURL& scriptUrl,
62 WebServiceWorkerProvider::WebServiceWorkerCallbacks* callbacks) {
63 DCHECK(callbacks);
64 int request_id = pending_callbacks_.Add(callbacks);
65 thread_safe_sender_->Send(new ServiceWorkerHostMsg_RegisterServiceWorker(
66 CurrentWorkerId(), request_id, pattern, scriptUrl));
67 }
68
69 void ServiceWorkerDispatcher::UnregisterServiceWorker(
70 const GURL& pattern,
71 WebServiceWorkerProvider::WebServiceWorkerCallbacks* callbacks) {
72 DCHECK(callbacks);
73 int request_id = pending_callbacks_.Add(callbacks);
74 thread_safe_sender_->Send(new ServiceWorkerHostMsg_UnregisterServiceWorker(
75 CurrentWorkerId(), request_id, pattern));
76 }
77
78 ServiceWorkerDispatcher* ServiceWorkerDispatcher::ThreadSpecificInstance(
79 ThreadSafeSender* thread_safe_sender) {
80 if (g_dispatcher_tls.Pointer()->Get() == kHasBeenDeleted) {
81 NOTREACHED() << "Re-instantiating TLS ServiceWorkerDispatcher.";
82 g_dispatcher_tls.Pointer()->Set(NULL);
83 }
84 if (g_dispatcher_tls.Pointer()->Get())
85 return g_dispatcher_tls.Pointer()->Get();
86
87 ServiceWorkerDispatcher* dispatcher =
88 new ServiceWorkerDispatcher(thread_safe_sender);
89 if (WorkerTaskRunner::Instance()->CurrentWorkerId())
90 webkit_glue::WorkerTaskRunner::Instance()->AddStopObserver(dispatcher);
91 return dispatcher;
92 }
93
94 void ServiceWorkerDispatcher::OnServiceWorkerRegistered(
95 int32 thread_id,
96 int32 request_id,
97 int64 service_worker_id) {
98 WebServiceWorkerProvider::WebServiceWorkerCallbacks* callbacks =
99 pending_callbacks_.Lookup(request_id);
100 DCHECK(callbacks);
101 if (!callbacks)
102 return;
103
104 // the browser has to generate the service_worker_id so the same
105 // worker can be called from different renderer contexts. However,
106 // the impl object doesn't have to be the same instance across calls
107 // unless we require the DOM objects to be identical when there's a
108 // duplicate registration. So for now we mint a new object each
109 // time.
110 WebServiceWorkerImpl* worker =
111 new WebServiceWorkerImpl(service_worker_id);
112 callbacks->onSuccess(worker);
kinuko 2013/10/25 15:28:00 nit: I prefer arranging these lines like: callbac
alecflett 2013/10/25 18:22:50 Done.
113 pending_callbacks_.Remove(request_id);
114 }
115
116 void ServiceWorkerDispatcher::OnServiceWorkerUnregistered(
117 int32 thread_id,
118 int32 request_id) {
119 WebServiceWorkerProvider::WebServiceWorkerCallbacks* callbacks =
120 pending_callbacks_.Lookup(request_id);
121 DCHECK(callbacks);
122 if (!callbacks)
123 return;
124
125 callbacks->onSuccess(NULL);
126 pending_callbacks_.Remove(request_id);
127 }
128
129 void ServiceWorkerDispatcher::OnWorkerRunLoopStopped() { delete this; }
130
131 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698