SensorService.cpp revision 8dd4fe8dd37b740282b48b7867eec26fcf95e027
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#include <stdint.h> 18f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian#include <math.h> 19fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <sys/types.h> 20fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 213301542828febc768e1df42892cfac4992c35474Mathias Agopian#include <cutils/properties.h> 223301542828febc768e1df42892cfac4992c35474Mathias Agopian 23fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/SortedVector.h> 24fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/KeyedVector.h> 25fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/threads.h> 26fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/Atomic.h> 27fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/Errors.h> 28fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <utils/RefBase.h> 29451beee076cac09f817abae78a990dea108a9482Mathias Agopian#include <utils/Singleton.h> 30c4a930d1d5a432a1f302763ac55460d6e83fe7e0Mathias Agopian#include <utils/String16.h> 31fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 32fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <binder/BinderService.h> 33451beee076cac09f817abae78a990dea108a9482Mathias Agopian#include <binder/IServiceManager.h> 341cb13461a8cf62e3ba634e5965332f2d284f6d42Mathias Agopian#include <binder/PermissionCache.h> 35fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 36fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/ISensorServer.h> 37fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <gui/ISensorEventConnection.h> 38907103bf186cfdd2ed9eb3b6c36de53ade7b16f6Mathias Agopian#include <gui/SensorEventQueue.h> 39fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 40fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian#include <hardware/sensors.h> 41fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 42984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian#include "CorrectedGyroSensor.h" 43f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian#include "GravitySensor.h" 44f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian#include "LinearAccelerationSensor.h" 45984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian#include "OrientationSensor.h" 46f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian#include "RotationVectorSensor.h" 47984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian#include "SensorFusion.h" 48984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian#include "SensorService.h" 49fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 50fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopiannamespace android { 51fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 52fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 533301542828febc768e1df42892cfac4992c35474Mathias Agopian/* 543301542828febc768e1df42892cfac4992c35474Mathias Agopian * Notes: 553301542828febc768e1df42892cfac4992c35474Mathias Agopian * 563301542828febc768e1df42892cfac4992c35474Mathias Agopian * - what about a gyro-corrected magnetic-field sensor? 573301542828febc768e1df42892cfac4992c35474Mathias Agopian * - run mag sensor from time to time to force calibration 583301542828febc768e1df42892cfac4992c35474Mathias Agopian * - gravity sensor length is wrong (=> drift in linear-acc sensor) 593301542828febc768e1df42892cfac4992c35474Mathias Agopian * 603301542828febc768e1df42892cfac4992c35474Mathias Agopian */ 613301542828febc768e1df42892cfac4992c35474Mathias Agopian 62fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSensorService::SensorService() 631cb13461a8cf62e3ba634e5965332f2d284f6d42Mathias Agopian : mInitCheck(NO_INIT) 64fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 65fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 66fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 67fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianvoid SensorService::onFirstRef() 68fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 69a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD("nuSensorService starting..."); 7050df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian 71f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorDevice& dev(SensorDevice::getInstance()); 72fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 73f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (dev.initCheck() == NO_ERROR) { 74f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sensor_t const* list; 757b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian ssize_t count = dev.getSensorList(&list); 767b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian if (count > 0) { 777b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian ssize_t orientationIndex = -1; 787b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian bool hasGyro = false; 797b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian uint32_t virtualSensorsNeeds = 807b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian (1<<SENSOR_TYPE_GRAVITY) | 817b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian (1<<SENSOR_TYPE_LINEAR_ACCELERATION) | 827b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian (1<<SENSOR_TYPE_ROTATION_VECTOR); 837b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian 847b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian mLastEventSeen.setCapacity(count); 857b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian for (ssize_t i=0 ; i<count ; i++) { 867b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerSensor( new HardwareSensor(list[i]) ); 877b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian switch (list[i].type) { 887b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian case SENSOR_TYPE_ORIENTATION: 897b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian orientationIndex = i; 907b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian break; 917b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian case SENSOR_TYPE_GYROSCOPE: 927b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian hasGyro = true; 937b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian break; 947b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian case SENSOR_TYPE_GRAVITY: 957b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian case SENSOR_TYPE_LINEAR_ACCELERATION: 967b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian case SENSOR_TYPE_ROTATION_VECTOR: 977b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian virtualSensorsNeeds &= ~(1<<list[i].type); 987b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian break; 997b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian } 10050df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian } 101fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 1027b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // it's safe to instantiate the SensorFusion object here 1037b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // (it wants to be instantiated after h/w sensors have been 1047b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // registered) 1057b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian const SensorFusion& fusion(SensorFusion::getInstance()); 1067b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian 1077b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian if (hasGyro) { 1087b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // Always instantiate Android's virtual sensors. Since they are 1097b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // instantiated behind sensors from the HAL, they won't 1107b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // interfere with applications, unless they looks specifically 1117b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // for them (by name). 1127b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian 1137b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerVirtualSensor( new RotationVectorSensor() ); 1147b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerVirtualSensor( new GravitySensor(list, count) ); 1157b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerVirtualSensor( new LinearAccelerationSensor(list, count) ); 1167b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian 1177b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // these are optional 1187b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerVirtualSensor( new OrientationSensor() ); 1197b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerVirtualSensor( new CorrectedGyroSensor(list, count) ); 1207b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian 1217b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // virtual debugging sensors... 1227b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian char value[PROPERTY_VALUE_MAX]; 1237b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian property_get("debug.sensors", value, "0"); 1247b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian if (atoi(value)) { 1257b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian registerVirtualSensor( new GyroDriftSensor() ); 1267b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian } 1273301542828febc768e1df42892cfac4992c35474Mathias Agopian } 128f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 1297b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // build the sensor list returned to users 1307b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian mUserSensorList = mSensorList; 1317b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian if (hasGyro && 1327b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian (virtualSensorsNeeds & (1<<SENSOR_TYPE_ROTATION_VECTOR))) { 1337b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // if we have the fancy sensor fusion, and it's not provided by the 1347b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // HAL, use our own (fused) orientation sensor by removing the 1357b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian // HAL supplied one form the user list. 1367b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian if (orientationIndex >= 0) { 1377b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian mUserSensorList.removeItemsAt(orientationIndex); 1387b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian } 139010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian } 140010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian 1417b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian run("SensorService", PRIORITY_URGENT_DISPLAY); 1427b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian mInitCheck = NO_ERROR; 1437b2b32f2e761a919deb6f82d978b379429f77b05Mathias Agopian } 144fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 145fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 146fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 147f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopianvoid SensorService::registerSensor(SensorInterface* s) 148f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian{ 149f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sensors_event_t event; 150f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian memset(&event, 0, sizeof(event)); 151f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 152f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian const Sensor sensor(s->getSensor()); 153f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // add to the sensor list (returned to clients) 154f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mSensorList.add(sensor); 155f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // add to our handle->SensorInterface mapping 156f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mSensorMap.add(sensor.getHandle(), s); 157f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // create an entry in the mLastEventSeen array 158f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mLastEventSeen.add(sensor.getHandle(), event); 159f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian} 160f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 161f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopianvoid SensorService::registerVirtualSensor(SensorInterface* s) 162f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian{ 163f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian registerSensor(s); 164f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mVirtualSensorList.add( s ); 165f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian} 166f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 167fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSensorService::~SensorService() 168fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 169f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian for (size_t i=0 ; i<mSensorMap.size() ; i++) 170f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian delete mSensorMap.valueAt(i); 171fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 172fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 1731cb13461a8cf62e3ba634e5965332f2d284f6d42Mathias Agopianstatic const String16 sDump("android.permission.DUMP"); 1741cb13461a8cf62e3ba634e5965332f2d284f6d42Mathias Agopian 175fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstatus_t SensorService::dump(int fd, const Vector<String16>& args) 176fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 177fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian const size_t SIZE = 1024; 178fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian char buffer[SIZE]; 179fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian String8 result; 1801cb13461a8cf62e3ba634e5965332f2d284f6d42Mathias Agopian if (!PermissionCache::checkCallingPermission(sDump)) { 181fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian snprintf(buffer, SIZE, "Permission Denial: " 182fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian "can't dump SurfaceFlinger from pid=%d, uid=%d\n", 183fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian IPCThreadState::self()->getCallingPid(), 184fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian IPCThreadState::self()->getCallingUid()); 185fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian result.append(buffer); 186fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } else { 187fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Mutex::Autolock _l(mLock); 1883560fb24b668675627934356f210d84d19bf4e56Mathias Agopian snprintf(buffer, SIZE, "Sensor List:\n"); 1893560fb24b668675627934356f210d84d19bf4e56Mathias Agopian result.append(buffer); 1903560fb24b668675627934356f210d84d19bf4e56Mathias Agopian for (size_t i=0 ; i<mSensorList.size() ; i++) { 1913560fb24b668675627934356f210d84d19bf4e56Mathias Agopian const Sensor& s(mSensorList[i]); 1923560fb24b668675627934356f210d84d19bf4e56Mathias Agopian const sensors_event_t& e(mLastEventSeen.valueFor(s.getHandle())); 193984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian snprintf(buffer, SIZE, 194984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian "%-48s| %-32s | 0x%08x | maxRate=%7.2fHz | " 195984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian "last=<%5.1f,%5.1f,%5.1f>\n", 1963560fb24b668675627934356f210d84d19bf4e56Mathias Agopian s.getName().string(), 1973560fb24b668675627934356f210d84d19bf4e56Mathias Agopian s.getVendor().string(), 1983560fb24b668675627934356f210d84d19bf4e56Mathias Agopian s.getHandle(), 19924d72350f321c17b0bfe1ef3fd52d4070a1c02c3Mathias Agopian s.getMinDelay() ? (1000000.0f / s.getMinDelay()) : 0.0f, 2003560fb24b668675627934356f210d84d19bf4e56Mathias Agopian e.data[0], e.data[1], e.data[2]); 2013560fb24b668675627934356f210d84d19bf4e56Mathias Agopian result.append(buffer); 2023560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } 203984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian SensorFusion::getInstance().dump(result, buffer, SIZE); 204f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorDevice::getInstance().dump(result, buffer, SIZE); 2053560fb24b668675627934356f210d84d19bf4e56Mathias Agopian 2067c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian snprintf(buffer, SIZE, "%d active connections\n", 2077c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian mActiveConnections.size()); 208fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian result.append(buffer); 209fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian snprintf(buffer, SIZE, "Active sensors:\n"); 210fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian result.append(buffer); 211fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian for (size_t i=0 ; i<mActiveSensors.size() ; i++) { 2125d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian int handle = mActiveSensors.keyAt(i); 213f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian snprintf(buffer, SIZE, "%s (handle=0x%08x, connections=%d)\n", 2145d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian getSensorName(handle).string(), 2155d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian handle, 216fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mActiveSensors.valueAt(i)->getNumConnections()); 217fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian result.append(buffer); 218fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 219fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 220fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian write(fd, result.string(), result.size()); 221fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return NO_ERROR; 222fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 223fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 224fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianbool SensorService::threadLoop() 225fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 226a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD("nuSensorService thread starting..."); 227fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 228d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian const size_t numEventMax = 16; 2298dd4fe8dd37b740282b48b7867eec26fcf95e027Mathias Agopian const size_t minBufferSize = numEventMax + numEventMax * mVirtualSensorList.size(); 230d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian sensors_event_t buffer[minBufferSize]; 231d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian sensors_event_t scratch[minBufferSize]; 232f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorDevice& device(SensorDevice::getInstance()); 233f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian const size_t vcount = mVirtualSensorList.size(); 234fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 235f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian ssize_t count; 236fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian do { 237f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian count = device.poll(buffer, numEventMax); 238fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (count<0) { 239f5a1230d322c14c42331d0a1536b50c87742973bSteve Block ALOGE("sensor poll failed (%s)", strerror(-count)); 240fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian break; 241fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 242fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 24394e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian recordLastValue(buffer, count); 24494e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian 245f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // handle virtual sensors 246f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (count && vcount) { 247984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian sensors_event_t const * const event = buffer; 248f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian const DefaultKeyedVector<int, SensorInterface*> virtualSensors( 249f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian getActiveVirtualSensors()); 250f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian const size_t activeVirtualSensorCount = virtualSensors.size(); 251f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (activeVirtualSensorCount) { 252f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian size_t k = 0; 253984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian SensorFusion& fusion(SensorFusion::getInstance()); 254984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian if (fusion.isEnabled()) { 255984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian for (size_t i=0 ; i<size_t(count) ; i++) { 256984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian fusion.process(event[i]); 257984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian } 258984826cc158193e61e3a00359ef4f6699c7d748aMathias Agopian } 259d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian for (size_t i=0 ; i<size_t(count) && k<minBufferSize ; i++) { 260f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian for (size_t j=0 ; j<activeVirtualSensorCount ; j++) { 261d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian if (count + k >= minBufferSize) { 262d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian ALOGE("buffer too small to hold all events: " 263d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian "count=%u, k=%u, size=%u", 264d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian count, k, minBufferSize); 265d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian break; 266d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian } 267f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sensors_event_t out; 268d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian SensorInterface* si = virtualSensors.valueAt(j); 269d1920ffede9e9bc107104ad94c291ca0f0f18bc3Mathias Agopian if (si->process(&out, event[i])) { 270f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian buffer[count + k] = out; 271f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian k++; 272f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 273f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 274f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 275f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (k) { 276f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // record the last synthesized values 277f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian recordLastValue(&buffer[count], k); 278f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian count += k; 279f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // sort the buffer by time-stamps 280f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sortEventBuffer(buffer, count); 281f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 282f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 283f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 284f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 285f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // send our events to clients... 286fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian const SortedVector< wp<SensorEventConnection> > activeConnections( 287fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian getActiveConnections()); 288fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian size_t numConnections = activeConnections.size(); 289f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian for (size_t i=0 ; i<numConnections ; i++) { 290f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sp<SensorEventConnection> connection( 291f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian activeConnections[i].promote()); 292f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (connection != 0) { 293f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian connection->sendEvents(buffer, count, scratch); 294fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 295fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 296fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } while (count >= 0 || Thread::exitPending()); 297fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 2983c20fbed7f3a916ced10f2ed5a272271b7d81edeSteve Block ALOGW("Exiting SensorService::threadLoop => aborting..."); 2991a62301fc58cd2af18239b0415813461bf5fc41bMathias Agopian abort(); 300fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return false; 301fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 302fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 30394e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopianvoid SensorService::recordLastValue( 30494e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian sensors_event_t const * buffer, size_t count) 30594e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian{ 30694e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian Mutex::Autolock _l(mLock); 30794e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian 30894e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian // record the last event for each sensor 30994e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian int32_t prev = buffer[0].sensor; 31094e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian for (size_t i=1 ; i<count ; i++) { 31194e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian // record the last event of each sensor type in this buffer 31294e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian int32_t curr = buffer[i].sensor; 31394e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian if (curr != prev) { 31494e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian mLastEventSeen.editValueFor(prev) = buffer[i-1]; 31594e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian prev = curr; 31694e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian } 31794e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian } 31894e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian mLastEventSeen.editValueFor(prev) = buffer[count-1]; 31994e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian} 32094e8f6813f3fb2beaa9bcbfb1ad9b4ae2eb46949Mathias Agopian 321f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopianvoid SensorService::sortEventBuffer(sensors_event_t* buffer, size_t count) 322f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian{ 323f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian struct compar { 324f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian static int cmp(void const* lhs, void const* rhs) { 325f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sensors_event_t const* l = static_cast<sensors_event_t const*>(lhs); 326f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian sensors_event_t const* r = static_cast<sensors_event_t const*>(rhs); 327a5c106a4f0afcf061728a1cb7c8c3b908728575dMathias Agopian return l->timestamp - r->timestamp; 328f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 329f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian }; 330f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian qsort(buffer, count, sizeof(sensors_event_t), compar::cmp); 331f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian} 332f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 333fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSortedVector< wp<SensorService::SensorEventConnection> > 334fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSensorService::getActiveConnections() const 335fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 336fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Mutex::Autolock _l(mLock); 337fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return mActiveConnections; 338fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 339fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 340f001c92436b4a66eb7687286325ced7f10c9f917Mathias AgopianDefaultKeyedVector<int, SensorInterface*> 341f001c92436b4a66eb7687286325ced7f10c9f917Mathias AgopianSensorService::getActiveVirtualSensors() const 342f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian{ 343f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian Mutex::Autolock _l(mLock); 344f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian return mActiveVirtualSensors; 345f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian} 346f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian 3475d2707214dfb97bd8dfcc6620be36841d3c82420Mathias AgopianString8 SensorService::getSensorName(int handle) const { 348010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian size_t count = mUserSensorList.size(); 3495d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian for (size_t i=0 ; i<count ; i++) { 350010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian const Sensor& sensor(mUserSensorList[i]); 3515d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian if (sensor.getHandle() == handle) { 3525d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian return sensor.getName(); 3535d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian } 3545d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian } 3555d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian String8 result("unknown"); 3565d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian return result; 3575d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian} 3585d2707214dfb97bd8dfcc6620be36841d3c82420Mathias Agopian 359fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianVector<Sensor> SensorService::getSensorList() 360fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 361010e42230135815907e76e5d7e5f30edf9e1799dMathias Agopian return mUserSensorList; 362fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 363fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 364fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopiansp<ISensorEventConnection> SensorService::createSensorEventConnection() 365fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 366fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian sp<SensorEventConnection> result(new SensorEventConnection(this)); 367fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return result; 368fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 369fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 370db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopianvoid SensorService::cleanupConnection(SensorEventConnection* c) 371fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 372fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Mutex::Autolock _l(mLock); 373db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian const wp<SensorEventConnection> connection(c); 3747c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian size_t size = mActiveSensors.size(); 375a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD_IF(DEBUG_CONNECTIONS, "%d active sensors", size); 3767c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian for (size_t i=0 ; i<size ; ) { 377db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian int handle = mActiveSensors.keyAt(i); 378db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian if (c->hasSensor(handle)) { 379a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD_IF(DEBUG_CONNECTIONS, "%i: disabling handle=0x%08x", i, handle); 380f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorInterface* sensor = mSensorMap.valueFor( handle ); 381f5a1230d322c14c42331d0a1536b50c87742973bSteve Block ALOGE_IF(!sensor, "mSensorMap[handle=0x%08x] is null!", handle); 382f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (sensor) { 383db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian sensor->activate(c, false); 384f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 385db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian } 386db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian SensorRecord* rec = mActiveSensors.valueAt(i); 387f5a1230d322c14c42331d0a1536b50c87742973bSteve Block ALOGE_IF(!rec, "mActiveSensors[%d] is null (handle=0x%08x)!", i, handle); 388a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD_IF(DEBUG_CONNECTIONS, 389a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian "removing connection %p for sensor[%d].handle=0x%08x", 390a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian c, i, handle); 391a1b7db95b6ccf5be9d8dfaac1b8f45494813edc0Mathias Agopian 392db5b4bce9e65ec9c2c7762b601297e4abadbc22aMathias Agopian if (rec && rec->removeConnection(connection)) { 393a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD_IF(DEBUG_CONNECTIONS, "... and it was the last connection"); 3947c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian mActiveSensors.removeItemsAt(i, 1); 395f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mActiveVirtualSensors.removeItem(handle); 3967c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian delete rec; 3977c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian size--; 3987c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian } else { 3997c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian i++; 400fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 401fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 4027c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian mActiveConnections.remove(connection); 403fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 404fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 405fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstatus_t SensorService::enable(const sp<SensorEventConnection>& connection, 406fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian int handle) 407fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 40850df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian if (mInitCheck != NO_ERROR) 40950df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian return mInitCheck; 41050df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian 411fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Mutex::Autolock _l(mLock); 412f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorInterface* sensor = mSensorMap.valueFor(handle); 413f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian status_t err = sensor ? sensor->activate(connection.get(), true) : status_t(BAD_VALUE); 414f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (err == NO_ERROR) { 415f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorRecord* rec = mActiveSensors.valueFor(handle); 416f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (rec == 0) { 417f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian rec = new SensorRecord(connection); 418f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mActiveSensors.add(handle, rec); 419f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (sensor->isVirtual()) { 420f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mActiveVirtualSensors.add(handle, sensor); 421f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 422f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } else { 423f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (rec->addConnection(connection)) { 424f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // this sensor is already activated, but we are adding a 425f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // connection that uses it. Immediately send down the last 4263f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian // known value of the requested sensor if it's not a 4273f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian // "continuous" sensor. 4283f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian if (sensor->getSensor().getMinDelay() == 0) { 4293f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian sensors_event_t scratch; 4303f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian sensors_event_t& event(mLastEventSeen.editValueFor(handle)); 4313f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian if (event.version == sizeof(sensors_event_t)) { 4323f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian connection->sendEvents(&event, 1); 4333f2f8916112126fb1a93e4a4b4e2d4e01570aeeeMathias Agopian } 434f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 4353560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } 4363560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } 437f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (err == NO_ERROR) { 438f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // connection now active 439f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (connection->addSensor(handle)) { 440f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // the sensor was added (which means it wasn't already there) 441f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian // so, see if this connection becomes active 442f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (mActiveConnections.indexOf(connection) < 0) { 443f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mActiveConnections.add(connection); 444f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian } 4457c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian } 446fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 447fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 448fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return err; 449fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 450fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 451fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstatus_t SensorService::disable(const sp<SensorEventConnection>& connection, 452fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian int handle) 453fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 45450df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian if (mInitCheck != NO_ERROR) 45550df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian return mInitCheck; 45650df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian 457fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian status_t err = NO_ERROR; 458fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian Mutex::Autolock _l(mLock); 459fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian SensorRecord* rec = mActiveSensors.valueFor(handle); 460fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (rec) { 461fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // see if this connection becomes inactive 462fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian connection->removeSensor(handle); 463fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (connection->hasAnySensor() == false) { 464fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mActiveConnections.remove(connection); 465fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 466fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // see if this sensor becomes inactive 467fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (rec->removeConnection(connection)) { 468fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mActiveSensors.removeItem(handle); 469f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mActiveVirtualSensors.removeItem(handle); 470fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian delete rec; 471fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 472f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian SensorInterface* sensor = mSensorMap.valueFor(handle); 473f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian err = sensor ? sensor->activate(connection.get(), false) : status_t(BAD_VALUE); 4747c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian } 475fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return err; 476fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 477fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 4787c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopianstatus_t SensorService::setEventRate(const sp<SensorEventConnection>& connection, 479fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian int handle, nsecs_t ns) 480fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 48150df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian if (mInitCheck != NO_ERROR) 48250df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian return mInitCheck; 48350df2959e58fc7408f98d11d77c8428397dca445Mathias Agopian 484ae09d65f5b35cb51da2e1386a6dd7a52085f1325Mathias Agopian SensorInterface* sensor = mSensorMap.valueFor(handle); 485ae09d65f5b35cb51da2e1386a6dd7a52085f1325Mathias Agopian if (!sensor) 486ae09d65f5b35cb51da2e1386a6dd7a52085f1325Mathias Agopian return BAD_VALUE; 487ae09d65f5b35cb51da2e1386a6dd7a52085f1325Mathias Agopian 4881cd700015318727d6d42236ab6274f1949fb08baMathias Agopian if (ns < 0) 4891cd700015318727d6d42236ab6274f1949fb08baMathias Agopian return BAD_VALUE; 4901cd700015318727d6d42236ab6274f1949fb08baMathias Agopian 49162569ecf526c7c01cb68ea461c6bbd3cb26057d2Mathias Agopian nsecs_t minDelayNs = sensor->getSensor().getMinDelayNs(); 49262569ecf526c7c01cb68ea461c6bbd3cb26057d2Mathias Agopian if (ns < minDelayNs) { 49362569ecf526c7c01cb68ea461c6bbd3cb26057d2Mathias Agopian ns = minDelayNs; 494ae09d65f5b35cb51da2e1386a6dd7a52085f1325Mathias Agopian } 495ae09d65f5b35cb51da2e1386a6dd7a52085f1325Mathias Agopian 4967c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian if (ns < MINIMUM_EVENTS_PERIOD) 4977c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian ns = MINIMUM_EVENTS_PERIOD; 4981cd700015318727d6d42236ab6274f1949fb08baMathias Agopian 499f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian return sensor->setDelay(connection.get(), handle, ns); 500fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 501fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 502fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 503fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 504fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSensorService::SensorRecord::SensorRecord( 505fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian const sp<SensorEventConnection>& connection) 506fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 507fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mConnections.add(connection); 508fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 509fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 5107c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopianbool SensorService::SensorRecord::addConnection( 511fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian const sp<SensorEventConnection>& connection) 512fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 513fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (mConnections.indexOf(connection) < 0) { 514fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mConnections.add(connection); 5157c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return true; 516fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 5177c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return false; 518fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 519fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 520fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianbool SensorService::SensorRecord::removeConnection( 521fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian const wp<SensorEventConnection>& connection) 522fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 523fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian ssize_t index = mConnections.indexOf(connection); 524fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (index >= 0) { 525fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mConnections.removeItemsAt(index, 1); 526fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 527fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return mConnections.size() ? false : true; 528fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 529fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 530fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 531fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 532fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSensorService::SensorEventConnection::SensorEventConnection( 533fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian const sp<SensorService>& service) 534b3989276d17f2b083bec67b695d1078fb86c6c53Mathias Agopian : mService(service), mChannel(new BitTube()) 535fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 536fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 537fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 538fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias AgopianSensorService::SensorEventConnection::~SensorEventConnection() 539fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 540a551237de142549fb8a6608ee9d2fbf4b7ca2ebfSteve Block ALOGD_IF(DEBUG_CONNECTIONS, "~SensorEventConnection(%p)", this); 541fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian mService->cleanupConnection(this); 542fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 543fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 544fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianvoid SensorService::SensorEventConnection::onFirstRef() 545fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 546fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 547fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 5487c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopianbool SensorService::SensorEventConnection::addSensor(int32_t handle) { 54971d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian Mutex::Autolock _l(mConnectionLock); 550f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (mSensorInfo.indexOf(handle) <= 0) { 551f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian mSensorInfo.add(handle); 5527c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return true; 553fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 5547c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return false; 555fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 556fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 5577c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopianbool SensorService::SensorEventConnection::removeSensor(int32_t handle) { 55871d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian Mutex::Autolock _l(mConnectionLock); 559f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (mSensorInfo.remove(handle) >= 0) { 5607c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return true; 5617c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian } 5627c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return false; 563fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 564fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 565fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianbool SensorService::SensorEventConnection::hasSensor(int32_t handle) const { 56671d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian Mutex::Autolock _l(mConnectionLock); 567f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian return mSensorInfo.indexOf(handle) >= 0; 568fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 569fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 570fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianbool SensorService::SensorEventConnection::hasAnySensor() const { 57171d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian Mutex::Autolock _l(mConnectionLock); 5727c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return mSensorInfo.size() ? true : false; 5737c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian} 5747c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian 575fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstatus_t SensorService::SensorEventConnection::sendEvents( 576cf51001dbf28e9885fcacd4048902f1c75768fe9Mathias Agopian sensors_event_t const* buffer, size_t numEvents, 577cf51001dbf28e9885fcacd4048902f1c75768fe9Mathias Agopian sensors_event_t* scratch) 578fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 579cf51001dbf28e9885fcacd4048902f1c75768fe9Mathias Agopian // filter out events not for this connection 5803560fb24b668675627934356f210d84d19bf4e56Mathias Agopian size_t count = 0; 5813560fb24b668675627934356f210d84d19bf4e56Mathias Agopian if (scratch) { 58271d7a5c289c6ef6b5fc86dd4784a075ca6470e38Mathias Agopian Mutex::Autolock _l(mConnectionLock); 5833560fb24b668675627934356f210d84d19bf4e56Mathias Agopian size_t i=0; 5843560fb24b668675627934356f210d84d19bf4e56Mathias Agopian while (i<numEvents) { 5853560fb24b668675627934356f210d84d19bf4e56Mathias Agopian const int32_t curr = buffer[i].sensor; 586f001c92436b4a66eb7687286325ced7f10c9f917Mathias Agopian if (mSensorInfo.indexOf(curr) >= 0) { 5873560fb24b668675627934356f210d84d19bf4e56Mathias Agopian do { 5883560fb24b668675627934356f210d84d19bf4e56Mathias Agopian scratch[count++] = buffer[i++]; 5893560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } while ((i<numEvents) && (buffer[i].sensor == curr)); 5903560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } else { 5913560fb24b668675627934356f210d84d19bf4e56Mathias Agopian i++; 5923560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } 593cf51001dbf28e9885fcacd4048902f1c75768fe9Mathias Agopian } 5943560fb24b668675627934356f210d84d19bf4e56Mathias Agopian } else { 5953560fb24b668675627934356f210d84d19bf4e56Mathias Agopian scratch = const_cast<sensors_event_t *>(buffer); 5963560fb24b668675627934356f210d84d19bf4e56Mathias Agopian count = numEvents; 597cf51001dbf28e9885fcacd4048902f1c75768fe9Mathias Agopian } 598fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 599907103bf186cfdd2ed9eb3b6c36de53ade7b16f6Mathias Agopian // NOTE: ASensorEvent and sensors_event_t are the same type 600907103bf186cfdd2ed9eb3b6c36de53ade7b16f6Mathias Agopian ssize_t size = SensorEventQueue::write(mChannel, 601907103bf186cfdd2ed9eb3b6c36de53ade7b16f6Mathias Agopian reinterpret_cast<ASensorEvent const*>(scratch), count); 602fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (size == -EAGAIN) { 603fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // the destination doesn't accept events anymore, it's probably 604fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian // full. For now, we just drop the events on the floor. 6053c20fbed7f3a916ced10f2ed5a272271b7d81edeSteve Block //ALOGW("dropping %d events on the floor", count); 606fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return size; 607fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 608fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 6091e0b1e8491e5f6dc59faabe70cbfa942853150e0Jeff Brown return size < 0 ? status_t(size) : status_t(NO_ERROR); 610fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 611fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 612b3989276d17f2b083bec67b695d1078fb86c6c53Mathias Agopiansp<BitTube> SensorService::SensorEventConnection::getSensorChannel() const 613fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 614fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return mChannel; 615fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 616fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 617fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstatus_t SensorService::SensorEventConnection::enableDisable( 618fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian int handle, bool enabled) 619fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 620fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian status_t err; 621fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian if (enabled) { 622fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian err = mService->enable(this, handle); 623fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } else { 624fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian err = mService->disable(this, handle); 625fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian } 626fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian return err; 627fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 628fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 629fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopianstatus_t SensorService::SensorEventConnection::setEventRate( 630fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian int handle, nsecs_t ns) 631fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian{ 6327c1c531872a95051cb11ec829e3daf890d9bb58aMathias Agopian return mService->setEventRate(this, handle, ns); 633fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian} 634fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 635fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian// --------------------------------------------------------------------------- 636fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian}; // namespace android 637fc32881fcc68640d008c7515cdd1bcd866f72cd5Mathias Agopian 638