libs/rt-thread
libs
/
rt-thread
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

error check of rt_event_recv() 

add error check
This commit is contained in:
Han Xinrong 2020-12-07 20:13:03 +08:00
parent 3f122bd790
commit 3bb8edf4c1
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bsp/nrf5x/libraries/templates/nrf52x/applications/ble_nus_app.c
View File

@ -599,9 +599,11 @@ static void _stack_thread(void *parameter)
{ {
rt_uint32_t event = 0; rt_uint32_t event = 0;
rt_tick_t dispatch_timeout = RT_WAITING_NO; rt_tick_t dispatch_timeout = RT_WAITING_NO;
rt_err_t result;
rt_event_recv(stack_event, STACK_EV_DISCON | STACK_EV_DISPATCH | STACK_EV_KEY, result = rt_event_recv(stack_event, STACK_EV_DISCON | STACK_EV_DISPATCH | STACK_EV_KEY,
RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR, next_timeout, &event); RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR, next_timeout, &event);
RT_ASSERT(result == RT_EOK);
if (evt_dispatch_worker() != RT_EOK) if (evt_dispatch_worker() != RT_EOK)
{ {

10
components/dfs/filesystems/jffs2/src/gcthread.c
View File

@ -187,7 +187,8 @@ jffs2_stop_garbage_collect_thread(struct jffs2_sb_info *c)
{ {
struct super_block *sb=OFNI_BS_2SFFJ(c); struct super_block *sb=OFNI_BS_2SFFJ(c);
cyg_mtab_entry *mte; cyg_mtab_entry *mte;
rt_uint32_t e; rt_uint32_t e;
rt_err_t result;
//RT_ASSERT(sb->s_gc_thread_handle); //RT_ASSERT(sb->s_gc_thread_handle);
@ -198,10 +199,11 @@ jffs2_stop_garbage_collect_thread(struct jffs2_sb_info *c)
D1(printk("jffs2_stop_garbage_collect_thread wait\n")); D1(printk("jffs2_stop_garbage_collect_thread wait\n"));
rt_event_recv(&sb->s_gc_thread_flags, result = rt_event_recv(&sb->s_gc_thread_flags,
GC_THREAD_FLAG_HAS_EXIT, GC_THREAD_FLAG_HAS_EXIT,
RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR, RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
RT_WAITING_FOREVER, &e); RT_WAITING_FOREVER, &e);
RT_ASSERT(result == RT_EOK);
// Kill and free the resources ... this is safe due to the flag // Kill and free the resources ... this is safe due to the flag
// from the thread. // from the thread.
@ -218,15 +220,17 @@ jffs2_garbage_collect_thread(unsigned long data)
struct super_block *sb=OFNI_BS_2SFFJ(c); struct super_block *sb=OFNI_BS_2SFFJ(c);
cyg_mtab_entry *mte; cyg_mtab_entry *mte;
rt_uint32_t flag = 0; rt_uint32_t flag = 0;
rt_err_t result;
D1(printk("jffs2_garbage_collect_thread START\n")); D1(printk("jffs2_garbage_collect_thread START\n"));
while(1) { while(1) {
rt_event_recv(&sb->s_gc_thread_flags, result = rt_event_recv(&sb->s_gc_thread_flags,
GC_THREAD_FLAG_TRIG | GC_THREAD_FLAG_STOP, GC_THREAD_FLAG_TRIG | GC_THREAD_FLAG_STOP,
RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR, RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
cyg_current_time() + CYGNUM_JFFS2_GS_THREAD_TICKS, cyg_current_time() + CYGNUM_JFFS2_GS_THREAD_TICKS,
&flag); &flag);
RT_ASSERT(result == RT_EOK);
if (flag & GC_THREAD_FLAG_STOP) if (flag & GC_THREAD_FLAG_STOP)
break; break;