1/* 2 * Copyright (C) 2017 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17#include "EventQueue.h" 18#include "utils.h" 19 20#include <utils/Looper.h> 21 22namespace android { 23namespace frameworks { 24namespace sensorservice { 25namespace V1_0 { 26namespace implementation { 27 28class EventQueueLooperCallback : public ::android::LooperCallback { 29public: 30 EventQueueLooperCallback(sp<::android::SensorEventQueue> queue, 31 sp<IEventQueueCallback> callback) 32 : mQueue(queue), mCallback(callback) { 33 } 34 35 int handleEvent(__unused int fd, __unused int events, __unused void* data) { 36 37 ASensorEvent event; 38 ssize_t actual; 39 40 auto internalQueue = mQueue.promote(); 41 if (internalQueue == nullptr) { 42 return 1; 43 } 44 45 while ((actual = internalQueue->read(&event, 1 /* count */)) > 0) { 46 internalQueue->sendAck(&event, actual); 47 Return<void> ret = mCallback->onEvent(convertEvent(event)); 48 (void)ret.isOk(); // ignored 49 } 50 51 return 1; // continue to receive callbacks 52 } 53 54private: 55 wp<::android::SensorEventQueue> mQueue; 56 sp<IEventQueueCallback> mCallback; 57}; 58 59EventQueue::EventQueue( 60 sp<IEventQueueCallback> callback, 61 sp<::android::Looper> looper, 62 sp<::android::SensorEventQueue> internalQueue) 63 : mLooper(looper), 64 mInternalQueue(internalQueue) { 65 66 mLooper->addFd(internalQueue->getFd(), ALOOPER_POLL_CALLBACK, ALOOPER_EVENT_INPUT, 67 new EventQueueLooperCallback(internalQueue, callback), NULL /* data */); 68} 69 70void EventQueue::onLastStrongRef(const void *id) { 71 IEventQueue::onLastStrongRef(id); 72 mLooper->removeFd(mInternalQueue->getFd()); 73} 74 75// Methods from ::android::frameworks::sensorservice::V1_0::IEventQueue follow. 76Return<Result> EventQueue::enableSensor(int32_t sensorHandle, int32_t samplingPeriodUs, 77 int64_t maxBatchReportLatencyUs) { 78 return convertResult(mInternalQueue->enableSensor(sensorHandle, samplingPeriodUs, 79 maxBatchReportLatencyUs, 0 /* reserved flags */)); 80} 81 82Return<Result> EventQueue::disableSensor(int32_t sensorHandle) { 83 return convertResult(mInternalQueue->disableSensor(sensorHandle)); 84} 85 86} // namespace implementation 87} // namespace V1_0 88} // namespace sensorservice 89} // namespace frameworks 90} // namespace android 91