os_msgqueue.h File Reference

#include "os_defines.h"

Go to the source code of this file.

Data Structures
struct	Msg_t

Macros
#define	OS_MSG_Q_POST(task, msg, delay, period, async)
#define	OS_MSG_Q_RECEIVE(task, pMsg, async)

Typedefs
typedef uint8_t	MsgQ_t

Enumerations
enum	{   MSG_QUEUE_UNDEF, MSG_QUEUE_DEF, MSG_QUEUE_EMPTY, MSG_QUEUE_FULL,   MSG_QUEUE_RECEIVED, MSG_QUEUE_POSTED }

Functions
void	os_msgQ_init ()
MsgQ_t	os_msgQ_create (Msg_t *buffer, uint8_t nMessages, uint16_t msgSize, taskproctype taskproc)
MsgQ_t	os_msgQ_find (taskproctype taskproc)
Evt_t	os_msgQ_event_get (MsgQ_t queue)
void	os_msgQ_tick (MsgQ_t queue)
uint8_t	os_msg_post (Msg_t *msg, MsgQ_t queue, uint16_t delay, uint16_t period)
uint8_t	os_msg_receive (Msg_t *msg, MsgQ_t queue)

Detailed Description

Message queue header file

Macro Definition Documentation

#define OS_MSG_Q_POST	(		task,
			msg,
			delay,
			period,
			async
	)

Value:

do {\
                                                                static uint8_t os_posted;\
                                                                static MsgQ_t queue;\
                                                                static Evt_t event;\
                                                                queue = os_msgQ_find( task );\
                                                                event = os_msgQ_event_get( queue );\
                                                                do {\
                                                                    os_posted = os_msg_post( (Msg_t*)&msg, queue, delay, period );\
                                                                    if ( os_posted == MSG_QUEUE_FULL ){\
                                                                        if ( async == 0 ) {\
                                                                            event_wait(event);\
                                                                        }\
                                                                        else {\
                                                                            os_posted = MSG_QUEUE_UNDEF;\
                                                                        }\
                                                                    }\
                                                                } while ( os_posted == MSG_QUEUE_FULL );\
                                                                if ( MSG_QUEUE_POSTED == os_posted ) {\
                                                                    os_signal_event(event);\
                                                                    os_event_set_signaling_tid( event, running_tid );\
                                                                }\
                                                            } while(0)

#define OS_MSG_Q_RECEIVE	(		task,
			pMsg,
			async
	)

Value:

do {\
                                                    static MsgQ_t queue;\
                                                    static uint8_t os_received;\
                                                    static Evt_t event;\
                                                    queue = os_msgQ_find( task );\
                                                    event = os_msgQ_event_get( queue );\
                                                    do {\
                                                        os_received = os_msg_receive( (Msg_t*)pMsg, queue );\
                                                        if ( os_received == MSG_QUEUE_EMPTY ){\
                                                            if ( async == 0 ) {\
                                                                event_wait(event);\
                                                            }\
                                                            else {\
                                                                ((Msg_t*)pMsg)->signal = NO_MSG_ID;\
                                                                os_received = MSG_QUEUE_UNDEF;\
                                                            }\
                                                        }\
                                                    } while ( os_received == MSG_QUEUE_EMPTY );\
                                                    if ( MSG_QUEUE_RECEIVED == os_received) {\
                                                        os_signal_event(event);\
                                                        os_event_set_signaling_tid(event, running_tid );\
                                                    }\
                                                } while(0)