M4和M7双核之间消息通信

今天我想和大家分享一种使用FreeRTOS消息缓冲区实现简单非对称多处理（AMP）核心到核心通信的方法，以STM32H7双核处理器为例。

在这个方案中，我们利用FreeRTOS官方提供的消息缓冲区功能来实现双核之间的通信。这个消息缓冲区是一个无锁循环缓冲区，能够将大小不同的数据包从一个发送方传递到一个接收方。

需要说明的是，这个消息缓冲区只提供数据的传输功能，不涉及通信相关的协议处理。

基本原理

实现双核之间通信基本原理：发送和接收任务位于非对称多处理器（AMP）配置中的多核微控制器（MCU）的不同内核上，这意味着每个内核都运行自己的FreeRTOS程序。

同时，一个内核在另一个内核中具有生成中断的能力，以及两个内核都有访问的内存区域（共享内存）。消息缓冲区以每个内核上运行在应用程序已知的地址置在共享内存中，如下图：

理想情况下，还将有一个内存保护单元（MPU），以确保只能通过内核的消息缓冲区API来访问消息缓冲区，并最好将共享内存标记为不可被其他程序占用。

单消息代码描述

这里官方提供了实现该方案的基础代码（仅供参考）。

将数据发送到流缓冲区的代码：

xMessageBufferSend()
{
    /* If a time out is specified and there isn't enough
    space in the message buffer to send the data, then
    enter the blocked state to wait for more space. */
    if( time out != 0 )
    {
        while( there is insufficient space in the buffer &&
               not timed out waiting )
        {
            Enter the blocked state to wait for space in the buffer
        }
    }

    if( there is enough space in the buffer )
    {
        write data to buffer
        sbSEND_COMPLETED()
    }
}

从流缓冲区读取数据的代码：

xMessageBufferReceive()
{
    /* If a time out is specified and the buffer doesn't
    contain any data that can be read, then enter the
    blocked state to wait for the buffer to contain data. */
    if( time out != 0 )
    {
        while( there is no data in the buffer &&
               not timed out waiting )
        {
            Enter the blocked state to wait for data
        }
    }

    if( there is data in the buffer )
    {
        read data from buffer
        sbRECEIVE_COMPLETED()
    }
}

如果任务在xMessageBufferReceive()中进入阻塞状态以等待缓冲区包含数据，则将数据发送到缓冲区必须取消阻塞该任务，以便它可以完成其操作。

当xMessageBufferSend()调用sbSEND_COMPLETED()时，任务将不受阻碍。

ISR通过将消息缓冲区的句柄作为参数传递给xMessageBufferSendCompletedFromISR()函数来解除对任务的阻塞。

如图箭头所示，其中发送和接收任务位于不同的MCU内核上：

**1.**接收任务尝试从空的消息缓冲区中读取数据，并进入阻止状态以等待数据到达。

**2.**发送任务将数据写入消息缓冲区。

**3.**sbSEND_COMPLETED（）在正在执行接收任务的内核中触发一个中断。

**4.**中断服务例程调用xMessageBufferSendCompletedFromISR()来解除阻止接收任务，该任务现在可以从缓冲区读取，因为缓冲区不再为空。

多消息代码描述

当只有一个消息缓冲区时，很容易将消息缓冲区的句柄传递到xMessageBufferSendCompletedFromISR()中。

但是要考虑有两个或更多消息缓冲区的情况，ISR必须首先确定哪个消息缓冲区包含数据。如果消息缓冲区的数量很少，则有几种方法可以实现：

• 如果硬件允许，则每个消息缓冲区可以使用不同的中断线，从而使中断服务程序和消息缓冲区之间保持一对一的映射。
• 中断服务例程可以简单地查询每个消息缓冲区以查看其是否包含数据。
• 可以通过传递元数据（消息是什么，消息的预期接收者是什么等等）以及实际数据的单个消息缓冲区来代替多个消息缓冲区。

但是，如果存在大量或未知的消息缓冲区，则这些技术效率不高。

在这种情况下，可伸缩的解决方案是引入单独的控制消息缓冲区。如下面的代码所示，sbSEND_COMPLETED()使用控制消息缓冲区将包含数据的消息缓冲区的句柄传递到中断服务例程中。

使用sbSEND_COMPLETED()的实现：

void InterruptServiceRoutine( void )
{
MessageBufferHandle_t xUpdatedMessageBuffer;
BaseType_t xHigherPriorityTaskWoken = pdFALSE;

    /* Receive the handle of the message buffer that contains data from the
    control message buffer.  Ensure to drain the buffer before returning. */
    while( xMessageBufferReceiveFromISR( xControlMessageBuffer,
                                         &xUpdatedMessageBuffer,
                                         sizeof( xUpdatedMessageBuffer ),
                                         &xHigherPriorityTaskWoken )
                                           == sizeof( xUpdatedMessageBuffer ) )
    {
        /* Call the API function that sends a notification to any task that is
        blocked on the xUpdatedMessageBuffer message buffer waiting for data to
        arrive. */
        xMessageBufferSendCompletedFromISR( xUpdatedMessageBuffer,
                                            &xHigherPriorityTaskWoken );
    }

    /* Normal FreeRTOS "yield from interrupt" semantics, where
    xHigherPriorityTaskWoken is initialised to pdFALSE and will then get set to
    pdTRUE if the interrupt unblocks a task that has a priority above that of
    the currently executing task. */
    portYIELD_FROM_ISR( xHigherPriorityTaskWoken );
}

然后，ISR读取控制消息缓冲区以获得句柄，将句柄作为参数传递到xMessageBufferSendCompletedFromISR()中：

void InterruptServiceRoutine( void )
{
MessageBufferHandle_t xUpdatedMessageBuffer;
BaseType_t xHigherPriorityTaskWoken = pdFALSE;

    /* Receive the handle of the message buffer that contains data from the
    control message buffer.  Ensure to drain the buffer before returning. */
    while( xMessageBufferReceiveFromISR( xControlMessageBuffer,
                                         &xUpdatedMessageBuffer,
                                         sizeof( xUpdatedMessageBuffer ),
                                         &xHigherPriorityTaskWoken )
                                           == sizeof( xUpdatedMessageBuffer ) )
    {
        /* Call the API function that sends a notification to any task that is
        blocked on the xUpdatedMessageBuffer message buffer waiting for data to
        arrive. */
        xMessageBufferSendCompletedFromISR( xUpdatedMessageBuffer,
                                            &xHigherPriorityTaskWoken );
    }

    /* Normal FreeRTOS "yield from interrupt" semantics, where
    xHigherPriorityTaskWoken is initialised to pdFALSE and will then get set to
    pdTRUE if the interrupt unblocks a task that has a priority above that of
    the currently executing task. */
    portYIELD_FROM_ISR( xHigherPriorityTaskWoken );
}

如图，使用控制消息缓冲区时的顺序：

**1.**接收任务尝试从空的消息缓冲区中读取数据，并进入阻止状态以等待数据到达。

**2.**发送任务将数据写入消息缓冲区。

**3.**sbSEND_COMPLETED()将现在包含数据的消息缓冲区的句柄发送到控制消息缓冲区。

**4.**sbSEND_COMPLETED()在正在执行接收任务的内核中触发一个中断。

**5.**中断服务例程从控制消息缓冲区中读取包含数据的消息缓冲区的句柄，然后将该句柄传递给xMessageBufferSendCompletedFromISR（）API函数以取消阻止接收任务，该任务现在可以从缓冲区读取，因为缓冲区不再存在空的。

当然，以上仅提供基础原理和方法，具体实现需结合项目实际情况。更多相关内容，请参看官方相关资料。

以上就是良许教程网为各位朋友分享的Linu系统相关内容。想要了解更多Linux相关知识记得关注公众号“良许Linux”，或扫描下方二维码进行关注，更多干货等着你 ！