多消息代码描述
当只有一个消息缓冲区时,很容易将消息缓冲区的句柄传递到xMessageBufferSendCompletedFromISR()中。
但是要考虑有两个或更多消息缓冲区的情况,ISR必须首先确定哪个消息缓冲区包含数据。如果消息缓冲区的数量很少,则有几种方法可以实现:
如果硬件允许,则每个消息缓冲区可以使用不同的中断线,从而使中断服务程序和消息缓冲区之间保持一对一的映射。
中断服务例程可以简单地查询每个消息缓冲区以查看其是否包含数据。
可以通过传递元数据(消息是什么,消息的预期接收者是什么等等)以及实际数据的单个消息缓冲区来代替多个消息缓冲区。
但是,如果存在大量或未知的消息缓冲区,则这些技术效率不高。
在这种情况下,可伸缩的解决方案是引入单独的控制消息缓冲区。如下面的代码所示,sbSEND_COMPLETED()使用控制消息缓冲区将包含数据的消息缓冲区的句柄传递到中断服务例程中。
使用sbSEND_COMPLETED()的实现:
- /* Added to FreeRTOSConfig.h to override the default implementation. */
- #define sbSEND_COMPLETED( pxStreamBuffer ) vGenerateCoreToCoreInterrupt( pxStreamBuffer )
- /* Implemented in a C file. */
- void vGenerateCoreToCoreInterrupt( MessageBufferHandle_t xUpdatedBuffer )
- {
- size_t BytesWritten.
- /* Called by the implementation of sbSEND_COMPLETED() in FreeRTOSConfig.h.
- If this function was called because data was written to any message buffer
- other than the control message buffer then write the handle of the message
- buffer that contains data to the control message buffer, then raise an
- interrupt in the other core. If this function was called because data was
- written to the control message buffer then do nothing. */
- if( xUpdatedBuffer != xControlMessageBuffer )
- {
- BytesWritten = xMessageBufferSend( xControlMessageBuffer,
- &xUpdatedBuffer,
- sizeof( xUpdatedBuffer ),
- 0 );
- /* If the bytes could not be written then the control message buffer
- is too small! */
- configASSERT( BytesWritten == sizeof( xUpdatedBuffer );
- /* Generate interrupt in the other core (pseudocode). */
- GenerateInterrupt();
- }
- }
然后,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函数以取消阻止接收任务,该任务现在可以从缓冲区读取,因为缓冲区不再存在空的。
当然,以上仅提供基础原理和方法,具体实现需结合项目实际情况。更多相关内容,请参看官方相关资料。
|