Lines Matching refs:pxStreamBuffer
62 #define sbRECEIVE_COMPLETED( pxStreamBuffer ) \ argument
65 if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL ) \
67 ( void ) xTaskNotify( ( pxStreamBuffer )->xTaskWaitingToSend, \
70 ( 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 ) )
247 static size_t prvBytesInBuffer( const StreamBuffer_t * const pxStreamBuffer ) PRIVILEGED_FUNCTION;
260 static size_t prvWriteBytesToBuffer( StreamBuffer_t * const pxStreamBuffer,
272 static size_t prvReadMessageFromBuffer( StreamBuffer_t * pxStreamBuffer,
284 static size_t prvWriteMessageToBuffer( StreamBuffer_t * const pxStreamBuffer,
302 static size_t prvReadBytesFromBuffer( StreamBuffer_t * pxStreamBuffer,
311 static void prvInitialiseNewStreamBuffer( StreamBuffer_t * const pxStreamBuffer,
406 …StreamBuffer_t * const pxStreamBuffer = ( StreamBuffer_t * ) pxStaticStreamBuffer; /*lint !e740 !e… in xStreamBufferGenericCreateStatic() local
450 prvInitialiseNewStreamBuffer( pxStreamBuffer, in xStreamBufferGenericCreateStatic()
460 pxStreamBuffer->ucFlags |= sbFLAGS_IS_STATICALLY_ALLOCATED; in xStreamBufferGenericCreateStatic()
462 traceSTREAM_BUFFER_CREATE( pxStreamBuffer, xIsMessageBuffer ); in xStreamBufferGenericCreateStatic()
483 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferGetStaticBuffers() local
485 configASSERT( pxStreamBuffer ); in xStreamBufferGetStaticBuffers()
489 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) != ( uint8_t ) 0 ) in xStreamBufferGetStaticBuffers()
491 *ppucStreamBufferStorageArea = pxStreamBuffer->pucBuffer; in xStreamBufferGetStaticBuffers()
492 *ppxStaticStreamBuffer = ( StaticStreamBuffer_t * ) pxStreamBuffer; in xStreamBufferGetStaticBuffers()
507 StreamBuffer_t * pxStreamBuffer = xStreamBuffer; in vStreamBufferDelete() local
509 configASSERT( pxStreamBuffer ); in vStreamBufferDelete()
513 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) == ( uint8_t ) pdFALSE ) in vStreamBufferDelete()
519 …vPortFree( ( void * ) pxStreamBuffer ); /*lint !e9087 Standard free() semantics require void *, pl… in vStreamBufferDelete()
533 ( void ) memset( pxStreamBuffer, 0x00, sizeof( StreamBuffer_t ) ); in vStreamBufferDelete()
540 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReset() local
548 configASSERT( pxStreamBuffer ); in xStreamBufferReset()
554 uxStreamBufferNumber = pxStreamBuffer->uxStreamBufferNumber; in xStreamBufferReset()
561 …if( ( pxStreamBuffer->xTaskWaitingToReceive == NULL ) && ( pxStreamBuffer->xTaskWaitingToSend == N… in xStreamBufferReset()
565 pxSendCallback = pxStreamBuffer->pxSendCompletedCallback; in xStreamBufferReset()
566 pxReceiveCallback = pxStreamBuffer->pxReceiveCompletedCallback; in xStreamBufferReset()
570 prvInitialiseNewStreamBuffer( pxStreamBuffer, in xStreamBufferReset()
571 pxStreamBuffer->pucBuffer, in xStreamBufferReset()
572 pxStreamBuffer->xLength, in xStreamBufferReset()
573 pxStreamBuffer->xTriggerLevelBytes, in xStreamBufferReset()
574 pxStreamBuffer->ucFlags, in xStreamBufferReset()
580 pxStreamBuffer->uxStreamBufferNumber = uxStreamBufferNumber; in xStreamBufferReset()
598 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSetTriggerLevel() local
601 configASSERT( pxStreamBuffer ); in xStreamBufferSetTriggerLevel()
611 if( xTriggerLevel < pxStreamBuffer->xLength ) in xStreamBufferSetTriggerLevel()
613 pxStreamBuffer->xTriggerLevelBytes = xTriggerLevel; in xStreamBufferSetTriggerLevel()
627 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSpacesAvailable() local
631 configASSERT( pxStreamBuffer ); in xStreamBufferSpacesAvailable()
638 xOriginalTail = pxStreamBuffer->xTail; in xStreamBufferSpacesAvailable()
639 xSpace = pxStreamBuffer->xLength + pxStreamBuffer->xTail; in xStreamBufferSpacesAvailable()
640 xSpace -= pxStreamBuffer->xHead; in xStreamBufferSpacesAvailable()
641 } while( xOriginalTail != pxStreamBuffer->xTail ); in xStreamBufferSpacesAvailable()
645 if( xSpace >= pxStreamBuffer->xLength ) in xStreamBufferSpacesAvailable()
647 xSpace -= pxStreamBuffer->xLength; in xStreamBufferSpacesAvailable()
660 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferBytesAvailable() local
663 configASSERT( pxStreamBuffer ); in xStreamBufferBytesAvailable()
665 xReturn = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferBytesAvailable()
675 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSend() local
682 configASSERT( pxStreamBuffer ); in xStreamBufferSend()
686 xMaxReportedSpace = pxStreamBuffer->xLength - ( size_t ) 1; in xStreamBufferSend()
692 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferSend()
737 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer ); in xStreamBufferSend()
745 configASSERT( pxStreamBuffer->xTaskWaitingToSend == NULL ); in xStreamBufferSend()
746 pxStreamBuffer->xTaskWaitingToSend = xTaskGetCurrentTaskHandle(); in xStreamBufferSend()
758 pxStreamBuffer->xTaskWaitingToSend = NULL; in xStreamBufferSend()
768 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer ); in xStreamBufferSend()
775 …xReturn = prvWriteMessageToBuffer( pxStreamBuffer, pvTxData, xDataLengthBytes, xSpace, xRequiredSp… in xStreamBufferSend()
782 if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes ) in xStreamBufferSend()
784 prvSEND_COMPLETED( pxStreamBuffer ); in xStreamBufferSend()
806 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSendFromISR() local
811 configASSERT( pxStreamBuffer ); in xStreamBufferSendFromISR()
817 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferSendFromISR()
826 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer ); in xStreamBufferSendFromISR()
827 …xReturn = prvWriteMessageToBuffer( pxStreamBuffer, pvTxData, xDataLengthBytes, xSpace, xRequiredSp… in xStreamBufferSendFromISR()
832 if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes ) in xStreamBufferSendFromISR()
834 prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ); in xStreamBufferSendFromISR()
852 static size_t prvWriteMessageToBuffer( StreamBuffer_t * const pxStreamBuffer, in prvWriteMessageToBuffer() argument
858 size_t xNextHead = pxStreamBuffer->xHead; in prvWriteMessageToBuffer()
861 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in prvWriteMessageToBuffer()
876 …xNextHead = prvWriteBytesToBuffer( pxStreamBuffer, ( const uint8_t * ) &( xMessageLength ), sbBYTE… in prvWriteMessageToBuffer()
895 …pxStreamBuffer->xHead = prvWriteBytesToBuffer( pxStreamBuffer, ( const uint8_t * ) pvTxData, xData… in prvWriteMessageToBuffer()
907 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReceive() local
911 configASSERT( pxStreamBuffer ); in xStreamBufferReceive()
918 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferReceive()
933 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceive()
946 configASSERT( pxStreamBuffer->xTaskWaitingToReceive == NULL ); in xStreamBufferReceive()
947 pxStreamBuffer->xTaskWaitingToReceive = xTaskGetCurrentTaskHandle(); in xStreamBufferReceive()
961 pxStreamBuffer->xTaskWaitingToReceive = NULL; in xStreamBufferReceive()
964 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceive()
973 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceive()
983 …xReceivedLength = prvReadMessageFromBuffer( pxStreamBuffer, pvRxData, xBufferLengthBytes, xBytesAv… in xStreamBufferReceive()
1008 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferNextMessageLengthBytes() local
1012 configASSERT( pxStreamBuffer ); in xStreamBufferNextMessageLengthBytes()
1015 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferNextMessageLengthBytes()
1017 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferNextMessageLengthBytes()
1024 …void ) prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) &xTempReturn, sbBYTES_TO_STORE_MESSAG… in xStreamBufferNextMessageLengthBytes()
1051 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReceiveFromISR() local
1055 configASSERT( pxStreamBuffer ); in xStreamBufferReceiveFromISR()
1062 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferReceiveFromISR()
1071 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceiveFromISR()
1080 …xReceivedLength = prvReadMessageFromBuffer( pxStreamBuffer, pvRxData, xBufferLengthBytes, xBytesAv… in xStreamBufferReceiveFromISR()
1085 prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ); in xStreamBufferReceiveFromISR()
1103 static size_t prvReadMessageFromBuffer( StreamBuffer_t * pxStreamBuffer, in prvReadMessageFromBuffer() argument
1110 size_t xNextTail = pxStreamBuffer->xTail; in prvReadMessageFromBuffer()
1112 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in prvReadMessageFromBuffer()
1116 …xNextTail = prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) &xTempNextMessageLength, sbBYTES… in prvReadMessageFromBuffer()
1148 …pxStreamBuffer->xTail = prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) pvRxData, xCount, xN… in prvReadMessageFromBuffer()
1157 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferIsEmpty() local
1161 configASSERT( pxStreamBuffer ); in xStreamBufferIsEmpty()
1164 xTail = pxStreamBuffer->xTail; in xStreamBufferIsEmpty()
1166 if( pxStreamBuffer->xHead == xTail ) in xStreamBufferIsEmpty()
1183 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferIsFull() local
1185 configASSERT( pxStreamBuffer ); in xStreamBufferIsFull()
1191 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferIsFull()
1217 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSendCompletedFromISR() local
1221 configASSERT( pxStreamBuffer ); in xStreamBufferSendCompletedFromISR()
1225 if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL ) in xStreamBufferSendCompletedFromISR()
1227 ( void ) xTaskNotifyFromISR( ( pxStreamBuffer )->xTaskWaitingToReceive, in xStreamBufferSendCompletedFromISR()
1231 ( pxStreamBuffer )->xTaskWaitingToReceive = NULL; in xStreamBufferSendCompletedFromISR()
1248 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReceiveCompletedFromISR() local
1252 configASSERT( pxStreamBuffer ); in xStreamBufferReceiveCompletedFromISR()
1256 if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL ) in xStreamBufferReceiveCompletedFromISR()
1258 ( void ) xTaskNotifyFromISR( ( pxStreamBuffer )->xTaskWaitingToSend, in xStreamBufferReceiveCompletedFromISR()
1262 ( pxStreamBuffer )->xTaskWaitingToSend = NULL; in xStreamBufferReceiveCompletedFromISR()
1276 static size_t prvWriteBytesToBuffer( StreamBuffer_t * const pxStreamBuffer, in prvWriteBytesToBuffer() argument
1288 xFirstLength = configMIN( pxStreamBuffer->xLength - xHead, xCount ); in prvWriteBytesToBuffer()
1291 configASSERT( ( xHead + xFirstLength ) <= pxStreamBuffer->xLength ); in prvWriteBytesToBuffer()
1292 …( void ) memcpy( ( void * ) ( &( pxStreamBuffer->pucBuffer[ xHead ] ) ), ( const void * ) pucData,… in prvWriteBytesToBuffer()
1299 configASSERT( ( xCount - xFirstLength ) <= pxStreamBuffer->xLength ); in prvWriteBytesToBuffer()
1300 …( void ) memcpy( ( void * ) pxStreamBuffer->pucBuffer, ( const void * ) &( pucData[ xFirstLength ]… in prvWriteBytesToBuffer()
1309 if( xHead >= pxStreamBuffer->xLength ) in prvWriteBytesToBuffer()
1311 xHead -= pxStreamBuffer->xLength; in prvWriteBytesToBuffer()
1322 static size_t prvReadBytesFromBuffer( StreamBuffer_t * pxStreamBuffer, in prvReadBytesFromBuffer() argument
1334 xFirstLength = configMIN( pxStreamBuffer->xLength - xTail, xCount ); in prvReadBytesFromBuffer()
1339 configASSERT( ( xTail + xFirstLength ) <= pxStreamBuffer->xLength ); in prvReadBytesFromBuffer()
1340 …( void ) memcpy( ( void * ) pucData, ( const void * ) &( pxStreamBuffer->pucBuffer[ xTail ] ), xFi… in prvReadBytesFromBuffer()
1347 …( void ) memcpy( ( void * ) &( pucData[ xFirstLength ] ), ( void * ) ( pxStreamBuffer->pucBuffer )… in prvReadBytesFromBuffer()
1357 if( xTail >= pxStreamBuffer->xLength ) in prvReadBytesFromBuffer()
1359 xTail -= pxStreamBuffer->xLength; in prvReadBytesFromBuffer()
1366 static size_t prvBytesInBuffer( const StreamBuffer_t * const pxStreamBuffer ) in prvBytesInBuffer() argument
1371 xCount = pxStreamBuffer->xLength + pxStreamBuffer->xHead; in prvBytesInBuffer()
1372 xCount -= pxStreamBuffer->xTail; in prvBytesInBuffer()
1374 if( xCount >= pxStreamBuffer->xLength ) in prvBytesInBuffer()
1376 xCount -= pxStreamBuffer->xLength; in prvBytesInBuffer()
1387 static void prvInitialiseNewStreamBuffer( StreamBuffer_t * const pxStreamBuffer, in prvInitialiseNewStreamBuffer() argument
1408 …( void ) memset( ( void * ) pxStreamBuffer, 0x00, sizeof( StreamBuffer_t ) ); /*lint !e9087 memset… in prvInitialiseNewStreamBuffer()
1409 pxStreamBuffer->pucBuffer = pucBuffer; in prvInitialiseNewStreamBuffer()
1410 pxStreamBuffer->xLength = xBufferSizeBytes; in prvInitialiseNewStreamBuffer()
1411 pxStreamBuffer->xTriggerLevelBytes = xTriggerLevelBytes; in prvInitialiseNewStreamBuffer()
1412 pxStreamBuffer->ucFlags = ucFlags; in prvInitialiseNewStreamBuffer()
1415 pxStreamBuffer->pxSendCompletedCallback = pxSendCompletedCallback; in prvInitialiseNewStreamBuffer()
1416 pxStreamBuffer->pxReceiveCompletedCallback = pxReceiveCompletedCallback; in prvInitialiseNewStreamBuffer()