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,
141 BaseType_t prvTCPStatusAgeCheck( FreeRTOS_Socket_t * pxSocket ) in prvTCPStatusAgeCheck() argument
145 eIPTCPState_t eState = pxSocket->u.xTCP.eTCPState; in prvTCPStatusAgeCheck()
183 TickType_t xAge = xTaskGetTickCount() - pxSocket->u.xTCP.xLastActTime; in prvTCPStatusAgeCheck()
191 pxSocket->usLocalPort, in prvTCPStatusAgeCheck()
192 … ( unsigned ) pxSocket->u.xTCP.xRemoteIP.ulIP_IPv4, in prvTCPStatusAgeCheck()
193 pxSocket->u.xTCP.usRemotePort, in prvTCPStatusAgeCheck()
194 … FreeRTOS_GetTCPStateName( ( UBaseType_t ) pxSocket->u.xTCP.eTCPState ) ) ); in prvTCPStatusAgeCheck()
199 vTCPStateChange( pxSocket, eCLOSE_WAIT ); in prvTCPStatusAgeCheck()
203 if( pxSocket->u.xTCP.bits.bPassQueued != pdFALSE_UNSIGNED ) in prvTCPStatusAgeCheck()
232 static BaseType_t prvTCPHandleFin( FreeRTOS_Socket_t * pxSocket, in prvTCPHandleFin() argument
244 TCPWindow_t * pxTCPWindow = &pxSocket->u.xTCP.xTCPWindow; in prvTCPHandleFin()
253 if( pxSocket->u.xTCP.bits.bFinSent == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
257 pxSocket->u.xTCP.bits.bFinSent = pdTRUE_UNSIGNED; in prvTCPHandleFin()
264 pxSocket->u.xTCP.bits.bFinAcked = pdTRUE_UNSIGNED; in prvTCPHandleFin()
268 if( pxSocket->u.xTCP.bits.bFinAcked == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
274 vTCPStateChange( pxSocket, eLAST_ACK ); in prvTCPHandleFin()
281 if( pxSocket->u.xTCP.bits.bFinRecv == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
289 if( pxSocket->u.xTCP.bits.bFinLast == pdFALSE_UNSIGNED ) in prvTCPHandleFin()
303 vTCPStateChange( pxSocket, eCLOSE_WAIT ); in prvTCPHandleFin()
311 …ucIntermediateResult = ( uint8_t ) ( uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + pxT… in prvTCPHandleFin()
345 static BaseType_t prvHandleSynReceived( FreeRTOS_Socket_t * pxSocket, in prvHandleSynReceived() argument
356 … pxNetworkBuffer->pucEthernetBuffer[ ipSIZE_OF_ETH_HEADER + uxIPHeaderSizeSocket( pxSocket ) ] ) ); in prvHandleSynReceived()
358 TCPWindow_t * pxTCPWindow = &pxSocket->u.xTCP.xTCPWindow; in prvHandleSynReceived()
368 if( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) in prvHandleSynReceived()
378 … ( pxSocket->u.xTCP.eTCPState == ( uint8_t ) eSYN_RECEIVED ) ? "eSYN_RECEIVED" : "eCONNECT_SYN", in prvHandleSynReceived()
383 vTCPStateChange( pxSocket, eCLOSE_WAIT ); in prvHandleSynReceived()
392 … uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + uxOptionsLength; in prvHandleSynReceived()
399 pxTCPWindow->usPeerPortNumber = pxSocket->u.xTCP.usRemotePort; in prvHandleSynReceived()
400 pxTCPWindow->usOurPortNumber = pxSocket->usLocalPort; in prvHandleSynReceived()
402 if( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) in prvHandleSynReceived()
410 …&( pxSocket->u.xTCP.xPacket.u.ucLastPacket[ ipSIZE_OF_ETH_HEADER + uxIPHeaderSizeSocket( pxSocket … in prvHandleSynReceived()
418 vTCPWindowInit( &pxSocket->u.xTCP.xTCPWindow, in prvHandleSynReceived()
419 …ulSequenceNumber, pxSocket->u.xTCP.xTCPWindow.ulOurSequenceNumber, ( uint32_t ) pxSocket->u.xTCP.u… in prvHandleSynReceived()
441 …( void ) FreeRTOS_inet_ntop( ( pxSocket->bits.bIsIPv6 != 0U ) ? FREERTOS_AF_INET6 : FREERTOS_AF_IN… in prvHandleSynReceived()
442 … ( void * ) pxSocket->u.xTCP.xRemoteIP.xIP_IPv6.ucBytes, in prvHandleSynReceived()
446 … ( pxSocket->u.xTCP.eTCPState == ( uint8_t ) eCONNECT_SYN ) ? "active" : "passive", in prvHandleSynReceived()
447 pxSocket->usLocalPort, in prvHandleSynReceived()
449 pxSocket->u.xTCP.usRemotePort, in prvHandleSynReceived()
450 ( unsigned ) pxSocket->u.xTCP.bits.bWinScaling ) ); in prvHandleSynReceived()
454 if( ( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) || ( ulReceiveLength != 0U ) ) in prvHandleSynReceived()
458 …uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ( size_t ) ipSIZE_OF_TCP_HEADER + uxOpti… in prvHandleSynReceived()
465 if( pxSocket->u.xTCP.bits.bWinScaling == pdFALSE_UNSIGNED ) in prvHandleSynReceived()
469 pxSocket->u.xTCP.ucMyWinScaleFactor = 0; in prvHandleSynReceived()
470 pxSocket->u.xTCP.ucPeerWinScaleFactor = 0; in prvHandleSynReceived()
477 vTCPStateChange( pxSocket, eESTABLISHED ); in prvHandleSynReceived()
498 static BaseType_t prvHandleEstablished( FreeRTOS_Socket_t * pxSocket, in prvHandleEstablished() argument
509 …xNetworkBuffer )->pucEthernetBuffer[ ipSIZE_OF_ETH_HEADER + uxIPHeaderSizeSocket( pxSocket ) ] ) ); in prvHandleEstablished()
511 TCPWindow_t * pxTCPWindow = &pxSocket->u.xTCP.xTCPWindow; in prvHandleEstablished()
521 pxSocket->u.xTCP.ulWindowSize = ( uint32_t ) usWindow; in prvHandleEstablished()
524 pxSocket->u.xTCP.ulWindowSize = in prvHandleEstablished()
525 ( pxSocket->u.xTCP.ulWindowSize << pxSocket->u.xTCP.ucPeerWinScaleFactor ); in prvHandleEstablished()
542 if( ( pxSocket->u.xTCP.txStream != NULL ) && ( ulCount > 0U ) ) in prvHandleEstablished()
548 … if( uxStreamBufferGet( pxSocket->u.xTCP.txStream, 0U, NULL, ( size_t ) ulCount, pdFALSE ) != 0U ) in prvHandleEstablished()
550 pxSocket->xEventBits |= ( EventBits_t ) eSOCKET_SEND; in prvHandleEstablished()
554 … if( ( pxSocket->xSelectBits & ( ( EventBits_t ) eSELECT_WRITE ) ) != 0U ) in prvHandleEstablished()
556 … pxSocket->xEventBits |= ( ( EventBits_t ) eSELECT_WRITE ) << SOCKET_EVENT_BIT_COUNT; in prvHandleEstablished()
565 if( ipconfigIS_VALID_PROG_ADDRESS( pxSocket->u.xTCP.pxHandleSent ) ) in prvHandleEstablished()
567 pxSocket->u.xTCP.pxHandleSent( ( Socket_t ) pxSocket, ulCount ); in prvHandleEstablished()
576 if( pxSocket->u.xTCP.txStream != NULL ) in prvHandleEstablished()
578 prvTCPAddTxData( pxSocket ); in prvHandleEstablished()
581 … pxSocket->u.xTCP.xTCPWindow.ulOurSequenceNumber = pxTCPWindow->tx.ulCurrentSequenceNumber; in prvHandleEstablished()
583 …if( ( pxSocket->u.xTCP.bits.bFinAccepted != pdFALSE_UNSIGNED ) || ( ( ucTCPFlags & ( uint8_t ) tcp… in prvHandleEstablished()
589 if( pxSocket->u.xTCP.bits.bFinSent == pdFALSE_UNSIGNED ) in prvHandleEstablished()
599 pxSocket->usLocalPort, in prvHandleEstablished()
600 pxSocket->u.xTCP.usRemotePort, in prvHandleEstablished()
626 … ( unsigned ) ( ulSequenceNumber - pxSocket->u.xTCP.xTCPWindow.rx.ulFirstSequenceNumber ), in prvHandleEstablished()
628 …( unsigned ) ( pxTCPWindow->tx.ulCurrentSequenceNumber - pxSocket->u.xTCP.xTCPWindow.tx.ulFirstSeq… in prvHandleEstablished()
633 pxSocket->u.xTCP.bits.bFinAccepted = pdTRUE_UNSIGNED; in prvHandleEstablished()
634 xSendLength = prvTCPHandleFin( pxSocket, *ppxNetworkBuffer ); in prvHandleEstablished()
644 … uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + uxOptionsLength; in prvHandleEstablished()
649 if( pxSocket->u.xTCP.bits.bFinSent != pdFALSE_UNSIGNED ) in prvHandleEstablished()
665 lSendResult = prvTCPPrepareSend( pxSocket, ppxNetworkBuffer, uxOptionsLength ); in prvHandleEstablished()
706 BaseType_t prvTCPHandleState( FreeRTOS_Socket_t * pxSocket, in prvTCPHandleState() argument
729 TCPWindow_t * pxTCPWindow = &( pxSocket->u.xTCP.xTCPWindow ); in prvTCPHandleState()
737 if( pxSocket->u.xTCP.eTCPState >= eESTABLISHED ) in prvTCPHandleState()
744 pxSocket->u.xTCP.bits.bWinChange = pdTRUE_UNSIGNED; in prvTCPHandleState()
758 if( prvStoreRxData( pxSocket, pucRecvData, *ppxNetworkBuffer, ulReceiveLength ) < 0 ) in prvTCPHandleState()
766 uxOptionsLength = prvSetOptions( pxSocket, *ppxNetworkBuffer ); in prvTCPHandleState()
768 …if( ( pxSocket->u.xTCP.eTCPState == eSYN_RECEIVED ) && ( ( ucTCPFlags & ( uint8_t ) tcpTCP_FLAG_CT… in prvTCPHandleState()
776 vTCPStateChange( pxSocket, eSYN_FIRST ); in prvTCPHandleState()
779 …if( ( ( ucTCPFlags & tcpTCP_FLAG_FIN ) != 0U ) && ( pxSocket->u.xTCP.bits.bFinRecv == pdFALSE_UNSI… in prvTCPHandleState()
784 pxSocket->u.xTCP.bits.bFinRecv = pdTRUE_UNSIGNED; in prvTCPHandleState()
787 if( pxSocket->u.xTCP.bits.bFinSent == pdFALSE_UNSIGNED ) in prvTCPHandleState()
790 pxSocket->u.xTCP.bits.bFinLast = pdTRUE_UNSIGNED; in prvTCPHandleState()
794 eState = ( eIPTCPState_t ) pxSocket->u.xTCP.eTCPState; in prvTCPHandleState()
817 uxOptionsLength = prvSetSynAckOptions( pxSocket, pxTCPHeader ); in prvTCPHandleState()
820 … uxIntermediateResult = uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER + uxOptionsLength; in prvTCPHandleState()
827 vTCPStateChange( pxSocket, eSYN_RECEIVED ); in prvTCPHandleState()
840 …xSendLength = prvHandleSynReceived( pxSocket, *( ppxNetworkBuffer ), ulReceiveLength, uxOptionsLen… in prvTCPHandleState()
848 …xSendLength = prvHandleEstablished( pxSocket, ppxNetworkBuffer, ulReceiveLength, uxOptionsLength ); in prvTCPHandleState()
861 xSendLength = prvTCPHandleFin( pxSocket, *ppxNetworkBuffer ); in prvTCPHandleState()
893 xSendLength = prvSendData( pxSocket, ppxNetworkBuffer, ulReceiveLength, xSendLength ); in prvTCPHandleState()
909 FreeRTOS_Socket_t * prvHandleListen( FreeRTOS_Socket_t * pxSocket, in prvHandleListen() argument
918 pxNewSocket = prvHandleListen_IPV4( pxSocket, pxNetworkBuffer ); in prvHandleListen()
924 pxNewSocket = prvHandleListen_IPV6( pxSocket, pxNetworkBuffer ); in prvHandleListen()
950 FreeRTOS_Socket_t * pxSocket ) in prvTCPSocketCopy() argument
955 pxNewSocket->xReceiveBlockTime = pxSocket->xReceiveBlockTime; in prvTCPSocketCopy()
956 pxNewSocket->xSendBlockTime = pxSocket->xSendBlockTime; in prvTCPSocketCopy()
957 pxNewSocket->ucSocketOptions = pxSocket->ucSocketOptions; in prvTCPSocketCopy()
958 pxNewSocket->u.xTCP.uxRxStreamSize = pxSocket->u.xTCP.uxRxStreamSize; in prvTCPSocketCopy()
959 pxNewSocket->u.xTCP.uxTxStreamSize = pxSocket->u.xTCP.uxTxStreamSize; in prvTCPSocketCopy()
960 pxNewSocket->u.xTCP.uxLittleSpace = pxSocket->u.xTCP.uxLittleSpace; in prvTCPSocketCopy()
961 pxNewSocket->u.xTCP.uxEnoughSpace = pxSocket->u.xTCP.uxEnoughSpace; in prvTCPSocketCopy()
962 pxNewSocket->u.xTCP.uxRxWinSize = pxSocket->u.xTCP.uxRxWinSize; in prvTCPSocketCopy()
963 pxNewSocket->u.xTCP.uxTxWinSize = pxSocket->u.xTCP.uxTxWinSize; in prvTCPSocketCopy()
967 pxNewSocket->pxUserSemaphore = pxSocket->pxUserSemaphore; in prvTCPSocketCopy()
974 pxNewSocket->u.xTCP.pxHandleConnected = pxSocket->u.xTCP.pxHandleConnected; in prvTCPSocketCopy()
975 pxNewSocket->u.xTCP.pxHandleReceive = pxSocket->u.xTCP.pxHandleReceive; in prvTCPSocketCopy()
976 pxNewSocket->u.xTCP.pxHandleSent = pxSocket->u.xTCP.pxHandleSent; in prvTCPSocketCopy()
984 if( pxSocket->pxSocketSet != NULL ) in prvTCPSocketCopy()
986 pxNewSocket->pxSocketSet = pxSocket->pxSocketSet; in prvTCPSocketCopy()
987 …pxNewSocket->xSelectBits = pxSocket->xSelectBits | ( ( EventBits_t ) eSELECT_READ ) | ( ( EventBit… in prvTCPSocketCopy()
994 xAddress.sin_port = FreeRTOS_htons( pxSocket->usLocalPort ); in prvTCPSocketCopy()
1005 pxNewSocket->u.xTCP.pxPeerSocket = pxSocket; in prvTCPSocketCopy()
1016 if( pxSocket->u.xTCP.pxPeerSocket == NULL ) in prvTCPSocketCopy()
1018 pxSocket->u.xTCP.pxPeerSocket = pxNewSocket; in prvTCPSocketCopy()
1023 pxSocket->u.xTCP.usChildCount++; in prvTCPSocketCopy()
1026 pxSocket->usLocalPort, in prvTCPSocketCopy()
1027 pxSocket->u.xTCP.usChildCount, in prvTCPSocketCopy()
1028 pxSocket->u.xTCP.usBacklog, in prvTCPSocketCopy()
1029 ( pxSocket->u.xTCP.usChildCount == 1U ) ? "" : "ren" ) ); in prvTCPSocketCopy()