diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/DemoTasks/S3DownloadMultithreadedHTTPExample.c b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/DemoTasks/S3DownloadMultithreadedHTTPExample.c new file mode 100644 index 0000000000..b06e1b2579 --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/DemoTasks/S3DownloadMultithreadedHTTPExample.c @@ -0,0 +1,1165 @@ +/* + * FreeRTOS V202011.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 + * + */ + +/* + * Demo for showing the use of the HTTP API using a server-authenticated network + * connection. + * + * This example resolves a S3 domain (using a pre-signed URL), establishes a TCP + * connection, validates the server's certificate using the configurable root CA + * certificate, and then finally performs a TLS handshake with the HTTP server, + * so that all communication is encrypted. + * + * Afterwards, two additional tasks are created (a request and response task), + * along with two thread-safe queues (a request and response queue), to + * demonstrate an asynchronous workflow for downloading an S3 file. + * + * There are three tasks to note in this demo: + * - prvHTTPDemoTask() is responsible for sending HTTP requests to the server + * over the transport interface, using the HTTP Client library API. It reads + * requests from the request queue and places corresponding server responses + * on the response queue. + * - prvRequestTask() is responsible for generating request objects and adding + * them to the request queue, specifying a byte range with each iteration in + * order to download the S3 file in partial content responses. + * - prvResponseTask() logs and evaluates server responses to outgoing requests. + * It reads responses from the response queue until the expected number of + * responses have been received. + * + * Each individual task runs continuously in a loop, until its respective job is + * completed. If any request fails, an error code is returned. + * + * @note This demo requires user-generated pre-signed URLs to be pasted into + * demo_config.h. Please use the provided script "presigned_urls_gen.py" + * (located in located in coreHTTP_Windows_Simulator/Common) to generate these + * URLs. For detailed instructions, see the accompanied README.md. + */ + +/** + * @file S3DownloadMultithreadedHTTPExample.c + * @brief Demonstrates usage of the HTTP library. + */ + +/* Standard includes. */ +#include +#include +#include + +/* Kernel includes. */ +#include "FreeRTOS.h" +#include "task.h" +#include "queue.h" + +/* Demo Specific configs. */ +#include "demo_config.h" + +/* HTTP library includes. */ +#include "core_http_client.h" + +/* Transport interface implementation include header for TLS. */ +#include "using_mbedtls.h" + +/* Common HTTP demo utilities. */ +#include "http_demo_utils.h" + +/*------------- Demo configurations -------------------------*/ + +/* Check that the root CA certificate is defined. */ +#ifndef democonfigROOT_CA_PEM + #error "Please define democonfigROOT_CA_PEM in demo_config.h." +#endif + +/* Check that the pre-signed GET URL is defined. */ +#ifndef democonfigS3_PRESIGNED_GET_URL + #error "Please define democonfigS3_PRESIGNED_GET_URL in demo_config.h." +#endif + +/* Check that a TLS port for AWS IoT Core is defined. */ +#ifndef democonfigHTTPS_PORT + #define democonfigHTTPS_PORT ( 443 ) +#endif + +/* Check the the queue size is defined. */ +#ifndef democonfigQUEUE_SIZE + #define democonfigQUEUE_SIZE ( 10 ) +#endif + +/* Check that a transport timeout for transport send and receive is defined. */ +#ifndef democonfigTRANSPORT_SEND_RECV_TIMEOUT_MS + #define democonfigTRANSPORT_SEND_RECV_TIMEOUT_MS ( 5000 ) +#endif + +/* Check that a size for the user buffer is defined. */ +#ifndef democonfigUSER_BUFFER_LENGTH + #define democonfigUSER_BUFFER_LENGTH ( 2048 ) +#endif + +/* Check that the range request length is defined. */ +#ifndef democonfigRANGE_REQUEST_LENGTH + #define democonfigRANGE_REQUEST_LENGTH ( 1024 ) +#endif + +/* Check that the stack size to use for HTTP tasks is defined. */ +#ifndef httpexampleTASK_STACK_SIZE + #define httpexampleTASK_STACK_SIZE ( configMINIMAL_STACK_SIZE * 4 ) +#endif + +/** + * @brief Length of the pre-signed GET URL defined in demo_config.h. + */ +#define httpexampleS3_PRESIGNED_GET_URL_LENGTH ( sizeof( democonfigS3_PRESIGNED_GET_URL ) - 1 ) + +/** + * @brief The length of the HTTP GET method. + */ +#define httpexampleHTTP_METHOD_GET_LENGTH ( sizeof( HTTP_METHOD_GET ) - 1 ) + +/** + * @brief Field name of the HTTP range header to read from the server response. + */ +#define httpexampleHTTP_CONTENT_RANGE_HEADER_FIELD "Content-Range" + +/** + * @brief Length of the HTTP range header field. + */ +#define httpexampleHTTP_CONTENT_RANGE_HEADER_FIELD_LENGTH ( sizeof( httpexampleHTTP_CONTENT_RANGE_HEADER_FIELD ) - 1 ) + +/** + * @brief The HTTP status code returned for partial content. + */ +#define httpexampleHTTP_STATUS_CODE_PARTIAL_CONTENT 206 + +/** + * @brief Ticks to wait for task notifications. + */ +#define httpexampleDEMO_TICKS_TO_WAIT pdMS_TO_TICKS( 1000 ) + +/** + * @brief Notification bit indicating an error between tasks. + */ +#define httpexampleHTTP_FAILURE ( 1U << 1 ) + +/** + * @brief Notification bit indicating completion of the request task. + */ +#define httpexampleREQUEST_TASK_COMPLETION ( 1U << 2 ) + +/** + * @brief Notification bit indicating completion of the response task. + */ +#define httpexampleRESPONSE_TASK_COMPLETION ( 1U << 3 ) + +/** + * @brief The maximum number of loop iterations to wait for task completion, or + * after the last received server response, before declaring failure. + */ +#define httpexampleMAX_WAIT_ITERATIONS ( 5 ) + +/** + * @brief The maximum number of times to run the loop in this demo. + * + * @note The loop is executed only if the demo fails initially. Once the demo + * loop succeeds on a single iteration, the demo exits successfully. + */ +#ifndef HTTP_MAX_DEMO_LOOP_COUNT + #define HTTP_MAX_DEMO_LOOP_COUNT ( 3 ) +#endif + +/** + * @brief Time in ticks to wait between retries of the demo loop, if + * demo loop fails. + */ +#define DELAY_BETWEEN_DEMO_RETRY_ITERATIONS_TICKS ( pdMS_TO_TICKS( 5000U ) ) + +/* Each compilation unit must define the NetworkContext struct. */ +struct NetworkContext +{ + TlsTransportParams_t * pParams; +}; + +/** + * @brief The network context used for the TLS session with the server. + */ +static NetworkContext_t xNetworkContext; + +/** + * @brief The host address string extracted from the pre-signed URL. + * + * @note httpexampleS3_PRESIGNED_GET_URL_LENGTH is set as the array length here + * as the length of the host name string cannot exceed this value. + */ +static char cServerHost[ httpexampleS3_PRESIGNED_GET_URL_LENGTH ]; + +/** + * @brief The length of the host address found in the pre-signed URL. + */ +static size_t xServerHostLength; + +/** + * @brief The location of the path within the pre-signed URL. + */ +static const char * pcPath; + +/** + * @brief Data type for the request queue. + * + * Contains the request header struct and its corresponding buffer, to be + * populated and enqueued by the request task, and read by the main task. The + * buffer is included to avoid pointer inaccuracy during queue copy operations. + */ +typedef struct RequestItem +{ + HTTPRequestHeaders_t xRequestHeaders; + uint8_t ucHeaderBuffer[ democonfigUSER_BUFFER_LENGTH ]; +} RequestItem_t; + +/** + * @brief Data type for the response queue. + * + * Contains the response data type and its corresponding buffer, to be enqueued + * by the main task, and interpreted by the response task. The buffer is + * included to avoid pointer inaccuracy during queue copy operations. + */ +typedef struct ResponseItem +{ + HTTPResponse_t xResponse; + uint8_t ucResponseBuffer[ democonfigUSER_BUFFER_LENGTH ]; +} ResponseItem_t; + +/** + * @brief Struct used by the request task to add requests to the request queue. + * + * This structure is modified only by the request task. Since queue operations + * are done by-copy, it is safe for the request task to modify this struct once + * the previous request has been successfully enqueued. + */ +static RequestItem_t xRequestItem = { 0 }; + +/** + * @brief Struct used by the response task to receive responses from the + * response queue. + * + * This structure is modified only by the response task. Since queue operations + * are done by-copy, it is safe for the response task to modify this struct once + * the previous response has been parsed. + */ +static ResponseItem_t xResponseItem = { 0 }; + +/** + * @brief Struct used by the main HTTP task to send requests to the server. + * + * This structure is modified only by the main HTTP task, and is used to receive + * requests off of the request queue and send them to the HTTP server. Since + * queue operations are done by-copy, it is safe for the main task to modify + * this struct once the previous request has been sent to the server. + */ +static RequestItem_t xDownloadReqItem = { 0 }; + +/** + * @brief Struct used by the main HTTP task to receive responses from the server + * and place them on the response queue. + * + * This structure is modified only by the main HTTP task. Since queue operations + * are done by-copy, it is safe for the main task to modify this struct once the + * previous response has been successfully enqueued. + */ +static ResponseItem_t xDownloadRespItem = { 0 }; + +/** + * @brief Queue for HTTP requests. Requests are enqueued by the request task, + * and dequeued by the main HTTP task. + */ +static QueueHandle_t xRequestQueue; + +/** + * @brief Queue for HTTP responses. Responses are enqueued by the main HTTP + * task, and dequeued by the response task. + */ +static QueueHandle_t xResponseQueue; + +/** + * @brief Handle for prvRequestTask. + */ +static TaskHandle_t xRequestTask; + +/** + * @brief Handle for prvResponseTask. + */ +static TaskHandle_t xResponseTask; + +/** + * @brief Handle for prvHTTPDemoTask. + */ +static TaskHandle_t xMainTask; + +/** + * @brief The length of the file located at democonfigS3_PRESIGNED_GET_URL. + */ +static size_t xFileSize = 0; + +/** + * @brief The number of responses expected by the response task. + */ +static size_t xResponseCount = 0; + +/*-----------------------------------------------------------*/ + +/** + * @brief The main task used to demonstrate the HTTP API. + * + * After creating the request and response tasks, this task will enter into a + * loop, processing requests from the request queue and calling the HTTP API to + * send them to the server. After the request task has finished adding requests + * to the queue, the task will break from the loop. + * + * @param[in] pvParameters Parameters as passed at the time of task creation. + * Not used in this example. + */ +static void prvHTTPDemoTask( void * pvParameters ); + +/** + * @brief Connect to the HTTP server with reconnection retries. + * + * @param[out] pxNetworkContext The output parameter to return the created + * network context. + * + * @return pdPASS on successful connection; pdFAIL otherwise. + */ +static BaseType_t prvConnectToServer( NetworkContext_t * pxNetworkContext ); + +/** + * @brief Enqueue an HTTP GET request for a given range of the S3 file. + * + * @param[in] pxRequestInfo The #HTTPRequestInfo_t for configuring the request. + * @param[in] xStart The position of the first byte in the range. + * @param[in] xEnd The position of the last byte in the range, inclusive. + * + * @return pdPASS if request successfully enqueued; pdFAIL otherwise. + */ +static BaseType_t prvRequestS3ObjectRange( const HTTPRequestInfo_t * pxRequestInfo, + const size_t xStart, + const size_t xEnd ); + +/** + * @brief Check for a task notification. + * + * @param[in] pulNotification Pointer holding the notification value. + * @param[in] ulExpectedBits Bits to wait for. + * @param[in] xClearBits If bits should be cleared. + * + * @return pdTRUE if notification received; pdFALSE otherwise. + */ +static BaseType_t prvCheckNotification( uint32_t * pulNotification, + uint32_t ulExpectedBits, + BaseType_t xClearBits ); + +/** + * @brief Enqueue a request for the size of the S3 object specified in pcPath. + * + * @param[in] pxRequestInfo The #HTTPRequestInfo_t for configuring the request. + * + * @return pdFAIL on failure; pdPASS on success. + */ +static BaseType_t prvGetS3ObjectFileSize( const HTTPRequestInfo_t * pxRequestInfo ); + +/** + * @brief Task to continuously enqueue HTTP range requests onto the request + * queue, until the entire length of the file has been requested. + * + * @param[in] pvArgs Parameters as passed at the time of task creation. Not used + * in this example. + */ +static void prvRequestTask( void * pvArgs ); + +/** + * @brief Read and interpret the server response corresponding to the file size + * request. Called by the response task. + * + * @return pdFAIL on failure; pdPASS on success. + */ +static BaseType_t prvReadFileSize( void ); + +/** + * @brief Task to continuously log and interpret responses present on the + * response queue, until the length of the file is downloaded. + * + * @param[in] pvArgs Parameters as passed at the time of task creation. Not used + * in this example. + */ +static void prvResponseTask( void * pvArgs ); + +/** + * @brief Services HTTP requests from the request queue and writes corresponding + * responses to the response queue. Called by the main task. + * + * @return pdFAIL on failure; pdPASS on success. + */ +static BaseType_t prvDownloadLoop( void ); + +/*-----------------------------------------------------------*/ + +/* + * @brief Create task to demonstrate the HTTP API over a server-authenticated + * network connection with a server. + */ +void vStartSimpleHTTPDemo( void ) +{ + /* This example uses one application task to process the request queue for + * HTTP operations, and creates additional tasks to add operations to that + * queue and interpret server responses. */ + xTaskCreate( prvHTTPDemoTask, /* Function that implements the task. */ + "MainTask", /* Text name for the task - only used for debugging. */ + democonfigDEMO_STACKSIZE, /* Size of stack (in words, not bytes) to allocate for the task. */ + NULL, /* Task parameter - not used in this case. */ + tskIDLE_PRIORITY + 1, /* Task priority, must be between 0 and configMAX_PRIORITIES - 1. */ + &xMainTask ); /* Used to pass out a handle to the created task. */ +} + +/*-----------------------------------------------------------*/ + +/** + * @brief Entry point of the demo. + * + * This example resolves a S3 domain (using a pre-signed URL), establishes a TCP + * connection, validates the server's certificate using the configurable root CA + * certificate, and then finally performs a TLS handshake with the HTTP server, + * so that all communication is encrypted. + * + * Afterwards, two additional tasks are created (a request and response task), + * along with two thread-safe queues (a request and response queue), to + * demonstrate an asynchronous workflow for downloading an S3 file. The tasks + * run continuously until the entire file is downloaded. If any request fails, + * an error code is returned. + * + * @note This demo requires user-generated pre-signed URLs to be pasted into + * demo_config.h. Please use the provided script "presigned_urls_gen.py" + * (located in located in coreHTTP_Windows_Simulator/Common) to generate these + * URLs. For detailed instructions, see the accompanied README.md. + * + */ +static void prvHTTPDemoTask( void * pvParameters ) +{ + BaseType_t xIsConnectionEstablished = pdFALSE; + TlsTransportParams_t xTlsTransportParams = { 0 }; + /* HTTP client library return status. */ + HTTPStatus_t xHTTPStatus = HTTPSuccess; + /* The location of the host address within the pre-signed URL. */ + const char * pcAddress = NULL; + /* The user of this demo must check the logs for any failure codes. */ + BaseType_t xDemoStatus = pdPASS; + UBaseType_t uxDemoRunCount = 0UL; + + /* The length of the path within the pre-signed URL. This variable is + * defined in order to store the length returned from parsing the URL, but + * it is unused. The path used for the requests in this demo needs all the + * query information following the location of the object, to the end of the + * S3 presigned URL. */ + size_t pathLen = 0; + + /* Remove compiler warnings about unused parameters. */ + ( void ) pvParameters; + + /* Set the pParams member of the network context with desired transport. */ + xNetworkContext.pParams = &xTlsTransportParams; + + LogInfo( ( "HTTP Client S3 multi-threaded download demo using pre-signed URL:\n%s", + democonfigS3_PRESIGNED_GET_URL ) ); + + /* This demo runs once, unless there are failures in the demo execution. In + * case of failure, the demo loop will be retried for up to + * HTTP_MAX_DEMO_LOOP_COUNT times. */ + do + { + /**************************** Parse Signed URL. ******************************/ + + /* Retrieve the path location from democonfigS3_PRESIGNED_GET_URL. This + * function returns the length of the path without the query, into + * pathLen. */ + xHTTPStatus = getUrlPath( democonfigS3_PRESIGNED_GET_URL, + httpexampleS3_PRESIGNED_GET_URL_LENGTH, + &pcPath, + &pathLen ); + + xDemoStatus = ( xHTTPStatus == HTTPSuccess ) ? pdPASS : pdFAIL; + + if( xDemoStatus == pdPASS ) + { + /* Retrieve the address location and length from + * democonfigS3_PRESIGNED_GET_URL. */ + xHTTPStatus = getUrlAddress( democonfigS3_PRESIGNED_GET_URL, + httpexampleS3_PRESIGNED_GET_URL_LENGTH, + &pcAddress, + &xServerHostLength ); + + xDemoStatus = ( xHTTPStatus == HTTPSuccess ) ? pdPASS : pdFAIL; + } + + if( xDemoStatus == pdPASS ) + { + /* cServerHost should consist only of the host address located in + * democonfigS3_PRESIGNED_GET_URL. */ + memcpy( cServerHost, pcAddress, xServerHostLength ); + cServerHost[ xServerHostLength ] = '\0'; + } + + /**************************** Connect. ******************************/ + + if( xDemoStatus == pdPASS ) + { + /* Attempt to connect to the HTTP server. If connection fails, retry after a + * timeout. The timeout value will be exponentially increased until either the + * maximum number of attempts or the maximum timeout value is reached. The + * function returns pdFAIL if the TCP connection cannot be established with + * the server after the configured number of attempts. */ + xDemoStatus = connectToServerWithBackoffRetries( prvConnectToServer, + &xNetworkContext ); + } + + if( xDemoStatus == pdPASS ) + { + /* Set a flag indicating that a TLS connection exists. */ + xIsConnectionEstablished = pdTRUE; + } + else + { + /* Log an error to indicate connection failure after all reconnect + * attempts are over. */ + LogError( ( "Failed to connect to HTTP server %s.", + cServerHost ) ); + } + + /************* Open queues and create additional tasks. *************/ + if( xDemoStatus == pdPASS ) + { + /* Open request and response queues. */ + xRequestQueue = xQueueCreate( democonfigQUEUE_SIZE, + sizeof( RequestItem_t ) ); + + xResponseQueue = xQueueCreate( democonfigQUEUE_SIZE, + sizeof( ResponseItem_t ) ); + + /* Open request and response tasks. */ + xDemoStatus = xTaskCreate( prvRequestTask, + "RequestTask", + httpexampleTASK_STACK_SIZE, + NULL, + tskIDLE_PRIORITY, + &xRequestTask ); + + xDemoStatus = xTaskCreate( prvResponseTask, + "ResponseTask", + httpexampleTASK_STACK_SIZE, + NULL, + tskIDLE_PRIORITY, + &xResponseTask ); + } + + /******************** Download S3 Object File. **********************/ + + if( xDemoStatus == pdPASS ) + { + /* Enter main HTTP task download loop. */ + xDemoStatus = prvDownloadLoop(); + } + + /************************** Disconnect. *****************************/ + + /* Close the network connection to clean up any system resources that the + * demo may have consumed. */ + if( xIsConnectionEstablished == pdTRUE ) + { + /* Close the network connection. */ + TLS_FreeRTOS_Disconnect( &xNetworkContext ); + } + + LogInfo( ( "Deleting queues." ) ); + + /* Close and delete the queues. */ + if( xRequestQueue != NULL ) + { + vQueueDelete( xRequestQueue ); + } + + if( xResponseQueue != NULL ) + { + vQueueDelete( xResponseQueue ); + } + + /******************** Retry in case of failure. *********************/ + + /* Increment the demo run count. */ + uxDemoRunCount++; + + if( xDemoStatus == pdPASS ) + { + LogInfo( ( "Demo iteration %lu was successful.", uxDemoRunCount ) ); + } + /* Attempt to retry a failed demo iteration for up to #HTTP_MAX_DEMO_LOOP_COUNT times. */ + else if( uxDemoRunCount < HTTP_MAX_DEMO_LOOP_COUNT ) + { + LogWarn( ( "Demo iteration %lu failed. Retrying...", uxDemoRunCount ) ); + vTaskDelay( DELAY_BETWEEN_DEMO_RETRY_ITERATIONS_TICKS ); + } + /* Failed all #HTTP_MAX_DEMO_LOOP_COUNT demo iterations. */ + else + { + LogError( ( "All %d demo iterations failed.", HTTP_MAX_DEMO_LOOP_COUNT ) ); + break; + } + } while( xDemoStatus != pdPASS ); + + if( xDemoStatus == pdPASS ) + { + LogInfo( ( "prvHTTPDemoTask() completed successfully. " + "Total free heap is %u.\r\n", + xPortGetFreeHeapSize() ) ); + LogInfo( ( "Demo completed successfully.\r\n" ) ); + } +} + +/*-----------------------------------------------------------*/ + +static BaseType_t prvConnectToServer( NetworkContext_t * pxNetworkContext ) +{ + TlsTransportStatus_t xNetworkStatus; + NetworkCredentials_t xNetworkCredentials = { 0 }; + BaseType_t xStatus = pdPASS; + + configASSERT( pxNetworkContext != NULL ); + + /* Set the credentials for establishing a TLS connection. */ + xNetworkCredentials.disableSni = democonfigDISABLE_SNI; + xNetworkCredentials.pRootCa = ( const unsigned char * ) democonfigROOT_CA_PEM; + xNetworkCredentials.rootCaSize = sizeof( democonfigROOT_CA_PEM ); + + /* Establish a TLS session with the HTTP server. This example connects to + * the server host found in democonfigPRESIGNED_GET_URL on port + * democonfigHTTPS_PORT in demo_config.h. */ + LogInfo( ( "Establishing a TLS session with %s:%d.", + cServerHost, + democonfigHTTPS_PORT ) ); + + /* Attempt to create a server-authenticated TLS connection. */ + xNetworkStatus = TLS_FreeRTOS_Connect( pxNetworkContext, + cServerHost, + democonfigHTTPS_PORT, + &xNetworkCredentials, + democonfigTRANSPORT_SEND_RECV_TIMEOUT_MS, + democonfigTRANSPORT_SEND_RECV_TIMEOUT_MS ); + + if( xNetworkStatus != TLS_TRANSPORT_SUCCESS ) + { + LogWarn( ( "Unsuccessful connection attempt, received error code:%d", + ( int ) xNetworkStatus ) ); + xStatus = pdFAIL; + } + + return xStatus; +} + +/*-----------------------------------------------------------*/ + +static BaseType_t prvRequestS3ObjectRange( const HTTPRequestInfo_t * pxRequestInfo, + const size_t xStart, + const size_t xEnd ) +{ + HTTPStatus_t xHTTPStatus = HTTPSuccess; + BaseType_t xStatus = pdPASS; + + configASSERT( pxRequestInfo != NULL ); + + /* Set the buffer used for storing request headers. */ + xRequestItem.xRequestHeaders.pBuffer = xRequestItem.ucHeaderBuffer; + xRequestItem.xRequestHeaders.bufferLen = democonfigUSER_BUFFER_LENGTH; + + xHTTPStatus = HTTPClient_InitializeRequestHeaders( &( xRequestItem.xRequestHeaders ), + pxRequestInfo ); + + if( xHTTPStatus != HTTPSuccess ) + { + LogError( ( "Failed to initialize HTTP request headers: Error=%s.", + HTTPClient_strerror( xHTTPStatus ) ) ); + xStatus = pdFAIL; + } + + if( xStatus == pdPASS ) + { + xHTTPStatus = HTTPClient_AddRangeHeader( &( xRequestItem.xRequestHeaders ), + xStart, + xEnd ); + + if( xHTTPStatus != HTTPSuccess ) + { + LogError( ( "Failed to add Range header to request headers: Error=%s.", + HTTPClient_strerror( xHTTPStatus ) ) ); + xStatus = pdFAIL; + } + } + + if( xStatus == pdPASS ) + { + LogInfo( ( "Request task: Enqueuing request for bytes %d to %d of S3 Object. ", + ( int32_t ) xStart, + ( int32_t ) xEnd ) ); + LogDebug( ( "Request Headers:\n%.*s", + ( int32_t ) xRequestItem.xRequestHeaders.headersLen, + ( char * ) xRequestItem.xRequestHeaders.pBuffer ) ); + + /* Enqueue the request. */ + xStatus = xQueueSendToBack( xRequestQueue, + &xRequestItem, + httpexampleDEMO_TICKS_TO_WAIT ); + + /* Ensure request was added to the queue. */ + if( xStatus == pdFAIL ) + { + LogError( ( "Request task: Could not enqueue request." ) ); + } + } + + return xStatus; +} + +/*-----------------------------------------------------------*/ + +static BaseType_t prvGetS3ObjectFileSize( const HTTPRequestInfo_t * pxRequestInfo ) +{ + BaseType_t xStatus = pdPASS; + + configASSERT( pxRequestInfo != NULL ); + + LogInfo( ( "Getting file object size from host..." ) ); + + /* Request bytes 0 to 0. S3 will respond with a Content-Range header that + * contains the size of the file. The header will look like the following: + * "Content-Range: bytes 0-0/FILESIZE". The response body will have a single + * byte, that we are ignoring. */ + xStatus = prvRequestS3ObjectRange( pxRequestInfo, + 0, + 0 ); + + return xStatus; +} + +/*-----------------------------------------------------------*/ + +static void prvRequestTask( void * pvArgs ) +{ + BaseType_t xStatus = pdPASS; + uint32_t ulNotification = 0UL; + + /* Configurations of the initial request headers. */ + HTTPRequestInfo_t xRequestInfo = { 0 }; + + /* The number of bytes to request on each iteration. */ + size_t xNumReqBytes = 0; + /* The starting byte of the next range request. */ + size_t xCurByte = 0; + + /* The path used for the requests in this demo require all the query + * information following the location of the object, to the end of the S3 + * presigned URL. */ + size_t xRequestUriLen = strlen( pcPath ); + + ( void ) pvArgs; + + /* Initialize the request object. */ + xRequestInfo.pHost = cServerHost; + xRequestInfo.hostLen = xServerHostLength; + xRequestInfo.pMethod = HTTP_METHOD_GET; + xRequestInfo.methodLen = httpexampleHTTP_METHOD_GET_LENGTH; + xRequestInfo.pPath = pcPath; + xRequestInfo.pathLen = xRequestUriLen; + + /* Set the HTTP "Connection" header to "keep-alive" to allow multiple + * requests to be sent over the same established TCP connection. This is + * done in order to download the file in parts. */ + xRequestInfo.reqFlags = HTTP_REQUEST_KEEP_ALIVE_FLAG; + + /* Get the length of the S3 file. */ + xStatus = prvGetS3ObjectFileSize( &xRequestInfo ); + + /* Wait for the response task to receive and interpret the server response + * to the file size request. */ + while( xFileSize == 0 ) + { + /* Check if any errors in the response task have occurred. */ + if( prvCheckNotification( &ulNotification, httpexampleHTTP_FAILURE, pdTRUE ) != pdFALSE ) + { + LogError( ( "Request task: Received error notification from response task while waiting for the file size. Exiting task." ) ); + xStatus = pdFAIL; + break; + } + } + + /* Set the number of bytes to request in each iteration, defined by the user + * in democonfigRANGE_REQUEST_LENGTH. */ + if( xFileSize < democonfigRANGE_REQUEST_LENGTH ) + { + xNumReqBytes = xFileSize; + } + else + { + xNumReqBytes = democonfigRANGE_REQUEST_LENGTH; + } + + /* Here we continuously add range requests to the request queue (and keep + * track of their count, with xResponseCount), until the entire length of + * the file has been requested. We keep track of the next starting byte to + * download with xCurByte, and increment by xNumReqBytes after each + * iteration, until xCurByte has reached xFileSize. */ + while( ( xStatus != pdFAIL ) && ( xCurByte < xFileSize ) ) + { + /* Add range request to the request queue. */ + xStatus = prvRequestS3ObjectRange( &xRequestInfo, + xCurByte, + xCurByte + xNumReqBytes - 1 ); + + /* Update the starting byte for the next iteration.*/ + xCurByte += xNumReqBytes; + + /* If the number of bytes left to download is less than the + * pre-defined constant xNumReqBytes, set xNumReqBytes to equal the + * accurate number of remaining bytes left to download. */ + if( ( xFileSize - xCurByte ) < xNumReqBytes ) + { + xNumReqBytes = xFileSize - xCurByte; + } + + /* If the request was successfully enqueued, we expect a + * corresponding response. */ + xResponseCount += 1; + } + + /* Clear this task's notifications. */ + xTaskNotifyStateClear( NULL ); + ulNotification = ulTaskNotifyValueClear( NULL, ~( 0UL ) ); + + /* Notify the main task of completion. */ + xTaskNotify( xMainTask, httpexampleREQUEST_TASK_COMPLETION, eSetBits ); + + /* Delete this task. */ + LogInfo( ( "Deleting request task." ) ); + vTaskDelete( NULL ); +} + +/*-----------------------------------------------------------*/ + +static BaseType_t prvReadFileSize( void ) +{ + BaseType_t xStatus = pdPASS; + HTTPStatus_t xHTTPStatus = HTTPSuccess; + + /* The location of the file size in pcContentRangeValStr. */ + char * pcFileSizeStr = NULL; + + /* String to store the Content-Range header value. */ + char * pcContentRangeValStr = NULL; + size_t xContentRangeValStrLength = 0; + + for( ; ; ) + { + if( xQueueReceive( xResponseQueue, &xResponseItem, httpexampleDEMO_TICKS_TO_WAIT ) != pdFAIL ) + { + /* Ensure that the buffer pointer is accurate after being copied from the queue. */ + xResponseItem.xResponse.pBuffer = xResponseItem.ucResponseBuffer; + + /* Ensure that we received a successful response from the server. */ + if( xResponseItem.xResponse.statusCode != httpexampleHTTP_STATUS_CODE_PARTIAL_CONTENT ) + { + LogError( ( "Received response with unexpected status code: %d.", xResponseItem.xResponse.statusCode ) ); + xStatus = pdFAIL; + } + else + { + xHTTPStatus = HTTPClient_ReadHeader( &xResponseItem.xResponse, + ( char * ) httpexampleHTTP_CONTENT_RANGE_HEADER_FIELD, + ( size_t ) httpexampleHTTP_CONTENT_RANGE_HEADER_FIELD_LENGTH, + ( const char ** ) &pcContentRangeValStr, + &xContentRangeValStrLength ); + + if( xHTTPStatus != HTTPSuccess ) + { + LogError( ( "Failed to read Content-Range header from HTTP response: Error=%s.", + HTTPClient_strerror( xHTTPStatus ) ) ); + xStatus = pdFAIL; + } + } + + break; + } + } + + /* Parse the Content-Range header value to get the file size. */ + if( xStatus == pdPASS ) + { + pcFileSizeStr = strstr( pcContentRangeValStr, "/" ); + + if( pcFileSizeStr == NULL ) + { + LogError( ( "'/' not present in Content-Range header value: %s.", + pcContentRangeValStr ) ); + xStatus = pdFAIL; + } + } + + if( xStatus == pdPASS ) + { + pcFileSizeStr += sizeof( char ); + xFileSize = ( size_t ) strtoul( pcFileSizeStr, NULL, 10 ); + + if( ( xFileSize == 0 ) || ( xFileSize == UINT32_MAX ) ) + { + LogError( ( "Error using strtoul to get the file size from %s: xFileSize=%d.", + pcFileSizeStr, ( int32_t ) xFileSize ) ); + xStatus = pdFAIL; + } + } + + if( xStatus == pdPASS ) + { + LogInfo( ( "The file is %d bytes long.", ( int32_t ) xFileSize ) ); + } + + return xStatus; +} + +/*-----------------------------------------------------------*/ + +static void prvResponseTask( void * pvArgs ) +{ + uint32_t ulWaitCounter = 0UL; + uint32_t ulNotification = 0UL; + size_t xNumResponses = 0; + + ( void ) pvArgs; + + if( prvReadFileSize() != pdPASS ) + { + LogError( ( "Response task: Error obtaining file size from the server response. Exiting task." ) ); + + /* Notify the other tasks of failure. */ + xTaskNotify( xRequestTask, httpexampleHTTP_FAILURE, eSetBits ); + xTaskNotify( xMainTask, httpexampleHTTP_FAILURE, eSetBits ); + } + else + { + for( ; ; ) + { + /* Retrieve response from the response queue, if available. */ + while( ( xQueueReceive( xResponseQueue, &xResponseItem, httpexampleDEMO_TICKS_TO_WAIT ) != pdFAIL ) ) + { + /* Ensure that the buffer pointer is accurate after being copied from the queue. */ + xResponseItem.xResponse.pBuffer = xResponseItem.ucResponseBuffer; + + /* Log contents of server response. */ + LogInfo( ( "The response task retrieved a server response from the response queue." ) ); + LogDebug( ( "Response Headers:\n%.*s", + ( int32_t ) xResponseItem.xResponse.headersLen, + xResponseItem.xResponse.pHeaders ) ); + LogDebug( ( "Response Status:\n%u", + xResponseItem.xResponse.statusCode ) ); + LogInfo( ( "Response Body:\n%.*s\n", + ( int32_t ) xResponseItem.xResponse.bodyLen, + xResponseItem.xResponse.pBody ) ); + + /* Check for a partial content status code (206), indicating a + * successful server response. */ + if( xResponseItem.xResponse.statusCode != httpexampleHTTP_STATUS_CODE_PARTIAL_CONTENT ) + { + LogError( ( "Received response with unexpected status code: %d", xResponseItem.xResponse.statusCode ) ); + break; + } + + /* Increment the number of responses found on the queue. */ + xNumResponses += 1; + /* Reset the wait counter every time a response is received. */ + ulWaitCounter = 0; + } + + /* Break if we have received all expected responses. */ + if( xNumResponses >= xResponseCount ) + { + break; + } + + /* Break if we have been stuck waiting for a response for too long. + * The total wait here will be the (notification check delay + queue + * check delay), multiplied by `httpexampleMAX_WAIT_ITERATIONS`. For + * example, with a 1000 ms delay for both checks, and a maximum + * iteration of 5, this function will wait 10 seconds after + * receiving the last response before exiting the loop. */ + if( ++ulWaitCounter > httpexampleMAX_WAIT_ITERATIONS ) + { + LogError( ( "Response receive loop exceeded maximum wait time." ) ); + break; + } + else if( prvCheckNotification( &ulNotification, httpexampleHTTP_FAILURE, pdTRUE ) != pdFALSE ) + { + LogError( ( "Response task: Received error notification from the main HTTP task. Exiting task." ) ); + break; + } + } + } + + /* Clear this task's notifications. */ + xTaskNotifyStateClear( NULL ); + ulNotification = ulTaskNotifyValueClear( NULL, ~( 0UL ) ); + + /* Notify the main task of completion. */ + xTaskNotify( xMainTask, httpexampleRESPONSE_TASK_COMPLETION, eSetBits ); + + /* Delete this task. */ + LogInfo( ( "Deleting response task." ) ); + vTaskDelete( NULL ); +} + +/*-----------------------------------------------------------*/ + +static BaseType_t prvCheckNotification( uint32_t * pulNotification, + uint32_t ulExpectedBits, + BaseType_t xClearBits ) +{ + BaseType_t xStatus = pdTRUE; + + configASSERT( pulNotification != NULL ); + + xTaskNotifyWait( 0, + ( xClearBits == pdTRUE ) ? ulExpectedBits : 0, + pulNotification, + httpexampleDEMO_TICKS_TO_WAIT ); + + xStatus = ( ( *pulNotification & ulExpectedBits ) == ulExpectedBits ) ? pdTRUE : pdFALSE; + + return xStatus; +} + +/*-----------------------------------------------------------*/ + +static BaseType_t prvDownloadLoop( void ) +{ + /* The transport layer interface used by the HTTP client library. */ + TransportInterface_t xTransportInterface; + HTTPStatus_t xHTTPStatus = HTTPSuccess; + BaseType_t xStatus = pdPASS; + uint32_t ulNotification = 0UL; + uint32_t ulWaitCounter = 0UL; + + /* Expected task completion notifications. */ + uint32_t ulExpectedNotifications = httpexampleREQUEST_TASK_COMPLETION | + httpexampleRESPONSE_TASK_COMPLETION; + + /* Define the transport interface. */ + xTransportInterface.pNetworkContext = &xNetworkContext; + xTransportInterface.send = TLS_FreeRTOS_send; + xTransportInterface.recv = TLS_FreeRTOS_recv; + + /* Initialize response struct. */ + xDownloadRespItem.xResponse.pBuffer = xDownloadRespItem.ucResponseBuffer; + xDownloadRespItem.xResponse.bufferLen = democonfigUSER_BUFFER_LENGTH; + + for( ; ; ) + { + /* Read request from the request queue. */ + if( xQueueReceive( xRequestQueue, &xDownloadReqItem, httpexampleDEMO_TICKS_TO_WAIT ) != pdPASS ) + { + /* Check for any errors in the response task. */ + if( prvCheckNotification( &ulNotification, httpexampleHTTP_FAILURE, pdFALSE ) != pdFALSE ) + { + LogInfo( ( "Main HTTP task: Received error notification from response task. Exiting HTTP download loop." ) ); + xStatus = pdFAIL; + break; + } + /* Check if the request task has finished adding requests to the queue. */ + else if( prvCheckNotification( &ulNotification, httpexampleREQUEST_TASK_COMPLETION, pdFALSE ) != pdFALSE ) + { + LogInfo( ( "Main HTTP task: Received notification of completion from request task -- no more requests to process. " + "Exiting HTTP download loop." ) ); + break; + } + + LogInfo( ( "Main HTTP task: No requests in the queue. Trying again." ) ); + continue; + } + + /* Ensure that the buffer pointer is accurate after being copied from the queue. */ + xDownloadReqItem.xRequestHeaders.pBuffer = xDownloadReqItem.ucHeaderBuffer; + + LogInfo( ( "The main HTTP task retrieved a request from the request queue. Sending to server..." ) ); + LogDebug( ( "Request Headers:\n%.*s", + ( int32_t ) xDownloadReqItem.xRequestHeaders.headersLen, + ( char * ) xDownloadReqItem.xRequestHeaders.pBuffer ) ); + + /* Send request to the S3 server. */ + xHTTPStatus = HTTPClient_Send( &xTransportInterface, + &xDownloadReqItem.xRequestHeaders, + NULL, + 0, + &xDownloadRespItem.xResponse, + 0 ); + + if( xHTTPStatus != HTTPSuccess ) + { + LogError( ( "Main HTTP task: Failed to send HTTP request: Error=%s.", + HTTPClient_strerror( xHTTPStatus ) ) ); + + /* Notify the response task that a response should not be expected. */ + xTaskNotify( xResponseTask, httpexampleHTTP_FAILURE, eSetBits ); + + xStatus = pdFAIL; + break; + } + else + { + LogInfo( ( "The HTTP task received a response from the server. Adding to response queue." ) ); + + /* Add response to response queue. */ + xStatus = xQueueSendToBack( xResponseQueue, + &xDownloadRespItem, + httpexampleDEMO_TICKS_TO_WAIT ); + + /* Ensure response was added to the queue successfully. */ + if( xStatus != pdPASS ) + { + LogError( ( "Main HTTP task: Could not enqueue response." ) ); + break; + } + } + } + + /* Wait for the other tasks to complete. */ + while( prvCheckNotification( &ulNotification, ulExpectedNotifications, pdFALSE ) != pdTRUE ) + { + if( ++ulWaitCounter > httpexampleMAX_WAIT_ITERATIONS ) + { + LogError( ( "Loop exceeded maximum wait time. Task completion error." ) ); + xStatus = pdFAIL; + break; + } + } + + return xStatus; +} diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/FreeRTOSConfig.h b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/FreeRTOSConfig.h new file mode 100644 index 0000000000..2f4d8e92a5 --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/FreeRTOSConfig.h @@ -0,0 +1,210 @@ +/* + * FreeRTOS V202011.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 + * + */ + +#ifndef FREERTOS_CONFIG_H +#define FREERTOS_CONFIG_H + +/*----------------------------------------------------------- +* Application specific definitions. +* +* These definitions should be adjusted for your particular hardware and +* application requirements. +* +* THESE PARAMETERS ARE DESCRIBED WITHIN THE 'CONFIGURATION' SECTION OF THE +* FreeRTOS API DOCUMENTATION AVAILABLE ON THE FreeRTOS.org WEB SITE. +* http://www.freertos.org/a00110.html +* +* The bottom of this file contains some constants specific to running the UDP +* stack in this demo. Constants specific to FreeRTOS+TCP itself (rather than +* the demo) are contained in FreeRTOSIPConfig.h. +*----------------------------------------------------------*/ +#define configUSE_PREEMPTION 1 +#define configUSE_PORT_OPTIMISED_TASK_SELECTION 1 +#define configMAX_PRIORITIES ( 7 ) +#define configTICK_RATE_HZ ( 1000 ) /* In this non-real time simulated environment the tick frequency has to be at least a multiple of the Win32 tick frequency, and therefore very slow. */ +#define configMINIMAL_STACK_SIZE ( ( unsigned short ) 60 ) /* In this simulated case, the stack only has to hold one small structure as the real stack is part of the Win32 thread. */ +#define configTOTAL_HEAP_SIZE ( ( size_t ) ( 2048U * 1024U ) ) +#define configMAX_TASK_NAME_LEN ( 15 ) +#define configUSE_TRACE_FACILITY 0 +#define configUSE_16_BIT_TICKS 0 +#define configIDLE_SHOULD_YIELD 1 +#define configUSE_CO_ROUTINES 0 +#define configUSE_MUTEXES 1 +#define configUSE_RECURSIVE_MUTEXES 1 +#define configQUEUE_REGISTRY_SIZE 0 +#define configUSE_APPLICATION_TASK_TAG 0 +#define configUSE_COUNTING_SEMAPHORES 1 +#define configUSE_ALTERNATIVE_API 0 +#define configNUM_THREAD_LOCAL_STORAGE_POINTERS 0 +#define configENABLE_BACKWARD_COMPATIBILITY 1 +#define configSUPPORT_STATIC_ALLOCATION 1 + +/* Hook function related definitions. */ +#define configUSE_TICK_HOOK 0 +#define configUSE_IDLE_HOOK 0 +#define configUSE_MALLOC_FAILED_HOOK 0 +#define configCHECK_FOR_STACK_OVERFLOW 0 /* Not applicable to the Win32 port. */ + +/* Software timer related definitions. */ +#define configUSE_TIMERS 1 +#define configTIMER_TASK_PRIORITY ( configMAX_PRIORITIES - 1 ) +#define configTIMER_QUEUE_LENGTH 5 +#define configTIMER_TASK_STACK_DEPTH ( configMINIMAL_STACK_SIZE * 2 ) + +/* Event group related definitions. */ +#define configUSE_EVENT_GROUPS 1 + +/* Run time stats gathering configuration options. */ +#define configGENERATE_RUN_TIME_STATS 0 + +/* Co-routine definitions. */ +#define configUSE_CO_ROUTINES 0 +#define configMAX_CO_ROUTINE_PRIORITIES ( 2 ) + +/* Set the following definitions to 1 to include the API function, or zero + * to exclude the API function. */ +#define INCLUDE_vTaskPrioritySet 1 +#define INCLUDE_uxTaskPriorityGet 1 +#define INCLUDE_vTaskDelete 1 +#define INCLUDE_vTaskCleanUpResources 0 +#define INCLUDE_vTaskSuspend 1 +#define INCLUDE_vTaskDelayUntil 1 +#define INCLUDE_vTaskDelay 1 +#define INCLUDE_uxTaskGetStackHighWaterMark 1 +#define INCLUDE_xTaskGetSchedulerState 1 +#define INCLUDE_xTimerGetTimerTaskHandle 0 +#define INCLUDE_xTaskGetIdleTaskHandle 0 +#define INCLUDE_xQueueGetMutexHolder 1 +#define INCLUDE_eTaskGetState 1 +#define INCLUDE_xEventGroupSetBitsFromISR 1 +#define INCLUDE_xTimerPendFunctionCall 1 +#define INCLUDE_pcTaskGetTaskName 1 + +/* This demo makes use of one or more example stats formatting functions. These + * format the raw data provided by the uxTaskGetSystemState() function in to human + * readable ASCII form. See the notes in the implementation of vTaskList() within + * FreeRTOS/Source/tasks.c for limitations. configUSE_STATS_FORMATTING_FUNCTIONS + * is set to 2 so the formatting functions are included without the stdio.h being + * included in tasks.c. That is because this project defines its own sprintf() + * functions. */ +#define configUSE_STATS_FORMATTING_FUNCTIONS 1 + +/* Assert call defined for debug builds. */ +#ifdef _DEBUG + extern void vAssertCalled( const char * pcFile, + uint32_t ulLine ); + #define configASSERT( x ) if( ( x ) == 0 ) vAssertCalled( __FILE__, __LINE__ ) +#endif /* _DEBUG */ + + + +/* Application specific definitions follow. **********************************/ + +/* Only used when running in the FreeRTOS Windows simulator. Defines the + * priority of the task used to simulate Ethernet interrupts. */ +#define configMAC_ISR_SIMULATOR_PRIORITY ( configMAX_PRIORITIES - 1 ) + +/* This demo creates a virtual network connection by accessing the raw Ethernet + * or WiFi data to and from a real network connection. Many computers have more + * than one real network port, and configNETWORK_INTERFACE_TO_USE is used to tell + * the demo which real port should be used to create the virtual port. The ports + * available are displayed on the console when the application is executed. For + * example, on my development laptop setting configNETWORK_INTERFACE_TO_USE to 4 + * results in the wired network being used, while setting + * configNETWORK_INTERFACE_TO_USE to 2 results in the wireless network being + * used. */ +#define configNETWORK_INTERFACE_TO_USE ( 0L ) + +/* The address to which logging is sent should UDP logging be enabled. */ +#define configUDP_LOGGING_ADDR0 192 +#define configUDP_LOGGING_ADDR1 168 +#define configUDP_LOGGING_ADDR2 0 +#define configUDP_LOGGING_ADDR3 11 + +/* Default MAC address configuration. The demo creates a virtual network + * connection that uses this MAC address by accessing the raw Ethernet/WiFi data + * to and from a real network connection on the host PC. See the + * configNETWORK_INTERFACE_TO_USE definition above for information on how to + * configure the real network connection to use. */ +#define configMAC_ADDR0 0x00 +#define configMAC_ADDR1 0x11 +#define configMAC_ADDR2 0x11 +#define configMAC_ADDR3 0x11 +#define configMAC_ADDR4 0x11 +#define configMAC_ADDR5 0x41 + +/* Default IP address configuration. Used in ipconfigUSE_DNS is set to 0, or + * ipconfigUSE_DNS is set to 1 but a DNS server cannot be contacted. */ +#define configIP_ADDR0 10 +#define configIP_ADDR1 10 +#define configIP_ADDR2 10 +#define configIP_ADDR3 200 + +/* Default gateway IP address configuration. Used in ipconfigUSE_DNS is set to + * 0, or ipconfigUSE_DNS is set to 1 but a DNS server cannot be contacted. */ +#define configGATEWAY_ADDR0 10 +#define configGATEWAY_ADDR1 10 +#define configGATEWAY_ADDR2 10 +#define configGATEWAY_ADDR3 1 + +/* Default DNS server configuration. OpenDNS addresses are 208.67.222.222 and + * 208.67.220.220. Used in ipconfigUSE_DNS is set to 0, or ipconfigUSE_DNS is set + * to 1 but a DNS server cannot be contacted.*/ +#define configDNS_SERVER_ADDR0 208 +#define configDNS_SERVER_ADDR1 67 +#define configDNS_SERVER_ADDR2 222 +#define configDNS_SERVER_ADDR3 222 + +/* Default netmask configuration. Used in ipconfigUSE_DNS is set to 0, or + * ipconfigUSE_DNS is set to 1 but a DNS server cannot be contacted. */ +#define configNET_MASK0 255 +#define configNET_MASK1 0 +#define configNET_MASK2 0 +#define configNET_MASK3 0 + +/* The UDP port to which print messages are sent. */ +#define configPRINT_PORT ( 15000 ) + + +#if ( defined( _MSC_VER ) && ( _MSC_VER <= 1600 ) && !defined( snprintf ) ) + /* Map to Windows names. */ + #define snprintf _snprintf + #define vsnprintf _vsnprintf +#endif + +/* Visual studio does not have an implementation of strcasecmp(). */ +#define strcasecmp _stricmp +#define strncasecmp _strnicmp +#define strcmpi _strcmpi + +/* Prototype for the function used to print out. In this case it prints to the + * console before the network is connected then a UDP port after the network has + * connected. */ +extern void vLoggingPrintf( const char * pcFormatString, + ... ); +#define configPRINTF( X ) vLoggingPrintf X + +#endif /* FREERTOS_CONFIG_H */ diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/FreeRTOSIPConfig.h b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/FreeRTOSIPConfig.h new file mode 100644 index 0000000000..ad24b2ff46 --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/FreeRTOSIPConfig.h @@ -0,0 +1,310 @@ +/* + * FreeRTOS V202011.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 + * + */ + + +/***************************************************************************** +* +* See the following URL for configuration information. +* http://www.freertos.org/FreeRTOS-Plus/FreeRTOS_Plus_TCP/TCP_IP_Configuration.html +* +*****************************************************************************/ + +#ifndef FREERTOS_IP_CONFIG_H +#define FREERTOS_IP_CONFIG_H + +/* Prototype for the function used to print out. In this case it prints to the + * console before the network is connected then a UDP port after the network has + * connected. */ +extern void vLoggingPrintf( const char * pcFormatString, + ... ); + +/* Set to 1 to print out debug messages. If ipconfigHAS_DEBUG_PRINTF is set to + * 1 then FreeRTOS_debug_printf should be defined to the function used to print + * out the debugging messages. */ +#define ipconfigHAS_DEBUG_PRINTF 0 +#if ( ipconfigHAS_DEBUG_PRINTF == 1 ) + #define FreeRTOS_debug_printf( X ) vLoggingPrintf X +#endif + +/* Set to 1 to print out non debugging messages, for example the output of the + * FreeRTOS_netstat() command, and ping replies. If ipconfigHAS_PRINTF is set to 1 + * then FreeRTOS_printf should be set to the function used to print out the + * messages. */ +#define ipconfigHAS_PRINTF 1 +#if ( ipconfigHAS_PRINTF == 1 ) + #define FreeRTOS_printf( X ) vLoggingPrintf X +#endif + +/* Define the byte order of the target MCU (the MCU FreeRTOS+TCP is executing + * on). Valid options are pdFREERTOS_BIG_ENDIAN and pdFREERTOS_LITTLE_ENDIAN. */ +#define ipconfigBYTE_ORDER pdFREERTOS_LITTLE_ENDIAN + +/* If the network card/driver includes checksum offloading (IP/TCP/UDP checksums) + * then set ipconfigDRIVER_INCLUDED_RX_IP_CHECKSUM to 1 to prevent the software + * stack repeating the checksum calculations. */ +#define ipconfigDRIVER_INCLUDED_RX_IP_CHECKSUM 1 + +/* Several API's will block until the result is known, or the action has been + * performed, for example FreeRTOS_send() and FreeRTOS_recv(). The timeouts can be + * set per socket, using setsockopt(). If not set, the times below will be + * used as defaults. */ +#define ipconfigSOCK_DEFAULT_RECEIVE_BLOCK_TIME ( 2000 ) +#define ipconfigSOCK_DEFAULT_SEND_BLOCK_TIME ( 5000 ) + +/* Include support for LLMNR: Link-local Multicast Name Resolution + * (non-Microsoft) */ +#define ipconfigUSE_LLMNR ( 0 ) + +/* Include support for NBNS: NetBIOS Name Service (Microsoft) */ +#define ipconfigUSE_NBNS ( 0 ) + +/* Include support for DNS caching. For TCP, having a small DNS cache is very + * useful. When a cache is present, ipconfigDNS_REQUEST_ATTEMPTS can be kept low + * and also DNS may use small timeouts. If a DNS reply comes in after the DNS + * socket has been destroyed, the result will be stored into the cache. The next + * call to FreeRTOS_gethostbyname() will return immediately, without even creating + * a socket. */ +#define ipconfigUSE_DNS_CACHE ( 1 ) +#define ipconfigDNS_CACHE_NAME_LENGTH ( 64 ) +#define ipconfigDNS_CACHE_ENTRIES ( 4 ) +#define ipconfigDNS_REQUEST_ATTEMPTS ( 2 ) + +/* The IP stack executes it its own task (although any application task can make + * use of its services through the published sockets API). ipconfigUDP_TASK_PRIORITY + * sets the priority of the task that executes the IP stack. The priority is a + * standard FreeRTOS task priority so can take any value from 0 (the lowest + * priority) to (configMAX_PRIORITIES - 1) (the highest priority). + * configMAX_PRIORITIES is a standard FreeRTOS configuration parameter defined in + * FreeRTOSConfig.h, not FreeRTOSIPConfig.h. Consideration needs to be given as to + * the priority assigned to the task executing the IP stack relative to the + * priority assigned to tasks that use the IP stack. */ +#define ipconfigIP_TASK_PRIORITY ( configMAX_PRIORITIES - 2 ) + +/* The size, in words (not bytes), of the stack allocated to the FreeRTOS+TCP + * task. This setting is less important when the FreeRTOS Win32 simulator is used + * as the Win32 simulator only stores a fixed amount of information on the task + * stack. FreeRTOS includes optional stack overflow detection, see: + * http://www.freertos.org/Stacks-and-stack-overflow-checking.html */ +#define ipconfigIP_TASK_STACK_SIZE_WORDS ( configMINIMAL_STACK_SIZE * 5 ) + +/* ipconfigRAND32() is called by the IP stack to generate random numbers for + * things such as a DHCP transaction number or initial sequence number. Random + * number generation is performed via this macro to allow applications to use their + * own random number generation method. For example, it might be possible to + * generate a random number by sampling noise on an analogue input. */ +extern UBaseType_t uxRand(); +#define ipconfigRAND32() uxRand() + +/* If ipconfigUSE_NETWORK_EVENT_HOOK is set to 1 then FreeRTOS+TCP will call the + * network event hook at the appropriate times. If ipconfigUSE_NETWORK_EVENT_HOOK + * is not set to 1 then the network event hook will never be called. See + * http://www.FreeRTOS.org/FreeRTOS-Plus/FreeRTOS_Plus_UDP/API/vApplicationIPNetworkEventHook.shtml + */ +#define ipconfigUSE_NETWORK_EVENT_HOOK 1 + +/* Sockets have a send block time attribute. If FreeRTOS_sendto() is called but + * a network buffer cannot be obtained then the calling task is held in the Blocked + * state (so other tasks can continue to executed) until either a network buffer + * becomes available or the send block time expires. If the send block time expires + * then the send operation is aborted. The maximum allowable send block time is + * capped to the value set by ipconfigMAX_SEND_BLOCK_TIME_TICKS. Capping the + * maximum allowable send block time prevents prevents a deadlock occurring when + * all the network buffers are in use and the tasks that process (and subsequently + * free) the network buffers are themselves blocked waiting for a network buffer. + * ipconfigMAX_SEND_BLOCK_TIME_TICKS is specified in RTOS ticks. A time in + * milliseconds can be converted to a time in ticks by dividing the time in + * milliseconds by portTICK_PERIOD_MS. */ +#define ipconfigUDP_MAX_SEND_BLOCK_TIME_TICKS ( 5000 / portTICK_PERIOD_MS ) + +/* If ipconfigUSE_DHCP is 1 then FreeRTOS+TCP will attempt to retrieve an IP + * address, netmask, DNS server address and gateway address from a DHCP server. If + * ipconfigUSE_DHCP is 0 then FreeRTOS+TCP will use a static IP address. The + * stack will revert to using the static IP address even when ipconfigUSE_DHCP is + * set to 1 if a valid configuration cannot be obtained from a DHCP server for any + * reason. The static configuration used is that passed into the stack by the + * FreeRTOS_IPInit() function call. */ +#define ipconfigUSE_DHCP 1 + +/* When ipconfigUSE_DHCP is set to 1, DHCP requests will be sent out at + * increasing time intervals until either a reply is received from a DHCP server + * and accepted, or the interval between transmissions reaches + * ipconfigMAXIMUM_DISCOVER_TX_PERIOD. The IP stack will revert to using the + * static IP address passed as a parameter to FreeRTOS_IPInit() if the + * re-transmission time interval reaches ipconfigMAXIMUM_DISCOVER_TX_PERIOD without + * a DHCP reply being received. */ +#define ipconfigMAXIMUM_DISCOVER_TX_PERIOD ( 120000 / portTICK_PERIOD_MS ) + +/* The ARP cache is a table that maps IP addresses to MAC addresses. The IP + * stack can only send a UDP message to a remove IP address if it knowns the MAC + * address associated with the IP address, or the MAC address of the router used to + * contact the remote IP address. When a UDP message is received from a remote IP + * address the MAC address and IP address are added to the ARP cache. When a UDP + * message is sent to a remote IP address that does not already appear in the ARP + * cache then the UDP message is replaced by a ARP message that solicits the + * required MAC address information. ipconfigARP_CACHE_ENTRIES defines the maximum + * number of entries that can exist in the ARP table at any one time. */ +#define ipconfigARP_CACHE_ENTRIES 6 + +/* ARP requests that do not result in an ARP response will be re-transmitted a + * maximum of ipconfigMAX_ARP_RETRANSMISSIONS times before the ARP request is + * aborted. */ +#define ipconfigMAX_ARP_RETRANSMISSIONS ( 5 ) + +/* ipconfigMAX_ARP_AGE defines the maximum time between an entry in the ARP + * table being created or refreshed and the entry being removed because it is stale. + * New ARP requests are sent for ARP cache entries that are nearing their maximum + * age. ipconfigMAX_ARP_AGE is specified in tens of seconds, so a value of 150 is + * equal to 1500 seconds (or 25 minutes). */ +#define ipconfigMAX_ARP_AGE 150 + +/* Implementing FreeRTOS_inet_addr() necessitates the use of string handling + * routines, which are relatively large. To save code space the full + * FreeRTOS_inet_addr() implementation is made optional, and a smaller and faster + * alternative called FreeRTOS_inet_addr_quick() is provided. FreeRTOS_inet_addr() + * takes an IP in decimal dot format (for example, "192.168.0.1") as its parameter. + * FreeRTOS_inet_addr_quick() takes an IP address as four separate numerical octets + * (for example, 192, 168, 0, 1) as its parameters. If + * ipconfigINCLUDE_FULL_INET_ADDR is set to 1 then both FreeRTOS_inet_addr() and + * FreeRTOS_indet_addr_quick() are available. If ipconfigINCLUDE_FULL_INET_ADDR is + * not set to 1 then only FreeRTOS_indet_addr_quick() is available. */ +#define ipconfigINCLUDE_FULL_INET_ADDR 1 + +/* ipconfigNUM_NETWORK_BUFFER_DESCRIPTORS defines the total number of network buffer that + * are available to the IP stack. The total number of network buffers is limited + * to ensure the total amount of RAM that can be consumed by the IP stack is capped + * to a pre-determinable value. */ +#define ipconfigNUM_NETWORK_BUFFER_DESCRIPTORS 60 + +/* A FreeRTOS queue is used to send events from application tasks to the IP + * stack. ipconfigEVENT_QUEUE_LENGTH sets the maximum number of events that can + * be queued for processing at any one time. The event queue must be a minimum of + * 5 greater than the total number of network buffers. */ +#define ipconfigEVENT_QUEUE_LENGTH ( ipconfigNUM_NETWORK_BUFFER_DESCRIPTORS + 5 ) + +/* The address of a socket is the combination of its IP address and its port + * number. FreeRTOS_bind() is used to manually allocate a port number to a socket + * (to 'bind' the socket to a port), but manual binding is not normally necessary + * for client sockets (those sockets that initiate outgoing connections rather than + * wait for incoming connections on a known port number). If + * ipconfigALLOW_SOCKET_SEND_WITHOUT_BIND is set to 1 then calling + * FreeRTOS_sendto() on a socket that has not yet been bound will result in the IP + * stack automatically binding the socket to a port number from the range + * socketAUTO_PORT_ALLOCATION_START_NUMBER to 0xffff. If + * ipconfigALLOW_SOCKET_SEND_WITHOUT_BIND is set to 0 then calling FreeRTOS_sendto() + * on a socket that has not yet been bound will result in the send operation being + * aborted. */ +#define ipconfigALLOW_SOCKET_SEND_WITHOUT_BIND 1 + +/* Defines the Time To Live (TTL) values used in outgoing UDP packets. */ +#define ipconfigUDP_TIME_TO_LIVE 128 +#define ipconfigTCP_TIME_TO_LIVE 128 /* also defined in FreeRTOSIPConfigDefaults.h */ + +/* USE_TCP: Use TCP and all its features */ +#define ipconfigUSE_TCP ( 1 ) + +/* Use the TCP socket wake context with a callback. */ +#define ipconfigSOCKET_HAS_USER_WAKE_CALLBACK_WITH_CONTEXT ( 1 ) + +/* USE_WIN: Let TCP use windowing mechanism. */ +#define ipconfigUSE_TCP_WIN ( 1 ) + +/* The MTU is the maximum number of bytes the payload of a network frame can + * contain. For normal Ethernet V2 frames the maximum MTU is 1500. Setting a + * lower value can save RAM, depending on the buffer management scheme used. If + * ipconfigCAN_FRAGMENT_OUTGOING_PACKETS is 1 then (ipconfigNETWORK_MTU - 28) must + * be divisible by 8. */ +#define ipconfigNETWORK_MTU 1200 + +/* Set ipconfigUSE_DNS to 1 to include a basic DNS client/resolver. DNS is used + * through the FreeRTOS_gethostbyname() API function. */ +#define ipconfigUSE_DNS 1 + +/* If ipconfigREPLY_TO_INCOMING_PINGS is set to 1 then the IP stack will + * generate replies to incoming ICMP echo (ping) requests. */ +#define ipconfigREPLY_TO_INCOMING_PINGS 1 + +/* If ipconfigSUPPORT_OUTGOING_PINGS is set to 1 then the + * FreeRTOS_SendPingRequest() API function is available. */ +#define ipconfigSUPPORT_OUTGOING_PINGS 0 + +/* If ipconfigSUPPORT_SELECT_FUNCTION is set to 1 then the FreeRTOS_select() + * (and associated) API function is available. */ +#define ipconfigSUPPORT_SELECT_FUNCTION 1 + +/* If ipconfigFILTER_OUT_NON_ETHERNET_II_FRAMES is set to 1 then Ethernet frames + * that are not in Ethernet II format will be dropped. This option is included for + * potential future IP stack developments. */ +#define ipconfigFILTER_OUT_NON_ETHERNET_II_FRAMES 1 + +/* If ipconfigETHERNET_DRIVER_FILTERS_FRAME_TYPES is set to 1 then it is the + * responsibility of the Ethernet interface to filter out packets that are of no + * interest. If the Ethernet interface does not implement this functionality, then + * set ipconfigETHERNET_DRIVER_FILTERS_FRAME_TYPES to 0 to have the IP stack + * perform the filtering instead (it is much less efficient for the stack to do it + * because the packet will already have been passed into the stack). If the + * Ethernet driver does all the necessary filtering in hardware then software + * filtering can be removed by using a value other than 1 or 0. */ +#define ipconfigETHERNET_DRIVER_FILTERS_FRAME_TYPES 1 + +/* The windows simulator cannot really simulate MAC interrupts, and needs to + * block occasionally to allow other tasks to run. */ +#define configWINDOWS_MAC_INTERRUPT_SIMULATOR_DELAY ( 20 / portTICK_PERIOD_MS ) + +/* Advanced only: in order to access 32-bit fields in the IP packets with + * 32-bit memory instructions, all packets will be stored 32-bit-aligned, plus 16-bits. + * This has to do with the contents of the IP-packets: all 32-bit fields are + * 32-bit-aligned, plus 16-bit(!) */ +#define ipconfigPACKET_FILLER_SIZE 2 + +/* Define the size of the pool of TCP window descriptors. On the average, each + * TCP socket will use up to 2 x 6 descriptors, meaning that it can have 2 x 6 + * outstanding packets (for Rx and Tx). When using up to 10 TP sockets + * simultaneously, one could define TCP_WIN_SEG_COUNT as 120. */ +#define ipconfigTCP_WIN_SEG_COUNT 240 + +/* Each TCP socket has a circular buffers for Rx and Tx, which have a fixed + * maximum size. Define the size of Rx buffer for TCP sockets. */ +#define ipconfigTCP_RX_BUFFER_LENGTH ( 1000 ) + +/* Define the size of Tx buffer for TCP sockets. */ +#define ipconfigTCP_TX_BUFFER_LENGTH ( 1000 ) + +/* When using call-back handlers, the driver may check if the handler points to + * real program memory (RAM or flash) or just has a random non-zero value. */ +#define ipconfigIS_VALID_PROG_ADDRESS( x ) ( ( x ) != NULL ) + +/* Include support for TCP hang protection. All sockets in a connecting or + * disconnecting stage will timeout after a period of non-activity. */ +#define ipconfigTCP_HANG_PROTECTION ( 1 ) +#define ipconfigTCP_HANG_PROTECTION_TIME ( 30 ) + +/* Include support for TCP keep-alive messages. */ +#define ipconfigTCP_KEEP_ALIVE ( 1 ) +#define ipconfigTCP_KEEP_ALIVE_INTERVAL ( 20 ) /* in seconds */ + +#define portINLINE __inline + +#endif /* FREERTOS_IP_CONFIG_H */ diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/WIN32.vcxproj b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/WIN32.vcxproj new file mode 100644 index 0000000000..bda001ca6c --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/WIN32.vcxproj @@ -0,0 +1,614 @@ + + + + + Debug + Win32 + + + Release + Win32 + + + + {C686325E-3261-42F7-AEB1-DDE5280E1CEB} + RTOSDemo + 10.0.19041.0 + + + + Application + false + MultiByte + v142 + + + Application + false + MultiByte + v142 + + + + + + + + + + + + + + + <_ProjectFileVersion>10.0.30319.1 + .\Debug\ + .\Debug\ + true + .\Release\ + .\Release\ + false + AllRules.ruleset + + + + .\Debug/WIN32.tlb + + + + + Disabled + ..\..\..\..\Source\FreeRTOS-Plus-Trace\Include;..\..\..\..\FreeRTOS-Plus\Source\FreeRTOS-Plus-TCP\include;..\..\..\..\FreeRTOS-Plus\Source\FreeRTOS-Plus-TCP\portable\BufferManagement;..\..\..\..\FreeRTOS-Plus\Source\FreeRTOS-Plus-TCP\portable\Compiler\MSVC;..\..\..\..\FreeRTOS-Plus\Source\Utilities\logging;..\..\Common\WinPCap;..\..\..\..\FreeRTOS\Source\include;..\..\..\..\FreeRTOS\Source\portable\MSVC-MingW;..\..\..\Source\Application-Protocols\coreMQTT\source\include;..\..\..\Source\Application-Protocols\coreMQTT\source\interface;..\..\..\Source\Application-Protocols\coreHTTP\source\include;..\..\..\Source\Application-Protocols\coreHTTP\source\interface;..\..\..\Source\Application-Protocols\coreHTTP\source\dependency\3rdparty\http_parser;..\..\..\Source\Utilities\backoff_algorithm\source\include;..\..\..\Source\Application-Protocols\network_transport\freertos_plus_tcp;..\..\..\Source\Application-Protocols\network_transport\freertos_plus_tcp\using_mbedtls;..\..\..\Source\Utilities\mbedtls_freertos;..\..\..\..\Source\mbedtls_utils;..\..\..\ThirdParty\mbedtls\include;..\Common;.;%(AdditionalIncludeDirectories) + MBEDTLS_CONFIG_FILE="mbedtls_config.h";WIN32;_DEBUG;_CONSOLE;_WIN32_WINNT=0x0500;WINVER=0x400;_CRT_SECURE_NO_WARNINGS;%(PreprocessorDefinitions) + false + EnableFastChecks + MultiThreadedDLL + .\Debug/WIN32.pch + .\Debug/ + .\Debug/ + .\Debug/ + Level4 + true + false + EditAndContinue + /wd4210 /wd4127 /wd4214 /wd4201 /wd4244 /wd4310 /wd4200 %(AdditionalOptions) + true + NotUsing + false + CompileAsC + + + _DEBUG;%(PreprocessorDefinitions) + 0x0c09 + + + .\Debug/RTOSDemo.exe + true + true + .\Debug/WIN32.pdb + Console + MachineX86 + wpcap.lib;Bcrypt.lib;%(AdditionalDependencies) + ..\..\Common\WinPCap + false + false + + + true + .\Debug/WIN32.bsc + + + + + .\Release/WIN32.tlb + + + + + MaxSpeed + OnlyExplicitInline + _WINSOCKAPI_;WIN32;NDEBUG;_CONSOLE;_CRT_SECURE_NO_WARNINGS;%(PreprocessorDefinitions) + true + MultiThreaded + true + .\Release/WIN32.pch + .\Release/ + .\Release/ + .\Release/ + Level3 + true + ..\Common\Utils;..\Common\ethernet\lwip-1.4.0\ports\win32\WinPCap;..\Common\ethernet\lwip-1.4.0\src\include\ipv4;..\Common\ethernet\lwip-1.4.0\src\include;..\..\..\Source\include;..\..\..\Source\portable\MSVC-MingW;..\Common\ethernet\lwip-1.4.0\ports\win32\include;..\Common\Include;.\lwIP_Apps;.;%(AdditionalIncludeDirectories) + + + NDEBUG;%(PreprocessorDefinitions) + 0x0c09 + + + .\Release/RTOSDemo.exe + true + .\Release/WIN32.pdb + Console + MachineX86 + ..\Common\ethernet\lwip-1.4.0\ports\win32\WinPCap + wpcap.lib;Bcrypt.lib;%(AdditionalDependencies) + + + true + .\Release/WIN32.bsc + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + TurnOffAllWarnings + TurnOffAllWarnings + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/WIN32.vcxproj.filters b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/WIN32.vcxproj.filters new file mode 100644 index 0000000000..8df8423120 --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/WIN32.vcxproj.filters @@ -0,0 +1,732 @@ + + + + + {af3445a1-4908-4170-89ed-39345d90d30c} + + + {f32be356-4763-4cae-9020-974a2638cb08} + *.c + + + {88f409e6-d396-4ac5-94bd-7a99c914be46} + + + {e5ad4ec7-23dc-4295-8add-2acaee488f5a} + + + {d2dcd641-8d91-492b-852f-5563ffadaec6} + + + {8672fa26-b119-481f-8b8d-086419c01a3e} + + + {4570be11-ec96-4b55-ac58-24b50ada980a} + + + {5d93ed51-023a-41ad-9243-8d230165d34b} + + + {b71e974a-9f28-4815-972b-d930ba8a34d0} + + + {60717407-397f-4ea5-8492-3314acdd25f0} + + + {8a90222f-d723-4b4e-8e6e-c57afaf7fa92} + + + {2d17d5e6-ed70-4e42-9693-f7a63baf4948} + + + {7158b0be-01e7-42d1-8d3f-c75118a596a2} + + + {6ad56e6d-c330-4830-8f4b-c75b05dfa866} + + + {84613aa2-91dc-4e1a-a3b3-823b6d7bf0e0} + + + {7bedd2e3-adbb-4c95-9632-445132b459ce} + + + {07a14673-4d02-4780-a099-6b8c654dff91} + + + {e875c5e3-40a2-4408-941e-5e1a951cc663} + + + {fcf93295-15e2-4a84-a5e9-b3c162e9f061} + + + {8a0aa896-6b3a-49b3-997e-681f0d1949ae} + + + {c5a01679-3e7a-4320-97ac-ee5b872c1650} + + + {c992824d-4198-46b2-8d59-5f99ab9946ab} + + + {6a35782c-bc09-42d5-a850-98bcb668a4dc} + + + + + FreeRTOS\Source\Portable + + + FreeRTOS\Source + + + FreeRTOS\Source + + + FreeRTOS\Source + + + FreeRTOS\Source + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP\portable + + + FreeRTOS+\FreeRTOS+TCP\portable + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS\Source + + + FreeRTOS\Source\Portable + + + FreeRTOS+\FreeRTOS+TCP + + + FreeRTOS\Source + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + FreeRTOS+\mbedtls\library + + + + + DemoTasks + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\mbedtls + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\mbedtls + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\freertos + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\transport + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\transport + + + + + + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS+\FreeRTOS+TCP\include + + + + + FreeRTOS+\FreeRTOS+TCP\include + + + FreeRTOS\Source\include + + + FreeRTOS\Source\include + + + + + FreeRTOS+\FreeRTOS IoT Libraries\platform + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + FreeRTOS+\mbedtls\include + + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\mbedtls + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\mbedtls + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\transport\include + + + FreeRTOS+\FreeRTOS IoT Libraries\platform\transport\include + + + + + + + \ No newline at end of file diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/core_http_config.h b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/core_http_config.h new file mode 100644 index 0000000000..c5265b2e52 --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/core_http_config.h @@ -0,0 +1,69 @@ +/* + * FreeRTOS V202011.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 + * + */ + +#ifndef CORE_HTTP_CONFIG_H_ +#define CORE_HTTP_CONFIG_H_ + +/**************************************************/ +/******* DO NOT CHANGE the following order ********/ +/**************************************************/ + +/* Logging config definition and header files inclusion are required in the following order: + * 1. Include the header file "logging_levels.h". + * 2. Define the LIBRARY_LOG_NAME and LIBRARY_LOG_LEVEL macros depending on + * the logging configuration for HTTP. + * 3. Include the header file "logging_stack.h", if logging is enabled for HTTP. + */ + +#include "logging_levels.h" + +/* Logging configuration for the HTTP library. */ +#ifndef LIBRARY_LOG_NAME + #define LIBRARY_LOG_NAME "HTTP" +#endif + +#ifndef LIBRARY_LOG_LEVEL + #define LIBRARY_LOG_LEVEL LOG_INFO +#endif + +/* Prototype for the function used to print to console on Windows simulator + * of FreeRTOS. + * The function prints to the console before the network is connected; + * then a UDP port after the network has connected. */ +extern void vLoggingPrintf( const char * pcFormatString, + ... ); + +/* Map the SdkLog macro to the logging function to enable logging + * on Windows simulator. */ +#ifndef SdkLog + #define SdkLog( message ) vLoggingPrintf message +#endif +#include "logging_stack.h" + + +/************ End of logging configuration ****************/ + +#endif /* ifndef CORE_HTTP_CONFIG_H_ */ diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/demo_config.h b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/demo_config.h new file mode 100644 index 0000000000..88ac2820ac --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/demo_config.h @@ -0,0 +1,153 @@ +/* + * FreeRTOS V202011.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 + * + */ + +#ifndef DEMO_CONFIG_H +#define DEMO_CONFIG_H + +/**************************************************/ +/******* DO NOT CHANGE the following order ********/ +/**************************************************/ + +/* Include logging header files and define logging macros in the following order: + * 1. Include the header file "logging_levels.h". + * 2. Define the LIBRARY_LOG_NAME and LIBRARY_LOG_LEVEL macros depending on + * the logging configuration for DEMO. + * 3. Include the header file "logging_stack.h", if logging is enabled for DEMO. + */ + +/* Include header that defines log levels. */ +#include "logging_levels.h" + +/* Logging configuration for the demo. */ +#ifndef LIBRARY_LOG_NAME + #define LIBRARY_LOG_NAME "HTTPDemo" +#endif + +#ifndef LIBRARY_LOG_LEVEL + #define LIBRARY_LOG_LEVEL LOG_INFO +#endif + +/* Prototype for the function used to print to console on Windows simulator + * of FreeRTOS. + * The function prints to the console before the network is connected; + * then a UDP port after the network has connected. */ +extern void vLoggingPrintf( const char * pcFormatString, + ... ); + +/* Map the SdkLog macro to the logging function to enable logging + * on Windows simulator. */ +#ifndef SdkLog + #define SdkLog( message ) vLoggingPrintf message +#endif + +#include "logging_stack.h" + +/************ End of logging configuration ****************/ + +/** + * @brief HTTP server port number. + * + * In general, port 443 is for TLS HTTP connections. + */ +#ifndef democonfigHTTPS_PORT + #define democonfigHTTPS_PORT 443 +#endif + +/** + * @brief Server's root CA certificate for TLS authentication with S3. + * + * The Baltimore Cybertrust Root CA Certificate should be pasted below using the + * following format: + * + * @note This certificate should be PEM-encoded. + * + * Must include the PEM header and footer: + * "-----BEGIN CERTIFICATE-----\n"\ + * "...base64 data...\n"\ + * "-----END CERTIFICATE-----\n" + * + * #define democonfigROOT_CA_PEM "...insert here..." + */ + +/** + * @brief The pre-signed GET URL generated by the python script located in + * FreeRTOS-Plus\Demo\coreHTTP_Windows_Simulator\Common\presigned_url_generator\presigned_urls_gen.py + * + * @note This script requires AWS CLI to be configured. For instructions, see + * https://docs.aws.amazon.com/cli/latest/userguide/cli-chap-configure.html + * + * Run this script and paste the output democonfigS3_PRESIGNED_GET_URL below. + * + * #define democonfigS3_PRESIGNED_GET_URL "...insert here..." + */ + +/** + * @brief An option to disable Server Name Indication. + * + * @note When using a local server setup, SNI needs to be disabled for a server + * that only has an IP address but no hostname. However, SNI should be enabled + * whenever possible. + */ +#define democonfigDISABLE_SNI ( pdFALSE ) + +/** + * @brief Transport timeout in milliseconds for transport send and receive. + */ +#define democonfigTRANSPORT_SEND_RECV_TIMEOUT_MS ( 5000 ) + +/** + * @brief The length in bytes of the user buffer. + * + * @note A portion of the user buffer will be used to store the response header, + * so the length of the response body returned on any given range request will + * be less than democonfigUSER_BUFFER_LENGTH. We don't expect S3 to send more + * than 1024 bytes of headers. + */ +#define democonfigUSER_BUFFER_LENGTH ( 2048 ) + +/** + * @brief The size of the range of the file to download, with each request. + * + * @note This should account for the response headers that will also be stored + * in the user buffer. We don't expect S3 to send more than 1024 bytes of + * headers. + */ +#define democonfigRANGE_REQUEST_LENGTH ( 1024 ) + +/** + * @brief The number of items that can be held in each queue. + */ +#define democonfigQUEUE_SIZE ( 10 ) + +/** + * @brief Set the stack size of the main demo task. + * + * In the Windows port, this stack only holds a structure. The actual + * stack is created by an operating system thread. + */ +#define democonfigDEMO_STACKSIZE configMINIMAL_STACK_SIZE + +#endif /* ifndef DEMO_CONFIG_H */ diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/http_s3_download_multithreaded_demo.sln b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/http_s3_download_multithreaded_demo.sln new file mode 100644 index 0000000000..dcfc1fe098 --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/http_s3_download_multithreaded_demo.sln @@ -0,0 +1,25 @@ + +Microsoft Visual Studio Solution File, Format Version 12.00 +# Visual Studio Version 16 +VisualStudioVersion = 16.0.29215.179 +MinimumVisualStudioVersion = 10.0.40219.1 +Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "RTOSDemo", "WIN32.vcxproj", "{C686325E-3261-42F7-AEB1-DDE5280E1CEB}" +EndProject +Global + GlobalSection(SolutionConfigurationPlatforms) = preSolution + Debug|Win32 = Debug|Win32 + EndGlobalSection + GlobalSection(ProjectConfigurationPlatforms) = postSolution + {C686325E-3261-42F7-AEB1-DDE5280E1CEB}.Debug|Win32.ActiveCfg = Debug|Win32 + {C686325E-3261-42F7-AEB1-DDE5280E1CEB}.Debug|Win32.Build.0 = Debug|Win32 + EndGlobalSection + GlobalSection(SolutionProperties) = preSolution + HideSolutionNode = FALSE + EndGlobalSection + GlobalSection(ExtensibilityGlobals) = postSolution + SolutionGuid = {150F08BF-9D61-4CC2-8DBF-1335172A1EA4} + EndGlobalSection + GlobalSection(TestCaseManagementSettings) = postSolution + CategoryFile = FreeRTOS_Plus_TCP_Minimal.vsmdi + EndGlobalSection +EndGlobal diff --git a/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/mbedtls_config.h b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/mbedtls_config.h new file mode 100644 index 0000000000..f25171ff7c --- /dev/null +++ b/FreeRTOS-Plus/Demo/coreHTTP_Windows_Simulator/HTTP_S3_Download_Multithreaded/mbedtls_config.h @@ -0,0 +1,131 @@ +/* + * FreeRTOS V202011.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 + * + */ + +/* This file configures mbed TLS for FreeRTOS. */ + +#ifndef MBEDTLS_CONFIG_H_ +#define MBEDTLS_CONFIG_H_ + +/* FreeRTOS include. */ +#include "FreeRTOS.h" + +/* Generate errors if deprecated functions are used. */ +#define MBEDTLS_DEPRECATED_REMOVED + +/* Place AES tables in ROM. */ +#define MBEDTLS_AES_ROM_TABLES + +/* Enable the following cipher modes. */ +#define MBEDTLS_CIPHER_MODE_CBC +#define MBEDTLS_CIPHER_MODE_CFB +#define MBEDTLS_CIPHER_MODE_CTR + +/* Enable the following cipher padding modes. */ +#define MBEDTLS_CIPHER_PADDING_PKCS7 +#define MBEDTLS_CIPHER_PADDING_ONE_AND_ZEROS +#define MBEDTLS_CIPHER_PADDING_ZEROS_AND_LEN +#define MBEDTLS_CIPHER_PADDING_ZEROS + +/* Cipher suite configuration. */ +#define MBEDTLS_REMOVE_ARC4_CIPHERSUITES +#define MBEDTLS_ECP_DP_SECP256R1_ENABLED +#define MBEDTLS_ECP_NIST_OPTIM +#define MBEDTLS_KEY_EXCHANGE_ECDHE_RSA_ENABLED +#define MBEDTLS_KEY_EXCHANGE_ECDHE_ECDSA_ENABLED + +/* Enable all SSL alert messages. */ +#define MBEDTLS_SSL_ALL_ALERT_MESSAGES + +/* Enable the following SSL features. */ +#define MBEDTLS_SSL_ENCRYPT_THEN_MAC +#define MBEDTLS_SSL_EXTENDED_MASTER_SECRET +#define MBEDTLS_SSL_MAX_FRAGMENT_LENGTH +#define MBEDTLS_SSL_PROTO_TLS1_2 +#define MBEDTLS_SSL_ALPN +#define MBEDTLS_SSL_SERVER_NAME_INDICATION + +/* Check certificate key usage. */ +#define MBEDTLS_X509_CHECK_KEY_USAGE +#define MBEDTLS_X509_CHECK_EXTENDED_KEY_USAGE + +/* Disable platform entropy functions. */ +#define MBEDTLS_NO_PLATFORM_ENTROPY + +/* Enable the following mbed TLS features. */ +#define MBEDTLS_AES_C +#define MBEDTLS_ASN1_PARSE_C +#define MBEDTLS_ASN1_WRITE_C +#define MBEDTLS_BASE64_C +#define MBEDTLS_BIGNUM_C +#define MBEDTLS_CIPHER_C +#define MBEDTLS_CTR_DRBG_C +#define MBEDTLS_ECDH_C +#define MBEDTLS_ECDSA_C +#define MBEDTLS_ECP_C +#define MBEDTLS_ENTROPY_C +#define MBEDTLS_GCM_C +#define MBEDTLS_MD_C +#define MBEDTLS_OID_C +#define MBEDTLS_PEM_PARSE_C +#define MBEDTLS_PK_C +#define MBEDTLS_PK_PARSE_C +#define MBEDTLS_PKCS1_V15 +#define MBEDTLS_PLATFORM_C +#define MBEDTLS_RSA_C +#define MBEDTLS_SHA1_C +#define MBEDTLS_SHA256_C +#define MBEDTLS_SSL_CLI_C +#define MBEDTLS_SSL_TLS_C +#define MBEDTLS_THREADING_ALT +#define MBEDTLS_THREADING_C +#define MBEDTLS_X509_USE_C +#define MBEDTLS_X509_CRT_PARSE_C + +/* Set the memory allocation functions on FreeRTOS. */ +void * mbedtls_platform_calloc( size_t nmemb, + size_t size ); +void mbedtls_platform_free( void * ptr ); +#define MBEDTLS_PLATFORM_MEMORY +#define MBEDTLS_PLATFORM_CALLOC_MACRO mbedtls_platform_calloc +#define MBEDTLS_PLATFORM_FREE_MACRO mbedtls_platform_free + +/* The network send and receive functions on FreeRTOS. */ +int mbedtls_platform_send( void * ctx, + const unsigned char * buf, + size_t len ); +int mbedtls_platform_recv( void * ctx, + unsigned char * buf, + size_t len ); + +/* The entropy poll function. */ +int mbedtls_platform_entropy_poll( void * data, + unsigned char * output, + size_t len, + size_t * olen ); + +#include "mbedtls/check_config.h" + +#endif /* ifndef MBEDTLS_CONFIG_H_ */