Lines Matching refs:pxSocket
67 static BaseType_t prvTCPHandleFin( FreeRTOS_Socket_t * pxSocket,
74 static BaseType_t prvHandleSynReceived( FreeRTOS_Socket_t * pxSocket,
82 static BaseType_t prvHandleEstablished( FreeRTOS_Socket_t * pxSocket,
92 FreeRTOS_Socket_t * pxSocket );
147 BaseType_t prvTCPStatusAgeCheck( FreeRTOS_Socket_t * pxSocket ) in prvTCPStatusAgeCheck() argument
151 eIPTCPState_t eState = pxSocket->u.xTCP.eTCPState; in prvTCPStatusAgeCheck()
189 TickType_t xAge = xTaskGetTickCount() - pxSocket->u.xTCP.xLastActTime; in prvTCPStatusAgeCheck()
197 pxSocket->usLocalPort, in prvTCPStatusAgeCheck()
198 ( unsigned ) pxSocket->u.xTCP.ulRemoteIP, in prvTCPStatusAgeCheck()
199 pxSocket->u.xTCP.usRemotePort, in prvTCPStatusAgeCheck()
200 … FreeRTOS_GetTCPStateName( ( UBaseType_t ) pxSocket->u.xTCP.eTCPState ) ) ); in prvTCPStatusAgeCheck()
205 vTCPStateChange( pxSocket, eCLOSE_WAIT ); in prvTCPStatusAgeCheck()
209 if( pxSocket->u.xTCP.bits.bPassQueued != pdFALSE_UNSIGNED ) in prvTCPStatusAgeCheck()
238 static BaseType_t prvTCPHandleFin( FreeRTOS_Socket_t * pxSocket, in prvTCPHandleFin() argument
250 TCPWindow_t * pxTCPWindow = &pxSocket->u.xTCP.xTCPWindow; in prvTCPHandleFin()
259 if( pxSocket->u.xTCP.bits.bFinSent == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
263 pxSocket->u.xTCP.bits.bFinSent = pdTRUE_UNSIGNED; in prvTCPHandleFin()
270 pxSocket->u.xTCP.bits.bFinAcked = pdTRUE_UNSIGNED; in prvTCPHandleFin()
274 if( pxSocket->u.xTCP.bits.bFinAcked == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
280 vTCPStateChange( pxSocket, eLAST_ACK ); in prvTCPHandleFin()
287 if( pxSocket->u.xTCP.bits.bFinRecv == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
295 if( pxSocket->u.xTCP.bits.bFinLast == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
309 vTCPStateChange( pxSocket, eCLOSE_WAIT ); in prvTCPHandleFin()
317 …ucIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + pxTCPWindow->ucOp… in prvTCPHandleFin()
351 static BaseType_t prvHandleSynReceived( FreeRTOS_Socket_t * pxSocket, in prvHandleSynReceived() argument
362 … pxNetworkBuffer->pucEthernetBuffer[ ipSIZE_OF_ETH_HEADER + uxIPHeaderSizeSocket( pxSocket ) ] ) ); in prvHandleSynReceived()
364 TCPWindow_t * pxTCPWindow = &pxSocket->u.xTCP.xTCPWindow; in prvHandleSynReceived()
374 if( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) in prvHandleSynReceived()
384 … ( pxSocket->u.xTCP.eTCPState == ( uint8_t ) eSYN_RECEIVED ) ? "eSYN_RECEIVED" : "eCONNECT_SYN", in prvHandleSynReceived()
389 vTCPStateChange( pxSocket, eCLOSE_WAIT ); in prvHandleSynReceived()
398 … uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + uxOptionsLength; in prvHandleSynReceived()
405 pxTCPWindow->usPeerPortNumber = pxSocket->u.xTCP.usRemotePort; in prvHandleSynReceived()
406 pxTCPWindow->usOurPortNumber = pxSocket->usLocalPort; in prvHandleSynReceived()
408 if( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) in prvHandleSynReceived()
416 …&( pxSocket->u.xTCP.xPacket.u.ucLastPacket[ ipSIZE_OF_ETH_HEADER + uxIPHeaderSizeSocket( pxSocket … in prvHandleSynReceived()
424 vTCPWindowInit( &pxSocket->u.xTCP.xTCPWindow, in prvHandleSynReceived()
425 …ulSequenceNumber, pxSocket->u.xTCP.xTCPWindow.ulOurSequenceNumber, ( uint32_t ) pxSocket->u.xTCP.u… in prvHandleSynReceived()
447 … ( pxSocket->u.xTCP.eTCPState == ( uint8_t ) eCONNECT_SYN ) ? "active" : "passive", in prvHandleSynReceived()
448 pxSocket->usLocalPort, in prvHandleSynReceived()
449 ( unsigned ) pxSocket->u.xTCP.ulRemoteIP, in prvHandleSynReceived()
450 pxSocket->u.xTCP.usRemotePort, in prvHandleSynReceived()
451 ( unsigned ) pxSocket->u.xTCP.bits.bWinScaling ) ); in prvHandleSynReceived()
455 if( ( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) || ( ulReceiveLength != 0U ) ) in prvHandleSynReceived()
459 …uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ( size_t ) ipSIZE_OF_TCP_HEADER + uxOpti… in prvHandleSynReceived()
466 if( pxSocket->u.xTCP.bits.bWinScaling == pdFALSE_UNSIGNED ) in prvHandleSynReceived()
470 pxSocket->u.xTCP.ucMyWinScaleFactor = 0; in prvHandleSynReceived()
471 pxSocket->u.xTCP.ucPeerWinScaleFactor = 0; in prvHandleSynReceived()
478 vTCPStateChange( pxSocket, eESTABLISHED ); in prvHandleSynReceived()
499 static BaseType_t prvHandleEstablished( FreeRTOS_Socket_t * pxSocket, in prvHandleEstablished() argument
510 …xNetworkBuffer )->pucEthernetBuffer[ ipSIZE_OF_ETH_HEADER + uxIPHeaderSizeSocket( pxSocket ) ] ) ); in prvHandleEstablished()
512 TCPWindow_t * pxTCPWindow = &pxSocket->u.xTCP.xTCPWindow; in prvHandleEstablished()
522 pxSocket->u.xTCP.ulWindowSize = ( uint32_t ) usWindow; in prvHandleEstablished()
525 pxSocket->u.xTCP.ulWindowSize = in prvHandleEstablished()
526 ( pxSocket->u.xTCP.ulWindowSize << pxSocket->u.xTCP.ucPeerWinScaleFactor ); in prvHandleEstablished()
543 if( ( pxSocket->u.xTCP.txStream != NULL ) && ( ulCount > 0U ) ) in prvHandleEstablished()
549 … if( uxStreamBufferGet( pxSocket->u.xTCP.txStream, 0U, NULL, ( size_t ) ulCount, pdFALSE ) != 0U ) in prvHandleEstablished()
551 pxSocket->xEventBits |= ( EventBits_t ) eSOCKET_SEND; in prvHandleEstablished()
555 … if( ( pxSocket->xSelectBits & ( ( EventBits_t ) eSELECT_WRITE ) ) != 0U ) in prvHandleEstablished()
557 … pxSocket->xEventBits |= ( ( EventBits_t ) eSELECT_WRITE ) << SOCKET_EVENT_BIT_COUNT; in prvHandleEstablished()
566 if( ipconfigIS_VALID_PROG_ADDRESS( pxSocket->u.xTCP.pxHandleSent ) ) in prvHandleEstablished()
568 pxSocket->u.xTCP.pxHandleSent( ( Socket_t ) pxSocket, ulCount ); in prvHandleEstablished()
577 if( pxSocket->u.xTCP.txStream != NULL ) in prvHandleEstablished()
579 prvTCPAddTxData( pxSocket ); in prvHandleEstablished()
582 … pxSocket->u.xTCP.xTCPWindow.ulOurSequenceNumber = pxTCPWindow->tx.ulCurrentSequenceNumber; in prvHandleEstablished()
584 …if( ( pxSocket->u.xTCP.bits.bFinAccepted != pdFALSE_UNSIGNED ) || ( ( ucTCPFlags & ( uint8_t ) tcp… in prvHandleEstablished()
590 if( pxSocket->u.xTCP.bits.bFinSent == pdFALSE_UNSIGNED ) in prvHandleEstablished()
600 pxSocket->usLocalPort, in prvHandleEstablished()
601 pxSocket->u.xTCP.usRemotePort, in prvHandleEstablished()
627 … ( unsigned ) ( ulSequenceNumber - pxSocket->u.xTCP.xTCPWindow.rx.ulFirstSequenceNumber ), in prvHandleEstablished()
629 …( unsigned ) ( pxTCPWindow->tx.ulCurrentSequenceNumber - pxSocket->u.xTCP.xTCPWindow.tx.ulFirstSeq… in prvHandleEstablished()
634 pxSocket->u.xTCP.bits.bFinAccepted = pdTRUE_UNSIGNED; in prvHandleEstablished()
635 xSendLength = prvTCPHandleFin( pxSocket, *ppxNetworkBuffer ); in prvHandleEstablished()
645 … uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + uxOptionsLength; in prvHandleEstablished()
650 if( pxSocket->u.xTCP.bits.bFinSent != pdFALSE_UNSIGNED ) in prvHandleEstablished()
666 lSendResult = prvTCPPrepareSend( pxSocket, ppxNetworkBuffer, uxOptionsLength ); in prvHandleEstablished()
707 BaseType_t prvTCPHandleState( FreeRTOS_Socket_t * pxSocket, in prvTCPHandleState() argument
730 TCPWindow_t * pxTCPWindow = &( pxSocket->u.xTCP.xTCPWindow ); in prvTCPHandleState()
738 if( pxSocket->u.xTCP.eTCPState >= eESTABLISHED ) in prvTCPHandleState()
745 pxSocket->u.xTCP.bits.bWinChange = pdTRUE_UNSIGNED; in prvTCPHandleState()
759 if( prvStoreRxData( pxSocket, pucRecvData, *ppxNetworkBuffer, ulReceiveLength ) < 0 ) in prvTCPHandleState()
767 uxOptionsLength = prvSetOptions( pxSocket, *ppxNetworkBuffer ); in prvTCPHandleState()
769 …if( ( pxSocket->u.xTCP.eTCPState == eSYN_RECEIVED ) && ( ( ucTCPFlags & ( uint8_t ) tcpTCP_FLAG_CT… in prvTCPHandleState()
777 vTCPStateChange( pxSocket, eSYN_FIRST ); in prvTCPHandleState()
780 …if( ( ( ucTCPFlags & tcpTCP_FLAG_FIN ) != 0U ) && ( pxSocket->u.xTCP.bits.bFinRecv == pdFALSE_UNSI… in prvTCPHandleState()
785 pxSocket->u.xTCP.bits.bFinRecv = pdTRUE_UNSIGNED; in prvTCPHandleState()
788 if( pxSocket->u.xTCP.bits.bFinSent == pdFALSE_UNSIGNED ) in prvTCPHandleState()
791 pxSocket->u.xTCP.bits.bFinLast = pdTRUE_UNSIGNED; in prvTCPHandleState()
795 eState = ( eIPTCPState_t ) pxSocket->u.xTCP.eTCPState; in prvTCPHandleState()
818 uxOptionsLength = prvSetSynAckOptions( pxSocket, pxTCPHeader ); in prvTCPHandleState()
821 … uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + uxOptionsLength; in prvTCPHandleState()
828 vTCPStateChange( pxSocket, eSYN_RECEIVED ); in prvTCPHandleState()
841 …xSendLength = prvHandleSynReceived( pxSocket, *( ppxNetworkBuffer ), ulReceiveLength, uxOptionsLen… in prvTCPHandleState()
849 …xSendLength = prvHandleEstablished( pxSocket, ppxNetworkBuffer, ulReceiveLength, uxOptionsLength ); in prvTCPHandleState()
862 xSendLength = prvTCPHandleFin( pxSocket, *ppxNetworkBuffer ); in prvTCPHandleState()
894 xSendLength = prvSendData( pxSocket, ppxNetworkBuffer, ulReceiveLength, xSendLength ); in prvTCPHandleState()
910 FreeRTOS_Socket_t * prvHandleListen( FreeRTOS_Socket_t * pxSocket, in prvHandleListen() argument
928 pxSocket->usLocalPort, in prvHandleListen()
942 if( pxSocket->u.xTCP.bits.bReuseSocket != pdFALSE_UNSIGNED ) in prvHandleListen()
946 pxReturn = pxSocket; in prvHandleListen()
947 pxSocket->u.xTCP.bits.bPassQueued = pdTRUE_UNSIGNED; in prvHandleListen()
948 pxSocket->u.xTCP.pxPeerSocket = pxSocket; in prvHandleListen()
956 if( pxSocket->u.xTCP.usChildCount >= pxSocket->u.xTCP.usBacklog ) in prvHandleListen()
959 pxSocket->usLocalPort, in prvHandleListen()
960 pxSocket->u.xTCP.usChildCount, in prvHandleListen()
961 pxSocket->u.xTCP.usBacklog, in prvHandleListen()
962 ( pxSocket->u.xTCP.usChildCount == 1U ) ? "" : "ren" ) ); in prvHandleListen()
978 else if( prvTCPSocketCopy( pxNewSocket, pxSocket ) != pdFALSE ) in prvHandleListen()
1039 FreeRTOS_Socket_t * pxSocket ) in prvTCPSocketCopy() argument
1044 pxNewSocket->xReceiveBlockTime = pxSocket->xReceiveBlockTime; in prvTCPSocketCopy()
1045 pxNewSocket->xSendBlockTime = pxSocket->xSendBlockTime; in prvTCPSocketCopy()
1046 pxNewSocket->ucSocketOptions = pxSocket->ucSocketOptions; in prvTCPSocketCopy()
1047 pxNewSocket->u.xTCP.uxRxStreamSize = pxSocket->u.xTCP.uxRxStreamSize; in prvTCPSocketCopy()
1048 pxNewSocket->u.xTCP.uxTxStreamSize = pxSocket->u.xTCP.uxTxStreamSize; in prvTCPSocketCopy()
1049 pxNewSocket->u.xTCP.uxLittleSpace = pxSocket->u.xTCP.uxLittleSpace; in prvTCPSocketCopy()
1050 pxNewSocket->u.xTCP.uxEnoughSpace = pxSocket->u.xTCP.uxEnoughSpace; in prvTCPSocketCopy()
1051 pxNewSocket->u.xTCP.uxRxWinSize = pxSocket->u.xTCP.uxRxWinSize; in prvTCPSocketCopy()
1052 pxNewSocket->u.xTCP.uxTxWinSize = pxSocket->u.xTCP.uxTxWinSize; in prvTCPSocketCopy()
1056 pxNewSocket->pxUserSemaphore = pxSocket->pxUserSemaphore; in prvTCPSocketCopy()
1063 pxNewSocket->u.xTCP.pxHandleConnected = pxSocket->u.xTCP.pxHandleConnected; in prvTCPSocketCopy()
1064 pxNewSocket->u.xTCP.pxHandleReceive = pxSocket->u.xTCP.pxHandleReceive; in prvTCPSocketCopy()
1065 pxNewSocket->u.xTCP.pxHandleSent = pxSocket->u.xTCP.pxHandleSent; in prvTCPSocketCopy()
1073 if( pxSocket->pxSocketSet != NULL ) in prvTCPSocketCopy()
1075 pxNewSocket->pxSocketSet = pxSocket->pxSocketSet; in prvTCPSocketCopy()
1076 …pxNewSocket->xSelectBits = pxSocket->xSelectBits | ( ( EventBits_t ) eSELECT_READ ) | ( ( EventBit… in prvTCPSocketCopy()
1083 xAddress.sin_port = FreeRTOS_htons( pxSocket->usLocalPort ); in prvTCPSocketCopy()
1094 pxNewSocket->u.xTCP.pxPeerSocket = pxSocket; in prvTCPSocketCopy()
1105 if( pxSocket->u.xTCP.pxPeerSocket == NULL ) in prvTCPSocketCopy()
1107 pxSocket->u.xTCP.pxPeerSocket = pxNewSocket; in prvTCPSocketCopy()
1112 pxSocket->u.xTCP.usChildCount++; in prvTCPSocketCopy()
1115 pxSocket->usLocalPort, in prvTCPSocketCopy()
1116 pxSocket->u.xTCP.usChildCount, in prvTCPSocketCopy()
1117 pxSocket->u.xTCP.usBacklog, in prvTCPSocketCopy()
1118 ( pxSocket->u.xTCP.usChildCount == 1U ) ? "" : "ren" ) ); in prvTCPSocketCopy()