PX4的UORB通信机制

2024-08-31 00:08
文章标签 通信 机制 px4 uorb

本文主要是介绍PX4的UORB通信机制,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在Firmware的msg文件夹里面,里面有很多.msg结尾的文件,这些msg文件在编译的时候可以生成h头文件,这些编译过程中生成的头文件一般是保存在build_default/src/module/uorb/topics。

添加msg文件的时候,首先把写好的msg文件放在msg文件夹里面,然后还有一个需要修改的就是cmakelist这个文件,要在这个文件里面把你的msg文件的名字加进去。

在写msg文件的时候注意不能用int,msg里面是没有int的,都是用uint16,uint8这种,曾经写了个int  i,这样生成的H头文件就是不对,就是int的问题。

老的PX4里面是没有这个cmakelist的。这个时候就是要在ORB_DEFINE里面手动添加上,详细的见下面2,

1.ORB_DECLARE在由msg文件生成的h头文件里面的最后一行会有一个ORB_DECLARE(status_led);这里的status_led就是tpoic的名字,这里的名字就是你在使用uorb的时候,比如说advertise函数的时候,ORB_ID后面括号里面的主题的名字。

2.ORB_DEFINE然后在objects_common.cpp通过ORB_DEFINE将主题的名字和结构体的定义关联起来。然后在发布或者copy的时候就要用ORB_DEFINE里面和主题关联起来的结构体,不能是把自己随便定义的一个结构体。(对于msg文件夹里面又cmakelist的情况,就不用手动的在objects_common里面手动的进行添加了)

3.发布端:然后接下来就是在发布的程序里面,首先需要定义结构体,例如:struct  esc_up-s  new_report;然后还需要定义主题句柄用来接收orb_advertise的返回值,例如:orb_advert_t  _esc_up_topic;注意orb_advertise函数的返回值是orb_advert_t类型的,而不是int型的。然后还需要定义主题ID用来作为函数orb-advertise的参数,例如orb_id_t        _esc_up_orb_id,这样定义的话在使用之前还需要用_esc_up_orb_id = ORB_ID(esc_up);进行赋值,然后就可以进行订阅和发布了,或者不用定义主题的ID,直接在公告的时候用,_esc_up_topic = orb_advertise(ORB_ID(esc_up), &new_report);这样就剩了一步了,然后就是进行公告和发布了。

          if (_esc_up_topic != nullptr) //NULL  in  cnullptr  in  c++

               {

                     orb_publish(_esc_up_orb_id, _esc_up_topic, &new_report);

            }

               else 

               {

                     _esc_up_topic = orb_advertise(_esc_up_orb_id, &new_report);

              if (_esc_up_topic == nullptr)

                     {

                          errx(1, "ADVERT FAIL");

                     }

                 }

4.接收端:然后就是在接收端了,接收端首先也是需要定义结构体用来保存接收到的值,例如:struct  esc_up_s  esc_up;然后也是需要定义一个用来接收主题句柄的变量,订阅函数subscribe的返回值不是orb_advert_t类型的,而是整型的,例如int _esc_up_orb_sub;然后就是进行订阅、check和copy了。

_esc_up_orb_sub = orb_subscribe(ORB_ID(esc_up));

         bool  updated;

         orb_check(_esc_up_orb_sub, &updated);

          if (updated)

         {

               orb_copy(ORB_ID(esc_up), _esc_up_orb_sub, & esc_up);

           }

在订阅的时候要注意,对于同一个topic,只订阅一次,要是多次订阅的话,那么你会发现,第一次订阅返回值是1,第二次订阅的返回值是2,第三次订阅的返回值是3,这样你下面check的时候永远不会更新,因为每次都是不同的主题了,又一次就是犯了这样的错误,注意,在订阅的时候可以用

If(0 == led_fd)

{

led_fd = orb_subscribe(ORB_ID(status_led))

}但是记住,led_fd定义之后要初始化为零,要不然不会进入这个if里面。

 

另外关于公告函数的返回值是orb_advert_t,订阅函数的返回值是int。这种问题不用问,直接自己看一下函数的返回值就可以了。

Uorb的时候,如果你订阅是在创建task之前,然后在taskmain里面进行check和copy,那么也是不成功的,理解为在一个线程中订阅的在另一个线程中不能使用吧。

 

这篇关于PX4的UORB通信机制的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1122324

相关文章

基于Redis自动过期的流处理暂停机制

《基于Redis自动过期的流处理暂停机制》基于Redis自动过期的流处理暂停机制是一种高效、可靠且易于实现的解决方案,防止延时过大的数据影响实时处理自动恢复处理,以避免积压的数据影响实时性,下面就来详... 目录核心思路代码实现1. 初始化Redis连接和键前缀2. 接收数据时检查暂停状态3. 检测到延时过

Redis中哨兵机制和集群的区别及说明

《Redis中哨兵机制和集群的区别及说明》Redis哨兵通过主从复制实现高可用,适用于中小规模数据;集群采用分布式分片,支持动态扩展,适合大规模数据,哨兵管理简单但扩展性弱,集群性能更强但架构复杂,根... 目录一、架构设计与节点角色1. 哨兵机制(Sentinel)2. 集群(Cluster)二、数据分片

深入理解go中interface机制

《深入理解go中interface机制》本文主要介绍了深入理解go中interface机制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前言interface使用类型判断总结前言go的interface是一组method的集合,不

C# async await 异步编程实现机制详解

《C#asyncawait异步编程实现机制详解》async/await是C#5.0引入的语法糖,它基于**状态机(StateMachine)**模式实现,将异步方法转换为编译器生成的状态机类,本... 目录一、async/await 异步编程实现机制1.1 核心概念1.2 编译器转换过程1.3 关键组件解析

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

Spring Security 单点登录与自动登录机制的实现原理

《SpringSecurity单点登录与自动登录机制的实现原理》本文探讨SpringSecurity实现单点登录(SSO)与自动登录机制,涵盖JWT跨系统认证、RememberMe持久化Token... 目录一、核心概念解析1.1 单点登录(SSO)1.2 自动登录(Remember Me)二、代码分析三、

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

Spring Boot 中的默认异常处理机制及执行流程

《SpringBoot中的默认异常处理机制及执行流程》SpringBoot内置BasicErrorController,自动处理异常并生成HTML/JSON响应,支持自定义错误路径、配置及扩展,如... 目录Spring Boot 异常处理机制详解默认错误页面功能自动异常转换机制错误属性配置选项默认错误处理

Java中的xxl-job调度器线程池工作机制

《Java中的xxl-job调度器线程池工作机制》xxl-job通过快慢线程池分离短时与长时任务,动态降级超时任务至慢池,结合异步触发和资源隔离机制,提升高频调度的性能与稳定性,支撑高并发场景下的可靠... 目录⚙️ 一、调度器线程池的核心设计 二、线程池的工作流程 三、线程池配置参数与优化 四、总结:线程

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho