SensorService.h revision 9a844cf78f09953145200b4074d47589257a408c
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> 27fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/RefBase.h> 28fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 29fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <binder/BinderService.h> 30fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 31fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/Sensor.h> 32b3989276d17f2b083bec67b695d1078fb86c6c53Mathias Agopian#include <gui/BitTube.h> 33fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/ISensorServer.h> 34fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/ISensorEventConnection.h> 35fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 36f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian#include "SensorInterface.h" 37f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 38fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 39fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 40a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian#define DEBUG_CONNECTIONS false 414c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella// Max size is 1 MB which is enough to accept a batch of about 10k events. 424c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella#define MAX_SOCKET_BUFFER_SIZE_BATCHED 1024 * 1024 434c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella#define SOCKET_BUFFER_SIZE_NON_BATCHED 4 * 1024 449a844cf78f09953145200b4074d47589257a408cAravind Akella#define WAKE_UP_SENSOR_EVENT_NEEDS_ACK (1 << 31) 45a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian 46fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstruct sensors_poll_device_t; 47fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstruct sensors_module_t; 48fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 49fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopiannamespace android { 50fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 51fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 52fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianclass SensorService : 53fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public BinderService<SensorService>, 54fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public BnSensorServer, 55fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian protected Thread 56fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 57b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian friend class BinderService<SensorService>; 58fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 59b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian static const char* WAKE_LOCK_NAME; 607c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 61b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian static char const* getServiceName() ANDROID_API { return "sensorservice"; } 62b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian SensorService() ANDROID_API; 63fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual ~SensorService(); 64fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 65fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual void onFirstRef(); 66fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 67fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // Thread interface 68fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual bool threadLoop(); 69fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 70fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // ISensorServer interface 71fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual Vector<Sensor> getSensorList(); 72fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual sp<ISensorEventConnection> createSensorEventConnection(); 73fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian virtual status_t dump(int fd, const Vector<String16>& args); 74fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 75fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian class SensorEventConnection : public BnSensorEventConnection { 767c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian virtual ~SensorEventConnection(); 777c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian virtual void onFirstRef(); 78b3989276d17f2b083bec67b695d1078fb86c6c53Mathias Agopian virtual sp<BitTube> getSensorChannel() const; 79724d91d778e71c8186399f4955de14b54812b3edAravind Akella virtual status_t enableDisable(int handle, bool enabled, nsecs_t samplingPeriodNs, 80724d91d778e71c8186399f4955de14b54812b3edAravind Akella nsecs_t maxBatchReportLatencyNs, int reservedFlags); 81724d91d778e71c8186399f4955de14b54812b3edAravind Akella virtual status_t setEventRate(int handle, nsecs_t samplingPeriodNs); 82701166d9f60a6e1149ff568aec0e03f3f3925292Aravind Akella virtual status_t flush(); 839a844cf78f09953145200b4074d47589257a408cAravind Akella void decreaseWakeLockRefCount(); 844c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // Count the number of flush complete events which are about to be dropped in the buffer. 854c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // Increment mPendingFlushEventsToSend in mSensorInfo. These flush complete events will be 864c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // sent separately before the next batch of events. 87c551eac5b16a53f872cbb692d3a0c81e39329725Aravind Akella void countFlushCompleteEventsLocked(sensors_event_t* scratch, int numEventsDropped); 887c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 899a844cf78f09953145200b4074d47589257a408cAravind Akella // Check if there are any wake up events in the buffer. If yes, increment the ref count. 909a844cf78f09953145200b4074d47589257a408cAravind Akella // Increment it by exactly one unit for each packet sent on the socket. SOCK_SEQPACKET for 919a844cf78f09953145200b4074d47589257a408cAravind Akella // the socket ensures that either the entire packet is read or dropped. 929a844cf78f09953145200b4074d47589257a408cAravind Akella // Return 1 if mWakeLockRefCount has been incremented, zero if not. 939a844cf78f09953145200b4074d47589257a408cAravind Akella int countWakeUpSensorEventsLocked(sensors_event_t* scratch, const int count); 949a844cf78f09953145200b4074d47589257a408cAravind Akella 95fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian sp<SensorService> const mService; 964c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella sp<BitTube> mChannel; 975307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian uid_t mUid; 9871d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian mutable Mutex mConnectionLock; 999a844cf78f09953145200b4074d47589257a408cAravind Akella // Number of events from wake up sensors which are still pending and haven't been delivered 1009a844cf78f09953145200b4074d47589257a408cAravind Akella // to the corresponding application. It is incremented by one unit for each write to the 1019a844cf78f09953145200b4074d47589257a408cAravind Akella // socket. 1029a844cf78f09953145200b4074d47589257a408cAravind Akella int mWakeLockRefCount; 1037c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 1044c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella struct FlushInfo { 1054c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // The number of flush complete events dropped for this sensor is stored here. 1064c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // They are sent separately before the next batch of events. 1074c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella int mPendingFlushEventsToSend; 1084c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // Every activate is preceded by a flush. Only after the first flush complete is 1094c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // received, the events for the sensor are sent on that *connection*. 1104c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella bool mFirstFlushPending; 1114c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella FlushInfo() : mPendingFlushEventsToSend(0), mFirstFlushPending(false) {} 1124c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella }; 1134c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella // protected by SensorService::mLock. Key for this vector is the sensor handle. 1144c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella KeyedVector<int, FlushInfo> mSensorInfo; 1157c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 116fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public: 1175307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian SensorEventConnection(const sp<SensorService>& service, uid_t uid); 1187c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 119cf51001dbf28e9885fcacd4048902f1c75768fe9Mathias Agopian status_t sendEvents(sensors_event_t const* buffer, size_t count, 1209a844cf78f09953145200b4074d47589257a408cAravind Akella sensors_event_t* scratch); 121fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian bool hasSensor(int32_t handle) const; 122fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian bool hasAnySensor() const; 1237c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian bool addSensor(int32_t handle); 1247c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian bool removeSensor(int32_t handle); 1254c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella void setFirstFlushPending(int32_t handle, bool value); 1264c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella void dump(String8& result); 1279a844cf78f09953145200b4074d47589257a408cAravind Akella bool needsWakeLock(); 1285307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian 1295307d17fe33fc26eeeacd6339a9fbfe96cf56873Mathias Agopian uid_t getUid() const { return mUid; } 130fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian }; 131fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 132fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian class SensorRecord { 133fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SortedVector< wp<SensorEventConnection> > mConnections; 134fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian public: 135fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SensorRecord(const sp<SensorEventConnection>& connection); 1367c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian bool addConnection(const sp<SensorEventConnection>& connection); 137fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian bool removeConnection(const wp<SensorEventConnection>& connection); 138fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian size_t getNumConnections() const { return mConnections.size(); } 139fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian }; 140fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 141f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian String8 getSensorName(int handle) const; 142b4099e77ec2bf8e9d4259ff30f0cb1d621deed91Aravind Akella bool isVirtualSensor(int handle) const; 143700180487ffec09d9df1657b018a7caadac24b75Aravind Akella Sensor getSensorFromHandle(int handle) const; 1449a844cf78f09953145200b4074d47589257a408cAravind Akella bool isWakeUpSensor(int type) const; 1459a844cf78f09953145200b4074d47589257a408cAravind Akella void recordLastValueLocked(const sensors_event_t* buffer, size_t count); 146f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian static void sortEventBuffer(sensors_event_t* buffer, size_t count); 1470319306670b0344da99efa606b6f172dde575a39Mathias Agopian Sensor registerSensor(SensorInterface* sensor); 1480319306670b0344da99efa606b6f172dde575a39Mathias Agopian Sensor registerVirtualSensor(SensorInterface* sensor); 149ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian status_t cleanupWithoutDisable( 150ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian const sp<SensorEventConnection>& connection, int handle); 151ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian status_t cleanupWithoutDisableLocked( 152ac9a96da65f6eae4513654adaad8a457d1c1575cMathias Agopian const sp<SensorEventConnection>& connection, int handle); 1539a844cf78f09953145200b4074d47589257a408cAravind Akella void cleanupAutoDisabledSensorLocked(const sp<SensorEventConnection>& connection, 154b6df7d0e4c2117ca476662bd52b6745b3d8a305fMathias Agopian sensors_event_t const* buffer, const int count); 155700180487ffec09d9df1657b018a7caadac24b75Aravind Akella static bool canAccessSensor(const Sensor& sensor); 156700180487ffec09d9df1657b018a7caadac24b75Aravind Akella static bool verifyCanAccessSensor(const Sensor& sensor, const char* operation); 1579a844cf78f09953145200b4074d47589257a408cAravind Akella // SensorService acquires a partial wakelock for delivering events from wake up sensors. This 1589a844cf78f09953145200b4074d47589257a408cAravind Akella // method checks whether all the events from these wake up sensors have been delivered to the 1599a844cf78f09953145200b4074d47589257a408cAravind Akella // corresponding applications, if yes the wakelock is released. 1609a844cf78f09953145200b4074d47589257a408cAravind Akella void checkWakeLockState(); 1619a844cf78f09953145200b4074d47589257a408cAravind Akella void checkWakeLockStateLocked(); 1629a844cf78f09953145200b4074d47589257a408cAravind Akella bool isWakeUpSensorEvent(const sensors_event_t& event) const; 163fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // constants 164fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Vector<Sensor> mSensorList; 16533264868ba0aaccb9d4b5e5a067a79a43633f6ecMathias Agopian Vector<Sensor> mUserSensorListDebug; 166010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian Vector<Sensor> mUserSensorList; 167f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian DefaultKeyedVector<int, SensorInterface*> mSensorMap; 168f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian Vector<SensorInterface *> mVirtualSensorList; 16950df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian status_t mInitCheck; 1704c8b951f8d6a121e758bd3905fa8987c77863790Aravind Akella size_t mSocketBufferSize; 171fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 172fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // protected by mLock 173fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mutable Mutex mLock; 174fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian DefaultKeyedVector<int, SensorRecord*> mActiveSensors; 175f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian DefaultKeyedVector<int, SensorInterface*> mActiveVirtualSensors; 176fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SortedVector< wp<SensorEventConnection> > mActiveConnections; 1779a844cf78f09953145200b4074d47589257a408cAravind Akella bool mWakeLockAcquired; 178fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 1793560fb24b668675627934356f210d84d19bf4e56Mathias Agopian // The size of this vector is constant, only the items are mutable 1803560fb24b668675627934356f210d84d19bf4e56Mathias Agopian KeyedVector<int32_t, sensors_event_t> mLastEventSeen; 1813560fb24b668675627934356f210d84d19bf4e56Mathias Agopian 182fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianpublic: 183db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian void cleanupConnection(SensorEventConnection* connection); 184724d91d778e71c8186399f4955de14b54812b3edAravind Akella status_t enable(const sp<SensorEventConnection>& connection, int handle, 185724d91d778e71c8186399f4955de14b54812b3edAravind Akella nsecs_t samplingPeriodNs, nsecs_t maxBatchReportLatencyNs, int reservedFlags); 186fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian status_t disable(const sp<SensorEventConnection>& connection, int handle); 1877c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian status_t setEventRate(const sp<SensorEventConnection>& connection, int handle, nsecs_t ns); 188724d91d778e71c8186399f4955de14b54812b3edAravind Akella status_t flushSensor(const sp<SensorEventConnection>& connection, int handle); 189fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian}; 190fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 191fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 192fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian}; // namespace android 193fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 194fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#endif // ANDROID_SENSOR_SERVICE_H 195