鸿蒙OpenHarmony技术—消息机制实现

用户态应用发送消息到驱动

用户态主要代码

struct HdfIoService *serv = HdfIoServiceBind(SAMPLE_SERVICE_NAME);


......


ret = serv->dispatcher->Dispatch(&serv->object, SAMPLE_WRITE_READ, data, reply);
if (ret != HDF_SUCCESS) {
    HDF_LOGE("fail to send service call");
    goto out;
}

重点就是通过HdfIoServiceBind绑定服务,调用服务的Dispatch接口

HdfIoServiceBind接口流程

HdfIoServiceBind接口的主要作用是open对应服务的字符设备节点/dev/hdf/serviceName,细节流程如下:

SHELL
HdfIoServiceBind(`drivers/hdf_core/framework/core/shared/src/hdf_io_service.c`)
    -> HdfIoServiceAdapterObtain
        -> open /dev/hdf/serviceName
        -> .Dispatch = HdfSyscallAdapterDispatch

HdfIoServiceAdapterObtain函数有两处实现:

  • 针对内核态,给内核用:drivers/hdf_core/framework/core/adapter/vnode/src/hdf_vnode_adapter.c
  • 针对用户态,给应用用:drivers/hdf_core/framework/core/adapter/syscall/src/hdf_syscall_adapter.c

这里主要看用户态的实现,即hdf_syscall_adapter.c

Dispatch接口流程

SHELL
serv->dispatcher->Dispatch()
dispatcher 
    -> Dispatch()
        -> HdfSyscallAdapterDispatch 
            -> ioctl - HDF_WRITE_READ

最底层就是通过系统调用ioctl来读写消息(HDF_WRITE_READ)。

用户态应用接收驱动上报事件

用户态代码

struct HdfIoService *serv = HdfIoServiceBind(SAMPLE_SERVICE_NAME);


......


static struct HdfDevEventlistener listener = {
    .callBack = OnDevEventReceived,
    .priv ="Service0"
};


if (HdfDeviceRegisterEventListener(serv, &listener) !=          HDF_SUCCESS) {
    HDF_LOGE("fail to register event listener");
    return HDF_FAILURE;
}

主要是通过HdfDeviceRegisterEventListener注册回调函数

HdfDeviceRegisterEventListener函数流程

drivers/hdf_core/framework/core/adapter/syscall/src/hdf_syscall_adapter.c

SHELL
HdfDeviceRegisterEventListener
    -> HdfDeviceRegisterEventListenerWithSchedPolicy
        -> HdfIoServiceStartListen
            -> HdfIoServiceThreadBindLocked
                -> HdfDevListenerThreadInit
                    -> HdfDevListenerThreadDoInit
                        -> OsalThreadCreate HdfDevEventListenTask
            -> HdfDevListenerThreadStart
                -> HdfAdapterStartListenIoctl  
                    -> ioctl  - HDF_LISTEN_EVENT_START
                -> OsalThreadStart HdfDevEventListenTask

调到最后,就是通过osal的接口OsalThreadCreate创建线程,OsalThreadStart开始线程,而对应的线程就是下面的HdfDevEventListenTask:

SHELL
HdfDevEventListenTask  - poll
    -> HdfDevEventReadAndDispatch  
        -> ioctl - HDF_READ_DEV_EVENT
        -> HdfDevEventDispatchLocked
            -> listener->callBack

以上的核心就是基于poll,通过ioctl来读取消息(HDF_READ_DEV_EVENT),然后再去调用上面传过来的回调函数。

有关进阶鸿蒙开发核心技术,可以前往主页查看更多。鸿蒙技术学习路线(略缩图)分布如下:

高清完整版获取可前往主页保存,另附鸿蒙文档


http://www.niftyadmin.cn/n/5304181.html

相关文章

从云计算到物联网:虚拟化技术的演变与嵌入式系统的融合

文章目录 一、硬件性能提升:摩尔定律与嵌入式虚拟化二、CPU多核技术:为嵌入式虚拟化提供支持三、业务负载整合:嵌入式虚拟化的核心需求四、降低硬件成本:虚拟化技术的经济效益五、软件重用与移植:虚拟化技术的优势六、…

计算机网络(10):下一代因特网

下一代网际协议 IPv6(IPng) 解决IP地址耗尽的措施 要解决IP地址耗尽的问题,可以采用以下三个措施: (1)采用无分类编址CIDR,使IP地址的分配更加合理。 (2)采用网络地址转换NAT方法,可节省许多全球IP地址。 (3)采用具有更大地址空…

02-微服务-Eureka注册中心

Eureka注册中心 假如我们的服务提供者user-service部署了多个实例,如图: 大家思考几个问题: order-service在发起远程调用的时候,该如何得知user-service实例的ip地址和端口?有多个user-service实例地址,…

用开源大语言模型开发的智能对话机器人初版原型验证

用开源大语言模型开发的智能对话机器人初版原型验证 0. 背景1. 初版检证效果展示2. 验证效果总结 0. 背景 同事要想做一个智能对话机器人,特别的需求有有些几点, 通过预置提示词(包括确认事项),让大语言模型用会话式…

【Linux Shell】4. 数组

文章目录 【 1. 数组的定义 】【 2. 读取数组 】【 3. 关联数组 】【 4. 获取数组中的所有元素 】【 5. 获取数组的长度 】 数组中可以存放多个值。 Bash Shell 只支持一维数组(不支持多维数组),初始化时不需要定义数组大小。与大部分编程语言…

对话惠买集团董事长兼CEO杜瑞勇:直播电商粗放时代结束,如何用AI+XR打造精细化的智慧直播生态?

“ 未来将是专业选手精细化运营的智慧直播时代。“ 整理 | 梦婕 编辑 | 渔舟 出品|极新&北京电子商务协会 直播电商在经过爆发式增长后,从业者不断涌入,竞争日趋激烈,行业发展必然将会进入到一个缓慢增长阶段。直播…

Azure Machine Learning - 人脸识别任务概述与技术实战

Azure AI 人脸服务提供了可检测、识别和分析图像中的人脸的 AI 算法。 人脸识别软件在许多不同情形中都十分重要,例如识别、无接触访问控制和实现隐私的人脸模糊。你可以通过客户端库 SDK,或者直接调用 REST API 使用人脸服务。 目录 一、人脸识别服务场…

test 系统学习-05-test jacoco 测试覆盖率与 idea 插件

1. idea 中使用 maven jmockit,如何查看增量的代码覆盖率 在使用 Maven 和 JMockit 进行单元测试时,你可以结合使用 JaCoCo 插件来查看增量的代码覆盖率报告。 JaCoCo 是一个流行的代码覆盖率工具,它与 Maven 集成良好,并且可以…