Lines Matching refs:pxSocket
107 void vSocketCloseNextTime( FreeRTOS_Socket_t * pxSocket ) in vSocketCloseNextTime() argument
109 if( ( xSocketToClose != NULL ) && ( xSocketToClose != pxSocket ) ) in vSocketCloseNextTime()
114 xSocketToClose = pxSocket; in vSocketCloseNextTime()
123 void vSocketListenNextTime( FreeRTOS_Socket_t * pxSocket ) in vSocketListenNextTime() argument
125 if( ( xSocketToListen != NULL ) && ( xSocketToListen != pxSocket ) ) in vSocketListenNextTime()
130 xSocketToListen = pxSocket; in vSocketListenNextTime()
152 BaseType_t xTCPSocketCheck( FreeRTOS_Socket_t * pxSocket ) in xTCPSocketCheck() argument
157 … if( ( pxSocket->u.xTCP.eTCPState >= eESTABLISHED ) && ( pxSocket->u.xTCP.txStream != NULL ) ) in xTCPSocketCheck()
161 prvTCPAddTxData( pxSocket ); in xTCPSocketCheck()
166 if( pxSocket->u.xTCP.pxAckMessage != NULL ) in xTCPSocketCheck()
170 if( pxSocket->u.xTCP.bits.bUserShutdown == pdFALSE_UNSIGNED ) in xTCPSocketCheck()
175 if( pxSocket->u.xTCP.eTCPState != eCLOSED ) in xTCPSocketCheck()
177 … if( ( xTCPWindowLoggingLevel > 1 ) && ipconfigTCP_MAY_LOG_PORT( pxSocket->usLocalPort ) ) in xTCPSocketCheck()
180 pxSocket->usLocalPort, in xTCPSocketCheck()
181 pxSocket->u.xTCP.usRemotePort, in xTCPSocketCheck()
182 …( unsigned ) ( pxSocket->u.xTCP.xTCPWindow.rx.ulCurrentSequenceNumber - pxSocket->u.xTCP.xTCPWindo… in xTCPSocketCheck()
183 …( unsigned ) ( pxSocket->u.xTCP.xTCPWindow.ulOurSequenceNumber - pxSocket->u.xTCP.xTCPWindow.tx.ul… in xTCPSocketCheck()
184 … ( unsigned ) ( uxIPHeaderSizeSocket( pxSocket ) + ipSIZE_OF_TCP_HEADER ) ) ); in xTCPSocketCheck()
187 …prvTCPReturnPacket( pxSocket, pxSocket->u.xTCP.pxAckMessage, ( uint32_t ) ( uxIPHeaderSizeSocket( … in xTCPSocketCheck()
193 pxSocket->u.xTCP.pxAckMessage = NULL; in xTCPSocketCheck()
198 if( prvTCPNextTimeout( pxSocket ) > 1U ) in xTCPSocketCheck()
211 if( pxSocket->u.xTCP.pxAckMessage != NULL ) in xTCPSocketCheck()
213 vReleaseNetworkBufferAndDescriptor( pxSocket->u.xTCP.pxAckMessage ); in xTCPSocketCheck()
214 pxSocket->u.xTCP.pxAckMessage = NULL; in xTCPSocketCheck()
223 if( ( pxSocket->u.xTCP.eTCPState >= eESTABLISHED ) || in xTCPSocketCheck()
224 ( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) ) in xTCPSocketCheck()
226 ( void ) prvTCPSendPacket( pxSocket ); in xTCPSocketCheck()
230 ( void ) prvTCPNextTimeout( pxSocket ); in xTCPSocketCheck()
236 xResult = prvTCPStatusAgeCheck( pxSocket ); in xTCPSocketCheck()
254 void prvTCPTouchSocket( struct xSOCKET * pxSocket ) in prvTCPTouchSocket() argument
258 pxSocket->u.xTCP.xLastActTime = xTaskGetTickCount(); in prvTCPTouchSocket()
264 pxSocket->u.xTCP.bits.bWaitKeepAlive = pdFALSE_UNSIGNED; in prvTCPTouchSocket()
265 pxSocket->u.xTCP.bits.bSendKeepAlive = pdFALSE_UNSIGNED; in prvTCPTouchSocket()
266 pxSocket->u.xTCP.ucKeepRepCount = 0U; in prvTCPTouchSocket()
267 pxSocket->u.xTCP.xLastAliveTime = xTaskGetTickCount(); in prvTCPTouchSocket()
271 ( void ) pxSocket; in prvTCPTouchSocket()
284 void vTCPStateChange( FreeRTOS_Socket_t * pxSocket, in vTCPStateChange() argument
287 FreeRTOS_Socket_t * xParent = pxSocket; in vTCPStateChange()
288 …BaseType_t bBefore = tcpNOW_CONNECTED( ( BaseType_t ) pxSocket->u.xTCP.eTCPState ); /* Was it conn… in vTCPStateChange()
291 eIPTCPState_t xPreviousState = pxSocket->u.xTCP.eTCPState; in vTCPStateChange()
318 if( pxSocket->u.xTCP.bits.bPassQueued != pdFALSE_UNSIGNED ) in vTCPStateChange()
321 if( pxSocket->u.xTCP.bits.bReuseSocket == pdFALSE_UNSIGNED ) in vTCPStateChange()
323 xParent = pxSocket->u.xTCP.pxPeerSocket; in vTCPStateChange()
332 if( pxSocket->u.xTCP.bits.bPassQueued != pdFALSE_UNSIGNED ) in vTCPStateChange()
343 xParent->u.xTCP.pxPeerSocket = pxSocket; in vTCPStateChange()
375 pxSocket->u.xTCP.pxPeerSocket = NULL; in vTCPStateChange()
376 pxSocket->u.xTCP.bits.bPassQueued = pdFALSE_UNSIGNED; in vTCPStateChange()
379 pxSocket->u.xTCP.bits.bPassAccept = pdTRUE_UNSIGNED; in vTCPStateChange()
386 pxSocket->xEventBits |= ( EventBits_t ) eSOCKET_CONNECT; in vTCPStateChange()
390 … if( ( pxSocket->xSelectBits & ( ( EventBits_t ) eSELECT_WRITE ) ) != 0U ) in vTCPStateChange()
392 … pxSocket->xEventBits |= ( ( EventBits_t ) eSELECT_WRITE ) << SOCKET_EVENT_BIT_COUNT; in vTCPStateChange()
415 …if( ( ipconfigIS_VALID_PROG_ADDRESS( pxSocket->u.xTCP.pxHandleConnected ) ) && ( xConnected == NUL… in vTCPStateChange()
418 xConnected = pxSocket; in vTCPStateChange()
423 if( prvTCPSocketIsActive( pxSocket->u.xTCP.eTCPState ) == 0 ) in vTCPStateChange()
429 pxSocket->u.xTCP.usTimeout = 0U; in vTCPStateChange()
434 pxSocket->u.xTCP.eTCPState = eTCPState; in vTCPStateChange()
443 if( ( pxSocket->u.xTCP.bits.bPassQueued != pdFALSE_UNSIGNED ) || in vTCPStateChange()
444 ( pxSocket->u.xTCP.bits.bPassAccept != pdFALSE_UNSIGNED ) ) in vTCPStateChange()
446 if( pxSocket->u.xTCP.bits.bReuseSocket == pdFALSE_UNSIGNED ) in vTCPStateChange()
448 pxSocket->u.xTCP.bits.bPassQueued = pdFALSE_UNSIGNED; in vTCPStateChange()
449 pxSocket->u.xTCP.bits.bPassAccept = pdFALSE_UNSIGNED; in vTCPStateChange()
456 if( pxSocket->u.xTCP.bits.bReuseSocket == pdFALSE_UNSIGNED ) in vTCPStateChange()
459 vSocketCloseNextTime( pxSocket ); in vTCPStateChange()
469 … if( ( eTCPState == eCLOSE_WAIT ) && ( pxSocket->u.xTCP.bits.bReuseSocket == pdTRUE_UNSIGNED ) ) in vTCPStateChange()
475 … FreeRTOS_debug_printf( ( "Restoring a reuse socket port %u\n", pxSocket->usLocalPort ) ); in vTCPStateChange()
479 pxSocket->u.xTCP.eTCPState = eCLOSED; in vTCPStateChange()
483 vSocketListenNextTime( pxSocket ); in vTCPStateChange()
493 prvTCPTouchSocket( pxSocket ); in vTCPStateChange()
497 … if( ( xTCPWindowLoggingLevel >= 0 ) && ( ipconfigTCP_MAY_LOG_PORT( pxSocket->usLocalPort ) ) ) in vTCPStateChange()
501 switch( pxSocket->bits.bIsIPv6 ) /* LCOV_EXCL_BR_LINE */ in vTCPStateChange()
506 … uint32_t ulIPAddress = FreeRTOS_ntohl( pxSocket->u.xTCP.xRemoteIP.ulIP_IPv4 ); in vTCPStateChange()
518 pxSocket->u.xTCP.xRemoteIP.xIP_IPv6.ucBytes, in vTCPStateChange()
530 pxSocket->usLocalPort, in vTCPStateChange()
532 pxSocket->u.xTCP.usRemotePort, in vTCPStateChange()
564 TickType_t prvTCPNextTimeout( struct xSOCKET * pxSocket ) in prvTCPNextTimeout() argument
568 if( pxSocket->u.xTCP.eTCPState == eCONNECT_SYN ) in prvTCPNextTimeout()
571 if( pxSocket->u.xTCP.bits.bConnPrepared != pdFALSE_UNSIGNED ) in prvTCPNextTimeout()
575 if( pxSocket->u.xTCP.ucRepCount < 3U ) in prvTCPNextTimeout()
577 ulDelayMs = ( ( ( uint32_t ) 3000U ) << ( pxSocket->u.xTCP.ucRepCount - 1U ) ); in prvTCPNextTimeout()
591 … ( unsigned ) pxSocket->u.xTCP.xRemoteIP.ulIP_IPv4, pxSocket->u.xTCP.usRemotePort, in prvTCPNextTimeout()
592 pxSocket->u.xTCP.ucRepCount, ( unsigned ) ulDelayMs ) ); in prvTCPNextTimeout()
593 pxSocket->u.xTCP.usTimeout = ( uint16_t ) ipMS_TO_MIN_TICKS( ulDelayMs ); in prvTCPNextTimeout()
595 else if( pxSocket->u.xTCP.usTimeout == 0U ) in prvTCPNextTimeout()
598 …BaseType_t xResult = xTCPWindowTxHasData( &pxSocket->u.xTCP.xTCPWindow, pxSocket->u.xTCP.ulWindowS… in prvTCPNextTimeout()
616 …pxSocket->u.xTCP.usTimeout = ( uint16_t ) ipMS_TO_MIN_TICKS( ulDelayMs ); /* LCOV_EXCL_BR_LINE ulD… in prvTCPNextTimeout()
625 return ( TickType_t ) pxSocket->u.xTCP.usTimeout; in prvTCPNextTimeout()
693 BaseType_t xTCPCheckNewClient( FreeRTOS_Socket_t * pxSocket ) in xTCPCheckNewClient() argument
695 TickType_t uxLocalPort = ( TickType_t ) FreeRTOS_htons( pxSocket->usLocalPort ); in xTCPCheckNewClient()
717 pxSocket->u.xTCP.pxPeerSocket = pxFound; in xTCPCheckNewClient()
718 … FreeRTOS_debug_printf( ( "xTCPCheckNewClient[0]: client on port %u\n", pxSocket->usLocalPort ) ); in xTCPCheckNewClient()