Lines Matching refs:pxSegment
152 static void vTCPWindowFree( TCPSegment_t * pxSegment );
481 TCPSegment_t * pxSegment, * pxReturn = NULL; in xTCPWindowRxFind() local
495 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in xTCPWindowRxFind()
497 if( pxSegment->ulSequenceNumber == ulSequenceNumber ) in xTCPWindowRxFind()
499 pxReturn = pxSegment; in xTCPWindowRxFind()
526 TCPSegment_t * pxSegment; in xTCPWindowNew() local
536 pxSegment = NULL; in xTCPWindowNew()
543 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxItem ) ); in xTCPWindowNew()
546 configASSERT( pxSegment != NULL ); in xTCPWindowNew()
562 vTCPTimerSet( &pxSegment->xTransmitTimer ); in xTCPWindowNew()
564 pxSegment->u.ulFlags = 0; in xTCPWindowNew()
565 pxSegment->u.bits.bIsForRx = ( xIsForRx != 0 ) ? 1U : 0U; in xTCPWindowNew()
566 pxSegment->lMaxLength = lCount; in xTCPWindowNew()
567 pxSegment->lDataLength = lCount; in xTCPWindowNew()
568 pxSegment->ulSequenceNumber = ulSequenceNumber; in xTCPWindowNew()
582 return pxSegment; in xTCPWindowNew()
640 TCPSegment_t * pxSegment; in xTCPWindowGetHead() local
646 pxSegment = NULL; in xTCPWindowGetHead()
651 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxItem ) ); in xTCPWindowGetHead()
656 return pxSegment; in xTCPWindowGetHead()
698 static void vTCPWindowFree( TCPSegment_t * pxSegment ) in vTCPWindowFree() argument
704 if( listLIST_ITEM_CONTAINER( &( pxSegment->xQueueItem ) ) != NULL ) in vTCPWindowFree()
706 ( void ) uxListRemove( &( pxSegment->xQueueItem ) ); in vTCPWindowFree()
709 pxSegment->ulSequenceNumber = 0U; in vTCPWindowFree()
710 pxSegment->lDataLength = 0; in vTCPWindowFree()
711 pxSegment->u.ulFlags = 0U; in vTCPWindowFree()
714 if( listLIST_ITEM_CONTAINER( &( pxSegment->xSegmentItem ) ) != NULL ) in vTCPWindowFree()
716 ( void ) uxListRemove( &( pxSegment->xSegmentItem ) ); in vTCPWindowFree()
720 vListInsertFifo( &xSegmentList, &( pxSegment->xSegmentItem ) ); in vTCPWindowFree()
736 TCPSegment_t * pxSegment; in vTCPWindowDestroy() local
757 … pxSegment = ( ( TCPSegment_t * ) listGET_OWNER_OF_HEAD_ENTRY( pxSegments ) ); in vTCPWindowDestroy()
758 vTCPWindowFree( pxSegment ); in vTCPWindowDestroy()
936 TCPSegment_t * pxSegment; in xTCPWindowRxConfirm() local
951 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in xTCPWindowRxConfirm()
957 … if( ( xSequenceGreaterThanOrEqual( pxSegment->ulSequenceNumber, ulSequenceNumber ) != 0 ) && in xTCPWindowRxConfirm()
958 … ( xSequenceLessThan( pxSegment->ulSequenceNumber, ulNextSequenceNumber ) != 0 ) ) in xTCPWindowRxConfirm()
960 …if( ( pxBest == NULL ) || ( xSequenceLessThan( pxSegment->ulSequenceNumber, pxBest->ulSequenceNumb… in xTCPWindowRxConfirm()
962 pxBest = pxSegment; in xTCPWindowRxConfirm()
1364 TCPSegment_t * pxSegment, in prvTCPWindowTxAdd_FrontSegment() argument
1367 …int32_t lToWrite = FreeRTOS_min_int32( lBytesLeft, pxSegment->lMaxLength - pxSegment->lDataLength … in prvTCPWindowTxAdd_FrontSegment()
1369 pxSegment->lDataLength += lToWrite; in prvTCPWindowTxAdd_FrontSegment()
1371 if( pxSegment->lDataLength >= pxSegment->lMaxLength ) in prvTCPWindowTxAdd_FrontSegment()
1386 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in prvTCPWindowTxAdd_FrontSegment()
1387 ( int ) pxSegment->lDataLength, in prvTCPWindowTxAdd_FrontSegment()
1389 ( int ) pxSegment->lStreamPos ) ); in prvTCPWindowTxAdd_FrontSegment()
1420 TCPSegment_t * pxSegment = pxWindow->pxHeadSegment; in lTCPWindowTxAdd() local
1424 if( ( pxSegment != NULL ) && in lTCPWindowTxAdd()
1425 ( pxSegment->lDataLength < pxSegment->lMaxLength ) && in lTCPWindowTxAdd()
1426 ( pxSegment->u.bits.bOutstanding == pdFALSE_UNSIGNED ) && in lTCPWindowTxAdd()
1427 ( pxSegment->lDataLength != 0 ) ) in lTCPWindowTxAdd()
1429 lToWrite = prvTCPWindowTxAdd_FrontSegment( pxWindow, pxSegment, lBytesLeft ); in lTCPWindowTxAdd()
1443 …pxSegment = xTCPWindowTxNew( pxWindow, pxWindow->ulNextTxSequenceNumber, ( int32_t ) pxWindow->usM… in lTCPWindowTxAdd()
1445 if( pxSegment != NULL ) in lTCPWindowTxAdd()
1449 lToWrite = FreeRTOS_min_int32( lBytesLeft, pxSegment->lMaxLength ); in lTCPWindowTxAdd()
1451 pxSegment->lDataLength = lToWrite; in lTCPWindowTxAdd()
1452 pxSegment->lStreamPos = lBufferIndex; in lTCPWindowTxAdd()
1459 vListInsertFifo( &( pxWindow->xTxQueue ), &( pxSegment->xQueueItem ) ); in lTCPWindowTxAdd()
1463 if( pxSegment->lDataLength < pxSegment->lMaxLength ) in lTCPWindowTxAdd()
1465 pxWindow->pxHeadSegment = pxSegment; in lTCPWindowTxAdd()
1521 const TCPSegment_t * pxSegment; in prvTCPWindowTxHasSpace() local
1527 pxSegment = xTCPWindowPeekHead( &( pxWindow->xTxQueue ) ); in prvTCPWindowTxHasSpace()
1529 if( pxSegment == NULL ) in prvTCPWindowTxHasSpace()
1550 if( ulNettSize >= ( uint32_t ) pxSegment->lDataLength ) in prvTCPWindowTxHasSpace()
1565 ( ulTxOutstanding + ( ( uint32_t ) pxSegment->lDataLength ) ) ) ) in prvTCPWindowTxHasSpace()
1591 TCPSegment_t const * pxSegment; in xTCPWindowTxHasData() local
1606 pxSegment = xTCPWindowPeekHead( &( pxWindow->xWaitQueue ) ); in xTCPWindowTxHasData()
1608 if( pxSegment != NULL ) in xTCPWindowTxHasData()
1614 ulAge = ulTimerGetAge( &pxSegment->xTransmitTimer ); in xTCPWindowTxHasData()
1619 ulMaxAge = ( ( uint32_t ) 1U << pxSegment->u.bits.ucTransmitCount ); in xTCPWindowTxHasData()
1634 pxSegment = xTCPWindowPeekHead( &pxWindow->xTxQueue ); in xTCPWindowTxHasData()
1637 if( pxSegment == NULL ) in xTCPWindowTxHasData()
1647 ( pxSegment->lDataLength < pxSegment->lMaxLength ) ) in xTCPWindowTxHasData()
1676 TCPSegment_t * pxSegment = xTCPWindowPeekHead( &( pxWindow->xWaitQueue ) ); in pxTCPWindowTx_GetWaitQueue() local
1678 if( pxSegment != NULL ) in pxTCPWindowTx_GetWaitQueue()
1683 ulMaxTime = ( ( uint32_t ) 1U ) << pxSegment->u.bits.ucTransmitCount; in pxTCPWindowTx_GetWaitQueue()
1686 if( ulTimerGetAge( &pxSegment->xTransmitTimer ) > ulMaxTime ) in pxTCPWindowTx_GetWaitQueue()
1690 pxSegment = xTCPWindowGetHead( &( pxWindow->xWaitQueue ) ); in pxTCPWindowTx_GetWaitQueue()
1691 pxSegment->u.bits.ucDupAckCount = ( uint8_t ) pdFALSE_UNSIGNED; in pxTCPWindowTx_GetWaitQueue()
1699 ( int ) pxSegment->lDataLength, in pxTCPWindowTx_GetWaitQueue()
1700 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in pxTCPWindowTx_GetWaitQueue()
1701 ( unsigned ) pxSegment->ulSequenceNumber ) ); in pxTCPWindowTx_GetWaitQueue()
1707 pxSegment = NULL; in pxTCPWindowTx_GetWaitQueue()
1711 return pxSegment; in pxTCPWindowTx_GetWaitQueue()
1731 TCPSegment_t * pxSegment = xTCPWindowPeekHead( &( pxWindow->xTxQueue ) ); in pxTCPWindowTx_GetTXQueue() local
1733 if( pxSegment == NULL ) in pxTCPWindowTx_GetTXQueue()
1738 ( pxSegment->lDataLength < pxSegment->lMaxLength ) ) in pxTCPWindowTx_GetTXQueue()
1742 pxSegment = NULL; in pxTCPWindowTx_GetTXQueue()
1747 pxSegment = NULL; in pxTCPWindowTx_GetTXQueue()
1753 pxSegment = xTCPWindowGetHead( &( pxWindow->xTxQueue ) ); in pxTCPWindowTx_GetTXQueue()
1757 if( pxWindow->pxHeadSegment == pxSegment ) in pxTCPWindowTx_GetTXQueue()
1764 …pxWindow->tx.ulHighestSequenceNumber = pxSegment->ulSequenceNumber + ( ( uint32_t ) pxSegment->lDa… in pxTCPWindowTx_GetTXQueue()
1772 ( int ) pxSegment->lDataLength, in pxTCPWindowTx_GetTXQueue()
1773 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in pxTCPWindowTx_GetTXQueue()
1779 return pxSegment; in pxTCPWindowTx_GetTXQueue()
1800 TCPSegment_t * pxSegment; in ulTCPWindowTxGet() local
1807 pxSegment = xTCPWindowGetHead( &( pxWindow->xPriorityQueue ) ); in ulTCPWindowTxGet()
1810 if( pxSegment != NULL ) in ulTCPWindowTxGet()
1819 ( int ) pxSegment->lDataLength, in ulTCPWindowTxGet()
1820 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in ulTCPWindowTxGet()
1830 pxSegment = pxTCPWindowTx_GetWaitQueue( pxWindow ); in ulTCPWindowTxGet()
1832 if( pxSegment == NULL ) in ulTCPWindowTxGet()
1836 pxSegment = pxTCPWindowTx_GetTXQueue( pxWindow, ulWindowSize ); in ulTCPWindowTxGet()
1841 if( pxSegment != NULL ) in ulTCPWindowTxGet()
1843 configASSERT( listLIST_ITEM_CONTAINER( &( pxSegment->xQueueItem ) ) == NULL ); in ulTCPWindowTxGet()
1847 vListInsertFifo( &pxWindow->xWaitQueue, &pxSegment->xQueueItem ); in ulTCPWindowTxGet()
1850 pxSegment->u.bits.bOutstanding = pdTRUE_UNSIGNED; in ulTCPWindowTxGet()
1854 ( pxSegment->u.bits.ucTransmitCount )++; in ulTCPWindowTxGet()
1858 … if( ( pxSegment->u.bits.ucTransmitCount == MAX_TRANSMIT_COUNT_USING_LARGE_WINDOW ) && in ulTCPWindowTxGet()
1871 vTCPTimerSet( &( pxSegment->xTransmitTimer ) ); in ulTCPWindowTxGet()
1873 pxWindow->ulOurSequenceNumber = pxSegment->ulSequenceNumber; in ulTCPWindowTxGet()
1876 *plPosition = pxSegment->lStreamPos; in ulTCPWindowTxGet()
1879 ulReturn = ( uint32_t ) pxSegment->lDataLength; in ulTCPWindowTxGet()
1898 const TCPSegment_t * pxSegment ) in prvTCPWindowTxCheckAck_CalcSRTT() argument
1900 int32_t mS = ( int32_t ) ulTimerGetAge( &( pxSegment->xTransmitTimer ) ); in prvTCPWindowTxCheckAck_CalcSRTT()
1950 TCPSegment_t * pxSegment; in prvTCPWindowTxCheckAck() local
1978 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in prvTCPWindowTxCheckAck()
1985 … if( xSequenceGreaterThan( ulSequenceNumber, pxSegment->ulSequenceNumber ) != pdFALSE ) in prvTCPWindowTxCheckAck()
1991 if( ulSequenceNumber != pxSegment->ulSequenceNumber ) in prvTCPWindowTxCheckAck()
1997 ulDataLength = ( uint32_t ) pxSegment->lDataLength; in prvTCPWindowTxCheckAck()
1999 if( pxSegment->u.bits.bAcked == pdFALSE_UNSIGNED ) in prvTCPWindowTxCheckAck()
2001 …if( xSequenceGreaterThan( pxSegment->ulSequenceNumber + ( uint32_t ) ulDataLength, ulLast ) != pdF… in prvTCPWindowTxCheckAck()
2010 … uint32_t ulFirstSeq = pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber; in prvTCPWindowTxCheckAck()
2025 pxSegment->u.bits.bAcked = pdTRUE; in prvTCPWindowTxCheckAck()
2029 if( ( pxSegment->u.bits.ucTransmitCount == 1U ) && in prvTCPWindowTxCheckAck()
2030 ( ( pxSegment->ulSequenceNumber + ulDataLength ) == ulLast ) ) in prvTCPWindowTxCheckAck()
2032 prvTCPWindowTxCheckAck_CalcSRTT( pxWindow, pxSegment ); in prvTCPWindowTxCheckAck()
2048 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ) ) ); in prvTCPWindowTxCheckAck()
2059 vTCPWindowFree( pxSegment ); in prvTCPWindowTxCheckAck()
2065 …if( ( xDoUnlink != pdFALSE ) && ( listLIST_ITEM_CONTAINER( &( pxSegment->xQueueItem ) ) != NULL ) ) in prvTCPWindowTxCheckAck()
2068 ( void ) uxListRemove( &pxSegment->xQueueItem ); in prvTCPWindowTxCheckAck()
2094 TCPSegment_t * pxSegment; in prvTCPWindowFastRetransmit() local
2110 pxSegment = ( ( TCPSegment_t * ) listGET_LIST_ITEM_OWNER( pxIterator ) ); in prvTCPWindowFastRetransmit()
2119 if( pxSegment->u.bits.bAcked == pdFALSE_UNSIGNED ) in prvTCPWindowFastRetransmit()
2121 if( xSequenceLessThan( pxSegment->ulSequenceNumber, ulFirst ) != pdFALSE ) in prvTCPWindowFastRetransmit()
2123 pxSegment->u.bits.ucDupAckCount++; in prvTCPWindowFastRetransmit()
2125 … if( pxSegment->u.bits.ucDupAckCount == DUPLICATE_ACKS_BEFORE_FAST_RETRANSMIT ) in prvTCPWindowFastRetransmit()
2127 pxSegment->u.bits.ucTransmitCount = ( uint8_t ) pdFALSE; in prvTCPWindowFastRetransmit()
2134 … ( unsigned ) ( pxSegment->ulSequenceNumber - pxWindow->tx.ulFirstSequenceNumber ), in prvTCPWindowFastRetransmit()
2140 ( void ) uxListRemove( &pxSegment->xQueueItem ); in prvTCPWindowFastRetransmit()
2144 … vListInsertFifo( &( pxWindow->xPriorityQueue ), &( pxSegment->xQueueItem ) ); in prvTCPWindowFastRetransmit()