OLD | NEW |
---|---|
(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 | |
OLD | NEW |