mirror of
https://github.com/oliverschmidt/contiki.git
synced 2024-12-22 10:30:13 +00:00
0b2d3d1615
Put periodic radio calibration on conditional.
1485 lines
44 KiB
C
1485 lines
44 KiB
C
/*
|
|
* Copyright (c) 2007, Swedish Institute of Computer Science
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* 3. Neither the name of the Institute nor the names of its contributors
|
|
* may be used to endorse or promote products derived from this software
|
|
* without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE INSTITUTE AND CONTRIBUTORS ``AS IS'' AND
|
|
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE INSTITUTE OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
|
* SUCH DAMAGE.
|
|
*
|
|
* This file is part of the Contiki operating system.
|
|
*
|
|
* @(#)$Id: rf230bb.c,v 1.24 2010/12/22 20:10:00 dak664 Exp $
|
|
*/
|
|
/*
|
|
* This code is almost device independent and should be easy to port.
|
|
* Ported to Atmel RF230 21Feb2010 by dak
|
|
*/
|
|
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
|
|
#include "contiki.h"
|
|
|
|
#if defined(__AVR__)
|
|
#include <avr/io.h>
|
|
|
|
//_delay_us has the potential to use floating point which brings the 256 byte clz table into RAM
|
|
//#include <util/delay.h>
|
|
//#define delay_us( us ) ( _delay_us( ( us ) ) )
|
|
//_delay_loop_2(uint16_t count) is 4 CPU cycles per iteration, up to 32 milliseconds at 8MHz
|
|
#include <util/delay_basic.h>
|
|
#define delay_us( us ) ( _delay_loop_2(1+(us*F_CPU)/4000000UL) )
|
|
|
|
#include <avr/pgmspace.h>
|
|
#elif defined(__MSP430__)
|
|
#include <io.h>
|
|
#endif
|
|
|
|
#include "dev/leds.h"
|
|
#include "dev/spi.h"
|
|
#include "rf230bb.h"
|
|
|
|
#include "net/packetbuf.h"
|
|
#include "net/rime/rimestats.h"
|
|
#include "net/netstack.h"
|
|
|
|
#include "sys/timetable.h"
|
|
|
|
#define WITH_SEND_CCA 0
|
|
|
|
/* Timestamps have not been tested */
|
|
#if RF230_CONF_TIMESTAMPS
|
|
#include "net/rime/timesynch.h"
|
|
#define TIMESTAMP_LEN 3
|
|
#else /* RF230_CONF_TIMESTAMPS */
|
|
#define TIMESTAMP_LEN 0
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
/* Nonzero FOOTER_LEN has not been tested */
|
|
#define FOOTER_LEN 0
|
|
|
|
/* RF230_CONF_CHECKSUM=0 for automatic hardware checksum */
|
|
#ifndef RF230_CONF_CHECKSUM
|
|
#define RF230_CONF_CHECKSUM 0
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
|
|
#ifndef RF230_CONF_AUTOACK
|
|
#define RF230_CONF_AUTOACK 1
|
|
#endif /* RF230_CONF_AUTOACK */
|
|
|
|
#if RF230_CONF_AUTOACK
|
|
static bool is_promiscuous;
|
|
#endif
|
|
|
|
#ifndef RF230_CONF_AUTORETRIES
|
|
#define RF230_CONF_AUTORETRIES 2
|
|
#endif /* RF230_CONF_AUTOACK */
|
|
|
|
//Automatic and manual CRC both append 2 bytes to packets
|
|
#if RF230_CONF_CHECKSUM || defined(RF230BB_HOOK_TX_PACKET)
|
|
#include "lib/crc16.h"
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
#define CHECKSUM_LEN 2
|
|
|
|
/* Note the AUC_LEN is equal to the CHECKSUM_LEN in any tested configurations to date! */
|
|
#define AUX_LEN (CHECKSUM_LEN + TIMESTAMP_LEN + FOOTER_LEN)
|
|
#if AUX_LEN != CHECKSUM_LEN
|
|
#warning RF230 Untested Configuration!
|
|
#endif
|
|
|
|
struct timestamp {
|
|
uint16_t time;
|
|
uint8_t authority_level;
|
|
};
|
|
|
|
#define FOOTER1_CRC_OK 0x80
|
|
#define FOOTER1_CORRELATION 0x7f
|
|
|
|
/* Leave radio on for testing low power protocols */
|
|
#if JACKDAW
|
|
#define RADIOALWAYSON 1
|
|
#else
|
|
#define RADIOALWAYSON 0
|
|
#define RADIOSLEEPSWHENOFF 1
|
|
#endif
|
|
|
|
//RS232 delays will cause 6lowpan fragment overruns!
|
|
#define DEBUG 0
|
|
#if DEBUG
|
|
#define PRINTF(FORMAT,args...) printf_P(PSTR(FORMAT),##args)
|
|
#define PRINTSHORT(FORMAT,args...) printf_P(PSTR(FORMAT),##args)
|
|
#else
|
|
#define PRINTF(...)
|
|
#define PRINTSHORT(...)
|
|
#endif
|
|
#if DEBUG>1
|
|
/* Output format is suitable for text2pcap to convert to wireshark pcap file.
|
|
* Use $text2pcap -e 0x809a (these_outputs) capture.pcap
|
|
* Since the hardware calculates and appends the two byte checksum to Tx packets,
|
|
* we just add two zero bytes to the packet dump. Don't forget to enable wireshark
|
|
* 802.15.4 dissection even when the checksum is wrong!
|
|
*/
|
|
//int wireshark_offset;
|
|
#endif
|
|
|
|
/* See clock.c and httpd-cgi.c for RADIOSTATS code */
|
|
#if WEBSERVER
|
|
#define RADIOSTATS 1
|
|
#endif
|
|
#if RADIOSTATS
|
|
uint16_t RF230_sendpackets,RF230_receivepackets,RF230_sendfail,RF230_receivefail;
|
|
#endif
|
|
|
|
#if RADIOCALIBRATE
|
|
/* Set in clock.c every 256 seconds */
|
|
uint8_t rf230_calibrate;
|
|
uint8_t rf230_calibrated; //for debugging, prints from main loop when calibration occurs
|
|
#endif
|
|
|
|
/* Track flow through driver, see contiki-raven-main.c for example of use */
|
|
//#define DEBUGFLOWSIZE 64
|
|
#if DEBUGFLOWSIZE
|
|
uint8_t debugflowsize,debugflow[DEBUGFLOWSIZE];
|
|
#define DEBUGFLOW(c) if (debugflowsize<(DEBUGFLOWSIZE-1)) debugflow[debugflowsize++]=c
|
|
#else
|
|
#define DEBUGFLOW(c)
|
|
#endif
|
|
|
|
/* XXX hack: these will be made as Chameleon packet attributes */
|
|
rtimer_clock_t rf230_time_of_arrival, rf230_time_of_departure;
|
|
|
|
int rf230_authority_level_of_sender;
|
|
|
|
#if RF230_CONF_TIMESTAMPS
|
|
static rtimer_clock_t setup_time_for_transmission;
|
|
static unsigned long total_time_for_transmission, total_transmission_len;
|
|
static int num_transmissions;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
|
|
static uint8_t volatile pending;
|
|
|
|
/* RF230 hardware delay times, from datasheet */
|
|
typedef enum{
|
|
TIME_TO_ENTER_P_ON = 510, /**< Transition time from VCC is applied to P_ON - most favorable case! */
|
|
TIME_P_ON_TO_TRX_OFF = 510, /**< Transition time from P_ON to TRX_OFF. */
|
|
TIME_SLEEP_TO_TRX_OFF = 880, /**< Transition time from SLEEP to TRX_OFF. */
|
|
TIME_RESET = 6, /**< Time to hold the RST pin low during reset */
|
|
TIME_ED_MEASUREMENT = 140, /**< Time it takes to do a ED measurement. */
|
|
TIME_CCA = 140, /**< Time it takes to do a CCA. */
|
|
TIME_PLL_LOCK = 150, /**< Maximum time it should take for the PLL to lock. */
|
|
TIME_FTN_TUNING = 25, /**< Maximum time it should take to do the filter tuning. */
|
|
TIME_NOCLK_TO_WAKE = 6, /**< Transition time from *_NOCLK to being awake. */
|
|
TIME_CMD_FORCE_TRX_OFF = 1, /**< Time it takes to execute the FORCE_TRX_OFF command. */
|
|
TIME_TRX_OFF_TO_PLL_ACTIVE = 180, /**< Transition time from TRX_OFF to: RX_ON, PLL_ON, TX_ARET_ON and RX_AACK_ON. */
|
|
TIME_STATE_TRANSITION_PLL_ACTIVE = 1, /**< Transition time from PLL active state to another. */
|
|
}radio_trx_timing_t;
|
|
/*---------------------------------------------------------------------------*/
|
|
PROCESS(rf230_process, "RF230 driver");
|
|
/*---------------------------------------------------------------------------*/
|
|
|
|
int rf230_on(void);
|
|
int rf230_off(void);
|
|
|
|
static int rf230_read(void *buf, unsigned short bufsize);
|
|
|
|
static int rf230_prepare(const void *data, unsigned short len);
|
|
static int rf230_transmit(unsigned short len);
|
|
static int rf230_send(const void *data, unsigned short len);
|
|
|
|
static int rf230_receiving_packet(void);
|
|
static int pending_packet(void);
|
|
static int rf230_cca(void);
|
|
|
|
signed char rf230_last_rssi;
|
|
uint8_t rf230_last_correlation;
|
|
|
|
const struct radio_driver rf230_driver =
|
|
{
|
|
rf230_init,
|
|
rf230_prepare,
|
|
rf230_transmit,
|
|
rf230_send,
|
|
rf230_read,
|
|
rf230_cca,
|
|
rf230_receiving_packet,
|
|
pending_packet,
|
|
rf230_on,
|
|
rf230_off
|
|
};
|
|
|
|
uint8_t RF230_receive_on,RF230_sleeping;
|
|
static uint8_t channel;
|
|
|
|
/* Received frames are buffered to rxframe in the interrupt routine in hal.c */
|
|
uint8_t rxframe_head,rxframe_tail;
|
|
hal_rx_frame_t rxframe[RF230_CONF_RX_BUFFERS];
|
|
|
|
/*----------------------------------------------------------------------------*/
|
|
/** \brief This function return the Radio Transceivers current state.
|
|
*
|
|
* \retval P_ON When the external supply voltage (VDD) is
|
|
* first supplied to the transceiver IC, the
|
|
* system is in the P_ON (Poweron) mode.
|
|
* \retval BUSY_RX The radio transceiver is busy receiving a
|
|
* frame.
|
|
* \retval BUSY_TX The radio transceiver is busy transmitting a
|
|
* frame.
|
|
* \retval RX_ON The RX_ON mode enables the analog and digital
|
|
* receiver blocks and the PLL frequency
|
|
* synthesizer.
|
|
* \retval TRX_OFF In this mode, the SPI module and crystal
|
|
* oscillator are active.
|
|
* \retval PLL_ON Entering the PLL_ON mode from TRX_OFF will
|
|
* first enable the analog voltage regulator. The
|
|
* transceiver is ready to transmit a frame.
|
|
* \retval BUSY_RX_AACK The radio was in RX_AACK_ON mode and received
|
|
* the Start of Frame Delimiter (SFD). State
|
|
* transition to BUSY_RX_AACK is done if the SFD
|
|
* is valid.
|
|
* \retval BUSY_TX_ARET The radio transceiver is busy handling the
|
|
* auto retry mechanism.
|
|
* \retval RX_AACK_ON The auto acknowledge mode of the radio is
|
|
* enabled and it is waiting for an incomming
|
|
* frame.
|
|
* \retval TX_ARET_ON The auto retry mechanism is enabled and the
|
|
* radio transceiver is waiting for the user to
|
|
* send the TX_START command.
|
|
* \retval RX_ON_NOCLK The radio transceiver is listening for
|
|
* incomming frames, but the CLKM is disabled so
|
|
* that the controller could be sleeping.
|
|
* However, this is only true if the controller
|
|
* is run from the clock output of the radio.
|
|
* \retval RX_AACK_ON_NOCLK Same as the RX_ON_NOCLK state, but with the
|
|
* auto acknowledge module turned on.
|
|
* \retval BUSY_RX_AACK_NOCLK Same as BUSY_RX_AACK, but the controller
|
|
* could be sleeping since the CLKM pin is
|
|
* disabled.
|
|
* \retval STATE_TRANSITION The radio transceiver's state machine is in
|
|
* transition between two states.
|
|
*/
|
|
static uint8_t
|
|
radio_get_trx_state(void)
|
|
{
|
|
return hal_subregister_read(SR_TRX_STATUS);
|
|
}
|
|
|
|
/*----------------------------------------------------------------------------*/
|
|
/** \brief This function checks if the radio transceiver is sleeping.
|
|
*
|
|
* \retval true The radio transceiver is in SLEEP or one of the *_NOCLK
|
|
* states.
|
|
* \retval false The radio transceiver is not sleeping.
|
|
*/
|
|
static bool radio_is_sleeping(void)
|
|
{
|
|
bool sleeping = false;
|
|
|
|
/* The radio transceiver will be at SLEEP or one of the *_NOCLK states only if */
|
|
/* the SLP_TR pin is high. */
|
|
if (hal_get_slptr() != 0){
|
|
sleeping = true;
|
|
}
|
|
|
|
return sleeping;
|
|
}
|
|
|
|
/*----------------------------------------------------------------------------*/
|
|
/** \brief This function will reset the state machine (to TRX_OFF) from any of
|
|
* its states, except for the SLEEP state.
|
|
*/
|
|
static void
|
|
radio_reset_state_machine(void)
|
|
{
|
|
hal_set_slptr_low();
|
|
delay_us(TIME_NOCLK_TO_WAKE);
|
|
hal_subregister_write(SR_TRX_CMD, CMD_FORCE_TRX_OFF);
|
|
delay_us(TIME_CMD_FORCE_TRX_OFF);
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static char
|
|
rf230_isidle(void)
|
|
{
|
|
uint8_t radio_state;
|
|
radio_state = hal_subregister_read(SR_TRX_STATUS);
|
|
if (radio_state != BUSY_TX_ARET &&
|
|
radio_state != BUSY_RX_AACK &&
|
|
radio_state != STATE_TRANSITION &&
|
|
radio_state != BUSY_RX &&
|
|
radio_state != BUSY_TX) {
|
|
return(1);
|
|
} else {
|
|
// printf(".%u",radio_state);
|
|
return(0);
|
|
}
|
|
}
|
|
|
|
static void
|
|
rf230_waitidle(void)
|
|
{
|
|
while (1) {
|
|
if (rf230_isidle()) break;
|
|
}
|
|
}
|
|
|
|
/*----------------------------------------------------------------------------*/
|
|
/** \brief This function will change the current state of the radio
|
|
* transceiver's internal state machine.
|
|
*
|
|
* \param new_state Here is a list of possible states:
|
|
* - RX_ON Requested transition to RX_ON state.
|
|
* - TRX_OFF Requested transition to TRX_OFF state.
|
|
* - PLL_ON Requested transition to PLL_ON state.
|
|
* - RX_AACK_ON Requested transition to RX_AACK_ON state.
|
|
* - TX_ARET_ON Requested transition to TX_ARET_ON state.
|
|
*
|
|
* \retval RADIO_SUCCESS Requested state transition completed
|
|
* successfully.
|
|
* \retval RADIO_INVALID_ARGUMENT Supplied function parameter out of bounds.
|
|
* \retval RADIO_WRONG_STATE Illegal state to do transition from.
|
|
* \retval RADIO_BUSY_STATE The radio transceiver is busy.
|
|
* \retval RADIO_TIMED_OUT The state transition could not be completed
|
|
* within resonable time.
|
|
*/
|
|
static radio_status_t
|
|
radio_set_trx_state(uint8_t new_state)
|
|
{
|
|
uint8_t original_state;
|
|
|
|
/*Check function paramter and current state of the radio transceiver.*/
|
|
if (!((new_state == TRX_OFF) ||
|
|
(new_state == RX_ON) ||
|
|
(new_state == PLL_ON) ||
|
|
(new_state == RX_AACK_ON) ||
|
|
(new_state == TX_ARET_ON))){
|
|
return RADIO_INVALID_ARGUMENT;
|
|
}
|
|
|
|
if (radio_is_sleeping() == true){
|
|
return RADIO_WRONG_STATE;
|
|
}
|
|
|
|
/* Wait for radio to finish previous operation */
|
|
rf230_waitidle();
|
|
// for(;;)
|
|
// {
|
|
original_state = radio_get_trx_state();
|
|
// if (original_state != BUSY_TX_ARET &&
|
|
// original_state != BUSY_RX_AACK &&
|
|
// original_state != BUSY_RX &&
|
|
// original_state != BUSY_TX)
|
|
// break;
|
|
// }
|
|
|
|
if (new_state == original_state){
|
|
return RADIO_SUCCESS;
|
|
}
|
|
|
|
|
|
/* At this point it is clear that the requested new_state is: */
|
|
/* TRX_OFF, RX_ON, PLL_ON, RX_AACK_ON or TX_ARET_ON. */
|
|
|
|
/* The radio transceiver can be in one of the following states: */
|
|
/* TRX_OFF, RX_ON, PLL_ON, RX_AACK_ON, TX_ARET_ON. */
|
|
if(new_state == TRX_OFF){
|
|
radio_reset_state_machine(); /* Go to TRX_OFF from any state. */
|
|
} else {
|
|
/* It is not allowed to go from RX_AACK_ON or TX_AACK_ON and directly to */
|
|
/* TX_AACK_ON or RX_AACK_ON respectively. Need to go via RX_ON or PLL_ON. */
|
|
if ((new_state == TX_ARET_ON) &&
|
|
(original_state == RX_AACK_ON)){
|
|
/* First do intermediate state transition to PLL_ON, then to TX_ARET_ON. */
|
|
/* The final state transition to TX_ARET_ON is handled after the if-else if. */
|
|
hal_subregister_write(SR_TRX_CMD, PLL_ON);
|
|
delay_us(TIME_STATE_TRANSITION_PLL_ACTIVE);
|
|
} else if ((new_state == RX_AACK_ON) &&
|
|
(original_state == TX_ARET_ON)){
|
|
/* First do intermediate state transition to RX_ON, then to RX_AACK_ON. */
|
|
/* The final state transition to RX_AACK_ON is handled after the if-else if. */
|
|
hal_subregister_write(SR_TRX_CMD, RX_ON);
|
|
delay_us(TIME_STATE_TRANSITION_PLL_ACTIVE);
|
|
}
|
|
|
|
/* Any other state transition can be done directly. */
|
|
hal_subregister_write(SR_TRX_CMD, new_state);
|
|
|
|
/* When the PLL is active most states can be reached in 1us. However, from */
|
|
/* TRX_OFF the PLL needs time to activate. */
|
|
if (original_state == TRX_OFF){
|
|
delay_us(TIME_TRX_OFF_TO_PLL_ACTIVE);
|
|
} else {
|
|
delay_us(TIME_STATE_TRANSITION_PLL_ACTIVE);
|
|
}
|
|
} /* end: if(new_state == TRX_OFF) ... */
|
|
|
|
/*Verify state transition.*/
|
|
radio_status_t set_state_status = RADIO_TIMED_OUT;
|
|
|
|
if (radio_get_trx_state() == new_state){
|
|
set_state_status = RADIO_SUCCESS;
|
|
}
|
|
|
|
return set_state_status;
|
|
}
|
|
|
|
void
|
|
rf230_set_promiscuous_mode(bool isPromiscuous) {
|
|
#if RF230_CONF_AUTOACK
|
|
is_promiscuous = isPromiscuous;
|
|
/* TODO: Figure out when to pass promisc state to 802.15.4 */
|
|
// radio_set_trx_state(is_promiscuous?RX_ON:RX_AACK_ON);
|
|
#endif
|
|
}
|
|
|
|
bool
|
|
rf230_is_ready_to_send() {
|
|
switch(radio_get_trx_state()) {
|
|
case BUSY_TX:
|
|
case BUSY_TX_ARET:
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
|
|
static void
|
|
flushrx(void)
|
|
{
|
|
rxframe[rxframe_head].length=0;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static uint8_t locked, lock_on, lock_off;
|
|
|
|
static void
|
|
on(void)
|
|
{
|
|
ENERGEST_ON(ENERGEST_TYPE_LISTEN);
|
|
|
|
#ifdef RF230BB_HOOK_RADIO_ON
|
|
RF230BB_HOOK_RADIO_ON();
|
|
#endif
|
|
|
|
if (RF230_sleeping) {
|
|
hal_set_slptr_low();
|
|
delay_us(TIME_SLEEP_TO_TRX_OFF);
|
|
// delay_us(TIME_SLEEP_TO_TRX_OFF);//extra delay for now, wake time depends on board capacitance
|
|
RF230_sleeping=0;
|
|
}
|
|
rf230_waitidle();
|
|
|
|
#if RF230_CONF_AUTOACK
|
|
// radio_set_trx_state(is_promiscuous?RX_ON:RX_AACK_ON);
|
|
radio_set_trx_state(RX_AACK_ON);
|
|
#else
|
|
radio_set_trx_state(RX_ON);
|
|
#endif
|
|
|
|
// flushrx();
|
|
// DEBUGFLOW('O');
|
|
RF230_receive_on = 1;
|
|
}
|
|
static void
|
|
off(void)
|
|
{
|
|
// rtimer_set(&rt, RTIMER_NOW()+ RTIMER_ARCH_SECOND*1UL, 1,(void *) rtimercycle, NULL);
|
|
RF230_receive_on = 0;
|
|
|
|
#ifdef RF230BB_HOOK_RADIO_OFF
|
|
RF230BB_HOOK_RADIO_OFF();
|
|
#endif
|
|
|
|
// DEBUGFLOW('F');
|
|
#if !RADIOALWAYSON
|
|
|
|
/* Wait any transmission to end */
|
|
rf230_waitidle();
|
|
|
|
/* Force the device into TRX_OFF. */
|
|
radio_reset_state_machine();
|
|
|
|
#if RADIOSLEEPSWHENOFF
|
|
/* Sleep Radio */
|
|
hal_set_slptr_high();
|
|
RF230_sleeping = 1;
|
|
#endif
|
|
|
|
#endif /* !RADIOALWAYSON */
|
|
|
|
ENERGEST_OFF(ENERGEST_TYPE_LISTEN);
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
#define GET_LOCK() locked = 1
|
|
static void RELEASE_LOCK(void) {
|
|
if(lock_on) {
|
|
on();
|
|
lock_on = 0;
|
|
}
|
|
if(lock_off) {
|
|
off();
|
|
lock_off = 0;
|
|
}
|
|
locked = 0;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static void
|
|
set_txpower(uint8_t power)
|
|
{
|
|
if (power > TX_PWR_17_2DBM){
|
|
power=TX_PWR_17_2DBM;
|
|
}
|
|
if (radio_is_sleeping() ==true) {
|
|
PRINTF("rf230_set_txpower:Sleeping"); //happens with cxmac
|
|
} else {
|
|
hal_subregister_write(SR_TX_PWR, power);
|
|
}
|
|
}
|
|
/*----------------------------------------------------------------------------*/
|
|
/**
|
|
\brief Calibrate the internal RC oscillator
|
|
|
|
This function calibrates the internal RC oscillator, based
|
|
on an external 32KHz crystal connected to TIMER2. In order to
|
|
verify the calibration result you can program the CKOUT fuse
|
|
and monitor the CPU clock on an I/O pin.
|
|
*/
|
|
#define AVR_ENTER_CRITICAL_REGION( ) {uint8_t volatile saved_sreg = SREG; cli( )
|
|
#define AVR_LEAVE_CRITICAL_REGION( ) SREG = saved_sreg;}
|
|
uint8_t osccal_original,osccal_calibrated;
|
|
void
|
|
calibrate_rc_osc_32k(void)
|
|
{
|
|
#if 1
|
|
|
|
/* Calibrate RC Oscillator: The calibration routine is done by clocking TIMER2
|
|
* from the external 32kHz crystal while running an internal timer simultaneously.
|
|
* The internal timer will be clocked at the same speed as the internal RC
|
|
* oscillator, while TIMER2 is running at 32768 Hz. This way it is not necessary
|
|
* to use a timed loop, and keep track cycles in timed loop vs. optimization
|
|
* and compiler.
|
|
*/
|
|
uint8_t osccal_original = OSCCAL;
|
|
volatile uint16_t temp;
|
|
|
|
/* Start with current value, which for some MCUs could be in upper or lower range */
|
|
|
|
// PRR0 &= ~((1 << PRTIM2)|(1 << PRTIM1)); /* Enable Timer 1 and 2 */
|
|
|
|
TIMSK2 = 0x00; /* Disable Timer/Counter 2 interrupts. */
|
|
TIMSK1 = 0x00; /* Disable Timer/Counter 1 interrupts. */
|
|
|
|
/* Enable TIMER/COUNTER 2 to be clocked from the external 32kHz clock crystal.
|
|
* Then wait for the timer to become stable before doing any calibration.
|
|
*/
|
|
ASSR |= (1 << AS2);
|
|
// while (ASSR & ((1 << TCN2UB)|(1 << OCR2AUB)|(1 << TCR2AUB)|(1 << TCR2BUB))) { ; }
|
|
TCCR2B = 1 << CS20; /* run timer 2 at divide by 1 (32KHz) */
|
|
|
|
delay_us(50000UL); //crystal takes significant time to stabilize
|
|
AVR_ENTER_CRITICAL_REGION();
|
|
|
|
uint8_t counter = 128;
|
|
bool cal_ok = false;
|
|
do{
|
|
/* wait for timer to be ready for updated config */
|
|
TCCR1B = 1 << CS10;
|
|
|
|
while (ASSR & ((1 << TCN2UB)|(1 << OCR2AUB)|(1 << TCR2AUB)|(1 << TCR2BUB))) { ; }
|
|
|
|
TCNT2 = 0x80;
|
|
TCNT1 = 0;
|
|
|
|
TIFR2 = 0xFF; /* Clear TIFR2 flags (Yes, really) */
|
|
|
|
/* Wait for TIMER/COUNTER 2 to overflow. Stop TIMER/COUNTER 1 and 2, and
|
|
* read the counter value of TIMER/COUNTER 1. It will now contain the
|
|
* number of cpu cycles elapsed within the 3906.25 microsecond period.
|
|
*/
|
|
while (!(TIFR2 & (1 << TOV2))){
|
|
;
|
|
}
|
|
temp = TCNT1;
|
|
|
|
TCCR1B = 0;
|
|
/* Defining these as floating point introduces a lot of code and the 256 byte .clz table to RAM */
|
|
/* At 8 MHz we would expect 8*3906.25 = 31250 CPU clocks */
|
|
#define cal_upper 32812 //(31250*1.05) // 32812 = 0x802c
|
|
#define cal_lower 29687 //(31250*0.95) // 29687 = 0x73f7
|
|
/* Iteratively reduce the error to be within limits */
|
|
if (temp < cal_lower) {
|
|
/* Too slow. Put the hammer down. */
|
|
if (OSCCAL==0x7e) break; //stay in lowest range
|
|
if (OSCCAL==0xff) break;
|
|
OSCCAL++;
|
|
} else if (temp > cal_upper) {
|
|
/* Too fast, retard. */
|
|
if (OSCCAL==0x81) break; //stay in highest range
|
|
if (OSCCAL==0x00) break;
|
|
OSCCAL--;
|
|
} else {
|
|
/* The CPU clock frequency is now within +/- 0.5% of the target value. */
|
|
cal_ok = true;
|
|
}
|
|
|
|
counter--;
|
|
} while ((counter != 0) && (false == cal_ok));
|
|
|
|
osccal_calibrated=OSCCAL;
|
|
if (true != cal_ok) {
|
|
/* We failed, therefore restore previous OSCCAL value. */
|
|
OSCCAL = osccal_original;
|
|
}
|
|
|
|
OSCCAL = osccal_original;
|
|
TCCR2B = 0;
|
|
|
|
ASSR &= ~(1 << AS2);
|
|
|
|
/* Disable both timers again to save power. */
|
|
// PRR0 |= (1 << PRTIM2);/* |(1 << PRTIM1); */
|
|
|
|
AVR_LEAVE_CRITICAL_REGION();
|
|
#endif
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
int
|
|
rf230_init(void)
|
|
{
|
|
uint8_t i;
|
|
DEBUGFLOW('I');
|
|
|
|
/* Wait in case VCC just applied */
|
|
delay_us(TIME_TO_ENTER_P_ON);
|
|
|
|
/* Calibrate oscillator */
|
|
// printf_P(PSTR("\nBefore calibration OSCCAL=%x\n"),OSCCAL);
|
|
// calibrate_rc_osc_32k();
|
|
// printf_P(PSTR("After calibration OSCCAL=%x\n"),OSCCAL);
|
|
|
|
/* Initialize Hardware Abstraction Layer */
|
|
hal_init();
|
|
|
|
/* Set receive buffers empty and point to the first */
|
|
for (i=0;i<RF230_CONF_RX_BUFFERS;i++) rxframe[i].length=0;
|
|
rxframe_head=0;rxframe_tail=0;
|
|
|
|
/* Do full rf230 Reset */
|
|
hal_set_rst_low();
|
|
hal_set_slptr_low();
|
|
delay_us(TIME_RESET);
|
|
hal_set_rst_high();
|
|
|
|
/* Force transition to TRX_OFF */
|
|
hal_subregister_write(SR_TRX_CMD, CMD_FORCE_TRX_OFF);
|
|
delay_us(TIME_P_ON_TO_TRX_OFF);
|
|
|
|
/* Verify that it is a supported version */
|
|
/* Note gcc optimizes this away if DEBUG is not set! */
|
|
//ATMEGA128RFA1 - version 4, ID 31
|
|
uint8_t tvers = hal_register_read(RG_VERSION_NUM);
|
|
uint8_t tmanu = hal_register_read(RG_MAN_ID_0);
|
|
|
|
if ((tvers != RF230_REVA) && (tvers != RF230_REVB))
|
|
PRINTF("rf230: Unsupported version %u\n",tvers);
|
|
if (tmanu != SUPPORTED_MANUFACTURER_ID)
|
|
PRINTF("rf230: Unsupported manufacturer ID %u\n",tmanu);
|
|
|
|
PRINTF("rf230: Version %u, ID %u\n",tvers,tmanu);
|
|
hal_register_write(RG_IRQ_MASK, RF230_SUPPORTED_INTERRUPT_MASK);
|
|
|
|
/* Set up number of automatic retries 0-15 (0 implies PLL_ON sends instead of the extended TX_ARET mode */
|
|
hal_subregister_write(SR_MAX_FRAME_RETRIES, RF230_CONF_AUTORETRIES );
|
|
|
|
/* Set up carrier sense/clear channel assesment parameters for extended operating mode */
|
|
hal_subregister_write(SR_MAX_CSMA_RETRIES, 5 );//highest allowed retries
|
|
hal_register_write(RG_CSMA_BE, 0x80); //min backoff exponent 0, max 8 (highest allowed)
|
|
hal_register_write(RG_CSMA_SEED_0,hal_register_read(RG_PHY_RSSI) );//upper two RSSI reg bits RND_VALUE are random in rf231
|
|
// hal_register_write(CSMA_SEED_1,42 );
|
|
|
|
/* Use automatic CRC unless manual is specified */
|
|
#if RF230_CONF_CHECKSUM
|
|
hal_subregister_write(SR_TX_AUTO_CRC_ON, 0);
|
|
#else
|
|
hal_subregister_write(SR_TX_AUTO_CRC_ON, 1);
|
|
#endif
|
|
|
|
/* Start the packet receive process */
|
|
process_start(&rf230_process, NULL);
|
|
|
|
/* Limit tx power for testing miniature Raven mesh */
|
|
#ifdef RF230_MAX_TX_POWER
|
|
set_txpower(RF230_MAX_TX_POWER); //0=3dbm 15=-17.2dbm
|
|
#endif
|
|
|
|
/* Leave radio in on state (?)*/
|
|
on();
|
|
|
|
|
|
return 1;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static uint8_t buffer[RF230_MAX_TX_FRAME_LENGTH+AUX_LEN];
|
|
static int
|
|
rf230_transmit(unsigned short payload_len)
|
|
{
|
|
int txpower;
|
|
uint8_t total_len;
|
|
uint8_t radiowason;
|
|
uint8_t tx_result;
|
|
#if RF230_CONF_TIMESTAMPS
|
|
struct timestamp timestamp;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
|
|
GET_LOCK();
|
|
// DEBUGFLOW('T');
|
|
|
|
/* Save receiver state */
|
|
radiowason=RF230_receive_on;
|
|
|
|
/* If radio is sleeping we have to turn it on first */
|
|
/* This automatically does the PLL calibrations */
|
|
if (RF230_sleeping) {
|
|
hal_set_slptr_low();
|
|
// delay_us(TIME_SLEEP_TO_TRX_OFF);
|
|
RF230_sleeping=0;
|
|
} else {
|
|
#if RADIOCALIBRATE
|
|
/* If on, do periodic calibration. See clock.c */
|
|
if (rf230_calibrate) {
|
|
hal_subregister_write(SR_PLL_CF_START,1); //takes 80us max
|
|
hal_subregister_write(SR_PLL_DCU_START,1); //takes 6us, concurrently
|
|
rf230_calibrate=0;
|
|
rf230_calibrated=1;
|
|
delay_us(80); //?
|
|
}
|
|
#endif
|
|
}
|
|
|
|
/* Wait for any previous operation or state transition to finish */
|
|
rf230_waitidle();
|
|
|
|
/* Prepare to transmit */
|
|
#if RF230_CONF_AUTORETRIES
|
|
radio_set_trx_state(TX_ARET_ON);
|
|
#else
|
|
radio_set_trx_state(PLL_ON);
|
|
#endif
|
|
|
|
txpower = 0;
|
|
|
|
if(packetbuf_attr(PACKETBUF_ATTR_RADIO_TXPOWER) > 0) {
|
|
/* Remember the current transmission power */
|
|
txpower = rf230_get_txpower();
|
|
/* Set the specified transmission power */
|
|
set_txpower(packetbuf_attr(PACKETBUF_ATTR_RADIO_TXPOWER) - 1);
|
|
}
|
|
|
|
total_len = payload_len + AUX_LEN;
|
|
|
|
#if RF230_CONF_TIMESTAMPS
|
|
rtimer_clock_t txtime = timesynch_time();
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
#if defined(__AVR_ATmega128RFA1__)
|
|
/* No interrupts across frame download! */
|
|
cli();
|
|
/* slow down the transmit? */
|
|
// delay_us(500);
|
|
#endif
|
|
/* Toggle the SLP_TR pin to initiate the frame transmission */
|
|
hal_set_slptr_high();
|
|
hal_set_slptr_low();
|
|
hal_frame_write(buffer, total_len);
|
|
#if defined(__AVR_ATmega128RFA1__)
|
|
sei();
|
|
#endif
|
|
PRINTF("rf230_transmit:\n");
|
|
#if DEBUG>1
|
|
/* Note the dumped packet will have a zero checksum unless compiled with RF230_CONF_CHECKSUM
|
|
* since we don't know what it will be if calculated by the hardware.
|
|
*/
|
|
{
|
|
uint8_t i;
|
|
PRINTF("0000"); //Start a new wireshark packet
|
|
for (i=0;i<total_len;i++) PRINTF(" %02x",buffer[i]);
|
|
PRINTF("\n");
|
|
}
|
|
#endif
|
|
|
|
if(RF230_receive_on) {
|
|
ENERGEST_OFF(ENERGEST_TYPE_LISTEN);
|
|
}
|
|
ENERGEST_ON(ENERGEST_TYPE_TRANSMIT);
|
|
|
|
#if RADIOSTATS
|
|
RF230_sendpackets++;
|
|
#endif
|
|
|
|
/* We wait until transmission has ended so that we get an
|
|
accurate measurement of the transmission time.*/
|
|
rf230_waitidle();
|
|
|
|
/* Get the transmission result */
|
|
#if RF230_CONF_AUTORETRIES
|
|
tx_result = hal_subregister_read(SR_TRAC_STATUS);
|
|
#else
|
|
tx_result=0;
|
|
#endif
|
|
|
|
#ifdef ENERGEST_CONF_LEVELDEVICE_LEVELS
|
|
ENERGEST_OFF_LEVEL(ENERGEST_TYPE_TRANSMIT,rf230_get_txpower());
|
|
#endif
|
|
|
|
/* Restore the transmission power */
|
|
if(packetbuf_attr(PACKETBUF_ATTR_RADIO_TXPOWER) > 0) {
|
|
set_txpower(txpower & 0xff);
|
|
}
|
|
|
|
/* Restore receive mode */
|
|
if(radiowason) {
|
|
// DEBUGFLOW('m');
|
|
on();
|
|
}
|
|
|
|
#if RF230_CONF_TIMESTAMPS
|
|
setup_time_for_transmission = txtime - timestamp.time;
|
|
|
|
if(num_transmissions < 10000) {
|
|
total_time_for_transmission += timesynch_time() - txtime;
|
|
total_transmission_len += total_len;
|
|
num_transmissions++;
|
|
}
|
|
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
|
|
ENERGEST_OFF(ENERGEST_TYPE_TRANSMIT);
|
|
if(RF230_receive_on) {
|
|
ENERGEST_ON(ENERGEST_TYPE_LISTEN);
|
|
} else {
|
|
#if RADIOALWAYSON
|
|
/* Enable reception */
|
|
on();
|
|
#else
|
|
/* Go to lower power TRX_OFF state (turn off PLL) */
|
|
hal_subregister_write(SR_TRX_CMD, CMD_FORCE_TRX_OFF);
|
|
#endif
|
|
}
|
|
|
|
RELEASE_LOCK();
|
|
|
|
if (tx_result==1) { //success, data pending from adressee
|
|
tx_result=0; //Just show success?
|
|
} else if (tx_result==3) { //CSMA channel access failure
|
|
RIMESTATS_ADD(contentiondrop);
|
|
PRINTF("rf230_transmit: Transmission never started\n");
|
|
//} else if (tx_result==5) { //Expected ACK, none received
|
|
//} else if (tx_result==7) { //Invalid (Can't happen since waited for idle above?)
|
|
}
|
|
|
|
return tx_result;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static int
|
|
rf230_prepare(const void *payload, unsigned short payload_len)
|
|
{
|
|
int ret = 0;
|
|
uint8_t total_len,*pbuf;
|
|
#if RF230_CONF_TIMESTAMPS
|
|
struct timestamp timestamp;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
#if RF230_CONF_CHECKSUM
|
|
uint16_t checksum;
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
|
|
GET_LOCK();
|
|
// DEBUGFLOW('P');
|
|
|
|
// PRINTF("rf230: sending %d bytes\n", payload_len);
|
|
// PRINTSHORT("s%d ",payload_len);
|
|
|
|
RIMESTATS_ADD(lltx);
|
|
|
|
#if RF230_CONF_CHECKSUM
|
|
checksum = crc16_data(payload, payload_len, 0);
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
|
|
/* Copy payload to RAM buffer */
|
|
total_len = payload_len + AUX_LEN;
|
|
if (total_len > RF230_MAX_TX_FRAME_LENGTH){
|
|
#if RADIOSTATS
|
|
RF230_sendfail++;
|
|
#endif
|
|
#if DEBUG
|
|
printf_P(PSTR("rf230_prepare: packet too large (%d, max: %d)\n"),total_len,RF230_MAX_TX_FRAME_LENGTH);
|
|
#endif
|
|
ret = -1;
|
|
goto bail;
|
|
}
|
|
pbuf=&buffer[0];
|
|
memcpy(pbuf,payload,payload_len);
|
|
pbuf+=payload_len;
|
|
|
|
#if RF230_CONF_CHECKSUM
|
|
memcpy(pbuf,&checksum,CHECKSUM_LEN);
|
|
pbuf+=CHECKSUM_LEN;
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
|
|
#if RF230_CONF_TIMESTAMPS
|
|
timestamp.authority_level = timesynch_authority_level();
|
|
timestamp.time = timesynch_time();
|
|
memcpy(pbuf,×tamp,TIMESTAMP_LEN);
|
|
pbuf+=TIMESTAMP_LEN;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
/*------------------------------------------------------------*/
|
|
|
|
#ifdef RF230BB_HOOK_TX_PACKET
|
|
#if !RF230_CONF_CHECKSUM
|
|
{ // Add a checksum before we log the packet out
|
|
uint16_t checksum;
|
|
checksum = crc16_data(payload, payload_len, 0);
|
|
memcpy(buffer+total_len-CHECKSUM_LEN,&checksum,CHECKSUM_LEN);
|
|
}
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
RF230BB_HOOK_TX_PACKET(buffer,total_len);
|
|
#endif
|
|
|
|
|
|
bail:
|
|
RELEASE_LOCK();
|
|
return ret;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static int
|
|
rf230_send(const void *payload, unsigned short payload_len)
|
|
{
|
|
int ret = 0;
|
|
|
|
#ifdef RF230BB_HOOK_IS_SEND_ENABLED
|
|
if(!RF230BB_HOOK_IS_SEND_ENABLED()) {
|
|
goto bail;
|
|
}
|
|
#endif
|
|
|
|
if((ret=rf230_prepare(payload, payload_len))) {
|
|
#if DEBUG
|
|
printf_P(PSTR("rf230_send: Unable to send, prep failed (%d)\n"),ret);
|
|
#endif
|
|
goto bail;
|
|
}
|
|
|
|
ret = rf230_transmit(payload_len);
|
|
|
|
bail:
|
|
#if RADIOSTATS
|
|
if (ret) RF230_sendfail++;
|
|
#endif
|
|
return ret;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
int
|
|
rf230_off(void)
|
|
{
|
|
/* Don't do anything if we are already turned off. */
|
|
if(RF230_receive_on == 0) {
|
|
return 1;
|
|
}
|
|
|
|
/* If we are called when the driver is locked, we indicate that the
|
|
radio should be turned off when the lock is unlocked. */
|
|
if(locked) {
|
|
lock_off = 1;
|
|
return 1;
|
|
}
|
|
|
|
/* If we are currently receiving a packet
|
|
we don't actually switch the radio off now, but signal that the
|
|
driver should switch off the radio once the packet has been
|
|
received and processed, by setting the 'lock_off' variable. */
|
|
if (!rf230_isidle()) {
|
|
// if (radio_get_trx_state()==BUSY_RX) {
|
|
lock_off = 1;
|
|
return 1;
|
|
}
|
|
|
|
off();
|
|
return 1;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
int
|
|
rf230_on(void)
|
|
{
|
|
if(RF230_receive_on) {
|
|
return 1;
|
|
}
|
|
if(locked) {
|
|
DEBUGFLOW('L');
|
|
lock_on = 1;
|
|
return 1;
|
|
}
|
|
|
|
on();
|
|
return 1;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
uint8_t
|
|
rf230_get_channel(void)
|
|
{
|
|
//jackdaw reads zero channel, raven reads correct channel?
|
|
//return hal_subregister_read(SR_CHANNEL);
|
|
return channel;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
void
|
|
rf230_set_channel(uint8_t c)
|
|
{
|
|
/* Wait for any transmission to end. */
|
|
PRINTF("rf230: Set Channel %u\n",c);
|
|
rf230_waitidle();
|
|
channel=c;
|
|
hal_subregister_write(SR_CHANNEL, c);
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
void
|
|
rf230_listen_channel(uint8_t c)
|
|
{
|
|
/* Same as set channel but forces RX_ON state for sniffer or energy scan */
|
|
// PRINTF("rf230: Listen Channel %u\n",c);
|
|
rf230_set_channel(c);
|
|
radio_set_trx_state(RX_ON);
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
void
|
|
rf230_set_pan_addr(unsigned pan,
|
|
unsigned addr,
|
|
const uint8_t ieee_addr[8])
|
|
//rf230_set_pan_addr(uint16_t pan,uint16_t addr,uint8_t *ieee_addr)
|
|
{
|
|
PRINTF("rf230: PAN=%x Short Addr=%x\n",pan,addr);
|
|
|
|
uint8_t abyte;
|
|
abyte = pan & 0xFF;
|
|
hal_register_write(RG_PAN_ID_0,abyte);
|
|
abyte = (pan >> 8*1) & 0xFF;
|
|
hal_register_write(RG_PAN_ID_1, abyte);
|
|
|
|
abyte = addr & 0xFF;
|
|
hal_register_write(RG_SHORT_ADDR_0, abyte);
|
|
abyte = (addr >> 8*1) & 0xFF;
|
|
hal_register_write(RG_SHORT_ADDR_1, abyte);
|
|
|
|
if (ieee_addr != NULL) {
|
|
PRINTF("MAC=%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_7, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_6, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_5, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_4, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_3, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_2, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_1, *ieee_addr++);
|
|
PRINTF(":%x",*ieee_addr);
|
|
hal_register_write(RG_IEEE_ADDR_0, *ieee_addr);
|
|
PRINTF("\n");
|
|
}
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
/*
|
|
* Interrupt leaves frame intact in FIFO.
|
|
*/
|
|
#if RF230_CONF_TIMESTAMPS
|
|
static volatile rtimer_clock_t interrupt_time;
|
|
static volatile int interrupt_time_set;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
#if RF230_TIMETABLE_PROFILING
|
|
#define rf230_timetable_size 16
|
|
TIMETABLE(rf230_timetable);
|
|
TIMETABLE_AGGREGATE(aggregate_time, 10);
|
|
#endif /* RF230_TIMETABLE_PROFILING */
|
|
int
|
|
rf230_interrupt(void)
|
|
{
|
|
/* Poll the receive process, unless the stack thinks the radio is off */
|
|
#if RADIOALWAYSON
|
|
if (RF230_receive_on) {
|
|
DEBUGFLOW('+');
|
|
#endif
|
|
#if RF230_CONF_TIMESTAMPS
|
|
interrupt_time = timesynch_time();
|
|
interrupt_time_set = 1;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
|
|
process_poll(&rf230_process);
|
|
|
|
#if RF230_TIMETABLE_PROFILING
|
|
timetable_clear(&rf230_timetable);
|
|
TIMETABLE_TIMESTAMP(rf230_timetable, "interrupt");
|
|
#endif /* RF230_TIMETABLE_PROFILING */
|
|
|
|
pending = 1;
|
|
|
|
#if RADIOSTATS //TODO:This will double count buffered packets
|
|
RF230_receivepackets++;
|
|
#endif
|
|
|
|
#if RADIOALWAYSON
|
|
} else {
|
|
DEBUGFLOW('-');
|
|
rxframe[rxframe_head].length=0;
|
|
}
|
|
#endif
|
|
return 1;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
/* Process to handle input packets
|
|
* Receive interrupts cause this process to be polled
|
|
* It calls the core MAC layer which calls rf230_read to get the packet
|
|
* rf230processflag can be printed in the main idle loop for debugging
|
|
*/
|
|
#if 0
|
|
uint8_t rf230processflag;
|
|
#define RF230PROCESSFLAG(arg) rf230processflag=arg
|
|
#else
|
|
#define RF230PROCESSFLAG(arg)
|
|
#endif
|
|
|
|
PROCESS_THREAD(rf230_process, ev, data)
|
|
{
|
|
int len;
|
|
PROCESS_BEGIN();
|
|
RF230PROCESSFLAG(99);
|
|
|
|
while(1) {
|
|
PROCESS_YIELD_UNTIL(ev == PROCESS_EVENT_POLL);
|
|
RF230PROCESSFLAG(42);
|
|
#if RF230_TIMETABLE_PROFILING
|
|
TIMETABLE_TIMESTAMP(rf230_timetable, "poll");
|
|
#endif /* RF230_TIMETABLE_PROFILING */
|
|
|
|
pending = 0;
|
|
|
|
packetbuf_clear();
|
|
len = rf230_read(packetbuf_dataptr(), PACKETBUF_SIZE);
|
|
RF230PROCESSFLAG(1);
|
|
if(len > 0) {
|
|
packetbuf_set_datalen(len);
|
|
RF230PROCESSFLAG(2);
|
|
NETSTACK_RDC.input();
|
|
#if RF230_TIMETABLE_PROFILING
|
|
TIMETABLE_TIMESTAMP(rf230_timetable, "end");
|
|
timetable_aggregate_compute_detailed(&aggregate_time,
|
|
&rf230_timetable);
|
|
timetable_clear(&rf230_timetable);
|
|
#endif /* RF230_TIMETABLE_PROFILING */
|
|
} else {
|
|
#if RADIOSTATS
|
|
RF230_receivefail++;
|
|
#endif
|
|
}
|
|
}
|
|
|
|
PROCESS_END();
|
|
}
|
|
/* Get packet from Radio if any, else return zero.
|
|
* The two-byte checksum is appended but the returned length does not include it.
|
|
* Frames are buffered in the interrupt routine so this routine
|
|
* does not access the hardware or change its status
|
|
*/
|
|
/*---------------------------------------------------------------------------*/
|
|
static int
|
|
rf230_read(void *buf, unsigned short bufsize)
|
|
{
|
|
uint8_t len,*framep;
|
|
#if FOOTER_LEN
|
|
uint8_t footer[FOOTER_LEN];
|
|
#endif /* FOOTER_LEN */
|
|
#if RF230_CONF_CHECKSUM
|
|
uint16_t checksum;
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
#if RF230_CONF_TIMESTAMPS
|
|
struct timestamp t;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
/* The length includes the twp-byte checksum but not the LQI byte */
|
|
len=rxframe[rxframe_head].length;
|
|
if (len==0) {
|
|
#if RADIOALWAYSON && DEBUGFLOWSIZE
|
|
if (RF230_receive_on==0) {if (debugflow[debugflowsize-1]!='z') DEBUGFLOW('z');} //cxmac calls with radio off?
|
|
#endif
|
|
return 0;
|
|
}
|
|
|
|
#if RADIOALWAYSON
|
|
if (RF230_receive_on) {
|
|
#endif
|
|
|
|
#if RF230_CONF_TIMESTAMPS
|
|
if(interrupt_time_set) {
|
|
rf230_time_of_arrival = interrupt_time;
|
|
interrupt_time_set = 0;
|
|
} else {
|
|
rf230_time_of_arrival = 0;
|
|
}
|
|
rf230_time_of_departure = 0;
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
|
|
// PRINTSHORT("r%d",rxframe[rxframe_head].length);
|
|
PRINTF("rf230_read: %u bytes lqi %u crc %u\n",rxframe[rxframe_head].length,rxframe[rxframe_head].lqi,rxframe[rxframe_head].crc);
|
|
#if DEBUG>1
|
|
{
|
|
uint8_t i;
|
|
PRINTF("0000");
|
|
for (i=0;i<rxframe[rxframe_head].length;i++) PRINTF(" %02x",rxframe[rxframe_head].data[i]);
|
|
PRINTF("\n");
|
|
}
|
|
#endif
|
|
|
|
// GET_LOCK();
|
|
|
|
//if(len > RF230_MAX_PACKET_LEN) {
|
|
if(len > RF230_MAX_TX_FRAME_LENGTH) {
|
|
/* Oops, we must be out of sync. */
|
|
DEBUGFLOW('y');
|
|
flushrx();
|
|
RIMESTATS_ADD(badsynch);
|
|
// RELEASE_LOCK();
|
|
return 0;
|
|
}
|
|
|
|
if(len <= AUX_LEN) {
|
|
DEBUGFLOW('s');
|
|
PRINTF("len <= AUX_LEN\n");
|
|
flushrx();
|
|
RIMESTATS_ADD(tooshort);
|
|
// RELEASE_LOCK();
|
|
return 0;
|
|
}
|
|
|
|
if(len - AUX_LEN > bufsize) {
|
|
DEBUGFLOW('b');
|
|
PRINTF("len - AUX_LEN > bufsize\n");
|
|
flushrx();
|
|
RIMESTATS_ADD(toolong);
|
|
// RELEASE_LOCK();
|
|
return 0;
|
|
}
|
|
/* Transfer the frame, stripping the footer, but copying the checksum */
|
|
framep=&(rxframe[rxframe_head].data[0]);
|
|
memcpy(buf,framep,len-AUX_LEN+CHECKSUM_LEN);
|
|
rf230_last_correlation = rxframe[rxframe_head].lqi;
|
|
|
|
/* Clear the length field to allow buffering of the next packet */
|
|
rxframe[rxframe_head].length=0;
|
|
rxframe_head++;if (rxframe_head >= RF230_CONF_RX_BUFFERS) rxframe_head=0;
|
|
/* If another packet has been buffered, schedule another receive poll */
|
|
if (rxframe[rxframe_head].length) rf230_interrupt();
|
|
|
|
/* Point to the checksum */
|
|
framep+=len-AUX_LEN;
|
|
#if RF230_CONF_CHECKSUM
|
|
memcpy(&checksum,framep,CHECKSUM_LEN);
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
framep+=CHECKSUM_LEN;
|
|
#if RF230_CONF_TIMESTAMPS
|
|
memcpy(&t,framep,TIMESTAMP_LEN);
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
framep+=TIMESTAMP_LEN;
|
|
#if FOOTER_LEN
|
|
memcpy(footer,framep,FOOTER_LEN);
|
|
#endif
|
|
#if RF230_CONF_CHECKSUM
|
|
if(checksum != crc16_data(buf, len - AUX_LEN, 0)) {
|
|
DEBUGFLOW('K');
|
|
PRINTF("checksum failed 0x%04x != 0x%04x\n",
|
|
checksum, crc16_data(buf, len - AUX_LEN, 0));
|
|
}
|
|
#if FOOTER_LEN
|
|
if(footer[1] & FOOTER1_CRC_OK &&
|
|
checksum == crc16_data(buf, len - AUX_LEN, 0)) {
|
|
#endif
|
|
#endif /* RF230_CONF_CHECKSUM */
|
|
|
|
/* Get the received signal strength for the packet, 0-84 dB above rx threshold */
|
|
#if 0 //more general
|
|
rf230_last_rssi = rf230_get_raw_rssi();
|
|
#else //faster
|
|
#if RF230_CONF_AUTOACK
|
|
// rf230_last_rssi = hal_subregister_read(SR_ED_LEVEL); //0-84 resolution 1 dB
|
|
rf230_last_rssi = hal_register_read(RG_PHY_ED_LEVEL); //0-84, resolution 1 dB
|
|
#else
|
|
/* last_rssi will have been set at RX_START interrupt */
|
|
// rf230_last_rssi = 3*hal_subregister_read(SR_RSSI); //0-28 resolution 3 dB
|
|
#endif
|
|
#endif /* speed vs. generality */
|
|
|
|
// rf230_last_correlation = rxframe[rxframe_head].lqi;
|
|
packetbuf_set_attr(PACKETBUF_ATTR_RSSI, rf230_last_rssi);
|
|
packetbuf_set_attr(PACKETBUF_ATTR_LINK_QUALITY, rf230_last_correlation);
|
|
|
|
RIMESTATS_ADD(llrx);
|
|
|
|
#if RF230_CONF_TIMESTAMPS
|
|
rf230_time_of_departure =
|
|
t.time +
|
|
setup_time_for_transmission +
|
|
(total_time_for_transmission * (len - 2)) / total_transmission_len;
|
|
|
|
rf230_authority_level_of_sender = t.authority_level;
|
|
|
|
packetbuf_set_attr(PACKETBUF_ATTR_TIMESTAMP, t.time);
|
|
#endif /* RF230_CONF_TIMESTAMPS */
|
|
|
|
#if RF230_CONF_CHECKSUM
|
|
#if FOOTER_LEN
|
|
} else {
|
|
DEBUGFLOW('X');
|
|
PRINTF("bad crc");
|
|
RIMESTATS_ADD(badcrc);
|
|
len = AUX_LEN;
|
|
}
|
|
#endif
|
|
#endif
|
|
|
|
#ifdef RF230BB_HOOK_RX_PACKET
|
|
RF230BB_HOOK_RX_PACKET(buf,len);
|
|
#endif
|
|
|
|
/* Here return just the data length. The checksum is however still in the buffer for packet sniffing */
|
|
return len - AUX_LEN;
|
|
|
|
#if RADIOALWAYSON
|
|
} else {
|
|
DEBUGFLOW('R'); //Stack thought radio was off
|
|
return 0;
|
|
}
|
|
#endif
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
void
|
|
rf230_set_txpower(uint8_t power)
|
|
{
|
|
GET_LOCK();
|
|
set_txpower(power);
|
|
RELEASE_LOCK();
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
uint8_t
|
|
rf230_get_txpower(void)
|
|
{
|
|
uint8_t power = TX_PWR_UNDEFINED;
|
|
if (radio_is_sleeping()) {
|
|
PRINTF("rf230_get_txpower:Sleeping");
|
|
} else {
|
|
power = hal_subregister_read(SR_TX_PWR);
|
|
}
|
|
return power;
|
|
}
|
|
|
|
/*---------------------------------------------------------------------------*/
|
|
uint8_t
|
|
rf230_get_raw_rssi(void)
|
|
{
|
|
uint8_t rssi,state;
|
|
bool radio_was_off = 0;
|
|
|
|
/*The RSSI measurement should only be done in RX_ON or BUSY_RX.*/
|
|
if(!RF230_receive_on) {
|
|
radio_was_off = 1;
|
|
rf230_on();
|
|
}
|
|
|
|
/* The energy detect register is used in extended mode (since RSSI will read 0) */
|
|
/* The rssi register is multiplied by 3 to a consistent value from either register */
|
|
state=radio_get_trx_state();
|
|
if ((state==RX_AACK_ON) || (state==BUSY_RX_AACK)) {
|
|
// rssi = hal_subregister_read(SR_ED_LEVEL); //0-84, resolution 1 dB
|
|
rssi = hal_register_read(RG_PHY_ED_LEVEL); //0-84, resolution 1 dB
|
|
} else {
|
|
#if 0 // 3-clock shift and add is faster on machines with no hardware multiply
|
|
/* avr-gcc may have an -Os bug that uses the general subroutine for multiplying by 3 */
|
|
rssi = hal_subregister_read(SR_RSSI); //0-28, resolution 3 dB
|
|
rssi = (rssi << 1) + rssi; //*3
|
|
#else // 1 or 2 clock multiply, or compiler with correct optimization
|
|
rssi = 3 * hal_subregister_read(SR_RSSI);
|
|
#endif
|
|
|
|
}
|
|
|
|
if(radio_was_off) {
|
|
rf230_off();
|
|
}
|
|
return rssi;
|
|
}
|
|
|
|
/*---------------------------------------------------------------------------*/
|
|
static int
|
|
rf230_cca(void)
|
|
{
|
|
int cca;
|
|
int radio_was_off = 0;
|
|
|
|
/* If the radio is locked by an underlying thread (because we are
|
|
being invoked through an interrupt), we preted that the coast is
|
|
clear (i.e., no packet is currently being transmitted by a
|
|
neighbor). */
|
|
if(locked) {
|
|
return 1;
|
|
}
|
|
|
|
if(!RF230_receive_on) {
|
|
radio_was_off = 1;
|
|
rf230_on();
|
|
}
|
|
|
|
// cca = CCA_IS_1;
|
|
DEBUGFLOW('c');
|
|
cca=1;
|
|
|
|
if(radio_was_off) {
|
|
rf230_off();
|
|
}
|
|
return cca;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
int
|
|
rf230_receiving_packet(void)
|
|
{
|
|
uint8_t radio_state;
|
|
radio_state = hal_subregister_read(SR_TRX_STATUS);
|
|
if ((radio_state==BUSY_RX) || (radio_state==BUSY_RX_AACK)) {
|
|
DEBUGFLOW('B');
|
|
return 1;
|
|
} else {
|
|
return 0;
|
|
}
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
static int
|
|
pending_packet(void)
|
|
{
|
|
if (pending) DEBUGFLOW('p');
|
|
return pending;
|
|
}
|
|
/*---------------------------------------------------------------------------*/
|
|
|