Toggle navigation
首页
问答
文章
积分商城
专家
专区
更多专区...
文档中心
返回主站
搜索
提问
会员
中心
登录
注册
bug
rt_event_事件集
set
rt_event_recv bug
发布于 2020-12-01 16:31:12 浏览:1471
订阅该版
rt_event_recv 源码中 为了不出现重复代码,逻辑写的有些复杂,可以优化,用goto 或许会更清晰一些 ,或者适量的重复代码也可以让代码的阅读性更好。 比如能正常接收时直接处理返回。而不是用if else 拖到最后。 ``` rt_err_t rt_event_recv(rt_event_t event,rt_uint32_t set,rt_uint8_t option,rt_int32_t timeout,rt_uint32_t *recved) { struct rt_thread *thread; register rt_ubase_t level; register rt_base_t status; RT_DEBUG_IN_THREAD_CONTEXT; /* parameter check */ RT_ASSERT(event != RT_NULL); RT_ASSERT(rt_object_get_type(&event->parent.parent) == RT_Object_Class_Event); if (set == 0) return -RT_ERROR; /* initialize status */ status = -RT_ERROR; /* get current thread */ thread = rt_thread_self(); /* reset thread error */ thread->error = RT_EOK; RT_OBJECT_HOOK_CALL(rt_object_trytake_hook, (&(event->parent.parent))); /* disable interrupt */ level = rt_hw_interrupt_disable(); /* check event set */ /*判断触发模式*/ if (option & RT_EVENT_FLAG_AND){ /*判断事件触发条件是否满足或者大于 获取的逻辑与的要求 */ if ((event->set & set) == set) status = RT_EOK; } else if (option & RT_EVENT_FLAG_OR){ /*判断事件触发条件是否满足获取要求某一个条件 */ if (event->set & set) status = RT_EOK; } else{ /* either RT_EVENT_FLAG_AND or RT_EVENT_FLAG_OR should be set */ RT_ASSERT(0); } /*达到触发条件*/ if (status == RT_EOK) { /* set received event */ /*设置接受到的事件条件*/ if (recved) *recved = (event->set & set); /* received event */ /*如果条件触发是一次性的则将此条件清除*/ if (option & RT_EVENT_FLAG_CLEAR) event->set &= ~set; } else if (timeout == 0) /*未达到触发条件,且 不等待*/ { /* no waiting */ thread->error = -RT_ETIMEOUT; } else /*未达到触发条件,但是超时等待*/ { /* fill thread event info */ thread->event_set = set; thread->event_info = option; /* put thread to suspended thread list */ /*未达到触发条件 ,且设置超时等待,则将线程挂入事件等待链表,然后设置并启动线程定时器*/ rt_ipc_list_suspend(&(event->parent.suspend_thread), thread, event->parent.parent.flag); /* if there is a waiting timeout, active thread timer */ if (timeout > 0) { /* reset the timeout of thread timer and start it */ rt_timer_control(&(thread->thread_timer), RT_TIMER_CTRL_SET_TIME, &timeout); rt_timer_start(&(thread->thread_timer)); } /* enable interrupt */ rt_hw_interrupt_enable(level); /* do a schedule */ /*线程进入等待,切换任务,此处会挂起*/ rt_schedule(); if (thread->error != RT_EOK) { /* return error */ return thread->error; } /* received an event, disable interrupt to protect */ level = rt_hw_interrupt_disable(); /* set received event */ if (recved) *recved = thread->event_set; } /* enable interrupt */ rt_hw_interrupt_enable(level); RT_OBJECT_HOOK_CALL(rt_object_take_hook, (&(event->parent.parent))); return thread->error; } RTM_EXPORT(rt_event_recv); ``` 修改成这样是否会更好? ``` rt_err_t rt_event_recv(rt_event_t event,rt_uint32_t set,rt_uint8_t option, rt_int32_t timeout,rt_uint32_t *recved) { struct rt_thread *thread; register rt_ubase_t level; register rt_base_t status; RT_DEBUG_IN_THREAD_CONTEXT; /* parameter check */ RT_ASSERT(event != RT_NULL); RT_ASSERT(rt_object_get_type(&event->parent.parent) == RT_Object_Class_Event); if (set == 0) return -RT_ERROR; /* initialize status */ status = -RT_ERROR; /* get current thread */ thread = rt_thread_self(); /* reset thread error */ thread->error = RT_EOK; RT_OBJECT_HOOK_CALL(rt_object_trytake_hook, (&(event->parent.parent))); /* disable interrupt */ level = rt_hw_interrupt_disable(); /* check event set */ /*判断触发模式*/ if ((option & RT_EVENT_FLAG_AND) && ((event->set & set) == set) || /*判断事件触发条件是否满足获取要求某一个条件 */ (option & RT_EVENT_FLAG_OR) && (event->set & set)) /*判断事件触发条件是否满足或者大于 获取的逻辑与的要求 */ status = RT_EOK; else RT_ASSERT(0); /* either RT_EVENT_FLAG_AND or RT_EVENT_FLAG_OR should be set */ /*达到触发条件*/ if (status == RT_EOK){ thread->event_set = (event->set & set); goto _EXIT_OK; } if (timeout == 0) /*未达到触发条件,且 不等待*/ { /* no waiting */ thread->error = -RT_ETIMEOUT; goto _EXIT_ERR; } /*未达到触发条件,但是超时等待*/ /* fill thread event info */ thread->event_set = set; thread->event_info = option; /* put thread to suspended thread list */ /*未达到触发条件 ,且设置超时等待,则将线程挂入事件等待链表,然后设置并启动线程定时器*/ rt_ipc_list_suspend(&(event->parent.suspend_thread), thread, event->parent.parent.flag); /* if there is a waiting timeout, active thread timer */ /*这个地方 难道timeout 不是一定大于0 吗?*/ if (timeout > 0) { /* reset the timeout of thread timer and start it */ rt_timer_control(&(thread->thread_timer), RT_TIMER_CTRL_SET_TIME, &timeout); rt_timer_start(&(thread->thread_timer)); } /* enable interrupt */ rt_hw_interrupt_enable(level); /* do a schedule */ /*线程进入等待,切换任务,此处会挂起*/ rt_schedule(); //此处为什么要判断这个 ,不是很明白 if (thread->error != RT_EOK) { /* return error */ return thread->error; } /* received an event, disable interrupt to protect */ level = rt_hw_interrupt_disable(); _EXIT_OK: /*设置接受到的事件条件*/ if (recved) *recved = (event->set & set); /* received event */ /*如果条件触发是一次性的则将此条件清除*/ if (option & RT_EVENT_FLAG_CLEAR) event->set &= ~set; _EXIT_ERR: rt_hw_interrupt_enable(level); RT_OBJECT_HOOK_CALL(rt_object_take_hook, (&(event->parent.parent))); return thread->error; } ```
查看更多
1
个回答
默认排序
按发布时间排序
mysterywolf
认证专家
2020-12-01
https://github.com/mysterywolf
c语言中,goto要慎用。尤其是这段代码已经经过10多年的检验,不可能无缘无故重新换成一种高风险的写法。 后续RTT会进行一些安全类的认证,例如MISRA2004 2012中都禁止使用goto语法。 另外问一下这个函数发现什么bug了吗?
撰写答案
登录
注册新账号
关注者
0
被浏览
1.5k
关于作者
楼兰听雨
这家伙很懒,什么也没写!
提问
9
回答
3
被采纳
1
关注TA
发私信
相关问题
1
rt_thread事件某位如何置0,如何简单获取某位状态
2
有单独清除事件标志的函数么?
3
rt_event事件问题
4
事件集的选择清除重置事件标志位
5
Nano 内核FinSH 的 list_event 查询问题
6
Nano 初始化两次 event,使用list_event 导致的问题
7
关于事件集和邮箱那一块
8
rt-thread事件集多线程接收的一个疑问?
9
事件集在中断服务函数与线程之间的同步的疑问
10
生产者消费者中是否可以使用一个事件集来代替多个二值信号量?
推荐文章
1
RT-Thread应用项目汇总
2
玩转RT-Thread系列教程
3
机器人操作系统 (ROS2) 和 RT-Thread 通信
4
五分钟玩转RT-Thread新社区
5
国产MCU移植系列教程汇总,欢迎查看!
6
【技术三千问】之《玩转ART-Pi》,看这篇就够了!干货汇总
7
关于STM32H7开发板上使用SDIO接口驱动SD卡挂载文件系统的问题总结
8
STM32的“GPU”——DMA2D实例详解
9
RT-Thread隐藏的宝藏之completion
10
【ART-PI】RT-Thread 开启RTC 与 Alarm组件
最新文章
1
RyanMqtt 移植指南(三)
2
RyanMqtt QOS质量测试(二)
3
WCH APT 零等待FLASH的思考
4
RyanMqtt使用介绍和示例代码(一)
5
RTT平台 zephyr_polling软件包 Bluenrg2 蓝牙芯片启动流程
热门标签
RT-Thread Studio
串口
Env
LWIP
AT
SPI
Bootloader
FinSH
ART-Pi
CAN总线
Hardfault
USB
文件系统
DMA
RT-Thread
SCons
线程
RT-Thread Nano
MQTT
stm32
ESP8266
rt-smart
WIZnet_W5500
RTC
flash
ota
UART
FAL
packages_软件包
I2C
freemodbus
cubemx
潘多拉开发板_Pandora
定时器
BSP
PWM
ADC
socket
AB32VG1
SDIO
keil_MDK
中断
消息队列_msg_queue
编译报错
Debug
C++_cpp
msh
QEMU
SFUD
MicroPython
本月问答贡献
张世争
19
个答案
4
次被采纳
道友
41
个答案
3
次被采纳
CrazyH
52
个答案
2
次被采纳
踩姑娘的小蘑菇
15
个答案
2
次被采纳
xiaorui
8
个答案
2
次被采纳
本月文章贡献
paradox
5
篇文章
4
次点赞
螺丝松掉的人
4
篇文章
12
次点赞
Ryan_CW
3
篇文章
5
次点赞
子牧r
3
篇文章
2
次点赞
牧尘
2
篇文章
6
次点赞
回到
顶部
发布
问题
分享
好友
手机
浏览
扫码手机浏览
投诉
建议
回到
底部