JunMo Hong / stm-spirit1-rf-driver_for_cubebite2

180718 HJM : 8 Count sensing data RF send, certTest, temp(cold)Test

Fork of EV-COG-AD3029LZ by JunMo Hong

source/NanostackRfPhySpirit1.cpp@65:a16f0064110a, 2017-07-03 (annotated)

Committer:
Wolfgang Betz
Date:
Mon Jul 03 16:42:03 2017 +0200
Revision:
65:a16f0064110a
Parent:
64:28ef790e4ef7
Child:
68:247fd6e0ab66
Delay setting of `expecting_ack` to when TX was successful

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Wolfgang Betz 61:0e6aa2ea086f 1 #if MBED_CONF_RTOS_PRESENT
Wolfgang Betz 61:0e6aa2ea086f 2
Wolfgang Betz 38:5deec3ab2025 3 #include "NanostackRfPhySpirit1.h"
Wolfgang Betz 38:5deec3ab2025 4 #include "SimpleSpirit1.h"
Wolfgang Betz 38:5deec3ab2025 5 #include "nanostack/platform/arm_hal_phy.h"
Wolfgang Betz 38:5deec3ab2025 6 #include "platform/arm_hal_interrupt.h"
Wolfgang Betz 38:5deec3ab2025 7
Wolfgang Betz 38:5deec3ab2025 8 #include "mbed_trace.h"
Wolfgang Betz 38:5deec3ab2025 9 #define TRACE_GROUP "SPIRIT"
Wolfgang Betz 38:5deec3ab2025 10
Wolfgang Betz 59:5dbfc9faf1c5 11 /* Define beyond macro if you want to perform heavy debug tracing (includes tracing in IRQ context) */
Wolfgang Betz 38:5deec3ab2025 12 // #define HEAVY_TRACING
Wolfgang Betz 38:5deec3ab2025 13
Wolfgang Betz 38:5deec3ab2025 14 static phy_device_driver_s device_driver;
Wolfgang Betz 38:5deec3ab2025 15 static int8_t rf_radio_driver_id = -1;
Wolfgang Betz 38:5deec3ab2025 16
Wolfgang Betz 38:5deec3ab2025 17 const phy_rf_channel_configuration_s phy_subghz = {868000000, 1000000, 250000, 11, M_GFSK};
Wolfgang Betz 38:5deec3ab2025 18
Wolfgang Betz 38:5deec3ab2025 19 static phy_device_channel_page_s phy_channel_pages[] = {
Wolfgang Betz 62:44ab5af08199 20 {CHANNEL_PAGE_2, &phy_subghz},
Wolfgang Betz 62:44ab5af08199 21 {CHANNEL_PAGE_0, NULL}
Wolfgang Betz 38:5deec3ab2025 22 };
Wolfgang Betz 38:5deec3ab2025 23
Wolfgang Betz 38:5deec3ab2025 24 static uint8_t tx_sequence = 0xff;
Wolfgang Betz 38:5deec3ab2025 25 static uint8_t mac_tx_handle = 0;
Wolfgang Betz 38:5deec3ab2025 26
Wolfgang Betz 38:5deec3ab2025 27 static SimpleSpirit1 *rf_device = NULL;
Wolfgang Betz 38:5deec3ab2025 28 static uint8_t rf_rx_buf[MAX_PACKET_LEN];
Wolfgang Betz 38:5deec3ab2025 29
Wolfgang Betz 38:5deec3ab2025 30 static uint16_t stored_short_adr;
Wolfgang Betz 38:5deec3ab2025 31 static uint16_t stored_pan_id;
Wolfgang Betz 52:053dbc4b570f 32 static uint8_t stored_mac_address[8] = MBED_CONF_SPIRIT1_MAC_ADDRESS;
Wolfgang Betz 38:5deec3ab2025 33
Wolfgang Betz 38:5deec3ab2025 34 #define RF_SIG_ACK_NEEDED (1<<0)
Wolfgang Betz 53:b036a3a850e6 35 #define RF_SIG_CB_TX_DONE (1<<1)
Wolfgang Betz 53:b036a3a850e6 36 #define RF_SIG_CB_RX_RCVD (1<<2)
Wolfgang Betz 38:5deec3ab2025 37 static Thread rf_ack_sender(osPriorityRealtime);
Wolfgang Betz 38:5deec3ab2025 38 static volatile uint8_t rf_rx_sequence;
Wolfgang Betz 38:5deec3ab2025 39 static volatile bool rf_ack_sent = false;
Wolfgang Betz 64:28ef790e4ef7 40 static volatile bool expecting_ack = false;
Wolfgang Betz 65:a16f0064110a 41 static volatile bool need_ack = false;
Wolfgang Betz 38:5deec3ab2025 42
Wolfgang Betz 38:5deec3ab2025 43 /* MAC frame helper macros */
Wolfgang Betz 38:5deec3ab2025 44 #define MAC_FCF_FRAME_TYPE_MASK 0x0007
Wolfgang Betz 38:5deec3ab2025 45 #define MAC_FCF_FRAME_TYPE_SHIFT 0
Wolfgang Betz 38:5deec3ab2025 46 #define MAC_FCF_SECURITY_BIT_MASK 0x0008
Wolfgang Betz 38:5deec3ab2025 47 #define MAC_FCF_SECURITY_BIT_SHIFT 3
Wolfgang Betz 38:5deec3ab2025 48 #define MAC_FCF_PENDING_BIT_MASK 0x0010
Wolfgang Betz 38:5deec3ab2025 49 #define MAC_FCF_PENDING_BIT_SHIFT 4
Wolfgang Betz 38:5deec3ab2025 50 #define MAC_FCF_ACK_REQ_BIT_MASK 0x0020
Wolfgang Betz 38:5deec3ab2025 51 #define MAC_FCF_ACK_REQ_BIT_SHIFT 5
Wolfgang Betz 38:5deec3ab2025 52 #define MAC_FCF_INTRA_PANID_MASK 0x0040
Wolfgang Betz 38:5deec3ab2025 53 #define MAC_FCF_INTRA_PANID_SHIFT 6
Wolfgang Betz 38:5deec3ab2025 54 #define MAC_FCF_DST_ADDR_MASK 0x0c00
Wolfgang Betz 38:5deec3ab2025 55 #define MAC_FCF_DST_ADDR_SHIFT 10
Wolfgang Betz 38:5deec3ab2025 56 #define MAC_FCF_VERSION_MASK 0x3000
Wolfgang Betz 38:5deec3ab2025 57 #define MAC_FCF_VERSION_SHIFT 12
Wolfgang Betz 38:5deec3ab2025 58 #define MAC_FCF_SRC_ADDR_MASK 0xc000
Wolfgang Betz 38:5deec3ab2025 59 #define MAC_FCF_SRC_ADDR_SHIFT 14
Wolfgang Betz 38:5deec3ab2025 60
Wolfgang Betz 38:5deec3ab2025 61 /* MAC supported frame types */
Wolfgang Betz 38:5deec3ab2025 62 #define FC_BEACON_FRAME 0x00
Wolfgang Betz 38:5deec3ab2025 63 #define FC_DATA_FRAME 0x01
Wolfgang Betz 38:5deec3ab2025 64 #define FC_ACK_FRAME 0x02
Wolfgang Betz 38:5deec3ab2025 65 #define FC_CMD_FRAME 0x03
Wolfgang Betz 38:5deec3ab2025 66
Wolfgang Betz 38:5deec3ab2025 67 static void rf_if_lock(void)
Wolfgang Betz 38:5deec3ab2025 68 {
Wolfgang Betz 38:5deec3ab2025 69 platform_enter_critical();
Wolfgang Betz 38:5deec3ab2025 70 }
Wolfgang Betz 38:5deec3ab2025 71
Wolfgang Betz 38:5deec3ab2025 72 static void rf_if_unlock(void)
Wolfgang Betz 38:5deec3ab2025 73 {
Wolfgang Betz 38:5deec3ab2025 74 platform_exit_critical();
Wolfgang Betz 38:5deec3ab2025 75 }
Wolfgang Betz 38:5deec3ab2025 76
Wolfgang Betz 38:5deec3ab2025 77 static inline uint16_t rf_read_16_bit(uint8_t *data_ptr) { // little-endian
Wolfgang Betz 53:b036a3a850e6 78 uint16_t ret;
Wolfgang Betz 38:5deec3ab2025 79
Wolfgang Betz 53:b036a3a850e6 80 ret = ((uint16_t)data_ptr[0]) + (((uint16_t)data_ptr[1]) << 8);
Wolfgang Betz 53:b036a3a850e6 81 return ret;
Wolfgang Betz 38:5deec3ab2025 82 }
Wolfgang Betz 38:5deec3ab2025 83
Wolfgang Betz 38:5deec3ab2025 84 static int8_t rf_trigger_send(uint8_t *data_ptr, uint16_t data_length, uint8_t tx_handle, data_protocol_e data_protocol)
Wolfgang Betz 38:5deec3ab2025 85 {
Wolfgang Betz 38:5deec3ab2025 86 #ifndef NDEBUG
Wolfgang Betz 53:b036a3a850e6 87 debug_if(!(data_length >= 3), "\n\rassert failed in: %s (%d)\n\r", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 88 #endif
Wolfgang Betz 38:5deec3ab2025 89
Wolfgang Betz 53:b036a3a850e6 90 /* Give 'rf_ack_sender' a better chance to run */
Wolfgang Betz 53:b036a3a850e6 91 Thread::yield();
Wolfgang Betz 38:5deec3ab2025 92
Wolfgang Betz 53:b036a3a850e6 93 /* Get Lock */
Wolfgang Betz 53:b036a3a850e6 94 rf_if_lock();
Wolfgang Betz 38:5deec3ab2025 95
Wolfgang Betz 38:5deec3ab2025 96 /*Check if transmitter is busy*/
Wolfgang Betz 38:5deec3ab2025 97 if(rf_device->is_receiving()) { /* betzw - WAS: (rf_device->channel_clear() != 0)), do NOT use this but rather study and enable automatic CCA */
Wolfgang Betz 58:4208689e447e 98 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 99 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 58:4208689e447e 100 #endif
Wolfgang Betz 38:5deec3ab2025 101
Wolfgang Betz 62:44ab5af08199 102 /* Release Lock */
Wolfgang Betz 62:44ab5af08199 103 rf_if_unlock();
Wolfgang Betz 62:44ab5af08199 104
Wolfgang Betz 62:44ab5af08199 105 /*Return busy*/
Wolfgang Betz 62:44ab5af08199 106 return -1;
Wolfgang Betz 38:5deec3ab2025 107 } else {
Wolfgang Betz 62:44ab5af08199 108 uint16_t fcf = rf_read_16_bit(data_ptr);
Wolfgang Betz 38:5deec3ab2025 109
Wolfgang Betz 62:44ab5af08199 110 /*Check if transmitted data needs to be acked*/
Wolfgang Betz 62:44ab5af08199 111 if((fcf & MAC_FCF_ACK_REQ_BIT_MASK) >> MAC_FCF_ACK_REQ_BIT_SHIFT)
Wolfgang Betz 65:a16f0064110a 112 need_ack = true;
Wolfgang Betz 62:44ab5af08199 113 else
Wolfgang Betz 65:a16f0064110a 114 need_ack = false;
Wolfgang Betz 38:5deec3ab2025 115
Wolfgang Betz 62:44ab5af08199 116 /*Store the sequence number for ACK handling*/
Wolfgang Betz 62:44ab5af08199 117 tx_sequence = *(data_ptr + 2);
Wolfgang Betz 38:5deec3ab2025 118
Wolfgang Betz 62:44ab5af08199 119 /*Store TX handle*/
Wolfgang Betz 62:44ab5af08199 120 mac_tx_handle = tx_handle;
Wolfgang Betz 38:5deec3ab2025 121
Wolfgang Betz 38:5deec3ab2025 122 #ifdef HEAVY_TRACING
Wolfgang Betz 65:a16f0064110a 123 tr_info("%s (%d), len=%d, tx_handle=%x, tx_seq=%x, need_ack=%d (%x:%x, %x:%x, %x:%x, %x:%x)", __func__, __LINE__,
Wolfgang Betz 65:a16f0064110a 124 data_length, tx_handle, tx_sequence, need_ack,
Wolfgang Betz 62:44ab5af08199 125 data_ptr[3], data_ptr[4], data_ptr[5], data_ptr[6],
Wolfgang Betz 62:44ab5af08199 126 data_ptr[7], data_ptr[8], data_ptr[9], data_ptr[10]);
Wolfgang Betz 38:5deec3ab2025 127 #endif
Wolfgang Betz 38:5deec3ab2025 128
Wolfgang Betz 62:44ab5af08199 129 /*Send the packet*/
Wolfgang Betz 62:44ab5af08199 130 rf_device->send(data_ptr, data_length);
Wolfgang Betz 38:5deec3ab2025 131
Wolfgang Betz 62:44ab5af08199 132 /* Release Lock */
Wolfgang Betz 62:44ab5af08199 133 rf_if_unlock();
Wolfgang Betz 38:5deec3ab2025 134 }
Wolfgang Betz 38:5deec3ab2025 135
Wolfgang Betz 53:b036a3a850e6 136 /*Return success*/
Wolfgang Betz 38:5deec3ab2025 137 return 0;
Wolfgang Betz 38:5deec3ab2025 138 }
Wolfgang Betz 38:5deec3ab2025 139
Wolfgang Betz 38:5deec3ab2025 140 static int8_t rf_interface_state_control(phy_interface_state_e new_state, uint8_t rf_channel)
Wolfgang Betz 38:5deec3ab2025 141 {
Wolfgang Betz 38:5deec3ab2025 142 int8_t ret_val = 0;
Wolfgang Betz 38:5deec3ab2025 143 switch (new_state)
Wolfgang Betz 38:5deec3ab2025 144 {
Wolfgang Betz 62:44ab5af08199 145 /*Reset PHY driver and set to idle*/
Wolfgang Betz 62:44ab5af08199 146 case PHY_INTERFACE_RESET:
Wolfgang Betz 62:44ab5af08199 147 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 148 rf_device->reset_board();
Wolfgang Betz 62:44ab5af08199 149 break;
Wolfgang Betz 62:44ab5af08199 150 /*Disable PHY Interface driver*/
Wolfgang Betz 62:44ab5af08199 151 case PHY_INTERFACE_DOWN:
Wolfgang Betz 62:44ab5af08199 152 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 153 ret_val = rf_device->off();
Wolfgang Betz 62:44ab5af08199 154 if(ret_val != 0) ret_val = -1;
Wolfgang Betz 62:44ab5af08199 155 break;
Wolfgang Betz 62:44ab5af08199 156 /*Enable PHY Interface driver*/
Wolfgang Betz 62:44ab5af08199 157 case PHY_INTERFACE_UP:
Wolfgang Betz 62:44ab5af08199 158 ret_val = rf_device->on();
Wolfgang Betz 62:44ab5af08199 159 if(ret_val != 0) {
Wolfgang Betz 62:44ab5af08199 160 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 161 ret_val = -1;
Wolfgang Betz 62:44ab5af08199 162 break;
Wolfgang Betz 62:44ab5af08199 163 }
Wolfgang Betz 62:44ab5af08199 164 tr_debug("%s (%d) - channel: %d", __func__, __LINE__, (int)rf_channel);
Wolfgang Betz 62:44ab5af08199 165 rf_device->set_channel(rf_channel);
Wolfgang Betz 62:44ab5af08199 166 break;
Wolfgang Betz 62:44ab5af08199 167 /*Enable wireless interface ED scan mode*/
Wolfgang Betz 62:44ab5af08199 168 case PHY_INTERFACE_RX_ENERGY_STATE:
Wolfgang Betz 62:44ab5af08199 169 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 170 break;
Wolfgang Betz 62:44ab5af08199 171 /*Enable Sniffer state*/
Wolfgang Betz 62:44ab5af08199 172 case PHY_INTERFACE_SNIFFER_STATE:
Wolfgang Betz 62:44ab5af08199 173 // TODO - if we really need this - WAS: rf_setup_sniffer(rf_channel);
Wolfgang Betz 62:44ab5af08199 174 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 175 ret_val = -1;
Wolfgang Betz 62:44ab5af08199 176 break;
Wolfgang Betz 62:44ab5af08199 177 default:
Wolfgang Betz 62:44ab5af08199 178 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 179 break;
Wolfgang Betz 38:5deec3ab2025 180 }
Wolfgang Betz 38:5deec3ab2025 181 return ret_val;
Wolfgang Betz 38:5deec3ab2025 182 }
Wolfgang Betz 38:5deec3ab2025 183
Wolfgang Betz 38:5deec3ab2025 184 static int8_t rf_extension(phy_extension_type_e extension_type, uint8_t *data_ptr)
Wolfgang Betz 38:5deec3ab2025 185 {
Wolfgang Betz 38:5deec3ab2025 186 switch (extension_type)
Wolfgang Betz 38:5deec3ab2025 187 {
Wolfgang Betz 62:44ab5af08199 188 /*Control MAC pending bit for Indirect data transmission*/
Wolfgang Betz 62:44ab5af08199 189 case PHY_EXTENSION_CTRL_PENDING_BIT:
Wolfgang Betz 62:44ab5af08199 190 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 191 break;
Wolfgang Betz 38:5deec3ab2025 192
Wolfgang Betz 62:44ab5af08199 193 /*Return frame pending status*/
Wolfgang Betz 62:44ab5af08199 194 case PHY_EXTENSION_READ_LAST_ACK_PENDING_STATUS:
Wolfgang Betz 62:44ab5af08199 195 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 196 *data_ptr = 0;
Wolfgang Betz 62:44ab5af08199 197 break;
Wolfgang Betz 38:5deec3ab2025 198
Wolfgang Betz 62:44ab5af08199 199 /*Set channel, used for setting channel for energy scan*/
Wolfgang Betz 62:44ab5af08199 200 case PHY_EXTENSION_SET_CHANNEL:
Wolfgang Betz 62:44ab5af08199 201 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 202 break;
Wolfgang Betz 38:5deec3ab2025 203
Wolfgang Betz 62:44ab5af08199 204 /*Read energy on the channel*/
Wolfgang Betz 62:44ab5af08199 205 case PHY_EXTENSION_READ_CHANNEL_ENERGY:
Wolfgang Betz 62:44ab5af08199 206 // TODO: *data_ptr = rf_get_channel_energy();
Wolfgang Betz 62:44ab5af08199 207 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 208 *data_ptr = (int8_t)rf_device->get_last_rssi_dbm();
Wolfgang Betz 62:44ab5af08199 209 break;
Wolfgang Betz 38:5deec3ab2025 210
Wolfgang Betz 62:44ab5af08199 211 /*Read status of the link*/
Wolfgang Betz 62:44ab5af08199 212 case PHY_EXTENSION_READ_LINK_STATUS:
Wolfgang Betz 62:44ab5af08199 213 // TODO: *data_ptr = rf_get_link_status();
Wolfgang Betz 62:44ab5af08199 214 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 215 *data_ptr = rf_device->get_last_sqi(); // use SQI as link quality
Wolfgang Betz 62:44ab5af08199 216 break;
Wolfgang Betz 38:5deec3ab2025 217
Wolfgang Betz 62:44ab5af08199 218 default:
Wolfgang Betz 62:44ab5af08199 219 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 220 break;
Wolfgang Betz 38:5deec3ab2025 221 }
Wolfgang Betz 38:5deec3ab2025 222 return 0;
Wolfgang Betz 38:5deec3ab2025 223 }
Wolfgang Betz 38:5deec3ab2025 224
Wolfgang Betz 38:5deec3ab2025 225 static inline void rf_set_mac_address(uint8_t *ptr) {
Wolfgang Betz 53:b036a3a850e6 226 tr_debug("%s (%d), adr0=%x, adr1=%x, adr2=%x, adr3=%x, adr4=%x, adr5=%x, adr6=%x, adr7=%x",
Wolfgang Betz 62:44ab5af08199 227 __func__, __LINE__,
Wolfgang Betz 62:44ab5af08199 228 ptr[0], ptr[1], ptr[2], ptr[3], ptr[4], ptr[5], ptr[6], ptr[7]);
Wolfgang Betz 53:b036a3a850e6 229 for(int i = 0; i < 8; i++) {
Wolfgang Betz 62:44ab5af08199 230 stored_mac_address[i] = ptr[i];
Wolfgang Betz 53:b036a3a850e6 231 }
Wolfgang Betz 38:5deec3ab2025 232 }
Wolfgang Betz 38:5deec3ab2025 233
Wolfgang Betz 38:5deec3ab2025 234 static inline void rf_get_mac_address(uint8_t *ptr) {
Wolfgang Betz 53:b036a3a850e6 235 for(int i = 0; i < 8; i++) {
Wolfgang Betz 62:44ab5af08199 236 ptr[i] = stored_mac_address[i];
Wolfgang Betz 53:b036a3a850e6 237 }
Wolfgang Betz 53:b036a3a850e6 238 tr_debug("%s (%d), adr0=%x, adr1=%x, adr2=%x, adr3=%x, adr4=%x, adr5=%x, adr6=%x, adr7=%x",
Wolfgang Betz 62:44ab5af08199 239 __func__, __LINE__,
Wolfgang Betz 62:44ab5af08199 240 ptr[0], ptr[1], ptr[2], ptr[3], ptr[4], ptr[5], ptr[6], ptr[7]);
Wolfgang Betz 38:5deec3ab2025 241 }
Wolfgang Betz 38:5deec3ab2025 242
Wolfgang Betz 38:5deec3ab2025 243 static inline void rf_set_short_adr(uint8_t *ptr) {
Wolfgang Betz 53:b036a3a850e6 244 stored_short_adr = (ptr[0] << 8) + ptr[1]; // big-endian
Wolfgang Betz 53:b036a3a850e6 245 tr_debug("%s (%d), adr0=%x, adr1=%x, val=%d",
Wolfgang Betz 62:44ab5af08199 246 __func__, __LINE__,
Wolfgang Betz 62:44ab5af08199 247 ptr[0], ptr[1], stored_short_adr);
Wolfgang Betz 38:5deec3ab2025 248 }
Wolfgang Betz 38:5deec3ab2025 249
Wolfgang Betz 38:5deec3ab2025 250 static inline void rf_set_pan_id(uint8_t *ptr) {
Wolfgang Betz 53:b036a3a850e6 251 stored_pan_id = (ptr[0] << 8) + ptr[1]; // big-endian
Wolfgang Betz 53:b036a3a850e6 252 tr_debug("%s (%d), adr0=%x, adr1=%x, val=%d",
Wolfgang Betz 63:d7530f62ed93 253 __func__, __LINE__,
Wolfgang Betz 63:d7530f62ed93 254 ptr[0], ptr[1], stored_pan_id);
Wolfgang Betz 38:5deec3ab2025 255 }
Wolfgang Betz 38:5deec3ab2025 256
Wolfgang Betz 38:5deec3ab2025 257 static int8_t rf_address_write(phy_address_type_e address_type, uint8_t *address_ptr)
Wolfgang Betz 38:5deec3ab2025 258 {
Wolfgang Betz 38:5deec3ab2025 259 switch (address_type)
Wolfgang Betz 38:5deec3ab2025 260 {
Wolfgang Betz 62:44ab5af08199 261 /*Set 48-bit address*/
Wolfgang Betz 62:44ab5af08199 262 case PHY_MAC_48BIT:
Wolfgang Betz 62:44ab5af08199 263 /* Not used in this example */
Wolfgang Betz 62:44ab5af08199 264 // betzw - WAS: rf_set_mac_48bit(address_ptr);
Wolfgang Betz 62:44ab5af08199 265 break;
Wolfgang Betz 62:44ab5af08199 266 /*Set 64-bit address*/
Wolfgang Betz 62:44ab5af08199 267 case PHY_MAC_64BIT:
Wolfgang Betz 62:44ab5af08199 268 rf_set_mac_address(address_ptr);
Wolfgang Betz 62:44ab5af08199 269 break;
Wolfgang Betz 62:44ab5af08199 270 /*Set 16-bit address*/
Wolfgang Betz 62:44ab5af08199 271 case PHY_MAC_16BIT:
Wolfgang Betz 62:44ab5af08199 272 rf_set_short_adr(address_ptr);
Wolfgang Betz 62:44ab5af08199 273 break;
Wolfgang Betz 62:44ab5af08199 274 /*Set PAN Id*/
Wolfgang Betz 62:44ab5af08199 275 case PHY_MAC_PANID:
Wolfgang Betz 62:44ab5af08199 276 rf_set_pan_id(address_ptr);
Wolfgang Betz 62:44ab5af08199 277 break;
Wolfgang Betz 38:5deec3ab2025 278 }
Wolfgang Betz 38:5deec3ab2025 279
Wolfgang Betz 38:5deec3ab2025 280 return 0;
Wolfgang Betz 38:5deec3ab2025 281 }
Wolfgang Betz 38:5deec3ab2025 282
Wolfgang Betz 38:5deec3ab2025 283 /* Note: we are in IRQ context */
Wolfgang Betz 53:b036a3a850e6 284 static inline void rf_send_signal(int32_t signal) {
Wolfgang Betz 53:b036a3a850e6 285 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 286 tr_info("%s (%d): %d", __func__, __LINE__, signal);
Wolfgang Betz 53:b036a3a850e6 287 #endif
Wolfgang Betz 53:b036a3a850e6 288 rf_ack_sender.signal_set(signal);
Wolfgang Betz 53:b036a3a850e6 289 }
Wolfgang Betz 53:b036a3a850e6 290
Wolfgang Betz 64:28ef790e4ef7 291 static volatile phy_link_tx_status_e phy_status;
Wolfgang Betz 53:b036a3a850e6 292 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 293 static void rf_handle_ack(uint8_t seq_number)
Wolfgang Betz 38:5deec3ab2025 294 {
Wolfgang Betz 38:5deec3ab2025 295 /*Received ACK sequence must be equal with transmitted packet sequence*/
Wolfgang Betz 38:5deec3ab2025 296 if(tx_sequence == seq_number)
Wolfgang Betz 38:5deec3ab2025 297 {
Wolfgang Betz 38:5deec3ab2025 298 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 299 tr_info("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 300 #endif
Wolfgang Betz 38:5deec3ab2025 301
Wolfgang Betz 62:44ab5af08199 302 /*Call PHY TX Done API*/
Wolfgang Betz 62:44ab5af08199 303 if(device_driver.phy_tx_done_cb){
Wolfgang Betz 62:44ab5af08199 304 phy_status = PHY_LINK_TX_DONE;
Wolfgang Betz 62:44ab5af08199 305 rf_send_signal(RF_SIG_CB_TX_DONE);
Wolfgang Betz 62:44ab5af08199 306 }
Wolfgang Betz 38:5deec3ab2025 307 } else {
Wolfgang Betz 38:5deec3ab2025 308 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 309 tr_info("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 310 #endif
Wolfgang Betz 64:28ef790e4ef7 311
Wolfgang Betz 64:28ef790e4ef7 312 /*Call PHY TX Done API*/
Wolfgang Betz 64:28ef790e4ef7 313 if(device_driver.phy_tx_done_cb){
Wolfgang Betz 64:28ef790e4ef7 314 phy_status = PHY_LINK_TX_FAIL;
Wolfgang Betz 64:28ef790e4ef7 315 rf_send_signal(RF_SIG_CB_TX_DONE);
Wolfgang Betz 64:28ef790e4ef7 316 }
Wolfgang Betz 38:5deec3ab2025 317 }
Wolfgang Betz 38:5deec3ab2025 318 }
Wolfgang Betz 38:5deec3ab2025 319
Wolfgang Betz 38:5deec3ab2025 320 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 321 static inline bool rf_check_mac_address(uint8_t *dest) {
Wolfgang Betz 53:b036a3a850e6 322 for(int i = 0; i < 8; i++) {
Wolfgang Betz 63:d7530f62ed93 323 if(dest[i] != stored_mac_address[7-i]) {
Wolfgang Betz 63:d7530f62ed93 324 #ifdef HEAVY_TRACING
Wolfgang Betz 63:d7530f62ed93 325 tr_debug("%s (%d): i=%d, dest=%x, stored=%x",
Wolfgang Betz 63:d7530f62ed93 326 __func__, __LINE__,
Wolfgang Betz 63:d7530f62ed93 327 i, dest[i], stored_mac_address[7-i]);
Wolfgang Betz 63:d7530f62ed93 328 #endif
Wolfgang Betz 63:d7530f62ed93 329 return false;
Wolfgang Betz 63:d7530f62ed93 330 }
Wolfgang Betz 53:b036a3a850e6 331 }
Wolfgang Betz 53:b036a3a850e6 332 return true;
Wolfgang Betz 38:5deec3ab2025 333 }
Wolfgang Betz 38:5deec3ab2025 334
Wolfgang Betz 38:5deec3ab2025 335 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 336 /* Returns true if packet should be accepted */
Wolfgang Betz 38:5deec3ab2025 337 static bool rf_check_destination(int len, uint8_t *ack_requested) {
Wolfgang Betz 53:b036a3a850e6 338 uint8_t frame_type;
Wolfgang Betz 53:b036a3a850e6 339 uint16_t dst_pan_id;
Wolfgang Betz 53:b036a3a850e6 340 uint16_t dst_short_adr;
Wolfgang Betz 53:b036a3a850e6 341 uint8_t dst_addr_mode = 0x0; /*0x00 = no address 0x01 = reserved 0x02 = 16-bit short address 0x03 = 64-bit extended address */
Wolfgang Betz 53:b036a3a850e6 342 uint8_t src_addr_mode = 0x0; /*0x00 = no address 0x01 = reserved 0x02 = 16-bit short address 0x03 = 64-bit extended address */
Wolfgang Betz 53:b036a3a850e6 343 uint8_t min_size = 3; // FCF & SeqNr
Wolfgang Betz 53:b036a3a850e6 344 bool ret = false;
Wolfgang Betz 53:b036a3a850e6 345 #if defined(HEAVY_TRACING)
Wolfgang Betz 53:b036a3a850e6 346 bool panid_compr = false;
Wolfgang Betz 38:5deec3ab2025 347 #endif
Wolfgang Betz 38:5deec3ab2025 348
Wolfgang Betz 53:b036a3a850e6 349 if(len < 3) {
Wolfgang Betz 62:44ab5af08199 350 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 62:44ab5af08199 351 return false;
Wolfgang Betz 53:b036a3a850e6 352 }
Wolfgang Betz 38:5deec3ab2025 353
Wolfgang Betz 53:b036a3a850e6 354 uint16_t fcf = rf_read_16_bit(rf_rx_buf);
Wolfgang Betz 53:b036a3a850e6 355 frame_type = ((fcf & MAC_FCF_FRAME_TYPE_MASK) >> MAC_FCF_FRAME_TYPE_SHIFT);
Wolfgang Betz 53:b036a3a850e6 356 (*ack_requested) = ((fcf & MAC_FCF_ACK_REQ_BIT_MASK) >> MAC_FCF_ACK_REQ_BIT_SHIFT);
Wolfgang Betz 53:b036a3a850e6 357 dst_addr_mode = ((fcf & MAC_FCF_DST_ADDR_MASK) >> MAC_FCF_DST_ADDR_SHIFT);
Wolfgang Betz 53:b036a3a850e6 358 src_addr_mode = ((fcf & MAC_FCF_SRC_ADDR_MASK) >> MAC_FCF_SRC_ADDR_SHIFT);
Wolfgang Betz 53:b036a3a850e6 359 #if defined(HEAVY_TRACING)
Wolfgang Betz 53:b036a3a850e6 360 panid_compr = ((fcf & MAC_FCF_INTRA_PANID_MASK) >> MAC_FCF_INTRA_PANID_SHIFT);
Wolfgang Betz 38:5deec3ab2025 361 #endif
Wolfgang Betz 38:5deec3ab2025 362
Wolfgang Betz 38:5deec3ab2025 363 #ifdef HEAVY_TRACING
Wolfgang Betz 53:b036a3a850e6 364 tr_info("%s (%d): len=%d, ftype=%x, snr=%x, ack=%d, dst=%x, src=%x, intra=%d", __func__, __LINE__, len, frame_type,
Wolfgang Betz 62:44ab5af08199 365 rf_rx_buf[2], (*ack_requested), dst_addr_mode, src_addr_mode, panid_compr);
Wolfgang Betz 38:5deec3ab2025 366 #endif
Wolfgang Betz 38:5deec3ab2025 367
Wolfgang Betz 53:b036a3a850e6 368 if(frame_type == FC_ACK_FRAME) { // betzw: we support up to two different forms of ACK frames!
Wolfgang Betz 62:44ab5af08199 369 if((len == 3) && (dst_addr_mode == 0x0) && (src_addr_mode == 0x0)) {
Wolfgang Betz 62:44ab5af08199 370 ret = true;
Wolfgang Betz 62:44ab5af08199 371 }
Wolfgang Betz 38:5deec3ab2025 372
Wolfgang Betz 38:5deec3ab2025 373 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 374 tr_info("%s (%d): ret=%d", __func__, __LINE__, ret);
Wolfgang Betz 53:b036a3a850e6 375 #endif
Wolfgang Betz 62:44ab5af08199 376 (*ack_requested) = 0; // Never acknowledge ACK frames
Wolfgang Betz 62:44ab5af08199 377 return ret;
Wolfgang Betz 53:b036a3a850e6 378 }
Wolfgang Betz 53:b036a3a850e6 379
Wolfgang Betz 53:b036a3a850e6 380 switch(dst_addr_mode) {
Wolfgang Betz 62:44ab5af08199 381 case 0x00:
Wolfgang Betz 62:44ab5af08199 382 ret = true; // no check possible;
Wolfgang Betz 62:44ab5af08199 383 break;
Wolfgang Betz 63:d7530f62ed93 384
Wolfgang Betz 62:44ab5af08199 385 case 0x02:
Wolfgang Betz 62:44ab5af08199 386 min_size += 4; // pan id + short dest adr
Wolfgang Betz 53:b036a3a850e6 387
Wolfgang Betz 62:44ab5af08199 388 if(len < 5) {
Wolfgang Betz 53:b036a3a850e6 389 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 390 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 391 #endif
Wolfgang Betz 62:44ab5af08199 392 return false;
Wolfgang Betz 62:44ab5af08199 393 }
Wolfgang Betz 53:b036a3a850e6 394
Wolfgang Betz 62:44ab5af08199 395 dst_pan_id = rf_read_16_bit(&rf_rx_buf[3]);
Wolfgang Betz 63:d7530f62ed93 396 if((dst_pan_id != stored_pan_id) && (dst_pan_id != 0xFFFF)) {
Wolfgang Betz 53:b036a3a850e6 397 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 398 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 399 #endif
Wolfgang Betz 63:d7530f62ed93 400 return false;
Wolfgang Betz 62:44ab5af08199 401 }
Wolfgang Betz 53:b036a3a850e6 402
Wolfgang Betz 62:44ab5af08199 403 if(len < 7) {
Wolfgang Betz 53:b036a3a850e6 404 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 405 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 406 #endif
Wolfgang Betz 62:44ab5af08199 407 return false;
Wolfgang Betz 62:44ab5af08199 408 }
Wolfgang Betz 53:b036a3a850e6 409
Wolfgang Betz 62:44ab5af08199 410 dst_short_adr = rf_read_16_bit(&rf_rx_buf[5]);
Wolfgang Betz 63:d7530f62ed93 411 if((dst_short_adr != stored_short_adr) && (dst_short_adr != 0xFFFF)) {
Wolfgang Betz 53:b036a3a850e6 412 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 413 tr_debug("%s (%d): %d!=%d", __func__, __LINE__, dst_short_adr, stored_short_adr);
Wolfgang Betz 53:b036a3a850e6 414 #endif
Wolfgang Betz 63:d7530f62ed93 415 return false;
Wolfgang Betz 62:44ab5af08199 416 }
Wolfgang Betz 63:d7530f62ed93 417
Wolfgang Betz 63:d7530f62ed93 418 ret = true;
Wolfgang Betz 62:44ab5af08199 419 break;
Wolfgang Betz 63:d7530f62ed93 420
Wolfgang Betz 62:44ab5af08199 421 case 0x03:
Wolfgang Betz 62:44ab5af08199 422 min_size += 10; // pan id + dest mac addr
Wolfgang Betz 53:b036a3a850e6 423
Wolfgang Betz 62:44ab5af08199 424 if(len < 5) {
Wolfgang Betz 53:b036a3a850e6 425 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 426 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 427 #endif
Wolfgang Betz 62:44ab5af08199 428 return false;
Wolfgang Betz 62:44ab5af08199 429 }
Wolfgang Betz 53:b036a3a850e6 430
Wolfgang Betz 62:44ab5af08199 431 dst_pan_id = rf_read_16_bit(&rf_rx_buf[3]);
Wolfgang Betz 63:d7530f62ed93 432 if((dst_pan_id != stored_pan_id) && (dst_pan_id != 0xFFFF)) {
Wolfgang Betz 53:b036a3a850e6 433 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 434 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 435 #endif
Wolfgang Betz 63:d7530f62ed93 436 return false;
Wolfgang Betz 62:44ab5af08199 437 }
Wolfgang Betz 53:b036a3a850e6 438
Wolfgang Betz 62:44ab5af08199 439 if(len < 13) {
Wolfgang Betz 53:b036a3a850e6 440 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 441 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 442 #endif
Wolfgang Betz 62:44ab5af08199 443 return false;
Wolfgang Betz 62:44ab5af08199 444 }
Wolfgang Betz 53:b036a3a850e6 445
Wolfgang Betz 62:44ab5af08199 446 ret = rf_check_mac_address(&rf_rx_buf[5]);
Wolfgang Betz 63:d7530f62ed93 447
Wolfgang Betz 63:d7530f62ed93 448 if(!ret) {
Wolfgang Betz 63:d7530f62ed93 449 #ifdef HEAVY_TRACING
Wolfgang Betz 63:d7530f62ed93 450 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 63:d7530f62ed93 451 #endif
Wolfgang Betz 63:d7530f62ed93 452 return false;
Wolfgang Betz 63:d7530f62ed93 453 }
Wolfgang Betz 63:d7530f62ed93 454
Wolfgang Betz 62:44ab5af08199 455 break;
Wolfgang Betz 63:d7530f62ed93 456
Wolfgang Betz 62:44ab5af08199 457 default:
Wolfgang Betz 62:44ab5af08199 458 /* not supported */
Wolfgang Betz 53:b036a3a850e6 459 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 460 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 461 #endif
Wolfgang Betz 62:44ab5af08199 462 return false;
Wolfgang Betz 53:b036a3a850e6 463 }
Wolfgang Betz 53:b036a3a850e6 464
Wolfgang Betz 53:b036a3a850e6 465 if(ret && (*ack_requested)) {
Wolfgang Betz 62:44ab5af08199 466 rf_rx_sequence = rf_rx_buf[2];
Wolfgang Betz 53:b036a3a850e6 467 }
Wolfgang Betz 53:b036a3a850e6 468
Wolfgang Betz 53:b036a3a850e6 469 #ifdef HEAVY_TRACING
Wolfgang Betz 53:b036a3a850e6 470 tr_info("%s (%d), ret=%d, ack=%d", __func__, __LINE__, ret, (*ack_requested));
Wolfgang Betz 53:b036a3a850e6 471 #endif
Wolfgang Betz 53:b036a3a850e6 472 return ret;
Wolfgang Betz 38:5deec3ab2025 473 }
Wolfgang Betz 38:5deec3ab2025 474
Wolfgang Betz 53:b036a3a850e6 475 static uint16_t rf_buffer_len = 0;
Wolfgang Betz 53:b036a3a850e6 476 static uint8_t rf_sqi;
Wolfgang Betz 53:b036a3a850e6 477 static int8_t rf_rssi;
Wolfgang Betz 38:5deec3ab2025 478 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 479 static inline void rf_handle_rx_end(void)
Wolfgang Betz 38:5deec3ab2025 480 {
Wolfgang Betz 38:5deec3ab2025 481 uint8_t ack_requested = 0;
Wolfgang Betz 38:5deec3ab2025 482
Wolfgang Betz 38:5deec3ab2025 483 /* Get received data */
Wolfgang Betz 38:5deec3ab2025 484 rf_buffer_len = rf_device->read(rf_rx_buf, MAX_PACKET_LEN);
Wolfgang Betz 38:5deec3ab2025 485 if(!rf_buffer_len)
Wolfgang Betz 62:44ab5af08199 486 return;
Wolfgang Betz 38:5deec3ab2025 487
Wolfgang Betz 38:5deec3ab2025 488 #ifdef HEAVY_TRACING
Wolfgang Betz 53:b036a3a850e6 489 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 490 #endif
Wolfgang Betz 38:5deec3ab2025 491
Wolfgang Betz 53:b036a3a850e6 492 /* Check if packet should be accepted */
Wolfgang Betz 38:5deec3ab2025 493 if(!rf_check_destination(rf_buffer_len, &ack_requested)) {
Wolfgang Betz 38:5deec3ab2025 494 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 495 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 496 #endif
Wolfgang Betz 62:44ab5af08199 497 return;
Wolfgang Betz 38:5deec3ab2025 498 }
Wolfgang Betz 38:5deec3ab2025 499
Wolfgang Betz 38:5deec3ab2025 500 /* If waiting for ACK, check here if the packet is an ACK to a message previously sent */
Wolfgang Betz 64:28ef790e4ef7 501 if(expecting_ack) {
Wolfgang Betz 64:28ef790e4ef7 502 uint16_t fcf = rf_read_16_bit(rf_rx_buf);
Wolfgang Betz 64:28ef790e4ef7 503 expecting_ack = false;
Wolfgang Betz 64:28ef790e4ef7 504
Wolfgang Betz 64:28ef790e4ef7 505 if(((fcf & MAC_FCF_FRAME_TYPE_MASK) >> MAC_FCF_FRAME_TYPE_SHIFT) == FC_ACK_FRAME) {
Wolfgang Betz 64:28ef790e4ef7 506 /*Send sequence number in ACK handler*/
Wolfgang Betz 38:5deec3ab2025 507 #ifdef HEAVY_TRACING
Wolfgang Betz 64:28ef790e4ef7 508 tr_debug("%s (%d), len=%u", __func__, __LINE__, (unsigned int)rf_buffer_len);
Wolfgang Betz 38:5deec3ab2025 509 #endif
Wolfgang Betz 64:28ef790e4ef7 510 rf_handle_ack(rf_rx_buf[2]);
Wolfgang Betz 64:28ef790e4ef7 511 return;
Wolfgang Betz 64:28ef790e4ef7 512 } else {
Wolfgang Betz 64:28ef790e4ef7 513 /*Call PHY TX Done API*/
Wolfgang Betz 64:28ef790e4ef7 514 if(device_driver.phy_tx_done_cb){
Wolfgang Betz 64:28ef790e4ef7 515 phy_status = PHY_LINK_TX_FAIL;
Wolfgang Betz 64:28ef790e4ef7 516 rf_send_signal(RF_SIG_CB_TX_DONE);
Wolfgang Betz 64:28ef790e4ef7 517 }
Wolfgang Betz 64:28ef790e4ef7 518 }
Wolfgang Betz 38:5deec3ab2025 519 }
Wolfgang Betz 38:5deec3ab2025 520
Wolfgang Betz 38:5deec3ab2025 521 /* Kick off ACK sending */
Wolfgang Betz 38:5deec3ab2025 522 if(ack_requested) {
Wolfgang Betz 38:5deec3ab2025 523 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 524 tr_debug("%s (%d), len=%u", __func__, __LINE__, (unsigned int)rf_buffer_len);
Wolfgang Betz 38:5deec3ab2025 525 #endif
Wolfgang Betz 62:44ab5af08199 526 rf_send_signal(RF_SIG_ACK_NEEDED);
Wolfgang Betz 38:5deec3ab2025 527 }
Wolfgang Betz 38:5deec3ab2025 528
Wolfgang Betz 38:5deec3ab2025 529 /* Get link information */
Wolfgang Betz 38:5deec3ab2025 530 rf_rssi = (int8_t)rf_device->get_last_rssi_dbm();
Wolfgang Betz 38:5deec3ab2025 531 rf_sqi = (uint8_t)rf_device->get_last_sqi(); // use SQI as link quality
Wolfgang Betz 38:5deec3ab2025 532
Wolfgang Betz 38:5deec3ab2025 533 /* Note: Checksum of the packet must be checked and removed before entering here */
Wolfgang Betz 38:5deec3ab2025 534 /* TODO - betzw: what to do? */
Wolfgang Betz 38:5deec3ab2025 535
Wolfgang Betz 38:5deec3ab2025 536 #ifdef HEAVY_TRACING
Wolfgang Betz 53:b036a3a850e6 537 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 538 #endif
Wolfgang Betz 38:5deec3ab2025 539
Wolfgang Betz 53:b036a3a850e6 540 /* Send received data and link information to the network stack */
Wolfgang Betz 38:5deec3ab2025 541 if( device_driver.phy_rx_cb ){
Wolfgang Betz 62:44ab5af08199 542 rf_send_signal(RF_SIG_CB_RX_RCVD);
Wolfgang Betz 38:5deec3ab2025 543 }
Wolfgang Betz 38:5deec3ab2025 544 }
Wolfgang Betz 38:5deec3ab2025 545
Wolfgang Betz 38:5deec3ab2025 546 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 547 static inline void rf_handle_tx_end(void)
Wolfgang Betz 38:5deec3ab2025 548 {
Wolfgang Betz 38:5deec3ab2025 549 /* Check if this is an ACK sending which is still pending */
Wolfgang Betz 53:b036a3a850e6 550 if(rf_ack_sent) {
Wolfgang Betz 62:44ab5af08199 551 rf_ack_sent = false;
Wolfgang Betz 38:5deec3ab2025 552 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 553 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 554 #endif
Wolfgang Betz 62:44ab5af08199 555 return; // no need to inform stack
Wolfgang Betz 53:b036a3a850e6 556 }
Wolfgang Betz 38:5deec3ab2025 557
Wolfgang Betz 65:a16f0064110a 558 /* Transform `need_ack` in `expecting_ack` */
Wolfgang Betz 65:a16f0064110a 559 if(need_ack) {
Wolfgang Betz 65:a16f0064110a 560 need_ack = false;
Wolfgang Betz 65:a16f0064110a 561 expecting_ack = true;
Wolfgang Betz 65:a16f0064110a 562 }
Wolfgang Betz 65:a16f0064110a 563
Wolfgang Betz 38:5deec3ab2025 564 /*Call PHY TX Done API*/
Wolfgang Betz 38:5deec3ab2025 565 if(device_driver.phy_tx_done_cb){
Wolfgang Betz 65:a16f0064110a 566 phy_status = PHY_LINK_TX_SUCCESS;
Wolfgang Betz 62:44ab5af08199 567 rf_send_signal(RF_SIG_CB_TX_DONE);
Wolfgang Betz 38:5deec3ab2025 568 }
Wolfgang Betz 38:5deec3ab2025 569 }
Wolfgang Betz 38:5deec3ab2025 570
Wolfgang Betz 38:5deec3ab2025 571 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 572 static inline void rf_handle_tx_err(void) {
Wolfgang Betz 38:5deec3ab2025 573 /*Call PHY TX Done API*/
Wolfgang Betz 38:5deec3ab2025 574 if(device_driver.phy_tx_done_cb){
Wolfgang Betz 65:a16f0064110a 575 need_ack = false;
Wolfgang Betz 62:44ab5af08199 576 phy_status = PHY_LINK_TX_FAIL;
Wolfgang Betz 62:44ab5af08199 577 rf_send_signal(RF_SIG_CB_TX_DONE);
Wolfgang Betz 38:5deec3ab2025 578 }
Wolfgang Betz 38:5deec3ab2025 579 }
Wolfgang Betz 38:5deec3ab2025 580
Wolfgang Betz 38:5deec3ab2025 581 /* Note: we are in IRQ context */
Wolfgang Betz 38:5deec3ab2025 582 static void rf_callback_func(int event) {
Wolfgang Betz 53:b036a3a850e6 583 switch(event) {
Wolfgang Betz 62:44ab5af08199 584 case SimpleSpirit1::RX_DONE:
Wolfgang Betz 62:44ab5af08199 585 rf_handle_rx_end();
Wolfgang Betz 62:44ab5af08199 586 break;
Wolfgang Betz 62:44ab5af08199 587 case SimpleSpirit1::TX_DONE:
Wolfgang Betz 62:44ab5af08199 588 rf_handle_tx_end();
Wolfgang Betz 62:44ab5af08199 589 break;
Wolfgang Betz 62:44ab5af08199 590 case SimpleSpirit1::TX_ERR:
Wolfgang Betz 38:5deec3ab2025 591 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 592 tr_debug("%s (%d): TX_ERR!!!", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 593 #endif
Wolfgang Betz 62:44ab5af08199 594 rf_handle_tx_err();
Wolfgang Betz 62:44ab5af08199 595 break;
Wolfgang Betz 53:b036a3a850e6 596 }
Wolfgang Betz 38:5deec3ab2025 597 }
Wolfgang Betz 38:5deec3ab2025 598
Wolfgang Betz 38:5deec3ab2025 599 static void rf_ack_loop(void) {
Wolfgang Betz 53:b036a3a850e6 600 static uint16_t buffer[2] = {
Wolfgang Betz 62:44ab5af08199 601 (FC_ACK_FRAME << MAC_FCF_FRAME_TYPE_SHIFT),
Wolfgang Betz 62:44ab5af08199 602 0x0
Wolfgang Betz 53:b036a3a850e6 603 };
Wolfgang Betz 53:b036a3a850e6 604
Wolfgang Betz 53:b036a3a850e6 605 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 606
Wolfgang Betz 53:b036a3a850e6 607 do {
Wolfgang Betz 62:44ab5af08199 608 /* Wait for signal */
Wolfgang Betz 62:44ab5af08199 609 osEvent event = rf_ack_sender.signal_wait(0);
Wolfgang Betz 38:5deec3ab2025 610
Wolfgang Betz 62:44ab5af08199 611 if(event.status != osEventSignal) {
Wolfgang Betz 53:b036a3a850e6 612 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 613 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 614 #endif
Wolfgang Betz 62:44ab5af08199 615 continue;
Wolfgang Betz 62:44ab5af08199 616 }
Wolfgang Betz 53:b036a3a850e6 617
Wolfgang Betz 62:44ab5af08199 618 int32_t signals = event.value.signals;
Wolfgang Betz 38:5deec3ab2025 619
Wolfgang Betz 38:5deec3ab2025 620 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 621 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 622 #endif
Wolfgang Betz 38:5deec3ab2025 623
Wolfgang Betz 62:44ab5af08199 624 /* Get Lock */
Wolfgang Betz 62:44ab5af08199 625 rf_if_lock();
Wolfgang Betz 53:b036a3a850e6 626
Wolfgang Betz 62:44ab5af08199 627 if(signals & RF_SIG_ACK_NEEDED) {
Wolfgang Betz 53:b036a3a850e6 628 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 629 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 630 #endif
Wolfgang Betz 53:b036a3a850e6 631
Wolfgang Betz 62:44ab5af08199 632 /* Prepare payload */
Wolfgang Betz 62:44ab5af08199 633 uint8_t *ptr = (uint8_t*)&buffer[1];
Wolfgang Betz 62:44ab5af08199 634 ptr[0] = rf_rx_sequence; // Sequence number
Wolfgang Betz 38:5deec3ab2025 635
Wolfgang Betz 62:44ab5af08199 636 /* Wait for device not receiving */
Wolfgang Betz 62:44ab5af08199 637 while(rf_device->is_receiving()) {
Wolfgang Betz 53:b036a3a850e6 638 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 639 tr_info("%s (%d)", __func__, __LINE__);
Wolfgang Betz 53:b036a3a850e6 640 #endif
Wolfgang Betz 62:44ab5af08199 641 wait_us(10);
Wolfgang Betz 62:44ab5af08199 642 }
Wolfgang Betz 53:b036a3a850e6 643
Wolfgang Betz 53:b036a3a850e6 644 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 645 tr_debug("%s (%d), hdr=%x, nr=%x", __func__, __LINE__, buffer[0], ptr[0]);
Wolfgang Betz 53:b036a3a850e6 646 #endif
Wolfgang Betz 53:b036a3a850e6 647
Wolfgang Betz 62:44ab5af08199 648 /* Set information that we have sent an ACK */
Wolfgang Betz 62:44ab5af08199 649 rf_ack_sent = true;
Wolfgang Betz 53:b036a3a850e6 650
Wolfgang Betz 62:44ab5af08199 651 /*Send the packet*/
Wolfgang Betz 64:28ef790e4ef7 652 rf_device->send((uint8_t*)buffer, 3, false);
Wolfgang Betz 53:b036a3a850e6 653
Wolfgang Betz 58:4208689e447e 654 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 655 tr_debug("%s (%d), hdr=%x, nr=%x", __func__, __LINE__, buffer[0], ptr[0]);
Wolfgang Betz 58:4208689e447e 656 #endif
Wolfgang Betz 62:44ab5af08199 657 }
Wolfgang Betz 53:b036a3a850e6 658
Wolfgang Betz 62:44ab5af08199 659 if(signals & RF_SIG_CB_TX_DONE) {
Wolfgang Betz 62:44ab5af08199 660 device_driver.phy_tx_done_cb(rf_radio_driver_id, mac_tx_handle, phy_status, 0, 0);
Wolfgang Betz 38:5deec3ab2025 661 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 662 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 663 #endif
Wolfgang Betz 62:44ab5af08199 664 }
Wolfgang Betz 38:5deec3ab2025 665
Wolfgang Betz 62:44ab5af08199 666 if(signals & RF_SIG_CB_RX_RCVD) {
Wolfgang Betz 62:44ab5af08199 667 device_driver.phy_rx_cb(rf_rx_buf, rf_buffer_len, rf_sqi, rf_rssi, rf_radio_driver_id);
Wolfgang Betz 38:5deec3ab2025 668 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 669 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 670 #endif
Wolfgang Betz 62:44ab5af08199 671 }
Wolfgang Betz 38:5deec3ab2025 672
Wolfgang Betz 62:44ab5af08199 673 /* Release Lock */
Wolfgang Betz 62:44ab5af08199 674 rf_if_unlock();
Wolfgang Betz 38:5deec3ab2025 675
Wolfgang Betz 38:5deec3ab2025 676 #ifdef HEAVY_TRACING
Wolfgang Betz 62:44ab5af08199 677 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 678 #endif
Wolfgang Betz 53:b036a3a850e6 679 } while(true);
Wolfgang Betz 38:5deec3ab2025 680 }
Wolfgang Betz 38:5deec3ab2025 681
Wolfgang Betz 38:5deec3ab2025 682 void NanostackRfPhySpirit1::rf_init(void) {
Wolfgang Betz 38:5deec3ab2025 683 #ifndef NDEBUG
Wolfgang Betz 53:b036a3a850e6 684 osStatus ret;
Wolfgang Betz 38:5deec3ab2025 685 #endif
Wolfgang Betz 38:5deec3ab2025 686
Wolfgang Betz 53:b036a3a850e6 687 if(rf_device == NULL) {
Wolfgang Betz 62:44ab5af08199 688 rf_device = &SimpleSpirit1::CreateInstance(_spi_mosi, _spi_miso, _spi_sclk, _dev_irq, _dev_cs, _dev_sdn, _brd_led);
Wolfgang Betz 62:44ab5af08199 689 rf_device->attach_irq_callback(rf_callback_func);
Wolfgang Betz 38:5deec3ab2025 690
Wolfgang Betz 38:5deec3ab2025 691 #ifndef NDEBUG
Wolfgang Betz 62:44ab5af08199 692 ret =
Wolfgang Betz 38:5deec3ab2025 693 #endif
Wolfgang Betz 62:44ab5af08199 694 rf_ack_sender.start(rf_ack_loop);
Wolfgang Betz 38:5deec3ab2025 695
Wolfgang Betz 38:5deec3ab2025 696 #ifndef NDEBUG
Wolfgang Betz 62:44ab5af08199 697 debug_if(!(ret == osOK), "\n\rassert failed in: %s (%d)\n\r", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 698 #endif
Wolfgang Betz 53:b036a3a850e6 699 }
Wolfgang Betz 38:5deec3ab2025 700 }
Wolfgang Betz 38:5deec3ab2025 701
Wolfgang Betz 38:5deec3ab2025 702 NanostackRfPhySpirit1::NanostackRfPhySpirit1(PinName spi_mosi, PinName spi_miso, PinName spi_sclk,
Wolfgang Betz 62:44ab5af08199 703 PinName dev_irq, PinName dev_cs, PinName dev_sdn, PinName brd_led) :
Wolfgang Betz 63:d7530f62ed93 704 _spi_mosi(spi_mosi),
Wolfgang Betz 63:d7530f62ed93 705 _spi_miso(spi_miso),
Wolfgang Betz 63:d7530f62ed93 706 _spi_sclk(spi_sclk),
Wolfgang Betz 63:d7530f62ed93 707 _dev_irq(dev_irq),
Wolfgang Betz 63:d7530f62ed93 708 _dev_cs(dev_cs),
Wolfgang Betz 63:d7530f62ed93 709 _dev_sdn(dev_sdn),
Wolfgang Betz 63:d7530f62ed93 710 _brd_led(brd_led)
Wolfgang Betz 38:5deec3ab2025 711 {
Wolfgang Betz 53:b036a3a850e6 712 /* Nothing to do */
Wolfgang Betz 53:b036a3a850e6 713 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 714 }
Wolfgang Betz 38:5deec3ab2025 715
Wolfgang Betz 38:5deec3ab2025 716 NanostackRfPhySpirit1::~NanostackRfPhySpirit1()
Wolfgang Betz 38:5deec3ab2025 717 {
Wolfgang Betz 53:b036a3a850e6 718 /* Nothing to do */
Wolfgang Betz 53:b036a3a850e6 719 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 720 }
Wolfgang Betz 38:5deec3ab2025 721
Wolfgang Betz 38:5deec3ab2025 722 int8_t NanostackRfPhySpirit1::rf_register()
Wolfgang Betz 38:5deec3ab2025 723 {
Wolfgang Betz 53:b036a3a850e6 724 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 725
Wolfgang Betz 53:b036a3a850e6 726 /* Get Lock */
Wolfgang Betz 53:b036a3a850e6 727 rf_if_lock();
Wolfgang Betz 38:5deec3ab2025 728
Wolfgang Betz 38:5deec3ab2025 729 /* Do some initialization */
Wolfgang Betz 38:5deec3ab2025 730 rf_init();
Wolfgang Betz 38:5deec3ab2025 731
Wolfgang Betz 38:5deec3ab2025 732 /* Set pointer to MAC address */
Wolfgang Betz 38:5deec3ab2025 733 device_driver.PHY_MAC = stored_mac_address;
Wolfgang Betz 38:5deec3ab2025 734
Wolfgang Betz 38:5deec3ab2025 735 /* Set driver Name */
Wolfgang Betz 38:5deec3ab2025 736 device_driver.driver_description = (char*)"Spirit1 Sub-GHz RF";
Wolfgang Betz 38:5deec3ab2025 737
Wolfgang Betz 38:5deec3ab2025 738 /*Type of RF PHY is SubGHz*/
Wolfgang Betz 38:5deec3ab2025 739 device_driver.link_type = PHY_LINK_15_4_SUBGHZ_TYPE;
Wolfgang Betz 38:5deec3ab2025 740
Wolfgang Betz 39:75481c4c6655 741 /*Maximum size of payload*/
Wolfgang Betz 38:5deec3ab2025 742 device_driver.phy_MTU = MAX_PACKET_LEN;
Wolfgang Betz 38:5deec3ab2025 743
Wolfgang Betz 38:5deec3ab2025 744 /*No header in PHY*/
Wolfgang Betz 38:5deec3ab2025 745 device_driver.phy_header_length = 0;
Wolfgang Betz 38:5deec3ab2025 746
Wolfgang Betz 38:5deec3ab2025 747 /*No tail in PHY*/
Wolfgang Betz 38:5deec3ab2025 748 device_driver.phy_tail_length = 0;
Wolfgang Betz 38:5deec3ab2025 749
Wolfgang Betz 38:5deec3ab2025 750 /*Set up driver functions*/
Wolfgang Betz 38:5deec3ab2025 751 device_driver.address_write = &rf_address_write;
Wolfgang Betz 38:5deec3ab2025 752 device_driver.extension = &rf_extension;
Wolfgang Betz 38:5deec3ab2025 753 device_driver.state_control = &rf_interface_state_control;
Wolfgang Betz 38:5deec3ab2025 754 device_driver.tx = &rf_trigger_send;
Wolfgang Betz 38:5deec3ab2025 755
Wolfgang Betz 38:5deec3ab2025 756 /*Set supported channel pages*/
Wolfgang Betz 38:5deec3ab2025 757 device_driver.phy_channel_pages = phy_channel_pages;
Wolfgang Betz 38:5deec3ab2025 758
Wolfgang Betz 38:5deec3ab2025 759 //Nullify rx/tx callbacks
Wolfgang Betz 38:5deec3ab2025 760 device_driver.phy_rx_cb = NULL;
Wolfgang Betz 38:5deec3ab2025 761 device_driver.phy_tx_done_cb = NULL;
Wolfgang Betz 38:5deec3ab2025 762 device_driver.arm_net_virtual_rx_cb = NULL;
Wolfgang Betz 38:5deec3ab2025 763 device_driver.arm_net_virtual_tx_cb = NULL;
Wolfgang Betz 38:5deec3ab2025 764
Wolfgang Betz 38:5deec3ab2025 765 /*Register device driver*/
Wolfgang Betz 38:5deec3ab2025 766 rf_radio_driver_id = arm_net_phy_register(&device_driver);
Wolfgang Betz 38:5deec3ab2025 767
Wolfgang Betz 53:b036a3a850e6 768 /* Release Lock */
Wolfgang Betz 53:b036a3a850e6 769 rf_if_unlock();
Wolfgang Betz 38:5deec3ab2025 770
Wolfgang Betz 53:b036a3a850e6 771 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 772 return rf_radio_driver_id;
Wolfgang Betz 38:5deec3ab2025 773 }
Wolfgang Betz 38:5deec3ab2025 774
Wolfgang Betz 38:5deec3ab2025 775 void NanostackRfPhySpirit1::rf_unregister()
Wolfgang Betz 38:5deec3ab2025 776 {
Wolfgang Betz 53:b036a3a850e6 777 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 778
Wolfgang Betz 53:b036a3a850e6 779 /* Get Lock */
Wolfgang Betz 53:b036a3a850e6 780 rf_if_lock();
Wolfgang Betz 38:5deec3ab2025 781
Wolfgang Betz 38:5deec3ab2025 782 if (rf_radio_driver_id >= 0) {
Wolfgang Betz 38:5deec3ab2025 783 arm_net_phy_unregister(rf_radio_driver_id);
Wolfgang Betz 38:5deec3ab2025 784 rf_radio_driver_id = -1;
Wolfgang Betz 38:5deec3ab2025 785 }
Wolfgang Betz 38:5deec3ab2025 786
Wolfgang Betz 53:b036a3a850e6 787 /* Release Lock */
Wolfgang Betz 53:b036a3a850e6 788 rf_if_unlock();
Wolfgang Betz 38:5deec3ab2025 789 }
Wolfgang Betz 38:5deec3ab2025 790
Wolfgang Betz 38:5deec3ab2025 791 void NanostackRfPhySpirit1::get_mac_address(uint8_t *mac)
Wolfgang Betz 38:5deec3ab2025 792 {
Wolfgang Betz 53:b036a3a850e6 793 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 794
Wolfgang Betz 53:b036a3a850e6 795 /* Get Lock */
Wolfgang Betz 53:b036a3a850e6 796 rf_if_lock();
Wolfgang Betz 38:5deec3ab2025 797
Wolfgang Betz 53:b036a3a850e6 798 if(rf_radio_driver_id >= 0) {
Wolfgang Betz 62:44ab5af08199 799 rf_get_mac_address(mac);
Wolfgang Betz 53:b036a3a850e6 800 } else {
Wolfgang Betz 38:5deec3ab2025 801 error("NanostackRfPhySpirit1 must be registered to read mac address");
Wolfgang Betz 53:b036a3a850e6 802 }
Wolfgang Betz 38:5deec3ab2025 803
Wolfgang Betz 53:b036a3a850e6 804 /* Release Lock */
Wolfgang Betz 53:b036a3a850e6 805 rf_if_unlock();
Wolfgang Betz 38:5deec3ab2025 806 }
Wolfgang Betz 38:5deec3ab2025 807
Wolfgang Betz 38:5deec3ab2025 808 void NanostackRfPhySpirit1::set_mac_address(uint8_t *mac)
Wolfgang Betz 38:5deec3ab2025 809 {
Wolfgang Betz 53:b036a3a850e6 810 tr_debug("%s (%d)", __func__, __LINE__);
Wolfgang Betz 38:5deec3ab2025 811
Wolfgang Betz 53:b036a3a850e6 812 /* Get Lock */
Wolfgang Betz 53:b036a3a850e6 813 rf_if_lock();
Wolfgang Betz 38:5deec3ab2025 814
Wolfgang Betz 53:b036a3a850e6 815 if(rf_radio_driver_id < 0) {
Wolfgang Betz 62:44ab5af08199 816 rf_set_mac_address(mac);
Wolfgang Betz 53:b036a3a850e6 817 } else {
Wolfgang Betz 38:5deec3ab2025 818 error("NanostackRfPhySpirit1 cannot change mac address when running");
Wolfgang Betz 53:b036a3a850e6 819 }
Wolfgang Betz 38:5deec3ab2025 820
Wolfgang Betz 53:b036a3a850e6 821 /* Release Lock */
Wolfgang Betz 53:b036a3a850e6 822 rf_if_unlock();
Wolfgang Betz 38:5deec3ab2025 823 }
Wolfgang Betz 61:0e6aa2ea086f 824
Wolfgang Betz 61:0e6aa2ea086f 825 #endif /* MBED_CONF_RTOS_PRESENT */