ucStreamBufferGetStreamBufferType (struct StreamBufferDef_t * xStreamBuffer) { uint8_t D.6587; unsigned char _1; uint8_t _4; : _1 = xStreamBuffer_3(D)->ucFlags; _4 = _1 & 1; : : return _4; } vStreamBufferSetStreamBufferNumber (struct StreamBufferDef_t * xStreamBuffer, UBaseType_t uxStreamBufferNumber) { : xStreamBuffer_2(D)->uxStreamBufferNumber = uxStreamBufferNumber_3(D); return; } uxStreamBufferGetStreamBufferNumber (struct StreamBufferDef_t * xStreamBuffer) { UBaseType_t D.6585; UBaseType_t _3; : _3 = xStreamBuffer_2(D)->uxStreamBufferNumber; : : return _3; } prvInitialiseNewStreamBuffer (struct StreamBuffer_t * const pxStreamBuffer, uint8_t * const pucBuffer, size_t xBufferSizeBytes, size_t xTriggerLevelBytes, uint8_t ucFlags) { const BaseType_t xWriteValue; void * _1; : xWriteValue_2 = 85; _1 = memset (pucBuffer_4(D), xWriteValue_2, xBufferSizeBytes_5(D)); if (pucBuffer_4(D) != _1) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : memset (pxStreamBuffer_7(D), 0, 36); pxStreamBuffer_7(D)->pucBuffer = pucBuffer_4(D); pxStreamBuffer_7(D)->xLength = xBufferSizeBytes_5(D); pxStreamBuffer_7(D)->xTriggerLevelBytes = xTriggerLevelBytes_11(D); pxStreamBuffer_7(D)->ucFlags = ucFlags_13(D); return; } prvBytesInBuffer (const struct StreamBuffer_t * const pxStreamBuffer) { size_t xCount; size_t D.6581; unsigned int D.6577; unsigned int _1; unsigned int _2; unsigned int _3; unsigned int _4; unsigned int _9; size_t _12; : _1 = pxStreamBuffer_7(D)->xLength; _2 ={v} pxStreamBuffer_7(D)->xHead; xCount_8 = _1 + _2; _9 ={v} pxStreamBuffer_7(D)->xTail; xCount_10 = xCount_8 - _9; _3 = pxStreamBuffer_7(D)->xLength; if (xCount_10 >= _3) goto ; [INV] else goto ; [INV] : _4 = pxStreamBuffer_7(D)->xLength; xCount_11 = xCount_10 - _4; : # xCount_5 = PHI _12 = xCount_5; : : return _12; } prvReadBytesFromBuffer (struct StreamBuffer_t * pxStreamBuffer, uint8_t * pucData, size_t xCount, size_t xTail) { size_t xFirstLength; size_t D.6575; unsigned int _1; unsigned int _2; unsigned int _3; unsigned int _4; uint8_t * _5; uint8_t * _6; uint8_t * _7; uint8_t * _8; unsigned int _9; unsigned int _10; unsigned int _11; size_t _24; : if (xCount_14(D) == 0) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_16(D)->xLength; _2 = _1 - xTail_17(D); xFirstLength_18 = MIN_EXPR ; if (xFirstLength_18 > xCount_14(D)) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _3 = xTail_17(D) + xFirstLength_18; _4 = pxStreamBuffer_16(D)->xLength; if (_3 > _4) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _5 = pxStreamBuffer_16(D)->pucBuffer; _6 = _5 + xTail_17(D); memcpy (pucData_19(D), _6, xFirstLength_18); if (xCount_14(D) > xFirstLength_18) goto ; [INV] else goto ; [INV] : _7 = pucData_19(D) + xFirstLength_18; _8 = pxStreamBuffer_16(D)->pucBuffer; _9 = xCount_14(D) - xFirstLength_18; memcpy (_7, _8, _9); : xTail_22 = xTail_17(D) + xCount_14(D); _10 = pxStreamBuffer_16(D)->xLength; if (xTail_22 >= _10) goto ; [INV] else goto ; [INV] : _11 = pxStreamBuffer_16(D)->xLength; xTail_23 = xTail_22 - _11; : # xTail_12 = PHI _24 = xTail_12; : : return _24; } prvWriteBytesToBuffer (struct StreamBuffer_t * const pxStreamBuffer, const uint8_t * pucData, size_t xCount, size_t xHead) { size_t xFirstLength; size_t D.6562; unsigned int _1; unsigned int _2; unsigned int _3; unsigned int _4; uint8_t * _5; uint8_t * _6; unsigned int _7; unsigned int _8; uint8_t * _9; const uint8_t * _10; unsigned int _11; unsigned int _12; unsigned int _13; size_t _27; : if (xCount_16(D) == 0) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_18(D)->xLength; _2 = _1 - xHead_19(D); xFirstLength_20 = MIN_EXPR ; _3 = xHead_19(D) + xFirstLength_20; _4 = pxStreamBuffer_18(D)->xLength; if (_3 > _4) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _5 = pxStreamBuffer_18(D)->pucBuffer; _6 = _5 + xHead_19(D); memcpy (_6, pucData_21(D), xFirstLength_20); if (xCount_16(D) > xFirstLength_20) goto ; [INV] else goto ; [INV] : _7 = xCount_16(D) - xFirstLength_20; _8 = pxStreamBuffer_18(D)->xLength; if (_7 > _8) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _9 = pxStreamBuffer_18(D)->pucBuffer; _10 = pucData_21(D) + xFirstLength_20; _11 = xCount_16(D) - xFirstLength_20; memcpy (_9, _10, _11); : xHead_25 = xHead_19(D) + xCount_16(D); _12 = pxStreamBuffer_18(D)->xLength; if (xHead_25 >= _12) goto ; [INV] else goto ; [INV] : _13 = pxStreamBuffer_18(D)->xLength; xHead_26 = xHead_25 - _13; : # xHead_14 = PHI _27 = xHead_14; : : return _27; } xStreamBufferReceiveCompletedFromISR (struct StreamBufferDef_t * xStreamBuffer, BaseType_t * pxHigherPriorityTaskWoken) { UBaseType_t uxSavedInterruptStatus; BaseType_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; BaseType_t D.6548; struct tskTaskControlBlock * _1; struct tskTaskControlBlock * _2; BaseType_t _16; : pxStreamBuffer_6 = xStreamBuffer_5(D); if (pxStreamBuffer_6 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : uxSavedInterruptStatus_9 = ulPortRaiseBASEPRI (); _1 ={v} pxStreamBuffer_6->xTaskWaitingToSend; if (_1 != 0B) goto ; [INV] else goto ; [INV] : _2 ={v} pxStreamBuffer_6->xTaskWaitingToSend; xTaskGenericNotifyFromISR (_2, 0, 0, 0, 0B, pxHigherPriorityTaskWoken_11(D)); pxStreamBuffer_6->xTaskWaitingToSend ={v} 0B; xReturn_14 = 1; goto ; [INV] : xReturn_10 = 0; : # xReturn_3 = PHI vPortSetBASEPRI (uxSavedInterruptStatus_9); _16 = xReturn_3; : : return _16; } xStreamBufferSendCompletedFromISR (struct StreamBufferDef_t * xStreamBuffer, BaseType_t * pxHigherPriorityTaskWoken) { UBaseType_t uxSavedInterruptStatus; BaseType_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; BaseType_t D.6541; struct tskTaskControlBlock * _1; struct tskTaskControlBlock * _2; BaseType_t _16; : pxStreamBuffer_6 = xStreamBuffer_5(D); if (pxStreamBuffer_6 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : uxSavedInterruptStatus_9 = ulPortRaiseBASEPRI (); _1 ={v} pxStreamBuffer_6->xTaskWaitingToReceive; if (_1 != 0B) goto ; [INV] else goto ; [INV] : _2 ={v} pxStreamBuffer_6->xTaskWaitingToReceive; xTaskGenericNotifyFromISR (_2, 0, 0, 0, 0B, pxHigherPriorityTaskWoken_11(D)); pxStreamBuffer_6->xTaskWaitingToReceive ={v} 0B; xReturn_14 = 1; goto ; [INV] : xReturn_10 = 0; : # xReturn_3 = PHI vPortSetBASEPRI (uxSavedInterruptStatus_9); _16 = xReturn_3; : : return _16; } xStreamBufferIsFull (struct StreamBufferDef_t * xStreamBuffer) { const struct StreamBuffer_t * const pxStreamBuffer; size_t xBytesToStoreMessageLength; BaseType_t xReturn; BaseType_t D.6534; unsigned char _1; int _2; int _3; unsigned int _4; BaseType_t _15; : pxStreamBuffer_8 = xStreamBuffer_7(D); if (pxStreamBuffer_8 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_8->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : xBytesToStoreMessageLength_11 = 4; goto ; [INV] : xBytesToStoreMessageLength_10 = 0; : # xBytesToStoreMessageLength_6 = PHI _4 = xStreamBufferSpacesAvailable (xStreamBuffer_7(D)); if (xBytesToStoreMessageLength_6 >= _4) goto ; [INV] else goto ; [INV] : xReturn_14 = 1; goto ; [INV] : xReturn_13 = 0; : # xReturn_5 = PHI _15 = xReturn_5; : : return _15; } xStreamBufferIsEmpty (struct StreamBufferDef_t * xStreamBuffer) { size_t xTail; BaseType_t xReturn; const struct StreamBuffer_t * const pxStreamBuffer; BaseType_t D.6524; unsigned int _1; BaseType_t _9; : pxStreamBuffer_4 = xStreamBuffer_3(D); if (pxStreamBuffer_4 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : xTail_6 ={v} pxStreamBuffer_4->xTail; _1 ={v} pxStreamBuffer_4->xHead; if (xTail_6 == _1) goto ; [INV] else goto ; [INV] : xReturn_8 = 1; goto ; [INV] : xReturn_7 = 0; : # xReturn_2 = PHI _9 = xReturn_2; : : return _9; } prvReadMessageFromBuffer (struct StreamBuffer_t * pxStreamBuffer, void * pvRxData, size_t xBufferLengthBytes, size_t xBytesAvailable) { size_t xNextTail; size_t xTempNextMessageLength; size_t xNextMessageLength; size_t xCount; size_t D.6516; unsigned char _1; int _2; int _3; unsigned int _4; size_t _25; : xNextTail_12 ={v} pxStreamBuffer_11(D)->xTail; _1 = pxStreamBuffer_11(D)->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : xNextTail_17 = prvReadBytesFromBuffer (pxStreamBuffer_11(D), &xTempNextMessageLength, 4, xNextTail_12); xNextMessageLength_18 = xTempNextMessageLength; xBytesAvailable_19 = xBytesAvailable_15(D) + 4294967292; if (xNextMessageLength_18 > xBufferLengthBytes_13(D)) goto ; [INV] else goto ; [INV] : xNextMessageLength_20 = 0; goto ; [INV] : xNextMessageLength_14 = xBufferLengthBytes_13(D); : # xBytesAvailable_5 = PHI # xNextMessageLength_6 = PHI # xNextTail_7 = PHI xCount_21 = MIN_EXPR ; if (xCount_21 != 0) goto ; [INV] else goto ; [INV] : _4 = prvReadBytesFromBuffer (pxStreamBuffer_11(D), pvRxData_22(D), xCount_21, xNextTail_7); pxStreamBuffer_11(D)->xTail ={v} _4; : _25 = xCount_21; xTempNextMessageLength ={v} {CLOBBER}; : : return _25; } xStreamBufferReceiveFromISR (struct StreamBufferDef_t * xStreamBuffer, void * pvRxData, size_t xBufferLengthBytes, BaseType_t * const pxHigherPriorityTaskWoken) { UBaseType_t uxSavedInterruptStatus; size_t xBytesToStoreMessageLength; size_t xBytesAvailable; size_t xReceivedLength; struct StreamBuffer_t * const pxStreamBuffer; size_t D.6506; unsigned char _1; int _2; int _3; struct tskTaskControlBlock * _4; struct tskTaskControlBlock * _5; size_t _28; : pxStreamBuffer_11 = xStreamBuffer_10(D); xReceivedLength_12 = 0; if (pvRxData_13(D) == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (pxStreamBuffer_11 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_11->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : xBytesToStoreMessageLength_16 = 4; goto ; [INV] : xBytesToStoreMessageLength_15 = 0; : # xBytesToStoreMessageLength_7 = PHI xBytesAvailable_18 = prvBytesInBuffer (pxStreamBuffer_11); if (xBytesAvailable_18 > xBytesToStoreMessageLength_7) goto ; [INV] else goto ; [INV] : xReceivedLength_21 = prvReadMessageFromBuffer (pxStreamBuffer_11, pvRxData_13(D), xBufferLengthBytes_19(D), xBytesAvailable_18); if (xReceivedLength_21 != 0) goto ; [INV] else goto ; [INV] : uxSavedInterruptStatus_23 = ulPortRaiseBASEPRI (); _4 ={v} pxStreamBuffer_11->xTaskWaitingToSend; if (_4 != 0B) goto ; [INV] else goto ; [INV] : _5 ={v} pxStreamBuffer_11->xTaskWaitingToSend; xTaskGenericNotifyFromISR (_5, 0, 0, 0, 0B, pxHigherPriorityTaskWoken_24(D)); pxStreamBuffer_11->xTaskWaitingToSend ={v} 0B; : vPortSetBASEPRI (uxSavedInterruptStatus_23); : # xReceivedLength_6 = PHI _28 = xReceivedLength_6; : : return _28; } xStreamBufferNextMessageLengthBytes (struct StreamBufferDef_t * xStreamBuffer) { size_t xTempReturn; size_t xBytesAvailable; size_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; size_t D.6488; unsigned char _1; int _2; int _3; unsigned int _4; size_t _17; : pxStreamBuffer_8 = xStreamBuffer_7(D); if (pxStreamBuffer_8 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_8->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : xBytesAvailable_12 = prvBytesInBuffer (pxStreamBuffer_8); if (xBytesAvailable_12 > 4) goto ; [INV] else goto ; [INV] : _4 ={v} pxStreamBuffer_8->xTail; prvReadBytesFromBuffer (pxStreamBuffer_8, &xTempReturn, 4, _4); xReturn_16 = xTempReturn; goto ; [INV] : if (xBytesAvailable_12 != 0) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : xReturn_13 = 0; goto ; [INV] : xReturn_10 = 0; : # xReturn_5 = PHI _17 = xReturn_5; xTempReturn ={v} {CLOBBER}; : : return _17; } xStreamBufferReceive (struct StreamBufferDef_t * xStreamBuffer, void * pvRxData, size_t xBufferLengthBytes, TickType_t xTicksToWait) { size_t xBytesToStoreMessageLength; size_t xBytesAvailable; size_t xReceivedLength; struct StreamBuffer_t * const pxStreamBuffer; size_t D.6476; unsigned char _1; int _2; int _3; struct tskTaskControlBlock * _4; struct tskTaskControlBlock * _5; struct tskTaskControlBlock * _6; struct tskTaskControlBlock * _7; size_t _44; : pxStreamBuffer_16 = xStreamBuffer_15(D); xReceivedLength_17 = 0; if (pvRxData_18(D) == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (pxStreamBuffer_16 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_16->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : xBytesToStoreMessageLength_21 = 4; goto ; [INV] : xBytesToStoreMessageLength_20 = 0; : # xBytesToStoreMessageLength_10 = PHI if (xTicksToWait_22(D) != 0) goto ; [INV] else goto ; [INV] : vPortEnterCritical (); xBytesAvailable_27 = prvBytesInBuffer (pxStreamBuffer_16); if (xBytesAvailable_27 <= xBytesToStoreMessageLength_10) goto ; [INV] else goto ; [INV] : xTaskGenericNotifyStateClear (0B, 0); _4 ={v} pxStreamBuffer_16->xTaskWaitingToReceive; if (_4 != 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _5 = xTaskGetCurrentTaskHandle (); pxStreamBuffer_16->xTaskWaitingToReceive ={v} _5; : vPortExitCritical (); if (xBytesAvailable_27 <= xBytesToStoreMessageLength_10) goto ; [INV] else goto ; [INV] : xTaskGenericNotifyWait (0, 0, 0, 0B, xTicksToWait_22(D)); pxStreamBuffer_16->xTaskWaitingToReceive ={v} 0B; xBytesAvailable_36 = prvBytesInBuffer (pxStreamBuffer_16); goto ; [INV] : xBytesAvailable_24 = prvBytesInBuffer (pxStreamBuffer_16); : # xBytesAvailable_9 = PHI if (xBytesAvailable_9 > xBytesToStoreMessageLength_10) goto ; [INV] else goto ; [INV] : xReceivedLength_39 = prvReadMessageFromBuffer (pxStreamBuffer_16, pvRxData_18(D), xBufferLengthBytes_37(D), xBytesAvailable_9); if (xReceivedLength_39 != 0) goto ; [INV] else goto ; [INV] : vTaskSuspendAll (); _6 ={v} pxStreamBuffer_16->xTaskWaitingToSend; if (_6 != 0B) goto ; [INV] else goto ; [INV] : _7 ={v} pxStreamBuffer_16->xTaskWaitingToSend; xTaskGenericNotify (_7, 0, 0, 0, 0B); pxStreamBuffer_16->xTaskWaitingToSend ={v} 0B; : xTaskResumeAll (); : # xReceivedLength_8 = PHI _44 = xReceivedLength_8; : : return _44; } prvWriteMessageToBuffer (struct StreamBuffer_t * const pxStreamBuffer, const void * pvTxData, size_t xDataLengthBytes, size_t xSpace, size_t xRequiredSpace) { size_t xNextHead; size_t D.6448; unsigned char _1; int _2; int _3; unsigned int xDataLengthBytes.2_4; unsigned int _5; unsigned int xDataLengthBytes.3_6; unsigned int xDataLengthBytes.4_7; unsigned int _8; size_t _24; : xNextHead_14 ={v} pxStreamBuffer_13(D)->xHead; _1 = pxStreamBuffer_13(D)->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : if (xSpace_15(D) >= xRequiredSpace_17(D)) goto ; [INV] else goto ; [INV] : xNextHead_20 = prvWriteBytesToBuffer (pxStreamBuffer_13(D), &xDataLengthBytes, 4, xNextHead_14); goto ; [INV] : xDataLengthBytes = 0; goto ; [INV] : xDataLengthBytes.2_4 = xDataLengthBytes; _5 = MIN_EXPR ; xDataLengthBytes = _5; : # xNextHead_9 = PHI xDataLengthBytes.3_6 = xDataLengthBytes; if (xDataLengthBytes.3_6 != 0) goto ; [INV] else goto ; [INV] : xDataLengthBytes.4_7 = xDataLengthBytes; _8 = prvWriteBytesToBuffer (pxStreamBuffer_13(D), pvTxData_21(D), xDataLengthBytes.4_7, xNextHead_9); pxStreamBuffer_13(D)->xHead ={v} _8; : _24 = xDataLengthBytes; : : return _24; } xStreamBufferSendFromISR (struct StreamBufferDef_t * xStreamBuffer, const void * pvTxData, size_t xDataLengthBytes, BaseType_t * const pxHigherPriorityTaskWoken) { UBaseType_t uxSavedInterruptStatus; size_t xRequiredSpace; size_t xSpace; size_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; size_t D.6436; unsigned char _1; int _2; int _3; unsigned int _4; unsigned int _5; struct tskTaskControlBlock * _6; struct tskTaskControlBlock * _7; size_t _29; : pxStreamBuffer_12 = xStreamBuffer_11(D); xRequiredSpace_14 = xDataLengthBytes_13(D); if (pvTxData_15(D) == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (pxStreamBuffer_12 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_12->ucFlags; _2 = (int) _1; _3 = _2 & 1; if (_3 != 0) goto ; [INV] else goto ; [INV] : xRequiredSpace_17 = xRequiredSpace_14 + 4; : # xRequiredSpace_8 = PHI xSpace_19 = xStreamBufferSpacesAvailable (pxStreamBuffer_12); xReturn_21 = prvWriteMessageToBuffer (pxStreamBuffer_12, pvTxData_15(D), xDataLengthBytes_13(D), xSpace_19, xRequiredSpace_8); if (xReturn_21 != 0) goto ; [INV] else goto ; [INV] : _4 = prvBytesInBuffer (pxStreamBuffer_12); _5 = pxStreamBuffer_12->xTriggerLevelBytes; if (_4 >= _5) goto ; [INV] else goto ; [INV] : uxSavedInterruptStatus_24 = ulPortRaiseBASEPRI (); _6 ={v} pxStreamBuffer_12->xTaskWaitingToReceive; if (_6 != 0B) goto ; [INV] else goto ; [INV] : _7 ={v} pxStreamBuffer_12->xTaskWaitingToReceive; xTaskGenericNotifyFromISR (_7, 0, 0, 0, 0B, pxHigherPriorityTaskWoken_25(D)); pxStreamBuffer_12->xTaskWaitingToReceive ={v} 0B; : vPortSetBASEPRI (uxSavedInterruptStatus_24); : _29 = xReturn_21; : : return _29; } xStreamBufferSend (struct StreamBufferDef_t * xStreamBuffer, const void * pvTxData, size_t xDataLengthBytes, TickType_t xTicksToWait) { size_t xMaxReportedSpace; struct TimeOut_t xTimeOut; size_t xRequiredSpace; size_t xSpace; size_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; size_t D.6418; unsigned int _1; unsigned char _2; int _3; int _4; long unsigned int xTicksToWait.0_5; struct tskTaskControlBlock * _6; struct tskTaskControlBlock * _7; long unsigned int xTicksToWait.1_8; long int _9; unsigned int _10; unsigned int _11; struct tskTaskControlBlock * _12; struct tskTaskControlBlock * _13; size_t _59; : pxStreamBuffer_25 = xStreamBuffer_24(D); xSpace_26 = 0; xRequiredSpace_28 = xDataLengthBytes_27(D); xMaxReportedSpace_29 = 0; if (pvTxData_30(D) == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (pxStreamBuffer_25 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_25->xLength; xMaxReportedSpace_32 = _1 + 4294967295; _2 = pxStreamBuffer_25->ucFlags; _3 = (int) _2; _4 = _3 & 1; if (_4 != 0) goto ; [INV] else goto ; [INV] : xRequiredSpace_34 = xRequiredSpace_28 + 4; if (xRequiredSpace_34 <= xDataLengthBytes_27(D)) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (xRequiredSpace_34 > xMaxReportedSpace_32) goto ; [INV] else goto ; [INV] : xTicksToWait = 0; goto ; [INV] : if (xRequiredSpace_28 > xMaxReportedSpace_32) goto ; [INV] else goto ; [INV] : xRequiredSpace_33 = xMaxReportedSpace_32; : # xRequiredSpace_16 = PHI xTicksToWait.0_5 = xTicksToWait; if (xTicksToWait.0_5 != 0) goto ; [INV] else goto ; [INV] : vTaskSetTimeOutState (&xTimeOut); : vPortEnterCritical (); xSpace_40 = xStreamBufferSpacesAvailable (pxStreamBuffer_25); if (xSpace_40 < xRequiredSpace_16) goto ; [INV] else goto ; [INV] : xTaskGenericNotifyStateClear (0B, 0); _6 ={v} pxStreamBuffer_25->xTaskWaitingToSend; if (_6 != 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _7 = xTaskGetCurrentTaskHandle (); pxStreamBuffer_25->xTaskWaitingToSend ={v} _7; goto ; [INV] : vPortExitCritical (); goto ; [INV] : vPortExitCritical (); xTicksToWait.1_8 = xTicksToWait; xTaskGenericNotifyWait (0, 0, 0, 0B, xTicksToWait.1_8); pxStreamBuffer_25->xTaskWaitingToSend ={v} 0B; _9 = xTaskCheckForTimeOut (&xTimeOut, &xTicksToWait); if (_9 == 0) goto ; [INV] else goto ; [INV] : : # xSpace_14 = PHI if (xSpace_14 == 0) goto ; [INV] else goto ; [INV] : xSpace_51 = xStreamBufferSpacesAvailable (pxStreamBuffer_25); : # xSpace_15 = PHI xReturn_53 = prvWriteMessageToBuffer (pxStreamBuffer_25, pvTxData_30(D), xDataLengthBytes_27(D), xSpace_15, xRequiredSpace_16); if (xReturn_53 != 0) goto ; [INV] else goto ; [INV] : _10 = prvBytesInBuffer (pxStreamBuffer_25); _11 = pxStreamBuffer_25->xTriggerLevelBytes; if (_10 >= _11) goto ; [INV] else goto ; [INV] : vTaskSuspendAll (); _12 ={v} pxStreamBuffer_25->xTaskWaitingToReceive; if (_12 != 0B) goto ; [INV] else goto ; [INV] : _13 ={v} pxStreamBuffer_25->xTaskWaitingToReceive; xTaskGenericNotify (_13, 0, 0, 0, 0B); pxStreamBuffer_25->xTaskWaitingToReceive ={v} 0B; : xTaskResumeAll (); : _59 = xReturn_53; xTimeOut ={v} {CLOBBER}; : : return _59; } xStreamBufferBytesAvailable (struct StreamBufferDef_t * xStreamBuffer) { size_t xReturn; const struct StreamBuffer_t * const pxStreamBuffer; size_t D.6382; size_t _6; : pxStreamBuffer_2 = xStreamBuffer_1(D); if (pxStreamBuffer_2 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : xReturn_5 = prvBytesInBuffer (pxStreamBuffer_2); _6 = xReturn_5; : : return _6; } xStreamBufferSpacesAvailable (struct StreamBufferDef_t * xStreamBuffer) { size_t xOriginalTail; size_t xSpace; const struct StreamBuffer_t * const pxStreamBuffer; size_t D.6378; unsigned int D.6374; unsigned int _1; unsigned int _2; unsigned int _3; unsigned int _4; unsigned int _5; unsigned int _12; size_t _16; : pxStreamBuffer_8 = xStreamBuffer_7(D); if (pxStreamBuffer_8 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : xOriginalTail_10 ={v} pxStreamBuffer_8->xTail; _1 = pxStreamBuffer_8->xLength; _2 ={v} pxStreamBuffer_8->xTail; xSpace_11 = _1 + _2; _12 ={v} pxStreamBuffer_8->xHead; xSpace_13 = xSpace_11 - _12; _3 ={v} pxStreamBuffer_8->xTail; if (xOriginalTail_10 != _3) goto ; [INV] else goto ; [INV] : xSpace_14 = xSpace_13 + 4294967295; _4 = pxStreamBuffer_8->xLength; if (xSpace_14 >= _4) goto ; [INV] else goto ; [INV] : _5 = pxStreamBuffer_8->xLength; xSpace_15 = xSpace_14 - _5; : # xSpace_6 = PHI _16 = xSpace_6; : : return _16; } xStreamBufferSetTriggerLevel (struct StreamBufferDef_t * xStreamBuffer, size_t xTriggerLevel) { BaseType_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; BaseType_t D.6370; unsigned int _1; BaseType_t _13; : pxStreamBuffer_6 = xStreamBuffer_5(D); if (pxStreamBuffer_6 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (xTriggerLevel_7(D) == 0) goto ; [INV] else goto ; [INV] : xTriggerLevel_8 = 1; : # xTriggerLevel_2 = PHI _1 = pxStreamBuffer_6->xLength; if (xTriggerLevel_2 < _1) goto ; [INV] else goto ; [INV] : pxStreamBuffer_6->xTriggerLevelBytes = xTriggerLevel_2; xReturn_12 = 1; goto ; [INV] : xReturn_10 = 0; : # xReturn_3 = PHI _13 = xReturn_3; : : return _13; } xStreamBufferReset (struct StreamBufferDef_t * xStreamBuffer) { UBaseType_t uxStreamBufferNumber; BaseType_t xReturn; struct StreamBuffer_t * const pxStreamBuffer; BaseType_t D.6361; struct tskTaskControlBlock * _1; struct tskTaskControlBlock * _2; uint8_t * _3; unsigned int _4; unsigned int _5; unsigned char _6; BaseType_t _19; : pxStreamBuffer_10 = xStreamBuffer_9(D); xReturn_11 = 0; if (pxStreamBuffer_10 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : uxStreamBufferNumber_13 = pxStreamBuffer_10->uxStreamBufferNumber; vPortEnterCritical (); _1 ={v} pxStreamBuffer_10->xTaskWaitingToReceive; if (_1 == 0B) goto ; [INV] else goto ; [INV] : _2 ={v} pxStreamBuffer_10->xTaskWaitingToSend; if (_2 == 0B) goto ; [INV] else goto ; [INV] : _3 = pxStreamBuffer_10->pucBuffer; _4 = pxStreamBuffer_10->xLength; _5 = pxStreamBuffer_10->xTriggerLevelBytes; _6 = pxStreamBuffer_10->ucFlags; prvInitialiseNewStreamBuffer (pxStreamBuffer_10, _3, _4, _5, _6); xReturn_16 = 1; pxStreamBuffer_10->uxStreamBufferNumber = uxStreamBufferNumber_13; : # xReturn_7 = PHI vPortExitCritical (); _19 = xReturn_7; : : return _19; } vStreamBufferDelete (struct StreamBufferDef_t * xStreamBuffer) { struct StreamBuffer_t * pxStreamBuffer; unsigned char _1; int _2; int _3; : pxStreamBuffer_6 = xStreamBuffer_5(D); if (pxStreamBuffer_6 == 0B) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : _1 = pxStreamBuffer_6->ucFlags; _2 = (int) _1; _3 = _2 & 2; if (_3 == 0) goto ; [INV] else goto ; [INV] : vPortFree (pxStreamBuffer_6); goto ; [INV] : memset (pxStreamBuffer_6, 0, 36); : return; } xStreamBufferGenericCreate (size_t xBufferSizeBytes, size_t xTriggerLevelBytes, BaseType_t xIsMessageBuffer) { uint8_t ucFlags; uint8_t * pucAllocatedMemory; struct StreamBufferDef_t * D.6348; unsigned int _1; uint8_t * _2; struct StreamBufferDef_t * _23; : if (xIsMessageBuffer_9(D) == 1) goto ; [INV] else goto ; [INV] : ucFlags_14 = 1; if (xBufferSizeBytes_11(D) <= 4) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : ucFlags_10 = 0; if (xBufferSizeBytes_11(D) == 0) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : # ucFlags_6 = PHI if (xTriggerLevelBytes_16(D) > xBufferSizeBytes_11(D)) goto ; [INV] else goto ; [INV] : vPortRaiseBASEPRI (); : goto ; [INV] : if (xTriggerLevelBytes_16(D) == 0) goto ; [INV] else goto ; [INV] : xTriggerLevelBytes_17 = 1; : # xTriggerLevelBytes_4 = PHI if (xBufferSizeBytes_11(D) <= 4294967258) goto ; [INV] else goto ; [INV] : xBufferSizeBytes_19 = xBufferSizeBytes_11(D) + 1; _1 = xBufferSizeBytes_19 + 36; pucAllocatedMemory_21 = pvPortMalloc (_1); goto ; [INV] : pucAllocatedMemory_18 = 0B; : # xBufferSizeBytes_3 = PHI # pucAllocatedMemory_5 = PHI if (pucAllocatedMemory_5 != 0B) goto ; [INV] else goto ; [INV] : _2 = pucAllocatedMemory_5 + 36; prvInitialiseNewStreamBuffer (pucAllocatedMemory_5, _2, xBufferSizeBytes_3, xTriggerLevelBytes_4, ucFlags_6); : _23 = pucAllocatedMemory_5; : : return _23; } __attribute__((always_inline)) vPortSetBASEPRI (uint32_t ulNewMaskValue) { : __asm__ __volatile__(" msr basepri, %0 " : : "r" ulNewMaskValue_2(D) : "memory"); return; } __attribute__((always_inline)) ulPortRaiseBASEPRI () { uint32_t ulNewBASEPRI; uint32_t ulOriginalBASEPRI; uint32_t D.6438; uint32_t _5; : __asm__ __volatile__(" mrs %0, basepri mov %1, %2 msr basepri, %1 isb dsb " : "=r" ulOriginalBASEPRI_3, "=r" ulNewBASEPRI_4 : "i" 16 : "memory"); _5 = ulOriginalBASEPRI_3; : : return _5; } __attribute__((always_inline)) vPortRaiseBASEPRI () { uint32_t ulNewBASEPRI; : __asm__ __volatile__(" mov %0, %1 msr basepri, %0 isb dsb " : "=r" ulNewBASEPRI_3 : "i" 16 : "memory"); return; }