Lines Matching refs:pxStreamBuffer
65 #define sbRECEIVE_COMPLETED( pxStreamBuffer ) \ argument
70 if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL ) \
72 ( void ) xTaskNotifyIndexed( ( pxStreamBuffer )->xTaskWaitingToSend, \
73 ( pxStreamBuffer )->uxNotificationIndex, \
76 ( pxStreamBuffer )->xTaskWaitingToSend = NULL; \
87 #define prvRECEIVE_COMPLETED( pxStreamBuffer ) \ argument
89 if( ( pxStreamBuffer )->pxReceiveCompletedCallback != NULL ) \
91 ( pxStreamBuffer )->pxReceiveCompletedCallback( ( pxStreamBuffer ), pdFALSE, NULL ); \
95 sbRECEIVE_COMPLETED( ( pxStreamBuffer ) ); \
99 #define prvRECEIVE_COMPLETED( pxStreamBuffer ) sbRECEIVE_COMPLETED( ( pxStreamBuffer ) ) argument
103 #define sbRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, \ argument
110 if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL ) \
112 ( void ) xTaskNotifyIndexedFromISR( ( pxStreamBuffer )->xTaskWaitingToSend, \
113 ( pxStreamBuffer )->uxNotificationIndex, \
117 ( pxStreamBuffer )->xTaskWaitingToSend = NULL; \
125 …#define prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, … argument
128 …if( ( pxStreamBuffer )->pxReceiveCompletedCallback != NULL ) …
130 …( pxStreamBuffer )->pxReceiveCompletedCallback( ( pxStreamBuffer ), pdTRUE, ( pxHigherPriorityTask…
134 …sbRECEIVE_COMPLETED_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) ); …
138 #define prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ) \ argument
139 sbRECEIVE_COMPLETED_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) )
147 #define sbSEND_COMPLETED( pxStreamBuffer ) \ argument
150 if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL ) \
152 ( void ) xTaskNotifyIndexed( ( pxStreamBuffer )->xTaskWaitingToReceive, \
153 ( pxStreamBuffer )->uxNotificationIndex, \
156 ( pxStreamBuffer )->xTaskWaitingToReceive = NULL; \
166 #define prvSEND_COMPLETED( pxStreamBuffer ) \ argument
168 if( ( pxStreamBuffer )->pxSendCompletedCallback != NULL ) \
170 ( pxStreamBuffer )->pxSendCompletedCallback( ( pxStreamBuffer ), pdFALSE, NULL ); \
174 sbSEND_COMPLETED( ( pxStreamBuffer ) ); \
178 #define prvSEND_COMPLETED( pxStreamBuffer ) sbSEND_COMPLETED( ( pxStreamBuffer ) ) argument
183 #define sbSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ) \ argument
189 if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL ) \
191 ( void ) xTaskNotifyIndexedFromISR( ( pxStreamBuffer )->xTaskWaitingToReceive, \
192 ( pxStreamBuffer )->uxNotificationIndex, \
196 ( pxStreamBuffer )->xTaskWaitingToReceive = NULL; \
205 …#define prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ) … argument
207 …if( ( pxStreamBuffer )->pxSendCompletedCallback != NULL ) …
209 …( pxStreamBuffer )->pxSendCompletedCallback( ( pxStreamBuffer ), pdTRUE, ( pxHigherPriorityTaskWok…
213 …sbSEND_COMPLETE_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) ); …
217 #define prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ) \ argument
218 sbSEND_COMPLETE_FROM_ISR( ( pxStreamBuffer ), ( pxHigherPriorityTaskWoken ) )
257 static size_t prvBytesInBuffer( const StreamBuffer_t * const pxStreamBuffer ) PRIVILEGED_FUNCTION;
270 static size_t prvWriteBytesToBuffer( StreamBuffer_t * const pxStreamBuffer,
282 static size_t prvReadMessageFromBuffer( StreamBuffer_t * pxStreamBuffer,
294 static size_t prvWriteMessageToBuffer( StreamBuffer_t * const pxStreamBuffer,
312 static size_t prvReadBytesFromBuffer( StreamBuffer_t * pxStreamBuffer,
321 static void prvInitialiseNewStreamBuffer( StreamBuffer_t * const pxStreamBuffer,
438 StreamBuffer_t * const pxStreamBuffer = ( StreamBuffer_t * ) pxStaticStreamBuffer; in xStreamBufferGenericCreateStatic() local
490 prvInitialiseNewStreamBuffer( pxStreamBuffer, in xStreamBufferGenericCreateStatic()
500 pxStreamBuffer->ucFlags |= sbFLAGS_IS_STATICALLY_ALLOCATED; in xStreamBufferGenericCreateStatic()
502 traceSTREAM_BUFFER_CREATE( pxStreamBuffer, xStreamBufferType ); in xStreamBufferGenericCreateStatic()
528 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferGetStaticBuffers() local
532 configASSERT( pxStreamBuffer ); in xStreamBufferGetStaticBuffers()
536 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) != ( uint8_t ) 0 ) in xStreamBufferGetStaticBuffers()
538 *ppucStreamBufferStorageArea = pxStreamBuffer->pucBuffer; in xStreamBufferGetStaticBuffers()
542 *ppxStaticStreamBuffer = ( StaticStreamBuffer_t * ) pxStreamBuffer; in xStreamBufferGetStaticBuffers()
559 StreamBuffer_t * pxStreamBuffer = xStreamBuffer; in vStreamBufferDelete() local
563 configASSERT( pxStreamBuffer ); in vStreamBufferDelete()
567 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_STATICALLY_ALLOCATED ) == ( uint8_t ) pdFALSE ) in vStreamBufferDelete()
573 vPortFree( ( void * ) pxStreamBuffer ); in vStreamBufferDelete()
587 ( void ) memset( pxStreamBuffer, 0x00, sizeof( StreamBuffer_t ) ); in vStreamBufferDelete()
596 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReset() local
606 configASSERT( pxStreamBuffer ); in xStreamBufferReset()
612 uxStreamBufferNumber = pxStreamBuffer->uxStreamBufferNumber; in xStreamBufferReset()
619 …if( ( pxStreamBuffer->xTaskWaitingToReceive == NULL ) && ( pxStreamBuffer->xTaskWaitingToSend == N… in xStreamBufferReset()
623 pxSendCallback = pxStreamBuffer->pxSendCompletedCallback; in xStreamBufferReset()
624 pxReceiveCallback = pxStreamBuffer->pxReceiveCompletedCallback; in xStreamBufferReset()
628 prvInitialiseNewStreamBuffer( pxStreamBuffer, in xStreamBufferReset()
629 pxStreamBuffer->pucBuffer, in xStreamBufferReset()
630 pxStreamBuffer->xLength, in xStreamBufferReset()
631 pxStreamBuffer->xTriggerLevelBytes, in xStreamBufferReset()
632 pxStreamBuffer->ucFlags, in xStreamBufferReset()
638 pxStreamBuffer->uxStreamBufferNumber = uxStreamBufferNumber; in xStreamBufferReset()
657 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferResetFromISR() local
668 configASSERT( pxStreamBuffer ); in xStreamBufferResetFromISR()
674 uxStreamBufferNumber = pxStreamBuffer->uxStreamBufferNumber; in xStreamBufferResetFromISR()
684 …if( ( pxStreamBuffer->xTaskWaitingToReceive == NULL ) && ( pxStreamBuffer->xTaskWaitingToSend == N… in xStreamBufferResetFromISR()
688 pxSendCallback = pxStreamBuffer->pxSendCompletedCallback; in xStreamBufferResetFromISR()
689 pxReceiveCallback = pxStreamBuffer->pxReceiveCompletedCallback; in xStreamBufferResetFromISR()
693 prvInitialiseNewStreamBuffer( pxStreamBuffer, in xStreamBufferResetFromISR()
694 pxStreamBuffer->pucBuffer, in xStreamBufferResetFromISR()
695 pxStreamBuffer->xLength, in xStreamBufferResetFromISR()
696 pxStreamBuffer->xTriggerLevelBytes, in xStreamBufferResetFromISR()
697 pxStreamBuffer->ucFlags, in xStreamBufferResetFromISR()
703 pxStreamBuffer->uxStreamBufferNumber = uxStreamBufferNumber; in xStreamBufferResetFromISR()
723 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSetTriggerLevel() local
728 configASSERT( pxStreamBuffer ); in xStreamBufferSetTriggerLevel()
738 if( xTriggerLevel < pxStreamBuffer->xLength ) in xStreamBufferSetTriggerLevel()
740 pxStreamBuffer->xTriggerLevelBytes = xTriggerLevel; in xStreamBufferSetTriggerLevel()
756 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSpacesAvailable() local
762 configASSERT( pxStreamBuffer ); in xStreamBufferSpacesAvailable()
769 xOriginalTail = pxStreamBuffer->xTail; in xStreamBufferSpacesAvailable()
770 xSpace = pxStreamBuffer->xLength + pxStreamBuffer->xTail; in xStreamBufferSpacesAvailable()
771 xSpace -= pxStreamBuffer->xHead; in xStreamBufferSpacesAvailable()
772 } while( xOriginalTail != pxStreamBuffer->xTail ); in xStreamBufferSpacesAvailable()
776 if( xSpace >= pxStreamBuffer->xLength ) in xStreamBufferSpacesAvailable()
778 xSpace -= pxStreamBuffer->xLength; in xStreamBufferSpacesAvailable()
793 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferBytesAvailable() local
798 configASSERT( pxStreamBuffer ); in xStreamBufferBytesAvailable()
800 xReturn = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferBytesAvailable()
813 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSend() local
822 configASSERT( pxStreamBuffer ); in xStreamBufferSend()
826 xMaxReportedSpace = pxStreamBuffer->xLength - ( size_t ) 1; in xStreamBufferSend()
832 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferSend()
877 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer ); in xStreamBufferSend()
882 … ( void ) xTaskNotifyStateClearIndexed( NULL, pxStreamBuffer->uxNotificationIndex ); in xStreamBufferSend()
885 configASSERT( pxStreamBuffer->xTaskWaitingToSend == NULL ); in xStreamBufferSend()
886 pxStreamBuffer->xTaskWaitingToSend = xTaskGetCurrentTaskHandle(); in xStreamBufferSend()
897 …( void ) xTaskNotifyWaitIndexed( pxStreamBuffer->uxNotificationIndex, ( uint32_t ) 0, ( uint32_t )… in xStreamBufferSend()
898 pxStreamBuffer->xTaskWaitingToSend = NULL; in xStreamBufferSend()
908 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer ); in xStreamBufferSend()
915 …xReturn = prvWriteMessageToBuffer( pxStreamBuffer, pvTxData, xDataLengthBytes, xSpace, xRequiredSp… in xStreamBufferSend()
922 if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes ) in xStreamBufferSend()
924 prvSEND_COMPLETED( pxStreamBuffer ); in xStreamBufferSend()
948 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSendFromISR() local
955 configASSERT( pxStreamBuffer ); in xStreamBufferSendFromISR()
961 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferSendFromISR()
970 xSpace = xStreamBufferSpacesAvailable( pxStreamBuffer ); in xStreamBufferSendFromISR()
971 …xReturn = prvWriteMessageToBuffer( pxStreamBuffer, pvTxData, xDataLengthBytes, xSpace, xRequiredSp… in xStreamBufferSendFromISR()
976 if( prvBytesInBuffer( pxStreamBuffer ) >= pxStreamBuffer->xTriggerLevelBytes ) in xStreamBufferSendFromISR()
981 prvSEND_COMPLETE_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ); in xStreamBufferSendFromISR()
1000 static size_t prvWriteMessageToBuffer( StreamBuffer_t * const pxStreamBuffer, in prvWriteMessageToBuffer() argument
1006 size_t xNextHead = pxStreamBuffer->xHead; in prvWriteMessageToBuffer()
1009 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in prvWriteMessageToBuffer()
1024 …xNextHead = prvWriteBytesToBuffer( pxStreamBuffer, ( const uint8_t * ) &( xMessageLength ), sbBYTE… in prvWriteMessageToBuffer()
1046 …pxStreamBuffer->xHead = prvWriteBytesToBuffer( pxStreamBuffer, ( const uint8_t * ) pvTxData, xData… in prvWriteMessageToBuffer()
1058 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReceive() local
1064 configASSERT( pxStreamBuffer ); in xStreamBufferReceive()
1071 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferReceive()
1075 else if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_BATCHING_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferReceive()
1079 xBytesToStoreMessageLength = pxStreamBuffer->xTriggerLevelBytes; in xStreamBufferReceive()
1092 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceive()
1104 ( void ) xTaskNotifyStateClearIndexed( NULL, pxStreamBuffer->uxNotificationIndex ); in xStreamBufferReceive()
1107 configASSERT( pxStreamBuffer->xTaskWaitingToReceive == NULL ); in xStreamBufferReceive()
1108 pxStreamBuffer->xTaskWaitingToReceive = xTaskGetCurrentTaskHandle(); in xStreamBufferReceive()
1121 …( void ) xTaskNotifyWaitIndexed( pxStreamBuffer->uxNotificationIndex, ( uint32_t ) 0, ( uint32_t )… in xStreamBufferReceive()
1122 pxStreamBuffer->xTaskWaitingToReceive = NULL; in xStreamBufferReceive()
1125 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceive()
1134 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceive()
1144 …xReceivedLength = prvReadMessageFromBuffer( pxStreamBuffer, pvRxData, xBufferLengthBytes, xBytesAv… in xStreamBufferReceive()
1171 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferNextMessageLengthBytes() local
1177 configASSERT( pxStreamBuffer ); in xStreamBufferNextMessageLengthBytes()
1180 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferNextMessageLengthBytes()
1182 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferNextMessageLengthBytes()
1189 …void ) prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) &xTempReturn, sbBYTES_TO_STORE_MESSAG… in xStreamBufferNextMessageLengthBytes()
1218 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReceiveFromISR() local
1224 configASSERT( pxStreamBuffer ); in xStreamBufferReceiveFromISR()
1231 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferReceiveFromISR()
1240 xBytesAvailable = prvBytesInBuffer( pxStreamBuffer ); in xStreamBufferReceiveFromISR()
1249 …xReceivedLength = prvReadMessageFromBuffer( pxStreamBuffer, pvRxData, xBufferLengthBytes, xBytesAv… in xStreamBufferReceiveFromISR()
1257 prvRECEIVE_COMPLETED_FROM_ISR( pxStreamBuffer, pxHigherPriorityTaskWoken ); in xStreamBufferReceiveFromISR()
1276 static size_t prvReadMessageFromBuffer( StreamBuffer_t * pxStreamBuffer, in prvReadMessageFromBuffer() argument
1283 size_t xNextTail = pxStreamBuffer->xTail; in prvReadMessageFromBuffer()
1285 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in prvReadMessageFromBuffer()
1289 …xNextTail = prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) &xTempNextMessageLength, sbBYTES… in prvReadMessageFromBuffer()
1324 …pxStreamBuffer->xTail = prvReadBytesFromBuffer( pxStreamBuffer, ( uint8_t * ) pvRxData, xCount, xN… in prvReadMessageFromBuffer()
1333 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferIsEmpty() local
1339 configASSERT( pxStreamBuffer ); in xStreamBufferIsEmpty()
1342 xTail = pxStreamBuffer->xTail; in xStreamBufferIsEmpty()
1344 if( pxStreamBuffer->xHead == xTail ) in xStreamBufferIsEmpty()
1363 const StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferIsFull() local
1367 configASSERT( pxStreamBuffer ); in xStreamBufferIsFull()
1373 if( ( pxStreamBuffer->ucFlags & sbFLAGS_IS_MESSAGE_BUFFER ) != ( uint8_t ) 0 ) in xStreamBufferIsFull()
1401 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferSendCompletedFromISR() local
1407 configASSERT( pxStreamBuffer ); in xStreamBufferSendCompletedFromISR()
1414 if( ( pxStreamBuffer )->xTaskWaitingToReceive != NULL ) in xStreamBufferSendCompletedFromISR()
1416 ( void ) xTaskNotifyIndexedFromISR( ( pxStreamBuffer )->xTaskWaitingToReceive, in xStreamBufferSendCompletedFromISR()
1417 ( pxStreamBuffer )->uxNotificationIndex, in xStreamBufferSendCompletedFromISR()
1421 ( pxStreamBuffer )->xTaskWaitingToReceive = NULL; in xStreamBufferSendCompletedFromISR()
1440 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in xStreamBufferReceiveCompletedFromISR() local
1446 configASSERT( pxStreamBuffer ); in xStreamBufferReceiveCompletedFromISR()
1453 if( ( pxStreamBuffer )->xTaskWaitingToSend != NULL ) in xStreamBufferReceiveCompletedFromISR()
1455 ( void ) xTaskNotifyIndexedFromISR( ( pxStreamBuffer )->xTaskWaitingToSend, in xStreamBufferReceiveCompletedFromISR()
1456 ( pxStreamBuffer )->uxNotificationIndex, in xStreamBufferReceiveCompletedFromISR()
1460 ( pxStreamBuffer )->xTaskWaitingToSend = NULL; in xStreamBufferReceiveCompletedFromISR()
1476 static size_t prvWriteBytesToBuffer( StreamBuffer_t * const pxStreamBuffer, in prvWriteBytesToBuffer() argument
1488 xFirstLength = configMIN( pxStreamBuffer->xLength - xHead, xCount ); in prvWriteBytesToBuffer()
1491 configASSERT( ( xHead + xFirstLength ) <= pxStreamBuffer->xLength ); in prvWriteBytesToBuffer()
1492 …( void ) memcpy( ( void * ) ( &( pxStreamBuffer->pucBuffer[ xHead ] ) ), ( const void * ) pucData,… in prvWriteBytesToBuffer()
1499 configASSERT( ( xCount - xFirstLength ) <= pxStreamBuffer->xLength ); in prvWriteBytesToBuffer()
1500 …( void ) memcpy( ( void * ) pxStreamBuffer->pucBuffer, ( const void * ) &( pucData[ xFirstLength ]… in prvWriteBytesToBuffer()
1509 if( xHead >= pxStreamBuffer->xLength ) in prvWriteBytesToBuffer()
1511 xHead -= pxStreamBuffer->xLength; in prvWriteBytesToBuffer()
1522 static size_t prvReadBytesFromBuffer( StreamBuffer_t * pxStreamBuffer, in prvReadBytesFromBuffer() argument
1534 xFirstLength = configMIN( pxStreamBuffer->xLength - xTail, xCount ); in prvReadBytesFromBuffer()
1539 configASSERT( ( xTail + xFirstLength ) <= pxStreamBuffer->xLength ); in prvReadBytesFromBuffer()
1540 …( void ) memcpy( ( void * ) pucData, ( const void * ) &( pxStreamBuffer->pucBuffer[ xTail ] ), xFi… in prvReadBytesFromBuffer()
1547 …( void ) memcpy( ( void * ) &( pucData[ xFirstLength ] ), ( void * ) ( pxStreamBuffer->pucBuffer )… in prvReadBytesFromBuffer()
1557 if( xTail >= pxStreamBuffer->xLength ) in prvReadBytesFromBuffer()
1559 xTail -= pxStreamBuffer->xLength; in prvReadBytesFromBuffer()
1566 static size_t prvBytesInBuffer( const StreamBuffer_t * const pxStreamBuffer ) in prvBytesInBuffer() argument
1571 xCount = pxStreamBuffer->xLength + pxStreamBuffer->xHead; in prvBytesInBuffer()
1572 xCount -= pxStreamBuffer->xTail; in prvBytesInBuffer()
1574 if( xCount >= pxStreamBuffer->xLength ) in prvBytesInBuffer()
1576 xCount -= pxStreamBuffer->xLength; in prvBytesInBuffer()
1587 static void prvInitialiseNewStreamBuffer( StreamBuffer_t * const pxStreamBuffer, in prvInitialiseNewStreamBuffer() argument
1608 ( void ) memset( ( void * ) pxStreamBuffer, 0x00, sizeof( StreamBuffer_t ) ); in prvInitialiseNewStreamBuffer()
1609 pxStreamBuffer->pucBuffer = pucBuffer; in prvInitialiseNewStreamBuffer()
1610 pxStreamBuffer->xLength = xBufferSizeBytes; in prvInitialiseNewStreamBuffer()
1611 pxStreamBuffer->xTriggerLevelBytes = xTriggerLevelBytes; in prvInitialiseNewStreamBuffer()
1612 pxStreamBuffer->ucFlags = ucFlags; in prvInitialiseNewStreamBuffer()
1613 pxStreamBuffer->uxNotificationIndex = tskDEFAULT_INDEX_TO_NOTIFY; in prvInitialiseNewStreamBuffer()
1616 pxStreamBuffer->pxSendCompletedCallback = pxSendCompletedCallback; in prvInitialiseNewStreamBuffer()
1617 pxStreamBuffer->pxReceiveCompletedCallback = pxReceiveCompletedCallback; in prvInitialiseNewStreamBuffer()
1637 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in uxStreamBufferGetStreamBufferNotificationIndex() local
1641 configASSERT( pxStreamBuffer ); in uxStreamBufferGetStreamBufferNotificationIndex()
1643 … traceRETURN_uxStreamBufferGetStreamBufferNotificationIndex( pxStreamBuffer->uxNotificationIndex ); in uxStreamBufferGetStreamBufferNotificationIndex()
1645 return pxStreamBuffer->uxNotificationIndex; in uxStreamBufferGetStreamBufferNotificationIndex()
1652 StreamBuffer_t * const pxStreamBuffer = xStreamBuffer; in vStreamBufferSetStreamBufferNotificationIndex() local
1656 configASSERT( pxStreamBuffer ); in vStreamBufferSetStreamBufferNotificationIndex()
1659 configASSERT( pxStreamBuffer->xTaskWaitingToReceive == NULL ); in vStreamBufferSetStreamBufferNotificationIndex()
1660 configASSERT( pxStreamBuffer->xTaskWaitingToSend == NULL ); in vStreamBufferSetStreamBufferNotificationIndex()
1665 pxStreamBuffer->uxNotificationIndex = uxNotificationIndex; in vStreamBufferSetStreamBufferNotificationIndex()