/* | |
* FreeRTOS Kernel V10.0.1 | |
* Copyright (C) 2017 Amazon.com, Inc. or its affiliates. All Rights Reserved. | |
* | |
* Permission is hereby granted, free of charge, to any person obtaining a copy of | |
* this software and associated documentation files (the "Software"), to deal in | |
* the Software without restriction, including without limitation the rights to | |
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of | |
* the Software, and to permit persons to whom the Software is furnished to do so, | |
* subject to the following conditions: | |
* | |
* The above copyright notice and this permission notice shall be included in all | |
* copies or substantial portions of the Software. | |
* | |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS | |
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR | |
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER | |
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN | |
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | |
* | |
* http://www.FreeRTOS.org | |
* http://aws.amazon.com/freertos | |
* | |
* 1 tab == 4 spaces! | |
*/ | |
/* Standard includes. */ | |
#include <string.h> | |
/* Scheduler includes. */ | |
#include "FreeRTOS.h" | |
#include "task.h" | |
#include "queue.h" | |
#include "timers.h" | |
/* uip includes. */ | |
#include "net/uip.h" | |
#include "net/uip_arp.h" | |
#include "apps/httpd/httpd.h" | |
#include "sys/timer.h" | |
#include "net/clock-arch.h" | |
/* Demo includes. */ | |
#include "ParTest.h" | |
/* Hardware driver includes. */ | |
#include "mss_ethernet_mac_regs.h" | |
#include "mss_ethernet_mac.h" | |
/* The buffer used by the uIP stack to both receive and send. In this case, | |
because the Ethernet driver has been modified to be zero copy - the uip_buf | |
variable is just a pointer to an Ethernet buffer, and not a buffer in its own | |
right. */ | |
extern unsigned char *uip_buf; | |
/* The ARP timer and the periodic timer share a callback function, so the | |
respective timer IDs are used to determine which timer actually expired. These | |
constants are assigned to the timer IDs. */ | |
#define uipARP_TIMER 0 | |
#define uipPERIODIC_TIMER 1 | |
/* The length of the queue used to send events from timers or the Ethernet | |
driver to the uIP stack. */ | |
#define uipEVENT_QUEUE_LENGTH 10 | |
/* A block time of zero simply means "don't block". */ | |
#define uipDONT_BLOCK 0UL | |
/* How long to wait before attempting to connect the MAC again. */ | |
#define uipINIT_WAIT ( 100 / portTICK_PERIOD_MS ) | |
/* Shortcut to the header within the Rx buffer. */ | |
#define xHeader ((struct uip_eth_hdr *) &uip_buf[ 0 ]) | |
/* Standard constant. */ | |
#define uipTOTAL_FRAME_HEADER_SIZE 54 | |
/*-----------------------------------------------------------*/ | |
/* | |
* Setup the MAC address in the MAC itself, and in the uIP stack. | |
*/ | |
static void prvSetMACAddress( void ); | |
/* | |
* Perform any uIP initialisation required to ready the stack for http | |
* processing. | |
*/ | |
static void prvInitialise_uIP( void ); | |
/* | |
* Handles Ethernet interrupt events. | |
*/ | |
static void prvEMACEventListener( unsigned long ulISREvents ); | |
/* | |
* The callback function that is assigned to both the periodic timer and the | |
* ARP timer. | |
*/ | |
static void prvUIPTimerCallback( TimerHandle_t xTimer ); | |
/* | |
* Initialise the MAC hardware. | |
*/ | |
static void prvInitEmac( void ); | |
/* | |
* Write data to the Ethener. Note that this actually writes data twice for the | |
* to get around delayed ack issues when communicating with a non real-time | |
* peer (for example, a Windows machine). | |
*/ | |
void vEMACWrite( void ); | |
/* | |
* Port functions required by the uIP stack. | |
*/ | |
clock_time_t clock_time( void ); | |
/*-----------------------------------------------------------*/ | |
/* The queue used to send TCP/IP events to the uIP stack. */ | |
QueueHandle_t xEMACEventQueue = NULL; | |
/*-----------------------------------------------------------*/ | |
clock_time_t clock_time( void ) | |
{ | |
return xTaskGetTickCount(); | |
} | |
/*-----------------------------------------------------------*/ | |
void vuIP_Task( void *pvParameters ) | |
{ | |
portBASE_TYPE i; | |
unsigned long ulNewEvent = 0UL, ulUIP_Events = 0UL; | |
long lPacketLength; | |
/* Just to prevent compiler warnings about the unused parameter. */ | |
( void ) pvParameters; | |
/* Initialise the uIP stack, configuring for web server usage. */ | |
prvInitialise_uIP(); | |
/* Initialise the MAC and PHY. */ | |
prvInitEmac(); | |
for( ;; ) | |
{ | |
/* Is there received data ready to be processed? */ | |
lPacketLength = MSS_MAC_rx_packet(); | |
/* Statements to be executed if data has been received on the Ethernet. */ | |
if( ( lPacketLength > 0 ) && ( uip_buf != NULL ) ) | |
{ | |
uip_len = ( u16_t ) lPacketLength; | |
/* Standard uIP loop taken from the uIP manual. */ | |
if( xHeader->type == htons( UIP_ETHTYPE_IP ) ) | |
{ | |
uip_arp_ipin(); | |
uip_input(); | |
/* If the above function invocation resulted in data that | |
should be sent out on the network, the global variable | |
uip_len is set to a value > 0. */ | |
if( uip_len > 0 ) | |
{ | |
uip_arp_out(); | |
vEMACWrite(); | |
} | |
} | |
else if( xHeader->type == htons( UIP_ETHTYPE_ARP ) ) | |
{ | |
uip_arp_arpin(); | |
/* If the above function invocation resulted in data that | |
should be sent out on the network, the global variable | |
uip_len is set to a value > 0. */ | |
if( uip_len > 0 ) | |
{ | |
vEMACWrite(); | |
} | |
} | |
} | |
else | |
{ | |
/* Clear the RX event latched in ulUIP_Events - if one was latched. */ | |
ulUIP_Events &= ~uipETHERNET_RX_EVENT; | |
} | |
/* Statements to be executed if the TCP/IP period timer has expired. */ | |
if( ( ulUIP_Events & uipPERIODIC_TIMER_EVENT ) != 0UL ) | |
{ | |
ulUIP_Events &= ~uipPERIODIC_TIMER_EVENT; | |
if( uip_buf != NULL ) | |
{ | |
for( i = 0; i < UIP_CONNS; i++ ) | |
{ | |
uip_periodic( i ); | |
/* If the above function invocation resulted in data that | |
should be sent out on the network, the global variable | |
uip_len is set to a value > 0. */ | |
if( uip_len > 0 ) | |
{ | |
uip_arp_out(); | |
vEMACWrite(); | |
} | |
} | |
} | |
} | |
/* Statements to be executed if the ARP timer has expired. */ | |
if( ( ulUIP_Events & uipARP_TIMER_EVENT ) != 0 ) | |
{ | |
ulUIP_Events &= ~uipARP_TIMER_EVENT; | |
uip_arp_timer(); | |
} | |
/* If all latched events have been cleared - block until another event | |
occurs. */ | |
if( ulUIP_Events == pdFALSE ) | |
{ | |
xQueueReceive( xEMACEventQueue, &ulNewEvent, portMAX_DELAY ); | |
ulUIP_Events |= ulNewEvent; | |
} | |
} | |
} | |
/*-----------------------------------------------------------*/ | |
static void prvSetMACAddress( void ) | |
{ | |
struct uip_eth_addr xAddr; | |
/* Configure the MAC address in the uIP stack. */ | |
xAddr.addr[ 0 ] = configMAC_ADDR0; | |
xAddr.addr[ 1 ] = configMAC_ADDR1; | |
xAddr.addr[ 2 ] = configMAC_ADDR2; | |
xAddr.addr[ 3 ] = configMAC_ADDR3; | |
xAddr.addr[ 4 ] = configMAC_ADDR4; | |
xAddr.addr[ 5 ] = configMAC_ADDR5; | |
uip_setethaddr( xAddr ); | |
} | |
/*-----------------------------------------------------------*/ | |
static void prvInitialise_uIP( void ) | |
{ | |
uip_ipaddr_t xIPAddr; | |
TimerHandle_t xARPTimer, xPeriodicTimer; | |
uip_init(); | |
uip_ipaddr( &xIPAddr, configIP_ADDR0, configIP_ADDR1, configIP_ADDR2, configIP_ADDR3 ); | |
uip_sethostaddr( &xIPAddr ); | |
uip_ipaddr( &xIPAddr, configNET_MASK0, configNET_MASK1, configNET_MASK2, configNET_MASK3 ); | |
uip_setnetmask( &xIPAddr ); | |
prvSetMACAddress(); | |
httpd_init(); | |
/* Create the queue used to sent TCP/IP events to the uIP stack. */ | |
xEMACEventQueue = xQueueCreate( uipEVENT_QUEUE_LENGTH, sizeof( unsigned long ) ); | |
/* Create and start the uIP timers. */ | |
xARPTimer = xTimerCreate( "ARPTimer", /* Just a name that is helpful for debugging, not used by the kernel. */ | |
( 10000UL / portTICK_PERIOD_MS ), /* Timer period. */ | |
pdTRUE, /* Autor-reload. */ | |
( void * ) uipARP_TIMER, | |
prvUIPTimerCallback | |
); | |
xPeriodicTimer = xTimerCreate( "PeriodicTimer", | |
( 500UL / portTICK_PERIOD_MS ), | |
pdTRUE, /* Autor-reload. */ | |
( void * ) uipPERIODIC_TIMER, | |
prvUIPTimerCallback | |
); | |
/* Sanity check that the timers were indeed created. */ | |
configASSERT( xARPTimer ); | |
configASSERT( xPeriodicTimer ); | |
/* These commands will block indefinitely until they succeed, so there is | |
no point in checking their return values. */ | |
xTimerStart( xARPTimer, portMAX_DELAY ); | |
xTimerStart( xPeriodicTimer, portMAX_DELAY ); | |
} | |
/*-----------------------------------------------------------*/ | |
static void prvEMACEventListener( unsigned long ulISREvents ) | |
{ | |
long lHigherPriorityTaskWoken = pdFALSE; | |
const unsigned long ulRxEvent = uipETHERNET_RX_EVENT; | |
/* Sanity check that the event queue was indeed created. */ | |
configASSERT( xEMACEventQueue ); | |
if( ( ulISREvents & MSS_MAC_EVENT_PACKET_SEND ) != 0UL ) | |
{ | |
/* An Ethernet Tx event has occurred. */ | |
MSS_MAC_FreeTxBuffers(); | |
} | |
if( ( ulISREvents & MSS_MAC_EVENT_PACKET_RECEIVED ) != 0UL ) | |
{ | |
/* An Ethernet Rx event has occurred. */ | |
xQueueSendFromISR( xEMACEventQueue, &ulRxEvent, &lHigherPriorityTaskWoken ); | |
} | |
portEND_SWITCHING_ISR( lHigherPriorityTaskWoken ); | |
} | |
/*-----------------------------------------------------------*/ | |
static void prvInitEmac( void ) | |
{ | |
const unsigned char ucPHYAddress = 1; | |
/* Initialise the MAC and PHY hardware. */ | |
MSS_MAC_init( ucPHYAddress ); | |
/* Register the event listener. The Ethernet interrupt handler will call | |
this listener whenever an Rx or a Tx interrupt occurs. */ | |
MSS_MAC_set_callback( ( MSS_MAC_callback_t ) prvEMACEventListener ); | |
/* Setup the EMAC and the NVIC for MAC interrupts. */ | |
NVIC_SetPriority( EthernetMAC_IRQn, configLIBRARY_MAX_SYSCALL_INTERRUPT_PRIORITY ); | |
NVIC_EnableIRQ( EthernetMAC_IRQn ); | |
} | |
/*-----------------------------------------------------------*/ | |
void vEMACWrite( void ) | |
{ | |
const long lMaxAttempts = 10; | |
long lAttempt; | |
const TickType_t xShortDelay = ( 5 / portTICK_PERIOD_MS ); | |
/* Try to send data to the Ethernet. Keep trying for a while if data cannot | |
be sent immediately. Note that this will actually cause the data to be sent | |
twice to get around delayed ACK problems when communicating with non real- | |
time TCP/IP stacks (such as a Windows machine). */ | |
for( lAttempt = 0; lAttempt < lMaxAttempts; lAttempt++ ) | |
{ | |
if( MSS_MAC_tx_packet( uip_len ) != 0 ) | |
{ | |
break; | |
} | |
else | |
{ | |
vTaskDelay( xShortDelay ); | |
} | |
} | |
} | |
/*-----------------------------------------------------------*/ | |
static void prvUIPTimerCallback( TimerHandle_t xTimer ) | |
{ | |
static const unsigned long ulARPTimerExpired = uipARP_TIMER_EVENT; | |
static const unsigned long ulPeriodicTimerExpired = uipPERIODIC_TIMER_EVENT; | |
/* This is a time callback, so calls to xQueueSend() must not attempt to | |
block. As this callback is assigned to both the ARP and Periodic timers, the | |
first thing to do is ascertain which timer it was that actually expired. */ | |
switch( ( int ) pvTimerGetTimerID( xTimer ) ) | |
{ | |
case uipARP_TIMER : xQueueSend( xEMACEventQueue, &ulARPTimerExpired, uipDONT_BLOCK ); | |
break; | |
case uipPERIODIC_TIMER : xQueueSend( xEMACEventQueue, &ulPeriodicTimerExpired, uipDONT_BLOCK ); | |
break; | |
default : /* Should not get here. */ | |
break; | |
} | |
} | |
/*-----------------------------------------------------------*/ | |
void vApplicationProcessFormInput( char *pcInputString ) | |
{ | |
char *c; | |
/* Only interested in processing form input if this is the IO page. */ | |
c = strstr( pcInputString, "io.shtml" ); | |
if( c ) | |
{ | |
/* Is there a command in the string? */ | |
c = strstr( pcInputString, "?" ); | |
if( c ) | |
{ | |
/* Turn the LED's on or off in accordance with the check box status. */ | |
if( strstr( c, "LED0=1" ) != NULL ) | |
{ | |
/* Turn the LEDs on. */ | |
vParTestSetLED( 3, 1 ); | |
vParTestSetLED( 4, 1 ); | |
} | |
else | |
{ | |
/* Turn the LEDs off. */ | |
vParTestSetLED( 3, 0 ); | |
vParTestSetLED( 4, 0 ); | |
} | |
} | |
else | |
{ | |
/* Commands to turn LEDs off are not always explicit. */ | |
vParTestSetLED( 3, 0 ); | |
vParTestSetLED( 4, 0 ); | |
} | |
} | |
} | |
/*-----------------------------------------------------------*/ |