【FreeRTOS（十五）】MessageBuffer

MessageBuffer

创建 xMessageBufferCreate

MessageBufferHandle_t xMessageBufferCreate( size_t xBufferSizeBytes );

参数：
	xBufferSizeBytes :buffer的最大容量，buffer占用的空间为xBufferSizeBytes+4.4字节uint32存放实际buff有效数据的长度

返回值：
	NULL：创建失败，一般是堆空间不够

发送 xMessageBufferSend

size_t xMessageBufferSend( MessageBufferHandle_t xMessageBuffer,
							const void *pvTxData,
							size_t xDataLengthBytes,
							TickType_t xTicksToWait );

参数：
	xMessageBuffer:句柄
	pvTxData：发送消息的指针
	xDataLengthBytes：发送消息的长度
	xTicksToWait ：buffer满了等待时间

返回值：
	实际写入buffer的数量，如果messagebuff没有足够的长度存储pvTxData，则返回值将会是0

接收 xMessageBufferReceive

size_t xMessageBufferReceive( MessageBufferHandle_t xMessageBuffer,
								void *pvRxData,
								size_t xBufferLengthBytes,
								TickType_t xTicksToWait );

参数：
	xMessageBuffer:句柄
	pvTxData：接收消息的指针
	xDataLengthBytes：接收buffer的长度，如果长度小于messge的长度，返回值为0
	xTicksToWait ：等待接收时间

返回值：
	读取到的长度，如果message超过接收buff的长度，返回值将会是0，消息仍然存在消息buffer中。如果message buffer 空，接收超过了xTicksToWait时间，则返回的也是0.

代码示例

#include <stdio.h>
#include <string.h>
#include "sdkconfig.h"
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "esp_system.h"
#include "esp_spi_flash.h"
#include "freertos/message_buffer.h"


MessageBufferHandle_t MessageBufferHandle = NULL;

void Task1(void *pvParam)
{
    int i = 0;
    int str_len = 0;
    int send_bytes = 0;
    char tx_buf[50];

    for(int i = 0; i < 3; i++)
    {
        i++;
        str_len = sprintf(tx_buf, "i = %d", i);

        send_bytes = xMessageBufferSend(MessageBufferHandle, (void *)tx_buf, str_len, portMAX_DELAY);

        printf("----------------!\n");
        printf("send: str_len = %d, send_bytes = %d!\n",str_len, send_bytes);
    }

	vTaskDelete(NULL);
}

void Task2(void *pvParam)
{
    char rx_buf[200];
    int rec_bytes = 0;
	
	vTaskDelay(pdMS_TO_TICKS(3000));
    
    while (1)
    {
        memset(rx_buf, 0, sizeof(rx_buf));

        rec_bytes = xMessageBufferReceive(MessageBufferHandle, (void *)rx_buf, sizeof(rx_buf), portMAX_DELAY);

        printf("----------------!\n");
        printf("receive: rec_bytes = %d, data { %s }!\n",rec_bytes, rx_buf);
        vTaskDelay(pdMS_TO_TICKS(1000));
    }
}

void app_main(void)
{
    MessageBufferHandle = xMessageBufferCreate(1000);

    if (MessageBufferHandle != NULL)
    {
        vTaskSuspendAll();

        xTaskCreate(Task1, "Task1", 1024 * 5, NULL, 1, NULL);
        xTaskCreate(Task2, "Task2", 1024 * 5, NULL, 1, NULL);

        xTaskResumeAll();
    }
    else
    {
        printf("Fail to create messagebuffer!\n");
    }
}