Compare commits
2 Commits
7a5707d87b
...
8648d1a687
| Author | SHA1 | Date |
|---|---|---|
|
|
8648d1a687 | |
|
|
4896902361 |
|
|
@ -0,0 +1,288 @@
|
||||||
|
/*
|
||||||
|
FreeRTOS V202212.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:
|
||||||
|
* https://www.FreeRTOS.org/FreeRTOS-Plus/FreeRTOS_Plus_TCP/TCP_Echo_Server.html
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* Standard includes. */
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <stdio.h>
|
||||||
|
|
||||||
|
/* 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
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Uses FreeRTOS+TCP to listen for incoming echo connections, creating a task
|
||||||
|
* to handle each connection.
|
||||||
|
*/
|
||||||
|
static void prvConnectionListeningTask( void *pvParameters );
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Created by the connection listening task to handle a single connection.
|
||||||
|
*/
|
||||||
|
static void prvServerConnectionInstance( void *pvParameters );
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
/* Stores the stack size passed into vStartSimpleTCPServerTasks() so it can be
|
||||||
|
reused when the server listening task creates tasks to handle connections. */
|
||||||
|
static uint16_t usUsedStackSize = 0;
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
void vStartSimpleTCPServerTasks( uint16_t usStackSize, UBaseType_t uxPriority )
|
||||||
|
{
|
||||||
|
/* Create the TCP echo server. */
|
||||||
|
xTaskCreate( prvConnectionListeningTask, "ServerListener", usStackSize, NULL, uxPriority + 1, NULL );
|
||||||
|
|
||||||
|
/* Remember the requested stack size so it can be re-used by the server
|
||||||
|
listening task when it creates tasks to handle connections. */
|
||||||
|
usUsedStackSize = usStackSize;
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvConnectionListeningTask( void *pvParameters )
|
||||||
|
{
|
||||||
|
struct freertos_sockaddr xClient, xBindAddress;
|
||||||
|
Socket_t xListeningSocket, xConnectedSocket;
|
||||||
|
socklen_t xSize = sizeof( xClient );
|
||||||
|
static const TickType_t xReceiveTimeOut = portMAX_DELAY;
|
||||||
|
const BaseType_t xBacklog = 20;
|
||||||
|
|
||||||
|
#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;
|
||||||
|
|
||||||
|
/* Attempt to open the socket. */
|
||||||
|
xListeningSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_STREAM, FREERTOS_IPPROTO_TCP );
|
||||||
|
configASSERT( xListeningSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* Set a time out so accept() will just 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 );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Wait for a client to connect. */
|
||||||
|
xConnectedSocket = FreeRTOS_accept( xListeningSocket, &xClient, &xSize );
|
||||||
|
configASSERT( xConnectedSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* Spawn a task to handle the connection. */
|
||||||
|
xTaskCreate( prvServerConnectionInstance, "EchoServer", usUsedStackSize, ( void * ) xConnectedSocket, tskIDLE_PRIORITY, NULL );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvServerConnectionInstance( void *pvParameters )
|
||||||
|
{
|
||||||
|
int32_t lBytes, lSent, lTotalSent;
|
||||||
|
Socket_t xConnectedSocket;
|
||||||
|
static const TickType_t xReceiveTimeOut = pdMS_TO_TICKS( 5000 );
|
||||||
|
static const TickType_t xSendTimeOut = pdMS_TO_TICKS( 5000 );
|
||||||
|
TickType_t xTimeOnShutdown;
|
||||||
|
uint8_t *pucRxBuffer;
|
||||||
|
|
||||||
|
xConnectedSocket = ( Socket_t ) pvParameters;
|
||||||
|
|
||||||
|
/* Attempt to create the buffer used to receive the string to be echoed
|
||||||
|
back. This could be avoided using a zero copy interface that just returned
|
||||||
|
the same buffer. */
|
||||||
|
pucRxBuffer = ( uint8_t * ) pvPortMalloc( ipconfigTCP_MSS );
|
||||||
|
|
||||||
|
if( pucRxBuffer != NULL )
|
||||||
|
{
|
||||||
|
FreeRTOS_setsockopt( xConnectedSocket, 0, FREERTOS_SO_RCVTIMEO, &xReceiveTimeOut, sizeof( xReceiveTimeOut ) );
|
||||||
|
FreeRTOS_setsockopt( xConnectedSocket, 0, FREERTOS_SO_SNDTIMEO, &xSendTimeOut, sizeof( xReceiveTimeOut ) );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Zero out the receive array so there is NULL at the end of the string
|
||||||
|
when it is printed out. */
|
||||||
|
memset( pucRxBuffer, 0x00, ipconfigTCP_MSS );
|
||||||
|
|
||||||
|
/* Receive data on the socket. */
|
||||||
|
lBytes = FreeRTOS_recv( xConnectedSocket, pucRxBuffer, ipconfigTCP_MSS, 0 );
|
||||||
|
|
||||||
|
/* If data was received, echo it back. */
|
||||||
|
if( lBytes >= 0 )
|
||||||
|
{
|
||||||
|
lSent = 0;
|
||||||
|
lTotalSent = 0;
|
||||||
|
|
||||||
|
/* Call send() until all the data has been sent. */
|
||||||
|
while( ( lSent >= 0 ) && ( lTotalSent < lBytes ) )
|
||||||
|
{
|
||||||
|
lSent = FreeRTOS_send( xConnectedSocket, pucRxBuffer, lBytes - lTotalSent, 0 );
|
||||||
|
lTotalSent += lSent;
|
||||||
|
}
|
||||||
|
|
||||||
|
if( lSent < 0 )
|
||||||
|
{
|
||||||
|
/* Socket closed? */
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/* Socket closed? */
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Initiate a shutdown in case it has not already been initiated. */
|
||||||
|
FreeRTOS_shutdown( xConnectedSocket, FREERTOS_SHUT_RDWR );
|
||||||
|
|
||||||
|
/* Wait for the shutdown to take effect, indicated by FreeRTOS_recv()
|
||||||
|
returning an error. */
|
||||||
|
xTimeOnShutdown = xTaskGetTickCount();
|
||||||
|
do
|
||||||
|
{
|
||||||
|
if( FreeRTOS_recv( xConnectedSocket, pucRxBuffer, ipconfigTCP_MSS, 0 ) < 0 )
|
||||||
|
{
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
} while( ( xTaskGetTickCount() - xTimeOnShutdown ) < tcpechoSHUTDOWN_DELAY );
|
||||||
|
|
||||||
|
/* Finished with the socket, buffer, the task. */
|
||||||
|
vPortFree( pucRxBuffer );
|
||||||
|
FreeRTOS_closesocket( xConnectedSocket );
|
||||||
|
|
||||||
|
vTaskDelete( NULL );
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
/* The whole file is excluded if TCP is not compiled in. */
|
||||||
|
#endif /* ipconfigUSE_TCP */
|
||||||
|
|
||||||
|
|
@ -0,0 +1,354 @@
|
||||||
|
/*
|
||||||
|
* FreeRTOS V202212.00
|
||||||
|
* Copyright (C) 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||||
|
* this software and associated documentation files (the "Software"), to deal in
|
||||||
|
* the Software without restriction, including without limitation the rights to
|
||||||
|
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
||||||
|
* the Software, and to permit persons to whom the Software is furnished to do so,
|
||||||
|
* subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in all
|
||||||
|
* copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
||||||
|
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
||||||
|
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
||||||
|
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
||||||
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
*
|
||||||
|
* https://www.FreeRTOS.org
|
||||||
|
* https://aws.amazon.com/freertos
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Creates two transmitting tasks and two receiving tasks. The transmitting
|
||||||
|
* tasks send values that are received by the receiving tasks. One set of tasks
|
||||||
|
* uses the standard API. The other set of tasks uses the zero copy API.
|
||||||
|
*
|
||||||
|
* See the following web page for essential demo usage and configuration
|
||||||
|
* details:
|
||||||
|
* https://www.FreeRTOS.org/FreeRTOS-Plus/FreeRTOS_Plus_TCP/examples_FreeRTOS_simulator.html
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* Standard includes. */
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <stdio.h>
|
||||||
|
|
||||||
|
/* FreeRTOS includes. */
|
||||||
|
#include "FreeRTOS.h"
|
||||||
|
#include "task.h"
|
||||||
|
|
||||||
|
/* FreeRTOS+TCP includes. */
|
||||||
|
#include "FreeRTOS_IP.h"
|
||||||
|
#include "FreeRTOS_Sockets.h"
|
||||||
|
|
||||||
|
#define simpTINY_DELAY ( ( TickType_t ) 2 )
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Uses a socket to send data without using the zero copy option.
|
||||||
|
* prvSimpleServerTask() will receive the data.
|
||||||
|
*/
|
||||||
|
static void prvSimpleClientTask( void *pvParameters );
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Uses a socket to receive the data sent by the prvSimpleClientTask() task.
|
||||||
|
* Does not use the zero copy option.
|
||||||
|
*/
|
||||||
|
static void prvSimpleServerTask( void *pvParameters );
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Uses a socket to send data using the zero copy option.
|
||||||
|
* prvSimpleZeroCopyServerTask() will receive the data.
|
||||||
|
*/
|
||||||
|
static void prvSimpleZeroCopyUDPClientTask( void *pvParameters );
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Uses a socket to receive the data sent by the prvSimpleZeroCopyUDPClientTask()
|
||||||
|
* task. Uses the zero copy option.
|
||||||
|
*/
|
||||||
|
static void prvSimpleZeroCopyServerTask( void *pvParameters );
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
void vStartSimpleUDPClientServerTasks( uint16_t usStackSize, uint32_t ulPort, UBaseType_t uxPriority )
|
||||||
|
{
|
||||||
|
/* Create the client and server tasks that do not use the zero copy
|
||||||
|
interface. */
|
||||||
|
xTaskCreate( prvSimpleClientTask, "SimpCpyClnt", usStackSize, ( void * ) ulPort, uxPriority, NULL );
|
||||||
|
xTaskCreate( prvSimpleServerTask, "SimpCpySrv", usStackSize, ( void * ) ulPort, uxPriority + 1, NULL );
|
||||||
|
|
||||||
|
/* Create the client and server tasks that do use the zero copy interface. */
|
||||||
|
xTaskCreate( prvSimpleZeroCopyUDPClientTask, "SimpZCpyClnt", usStackSize, ( void * ) ( ulPort + 1 ), uxPriority, NULL );
|
||||||
|
xTaskCreate( prvSimpleZeroCopyServerTask, "SimpZCpySrv", usStackSize, ( void * ) ( ulPort + 1 ), uxPriority + 1, NULL );
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvSimpleClientTask( void *pvParameters )
|
||||||
|
{
|
||||||
|
Socket_t xClientSocket;
|
||||||
|
struct freertos_sockaddr xDestinationAddress;
|
||||||
|
uint8_t cString[ 65 ];
|
||||||
|
BaseType_t lReturned;
|
||||||
|
uint32_t ulCount = 0UL, ulIPAddress;
|
||||||
|
const uint32_t ulLoopsPerSocket = 10UL;
|
||||||
|
const TickType_t x150ms = 150UL / portTICK_PERIOD_MS;
|
||||||
|
|
||||||
|
/* Remove compiler warning about unused parameters. */
|
||||||
|
( void ) pvParameters;
|
||||||
|
|
||||||
|
/* It is assumed that this task is not created until the network is up,
|
||||||
|
so the IP address can be obtained immediately. store the IP address being
|
||||||
|
used in ulIPAddress. This is done so the socket can send to a different
|
||||||
|
port on the same IP address. */
|
||||||
|
FreeRTOS_GetAddressConfiguration( &ulIPAddress, NULL, NULL, NULL );
|
||||||
|
|
||||||
|
/* This test sends to itself, so data sent from here is received by a server
|
||||||
|
socket on the same IP address. Setup the freertos_sockaddr structure with
|
||||||
|
this nodes IP address, and the port number being sent to. The strange
|
||||||
|
casting is to try and remove compiler warnings on 32 bit machines. */
|
||||||
|
xDestinationAddress.sin_addr = ulIPAddress;
|
||||||
|
xDestinationAddress.sin_port = ( uint16_t ) ( ( uint32_t ) pvParameters ) & 0xffffUL;
|
||||||
|
xDestinationAddress.sin_port = FreeRTOS_htons( xDestinationAddress.sin_port );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Create the socket. */
|
||||||
|
xClientSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_DGRAM, FREERTOS_IPPROTO_UDP );
|
||||||
|
configASSERT( xClientSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* The count is used to differentiate between different messages sent to
|
||||||
|
the server, and to break out of the do while loop below. */
|
||||||
|
ulCount = 0UL;
|
||||||
|
|
||||||
|
do
|
||||||
|
{
|
||||||
|
/* Create the string that is sent to the server. */
|
||||||
|
printf( ( char * ) cString, "Server received (not zero copy): Message number %lu\r\n", ulCount );
|
||||||
|
|
||||||
|
/* Send the string to the socket. ulFlags is set to 0, so the zero
|
||||||
|
copy option is not selected. That means the data from cString[] is
|
||||||
|
copied into a network buffer inside FreeRTOS_sendto(), and cString[]
|
||||||
|
can be reused as soon as FreeRTOS_sendto() has returned. */
|
||||||
|
lReturned = FreeRTOS_sendto( xClientSocket, ( void * ) cString, strlen( ( const char * ) cString ), 0, &xDestinationAddress, sizeof( xDestinationAddress ) );
|
||||||
|
|
||||||
|
ulCount++;
|
||||||
|
|
||||||
|
} while( ( lReturned != FREERTOS_SOCKET_ERROR ) && ( ulCount < ulLoopsPerSocket ) );
|
||||||
|
|
||||||
|
FreeRTOS_closesocket( xClientSocket );
|
||||||
|
|
||||||
|
/* A short delay to prevent the messages printed by the server task
|
||||||
|
scrolling off the screen too quickly, and to prevent reduce the network
|
||||||
|
loading. */
|
||||||
|
vTaskDelay( x150ms );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvSimpleServerTask( void *pvParameters )
|
||||||
|
{
|
||||||
|
int32_t lBytes;
|
||||||
|
uint8_t cReceivedString[ 60 ];
|
||||||
|
struct freertos_sockaddr xClient, xBindAddress;
|
||||||
|
uint32_t xClientLength = sizeof( xClient );
|
||||||
|
Socket_t xListeningSocket;
|
||||||
|
|
||||||
|
/* Just to prevent compiler warnings. */
|
||||||
|
( void ) pvParameters;
|
||||||
|
|
||||||
|
/* Attempt to open the socket. */
|
||||||
|
xListeningSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_DGRAM, FREERTOS_IPPROTO_UDP );
|
||||||
|
configASSERT( xListeningSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* This test receives data sent from a different port on the same IP
|
||||||
|
address. Configure the freertos_sockaddr structure with the address being
|
||||||
|
bound to. The strange casting is to try and remove compiler warnings on 32
|
||||||
|
bit machines. Note that this task is only created after the network is up,
|
||||||
|
so the IP address is valid here. */
|
||||||
|
xBindAddress.sin_port = ( uint16_t ) ( ( uint32_t ) pvParameters ) & 0xffffUL;
|
||||||
|
xBindAddress.sin_port = FreeRTOS_htons( xBindAddress.sin_port );
|
||||||
|
|
||||||
|
/* Bind the socket to the port that the client task will send to. */
|
||||||
|
FreeRTOS_bind( xListeningSocket, &xBindAddress, sizeof( xBindAddress ) );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Zero out the receive array so there is NULL at the end of the string
|
||||||
|
when it is printed out. */
|
||||||
|
memset( cReceivedString, 0x00, sizeof( cReceivedString ) );
|
||||||
|
|
||||||
|
/* Receive data on the socket. ulFlags is zero, so the zero copy option
|
||||||
|
is not set and the received data is copied into the buffer pointed to by
|
||||||
|
cReceivedString. By default the block time is portMAX_DELAY.
|
||||||
|
xClientLength is not actually used by FreeRTOS_recvfrom(), but is set
|
||||||
|
appropriately in case future versions do use it. */
|
||||||
|
lBytes = FreeRTOS_recvfrom( xListeningSocket, cReceivedString, sizeof( cReceivedString ), 0, &xClient, &xClientLength );
|
||||||
|
|
||||||
|
/* Error check. */
|
||||||
|
configASSERT( lBytes == ( BaseType_t ) strlen( ( const char * ) cReceivedString ) );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvSimpleZeroCopyUDPClientTask( void *pvParameters )
|
||||||
|
{
|
||||||
|
Socket_t xClientSocket;
|
||||||
|
uint8_t *pucUDPPayloadBuffer;
|
||||||
|
struct freertos_sockaddr xDestinationAddress;
|
||||||
|
BaseType_t lReturned;
|
||||||
|
uint32_t ulCount = 0UL, ulIPAddress;
|
||||||
|
const uint32_t ulLoopsPerSocket = 10UL;
|
||||||
|
const char *pcStringToSend = "Server received (using zero copy): Message number ";
|
||||||
|
const TickType_t x150ms = 150UL / portTICK_PERIOD_MS;
|
||||||
|
/* 15 is added to ensure the number, \r\n and terminating zero fit. */
|
||||||
|
const size_t xStringLength = strlen( pcStringToSend ) + 15;
|
||||||
|
|
||||||
|
/* Remove compiler warning about unused parameters. */
|
||||||
|
( void ) pvParameters;
|
||||||
|
|
||||||
|
/* It is assumed that this task is not created until the network is up,
|
||||||
|
so the IP address can be obtained immediately. store the IP address being
|
||||||
|
used in ulIPAddress. This is done so the socket can send to a different
|
||||||
|
port on the same IP address. */
|
||||||
|
FreeRTOS_GetAddressConfiguration( &ulIPAddress, NULL, NULL, NULL );
|
||||||
|
|
||||||
|
/* This test sends to itself, so data sent from here is received by a server
|
||||||
|
socket on the same IP address. Setup the freertos_sockaddr structure with
|
||||||
|
this nodes IP address, and the port number being sent to. The strange
|
||||||
|
casting is to try and remove compiler warnings on 32 bit machines. */
|
||||||
|
xDestinationAddress.sin_addr = ulIPAddress;
|
||||||
|
xDestinationAddress.sin_port = ( uint16_t ) ( ( uint32_t ) pvParameters ) & 0xffffUL;
|
||||||
|
xDestinationAddress.sin_port = FreeRTOS_htons( xDestinationAddress.sin_port );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Create the socket. */
|
||||||
|
xClientSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_DGRAM, FREERTOS_IPPROTO_UDP );
|
||||||
|
configASSERT( xClientSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* The count is used to differentiate between different messages sent to
|
||||||
|
the server, and to break out of the do while loop below. */
|
||||||
|
ulCount = 0UL;
|
||||||
|
|
||||||
|
do
|
||||||
|
{
|
||||||
|
/* This task is going to send using the zero copy interface. The
|
||||||
|
data being sent is therefore written directly into a buffer that is
|
||||||
|
passed into, rather than copied into, the FreeRTOS_sendto()
|
||||||
|
function.
|
||||||
|
|
||||||
|
First obtain a buffer of adequate length from the IP stack into which
|
||||||
|
the string will be written. Although a max delay is used, the actual
|
||||||
|
delay will be capped to ipconfigMAX_SEND_BLOCK_TIME_TICKS, hence
|
||||||
|
the do while loop is used to ensure a buffer is obtained. */
|
||||||
|
do
|
||||||
|
{
|
||||||
|
} while( ( pucUDPPayloadBuffer = ( uint8_t * ) FreeRTOS_GetUDPPayloadBuffer( xStringLength, portMAX_DELAY ) ) == NULL );
|
||||||
|
|
||||||
|
/* A buffer was successfully obtained. Create the string that is
|
||||||
|
sent to the server. First the string is filled with zeros as this will
|
||||||
|
effectively be the null terminator when the string is received at the other
|
||||||
|
end. Note that the string is being written directly into the buffer
|
||||||
|
obtained from the IP stack above. */
|
||||||
|
memset( ( void * ) pucUDPPayloadBuffer, 0x00, xStringLength );
|
||||||
|
printf( ( char * ) pucUDPPayloadBuffer, "%s%lu\r\n", pcStringToSend, ulCount );
|
||||||
|
|
||||||
|
/* Pass the buffer into the send function. ulFlags has the
|
||||||
|
FREERTOS_ZERO_COPY bit set so the IP stack will take control of the
|
||||||
|
buffer rather than copy data out of the buffer. */
|
||||||
|
lReturned = FreeRTOS_sendto( xClientSocket, /* The socket being sent to. */
|
||||||
|
( void * ) pucUDPPayloadBuffer, /* A pointer to the the data being sent. */
|
||||||
|
strlen( ( const char * ) pucUDPPayloadBuffer ) + 1, /* The length of the data being sent - including the string's null terminator. */
|
||||||
|
FREERTOS_ZERO_COPY, /* ulFlags with the FREERTOS_ZERO_COPY bit set. */
|
||||||
|
&xDestinationAddress, /* Where the data is being sent. */
|
||||||
|
sizeof( xDestinationAddress ) );
|
||||||
|
|
||||||
|
if( lReturned == 0 )
|
||||||
|
{
|
||||||
|
/* The send operation failed, so this task is still responsible
|
||||||
|
for the buffer obtained from the IP stack. To ensure the buffer
|
||||||
|
is not lost it must either be used again, or, as in this case,
|
||||||
|
returned to the IP stack using FreeRTOS_ReleaseUDPPayloadBuffer().
|
||||||
|
pucUDPPayloadBuffer can be safely re-used after this call. */
|
||||||
|
FreeRTOS_ReleaseUDPPayloadBuffer( ( void * ) pucUDPPayloadBuffer );
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/* The send was successful so the IP stack is now managing the
|
||||||
|
buffer pointed to by pucUDPPayloadBuffer, and the IP stack will
|
||||||
|
return the buffer once it has been sent. pucUDPPayloadBuffer can
|
||||||
|
be safely re-used. */
|
||||||
|
}
|
||||||
|
|
||||||
|
ulCount++;
|
||||||
|
|
||||||
|
} while( ( lReturned != FREERTOS_SOCKET_ERROR ) && ( ulCount < ulLoopsPerSocket ) );
|
||||||
|
|
||||||
|
FreeRTOS_closesocket( xClientSocket );
|
||||||
|
|
||||||
|
/* A short delay to prevent the messages scrolling off the screen too
|
||||||
|
quickly. */
|
||||||
|
vTaskDelay( x150ms );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvSimpleZeroCopyServerTask( void *pvParameters )
|
||||||
|
{
|
||||||
|
int32_t lBytes;
|
||||||
|
uint8_t *pucUDPPayloadBuffer;
|
||||||
|
struct freertos_sockaddr xClient, xBindAddress;
|
||||||
|
uint32_t xClientLength = sizeof( xClient ), ulIPAddress;
|
||||||
|
Socket_t xListeningSocket;
|
||||||
|
|
||||||
|
/* Just to prevent compiler warnings. */
|
||||||
|
( void ) pvParameters;
|
||||||
|
|
||||||
|
/* Attempt to open the socket. */
|
||||||
|
xListeningSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_DGRAM, FREERTOS_IPPROTO_UDP );
|
||||||
|
configASSERT( xListeningSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* This test receives data sent from a different port on the same IP address.
|
||||||
|
Obtain the nodes IP address. Configure the freertos_sockaddr structure with
|
||||||
|
the address being bound to. The strange casting is to try and remove
|
||||||
|
compiler warnings on 32 bit machines. Note that this task is only created
|
||||||
|
after the network is up, so the IP address is valid here. */
|
||||||
|
FreeRTOS_GetAddressConfiguration( &ulIPAddress, NULL, NULL, NULL );
|
||||||
|
xBindAddress.sin_addr = ulIPAddress;
|
||||||
|
xBindAddress.sin_port = ( uint16_t ) ( ( uint32_t ) pvParameters ) & 0xffffUL;
|
||||||
|
xBindAddress.sin_port = FreeRTOS_htons( xBindAddress.sin_port );
|
||||||
|
|
||||||
|
/* Bind the socket to the port that the client task will send to. */
|
||||||
|
FreeRTOS_bind( xListeningSocket, &xBindAddress, sizeof( xBindAddress ) );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Receive data on the socket. ulFlags has the zero copy bit set
|
||||||
|
(FREERTOS_ZERO_COPY) indicating to the stack that a reference to the
|
||||||
|
received data should be passed out to this task using the second
|
||||||
|
parameter to the FreeRTOS_recvfrom() call. When this is done the
|
||||||
|
IP stack is no longer responsible for releasing the buffer, and
|
||||||
|
the task *must* return the buffer to the stack when it is no longer
|
||||||
|
needed. By default the block time is portMAX_DELAY. */
|
||||||
|
lBytes = FreeRTOS_recvfrom( xListeningSocket, ( void * ) &pucUDPPayloadBuffer, 0, FREERTOS_ZERO_COPY, &xClient, &xClientLength );
|
||||||
|
|
||||||
|
/* Print the received characters. */
|
||||||
|
if( lBytes > 0 )
|
||||||
|
{
|
||||||
|
/* It is expected to receive one more byte than the string length as
|
||||||
|
the NULL terminator is also transmitted. */
|
||||||
|
configASSERT( lBytes == ( ( BaseType_t ) strlen( ( const char * ) pucUDPPayloadBuffer ) + 1 ) );
|
||||||
|
}
|
||||||
|
|
||||||
|
if( lBytes >= 0 )
|
||||||
|
{
|
||||||
|
/* The buffer *must* be freed once it is no longer needed. */
|
||||||
|
FreeRTOS_ReleaseUDPPayloadBuffer( pucUDPPayloadBuffer );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
@ -0,0 +1,358 @@
|
||||||
|
/*
|
||||||
|
* FreeRTOS V202212.00
|
||||||
|
* Copyright (C) 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||||
|
* this software and associated documentation files (the "Software"), to deal in
|
||||||
|
* the Software without restriction, including without limitation the rights to
|
||||||
|
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
||||||
|
* the Software, and to permit persons to whom the Software is furnished to do so,
|
||||||
|
* subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in all
|
||||||
|
* copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
||||||
|
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
||||||
|
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
||||||
|
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
||||||
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
*
|
||||||
|
* https://www.FreeRTOS.org
|
||||||
|
* https://github.com/FreeRTOS
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
/*
|
||||||
|
* A set of tasks are created that send TCP echo requests to the standard echo
|
||||||
|
* port (port 7) on the IP address set by the configECHO_SERVER_ADDR0 to
|
||||||
|
* configECHO_SERVER_ADDR3 constants, then wait for and verify the reply
|
||||||
|
* (another demo is available that demonstrates the reception being performed in
|
||||||
|
* a task other than that from with the request was made).
|
||||||
|
*
|
||||||
|
* See the following web page for essential demo usage and configuration
|
||||||
|
* details:
|
||||||
|
* https://www.FreeRTOS.org/FreeRTOS-Plus/FreeRTOS_Plus_TCP/examples_FreeRTOS_simulator.html
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* Standard includes. */
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
|
||||||
|
/* FreeRTOS includes. */
|
||||||
|
#include "FreeRTOS.h"
|
||||||
|
#include "task.h"
|
||||||
|
#include "queue.h"
|
||||||
|
|
||||||
|
/* FreeRTOS+TCP includes. */
|
||||||
|
#include "FreeRTOS_IP.h"
|
||||||
|
#include "FreeRTOS_Sockets.h"
|
||||||
|
|
||||||
|
#include "tcp_echo_config.h"
|
||||||
|
|
||||||
|
/* Exclude the whole file if FreeRTOSIPConfig.h is configured to use UDP only. */
|
||||||
|
#if( ipconfigUSE_TCP == 1 )
|
||||||
|
|
||||||
|
/* The echo tasks create a socket, send out a number of echo requests, listen
|
||||||
|
for the echo reply, then close the socket again before starting over. This
|
||||||
|
delay is used between each iteration to ensure the network does not get too
|
||||||
|
congested. */
|
||||||
|
#define echoLOOP_DELAY ( ( TickType_t ) 150 / portTICK_PERIOD_MS )
|
||||||
|
|
||||||
|
/* The echo server is assumed to be on port 7, which is the standard echo
|
||||||
|
protocol port. */
|
||||||
|
#define echoECHO_PORT ( 7 )
|
||||||
|
|
||||||
|
/* The size of the buffers is a multiple of the MSS - the length of the data
|
||||||
|
sent is a pseudo random size between 20 and echoBUFFER_SIZES. */
|
||||||
|
#define echoBUFFER_SIZE_MULTIPLIER ( 3 )
|
||||||
|
#define echoBUFFER_SIZES ( ipconfigTCP_MSS * echoBUFFER_SIZE_MULTIPLIER )
|
||||||
|
|
||||||
|
/* The number of instances of the echo client task to create. */
|
||||||
|
#define echoNUM_ECHO_CLIENTS ( 5 )
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Uses a socket to send data to, then receive data from, the standard echo
|
||||||
|
* port number 7.
|
||||||
|
*/
|
||||||
|
static void prvEchoClientTask( void *pvParameters );
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Creates a pseudo random sized buffer of data to send to the echo server.
|
||||||
|
*/
|
||||||
|
static BaseType_t prvCreateTxData( char *ucBuffer, uint32_t ulBufferLength );
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
/* Rx and Tx time outs are used to ensure the sockets do not wait too long for
|
||||||
|
missing data. */
|
||||||
|
static const TickType_t xReceiveTimeOut = pdMS_TO_TICKS( 4000 );
|
||||||
|
static const TickType_t xSendTimeOut = pdMS_TO_TICKS( 2000 );
|
||||||
|
|
||||||
|
/* Counters for each created task - for inspection only. */
|
||||||
|
static uint32_t ulTxRxCycles[ echoNUM_ECHO_CLIENTS ] = { 0 },
|
||||||
|
ulTxRxFailures[ echoNUM_ECHO_CLIENTS ] = { 0 },
|
||||||
|
ulConnections[ echoNUM_ECHO_CLIENTS ] = { 0 };
|
||||||
|
|
||||||
|
/* Rx and Tx buffers for each created task. */
|
||||||
|
static char cTxBuffers[ echoNUM_ECHO_CLIENTS ][ echoBUFFER_SIZES ],
|
||||||
|
cRxBuffers[ echoNUM_ECHO_CLIENTS ][ echoBUFFER_SIZES ];
|
||||||
|
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
void vStartTCPEchoClientTasks_SingleTasks( uint16_t usTaskStackSize, UBaseType_t uxTaskPriority )
|
||||||
|
{
|
||||||
|
BaseType_t x;
|
||||||
|
|
||||||
|
/* Create the echo client tasks. */
|
||||||
|
for( x = 0; x < echoNUM_ECHO_CLIENTS; x++ )
|
||||||
|
{
|
||||||
|
xTaskCreate( prvEchoClientTask, /* The function that implements the task. */
|
||||||
|
"Echo0", /* Just a text name for the task to aid debugging. */
|
||||||
|
usTaskStackSize, /* The stack size is defined in FreeRTOSIPConfig.h. */
|
||||||
|
( void * ) x, /* The task parameter, not used in this case. */
|
||||||
|
uxTaskPriority, /* The priority assigned to the task is defined in FreeRTOSConfig.h. */
|
||||||
|
NULL ); /* The task handle is not used. */
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static void prvEchoClientTask( void *pvParameters )
|
||||||
|
{
|
||||||
|
Socket_t xSocket;
|
||||||
|
struct freertos_sockaddr xEchoServerAddress;
|
||||||
|
int32_t lLoopCount = 0UL;
|
||||||
|
const int32_t lMaxLoopCount = 1;
|
||||||
|
volatile uint32_t ulTxCount = 0UL;
|
||||||
|
BaseType_t xReceivedBytes, xReturned, xInstance;
|
||||||
|
BaseType_t lTransmitted, lStringLength;
|
||||||
|
char *pcTransmittedString, *pcReceivedString;
|
||||||
|
WinProperties_t xWinProps;
|
||||||
|
TickType_t xTimeOnEntering;
|
||||||
|
|
||||||
|
/* Fill in the buffer and window sizes that will be used by the socket. */
|
||||||
|
xWinProps.lTxBufSize = 6 * ipconfigTCP_MSS;
|
||||||
|
xWinProps.lTxWinSize = 3;
|
||||||
|
xWinProps.lRxBufSize = 6 * ipconfigTCP_MSS;
|
||||||
|
xWinProps.lRxWinSize = 3;
|
||||||
|
|
||||||
|
/* This task can be created a number of times. Each instance is numbered
|
||||||
|
to enable each instance to use a different Rx and Tx buffer. The number is
|
||||||
|
passed in as the task's parameter. */
|
||||||
|
xInstance = ( BaseType_t ) pvParameters;
|
||||||
|
|
||||||
|
/* Point to the buffers to be used by this instance of this task. */
|
||||||
|
pcTransmittedString = &( cTxBuffers[ xInstance ][ 0 ] );
|
||||||
|
pcReceivedString = &( cRxBuffers[ xInstance ][ 0 ] );
|
||||||
|
|
||||||
|
/* Echo requests are sent to the echo server. The address of the echo
|
||||||
|
server is configured by the constants configECHO_SERVER_ADDR0 to
|
||||||
|
configECHO_SERVER_ADDR3 in FreeRTOSConfig.h. */
|
||||||
|
xEchoServerAddress.sin_port = FreeRTOS_htons( echoECHO_PORT );
|
||||||
|
xEchoServerAddress.sin_addr = FreeRTOS_inet_addr( configECHO_SERVER_ADDR );
|
||||||
|
|
||||||
|
for( ;; )
|
||||||
|
{
|
||||||
|
/* Create a TCP socket. */
|
||||||
|
xSocket = FreeRTOS_socket( FREERTOS_AF_INET, FREERTOS_SOCK_STREAM, FREERTOS_IPPROTO_TCP );
|
||||||
|
configASSERT( xSocket != FREERTOS_INVALID_SOCKET );
|
||||||
|
|
||||||
|
/* Set a time out so a missing reply does not cause the task to block
|
||||||
|
indefinitely. */
|
||||||
|
FreeRTOS_setsockopt( xSocket, 0, FREERTOS_SO_RCVTIMEO, &xReceiveTimeOut, sizeof( xReceiveTimeOut ) );
|
||||||
|
FreeRTOS_setsockopt( xSocket, 0, FREERTOS_SO_SNDTIMEO, &xSendTimeOut, sizeof( xSendTimeOut ) );
|
||||||
|
|
||||||
|
/* Set the window and buffer sizes. */
|
||||||
|
FreeRTOS_setsockopt( xSocket, 0, FREERTOS_SO_WIN_PROPERTIES, ( void * ) &xWinProps, sizeof( xWinProps ) );
|
||||||
|
|
||||||
|
/* Connect to the echo server. */
|
||||||
|
if( FreeRTOS_connect( xSocket, &xEchoServerAddress, sizeof( xEchoServerAddress ) ) == 0 )
|
||||||
|
{
|
||||||
|
ulConnections[ xInstance ]++;
|
||||||
|
|
||||||
|
/* Send a number of echo requests. */
|
||||||
|
for( lLoopCount = 0; lLoopCount < lMaxLoopCount; lLoopCount++ )
|
||||||
|
{
|
||||||
|
/* Create the string that is sent to the echo server. */
|
||||||
|
lStringLength = prvCreateTxData( pcTransmittedString, echoBUFFER_SIZES );
|
||||||
|
|
||||||
|
/* Add in some unique text at the front of the string. */
|
||||||
|
sprintf( pcTransmittedString, "TxRx message number %u", ulTxCount );
|
||||||
|
ulTxCount++;
|
||||||
|
|
||||||
|
/* Send the string to the socket. */
|
||||||
|
lTransmitted = FreeRTOS_send( xSocket, /* The socket being sent to. */
|
||||||
|
( void * ) pcTransmittedString, /* The data being sent. */
|
||||||
|
lStringLength, /* The length of the data being sent. */
|
||||||
|
0 ); /* No flags. */
|
||||||
|
|
||||||
|
if( lTransmitted < 0 )
|
||||||
|
{
|
||||||
|
/* Error? */
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Clear the buffer into which the echoed string will be
|
||||||
|
placed. */
|
||||||
|
memset( ( void * ) pcReceivedString, 0x00, echoBUFFER_SIZES );
|
||||||
|
xReceivedBytes = 0;
|
||||||
|
|
||||||
|
/* Receive data echoed back to the socket. */
|
||||||
|
while( xReceivedBytes < lTransmitted )
|
||||||
|
{
|
||||||
|
xReturned = FreeRTOS_recv( xSocket, /* The socket being received from. */
|
||||||
|
&( pcReceivedString[ xReceivedBytes ] ),/* The buffer into which the received data will be written. */
|
||||||
|
lStringLength - xReceivedBytes, /* The size of the buffer provided to receive the data. */
|
||||||
|
0 ); /* No flags. */
|
||||||
|
|
||||||
|
if( xReturned < 0 )
|
||||||
|
{
|
||||||
|
/* Error occurred. Latch it so it can be detected
|
||||||
|
below. */
|
||||||
|
xReceivedBytes = xReturned;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
else if( xReturned == 0 )
|
||||||
|
{
|
||||||
|
/* Timed out. */
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/* Keep a count of the bytes received so far. */
|
||||||
|
xReceivedBytes += xReturned;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* If an error occurred it will be latched in xReceivedBytes,
|
||||||
|
otherwise xReceived bytes will be just that - the number of
|
||||||
|
bytes received from the echo server. */
|
||||||
|
if( xReceivedBytes > 0 )
|
||||||
|
{
|
||||||
|
/* Compare the transmitted string to the received string. */
|
||||||
|
configASSERT( strncmp( pcReceivedString, pcTransmittedString, lTransmitted ) == 0 );
|
||||||
|
if( strncmp( pcReceivedString, pcTransmittedString, lTransmitted ) == 0 )
|
||||||
|
{
|
||||||
|
/* The echo reply was received without error. */
|
||||||
|
ulTxRxCycles[ xInstance ]++;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/* The received string did not match the transmitted
|
||||||
|
string. */
|
||||||
|
ulTxRxFailures[ xInstance ]++;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if( xReceivedBytes < 0 )
|
||||||
|
{
|
||||||
|
/* FreeRTOS_recv() returned an error. */
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/* Timed out without receiving anything? */
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Finished using the connected socket, initiate a graceful close:
|
||||||
|
FIN, FIN+ACK, ACK. */
|
||||||
|
FreeRTOS_shutdown( xSocket, FREERTOS_SHUT_RDWR );
|
||||||
|
|
||||||
|
/* Expect FreeRTOS_recv() to return an error once the shutdown is
|
||||||
|
complete. */
|
||||||
|
xTimeOnEntering = xTaskGetTickCount();
|
||||||
|
do
|
||||||
|
{
|
||||||
|
xReturned = FreeRTOS_recv( xSocket, /* The socket being received from. */
|
||||||
|
&( pcReceivedString[ 0 ] ), /* The buffer into which the received data will be written. */
|
||||||
|
echoBUFFER_SIZES, /* The size of the buffer provided to receive the data. */
|
||||||
|
0 );
|
||||||
|
|
||||||
|
if( xReturned < 0 )
|
||||||
|
{
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
} while( ( xTaskGetTickCount() - xTimeOnEntering ) < xReceiveTimeOut );
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Close this socket before looping back to create another. */
|
||||||
|
FreeRTOS_closesocket( xSocket );
|
||||||
|
|
||||||
|
/* Pause for a short while to ensure the network is not too
|
||||||
|
congested. */
|
||||||
|
vTaskDelay( echoLOOP_DELAY );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
static BaseType_t prvCreateTxData( char *cBuffer, uint32_t ulBufferLength )
|
||||||
|
{
|
||||||
|
BaseType_t lCharactersToAdd, lCharacter;
|
||||||
|
char cChar = '0';
|
||||||
|
const BaseType_t lMinimumLength = 60;
|
||||||
|
uint32_t ulRandomNumber;
|
||||||
|
|
||||||
|
/* Randomise the number of characters that will be sent in the echo
|
||||||
|
request. */
|
||||||
|
do
|
||||||
|
{
|
||||||
|
( void ) xApplicationGetRandomNumber( &ulRandomNumber );
|
||||||
|
lCharactersToAdd = ulRandomNumber % ( ulBufferLength - 20UL );
|
||||||
|
} while ( ( lCharactersToAdd == 0 ) || ( lCharactersToAdd < lMinimumLength ) ); /* Must be at least enough to add the unique text to the start of the string later. */
|
||||||
|
|
||||||
|
/* Fill the buffer. */
|
||||||
|
for( lCharacter = 0; lCharacter < lCharactersToAdd; lCharacter++ )
|
||||||
|
{
|
||||||
|
cBuffer[ lCharacter ] = cChar;
|
||||||
|
cChar++;
|
||||||
|
|
||||||
|
if( cChar > '~' )
|
||||||
|
{
|
||||||
|
cChar = '0';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return lCharactersToAdd;
|
||||||
|
}
|
||||||
|
/*-----------------------------------------------------------*/
|
||||||
|
|
||||||
|
BaseType_t xAreSingleTaskTCPEchoClientsStillRunning( void )
|
||||||
|
{
|
||||||
|
static uint32_t ulLastEchoSocketCount[ echoNUM_ECHO_CLIENTS ] = { 0 }, ulLastConnections[ echoNUM_ECHO_CLIENTS ] = { 0 };
|
||||||
|
BaseType_t xReturn = pdPASS, x;
|
||||||
|
|
||||||
|
/* Return fail is the number of cycles does not increment between
|
||||||
|
consecutive calls. */
|
||||||
|
for( x = 0; x < echoNUM_ECHO_CLIENTS; x++ )
|
||||||
|
{
|
||||||
|
if( ulTxRxCycles[ x ] == ulLastEchoSocketCount[ x ] )
|
||||||
|
{
|
||||||
|
xReturn = pdFAIL;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
ulLastEchoSocketCount[ x ] = ulTxRxCycles[ x ];
|
||||||
|
}
|
||||||
|
|
||||||
|
if( ulConnections[ x ] == ulLastConnections[ x ] )
|
||||||
|
{
|
||||||
|
xReturn = pdFAIL;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
ulConnections[ x ] = ulLastConnections[ x ];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return xReturn;
|
||||||
|
}
|
||||||
|
|
||||||
|
#endif /* ipconfigUSE_TCP */
|
||||||
|
|
||||||
|
|
@ -0,0 +1,76 @@
|
||||||
|
/*
|
||||||
|
FreeRTOS V202212.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!
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef SIMPLE_TCP_ECHO_SERVER_H
|
||||||
|
#define SIMPLE_TCP_ECHO_SERVER_H
|
||||||
|
|
||||||
|
void vStartSimpleTCPServerTasks( uint16_t usStackSize, BaseType_t uxPriority );
|
||||||
|
BaseType_t xAreTCPEchoServersStillRunning( void );
|
||||||
|
|
||||||
|
#endif /* SIMPLE_TCP_ECHO_SERVER_H */
|
||||||
|
|
@ -0,0 +1,32 @@
|
||||||
|
/*
|
||||||
|
* FreeRTOS V202212.00
|
||||||
|
* Copyright (C) 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||||
|
* this software and associated documentation files (the "Software"), to deal in
|
||||||
|
* the Software without restriction, including without limitation the rights to
|
||||||
|
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
||||||
|
* the Software, and to permit persons to whom the Software is furnished to do so,
|
||||||
|
* subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in all
|
||||||
|
* copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
||||||
|
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
||||||
|
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
||||||
|
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
||||||
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
*
|
||||||
|
* https://www.FreeRTOS.org
|
||||||
|
* https://aws.amazon.com/freertos
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef SIMPLE_UDP_CLIENT_AND_SERVER_H
|
||||||
|
#define SIMPLE_UDP_CLIENT_AND_SERVER_H
|
||||||
|
|
||||||
|
void vStartSimpleUDPClientServerTasks( uint16_t usStackSize, uint32_t ulsPort, UBaseType_t uxPriority );
|
||||||
|
|
||||||
|
#endif /* SIMPLE_UDPCLIENT_AND_SERVER_H */
|
||||||
|
|
@ -0,0 +1,39 @@
|
||||||
|
/*
|
||||||
|
* FreeRTOS V202212.00
|
||||||
|
* Copyright (C) 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||||
|
* this software and associated documentation files (the "Software"), to deal in
|
||||||
|
* the Software without restriction, including without limitation the rights to
|
||||||
|
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
||||||
|
* the Software, and to permit persons to whom the Software is furnished to do so,
|
||||||
|
* subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in all
|
||||||
|
* copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
||||||
|
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
||||||
|
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
||||||
|
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
||||||
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
*
|
||||||
|
* https://www.FreeRTOS.org
|
||||||
|
* https://aws.amazon.com/freertos
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef SINGLE_TASK_TCP_ECHO_CLIENTS_H
|
||||||
|
#define SINGLE_TASK_TCP_ECHO_CLIENTS_H
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Create the TCP echo client tasks. This is the version where an echo request
|
||||||
|
* is made from the same task that listens for the echo reply.
|
||||||
|
*/
|
||||||
|
void vStartTCPEchoClientTasks_SingleTasks( uint16_t usTaskStackSize, UBaseType_t uxTaskPriority );
|
||||||
|
BaseType_t xAreSingleTaskTCPEchoClientsStillRunning( void );
|
||||||
|
|
||||||
|
#endif /* SINGLE_TASK_TCP_ECHO_CLIENTS_H */
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -0,0 +1,35 @@
|
||||||
|
/*
|
||||||
|
* FreeRTOS V202212.00
|
||||||
|
* Copyright (C) 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||||
|
* this software and associated documentation files (the "Software"), to deal in
|
||||||
|
* the Software without restriction, including without limitation the rights to
|
||||||
|
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
||||||
|
* the Software, and to permit persons to whom the Software is furnished to do so,
|
||||||
|
* subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in all
|
||||||
|
* copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
||||||
|
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
||||||
|
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
||||||
|
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
||||||
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
*
|
||||||
|
* https://www.FreeRTOS.org
|
||||||
|
* https://github.com/FreeRTOS
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
/* TCP Echo Demo configuration */
|
||||||
|
|
||||||
|
#ifndef TCP_ECHO_CONFIG_H_
|
||||||
|
#define TCP_ECHO_CONFIG_H_
|
||||||
|
|
||||||
|
#define configECHO_SERVER_ADDR "127.0.0.1"
|
||||||
|
#define configECHO_SERVER_PORT ( 9000U )
|
||||||
|
|
||||||
|
#endif /* TCP_ECHO_CONFIG_H_ */
|
||||||
Binary file not shown.
File diff suppressed because one or more lines are too long
|
|
@ -229,7 +229,7 @@
|
||||||
<GroupNumber>1</GroupNumber>
|
<GroupNumber>1</GroupNumber>
|
||||||
<FileNumber>1</FileNumber>
|
<FileNumber>1</FileNumber>
|
||||||
<FileType>1</FileType>
|
<FileType>1</FileType>
|
||||||
<tvExp>0</tvExp>
|
<tvExp>1</tvExp>
|
||||||
<tvExpOptDlg>0</tvExpOptDlg>
|
<tvExpOptDlg>0</tvExpOptDlg>
|
||||||
<bDave2>0</bDave2>
|
<bDave2>0</bDave2>
|
||||||
<PathWithFileName>.\main.c</PathWithFileName>
|
<PathWithFileName>.\main.c</PathWithFileName>
|
||||||
|
|
@ -241,7 +241,7 @@
|
||||||
<GroupNumber>1</GroupNumber>
|
<GroupNumber>1</GroupNumber>
|
||||||
<FileNumber>2</FileNumber>
|
<FileNumber>2</FileNumber>
|
||||||
<FileType>1</FileType>
|
<FileType>1</FileType>
|
||||||
<tvExp>0</tvExp>
|
<tvExp>1</tvExp>
|
||||||
<tvExpOptDlg>0</tvExpOptDlg>
|
<tvExpOptDlg>0</tvExpOptDlg>
|
||||||
<bDave2>0</bDave2>
|
<bDave2>0</bDave2>
|
||||||
<PathWithFileName>.\DemoTasks\SimpleTCPEchoServer.c</PathWithFileName>
|
<PathWithFileName>.\DemoTasks\SimpleTCPEchoServer.c</PathWithFileName>
|
||||||
|
|
@ -253,7 +253,7 @@
|
||||||
<GroupNumber>1</GroupNumber>
|
<GroupNumber>1</GroupNumber>
|
||||||
<FileNumber>3</FileNumber>
|
<FileNumber>3</FileNumber>
|
||||||
<FileType>1</FileType>
|
<FileType>1</FileType>
|
||||||
<tvExp>1</tvExp>
|
<tvExp>0</tvExp>
|
||||||
<tvExpOptDlg>0</tvExpOptDlg>
|
<tvExpOptDlg>0</tvExpOptDlg>
|
||||||
<bDave2>0</bDave2>
|
<bDave2>0</bDave2>
|
||||||
<PathWithFileName>.\DemoTasks\SimpleUDPClientAndServer.c</PathWithFileName>
|
<PathWithFileName>.\DemoTasks\SimpleUDPClientAndServer.c</PathWithFileName>
|
||||||
|
|
@ -277,7 +277,7 @@
|
||||||
|
|
||||||
<Group>
|
<Group>
|
||||||
<GroupName>FreeRTOS</GroupName>
|
<GroupName>FreeRTOS</GroupName>
|
||||||
<tvExp>0</tvExp>
|
<tvExp>1</tvExp>
|
||||||
<tvExpOptDlg>0</tvExpOptDlg>
|
<tvExpOptDlg>0</tvExpOptDlg>
|
||||||
<cbSel>0</cbSel>
|
<cbSel>0</cbSel>
|
||||||
<RteFlg>0</RteFlg>
|
<RteFlg>0</RteFlg>
|
||||||
|
|
@ -501,7 +501,7 @@
|
||||||
<GroupNumber>2</GroupNumber>
|
<GroupNumber>2</GroupNumber>
|
||||||
<FileNumber>23</FileNumber>
|
<FileNumber>23</FileNumber>
|
||||||
<FileType>1</FileType>
|
<FileType>1</FileType>
|
||||||
<tvExp>0</tvExp>
|
<tvExp>1</tvExp>
|
||||||
<tvExpOptDlg>0</tvExpOptDlg>
|
<tvExpOptDlg>0</tvExpOptDlg>
|
||||||
<bDave2>0</bDave2>
|
<bDave2>0</bDave2>
|
||||||
<PathWithFileName>.\FreeRTOS\source\FreeRTOS_TCP_Utils.c</PathWithFileName>
|
<PathWithFileName>.\FreeRTOS\source\FreeRTOS_TCP_Utils.c</PathWithFileName>
|
||||||
|
|
|
||||||
23
main.c
23
main.c
|
|
@ -4,9 +4,14 @@
|
||||||
#include "gd32f10x_gpio.h"
|
#include "gd32f10x_gpio.h"
|
||||||
#include "stdio.h"
|
#include "stdio.h"
|
||||||
/* System application includes. */
|
/* System application includes. */
|
||||||
|
#include "FreeRTOSIPConfig.h"
|
||||||
|
|
||||||
|
/* Demo application includes. */
|
||||||
#include "FreeRTOS_IP.h"
|
#include "FreeRTOS_IP.h"
|
||||||
#include "FreeRTOS_Sockets.h"
|
#include "FreeRTOS_Sockets.h"
|
||||||
#include "FreeRTOS_DHCP.h"
|
#include "SimpleUDPClientAndServer.h"
|
||||||
|
#include "SimpleTCPEchoServer.h"
|
||||||
|
#include "TCPEchoClient_SingleTasks.h"
|
||||||
|
|
||||||
#define BUTTON_USER GPIO_PIN_14
|
#define BUTTON_USER GPIO_PIN_14
|
||||||
|
|
||||||
|
|
@ -25,6 +30,22 @@
|
||||||
#define mainCREATE_TCP_ECHO_TASKS_SINGLE 0
|
#define mainCREATE_TCP_ECHO_TASKS_SINGLE 0
|
||||||
#define mainCREATE_TCP_ECHO_SERVER_TASK 0
|
#define mainCREATE_TCP_ECHO_SERVER_TASK 0
|
||||||
|
|
||||||
|
/* Simple UDP client and server task parameters. */
|
||||||
|
#define mainSIMPLE_UDP_CLIENT_SERVER_TASK_PRIORITY ( tskIDLE_PRIORITY )
|
||||||
|
#define mainSIMPLE_UDP_CLIENT_SERVER_PORT ( 5005UL )
|
||||||
|
|
||||||
|
/* Echo client task parameters - used for both TCP and UDP echo clients. */
|
||||||
|
#define mainECHO_CLIENT_TASK_STACK_SIZE ( configMINIMAL_STACK_SIZE * 2 ) /* Not used in the Windows port. */
|
||||||
|
#define mainECHO_CLIENT_TASK_PRIORITY ( tskIDLE_PRIORITY + 1 )
|
||||||
|
|
||||||
|
/* Echo server task parameters. */
|
||||||
|
#define mainECHO_SERVER_TASK_STACK_SIZE ( configMINIMAL_STACK_SIZE * 2 ) /* Not used in the Windows port. */
|
||||||
|
#define mainECHO_SERVER_TASK_PRIORITY ( tskIDLE_PRIORITY + 1 )
|
||||||
|
|
||||||
|
/* Define a name that will be used for LLMNR and NBNS searches. */
|
||||||
|
//#define mainHOST_NAME "RTOSDemo"
|
||||||
|
//#define mainDEVICE_NICK_NAME "windows_demo"
|
||||||
|
|
||||||
/* Default MAC address configuration. The demo creates a virtual network
|
/* Default MAC address configuration. The demo creates a virtual network
|
||||||
* connection that uses this MAC address by accessing the raw Ethernet data
|
* connection that uses this MAC address by accessing the raw Ethernet data
|
||||||
* to and from a real network connection on the host PC. See the
|
* to and from a real network connection on the host PC. See the
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue