Re: [Xenomai-help] RT_QUEUE problem in Sender/Receiver order

[Philippe Gerum <rpm@xenomai.org>]

On Tue, 2010-04-20 at 00:46 -0400, Josh Bowman wrote:
> Hi,
> 
> I'm reluctant to jump in here with my own notably limited psychic
> powers, but I did notice that the code given spawns the receiving
> tasks before it creates the queues that they receive from.  This would
> create a race condition (if a STD_PRIO task can preempt the task
> that's doing the initialization.)
> 

You are likely right, priority issues are usually involved in that
scenario, particularly since the initiator of all those creation calls
is the low-priority root thread.

> -Josh
> 
> On Mon, Apr 19, 2010 at 1:16 PM, Philippe Gerum <rpm@xenomai.org>
> wrote:
>         On Mon, 2010-04-19 at 19:01 +0200, Michel He wrote:
>         
>         >
>         >       err = rt_task_spawn(&test_task2_ptr, "Recep2",
>         STACK_SIZE, STD_PRIO,
>         > 0, &testtask2, NULL);
>         >       if (err) {
>         >               rt_printf("error rt_task_spawn 2\n");
>         >               return 0;
>         >       }
>         >       recvTask[nrecvhost]=&test_task2_ptr;
>         >
>         >       err =
>         >
>         rt_queue_create(&(recvCanal[nrecvhost]),"Recep2CANAL",MAX_MESSAGE_LENGTH,
>         > QUEUE_LIM, Q_FIFO);
>         >
>         >       if (err) {
>         >               rt_printf("error RT_canal_create 2 \n");
>         >               return 0;
>         >       }
>         >       nrecvhost++;
>         >
>         >
>         >       err = rt_task_spawn(&test_task3_ptr, "Recep3",
>         STACK_SIZE, STD_PRIO,
>         > 0, &testtask3, NULL);
>         >       if (err) {
>         >               rt_printf("error rt_task_spawn 3\n");
>         >               return 0;
>         >       }
>         >       recvTask[nrecvhost]=&test_task3_ptr;
>         >
>         >       err =
>         >
>         rt_queue_create(&(recvCanal[nrecvhost]),"Recep3CANAL",MAX_MESSAGE_LENGTH,
>         > QUEUE_LIM, Q_FIFO);
>         >
>         >       if (err) {
>         >               rt_printf("error RT_canal_create 2 \n");
>         >               return 0;
>         >
>         >       }
>         >       nrecvhost++;
>         >
>         >
>         >       err = rt_task_spawn(&test_task_ptr, "Sender",
>         STACK_SIZE, STD_PRIO,
>         > 0, &testtask, NULL);
>         >       if (err) {
>         >               rt_printf("error rt_task_spawn\n");
>         >               return 0;
>         >       }
>         >       recvTask[nrecvhost]=&test_task_ptr;
>         >       nrecvhost++;
>         >
>         >
>         >
>         > testtask2()
>         > {
>         > ...
>         >
>         rcbytes=RT_queue_read(&(recvCanal[0]),&rcvmsg,sizeof(rcvmsg),TM_INFINITE);
>         > }
>         >
>         >
>         > testtask3()
>         > {
>         > ...
>         >
>         rcbytes=RT_queue_read(&(recvCanal[1]),&rcvmsg,sizeof(rcvmsg),TM_INFINITE);
>         > }
>         >
>         
> 


-- 
Philippe.