1fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian/* 2fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * Copyright (C) 2010 The Android Open Source Project 3fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * 4fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * Licensed under the Apache License, Version 2.0 (the "License"); 5fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * you may not use this file except in compliance with the License. 6fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * You may obtain a copy of the License at 7fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * 8fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * http://www.apache.org/licenses/LICENSE-2.0 9fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * 10fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * Unless required by applicable law or agreed to in writing, software 11fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * distributed under the License is distributed on an "AS IS" BASIS, 12fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * See the License for the specific language governing permissions and 14fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian * limitations under the License. 15fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian */ 16fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 17fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#ifndef ANDROID_SENSOR_SERVICE_H 18fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#define ANDROID_SENSOR_SERVICE_H 19fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 20fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <stdint.h> 21fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <sys/types.h> 22fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 23fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/Vector.h> 24fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/SortedVector.h> 25fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/KeyedVector.h> 26fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/threads.h> 2756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella#include <utils/AndroidThreads.h> 28fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/RefBase.h> 2956ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella#include <utils/Looper.h> 30fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 31fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <binder/BinderService.h> 32fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 33fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/Sensor.h> 34b3989276d17f2b083bec67b695d1078fb86c6c53Mathias Agopian#include <gui/BitTube.h> 35fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/ISensorServer.h> 36fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/ISensorEventConnection.h> 37fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 38f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian#include "SensorInterface.h" 39f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 40fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 41fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 42a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian#define DEBUG_CONNECTIONS false 4356ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella// Max size is 100 KB which is enough to accept a batch of about 1000 events. 4456ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella#define MAX_SOCKET_BUFFER_SIZE_BATCHED 100 * 1024 4556ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella// For older HALs which don't support batching, use a smaller socket buffer size. 464c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella#define SOCKET_BUFFER_SIZE_NON_BATCHED 4 * 1024 47a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian 48fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstruct sensors_poll_device_t; 49fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstruct sensors_module_t; 50fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 51fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopiannamespace android { 52fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 53fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 54fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianclass SensorService : 55fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public BinderService<SensorService>, 56fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public BnSensorServer, 57fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian protected Thread 58fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 59b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian friend class BinderService<SensorService>; 60fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 61b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian static const char* WAKE_LOCK_NAME; 627c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 63b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian static char const* getServiceName() ANDROID_API { return "sensorservice"; } 64b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian SensorService() ANDROID_API; 65fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual ~SensorService(); 66fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 67fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual void onFirstRef(); 68fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 69fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // Thread interface 70fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual bool threadLoop(); 71fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 72fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // ISensorServer interface 73fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual Vector<Sensor> getSensorList(); 74fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual sp<ISensorEventConnection> createSensorEventConnection(); 75fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual status_t dump(int fd, const Vector<String16>& args); 76fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 7756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella class SensorEventConnection : public BnSensorEventConnection, public LooperCallback { 7856ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella friend class SensorService; 797c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian virtual ~SensorEventConnection(); 807c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian virtual void onFirstRef(); 81b3989276d17f2b083bec67b695d1078fb86c6c53Mathias Agopian virtual sp<BitTube> getSensorChannel() const; 82724d91d778e71c8186399f4955de14b54812b3edAravind Akella virtual status_t enableDisable(int handle, bool enabled, nsecs_t samplingPeriodNs, 83724d91d778e71c8186399f4955de14b54812b3edAravind Akella nsecs_t maxBatchReportLatencyNs, int reservedFlags); 84724d91d778e71c8186399f4955de14b54812b3edAravind Akella virtual status_t setEventRate(int handle, nsecs_t samplingPeriodNs); 85701166d9f60a6e1149ff568aec0e03f3f3925292Aravind Akella virtual status_t flush(); 864c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // Count the number of flush complete events which are about to be dropped in the buffer. 874c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // Increment mPendingFlushEventsToSend in mSensorInfo. These flush complete events will be 884c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // sent separately before the next batch of events. 890ec2066e4774b851c66176b99b0a5aa5abe6ad00Aravind Akella void countFlushCompleteEventsLocked(sensors_event_t const* scratch, int numEventsDropped); 907c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 916c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // Check if there are any wake up events in the buffer. If yes, return the index of the 926c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // first wake_up sensor event in the buffer else return -1. This wake_up sensor event will 936c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // have the flag WAKE_UP_SENSOR_EVENT_NEEDS_ACK set. Exactly one event per packet will have 946c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // the wake_up flag set. SOCK_SEQPACKET ensures that either the entire packet is read or 956c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // dropped. 966c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella int findWakeUpSensorEventLocked(sensors_event_t const* scratch, int count); 976c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella 986c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // Send pending flush_complete events. There may have been flush_complete_events that are 996c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // dropped which need to be sent separately before other events. On older HALs (1_0) this 1006c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // method emulates the behavior of flush(). 1016c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella void sendPendingFlushEventsLocked(); 10256ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 10356ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // Writes events from mEventCache to the socket. 104b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella void writeToSocketFromCache(); 10556ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 10656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // Compute the approximate cache size from the FIFO sizes of various sensors registered for 10756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // this connection. Wake up and non-wake up sensors have separate FIFOs but FIFO may be 10856ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // shared amongst wake-up sensors and non-wake up sensors. 10956ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella int computeMaxCacheSizeLocked() const; 11056ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 1116c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // When more sensors register, the maximum cache size desired may change. Compute max cache 1126c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // size, reallocate memory and copy over events from the older cache. 1136c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella void reAllocateCacheLocked(sensors_event_t const* scratch, int count); 1146c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella 11556ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // LooperCallback method. If there is data to read on this fd, it is an ack from the 11656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // app that it has read events from a wake up sensor, decrement mWakeLockRefCount. 11756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella // If this fd is available for writing send the data from the cache. 11856ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella virtual int handleEvent(int fd, int events, void* data); 1199a844cf78f09953145200b4074d47589257a408cAravind Akella 1208a96955c8e14db40b16164236830fc9506a00872Aravind Akella // Increment mPendingFlushEventsToSend for the given sensor handle. 1218a96955c8e14db40b16164236830fc9506a00872Aravind Akella void incrementPendingFlushCount(int32_t handle); 1228a96955c8e14db40b16164236830fc9506a00872Aravind Akella 1238a96955c8e14db40b16164236830fc9506a00872Aravind Akella // Add or remove the file descriptor associated with the BitTube to the looper. If mDead is 1248a96955c8e14db40b16164236830fc9506a00872Aravind Akella // set to true or there are no more sensors for this connection, the file descriptor is 1258a96955c8e14db40b16164236830fc9506a00872Aravind Akella // removed if it has been previously added to the Looper. Depending on the state of the 1268a96955c8e14db40b16164236830fc9506a00872Aravind Akella // connection FD may be added to the Looper. The flags to set are determined by the internal 1278a96955c8e14db40b16164236830fc9506a00872Aravind Akella // state of the connection. FDs are added to the looper when wake-up sensors are registered 1288a96955c8e14db40b16164236830fc9506a00872Aravind Akella // (to poll for acknowledgements) and when write fails on the socket when there are too many 1298a96955c8e14db40b16164236830fc9506a00872Aravind Akella // events (to poll when the FD is available for writing). FDs are removed when there is an 1308a96955c8e14db40b16164236830fc9506a00872Aravind Akella // error and the other end hangs up or when this client unregisters for this connection. 1318a96955c8e14db40b16164236830fc9506a00872Aravind Akella void updateLooperRegistration(const sp<Looper>& looper); 1328a96955c8e14db40b16164236830fc9506a00872Aravind Akella void updateLooperRegistrationLocked(const sp<Looper>& looper); 1338a96955c8e14db40b16164236830fc9506a00872Aravind Akella 134fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian sp<SensorService> const mService; 1354c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella sp<BitTube> mChannel; 1365307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian uid_t mUid; 13771d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian mutable Mutex mConnectionLock; 1389a844cf78f09953145200b4074d47589257a408cAravind Akella // Number of events from wake up sensors which are still pending and haven't been delivered 1399a844cf78f09953145200b4074d47589257a408cAravind Akella // to the corresponding application. It is incremented by one unit for each write to the 1409a844cf78f09953145200b4074d47589257a408cAravind Akella // socket. 1418a96955c8e14db40b16164236830fc9506a00872Aravind Akella uint32_t mWakeLockRefCount; 1428a96955c8e14db40b16164236830fc9506a00872Aravind Akella 1438a96955c8e14db40b16164236830fc9506a00872Aravind Akella // If this flag is set to true, it means that the file descriptor associated with the 1448a96955c8e14db40b16164236830fc9506a00872Aravind Akella // BitTube has been added to the Looper in SensorService. This flag is typically set when 1458a96955c8e14db40b16164236830fc9506a00872Aravind Akella // this connection has wake-up sensors associated with it or when write has failed on this 1468a96955c8e14db40b16164236830fc9506a00872Aravind Akella // connection and we're storing some events in the cache. 1478a96955c8e14db40b16164236830fc9506a00872Aravind Akella bool mHasLooperCallbacks; 1488a96955c8e14db40b16164236830fc9506a00872Aravind Akella // If there are any errors associated with the Looper this flag is set to true and 1498a96955c8e14db40b16164236830fc9506a00872Aravind Akella // mWakeLockRefCount is reset to zero. needsWakeLock method will always return false, if 1508a96955c8e14db40b16164236830fc9506a00872Aravind Akella // this flag is set. 1518a96955c8e14db40b16164236830fc9506a00872Aravind Akella bool mDead; 1524c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella struct FlushInfo { 1534c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // The number of flush complete events dropped for this sensor is stored here. 1544c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // They are sent separately before the next batch of events. 1554c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella int mPendingFlushEventsToSend; 1564c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // Every activate is preceded by a flush. Only after the first flush complete is 1574c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // received, the events for the sensor are sent on that *connection*. 1584c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella bool mFirstFlushPending; 1596c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella FlushInfo() : mPendingFlushEventsToSend(0), mFirstFlushPending(false) {} 1604c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella }; 1614c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // protected by SensorService::mLock. Key for this vector is the sensor handle. 1624c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella KeyedVector<int, FlushInfo> mSensorInfo; 16356ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella sensors_event_t *mEventCache; 16456ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella int mCacheSize, mMaxCacheSize; 16556ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 16656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella#if DEBUG_CONNECTIONS 16756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella int mEventsReceived, mEventsSent, mEventsSentFromCache; 168e74baf6ca7d57375f38540b6b7ac5e4af019951bAravind Akella int mTotalAcksNeeded, mTotalAcksReceived; 16956ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella#endif 1707c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 171fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public: 1725307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian SensorEventConnection(const sp<SensorService>& service, uid_t uid); 1737c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 1740ec2066e4774b851c66176b99b0a5aa5abe6ad00Aravind Akella status_t sendEvents(sensors_event_t const* buffer, size_t count, 1758493b79e1cff92450076ca7450c4bf4e434a6816Aravind Akella sensors_event_t* scratch, 1768493b79e1cff92450076ca7450c4bf4e434a6816Aravind Akella SensorEventConnection const * const * mapFlushEventsToConnections = NULL); 177fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian bool hasSensor(int32_t handle) const; 178fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian bool hasAnySensor() const; 1798493b79e1cff92450076ca7450c4bf4e434a6816Aravind Akella bool hasOneShotSensors() const; 1807c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian bool addSensor(int32_t handle); 1817c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian bool removeSensor(int32_t handle); 1824c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella void setFirstFlushPending(int32_t handle, bool value); 1834c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella void dump(String8& result); 1849a844cf78f09953145200b4074d47589257a408cAravind Akella bool needsWakeLock(); 185b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella void resetWakeLockRefCount(); 1865307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian 1875307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian uid_t getUid() const { return mUid; } 188fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian }; 189fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 190fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian class SensorRecord { 191fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SortedVector< wp<SensorEventConnection> > mConnections; 1926c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // A queue of all flush() calls made on this sensor. Flush complete events will be 1936c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella // sent in this order. 1946c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella Vector< wp<SensorEventConnection> > mPendingFlushConnections; 195fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public: 196fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SensorRecord(const sp<SensorEventConnection>& connection); 1977c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian bool addConnection(const sp<SensorEventConnection>& connection); 198fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian bool removeConnection(const wp<SensorEventConnection>& connection); 199fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian size_t getNumConnections() const { return mConnections.size(); } 2006c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella 2016c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella void addPendingFlushConnection(const sp<SensorEventConnection>& connection); 2026c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella void removeFirstPendingFlushConnection(); 2036c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella SensorEventConnection * getFirstPendingFlushConnection(); 204fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian }; 205fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 20656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella class SensorEventAckReceiver : public Thread { 20756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella sp<SensorService> const mService; 20856ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella public: 20956ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella virtual bool threadLoop(); 21056ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella SensorEventAckReceiver(const sp<SensorService>& service): mService(service) {} 21156ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella }; 21256ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 213f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian String8 getSensorName(int handle) const; 214b4099e77ec2bf8e9d4259ff30f0cb1d621deed91Aravind Akella bool isVirtualSensor(int handle) const; 215700180487ffec09d9df1657b018a7caadac24b75Aravind Akella Sensor getSensorFromHandle(int handle) const; 2169a844cf78f09953145200b4074d47589257a408cAravind Akella bool isWakeUpSensor(int type) const; 2170ec2066e4774b851c66176b99b0a5aa5abe6ad00Aravind Akella void recordLastValueLocked(sensors_event_t const* buffer, size_t count); 218f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian static void sortEventBuffer(sensors_event_t* buffer, size_t count); 2190319306670b0344da99efa606b6f172dde575a39Mathias Agopian Sensor registerSensor(SensorInterface* sensor); 2200319306670b0344da99efa606b6f172dde575a39Mathias Agopian Sensor registerVirtualSensor(SensorInterface* sensor); 221ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian status_t cleanupWithoutDisable( 222ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian const sp<SensorEventConnection>& connection, int handle); 223ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian status_t cleanupWithoutDisableLocked( 224ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian const sp<SensorEventConnection>& connection, int handle); 2259a844cf78f09953145200b4074d47589257a408cAravind Akella void cleanupAutoDisabledSensorLocked(const sp<SensorEventConnection>& connection, 226b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian sensors_event_t const* buffer, const int count); 227700180487ffec09d9df1657b018a7caadac24b75Aravind Akella static bool canAccessSensor(const Sensor& sensor); 228700180487ffec09d9df1657b018a7caadac24b75Aravind Akella static bool verifyCanAccessSensor(const Sensor& sensor, const char* operation); 2299a844cf78f09953145200b4074d47589257a408cAravind Akella // SensorService acquires a partial wakelock for delivering events from wake up sensors. This 2309a844cf78f09953145200b4074d47589257a408cAravind Akella // method checks whether all the events from these wake up sensors have been delivered to the 2319a844cf78f09953145200b4074d47589257a408cAravind Akella // corresponding applications, if yes the wakelock is released. 2329a844cf78f09953145200b4074d47589257a408cAravind Akella void checkWakeLockState(); 2339a844cf78f09953145200b4074d47589257a408cAravind Akella void checkWakeLockStateLocked(); 234b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella bool isWakeLockAcquired(); 2359a844cf78f09953145200b4074d47589257a408cAravind Akella bool isWakeUpSensorEvent(const sensors_event_t& event) const; 23656ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 2376c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella SensorRecord * getSensorRecord(int handle); 2386c2664ae34fd582bc174d3c83e2b18e895ca2496Aravind Akella 23956ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella sp<Looper> getLooper() const; 24056ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella 241b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // Reset mWakeLockRefCounts for all SensorEventConnections to zero. This may happen if 242b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // SensorService did not receive any acknowledgements from apps which have registered for 243b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // wake_up sensors. 244b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella void resetAllWakeLockRefCounts(); 245b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella 246b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // Acquire or release wake_lock. If wake_lock is acquired, set the timeout in the looper to 247b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // 5 seconds and wake the looper. 248b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella void setWakeLockAcquiredLocked(bool acquire); 249b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella 250b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // Send events from the event cache for this particular connection. 251b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella void sendEventsFromCache(const sp<SensorEventConnection>& connection); 252b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella 253b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // Promote all weak referecences in mActiveConnections vector to strong references and add them 254b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella // to the output vector. 255b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella void populateActiveConnections(SortedVector< sp<SensorEventConnection> >* activeConnections); 256b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella 257fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // constants 258fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Vector<Sensor> mSensorList; 25933264868ba0aaccb9d4b5e5a067a79a43633f6ecMathias Agopian Vector<Sensor> mUserSensorListDebug; 260010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian Vector<Sensor> mUserSensorList; 261f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian DefaultKeyedVector<int, SensorInterface*> mSensorMap; 262f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian Vector<SensorInterface *> mVirtualSensorList; 26350df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian status_t mInitCheck; 2645466c3d20d03d4ae4b0fd0e0a93175091e3b0bb2Aravind Akella // Socket buffersize used to initialize BitTube. This size depends on whether batching is 2655466c3d20d03d4ae4b0fd0e0a93175091e3b0bb2Aravind Akella // supported or not. 2668a96955c8e14db40b16164236830fc9506a00872Aravind Akella uint32_t mSocketBufferSize; 26756ae42613c91f6a6fb0dc3f626daa24666fd18c2Aravind Akella sp<Looper> mLooper; 268b4373ac9f53e3a6edee915715101d535e1a851a1Aravind Akella sp<SensorEventAckReceiver> mAckReceiver; 269fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 270fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // protected by mLock 271fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mutable Mutex mLock; 272fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian DefaultKeyedVector<int, SensorRecord*> mActiveSensors; 273f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian DefaultKeyedVector<int, SensorInterface*> mActiveVirtualSensors; 274fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SortedVector< wp<SensorEventConnection> > mActiveConnections; 2759a844cf78f09953145200b4074d47589257a408cAravind Akella bool mWakeLockAcquired; 2768493b79e1cff92450076ca7450c4bf4e434a6816Aravind Akella sensors_event_t *mSensorEventBuffer, *mSensorEventScratch; 2778493b79e1cff92450076ca7450c4bf4e434a6816Aravind Akella SensorEventConnection const **mMapFlushEventsToConnections; 2788493b79e1cff92450076ca7450c4bf4e434a6816Aravind Akella 2793560fb24b668675627934356f210d84d19bf4e56Mathias Agopian // The size of this vector is constant, only the items are mutable 2803560fb24b668675627934356f210d84d19bf4e56Mathias Agopian KeyedVector<int32_t, sensors_event_t> mLastEventSeen; 2813560fb24b668675627934356f210d84d19bf4e56Mathias Agopian 282fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianpublic: 283db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian void cleanupConnection(SensorEventConnection* connection); 284724d91d778e71c8186399f4955de14b54812b3edAravind Akella status_t enable(const sp<SensorEventConnection>& connection, int handle, 285724d91d778e71c8186399f4955de14b54812b3edAravind Akella nsecs_t samplingPeriodNs, nsecs_t maxBatchReportLatencyNs, int reservedFlags); 286fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian status_t disable(const sp<SensorEventConnection>& connection, int handle); 2877c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian status_t setEventRate(const sp<SensorEventConnection>& connection, int handle, nsecs_t ns); 2889e3adfcebf28c5c76085108dffe98c74df56857dAravind Akella status_t flushSensor(const sp<SensorEventConnection>& connection); 289fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian}; 290fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 291fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 292fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian}; // namespace android 293fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 294fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#endif // ANDROID_SENSOR_SERVICE_H 295