42 #if ( configUSE_TASK_NOTIFICATIONS != 1 )
46 #if ( INCLUDE_xTaskGetCurrentTaskHandle != 1 )
55 /* If the user has not provided application specific Rx notification macros,
64             if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL )              \
76 /* If user has provided a per-instance receive complete callback, then
79 #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )
82         if( ( pxStreamBuffer )->pxReceiveCompletedCallback != NULL )                             \
91 #else /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
93 #endif /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
103             if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL )                     \
116 #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )
120 …if( ( pxStreamBuffer )->pxReceiveCompletedCallback != NULL )                                      …
129 #else /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
132 #endif /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
134 /* If the user has not provided an application specific Tx notification macro,
142         if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL )              \
153 /* If user has provided a per-instance send completed callback, then
156 #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )
159         if( ( pxStreamBuffer )->pxSendCompletedCallback != NULL )                             \
168 #else /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
170 #endif /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
180             if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL )                     \
194 #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )
197 …if( ( pxStreamBuffer )->pxSendCompletedCallback != NULL )                                         …
206 #else /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
209 #endif /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */
215 #define sbFLAGS_IS_MESSAGE_BUFFER          ( ( uint8_t ) 1 ) /* Set if the stream buffer was create…
216 #define sbFLAGS_IS_STATICALLY_ALLOCATED    ( ( uint8_t ) 2 ) /* Set if the stream buffer was create…
227 …kWaitingToReceive; /* Holds the handle of a task waiting for data, or NULL if no tasks are waiting…
232     #if ( configUSE_TRACE_FACILITY == 1 )
236     #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )
237 …ck;    /* Optional callback called on send complete. sbSEND_COMPLETED is called if this is NULL. */
238 …/* Optional callback called on receive complete.  sbRECEIVE_COMPLETED is called if this is NULL. */
264  * If the stream buffer is being used as a message buffer, then reads an entire
265  * message out of the buffer.  If the stream buffer is being used as a stream
276  * If the stream buffer is being used as a message buffer, then writes an entire
277  * message to the buffer.  If the stream buffer is being used as a stream
294  * copied over, especially if we have to abort the read due to insufficient receiving space.
318 #if ( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
334         if( xIsMessageBuffer == pdTRUE )  in xStreamBufferGenericCreate()
351         if( xTriggerLevelBytes == ( size_t ) 0 )  in xStreamBufferGenericCreate()
364         if( xBufferSizeBytes < ( xBufferSizeBytes + 1U + sizeof( StreamBuffer_t ) ) )  in xStreamBufferGenericCreate()
374         if( pvAllocatedMemory != NULL )  in xStreamBufferGenericCreate()
407 #if ( configSUPPORT_STATIC_ALLOCATION == 1 )
432         if( xTriggerLevelBytes == ( size_t ) 0 )  in xStreamBufferGenericCreateStatic()
442         if( xIsMessageBuffer != pdFALSE )  in xStreamBufferGenericCreateStatic()
454         #if ( configASSERT_DEFINED == 1 )  in xStreamBufferGenericCreateStatic()
464         if( ( pucStreamBufferStorageArea != NULL ) && ( pxStaticStreamBuffer != NULL ) )  in xStreamBufferGenericCreateStatic()
498 #if ( configSUPPORT_STATIC_ALLOCATION == 1 )
512         if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) != ( uint8_t ) 0 )  in xStreamBufferGetStaticBuffers()
543     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) == ( uint8_t ) pdFALSE )  in vStreamBufferDelete()
545         #if ( configSUPPORT_DYNAMIC_ALLOCATION == 1 )  in vStreamBufferDelete()
576     #if ( configUSE_TRACE_FACILITY == 1 )  in xStreamBufferReset()
584     #if ( configUSE_TRACE_FACILITY == 1 )  in xStreamBufferReset()
592     /* Can only reset a message buffer if there are no tasks blocked on it. */  in xStreamBufferReset()
595 …if( ( pxStreamBuffer->xTaskWaitingToReceive == NULL ) && ( pxStreamBuffer->xTaskWaitingToSend == N…  in xStreamBufferReset()
597             #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )  in xStreamBufferReset()
612             #if ( configUSE_TRACE_FACILITY == 1 )  in xStreamBufferReset()
642     if( xTriggerLevel == ( size_t ) 0 )  in xStreamBufferSetTriggerLevel()
649     if( xTriggerLevel < pxStreamBuffer->xLength )  in xStreamBufferSetTriggerLevel()
675     /* The code below reads xTail and then xHead.  This is safe if the stream  in xStreamBufferSpacesAvailable()
676      * buffer is updated once between the two reads - but not if the stream buffer  in xStreamBufferSpacesAvailable()
687     if( xSpace >= pxStreamBuffer->xLength )  in xStreamBufferSpacesAvailable()
740      * buffers.  If this is a message buffer then the space needed must be  in xStreamBufferSend()
743     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferSend()
750         /* If this is a message buffer then it must be possible to write the  in xStreamBufferSend()
752         if( xRequiredSpace > xMaxReportedSpace )  in xStreamBufferSend()
754             /* The message would not fit even if the entire buffer was empty,  in xStreamBufferSend()
765         /* If this is a stream buffer then it is acceptable to write only part  in xStreamBufferSend()
768         if( xRequiredSpace > xMaxReportedSpace )  in xStreamBufferSend()
778     if( xTicksToWait != ( TickType_t ) 0 )  in xStreamBufferSend()
790                 if( xSpace < xRequiredSpace )  in xStreamBufferSend()
817     if( xSpace == ( size_t ) 0 )  in xStreamBufferSend()
828     if( xReturn > ( size_t ) 0 )  in xStreamBufferSend()
833         if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes )  in xStreamBufferSend()
869      * buffers.  If this is a message buffer then the space needed must be  in xStreamBufferSendFromISR()
872     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferSendFromISR()
884     if( xReturn > ( size_t ) 0 )  in xStreamBufferSendFromISR()
887         if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes )  in xStreamBufferSendFromISR()
917     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in prvWriteMessageToBuffer()
927         if( xSpace >= xRequiredSpace )  in prvWriteMessageToBuffer()
948     if( xDataLengthBytes != ( size_t ) 0 )  in prvWriteMessageToBuffer()
979     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferReceive()
988     if( xTicksToWait != ( TickType_t ) 0 )  in xStreamBufferReceive()
990         /* Checking if there is data and clearing the notification state must be  in xStreamBufferReceive()
996             /* If this function was invoked by a message buffer read then  in xStreamBufferReceive()
998              * the length of the next discrete message.  If this function was  in xStreamBufferReceive()
1001             if( xBytesAvailable <= xBytesToStoreMessageLength )  in xStreamBufferReceive()
1017         if( xBytesAvailable <= xBytesToStoreMessageLength )  in xStreamBufferReceive()
1042     if( xBytesAvailable > xBytesToStoreMessageLength )  in xStreamBufferReceive()
1047         if( xReceivedLength != ( size_t ) 0 )  in xStreamBufferReceive()
1080     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferNextMessageLengthBytes()
1084         if( xBytesAvailable > sbBYTES_TO_STORE_MESSAGE_LENGTH )  in xStreamBufferNextMessageLengthBytes()
1095              * ( sbBYTES_TO_STORE_MESSAGE_LENGTH + 1 ), so if xBytesAvailable is  in xStreamBufferNextMessageLengthBytes()
1131     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferReceiveFromISR()
1147     if( xBytesAvailable > xBytesToStoreMessageLength )  in xStreamBufferReceiveFromISR()
1152         if( xReceivedLength != ( size_t ) 0 )  in xStreamBufferReceiveFromISR()
1182     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in prvReadMessageFromBuffer()
1195         if( xNextMessageLength > xBufferLengthBytes )  in prvReadMessageFromBuffer()
1215     if( xCount != ( size_t ) 0 )  in prvReadMessageFromBuffer()
1238     /* True if no bytes are available. */  in xStreamBufferIsEmpty()
1241     if( pxStreamBuffer->xHead == xTail )  in xStreamBufferIsEmpty()
1270     if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 )  in xStreamBufferIsFull()
1279     /* True if the available space equals zero. */  in xStreamBufferIsFull()
1280     if( xStreamBufferSpacesAvailable( xStreamBuffer ) <= xBytesToStoreMessageLength )  in xStreamBufferIsFull()
1308         if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL )  in xStreamBufferSendCompletedFromISR()
1343         if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL )  in xStreamBufferReceiveCompletedFromISR()
1375      * which may be less than the total number of bytes that need to be added if  in prvWriteBytesToBuffer()
1383     /* If the number of bytes written was less than the number that could be  in prvWriteBytesToBuffer()
1385     if( xCount > xFirstLength )  in prvWriteBytesToBuffer()
1398     if( xHead >= pxStreamBuffer->xLength )  in prvWriteBytesToBuffer()
1421      * less than the number wanted if the data wraps around to the start of  in prvReadBytesFromBuffer()
1431     /* If the total number of wanted bytes is greater than the number  in prvReadBytesFromBuffer()
1433     if( xCount > xFirstLength )  in prvReadBytesFromBuffer()
1446     if( xTail >= pxStreamBuffer->xLength )  in prvReadBytesFromBuffer()
1463     if( xCount >= pxStreamBuffer->xLength )  in prvBytesInBuffer()
1487     #if ( configASSERT_DEFINED == 1 )  in prvInitialiseNewStreamBuffer()
1502     #if ( configUSE_SB_COMPLETED_CALLBACK == 1 )  in prvInitialiseNewStreamBuffer()
1519     #endif /* if ( configUSE_SB_COMPLETED_CALLBACK == 1 ) */  in prvInitialiseNewStreamBuffer()
1522 #if ( configUSE_TRACE_FACILITY == 1 )
1536 #if ( configUSE_TRACE_FACILITY == 1 )
1551 #if ( configUSE_TRACE_FACILITY == 1 )