AIO Message Queue Examples

The AIO message queue library works around opening a message queue with a specific name whose incoming traffic is then handled by the handler function specified. Sending to the message queue is simple through the use of the queue's name. More...

Functions
int	xCreateMessageQueueTasks (void)
	Creates the demo message queue task found in async_message_queues.c. More...
void	vDeleteMessageQueueTasks (void)
	Deletes the demo message queue task found in async_message_queues.c. More...

Variables
const char *	mq_one_name
const char *	mq_two_name
aIO_handle_t	mq_one
aIO_handle_t	mq_two
TaskHandle_t	MQDemoTask

Detailed Description

The AIO message queue library works around opening a message queue with a specific name whose incoming traffic is then handled by the handler function specified. Sending to the message queue is simple through the use of the queue's name.

Opening a queue

void vMQDemoTask(void *pvParameters)
{
    mq_one = aIOOpenMessageQueue(mq_one_name, MSG_QUEUE_MAX_MSG_COUNT,
                                MSG_QUEUE_BUFFER_SIZE, MQHandlerOne, NULL);
    mq_two = aIOOpenMessageQueue(mq_two_name, MSG_QUEUE_MAX_MSG_COUNT,
                                MSG_QUEUE_BUFFER_SIZE, MQHanderTwo, NULL);
 
    while (1)
 
    {
        vTaskDelay(pdMS_TO_TICKS(1000));
    }
}

Message handler

void MQHandlerOne(size_t read_size, char *buffer, void *args)
{
    prints("MQ Recv in first handler: %s\n", buffer);
}
 
void MQHanderTwo(size_t read_size, char *buffer, void *args)
{
    prints("MQ Recv in second handler: %s\n", buffer);
}

Putting to message queue

if (mq_one) {
    aIOMessageQueuePut(mq_one_name, "Hello MQ one");
}
if (mq_two) {
    aIOMessageQueuePut(mq_two_name, "Hello MQ two");
}

Function Documentation

vDeleteMessageQueueTasks()

void vDeleteMessageQueueTasks

(

void

)

Deletes the demo message queue task found in async_message_queues.c.

xCreateMessageQueueTasks()

int xCreateMessageQueueTasks

(

void

)

Creates the demo message queue task found in async_message_queues.c.

Returns

0 on success

Variable Documentation

mq_one

aIO_handle_t mq_one

extern

mq_one_name

const char* mq_one_name

extern

mq_two

aIO_handle_t mq_two

extern

mq_two_name

const char* mq_two_name

extern

MQDemoTask

TaskHandle_t MQDemoTask

extern