使用FreeRTOS消息缓冲区，实现简单的非对称多处理（AMP）核心到核心通信（STM32H7 双核处理器）。

一、概述

实现STM32H7双核之间通信是FreeRTOS官方提供的一个方案，是基于FreeRTOS消息缓冲区，该消息缓冲区是无锁循环缓冲区，可以将大小不同的数据包从单个发送方传递到单个接收方。

说明，该消息缓冲区仅提供数据的传输，不提供通信相关协议处理。

二、基本原理

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

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

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

三、单消息代码描述

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

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

1. xMessageBufferSend()
   
2. {
   ) Q$ T" N! i# W) T9 N5 {2 ^1 ]$ x( ~* z4 p
3.     /* If a time out is specified and there isn't enough
   8 w: K4 J# q! s$ }) f- `7 c
4.     space in the message buffer to send the data, then
   5 Z5 i4 E( `# x1 [: d. `3 T
5.     enter the blocked state to wait for more space. */
   
6.     if( time out != 0 )
   
7.     {
   
8.         while( there is insufficient space in the buffer &&
   ) s7 E( p& g5 U1 U  Z# z
9.                not timed out waiting )
   
10.         {
    
11.             Enter the blocked state to wait for space in the buffer
    6 M6 q! Y. q5 o+ A) |: Y  D
12.         }
    
13.     }
    
14. 
    

复制代码

1. if( there is enough space in the buffer )
   
2. {
   ! l# ^8 Q" X9 X, f
3. write data to buffer
   
4. sbSEND_COMPLETED()
   ; G: p& z0 F: _0 ?) h
5. }
   
6. }

复制代码

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

1. xMessageBufferReceive()
   
2. {
   / y* y) K1 I! B0 y+ O& Z
3.     /* If a time out is specified and the buffer doesn't
   
4.     contain any data that can be read, then enter the
   + N( a" ]& N* V" c
5.     blocked state to wait for the buffer to contain data. */
   
6.     if( time out != 0 )
   
7.     {
   
8.         while( there is no data in the buffer &&
   
9.                not timed out waiting )
   
10.         {
    2 m0 u( e5 U1 ~3 t# B3 F
11.             Enter the blocked state to wait for data
    . q- D  r6 ~' ?8 c
12.         }
    ) [( m! x% r" O) x8 U3 Z( _8 G- L
13.     }
    / {; g" T# f* X- ?
14. 
    

复制代码

1. if( there is data in the buffer )
   
2. {
   + O% R+ L" ~8 x% ]! t( E8 j: ?
3. read data from buffer
   
4. sbRECEIVE_COMPLETED()
   ' ~5 l% K  s, Y* H3 l
5. }
   ) H$ V2 X3 r# b! n; D  \
6. }

复制代码

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

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

7 l3 O0 P# ]% `3 c+ r4 C* `9 V6 v; v

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

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

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

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

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

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

四、多消息代码描述

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

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

• 如果硬件允许，则每个消息缓冲区可以使用不同的中断线，从而使中断服务程序和消息缓冲区之间保持一对一的映射。

• 中断服务例程可以简单地查询每个消息缓冲区以查看其是否包含数据。

• 可以通过传递元数据（消息是什么，消息的预期接收者是什么等等）以及实际数据的单个消息缓冲区来代替多个消息缓冲区。

  
  ; ]3 m+ A+ J0 s, {) I# u
  

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

3 c6 d' F+ `+ h" |7 _. C4 Z

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

; G  ]: d. {6 k0 w0 _0 Q/ a

使用sbSEND_COMPLETED()的实现：​​​​​​​

1. /* Added to FreeRTOSConfig.h to override the default implementation. */
   2 K" @: Z+ n9 z
2. #define sbSEND_COMPLETED( pxStreamBuffer ) vGenerateCoreToCoreInterrupt( pxStreamBuffer )
   

复制代码

1. /* Implemented in a C file. */
   * C& n1 w0 \' V3 ^6 w, h
2. void vGenerateCoreToCoreInterrupt( MessageBufferHandle_t xUpdatedBuffer )
   
3. {
   - I" g8 h4 C4 u7 ?5 }, {
4. size_t BytesWritten.
   , \% ^3 v+ p5 ]1 s% N

复制代码

1. /* Called by the implementation of sbSEND_COMPLETED() in FreeRTOSConfig.h.
   5 O; L; y* J. Z# j+ x6 a
2. If this function was called because data was written to any message buffer
   : Q' W: Y/ W- Z4 l# S
3. other than the control message buffer then write the handle of the message
   / Q9 `8 F. b1 e' h
4. buffer that contains data to the control message buffer, then raise an
   
5. interrupt in the other core. If this function was called because data was
   
6. written to the control message buffer then do nothing. */
   * k* _% _/ B, f- [& A$ t1 K
7. if( xUpdatedBuffer != xControlMessageBuffer )
   ; W& ~/ [6 p. o
8. {
   4 x  l5 ~+ @' `9 ?/ w
9.     BytesWritten = xMessageBufferSend( xControlMessageBuffer,
   / Q9 A9 @- u5 O6 |6 f" e! V. X5 y
10.                                                          &xUpdatedBuffer,
    ( @+ I3 e! Q' {3 @. h
11.                                                          sizeof( xUpdatedBuffer ),
    
12.                                                           0 );
    ! V8 _; i8 v  `% F; }

复制代码

1. /* If the bytes could not be written then the control message buffer
   7 S, d2 g' ^" e2 [8 U" ^
2. is too small! */
   % E' O* j+ |4 q$ n; k" m2 g
3. configASSERT( BytesWritten == sizeof( xUpdatedBuffer );
   ' ]/ a: c9 u# @; T; \' U

复制代码

1. /* Generate interrupt in the other core (pseudocode). */
   
2. GenerateInterrupt();
   : e5 j  l& R# {1 M6 j4 t
3. }
   
4. }

复制代码

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

1. void InterruptServiceRoutine( void )
   9 J; m: B+ f: O5 C6 F+ K: g& C
2. {
   % s) B4 r0 c: \7 _( U5 M* T( B
3. MessageBufferHandle_t xUpdatedMessageBuffer;
   + N/ w8 M3 C4 f7 {' o5 q& v
4. BaseType_t xHigherPriorityTaskWoken = pdFALSE;
     ~- A5 ^- n$ y/ x- T: q- b

复制代码

1. /* Receive the handle of the message buffer that contains data from the
   
2. control message buffer. Ensure to drain the buffer before returning. */
   ( u5 A$ r0 _+ H
3. while( xMessageBufferReceiveFromISR( xControlMessageBuffer,
   
4. &xUpdatedMessageBuffer,
   7 ~  W2 D! w! J7 R+ T1 k& t
5. sizeof( xUpdatedMessageBuffer ),
   1 l/ C% a' _$ x5 D
6. &xHigherPriorityTaskWoken )
   ! o  H# I' F8 q
7. == sizeof( xUpdatedMessageBuffer ) )
   
8. {
   
9. /* Call the API function that sends a notification to any task that is
   6 S) R9 B3 f" p0 ?* q# M0 G1 ^3 b. s
10. blocked on the xUpdatedMessageBuffer message buffer waiting for data to
    * j) _$ e6 z2 ?( E" l" V( {9 I6 l
11. arrive. */
    
12. xMessageBufferSendCompletedFromISR( xUpdatedMessageBuffer,
    
13. &xHigherPriorityTaskWoken );
    ; V& {2 h! E; q! j6 e
14. }
    

复制代码

1. /* Normal FreeRTOS "yield from interrupt" semantics, where
     E9 X& a0 u. b- R0 `) |% h' ^, h
2. xHigherPriorityTaskWoken is initialised to pdFALSE and will then get set to
   / D* E, R9 q& g, G# D5 C9 J
3. pdTRUE if the interrupt unblocks a task that has a priority above that of
   
4. the currently executing task. */
   # n% M! q- K( w5 Z, ?7 X! e) a
5. portYIELD_FROM_ISR( xHigherPriorityTaskWoken );
   3 C5 q6 R/ V, t4 ~' {* p; E/ {# |0 O
6. }

复制代码

) X+ |" X9 C( U* F2 |; F

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

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

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

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

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

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

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

3 t4 B# h0 Y6 T! [

好好学习