1 /* 2 * Copyright (c) 2021-2023 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16 #ifndef SENSOR_SERVICE_H 17 #define SENSOR_SERVICE_H 18 19 #include <mutex> 20 #include <thread> 21 #include <unordered_map> 22 23 #include "nocopyable.h" 24 #include "system_ability.h" 25 26 #include "client_info.h" 27 #include "death_recipient_template.h" 28 #include "sensor_data_event.h" 29 #include "sensor_delayed_sp_singleton.h" 30 #include "sensor_manager.h" 31 #include "sensor_power_policy.h" 32 #include "sensor_service_stub.h" 33 #include "stream_server.h" 34 #ifdef HDF_DRIVERS_INTERFACE_SENSOR 35 #include "sensor_hdi_connection.h" 36 #endif // HDF_DRIVERS_INTERFACE_SENSOR 37 38 namespace OHOS { 39 namespace Sensors { 40 enum class SensorServiceState { 41 STATE_STOPPED, 42 STATE_RUNNING, 43 }; 44 45 class SensorService : public SystemAbility, public StreamServer, public SensorServiceStub { 46 DECLARE_SYSTEM_ABILITY(SensorService) 47 SENSOR_DECLARE_DELAYED_SP_SINGLETON(SensorService); 48 49 public: 50 void OnDump() override; 51 void OnStart() override; 52 void OnStop() override; 53 int Dump(int fd, const std::vector<std::u16string> &args) override; 54 ErrCode EnableSensor(int32_t sensorId, int64_t samplingPeriodNs, int64_t maxReportDelayNs) override; 55 ErrCode DisableSensor(int32_t sensorId) override; 56 std::vector<Sensor> GetSensorList() override; 57 ErrCode TransferDataChannel(const sptr<SensorBasicDataChannel> &sensorBasicDataChannel, 58 const sptr<IRemoteObject> &sensorClient) override; 59 ErrCode DestroySensorChannel(sptr<IRemoteObject> sensorClient) override; 60 void ProcessDeathObserver(const wptr<IRemoteObject> &object); 61 ErrCode SuspendSensors(int32_t pid) override; 62 ErrCode ResumeSensors(int32_t pid) override; 63 ErrCode GetActiveInfoList(int32_t pid, std::vector<ActiveInfo> &activeInfoList) override; 64 ErrCode CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) override; 65 ErrCode DestroySocketChannel(sptr<IRemoteObject> sensorClient) override; 66 ErrCode EnableActiveInfoCB() override; 67 ErrCode DisableActiveInfoCB() override; 68 ErrCode ResetSensors() override; 69 70 private: 71 DISALLOW_COPY_AND_MOVE(SensorService); 72 void OnAddSystemAbility(int32_t systemAbilityId, const std::string &deviceId) override; 73 void OnRemoveSystemAbility(int32_t systemAbilityId, const std::string &deviceId) override; 74 bool CheckParameter(int32_t sensorId, int64_t samplingPeriodNs, int64_t maxReportDelayNs); 75 76 class PermStateChangeCb : public Security::AccessToken::PermStateChangeCallbackCustomize { 77 public: PermStateChangeCb(const Security::AccessToken::PermStateChangeScope & scope,sptr<SensorService> server)78 PermStateChangeCb(const Security::AccessToken::PermStateChangeScope &scope, 79 sptr<SensorService> server) : PermStateChangeCallbackCustomize(scope), server_(server) {} 80 void PermStateChangeCallback(PermStateChangeInfo &result) override; 81 82 private: 83 sptr<SensorService> server_ = nullptr; 84 }; 85 86 void RegisterClientDeathRecipient(sptr<IRemoteObject> sensorClient, int32_t pid); 87 void UnregisterClientDeathRecipient(sptr<IRemoteObject> sensorClient); 88 bool InitSensorPolicy(); 89 void ReportOnChangeData(int32_t sensorId); 90 void ReportSensorSysEvent(int32_t sensorId, bool enable, int32_t pid, int64_t samplingPeriodNs = 0, 91 int64_t maxReportDelayNs = 0); 92 ErrCode DisableSensor(int32_t sensorId, int32_t pid); 93 bool RegisterPermCallback(int32_t sensorId); 94 void UnregisterPermCallback(); 95 void ReportActiveInfo(int32_t sensorId, int32_t pid); 96 bool CheckSensorId(int32_t sensorId); 97 SensorServiceState state_; 98 std::mutex serviceLock_; 99 std::mutex sensorsMutex_; 100 std::mutex sensorMapMutex_; 101 std::vector<Sensor> sensors_; 102 std::unordered_map<int32_t, Sensor> sensorMap_; 103 #ifdef HDF_DRIVERS_INTERFACE_SENSOR 104 bool InitInterface(); 105 bool InitDataCallback(); 106 bool InitSensorList(); 107 SensorHdiConnection &sensorHdiConnection_ = SensorHdiConnection::GetInstance(); 108 sptr<SensorDataProcesser> sensorDataProcesser_ = nullptr; 109 sptr<ReportDataCallback> reportDataCallback_ = nullptr; 110 #endif // HDF_DRIVERS_INTERFACE_SENSOR 111 ClientInfo &clientInfo_ = ClientInfo::GetInstance(); 112 SensorManager &sensorManager_ = SensorManager::GetInstance(); 113 std::mutex uidLock_; 114 // death recipient of sensor client 115 std::mutex clientDeathObserverMutex_; 116 sptr<IRemoteObject::DeathRecipient> clientDeathObserver_ = nullptr; 117 std::shared_ptr<PermStateChangeCb> permStateChangeCb_ = nullptr; 118 ErrCode SaveSubscriber(int32_t sensorId, int64_t samplingPeriodNs, int64_t maxReportDelayNs); 119 std::atomic_bool isReportActiveInfo_ = false; 120 static std::atomic_bool isAccessTokenServiceActive_; 121 }; 122 123 #define POWER_POLICY SensorPowerPolicy::GetInstance() 124 } // namespace Sensors 125 } // namespace OHOS 126 #endif // SENSOR_SERVICE_H 127