AVR Z-LINK®

wireless_uart_extended.c

Go to the documentation of this file.

/* This file has been prepared for Doxygen automatic documentation generation.*/
/*============================ INCLDUE =======================================*/
#include <stdint.h>
#include <stdbool.h>

#include "config_uart_extended.h" // See this file for all project options.

#include "compiler.h"

#include "at86rf230_registermap.h"
#include "hal.h"
#include "tat.h"
#include "com.h"
/*============================ MACROS ========================================*/
/*============================ TYPEDEFS ======================================*/
/*============================ VARIABLES =====================================*/
static uint8_t tx_frame[ 127 ]; 

static hal_rx_frame_t rx_pool[ RX_POOL_SIZE ]; 
static hal_rx_frame_t *rx_pool_start; 
static hal_rx_frame_t *rx_pool_end; 
static hal_rx_frame_t *rx_pool_head; 
static hal_rx_frame_t *rx_pool_tail; 
static uint8_t rx_pool_items_free; 
static uint8_t rx_pool_items_used; // !< Number of used items.
static bool rx_pool_overflow_flag; 

static bool rx_flag; 

static uint8_t debug_pll_transition[] = "State transition failed\r\n"; 
static uint8_t debug_type_message[] = "\r<---Type Message:\r\n"; 
static uint8_t debug_data_sent[] = "<---TX OK.\r\n"; 
static uint8_t debug_data_received[] = "\r--->Rx:\r"; 
static uint8_t debug_lqi[] = "LQI: "; 
static uint8_t debug_rx_pool_overflow[] = "RX Buffer Overflow!\r\n"; 
static uint8_t debug_transmission_failed[] = "TX Failed!\r\n"; 
static uint8_t debug_transmission_length[] = "Typed Message too long!!\r\n"; 
static uint8_t debug_fatal_error[] = "A fatal error. System must be reset.\r\n"; 
/*============================ PROTOTYPES ====================================*/
static bool trx_init( void );
static void avr_init( void );
static void trx_end_handler( uint32_t time_stamp );
static void rx_pool_init( void );

static bool trx_init( void ){
    
    static bool status;
    
    if (tat_init( ) != TAT_SUCCESS) {
        status = false;
    } else if (tat_set_operating_channel( OPERATING_CHANNEL ) != TAT_SUCCESS) {
        status = false;
    } else if (tat_set_clock_speed( true, CLKM_DISABLED ) != TAT_SUCCESS) {
        status = false; 
    } else{

        /*Set up the extended modes:*/
        //RX_AACK:
        tat_set_short_address( SHORT_ADDRESS ); //Short Address.
        tat_set_pan_id( PAN_ID ); //PAN ID.
        tat_set_device_role( false ); // No Coordintor support is necessary.
        
        //TX_ARET:
        tat_configure_csma( 234, 0xE2 ); // Default CSMA_SEED_0, MIN_BE = 3, MAX_CSMA_RETRIES = , and CSMA_SEED_1 = 
        
        //Both Modes:
        tat_use_auto_tx_crc( true ); //Automatic CRC must be enabled.
        hal_set_trx_end_event_handler( trx_end_handler ); // Event handler for TRX_END events.
        
        status = true;
    } // end: if (tat_init( ) != TAT_SUCCESS) ...

    return status;
}    

static void avr_init( void ){
    com_init( BR_38400 );
}

static void rx_pool_init( void ){

    rx_pool_start = rx_pool;
    rx_pool_end = &rx_pool[ RX_POOL_SIZE - 1 ];
    
    rx_pool_head = rx_pool_start;
    rx_pool_tail = rx_pool_end;
    
    rx_pool_items_free = RX_POOL_SIZE;
    rx_pool_items_used = 0;
    
    rx_pool_overflow_flag = false;
}

static void trx_end_handler( uint32_t time_stamp ){
    
    if (rx_flag == true) {
        
        //Check if these is space left in the rx_pool.
        if (rx_pool_items_free == 0) {
            rx_pool_overflow_flag = true;
        } else {
        
            //Space left, so upload the received frame.
            hal_frame_read( rx_pool_head );
            
            //Then check the CRC. Will not store frames with invalid CRC.
            if (rx_pool_head->crc == true) {
                
                //Handle wrapping of rx_pool.
                if (rx_pool_head == rx_pool_end) {
                    rx_pool_head = rx_pool_start;
                } else {
                    ++rx_pool_head;
                } // end: if (rx_pool_head == rx_pool_end) ...
                
                --rx_pool_items_free;
                ++rx_pool_items_used;
            } // end: if (rx_pool_head->crc == true) ...
        } // end: if (rx_pool_items_free == 0) ...
    } // end:  if (rx_flag == true) ...
}

void main( void ){
    
    static uint8_t length_of_received_data = 0;
    static uint8_t frame_sequence_number = 0;
    rx_flag = true;
    
    /*Pre Build Header of IEEE 802.15.4 Data frame.*/
    tx_frame[ 0 ] = 0x61; //FCF.
    tx_frame[ 1 ] = 0x88; //FCF.
                           //Sequence number set during frame transmission.
    tx_frame[ 3 ] = PAN_ID & 0xFF; //Dest. PANID.
    tx_frame[ 4 ] = (PAN_ID >> 8 ) & 0xFF; //Dest. PANID.
    tx_frame[ 5 ] = DEST_ADDRESS & 0xFF; //Dest. Addr.
    tx_frame[ 6 ] = (DEST_ADDRESS >> 8 ) & 0xFF; //Dest. Addr.
    tx_frame[ 7 ] = SHORT_ADDRESS & 0xFF; //Source Addr.
    tx_frame[ 8 ] = (SHORT_ADDRESS >> 8 ) & 0xFF; //Source Addr.
    
    rx_pool_init( );
    avr_init( );
    trx_init( );
    
    //Set system state to RX_AACK_ON
    if (tat_set_trx_state( RX_AACK_ON ) != TAT_SUCCESS) {
        com_send_string( debug_fatal_error, sizeof( debug_fatal_error ) );
    } // end: if (tat_set_trx_state( RX_AACK_ON ) != TAT_SUCCESS) ...
    
    sei( );
    
    //Give the user an indication that the system is ready.
    com_send_string( debug_type_message, sizeof( debug_type_message ) );
    
    /*Enter Normal Program Flow:
        - Check for newly received frames. Print them if something is received.
        - Notify on rx_pool overflow.
        - Try to send data on air interface, if something is received on UART/USB.
        - Notify if the typed message was too long.
     */
    while (true) {
        
        //Check if we have received something on the air interface.
        if (rx_pool_items_used != 0) {
        
            //Handle wrapping of rx_pool.
            if (rx_pool_tail == rx_pool_end) {
                rx_pool_tail = rx_pool_start;
            } else {
                ++rx_pool_tail;
            } // end: if (rx_pool_tail == rx_pool_end) ...
            
            //Turn interrupts off for a short while to protect when status
            //information about the rx_pool is updated.
            cli( );
            
            ++rx_pool_items_free;
            --rx_pool_items_used;
            
            sei( );
            
            //Send the frame to the user:
            com_send_string( debug_data_received, sizeof( debug_data_received ) );
            com_send_string( &(rx_pool_tail->data[ 9 ]), ((rx_pool_tail->length) - 9 - 2 ) );
            com_send_string( debug_lqi, sizeof( debug_lqi ) );
            com_send_hex( rx_pool_tail->lqi );
            com_send_string( debug_type_message, sizeof( debug_type_message ) );
        } // end: if (rx_pool_items_used != 0) ...
        
        //Check for rx_pool overflow.
        if (rx_pool_overflow_flag == true) {
            
            cli();
            rx_pool_init( );
            com_send_string( debug_rx_pool_overflow, sizeof( debug_rx_pool_overflow ) );
            sei();
        } // end: if (rx_pool_overflow_flag == true) ...
        
        //Check for new data on the serial interface.
        //Check if data is ready to be sent.
        length_of_received_data = com_get_number_of_received_bytes( );
        
        if (length_of_received_data == 1) {
            
            //length_of_received_data == 1 indicates a buffer overflow. Received data too long.
            com_send_string( debug_transmission_length, sizeof( debug_transmission_length ) );
            com_reset_receiver( );
        } else {
            
            if ((length_of_received_data >= 3) && (length_of_received_data <= COM_RX_BUFFER_SIZE)) {
            
                //Change state to TX_ARET_ON and send data if the state transition was successful.
                if (tat_set_trx_state( TX_ARET_ON ) == TAT_SUCCESS) {
                
                    uint8_t *rx_frame = com_get_received_data( );
                
                    uint8_t tx_frame_length = 9; // Length of prebuilt frame header.
                    tx_frame[ 2 ] = frame_sequence_number++; //Sequence Number.
                
                    //Copy data into the TX frame buffer.
                    do {
                        tx_frame[ tx_frame_length++ ] = *rx_frame++;
                    } while (--length_of_received_data > 0);
                
                    rx_flag = false; // Set the flag false, so that the TRX_END event is not misinterpreted.
                
                    if (tat_send_data_with_retry( tx_frame_length, tx_frame, 1 ) == TAT_SUCCESS) {   
                        com_send_string( debug_data_sent, sizeof( debug_data_sent ) );
                    } else {
                        com_send_string( debug_transmission_failed, sizeof( debug_transmission_failed ) );
                    } // end:  if (tat_send_data_with_retry( tx_frame_length, tx_frame, 1 ) ...
                } else {
                    com_send_string( debug_pll_transition, sizeof( debug_pll_transition ) );
                } // end: if (tat_set_trx_state( TX_ARET_ON ) == TAT_SUCCESS) ...
            
                if (tat_set_trx_state( RX_AACK_ON ) != TAT_SUCCESS) {
                    com_send_string( debug_fatal_error, sizeof( debug_fatal_error ) );
                } // end: if (tat_set_trx_state( RX_AACK_ON ) != TAT_SUCCESS) ...
            
                rx_flag = true; // Set the flag back again. Only used to protec the frame transmission.
                com_reset_receiver( );
                com_send_string( debug_type_message, sizeof( debug_type_message ) );
            } // end: 
        } // end: if (length_of_received_data == 1) ...
    } // emd: while (true) ...
}
/*EOF*/