OLD | NEW |
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 "device_motion_event_pump.h" | 5 #include "device_motion_event_pump.h" |
6 | 6 |
7 #include "content/common/device_sensors/device_motion_messages.h" | 7 #include "content/common/device_sensors/device_motion_messages.h" |
8 #include "content/public/renderer/render_thread.h" | 8 #include "content/public/renderer/render_thread.h" |
9 #include "third_party/WebKit/public/platform/WebDeviceMotionListener.h" | 9 #include "third_party/WebKit/public/platform/WebDeviceMotionListener.h" |
10 | 10 |
11 namespace content { | 11 namespace content { |
12 | 12 |
13 DeviceMotionEventPump::DeviceMotionEventPump(RenderThread* thread) | 13 DeviceMotionEventPump::DeviceMotionEventPump() |
14 : DeviceSensorEventPump<blink::WebDeviceMotionListener>(thread) { | 14 : DeviceSensorEventPump(), listener_(0) { |
| 15 } |
| 16 |
| 17 DeviceMotionEventPump::DeviceMotionEventPump(int pump_delay_millis) |
| 18 : DeviceSensorEventPump(pump_delay_millis), listener_(0) { |
15 } | 19 } |
16 | 20 |
17 DeviceMotionEventPump::~DeviceMotionEventPump() { | 21 DeviceMotionEventPump::~DeviceMotionEventPump() { |
18 } | 22 } |
19 | 23 |
| 24 bool DeviceMotionEventPump::SetListener( |
| 25 blink::WebDeviceMotionListener* listener) { |
| 26 listener_ = listener; |
| 27 return listener_ ? RequestStart() : Stop(); |
| 28 } |
| 29 |
20 bool DeviceMotionEventPump::OnControlMessageReceived( | 30 bool DeviceMotionEventPump::OnControlMessageReceived( |
21 const IPC::Message& message) { | 31 const IPC::Message& message) { |
22 bool handled = true; | 32 bool handled = true; |
23 IPC_BEGIN_MESSAGE_MAP(DeviceMotionEventPump, message) | 33 IPC_BEGIN_MESSAGE_MAP(DeviceMotionEventPump, message) |
24 IPC_MESSAGE_HANDLER(DeviceMotionMsg_DidStartPolling, OnDidStart) | 34 IPC_MESSAGE_HANDLER(DeviceMotionMsg_DidStartPolling, OnDidStart) |
25 IPC_MESSAGE_UNHANDLED(handled = false) | 35 IPC_MESSAGE_UNHANDLED(handled = false) |
26 IPC_END_MESSAGE_MAP() | 36 IPC_END_MESSAGE_MAP() |
27 return handled; | 37 return handled; |
28 } | 38 } |
29 | 39 |
30 void DeviceMotionEventPump::FireEvent() { | 40 void DeviceMotionEventPump::FireEvent() { |
31 DCHECK(listener()); | 41 DCHECK(listener_); |
32 blink::WebDeviceMotionData data; | 42 blink::WebDeviceMotionData data; |
33 if (reader_->GetLatestData(&data) && data.allAvailableSensorsAreActive) | 43 if (reader_->GetLatestData(&data) && data.allAvailableSensorsAreActive) |
34 listener()->didChangeDeviceMotion(data); | 44 listener_->didChangeDeviceMotion(data); |
35 } | 45 } |
36 | 46 |
37 bool DeviceMotionEventPump::InitializeReader(base::SharedMemoryHandle handle) { | 47 bool DeviceMotionEventPump::InitializeReader(base::SharedMemoryHandle handle) { |
38 if (!reader_) | 48 if (!reader_) |
39 reader_.reset(new DeviceMotionSharedMemoryReader()); | 49 reader_.reset(new DeviceMotionSharedMemoryReader()); |
40 return reader_->Initialize(handle); | 50 return reader_->Initialize(handle); |
41 } | 51 } |
42 | 52 |
43 void DeviceMotionEventPump::SendStartMessage() { | 53 bool DeviceMotionEventPump::SendStartMessage() { |
44 RenderThread::Get()->Send(new DeviceMotionHostMsg_StartPolling()); | 54 return RenderThread::Get()->Send(new DeviceMotionHostMsg_StartPolling()); |
45 } | 55 } |
46 | 56 |
47 void DeviceMotionEventPump::SendStopMessage() { | |
48 RenderThread::Get()->Send(new DeviceMotionHostMsg_StopPolling()); | |
49 } | |
50 | 57 |
51 void DeviceMotionEventPump::SendFakeDataForTesting(void* fake_data) { | 58 bool DeviceMotionEventPump::SendStopMessage() { |
52 blink::WebDeviceMotionData data = | 59 return RenderThread::Get()->Send(new DeviceMotionHostMsg_StopPolling()); |
53 *static_cast<blink::WebDeviceMotionData*>(fake_data); | |
54 | |
55 listener()->didChangeDeviceMotion(data); | |
56 } | 60 } |
57 | 61 |
58 } // namespace content | 62 } // namespace content |
OLD | NEW |