SensorService中Binder案例

SensorService中Binder案例

  • 1、FWK实际操作在Native层
  • 2、Native层中代码实现Bn/Bp端
    • 2.1 代码实现Bn端
    • 2.2 代码实现Bp端
      • 2.2.1 模板interface_cast

android12-release


1、FWK实际操作在Native层

SensorService.java实际操作Native层SensorService.cpp;对应Bn服务端。
应用获取Context.SEARCH_SERVICE实际操作Native层SensorManager.cpp;对应Bp客户端。
在这里插入图片描述

frameworks/base/services/core/java/com/android/server/sensors/SensorService.java

public SensorService(Context ctx) {super(ctx);synchronized (mLock) {mSensorServiceStart = SystemServerInitThreadPool.submit(() -> {TimingsTraceAndSlog traceLog = TimingsTraceAndSlog.newAsyncLog();traceLog.traceBegin(START_NATIVE_SENSOR_SERVICE);long ptr = startSensorServiceNative(new ProximityListenerDelegate());synchronized (mLock) {mPtr = ptr;}traceLog.traceEnd();}, START_NATIVE_SENSOR_SERVICE);}
}@Override
public void onStart() {LocalServices.addService(SensorManagerInternal.class, new LocalService());
}

frameworks/base/core/java/android/hardware/SystemSensorManager.java

/** {@hide} */
public SystemSensorManager(Context context, Looper mainLooper) {synchronized (sLock) {if (!sNativeClassInited) {sNativeClassInited = true;nativeClassInit();}}mMainLooper = mainLooper;ApplicationInfo appInfo = context.getApplicationInfo();mTargetSdkLevel = appInfo.targetSdkVersion;mContext = context;mNativeInstance = nativeCreate(context.getOpPackageName());mIsPackageDebuggable = (0 != (appInfo.flags & ApplicationInfo.FLAG_DEBUGGABLE));PackageManager packageManager = context.getPackageManager();mHasHighSamplingRateSensorsPermission =(PERMISSION_GRANTED == packageManager.checkPermission(HIGH_SAMPLING_RATE_SENSORS_PERMISSION,appInfo.packageName));// initialize the sensor listfor (int index = 0;; ++index) {Sensor sensor = new Sensor();if (!nativeGetSensorAtIndex(mNativeInstance, sensor, index)) break;mFullSensorsList.add(sensor);mHandleToSensor.put(sensor.getHandle(), sensor);}
}

2、Native层中代码实现Bn/Bp端

ServiceManager中添加"sensorservice"

frameworks/base/services/core/jni/com_android_server_sensor_SensorService.cpp

NativeSensorService::NativeSensorService(JNIEnv* env, jobject listener): mProximityActiveListenerDelegate(new ProximityActiveListenerDelegate(env, listener)) {if (base::GetBoolProperty("system_init.startsensorservice", true)) {sp<IServiceManager> sm(defaultServiceManager());mService = new SensorService();sm->addService(String16(SensorService::getServiceName()), mService,false /* allowIsolated */, IServiceManager::DUMP_FLAG_PRIORITY_CRITICAL);}
}

2.1 代码实现Bn端

SensorService继承BnSensorServer,实现onTransact方法一边Bp客户端调用,Code标签对应调用方法,Parcel& data参数,Parcel* reply接收返回值,flags = 0存在默认值。

frameworks/native/libs/sensor/include/sensor/ISensorServer.h

class BnSensorServer : public BnInterface<ISensorServer>
{
public:virtual status_t shellCommand(int in, int out, int err,Vector<String16>& args) = 0;virtual status_t    onTransact( uint32_t code,const Parcel& data,Parcel* reply,uint32_t flags = 0);
};

frameworks/native/libs/sensor/ISensorServer.cpp

enum {GET_SENSOR_LIST = IBinder::FIRST_CALL_TRANSACTION,CREATE_SENSOR_EVENT_CONNECTION,ENABLE_DATA_INJECTION,GET_DYNAMIC_SENSOR_LIST,CREATE_SENSOR_DIRECT_CONNECTION,SET_OPERATION_PARAMETER,
};status_t BnSensorServer::onTransact(uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags)
{switch(code) {case GET_SENSOR_LIST: {CHECK_INTERFACE(ISensorServer, data, reply);const String16& opPackageName = data.readString16();Vector<Sensor> v(getSensorList(opPackageName));size_t n = v.size();reply->writeUint32(static_cast<uint32_t>(n));for (size_t i = 0; i < n; i++) {reply->write(v[i]);}return NO_ERROR;}case CREATE_SENSOR_EVENT_CONNECTION: {CHECK_INTERFACE(ISensorServer, data, reply);String8 packageName = data.readString8();int32_t mode = data.readInt32();const String16& opPackageName = data.readString16();const String16& attributionTag = data.readString16();sp<ISensorEventConnection> connection(createSensorEventConnection(packageName, mode,opPackageName, attributionTag));reply->writeStrongBinder(IInterface::asBinder(connection));return NO_ERROR;}case ENABLE_DATA_INJECTION: {CHECK_INTERFACE(ISensorServer, data, reply);int32_t ret = isDataInjectionEnabled();reply->writeInt32(static_cast<int32_t>(ret));return NO_ERROR;}case GET_DYNAMIC_SENSOR_LIST: {CHECK_INTERFACE(ISensorServer, data, reply);const String16& opPackageName = data.readString16();Vector<Sensor> v(getDynamicSensorList(opPackageName));size_t n = v.size();reply->writeUint32(static_cast<uint32_t>(n));for (size_t i = 0; i < n; i++) {reply->write(v[i]);}return NO_ERROR;}case CREATE_SENSOR_DIRECT_CONNECTION: {CHECK_INTERFACE(ISensorServer, data, reply);const String16& opPackageName = data.readString16();uint32_t size = data.readUint32();int32_t type = data.readInt32();int32_t format = data.readInt32();native_handle_t *resource = data.readNativeHandle();// Avoid a crash in native_handle_close if resource is nullptrif (resource == nullptr) {return BAD_VALUE;}sp<ISensorEventConnection> ch =createSensorDirectConnection(opPackageName, size, type, format, resource);native_handle_close(resource);native_handle_delete(resource);reply->writeStrongBinder(IInterface::asBinder(ch));return NO_ERROR;}case SET_OPERATION_PARAMETER: {CHECK_INTERFACE(ISensorServer, data, reply);int32_t handle;int32_t type;Vector<float> floats;Vector<int32_t> ints;uint32_t count;handle = data.readInt32();type = data.readInt32();count = data.readUint32();if (count > (data.dataAvail() / sizeof(float))) {return BAD_VALUE;}floats.resize(count);for (auto &i : floats) {i = data.readFloat();}count = data.readUint32();if (count > (data.dataAvail() / sizeof(int32_t))) {return BAD_VALUE;}ints.resize(count);for (auto &i : ints) {i = data.readInt32();}int32_t ret = setOperationParameter(handle, type, floats, ints);reply->writeInt32(ret);return NO_ERROR;}case SHELL_COMMAND_TRANSACTION: {int in = data.readFileDescriptor();int out = data.readFileDescriptor();int err = data.readFileDescriptor();int argc = data.readInt32();Vector<String16> args;for (int i = 0; i < argc && data.dataAvail() > 0; i++) {args.add(data.readString16());}sp<IBinder> unusedCallback;sp<IResultReceiver> resultReceiver;status_t status;if ((status = data.readNullableStrongBinder(&unusedCallback)) != NO_ERROR) {return status;}if ((status = data.readNullableStrongBinder(&resultReceiver)) != NO_ERROR) {return status;}status = shellCommand(in, out, err, args);if (resultReceiver != nullptr) {resultReceiver->send(status);}return NO_ERROR;}}return BBinder::onTransact(code, data, reply, flags);
}

2.2 代码实现Bp端

应用获取Context.SEARCH_SERVICE实际操作Native层SensorManager.cpp;对应Bp客户端获取查看 Binder系列2-ServiceManager 中模板interface_cast => 模板::android::sp<Bp##INTERFACE>::make(obj)

Bp端中方法如getSensorList(),通过remote()->transact(GET_SENSOR_LIST, data, &reply);最终调用到Bn端的onTransact方法,GET_SENSOR_LIST作为Code标签调用对应方法,Parcel& data参数,Parcel* reply接收返回值,flags = 0有默认值。

frameworks/native/libs/sensor/include/sensor/ISensorServer.h
frameworks/native/libs/sensor/ISensorServer.cpp

enum {GET_SENSOR_LIST = IBinder::FIRST_CALL_TRANSACTION,CREATE_SENSOR_EVENT_CONNECTION,ENABLE_DATA_INJECTION,GET_DYNAMIC_SENSOR_LIST,CREATE_SENSOR_DIRECT_CONNECTION,SET_OPERATION_PARAMETER,
};class BpSensorServer : public BpInterface<ISensorServer>
{
public:explicit BpSensorServer(const sp<IBinder>& impl): BpInterface<ISensorServer>(impl){}virtual ~BpSensorServer();virtual Vector<Sensor> getSensorList(const String16& opPackageName){Parcel data, reply;data.writeInterfaceToken(ISensorServer::getInterfaceDescriptor());data.writeString16(opPackageName);remote()->transact(GET_SENSOR_LIST, data, &reply);Sensor s;Vector<Sensor> v;uint32_t n = reply.readUint32();v.setCapacity(n);while (n) {n--;reply.read(s);v.add(s);}return v;}virtual Vector<Sensor> getDynamicSensorList(const String16& opPackageName){Parcel data, reply;data.writeInterfaceToken(ISensorServer::getInterfaceDescriptor());data.writeString16(opPackageName);remote()->transact(GET_DYNAMIC_SENSOR_LIST, data, &reply);Sensor s;Vector<Sensor> v;uint32_t n = reply.readUint32();v.setCapacity(n);while (n) {n--;reply.read(s);v.add(s);}return v;}virtual sp<ISensorEventConnection> createSensorEventConnection(const String8& packageName,int mode, const String16& opPackageName, const String16& attributionTag){Parcel data, reply;data.writeInterfaceToken(ISensorServer::getInterfaceDescriptor());data.writeString8(packageName);data.writeInt32(mode);data.writeString16(opPackageName);data.writeString16(attributionTag);remote()->transact(CREATE_SENSOR_EVENT_CONNECTION, data, &reply);return interface_cast<ISensorEventConnection>(reply.readStrongBinder());}virtual int isDataInjectionEnabled() {Parcel data, reply;data.writeInterfaceToken(ISensorServer::getInterfaceDescriptor());remote()->transact(ENABLE_DATA_INJECTION, data, &reply);return reply.readInt32();}virtual sp<ISensorEventConnection> createSensorDirectConnection(const String16& opPackageName,uint32_t size, int32_t type, int32_t format, const native_handle_t *resource) {Parcel data, reply;data.writeInterfaceToken(ISensorServer::getInterfaceDescriptor());data.writeString16(opPackageName);data.writeUint32(size);data.writeInt32(type);data.writeInt32(format);data.writeNativeHandle(resource);remote()->transact(CREATE_SENSOR_DIRECT_CONNECTION, data, &reply);return interface_cast<ISensorEventConnection>(reply.readStrongBinder());}virtual int setOperationParameter(int32_t handle, int32_t type,const Vector<float> &floats,const Vector<int32_t> &ints) {Parcel data, reply;data.writeInterfaceToken(ISensorServer::getInterfaceDescriptor());data.writeInt32(handle);data.writeInt32(type);data.writeUint32(static_cast<uint32_t>(floats.size()));for (auto i : floats) {data.writeFloat(i);}data.writeUint32(static_cast<uint32_t>(ints.size()));for (auto i : ints) {data.writeInt32(i);}remote()->transact(SET_OPERATION_PARAMETER, data, &reply);return reply.readInt32();}
};// Out-of-line virtual method definition to trigger vtable emission in this
// translation unit (see clang warning -Wweak-vtables)
BpSensorServer::~BpSensorServer() {}

2.2.1 模板interface_cast

对应Bp客户端获取查看 Binder系列2-ServiceManager 中模板interface_cast => 模板::android::sp<Bp##INTERFACE>::make(obj)

frameworks/native/libs/binder/include/binder/IServiceManager.h

template<typename INTERFACE>
status_t getService(const String16& name, sp<INTERFACE>* outService)
{const sp<IServiceManager> sm = defaultServiceManager();if (sm != nullptr) {*outService = interface_cast<INTERFACE>(sm->getService(name));if ((*outService) != nullptr) return NO_ERROR;}return NAME_NOT_FOUND;
}

frameworks/native/libs/binder/include/binder/IInterface.h

//... ...
template<typename INTERFACE>
inline sp<INTERFACE> interface_cast(const sp<IBinder>& obj)
{return INTERFACE::asInterface(obj);
}
//... ...static ::android::sp<I##INTERFACE> asInterface(                     \const ::android::sp<::android::IBinder>& obj);              \
//... ...::android::sp<I##INTERFACE> I##INTERFACE::asInterface(              \const ::android::sp<::android::IBinder>& obj)               \{                                                                   \::android::sp<I##INTERFACE> intr;                               \if (obj != nullptr) {                                           \intr = ::android::sp<I##INTERFACE>::cast(                   \obj->queryLocalInterface(I##INTERFACE::descriptor));    \if (intr == nullptr) {                                      \intr = ::android::sp<Bp##INTERFACE>::make(obj);         \}                                                           \}                                                               \return intr;                                                    \}                                                                   \

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/52339.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

微信小程序 车牌号输入组件

概述 一个小组件&#xff0c;用于方便用户输入车牌号码 详细 概述 有时候我们开发过程中会遇到需要用户输入车牌号的情况&#xff0c;让客户通过自带键盘输入&#xff0c;体验不好且容易出错&#xff0c;例如车牌号是不能输入O和I的&#xff0c;因此需要有一个自定义的键盘…

vue直接使用高德api

第一步&#xff1a;在index.html 引入 <script src"https://webapi.amap.com/maps?v2.0&key你的key"></script>第二步&#xff1a;在你需要地图的时候 放入 <template><div style"width: 200px; height: 200px"><div id&q…

极狐GitLab 价值流管理之「总时间图」使用指南

本文来源&#xff1a;about.gitlab.com 作者&#xff1a;Haim Snir 译者&#xff1a;极狐(GitLab) 市场部内容团队 对于软件研发管理者来说&#xff0c;了解在整个研发过程中时间都耗费在了哪些地方&#xff0c;是进行交付价值优化的关键洞察。GitLab / 极狐GitLab 新的价值流分…

回归预测 | MATLAB实现PSO-RBF粒子群优化算法优化径向基函数神经网络多输入单输出回归预测(多指标,多图)

回归预测 | MATLAB实现PSO-RBF粒子群优化算法优化径向基函数神经网络多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09; 目录 回归预测 | MATLAB实现PSO-RBF粒子群优化算法优化径向基函数神经网络多输入单输出回归预测&#xff08;多指标&#xff0c;多图&a…

创建和分析二维桁架和梁结构研究(Matlab代码实现)

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…

Git基础——基本的 Git本地操作

本文涵盖了你在使用Git的绝大多数时间里会用到的所有基础命令。学完之后&#xff0c;你应该能够配置并初始化Git仓库、开始或停止跟踪文件、暂存或者提交更改。我们也会讲授如何让Git忽略某些文件和文件模式&#xff0c;如何简单快速地撤销错误操作&#xff0c;如何浏览项目版本…

Spring详解

文章目录 一、引言1.1 原生web开发中存在哪些问题&#xff1f; 二、Spring框架2.1 概念2.2 访问与下载 三、Spring架构组成四、自定义工厂4.1 配置文件4.2 工厂类 五、构建Maven项目5.1 新建项目5.2 选择Maven目录5.3 GAV坐标 六、Spring环境搭建6.1 pom.xml中引入Spring常用依…

【sql】MongoDB 增删改查 高级用法

【sql】MongoDB 增删改查 高级用法 相关使用文档 MongoDB Query API — MongoDB Manual https://www.mongodb.com/docs/manual/reference/sql-comparison //增 //新增数据2种方式 db.msg.save({"name":"springboot&#x1f600;"}); db.msg.insert({&qu…

prompt工程(持续更新ing...)

诸神缄默不语-个人CSDN博文目录 我准备想办法把这些东西整合到我的ScholarEase项目里。到时候按照分类、按照prompt生成方法列一堆选项&#xff0c;用户自己生成prompt后可以选择在ScholarEase里面聊天&#xff0c;也可以复制到别的地方&#xff08;比如ChatGPT网页版之类的&a…

Ansible 使用 RHEL 系统角色

安装 RHEL 系统角色软件包&#xff0c;并创建符合以下条件的 playbook /home/greg/ansible/timesync.yml 在所有受管节点上运行 使用 timesync 角色 配置该角色&#xff0c;以使用当前有效的 NTP 提供商 配置该角色&#xff0c;以使用时间服务器 172.25.254.254 配置该角色&am…

Linux虚拟机安装(Ubuntu 20)

最近这段时间使用VMWare安装了一下Ubuntu版本的Linux虚拟机&#xff0c;在这里记录一下安装时参考的文章以及需要注意的细节 参考链接&#xff1a; VMware虚拟机下安装Ubuntu20.04&#xff08;保姆级教程&#xff09; 一、安装VMWare 下载链接&#xff1a;VMware Workstatio…

GB28181国标平台测试软件NTV-GBC(包含服务器和模拟客户端)

GB28181国标平台测试软件NTV-GBC用于对GB28181国标平台进行测试(测试用例需要服务器软件&#xff0c;服务器软件可以是任何标准的国标平台&#xff0c;我们测试使用的是NTV-GBS&#xff09;&#xff0c;软件实现了设备注册、注销、目录查询&#xff0c;消息订阅、INVITE&#x…

概率密度函数 累积分布函数

概率密度函数&#xff1a;是指想要求得面积的图形表达式&#xff0c;注意只是表达式&#xff0c;要乘上区间才是概率&#xff0c;所以概率密度并不是概率&#xff0c;而是概率的分布程度。 为什么要引入概率密度&#xff0c;可能是因为连续变量&#xff0c;无法求出某个变量的…

软件测试及数据分析处理实训室建设方案

一 、系统概述 软件测试及数据分析处理是软件开发过程中的一项重要测试活动&#xff0c;旨在验证不同软件模块或组件之间的集成与交互是否正常。综合测试确保各个模块按照设计要求正确地协同工作&#xff0c;以实现整个软件系统的功能和性能。以下是软件测试及数据分析处理的一…

【BUG】解决安装oracle11g或12C中无法访问临时位置的问题

项目场景&#xff1a; 安装oracle时&#xff0c;到第二步出现oracle11g或12C中无法访问临时位置的问题。 解决方案&#xff1a; 针对客户端安装&#xff0c;在cmd中执行命令&#xff1a;前面加实际路径setup.exe -ignorePrereq -J"-Doracle.install.client.validate.cli…

汽车电子笔记之:AUTOSA架构下的多核OS操作系统

目录 1、AUTOSAR多核操作系统 1.1、OS Application 1.2、多核OS的软件分区 1.3、任务调度 1.4、核间任务同步 1.5、计数器、报警器、调度表 1.6、自旋锁与共享资源 1.7、核间通信IOC 1.8、OS Object中元素交互 1.9、多核OS的启动与关闭 2、多核OS注意事项 2.1、最小…

【QT5-自我学习-线程qThread练习-两种使用方式-2:通过继承Qobject类-自己实现功能函数方式-基础样例】

【QT5-自我学习-线程qThread练习-两种使用方式-2&#xff1a;通过继承Qobject类-自己实现功能函数方式-基础样例】 1、前言2、实验环境3-1、学习链接-参考文章3-2、先前了解-自我总结&#xff08;1&#xff09;线程处理逻辑事件&#xff0c;不能带有主窗口的事件&#xff08;2&…

4G模组EC20 网卡udhcpc获取IP但是没有设置IP

使能网卡&#xff1a; ifconfig usb0 up dhcp获取ip&#xff0c;虽然没有报error&#xff0c;但是很显然没有设置进配置 获取ip命令&#xff1a;udhcpc -i usb0 非正常现象&#xff1a; 正常现象&#xff1a; 解决方法&#xff1a; &#xff08;1&#xff09;rootfs 创建文件夹…

lvs-DR模式:

lvs-DR数据包流向分析 客户端发送请求到 Director Server&#xff08;负载均衡器&#xff09;&#xff0c;请求的数据报文&#xff08;源 IP 是 CIP,目标 IP 是 VIP&#xff09;到达内核空间。 Director Server 和 Real Server 在同一个网络中&#xff0c;数据通过二层数据链路…

安卓主板定制_电磁屏/电容屏安卓平板基于MTK联发科方案定制

定制化行业平板 在各行各业中的地位越来越重要&#xff0c;甚至在行业转型和发展中发挥着不可替代的作用。随着工业化社会的快速发展&#xff0c;工业生产对智控设备要求越来越高&#xff0c;运用的范畴也越来越普遍广泛&#xff0c;工业级平板就是其中一种应用广泛的设备。 新…