Lines Matching refs:pxSegment
154 static void vTCPWindowFree( TCPSegment_t * pxSegment );
485 TCPSegment_t * pxSegment, * pxReturn = NULL; in xTCPWindowRxFind() local
499 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in xTCPWindowRxFind()
501 if( pxSegment->ulSequenceNumber == ulSequenceNumber ) in xTCPWindowRxFind()
503 pxReturn = pxSegment; in xTCPWindowRxFind()
530 TCPSegment_t * pxSegment; in xTCPWindowNew() local
540 pxSegment = NULL; in xTCPWindowNew()
547 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxItem ) ); in xTCPWindowNew()
550 configASSERT( pxSegment != NULL ); in xTCPWindowNew()
566 vTCPTimerSet( &pxSegment->xTransmitTimer ); in xTCPWindowNew()
568 pxSegment->u.ulFlags = 0; in xTCPWindowNew()
569 pxSegment->u.bits.bIsForRx = ( xIsForRx != 0 ) ? 1U : 0U; in xTCPWindowNew()
570 pxSegment->lMaxLength = lCount; in xTCPWindowNew()
571 pxSegment->lDataLength = lCount; in xTCPWindowNew()
572 pxSegment->ulSequenceNumber = ulSequenceNumber; in xTCPWindowNew()
586 return pxSegment; in xTCPWindowNew()
644 TCPSegment_t * pxSegment; in xTCPWindowGetHead() local
650 pxSegment = NULL; in xTCPWindowGetHead()
655 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxItem ) ); in xTCPWindowGetHead()
660 return pxSegment; in xTCPWindowGetHead()
702 static void vTCPWindowFree( TCPSegment_t * pxSegment ) in vTCPWindowFree() argument
708 if( listLIST_ITEM_CONTAINER( &( pxSegment->xQueueItem ) ) != NULL ) in vTCPWindowFree()
710 ( void ) uxListRemove( &( pxSegment->xQueueItem ) ); in vTCPWindowFree()
713 pxSegment->ulSequenceNumber = 0U; in vTCPWindowFree()
714 pxSegment->lDataLength = 0; in vTCPWindowFree()
715 pxSegment->u.ulFlags = 0U; in vTCPWindowFree()
718 if( listLIST_ITEM_CONTAINER( &( pxSegment->xSegmentItem ) ) != NULL ) in vTCPWindowFree()
720 ( void ) uxListRemove( &( pxSegment->xSegmentItem ) ); in vTCPWindowFree()
724 vListInsertFifo( &xSegmentList, &( pxSegment->xSegmentItem ) ); in vTCPWindowFree()
740 TCPSegment_t * pxSegment; in vTCPWindowDestroy() local
761 … pxSegment = ( ( TCPSegment_t * ) listGET_OWNER_OF_HEAD_ENTRY( pxSegments ) ); in vTCPWindowDestroy()
762 vTCPWindowFree( pxSegment ); in vTCPWindowDestroy()
940 TCPSegment_t * pxSegment; in xTCPWindowRxConfirm() local
955 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in xTCPWindowRxConfirm()
961 … if( ( xSequenceGreaterThanOrEqual( pxSegment->ulSequenceNumber, ulSequenceNumber ) != 0 ) && in xTCPWindowRxConfirm()
962 … ( xSequenceLessThan( pxSegment->ulSequenceNumber, ulNextSequenceNumber ) != 0 ) ) in xTCPWindowRxConfirm()
964 …if( ( pxBest == NULL ) || ( xSequenceLessThan( pxSegment->ulSequenceNumber, pxBest->ulSequenceNumb… in xTCPWindowRxConfirm()
966 pxBest = pxSegment; in xTCPWindowRxConfirm()
1368 TCPSegment_t * pxSegment, in prvTCPWindowTxAdd_FrontSegment() argument
1371 …int32_t lToWrite = FreeRTOS_min_int32( lBytesLeft, pxSegment->lMaxLength - pxSegment->lDataLength … in prvTCPWindowTxAdd_FrontSegment()
1373 pxSegment->lDataLength += lToWrite; in prvTCPWindowTxAdd_FrontSegment()
1375 if( pxSegment->lDataLength >= pxSegment->lMaxLength ) in prvTCPWindowTxAdd_FrontSegment()
1390 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in prvTCPWindowTxAdd_FrontSegment()
1391 ( int ) pxSegment->lDataLength, in prvTCPWindowTxAdd_FrontSegment()
1393 ( int ) pxSegment->lStreamPos ) ); in prvTCPWindowTxAdd_FrontSegment()
1424 TCPSegment_t * pxSegment = pxWindow->pxHeadSegment; in lTCPWindowTxAdd() local
1428 if( ( pxSegment != NULL ) && in lTCPWindowTxAdd()
1429 ( pxSegment->lDataLength < pxSegment->lMaxLength ) && in lTCPWindowTxAdd()
1430 ( pxSegment->u.bits.bOutstanding == pdFALSE_UNSIGNED ) && in lTCPWindowTxAdd()
1431 ( pxSegment->lDataLength != 0 ) ) in lTCPWindowTxAdd()
1433 lToWrite = prvTCPWindowTxAdd_FrontSegment( pxWindow, pxSegment, lBytesLeft ); in lTCPWindowTxAdd()
1447 …pxSegment = xTCPWindowTxNew( pxWindow, pxWindow->ulNextTxSequenceNumber, ( int32_t ) pxWindow->usM… in lTCPWindowTxAdd()
1449 if( pxSegment != NULL ) in lTCPWindowTxAdd()
1453 lToWrite = FreeRTOS_min_int32( lBytesLeft, pxSegment->lMaxLength ); in lTCPWindowTxAdd()
1455 pxSegment->lDataLength = lToWrite; in lTCPWindowTxAdd()
1456 pxSegment->lStreamPos = lBufferIndex; in lTCPWindowTxAdd()
1463 vListInsertFifo( &( pxWindow->xTxQueue ), &( pxSegment->xQueueItem ) ); in lTCPWindowTxAdd()
1467 if( pxSegment->lDataLength < pxSegment->lMaxLength ) in lTCPWindowTxAdd()
1469 pxWindow->pxHeadSegment = pxSegment; in lTCPWindowTxAdd()
1525 const TCPSegment_t * pxSegment; in prvTCPWindowTxHasSpace() local
1531 pxSegment = xTCPWindowPeekHead( &( pxWindow->xTxQueue ) ); in prvTCPWindowTxHasSpace()
1533 if( pxSegment == NULL ) in prvTCPWindowTxHasSpace()
1554 if( ulNettSize >= ( uint32_t ) pxSegment->lDataLength ) in prvTCPWindowTxHasSpace()
1569 ( ulTxOutstanding + ( ( uint32_t ) pxSegment->lDataLength ) ) ) ) in prvTCPWindowTxHasSpace()
1595 TCPSegment_t const * pxSegment; in xTCPWindowTxHasData() local
1610 pxSegment = xTCPWindowPeekHead( &( pxWindow->xWaitQueue ) ); in xTCPWindowTxHasData()
1612 if( pxSegment != NULL ) in xTCPWindowTxHasData()
1618 ulAge = ulTimerGetAge( &pxSegment->xTransmitTimer ); in xTCPWindowTxHasData()
1623 ulMaxAge = ( ( uint32_t ) 1U << pxSegment->u.bits.ucTransmitCount ); in xTCPWindowTxHasData()
1638 pxSegment = xTCPWindowPeekHead( &pxWindow->xTxQueue ); in xTCPWindowTxHasData()
1641 if( pxSegment == NULL ) in xTCPWindowTxHasData()
1651 ( pxSegment->lDataLength < pxSegment->lMaxLength ) ) in xTCPWindowTxHasData()
1680 TCPSegment_t * pxSegment = xTCPWindowPeekHead( &( pxWindow->xWaitQueue ) ); in pxTCPWindowTx_GetWaitQueue() local
1682 if( pxSegment != NULL ) in pxTCPWindowTx_GetWaitQueue()
1687 ulMaxTime = ( ( uint32_t ) 1U ) << pxSegment->u.bits.ucTransmitCount; in pxTCPWindowTx_GetWaitQueue()
1690 if( ulTimerGetAge( &pxSegment->xTransmitTimer ) > ulMaxTime ) in pxTCPWindowTx_GetWaitQueue()
1694 pxSegment = xTCPWindowGetHead( &( pxWindow->xWaitQueue ) ); in pxTCPWindowTx_GetWaitQueue()
1695 pxSegment->u.bits.ucDupAckCount = ( uint8_t ) pdFALSE_UNSIGNED; in pxTCPWindowTx_GetWaitQueue()
1703 ( int ) pxSegment->lDataLength, in pxTCPWindowTx_GetWaitQueue()
1704 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in pxTCPWindowTx_GetWaitQueue()
1705 ( unsigned ) pxSegment->ulSequenceNumber ) ); in pxTCPWindowTx_GetWaitQueue()
1711 pxSegment = NULL; in pxTCPWindowTx_GetWaitQueue()
1715 return pxSegment; in pxTCPWindowTx_GetWaitQueue()
1735 TCPSegment_t * pxSegment = xTCPWindowPeekHead( &( pxWindow->xTxQueue ) ); in pxTCPWindowTx_GetTXQueue() local
1737 if( pxSegment == NULL ) in pxTCPWindowTx_GetTXQueue()
1742 ( pxSegment->lDataLength < pxSegment->lMaxLength ) ) in pxTCPWindowTx_GetTXQueue()
1746 pxSegment = NULL; in pxTCPWindowTx_GetTXQueue()
1751 pxSegment = NULL; in pxTCPWindowTx_GetTXQueue()
1757 pxSegment = xTCPWindowGetHead( &( pxWindow->xTxQueue ) ); in pxTCPWindowTx_GetTXQueue()
1761 if( pxWindow->pxHeadSegment == pxSegment ) in pxTCPWindowTx_GetTXQueue()
1768 …pxWindow->tx.ulHighestSequenceNumber = pxSegment->ulSequenceNumber + ( ( uint32_t ) pxSegment->lDa… in pxTCPWindowTx_GetTXQueue()
1776 ( int ) pxSegment->lDataLength, in pxTCPWindowTx_GetTXQueue()
1777 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in pxTCPWindowTx_GetTXQueue()
1783 return pxSegment; in pxTCPWindowTx_GetTXQueue()
1804 TCPSegment_t * pxSegment; in ulTCPWindowTxGet() local
1811 pxSegment = xTCPWindowGetHead( &( pxWindow->xPriorityQueue ) ); in ulTCPWindowTxGet()
1814 if( pxSegment != NULL ) in ulTCPWindowTxGet()
1823 ( int ) pxSegment->lDataLength, in ulTCPWindowTxGet()
1824 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in ulTCPWindowTxGet()
1834 pxSegment = pxTCPWindowTx_GetWaitQueue( pxWindow ); in ulTCPWindowTxGet()
1836 if( pxSegment == NULL ) in ulTCPWindowTxGet()
1840 pxSegment = pxTCPWindowTx_GetTXQueue( pxWindow, ulWindowSize ); in ulTCPWindowTxGet()
1845 if( pxSegment != NULL ) in ulTCPWindowTxGet()
1847 configASSERT( listLIST_ITEM_CONTAINER( &( pxSegment->xQueueItem ) ) == NULL ); in ulTCPWindowTxGet()
1851 vListInsertFifo( &pxWindow->xWaitQueue, &pxSegment->xQueueItem ); in ulTCPWindowTxGet()
1854 pxSegment->u.bits.bOutstanding = pdTRUE_UNSIGNED; in ulTCPWindowTxGet()
1858 ( pxSegment->u.bits.ucTransmitCount )++; in ulTCPWindowTxGet()
1862 … if( ( pxSegment->u.bits.ucTransmitCount == MAX_TRANSMIT_COUNT_USING_LARGE_WINDOW ) && in ulTCPWindowTxGet()
1875 vTCPTimerSet( &( pxSegment->xTransmitTimer ) ); in ulTCPWindowTxGet()
1877 pxWindow->ulOurSequenceNumber = pxSegment->ulSequenceNumber; in ulTCPWindowTxGet()
1880 *plPosition = pxSegment->lStreamPos; in ulTCPWindowTxGet()
1883 ulReturn = ( uint32_t ) pxSegment->lDataLength; in ulTCPWindowTxGet()
1902 const TCPSegment_t * pxSegment ) in prvTCPWindowTxCheckAck_CalcSRTT() argument
1904 int32_t mS = ( int32_t ) ulTimerGetAge( &( pxSegment->xTransmitTimer ) ); in prvTCPWindowTxCheckAck_CalcSRTT()
1954 TCPSegment_t * pxSegment; in prvTCPWindowTxCheckAck() local
1982 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in prvTCPWindowTxCheckAck()
1989 … if( xSequenceGreaterThan( ulSequenceNumber, pxSegment->ulSequenceNumber ) != pdFALSE ) in prvTCPWindowTxCheckAck()
1995 if( ulSequenceNumber != pxSegment->ulSequenceNumber ) in prvTCPWindowTxCheckAck()
2001 ulDataLength = ( uint32_t ) pxSegment->lDataLength; in prvTCPWindowTxCheckAck()
2003 if( pxSegment->u.bits.bAcked == pdFALSE_UNSIGNED ) in prvTCPWindowTxCheckAck()
2005 …if( xSequenceGreaterThan( pxSegment->ulSequenceNumber + ( uint32_t ) ulDataLength, ulLast ) != pdF… in prvTCPWindowTxCheckAck()
2014 … uint32_t ulFirstSeq = pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber; in prvTCPWindowTxCheckAck()
2029 pxSegment->u.bits.bAcked = pdTRUE; in prvTCPWindowTxCheckAck()
2033 if( ( pxSegment->u.bits.ucTransmitCount == 1U ) && in prvTCPWindowTxCheckAck()
2034 ( ( pxSegment->ulSequenceNumber + ulDataLength ) == ulLast ) ) in prvTCPWindowTxCheckAck()
2036 prvTCPWindowTxCheckAck_CalcSRTT( pxWindow, pxSegment ); in prvTCPWindowTxCheckAck()
2052 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ) ) ); in prvTCPWindowTxCheckAck()
2063 vTCPWindowFree( pxSegment ); in prvTCPWindowTxCheckAck()
2069 …if( ( xDoUnlink != pdFALSE ) && ( listLIST_ITEM_CONTAINER( &( pxSegment->xQueueItem ) ) != NULL ) ) in prvTCPWindowTxCheckAck()
2072 ( void ) uxListRemove( &pxSegment->xQueueItem ); in prvTCPWindowTxCheckAck()
2098 TCPSegment_t * pxSegment; in prvTCPWindowFastRetransmit() local
2114 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in prvTCPWindowFastRetransmit()
2123 if( pxSegment->u.bits.bAcked == pdFALSE_UNSIGNED ) in prvTCPWindowFastRetransmit()
2125 if( xSequenceLessThan( pxSegment->ulSequenceNumber, ulFirst ) != pdFALSE ) in prvTCPWindowFastRetransmit()
2127 pxSegment->u.bits.ucDupAckCount++; in prvTCPWindowFastRetransmit()
2129 … if( pxSegment->u.bits.ucDupAckCount == DUPLICATE_ACKS_BEFORE_FAST_RETRANSMIT ) in prvTCPWindowFastRetransmit()
2131 pxSegment->u.bits.ucTransmitCount = ( uint8_t ) pdFALSE; in prvTCPWindowFastRetransmit()
2138 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in prvTCPWindowFastRetransmit()
2144 ( void ) uxListRemove( &pxSegment->xQueueItem ); in prvTCPWindowFastRetransmit()
2148 … vListInsertFifo( &( pxWindow->xPriorityQueue ), &( pxSegment->xQueueItem ) ); in prvTCPWindowFastRetransmit()