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

Side by Side Diff: content/child/geofencing/geofencing_dispatcher.cc

Issue 476293002: Pass through geofencing API calls to the browser process. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase and add region_id sanity check Created 6 years, 2 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 | Annotate | Revision Log
OLDNEW
(Empty)
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
3 // found in the LICENSE file.
4
5 #include "content/child/geofencing/geofencing_dispatcher.h"
6
7 #include "base/lazy_instance.h"
8 #include "base/memory/scoped_ptr.h"
9 #include "base/message_loop/message_loop.h"
10 #include "base/thread_task_runner_handle.h"
11 #include "content/child/thread_safe_sender.h"
12 #include "content/child/worker_thread_task_runner.h"
13 #include "content/common/geofencing_messages.h"
14 #include "third_party/WebKit/public/platform/WebCircularGeofencingRegion.h"
15 #include "third_party/WebKit/public/platform/WebGeofencingError.h"
16 #include "third_party/WebKit/public/platform/WebGeofencingRegistration.h"
17
18 using blink::WebGeofencingError;
19
20 namespace content {
21
22 namespace {
23
24 base::LazyInstance<base::ThreadLocalPointer<GeofencingDispatcher>>::Leaky
25 g_dispatcher_tls = LAZY_INSTANCE_INITIALIZER;
26
27 GeofencingDispatcher* const kHasBeenDeleted =
28 reinterpret_cast<GeofencingDispatcher*>(0x1);
29
30 int CurrentWorkerId() {
31 return WorkerTaskRunner::Instance()->CurrentWorkerId();
32 }
33
34 } // namespace
35
36 GeofencingDispatcher::GeofencingDispatcher(ThreadSafeSender* sender)
37 : thread_safe_sender_(sender) {
38 g_dispatcher_tls.Pointer()->Set(this);
39 }
40
41 GeofencingDispatcher::~GeofencingDispatcher() {
42 g_dispatcher_tls.Pointer()->Set(kHasBeenDeleted);
43 }
44
45 bool GeofencingDispatcher::Send(IPC::Message* msg) {
46 return thread_safe_sender_->Send(msg);
47 }
48
49 void GeofencingDispatcher::OnMessageReceived(const IPC::Message& msg) {
50 bool handled = true;
51 IPC_BEGIN_MESSAGE_MAP(GeofencingDispatcher, msg)
52 IPC_MESSAGE_HANDLER(GeofencingMsg_RegisterRegionComplete,
53 OnRegisterRegionComplete)
54 IPC_MESSAGE_HANDLER(GeofencingMsg_UnregisterRegionComplete,
55 OnUnregisterRegionComplete)
56 IPC_MESSAGE_HANDLER(GeofencingMsg_GetRegisteredRegionsComplete,
57 OnGetRegisteredRegionsComplete)
58 IPC_MESSAGE_UNHANDLED(handled = false)
59 IPC_END_MESSAGE_MAP()
60 DCHECK(handled) << "Unhandled message:" << msg.type();
61 }
62
63 void GeofencingDispatcher::RegisterRegion(
64 const blink::WebString& region_id,
65 const blink::WebCircularGeofencingRegion& region,
66 blink::WebGeofencingCallbacks* callbacks) {
67 DCHECK(callbacks);
68 int request_id = region_registration_requests_.Add(callbacks);
69 Send(new GeofencingHostMsg_RegisterRegion(
70 CurrentWorkerId(), request_id, region_id.utf8(), region));
71 }
72
73 void GeofencingDispatcher::UnregisterRegion(
74 const blink::WebString& region_id,
75 blink::WebGeofencingCallbacks* callbacks) {
76 DCHECK(callbacks);
77 int request_id = region_unregistration_requests_.Add(callbacks);
78 Send(new GeofencingHostMsg_UnregisterRegion(
79 CurrentWorkerId(), request_id, region_id.utf8()));
80 }
81
82 void GeofencingDispatcher::GetRegisteredRegions(
83 blink::WebGeofencingRegionsCallbacks* callbacks) {
84 DCHECK(callbacks);
85 int request_id = get_registered_regions_requests_.Add(callbacks);
86 Send(new GeofencingHostMsg_GetRegisteredRegions(CurrentWorkerId(),
87 request_id));
88 }
89
90 GeofencingDispatcher* GeofencingDispatcher::GetOrCreateThreadSpecificInstance(
91 ThreadSafeSender* thread_safe_sender) {
92 if (g_dispatcher_tls.Pointer()->Get() == kHasBeenDeleted) {
93 NOTREACHED() << "Re-instantiating TLS GeofencingDispatcher.";
94 g_dispatcher_tls.Pointer()->Set(NULL);
95 }
96 if (g_dispatcher_tls.Pointer()->Get())
97 return g_dispatcher_tls.Pointer()->Get();
98
99 GeofencingDispatcher* dispatcher =
100 new GeofencingDispatcher(thread_safe_sender);
101 if (WorkerTaskRunner::Instance()->CurrentWorkerId())
102 WorkerTaskRunner::Instance()->AddStopObserver(dispatcher);
103 return dispatcher;
104 }
105
106 GeofencingDispatcher* GeofencingDispatcher::GetThreadSpecificInstance() {
107 if (g_dispatcher_tls.Pointer()->Get() == kHasBeenDeleted)
108 return NULL;
109 return g_dispatcher_tls.Pointer()->Get();
110 }
111
112 void GeofencingDispatcher::OnRegisterRegionComplete(int thread_id,
113 int request_id,
114 GeofencingStatus status) {
115 blink::WebGeofencingCallbacks* callbacks =
116 region_registration_requests_.Lookup(request_id);
117 DCHECK(callbacks);
118 if (!callbacks)
119 return;
120
121 if (status == GEOFENCING_STATUS_OK) {
122 callbacks->onSuccess();
123 } else {
124 callbacks->onError(new WebGeofencingError(
125 WebGeofencingError::ErrorTypeAbort,
126 blink::WebString::fromUTF8(GeofencingStatusToString(status))));
127 }
128 region_registration_requests_.Remove(request_id);
129 }
130
131 void GeofencingDispatcher::OnUnregisterRegionComplete(int thread_id,
132 int request_id,
133 GeofencingStatus status) {
134 blink::WebGeofencingCallbacks* callbacks =
135 region_unregistration_requests_.Lookup(request_id);
136 DCHECK(callbacks);
137 if (!callbacks)
138 return;
139
140 if (status == GEOFENCING_STATUS_OK) {
141 callbacks->onSuccess();
142 } else {
143 callbacks->onError(new WebGeofencingError(
144 WebGeofencingError::ErrorTypeAbort,
145 blink::WebString::fromUTF8(GeofencingStatusToString(status))));
146 }
147 region_unregistration_requests_.Remove(request_id);
148 }
149
150 void GeofencingDispatcher::OnGetRegisteredRegionsComplete(
151 int thread_id,
152 int request_id,
153 GeofencingStatus status,
154 const GeofencingRegistrations& regions) {
155 blink::WebGeofencingRegionsCallbacks* callbacks =
156 get_registered_regions_requests_.Lookup(request_id);
157 DCHECK(callbacks);
158 if (!callbacks)
159 return;
160
161 if (status == GEOFENCING_STATUS_OK) {
162 scoped_ptr<blink::WebVector<blink::WebGeofencingRegistration>> result(
163 new blink::WebVector<blink::WebGeofencingRegistration>(regions.size()));
164 size_t index = 0;
165 for (GeofencingRegistrations::const_iterator it = regions.begin();
166 it != regions.end();
167 ++it, ++index) {
168 (*result)[index].id = blink::WebString::fromUTF8(it->first);
169 (*result)[index].region = it->second;
170 }
171 callbacks->onSuccess(result.release());
172 } else {
173 callbacks->onError(new WebGeofencingError(
174 WebGeofencingError::ErrorTypeAbort,
175 blink::WebString::fromUTF8(GeofencingStatusToString(status))));
176 }
177 get_registered_regions_requests_.Remove(request_id);
178 }
179
180 void GeofencingDispatcher::OnWorkerRunLoopStopped() {
181 delete this;
182 }
183
184 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698