59     #define sbRECEIVE_COMPLETED( pxStreamBuffer )                             \  argument
64             if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL )              \
66                 ( void ) xTaskNotify( ( pxStreamBuffer )->xTaskWaitingToSend, \
69                 ( pxStreamBuffer )->xTaskWaitingToSend = NULL;                \
80     #define prvRECEIVE_COMPLETED( pxStreamBuffer )                                               \  argument
82         if( ( pxStreamBuffer )->pxReceiveCompletedCallback != NULL )                             \
84             ( pxStreamBuffer )->pxReceiveCompletedCallback( ( pxStreamBuffer ), pdFALSE, NULL ); \
88             sbRECEIVE_COMPLETED( ( pxStreamBuffer ) );                                           \
92     #define prvRECEIVE_COMPLETED( pxStreamBuffer )    sbRECEIVE_COMPLETED( ( pxStreamBuffer ) )  argument
96     #define sbRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer,                            \  argument
103             if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL )                     \
105                 ( void ) xTaskNotifyFromISR( ( pxStreamBuffer )->xTaskWaitingToSend, \
109                 ( pxStreamBuffer )->xTaskWaitingToSend = NULL;                       \
117 …#define prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer,                                            …  argument
120 …if( ( pxStreamBuffer )->pxReceiveCompletedCallback != NULL )                                      …
122 …( pxStreamBuffer )->pxReceiveCompletedCallback( ( pxStreamBuffer ), pdTRUE, ( pxHigherPriorityTask…
126 …sbRECEIVE_COMPLETED_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) );                …
130     #define prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ) \  argument
131     sbRECEIVE_COMPLETED_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) )
139     #define sbSEND_COMPLETED( pxStreamBuffer )                               \  argument
142         if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL )              \
144             ( void ) xTaskNotify( ( pxStreamBuffer )->xTaskWaitingToReceive, \
147             ( pxStreamBuffer )->xTaskWaitingToReceive = NULL;                \
157     #define prvSEND_COMPLETED( pxStreamBuffer )                                               \  argument
159         if( ( pxStreamBuffer )->pxSendCompletedCallback != NULL )                             \
161             ( pxStreamBuffer )->pxSendCompletedCallback( ( pxStreamBuffer ), pdFALSE, NULL ); \
165             sbSEND_COMPLETED( ( pxStreamBuffer ) );                                           \
169     #define prvSEND_COMPLETED( pxStreamBuffer )    sbSEND_COMPLETED( ( pxStreamBuffer ) )  argument
174     #define sbSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken )       \  argument
180             if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL )                     \
182                 ( void ) xTaskNotifyFromISR( ( pxStreamBuffer )->xTaskWaitingToReceive, \
186                 ( pxStreamBuffer )->xTaskWaitingToReceive = NULL;                       \
195 …#define prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken )                    …  argument
197 …if( ( pxStreamBuffer )->pxSendCompletedCallback != NULL )                                         …
199 …( pxStreamBuffer )->pxSendCompletedCallback( ( pxStreamBuffer ), pdTRUE, ( pxHigherPriorityTaskWok…
203 …sbSEND_COMPLETE_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) );                    …
207     #define prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ) \  argument
208     sbSEND_COMPLETE_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) )
245 static size_t prvBytesInBuffer( const StreamBuffer_t * const pxStreamBuffer ) PRIVILEGED_FUNCTION;
258 static size_t prvWriteBytesToBuffer( StreamBuffer_t * const pxStreamBuffer,
270 static size_t prvReadMessageFromBuffer( StreamBuffer_t * pxStreamBuffer,
282 static size_t prvWriteMessageToBuffer( StreamBuffer_t * const pxStreamBuffer,
300 static size_t prvReadBytesFromBuffer( StreamBuffer_t * pxStreamBuffer,
309 static void prvInitialiseNewStreamBuffer( StreamBuffer_t * const pxStreamBuffer,
420         StreamBuffer_t * const pxStreamBuffer = ( StreamBuffer_t * ) pxStaticStreamBuffer;  in xStreamBufferGenericCreateStatic()  local
466             prvInitialiseNewStreamBuffer( pxStreamBuffer,  in xStreamBufferGenericCreateStatic()
476             pxStreamBuffer->ucFlags |= sbFLAGS_IS_STATICALLY_ALLOCATED;  in xStreamBufferGenericCreateStatic()
478             traceSTREAM_BUFFER_CREATE( pxStreamBuffer, xIsMessageBuffer );  in xStreamBufferGenericCreateStatic()
504         StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferGetStaticBuffers()  local
508         configASSERT( pxStreamBuffer );  in xStreamBufferGetStaticBuffers()
512         if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) != ( uint8_t ) 0 )  in xStreamBufferGetStaticBuffers()
514             *ppucStreamBufferStorageArea = pxStreamBuffer->pucBuffer;  in xStreamBufferGetStaticBuffers()
518             *ppxStaticStreamBuffer = ( StaticStreamBuffer_t * ) pxStreamBuffer;  in xStreamBufferGetStaticBuffers()
535     StreamBuffer_t * pxStreamBuffer = xStreamBuffer;  in vStreamBufferDelete()  local
539     configASSERT( pxStreamBuffer );  in vStreamBufferDelete()
543     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) == ( uint8_t ) pdFALSE )  in vStreamBufferDelete()
549             vPortFree( ( void * ) pxStreamBuffer );  in vStreamBufferDelete()
563         ( void ) memset( pxStreamBuffer, 0x00, sizeof( StreamBuffer_t ) );  in vStreamBufferDelete()
572     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferReset()  local
582     configASSERT( pxStreamBuffer );  in xStreamBufferReset()
588         uxStreamBufferNumber = pxStreamBuffer->uxStreamBufferNumber;  in xStreamBufferReset()
595 …if( ( pxStreamBuffer->xTaskWaitingToReceive == NULL ) && ( pxStreamBuffer->xTaskWaitingToSend == N…  in xStreamBufferReset()
599                 pxSendCallback = pxStreamBuffer->pxSendCompletedCallback;  in xStreamBufferReset()
600                 pxReceiveCallback = pxStreamBuffer->pxReceiveCompletedCallback;  in xStreamBufferReset()
604             prvInitialiseNewStreamBuffer( pxStreamBuffer,  in xStreamBufferReset()
605                                           pxStreamBuffer->pucBuffer,  in xStreamBufferReset()
606                                           pxStreamBuffer->xLength,  in xStreamBufferReset()
607                                           pxStreamBuffer->xTriggerLevelBytes,  in xStreamBufferReset()
608                                           pxStreamBuffer->ucFlags,  in xStreamBufferReset()
614                 pxStreamBuffer->uxStreamBufferNumber = uxStreamBufferNumber;  in xStreamBufferReset()
634     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferSetTriggerLevel()  local
639     configASSERT( pxStreamBuffer );  in xStreamBufferSetTriggerLevel()
649     if( xTriggerLevel < pxStreamBuffer->xLength )  in xStreamBufferSetTriggerLevel()
651         pxStreamBuffer->xTriggerLevelBytes = xTriggerLevel;  in xStreamBufferSetTriggerLevel()
667     const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferSpacesAvailable()  local
673     configASSERT( pxStreamBuffer );  in xStreamBufferSpacesAvailable()
680         xOriginalTail = pxStreamBuffer->xTail;  in xStreamBufferSpacesAvailable()
681         xSpace = pxStreamBuffer->xLength + pxStreamBuffer->xTail;  in xStreamBufferSpacesAvailable()
682         xSpace -= pxStreamBuffer->xHead;  in xStreamBufferSpacesAvailable()
683     } while( xOriginalTail != pxStreamBuffer->xTail );  in xStreamBufferSpacesAvailable()
687     if( xSpace >= pxStreamBuffer->xLength )  in xStreamBufferSpacesAvailable()
689         xSpace -= pxStreamBuffer->xLength;  in xStreamBufferSpacesAvailable()
704     const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferBytesAvailable()  local
709     configASSERT( pxStreamBuffer );  in xStreamBufferBytesAvailable()
711     xReturn = prvBytesInBuffer( pxStreamBuffer );  in xStreamBufferBytesAvailable()
724     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferSend()  local
733     configASSERT( pxStreamBuffer );  in xStreamBufferSend()
737     xMaxReportedSpace = pxStreamBuffer->xLength - ( size_t ) 1;  in xStreamBufferSend()
743     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferSend()
788                 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer );  in xStreamBufferSend()
796                     configASSERT( pxStreamBuffer->xTaskWaitingToSend == NULL );  in xStreamBufferSend()
797                     pxStreamBuffer->xTaskWaitingToSend = xTaskGetCurrentTaskHandle();  in xStreamBufferSend()
809             pxStreamBuffer->xTaskWaitingToSend = NULL;  in xStreamBufferSend()
819         xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer );  in xStreamBufferSend()
826 …xReturn = prvWriteMessageToBuffer( pxStreamBuffer, pvTxData, xDataLengthBytes, xSpace, xRequiredSp…  in xStreamBufferSend()
833         if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes )  in xStreamBufferSend()
835             prvSEND_COMPLETED( pxStreamBuffer );  in xStreamBufferSend()
859     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferSendFromISR()  local
866     configASSERT( pxStreamBuffer );  in xStreamBufferSendFromISR()
872     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferSendFromISR()
881     xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer );  in xStreamBufferSendFromISR()
882 …xReturn = prvWriteMessageToBuffer( pxStreamBuffer, pvTxData, xDataLengthBytes, xSpace, xRequiredSp…  in xStreamBufferSendFromISR()
887         if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes )  in xStreamBufferSendFromISR()
889             prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken );  in xStreamBufferSendFromISR()
908 static size_t prvWriteMessageToBuffer( StreamBuffer_t * const pxStreamBuffer,  in prvWriteMessageToBuffer()  argument
914     size_t xNextHead = pxStreamBuffer->xHead;  in prvWriteMessageToBuffer()
917     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in prvWriteMessageToBuffer()
932 …xNextHead = prvWriteBytesToBuffer( pxStreamBuffer, ( const uint8_t * ) &( xMessageLength ), sbBYTE…  in prvWriteMessageToBuffer()
954 …pxStreamBuffer->xHead = prvWriteBytesToBuffer( pxStreamBuffer, ( const uint8_t * ) pvTxData, xData…  in prvWriteMessageToBuffer()
966     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferReceive()  local
972     configASSERT( pxStreamBuffer );  in xStreamBufferReceive()
979     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferReceive()
994             xBytesAvailable = prvBytesInBuffer( pxStreamBuffer );  in xStreamBufferReceive()
1007                 configASSERT( pxStreamBuffer->xTaskWaitingToReceive == NULL );  in xStreamBufferReceive()
1008                 pxStreamBuffer->xTaskWaitingToReceive = xTaskGetCurrentTaskHandle();  in xStreamBufferReceive()
1022             pxStreamBuffer->xTaskWaitingToReceive = NULL;  in xStreamBufferReceive()
1025             xBytesAvailable = prvBytesInBuffer( pxStreamBuffer );  in xStreamBufferReceive()
1034         xBytesAvailable = prvBytesInBuffer( pxStreamBuffer );  in xStreamBufferReceive()
1044 …xReceivedLength = prvReadMessageFromBuffer( pxStreamBuffer, pvRxData, xBufferLengthBytes, xBytesAv…  in xStreamBufferReceive()
1071     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferNextMessageLengthBytes()  local
1077     configASSERT( pxStreamBuffer );  in xStreamBufferNextMessageLengthBytes()
1080     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferNextMessageLengthBytes()
1082         xBytesAvailable = prvBytesInBuffer( pxStreamBuffer );  in xStreamBufferNextMessageLengthBytes()
1089 …void ) prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) &xTempReturn, sbBYTES_TO_STORE_MESSAG…  in xStreamBufferNextMessageLengthBytes()
1118     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferReceiveFromISR()  local
1124     configASSERT( pxStreamBuffer );  in xStreamBufferReceiveFromISR()
1131     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferReceiveFromISR()
1140     xBytesAvailable = prvBytesInBuffer( pxStreamBuffer );  in xStreamBufferReceiveFromISR()
1149 …xReceivedLength = prvReadMessageFromBuffer( pxStreamBuffer, pvRxData, xBufferLengthBytes, xBytesAv…  in xStreamBufferReceiveFromISR()
1154             prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken );  in xStreamBufferReceiveFromISR()
1173 static size_t prvReadMessageFromBuffer( StreamBuffer_t * pxStreamBuffer,  in prvReadMessageFromBuffer()  argument
1180     size_t xNextTail = pxStreamBuffer->xTail;  in prvReadMessageFromBuffer()
1182     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in prvReadMessageFromBuffer()
1186 …xNextTail = prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) &xTempNextMessageLength, sbBYTES…  in prvReadMessageFromBuffer()
1221 …pxStreamBuffer->xTail = prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) pvRxData, xCount, xN…  in prvReadMessageFromBuffer()
1230     const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferIsEmpty()  local
1236     configASSERT( pxStreamBuffer );  in xStreamBufferIsEmpty()
1239     xTail = pxStreamBuffer->xTail;  in xStreamBufferIsEmpty()
1241     if( pxStreamBuffer->xHead == xTail )  in xStreamBufferIsEmpty()
1260     const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferIsFull()  local
1264     configASSERT( pxStreamBuffer );  in xStreamBufferIsFull()
1270     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferIsFull()
1298     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferSendCompletedFromISR()  local
1304     configASSERT( pxStreamBuffer );  in xStreamBufferSendCompletedFromISR()
1308         if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL )  in xStreamBufferSendCompletedFromISR()
1310             ( void ) xTaskNotifyFromISR( ( pxStreamBuffer )->xTaskWaitingToReceive,  in xStreamBufferSendCompletedFromISR()
1314             ( pxStreamBuffer )->xTaskWaitingToReceive = NULL;  in xStreamBufferSendCompletedFromISR()
1333     StreamBuffer_t * const pxStreamBuffer = xStreamBuffer;  in xStreamBufferReceiveCompletedFromISR()  local
1339     configASSERT( pxStreamBuffer );  in xStreamBufferReceiveCompletedFromISR()
1343         if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL )  in xStreamBufferReceiveCompletedFromISR()
1345             ( void ) xTaskNotifyFromISR( ( pxStreamBuffer )->xTaskWaitingToSend,  in xStreamBufferReceiveCompletedFromISR()
1349             ( pxStreamBuffer )->xTaskWaitingToSend = NULL;  in xStreamBufferReceiveCompletedFromISR()
1365 static size_t prvWriteBytesToBuffer( StreamBuffer_t * const pxStreamBuffer,  in prvWriteBytesToBuffer()  argument
1377     xFirstLength = configMIN( pxStreamBuffer->xLength - xHead, xCount );  in prvWriteBytesToBuffer()
1380     configASSERT( ( xHead + xFirstLength ) <= pxStreamBuffer->xLength );  in prvWriteBytesToBuffer()
1381 …( void ) memcpy( ( void * ) ( &( pxStreamBuffer->pucBuffer[ xHead ] ) ), ( const void * ) pucData,…  in prvWriteBytesToBuffer()
1388         configASSERT( ( xCount - xFirstLength ) <= pxStreamBuffer->xLength );  in prvWriteBytesToBuffer()
1389 …( void ) memcpy( ( void * ) pxStreamBuffer->pucBuffer, ( const void * ) &( pucData[ xFirstLength ]…  in prvWriteBytesToBuffer()
1398     if( xHead >= pxStreamBuffer->xLength )  in prvWriteBytesToBuffer()
1400         xHead -= pxStreamBuffer->xLength;  in prvWriteBytesToBuffer()
1411 static size_t prvReadBytesFromBuffer( StreamBuffer_t * pxStreamBuffer,  in prvReadBytesFromBuffer()  argument
1423     xFirstLength = configMIN( pxStreamBuffer->xLength - xTail, xCount );  in prvReadBytesFromBuffer()
1428     configASSERT( ( xTail + xFirstLength ) <= pxStreamBuffer->xLength );  in prvReadBytesFromBuffer()
1429 …( void ) memcpy( ( void * ) pucData, ( const void * ) &( pxStreamBuffer->pucBuffer[ xTail ] ), xFi…  in prvReadBytesFromBuffer()
1436 …( void ) memcpy( ( void * ) &( pucData[ xFirstLength ] ), ( void * ) ( pxStreamBuffer->pucBuffer )…  in prvReadBytesFromBuffer()
1446     if( xTail >= pxStreamBuffer->xLength )  in prvReadBytesFromBuffer()
1448         xTail -= pxStreamBuffer->xLength;  in prvReadBytesFromBuffer()
1455 static size_t prvBytesInBuffer( const StreamBuffer_t * const pxStreamBuffer )  in prvBytesInBuffer()  argument
1460     xCount = pxStreamBuffer->xLength + pxStreamBuffer->xHead;  in prvBytesInBuffer()
1461     xCount -= pxStreamBuffer->xTail;  in prvBytesInBuffer()
1463     if( xCount >= pxStreamBuffer->xLength )  in prvBytesInBuffer()
1465         xCount -= pxStreamBuffer->xLength;  in prvBytesInBuffer()
1476 static void prvInitialiseNewStreamBuffer( StreamBuffer_t * const pxStreamBuffer,  in prvInitialiseNewStreamBuffer()  argument
1497     ( void ) memset( ( void * ) pxStreamBuffer, 0x00, sizeof( StreamBuffer_t ) );  in prvInitialiseNewStreamBuffer()
1498     pxStreamBuffer->pucBuffer = pucBuffer;  in prvInitialiseNewStreamBuffer()
1499     pxStreamBuffer->xLength = xBufferSizeBytes;  in prvInitialiseNewStreamBuffer()
1500     pxStreamBuffer->xTriggerLevelBytes = xTriggerLevelBytes;  in prvInitialiseNewStreamBuffer()
1501     pxStreamBuffer->ucFlags = ucFlags;  in prvInitialiseNewStreamBuffer()
1504         pxStreamBuffer->pxSendCompletedCallback = pxSendCompletedCallback;  in prvInitialiseNewStreamBuffer()
1505         pxStreamBuffer->pxReceiveCompletedCallback = pxReceiveCompletedCallback;  in prvInitialiseNewStreamBuffer()