Worker thread wake test protected by rtl_no_interrupts.

diff --git a/lincan/src/can_devrtl.c b/lincan/src/can_devrtl.c
index 052090264e405f7f8d0c8f8740256adc7cbd53a4..ad6d6c206327050092c492b64547d98b1fbd033d 100644 (file)
--- a/lincan/src/can_devrtl.c
+++ b/lincan/src/can_devrtl.c
@@ -95,6 +95,7 @@ void * can_chip_worker_thread(void *arg)
        struct msgobj_t *obj;
        int ret, i;
        int loop_cnt;
        struct msgobj_t *obj;
        int ret, i;
        int loop_cnt;

+       rtl_irqstate_t flags;

        
        if(!chip) return 0;
        
        
        if(!chip) return 0;
        


@@ -161,11 +162,14 @@ void * can_chip_worker_thread(void *arg)
 
                }
 
 
                }
 

+                rtl_no_interrupts (flags);

                RTL_MARK_SUSPENDED(pthread_self());
                if(test_and_clear_bit(MSGOBJ_WORKER_WAKE_b,&chip->pend_flags)){
                        RTL_MARK_READY(pthread_self());
                RTL_MARK_SUSPENDED(pthread_self());
                if(test_and_clear_bit(MSGOBJ_WORKER_WAKE_b,&chip->pend_flags)){
                        RTL_MARK_READY(pthread_self());

+                        rtl_restore_interrupts (flags);

                        continue;
                }
                        continue;
                }

+                rtl_restore_interrupts (flags);

                rtl_schedule();
 
        }
                rtl_schedule();
 
        }