/* FreeRTOS V202104.00 All rights reserved VISIT http://www.FreeRTOS.org TO ENSURE YOU ARE USING THE LATEST VERSION. This file is part of the FreeRTOS distribution. FreeRTOS is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License (version 2) as published by the Free Software Foundation >>!AND MODIFIED BY!<< the FreeRTOS exception. *************************************************************************** >>! NOTE: The modification to the GPL is included to allow you to !<< >>! distribute a combined work that includes FreeRTOS without being !<< >>! obliged to provide the source code for proprietary components !<< >>! outside of the FreeRTOS kernel. !<< *************************************************************************** FreeRTOS is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. Full license text is available on the following link: http://www.freertos.org/a00114.html *************************************************************************** * * * FreeRTOS provides completely free yet professionally developed, * * robust, strictly quality controlled, supported, and cross * * platform software that is more than just the market leader, it * * is the industry's de facto standard. * * * * Help yourself get started quickly while simultaneously helping * * to support the FreeRTOS project by purchasing a FreeRTOS * * tutorial book, reference manual, or both: * * http://www.FreeRTOS.org/Documentation * * * *************************************************************************** http://www.FreeRTOS.org/FAQHelp.html - Having a problem? Start by reading the FAQ page "My application does not run, what could be wrong?". Have you defined configASSERT()? http://www.FreeRTOS.org/support - In return for receiving this top quality embedded software for free we request you assist our global community by participating in the support forum. http://www.FreeRTOS.org/training - Investing in training allows your team to be as productive as possible as early as possible. Now you can receive FreeRTOS training directly from Richard Barry, CEO of Real Time Engineers Ltd, and the world's leading authority on the world's leading RTOS. http://www.FreeRTOS.org/plus - A selection of FreeRTOS ecosystem products, including FreeRTOS+Trace - an indispensable productivity tool, a DOS compatible FAT file system, and our tiny thread aware UDP/IP stack. http://www.FreeRTOS.org/labs - Where new FreeRTOS products go to incubate. Come and try FreeRTOS+TCP, our new open source TCP/IP stack for FreeRTOS. http://www.OpenRTOS.com - Real Time Engineers ltd. license FreeRTOS to High Integrity Systems ltd. to sell under the OpenRTOS brand. Low cost OpenRTOS licenses offer ticketed support, indemnification and commercial middleware. http://www.SafeRTOS.com - High Integrity Systems also provide a safety engineered and independently SIL3 certified version for use in safety and mission critical applications that require provable dependability. 1 tab == 4 spaces! */ /* * FreeRTOS tasks are used with FreeRTOS+TCP to create a TCP echo server on the * standard echo port number (7). * * See the following web page for essential demo usage and configuration * details: * http://www.freertos.org/FreeRTOS-Plus/FreeRTOS_Plus_TCP/TCP_Echo_Server.html */ /* Standard includes. */ #include //#include /* FreeRTOS includes. */ #include "FreeRTOS.h" #include "task.h" #include "semphr.h" /* FreeRTOS+TCP includes. */ #include "FreeRTOS_IP.h" #include "FreeRTOS_Sockets.h" /* Remove the whole file if FreeRTOSIPConfig.h is set to exclude TCP. */ #if( ipconfigUSE_TCP == 1 ) /* The maximum time to wait for a closing socket to close. */ #define tcpechoSHUTDOWN_DELAY ( pdMS_TO_TICKS( 5000 ) ) /* The standard echo port number. */ #define tcpechoPORT_NUMBER 7 /* If ipconfigUSE_TCP_WIN is 1 then the Tx sockets will use a buffer size set by ipconfigTCP_TX_BUFFER_LENGTH, and the Tx window size will be configECHO_SERVER_TX_WINDOW_SIZE times the buffer size. Note ipconfigTCP_TX_BUFFER_LENGTH is set in FreeRTOSIPConfig.h as it is a standard TCP/IP stack constant, whereas configECHO_SERVER_TX_WINDOW_SIZE is set in FreeRTOSConfig.h as it is a demo application constant. */ #ifndef configECHO_SERVER_TX_WINDOW_SIZE #define configECHO_SERVER_TX_WINDOW_SIZE 2 #endif /* If ipconfigUSE_TCP_WIN is 1 then the Rx sockets will use a buffer size set by ipconfigTCP_RX_BUFFER_LENGTH, and the Rx window size will be configECHO_SERVER_RX_WINDOW_SIZE times the buffer size. Note ipconfigTCP_RX_BUFFER_LENGTH is set in FreeRTOSIPConfig.h as it is a standard TCP/IP stack constant, whereas configECHO_SERVER_RX_WINDOW_SIZE is set in FreeRTOSConfig.h as it is a demo application constant. */ #ifndef configECHO_SERVER_RX_WINDOW_SIZE #define configECHO_SERVER_RX_WINDOW_SIZE 2 #endif void FreeRTOS_ReleaseTCPPayload( Socket_t xSocket, BaseType_t xByteCount ); /*-----------------------------------------------------------*/ /* * Uses FreeRTOS+TCP to listen for incoming echo connections, creating a socket * to handle each connection. */ static void prvConnectionListeningTask( void *pvParameters ); /*-----------------------------------------------------------*/ void vStartSimpleTCPServerTasks( uint16_t usStackSize, UBaseType_t uxPriority ) { /* Create the TCP echo server. */ xTaskCreate( prvConnectionListeningTask, "TcpEchoServer", usStackSize, NULL, uxPriority, NULL ); } /*-----------------------------------------------------------*/ static Socket_t xSockets[2]; static const BaseType_t xBacklog = sizeof( xSockets ) / sizeof( xSockets[0] ); static void prvConnectionListeningTask( void *pvParameters ) { //Socket_t xSockets[2]; //static const BaseType_t xBacklog = sizeof( xSockets ) / sizeof( xSockets[0] ); struct freertos_sockaddr xClient, xBindAddress; socklen_t xClientSize = sizeof( xClient ); Socket_t xListeningSocket, xConnectedSocket; SocketSet_t xFD_Set; static const TickType_t xReceiveTimeOut = 0; static const TickType_t xSendTimeOut = pdMS_TO_TICKS( 5000 ); BaseType_t xResult; BaseType_t xInst; uint8_t *pucRxBuffer; #if( ipconfigUSE_TCP_WIN == 1 ) WinProperties_t xWinProps; /* Fill in the buffer and window sizes that will be used by the socket. */ xWinProps.lTxBufSize = ipconfigTCP_TX_BUFFER_LENGTH; xWinProps.lTxWinSize = configECHO_SERVER_TX_WINDOW_SIZE; xWinProps.lRxBufSize = ipconfigTCP_RX_BUFFER_LENGTH; xWinProps.lRxWinSize = configECHO_SERVER_RX_WINDOW_SIZE; #endif /* ipconfigUSE_TCP_WIN */ /* Just to prevent compiler warnings. */ ( void ) pvParameters; /* Initialize the list of client sockets. */ for( xInst = 0; xInst < xBacklog; xInst++ ) { xSockets[xInst] = NULL; } /* Create the set of sockets that will be passed into FreeRTOS_select(). */ xFD_Set = FreeRTOS_CreateSocketSet(); configASSERT( xFD_Set != NULL ); /* Attempt to open the socket. */ xListeningSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_STREAM, FREERTOS_IPPROTO_TCP ); configASSERT( xListeningSocket != FREERTOS_INVALID_SOCKET ); /* Set a 0 time out so accept() will not wait for a connection. */ FreeRTOS_setsockopt( xListeningSocket, 0, FREERTOS_SO_RCVTIMEO, &xReceiveTimeOut, sizeof( xReceiveTimeOut ) ); /* Set the window and buffer sizes. */ #if( ipconfigUSE_TCP_WIN == 1 ) { FreeRTOS_setsockopt( xListeningSocket, 0, FREERTOS_SO_WIN_PROPERTIES, ( void * ) &xWinProps, sizeof( xWinProps ) ); } #endif /* ipconfigUSE_TCP_WIN */ /* Bind the socket to the port that the client task will send to, then listen for incoming connections. */ xBindAddress.sin_port = tcpechoPORT_NUMBER; xBindAddress.sin_port = FreeRTOS_htons( xBindAddress.sin_port ); FreeRTOS_bind( xListeningSocket, &xBindAddress, sizeof( xBindAddress ) ); FreeRTOS_listen( xListeningSocket, xBacklog ); /* Only the READ event can unblock a call to select(). */ FreeRTOS_FD_SET( xListeningSocket, xFD_Set, eSELECT_READ ); for( ;; ) { /* Wait for any event within the socket set. */ xResult = FreeRTOS_select( xFD_Set, portMAX_DELAY ); if( xResult != 0 ) { /* The return value should never be zero because FreeRTOS_select() was called with an indefinite delay (assuming INCLUDE_vTaskSuspend is set to 1). Now check each socket which belongs to the set if it had an event. */ for( xInst = 0; xInst < xBacklog; xInst++ ) { if( xSockets[xInst] != NULL ) { xResult = FreeRTOS_FD_ISSET( xSockets[xInst], xFD_Set ); if( xResult & eSELECT_EXCEPT ) { FreeRTOS_closesocket( xSockets[xInst] ); FreeRTOS_FD_SET( xSockets[xInst], xFD_Set, eSELECT_ALL ); xSockets[xInst] = NULL; } else { if( xResult & eSELECT_READ ) { BaseType_t lBytes; /* Receive data on the socket. */ #define USE_ZERO_COPY 1 #if USE_ZERO_COPY lBytes = FreeRTOS_recv( xSockets[xInst], &pucRxBuffer, 0, FREERTOS_ZERO_COPY ); #else uint8_t ucRxBuffer[512]; pucRxBuffer = ucRxBuffer; lBytes = FreeRTOS_recv( xSockets[xInst], pucRxBuffer, sizeof( ucRxBuffer ), 0 ); #endif /* If data was received, echo it back. */ if( lBytes >= 0 ) { BaseType_t lSent = 0; BaseType_t lTotalSent = 0; /* Call send() until all the data has been sent. */ while( ( lSent >= 0 ) && ( ( lTotalSent += lSent ) < lBytes ) ) { lSent = FreeRTOS_send( xSockets[xInst], pucRxBuffer + lTotalSent, lBytes - lTotalSent, 0 ); } #if USE_ZERO_COPY /* Release the data now that it was consumed. */ FreeRTOS_ReleaseTCPPayload( xSockets[xInst], lBytes ); #endif } } } } } if( FreeRTOS_FD_ISSET( xListeningSocket, xFD_Set ) ) { /* Wait for a client to connect. */ xConnectedSocket = FreeRTOS_accept( xListeningSocket, &xClient, &xClientSize ); configASSERT( xConnectedSocket != FREERTOS_INVALID_SOCKET ); for( xInst = 0; xInst < xBacklog; xInst++ ) { if( xSockets[xInst] == NULL ) break; } if(xInst < xBacklog) { xSockets[xInst] = xConnectedSocket; FreeRTOS_FD_SET( xConnectedSocket, xFD_Set, eSELECT_READ | eSELECT_EXCEPT ); FreeRTOS_setsockopt( xConnectedSocket, 0, FREERTOS_SO_RCVTIMEO, &xReceiveTimeOut, sizeof( xReceiveTimeOut ) ); FreeRTOS_setsockopt( xConnectedSocket, 0, FREERTOS_SO_SNDTIMEO, &xSendTimeOut, sizeof( xSendTimeOut ) ); } else { /* This shouldn't happen. */ FreeRTOS_closesocket( xConnectedSocket ); } } } } } /*-----------------------------------------------------------*/ void FreeRTOS_ReleaseTCPPayload( Socket_t xSocket, BaseType_t xByteCount ) { BaseType_t xByteCountReleased; /* Call recv with NULL pointer to advance the circular buffer. */ xByteCountReleased = FreeRTOS_recv( xSocket, NULL, xByteCount, FREERTOS_MSG_DONTWAIT ); configASSERT( xByteCountReleased == xByteCount ); } /*-----------------------------------------------------------*/ /* The whole file is excluded if TCP is not compiled in. */ #endif /* ipconfigUSE_TCP */