alan broad
/
carbon_v5_arm_studio
arm studio build
src/main.cpp@18:d95e1a2c4303, 2019-01-27 (annotated)
- Committer:
- alan1974
- Date:
- Sun Jan 27 15:27:53 2019 +0000
- Revision:
- 18:d95e1a2c4303
- Parent:
- 17:74d60177c6b6
- Child:
- 19:cff66b2c15b5
exit from end of mcast session (Class C) -> ClassA completed
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
alan1974 | 12:7944e4dbe853 | 1 | #include "mbed.h" |
alan1974 | 1:0d25d9ddbe9f | 2 | #include "global.h" |
alan1974 | 0:a91cd1b08360 | 3 | #include "commI2C.h" |
alan1974 | 0:a91cd1b08360 | 4 | #include "dot_util.h" |
alan1974 | 0:a91cd1b08360 | 5 | #include "wbit_util.h" |
alan1974 | 14:fc836a5a5d2f | 6 | #include "multicast.h" |
alan1974 | 0:a91cd1b08360 | 7 | #include "mDot.h" |
alan1974 | 0:a91cd1b08360 | 8 | #include "RadioEvent.h" |
alan1974 | 15:ed77b752eaa9 | 9 | #include "ChannelPlans.h" |
alan1974 | 0:a91cd1b08360 | 10 | #include "Lora.h" |
alan1974 | 0:a91cd1b08360 | 11 | |
alan1974 | 17:74d60177c6b6 | 12 | bool verbose = true; |
alan1974 | 17:74d60177c6b6 | 13 | bool bRxDone = false; //true if callback function RxDone() triggered |
alan1974 | 17:74d60177c6b6 | 14 | bool bDownLinkCntrFail = false; //true if callback function RxDone() triggered and bad downlink frame count |
alan1974 | 17:74d60177c6b6 | 15 | bool bListen4Multicast; |
alan1974 | 17:74d60177c6b6 | 16 | uint16_t maxMulticastSessionTime = 0; |
alan1974 | 1:0d25d9ddbe9f | 17 | //nvm storage params |
alan1974 | 17:74d60177c6b6 | 18 | nvm nvmData; |
alan1974 | 17:74d60177c6b6 | 19 | nvm *pNvmData = &nvmData; |
alan1974 | 1:0d25d9ddbe9f | 20 | |
alan1974 | 15:ed77b752eaa9 | 21 | |
alan1974 | 15:ed77b752eaa9 | 22 | |
alan1974 | 0:a91cd1b08360 | 23 | //======================================================================================================= |
alan1974 | 10:061fab1195e7 | 24 | // enable GPIO for scope trigger |
alan1974 | 0:a91cd1b08360 | 25 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 26 | //#define GPIO_ENABLE |
alan1974 | 0:a91cd1b08360 | 27 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 28 | // configure for either private (test only) or public network (standard) |
alan1974 | 0:a91cd1b08360 | 29 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 30 | //#define MT_PRIVATE_NETWORK //ENABLE THIS FOR PRIVATE NETWORK |
alan1974 | 0:a91cd1b08360 | 31 | |
alan1974 | 0:a91cd1b08360 | 32 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 33 | //code api level and version |
alan1974 | 0:a91cd1b08360 | 34 | //api_level: proc code will not run if api level (last two bytess) greater than what it expects |
alan1974 | 0:a91cd1b08360 | 35 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 36 | uint8_t api_level[4] = { 0x00, 0x00, 0x00, 0x03 }; //api-level, determines if xdot code works with proc code |
alan1974 | 12:7944e4dbe853 | 37 | uint8_t ver_level[4] = { 0x00, 0x00, 0x00, 0x09 }; //updated for every code check-in |
alan1974 | 0:a91cd1b08360 | 38 | |
alan1974 | 0:a91cd1b08360 | 39 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 40 | //configuring mbed pinsa; https://docs.mbed.com/docs/mbed-os-api-reference/en/latest/APIs/io/DigitalInOut/ |
alan1974 | 0:a91cd1b08360 | 41 | // * these options must match the settings on your gateway // |
alan1974 | 0:a91cd1b08360 | 42 | // * edit their values to match your configuration // |
alan1974 | 0:a91cd1b08360 | 43 | // * frequency sub band is only relevant for the 915 bands // |
alan1974 | 0:a91cd1b08360 | 44 | // * either the network name and passphrase can be used or // |
alan1974 | 0:a91cd1b08360 | 45 | // the network ID (8 bytes) and KEY (16 bytes) // |
alan1974 | 0:a91cd1b08360 | 46 | //======================================================================================================= |
alan1974 | 1:0d25d9ddbe9f | 47 | static std::string network_name = "asdfqwer"; //not used |
alan1974 | 1:0d25d9ddbe9f | 48 | static std::string network_passphrase = "zxcvasdf"; //not used |
alan1974 | 12:7944e4dbe853 | 49 | |
alan1974 | 0:a91cd1b08360 | 50 | |
alan1974 | 0:a91cd1b08360 | 51 | #ifdef MT_PRIVATE_NETWORK |
alan1974 | 0:a91cd1b08360 | 52 | static uint8_t frequency_sub_band = 4; |
alan1974 | 0:a91cd1b08360 | 53 | static bool public_network = false; |
alan1974 | 0:a91cd1b08360 | 54 | static uint8_t ack = 1; //0; |
alan1974 | 0:a91cd1b08360 | 55 | #else |
alan1974 | 1:0d25d9ddbe9f | 56 | uint8_t frequency_sub_band = 1; |
alan1974 | 1:0d25d9ddbe9f | 57 | bool public_network = true; //false |
alan1974 | 1:0d25d9ddbe9f | 58 | uint8_t ack = 1; //0; |
alan1974 | 1:0d25d9ddbe9f | 59 | uint8_t link_check_treshold = 100; //5; |
alan1974 | 0:a91cd1b08360 | 60 | #endif |
alan1974 | 0:a91cd1b08360 | 61 | |
alan1974 | 1:0d25d9ddbe9f | 62 | bool adr = false; //set adaptive data rate |
alan1974 | 10:061fab1195e7 | 63 | //======================================================================================================= |
alan1974 | 10:061fab1195e7 | 64 | // -need to add a delay between exiting i2c read->proc and before putting xdot to sleep to allow for final |
alan1974 | 10:061fab1195e7 | 65 | // xfr of bytes in i2c buffer to be xfrd to proc. If log output enabled then it causes enough delay when |
alan1974 | 10:061fab1195e7 | 66 | // it prints status info to make the delay ok. For now add this delay when both log enabled and disabled. |
alan1974 | 10:061fab1195e7 | 67 | int16_t wait_before_sleep_usec = 10000; |
alan1974 | 0:a91cd1b08360 | 68 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 69 | // deepsleep consumes slightly less current than sleep |
alan1974 | 15:ed77b752eaa9 | 70 | // sleep mode: IO state is maintained, RAM is retained, and application will resume after waking up |
alan1974 | 15:ed77b752eaa9 | 71 | // deepsleep mode: IOs float, RAM is lost, and application will start from beginning after waking up |
alan1974 | 0:a91cd1b08360 | 72 | // if deep_sleep == true, device will enter deepsleep mode |
alan1974 | 8:a5316708e51d | 73 | // asb: |
alan1974 | 8:a5316708e51d | 74 | // no longer use deepsleep since we want to retain state |
alan1974 | 8:a5316708e51d | 75 | // sleep uses only 1uA more current than deepsleep |
alan1974 | 0:a91cd1b08360 | 76 | //======================================================================================================= |
alan1974 | 0:a91cd1b08360 | 77 | static bool deep_sleep = false; //false; |
alan1974 | 0:a91cd1b08360 | 78 | |
alan1974 | 0:a91cd1b08360 | 79 | uint32_t packets_sent = 0; |
alan1974 | 0:a91cd1b08360 | 80 | uint32_t acks_rcvd = 0; |
alan1974 | 0:a91cd1b08360 | 81 | int8_t rssi =0; //rssi of last rcvd rx1/rx2 |
alan1974 | 0:a91cd1b08360 | 82 | std::string eui = " "; |
alan1974 | 0:a91cd1b08360 | 83 | static bool led_enabled = false; //true; //false; |
alan1974 | 0:a91cd1b08360 | 84 | mDot* dot = NULL; |
alan1974 | 0:a91cd1b08360 | 85 | lora::ChannelPlan* plan = NULL; |
alan1974 | 0:a91cd1b08360 | 86 | uint8_t buf_xmt[BUFFER_SIZE_I2C]; //outgoing data |
alan1974 | 0:a91cd1b08360 | 87 | uint8_t buf_rcv[BUFFER_SIZE_I2C]; //incoming data |
alan1974 | 0:a91cd1b08360 | 88 | std::vector<uint8_t> upstream_packet; |
alan1974 | 0:a91cd1b08360 | 89 | |
alan1974 | 0:a91cd1b08360 | 90 | #ifdef GPIO_ENABLE |
alan1974 | 0:a91cd1b08360 | 91 | DigitalInOut gpio1(PA_5); //scope debug PA-5 is connected to SW1 pads on Loren v04 and can be used for scope debug |
alan1974 | 0:a91cd1b08360 | 92 | #endif |
alan1974 | 0:a91cd1b08360 | 93 | |
alan1974 | 0:a91cd1b08360 | 94 | Serial pc(USBTX, USBRX); //serial port output |
alan1974 | 0:a91cd1b08360 | 95 | |
alan1974 | 0:a91cd1b08360 | 96 | //================================================================================== |
alan1974 | 0:a91cd1b08360 | 97 | //chksum |
alan1974 | 0:a91cd1b08360 | 98 | //compute checksum over i2c buffer except for last byte (chksum byte) |
alan1974 | 0:a91cd1b08360 | 99 | //================================================================================== |
alan1974 | 0:a91cd1b08360 | 100 | uint8_t chksum_proc(uint8_t *bfr_xdot){ |
alan1974 | 0:a91cd1b08360 | 101 | uint8_t i; |
alan1974 | 0:a91cd1b08360 | 102 | uint8_t chksum = 0; |
alan1974 | 0:a91cd1b08360 | 103 | for (i=0; i < BUFFER_SIZE_I2C-1;i++)chksum += bfr_xdot[i];//good code |
alan1974 | 0:a91cd1b08360 | 104 | return chksum; |
alan1974 | 0:a91cd1b08360 | 105 | } |
alan1974 | 0:a91cd1b08360 | 106 | //================================================================================================= |
alan1974 | 0:a91cd1b08360 | 107 | //cfg_network: |
alan1974 | 0:a91cd1b08360 | 108 | // configure the network public/private and sub-band |
alan1974 | 0:a91cd1b08360 | 109 | // bForceCfg : true => force a network cfg |
alan1974 | 0:a91cd1b08360 | 110 | // false => only change if bPublic or sub_band have changed |
alan1974 | 0:a91cd1b08360 | 111 | // bPublic : true if network is public, else private |
alan1974 | 0:a91cd1b08360 | 112 | // sub_band: sub band number (1..8) |
alan1974 | 0:a91cd1b08360 | 113 | |
alan1974 | 0:a91cd1b08360 | 114 | // NOTE: THIS ONLY WORKS WHEN THE XDOT BOOTS UP. IT DOES NOT WORK WHEN TRYING TO CHANGE AFTER. |
alan1974 | 0:a91cd1b08360 | 115 | // NOT SURE WHY...WHEN THE XDOT REJOINS IT SHOULD USE NEW SESSION SETTINGS... asb |
alan1974 | 0:a91cd1b08360 | 116 | // |
alan1974 | 0:a91cd1b08360 | 117 | //asb:dec 2017: try this later and see if it works:mdot.h: |
alan1974 | 0:a91cd1b08360 | 118 | // int32_t setPublicNetwork(const bool& on); |
alan1974 | 0:a91cd1b08360 | 119 | // bool getPublicNetwork(); |
alan1974 | 0:a91cd1b08360 | 120 | // int32_t setFrequencySubBand(const uint8_t& band); |
alan1974 | 0:a91cd1b08360 | 121 | //================================================================================================= |
alan1974 | 0:a91cd1b08360 | 122 | bool cfg_network(bool bForceCfg,bool bPublic,uint8_t sub_band){ |
alan1974 | 0:a91cd1b08360 | 123 | // if bForceCfg false and network parameters haven't changed then just exit |
alan1974 | 0:a91cd1b08360 | 124 | if (!bForceCfg){ |
alan1974 | 5:abfe25f0de33 | 125 | if(verbose)pc.printf("no configuration change needed subband the same"); |
alan1974 | 0:a91cd1b08360 | 126 | if ((public_network ==bPublic) && (frequency_sub_band ==sub_band))return true; |
alan1974 | 0:a91cd1b08360 | 127 | } |
alan1974 | 5:abfe25f0de33 | 128 | if(verbose)pc.printf("changing to subband: %d\r\n",sub_band); |
alan1974 | 0:a91cd1b08360 | 129 | // update network settings |
alan1974 | 0:a91cd1b08360 | 130 | public_network = bPublic; |
alan1974 | 0:a91cd1b08360 | 131 | frequency_sub_band =sub_band; |
alan1974 | 0:a91cd1b08360 | 132 | // start from a well-known state |
alan1974 | 11:77fe4f18a81b | 133 | logInfo("defaulting Dot configuration"); |
alan1974 | 0:a91cd1b08360 | 134 | if (dot->getJoinMode() != mDot::OTA) { // update configuration if necessary |
alan1974 | 0:a91cd1b08360 | 135 | logInfo("changing network join mode to OTA"); |
alan1974 | 0:a91cd1b08360 | 136 | if (dot->setJoinMode(mDot::OTA) != mDot::MDOT_OK) { |
alan1974 | 0:a91cd1b08360 | 137 | logError("failed to set network join mode to OTA"); |
alan1974 | 0:a91cd1b08360 | 138 | return false; |
alan1974 | 0:a91cd1b08360 | 139 | } |
alan1974 | 0:a91cd1b08360 | 140 | } |
alan1974 | 0:a91cd1b08360 | 141 | // in OTA and AUTO_OTA join modes, the credentials can be passed to the library as a name and passphrase or an ID and KEY |
alan1974 | 0:a91cd1b08360 | 142 | // only one method or the other should be used! |
alan1974 | 0:a91cd1b08360 | 143 | if (public_network){ |
alan1974 | 12:7944e4dbe853 | 144 | update_ota_config_id_key(nvmData.key_AppEUI,nvmData.key_AppKey, frequency_sub_band, public_network, ack); |
alan1974 | 0:a91cd1b08360 | 145 | logInfo("-------------- network configured for public access -----------------------------"); |
alan1974 | 0:a91cd1b08360 | 146 | } |
alan1974 | 0:a91cd1b08360 | 147 | else{ |
alan1974 | 0:a91cd1b08360 | 148 | update_ota_config_name_phrase(network_name, network_passphrase, frequency_sub_band, public_network, ack); |
alan1974 | 0:a91cd1b08360 | 149 | logInfo("-------------- network configured for private access -------------------------------"); |
alan1974 | 1:0d25d9ddbe9f | 150 | } |
alan1974 | 1:0d25d9ddbe9f | 151 | // configure network link check count |
alan1974 | 1:0d25d9ddbe9f | 152 | // declares the Dot disconnected if no acks received within link_check_treshold transmits |
alan1974 | 1:0d25d9ddbe9f | 153 | //update_network_link_check_config(3, 5); |
alan1974 | 1:0d25d9ddbe9f | 154 | dot->setLinkCheckThreshold(link_check_treshold); |
alan1974 | 11:77fe4f18a81b | 155 | return true; |
alan1974 | 0:a91cd1b08360 | 156 | } |
alan1974 | 0:a91cd1b08360 | 157 | //================================================================================================= |
alan1974 | 0:a91cd1b08360 | 158 | //main() |
alan1974 | 0:a91cd1b08360 | 159 | // main() runs in its own thread in the OS |
alan1974 | 0:a91cd1b08360 | 160 | // (note the calls to wait below for delays) |
alan1974 | 0:a91cd1b08360 | 161 | //================================================================================================= |
alan1974 | 0:a91cd1b08360 | 162 | int main() { |
alan1974 | 1:0d25d9ddbe9f | 163 | uint8_t i; |
alan1974 | 12:7944e4dbe853 | 164 | RadioEvent events; //class to return info on rx pkts |
alan1974 | 0:a91cd1b08360 | 165 | mDotEvent mdotevent; //used to get ping info???? |
alan1974 | 15:ed77b752eaa9 | 166 | //plan = new lora::ChannelPlan_US915(); |
alan1974 | 15:ed77b752eaa9 | 167 | static lora::ChannelPlan_US915 plan; |
alan1974 | 0:a91cd1b08360 | 168 | #ifdef GPIO_ENABLE |
alan1974 | 0:a91cd1b08360 | 169 | gpio1.output(); |
alan1974 | 0:a91cd1b08360 | 170 | gpio1 =0; |
alan1974 | 0:a91cd1b08360 | 171 | #endif |
alan1974 | 0:a91cd1b08360 | 172 | pc.baud(115200); |
alan1974 | 11:77fe4f18a81b | 173 | |
alan1974 | 0:a91cd1b08360 | 174 | pc.printf("\r\n**********************************************************\r\n"); |
alan1974 | 0:a91cd1b08360 | 175 | pc.printf("\r\n XDOT BOOT\r\n"); |
alan1974 | 0:a91cd1b08360 | 176 | pc.printf("COMM api_level = <HEX> %x.%x.%x.%x\r\n",api_level[0],api_level[1],api_level[2],api_level[3]); |
alan1974 | 0:a91cd1b08360 | 177 | pc.printf("COMM version = %x.%x.%x.%x\r\n",ver_level[0],ver_level[1],ver_level[2],ver_level[3]); |
alan1974 | 1:0d25d9ddbe9f | 178 | pc.printf("**********************************************************\r\n"); |
alan1974 | 15:ed77b752eaa9 | 179 | //assert(plan); |
alan1974 | 15:ed77b752eaa9 | 180 | //dot = mDot::getInstance(plan); |
alan1974 | 15:ed77b752eaa9 | 181 | dot = mDot::getInstance(&plan); |
alan1974 | 15:ed77b752eaa9 | 182 | //assert(dot); |
alan1974 | 1:0d25d9ddbe9f | 183 | |
alan1974 | 16:5cc10d804d49 | 184 | dot->setEvents(&events); |
alan1974 | 15:ed77b752eaa9 | 185 | |
alan1974 | 15:ed77b752eaa9 | 186 | |
alan1974 | 15:ed77b752eaa9 | 187 | |
alan1974 | 1:0d25d9ddbe9f | 188 | nvmRead(pNvmData); |
alan1974 | 8:a5316708e51d | 189 | |
alan1974 | 5:abfe25f0de33 | 190 | if (pNvmData->bLogOutputOn == 0){ |
alan1974 | 5:abfe25f0de33 | 191 | pc.printf("\r\nDISABLING TERMINAL OUTPUT\r\n"); |
alan1974 | 10:061fab1195e7 | 192 | dot->setLogLevel(mts::MTSLog::NONE_LEVEL); //doesn't work |
alan1974 | 8:a5316708e51d | 193 | verbose = false; |
alan1974 | 5:abfe25f0de33 | 194 | } |
alan1974 | 5:abfe25f0de33 | 195 | else{ |
alan1974 | 5:abfe25f0de33 | 196 | printNmvData(pNvmData); |
alan1974 | 17:74d60177c6b6 | 197 | //dot->setLogLevel((verbose) ? mts::MTSLog::TRACE_LEVEL : mts::MTSLog::TRACE_LEVEL); // TRACE_LEVEL , INFO_LEVEL |
alan1974 | 1:0d25d9ddbe9f | 198 | } |
alan1974 | 7:fba1e8fc7693 | 199 | |
alan1974 | 0:a91cd1b08360 | 200 | // getStandbyFlag() should return the state of the standby flag directly from the processor |
alan1974 | 0:a91cd1b08360 | 201 | // Standby flag: This bit is set by hardware and cleared only by a POR/PDR (power on reset/power down reset) or by setting the CSBF bit in the PWR power control register (PWR_CR) |
alan1974 | 0:a91cd1b08360 | 202 | // 0: Device has not been in Standby mode |
alan1974 | 0:a91cd1b08360 | 203 | // 1: Device has been in Standby mode |
alan1974 | 0:a91cd1b08360 | 204 | // The xDot should enter standby mode when deep sleep in invoked. So you should see the standby flag set if it came out of deep sleep. |
alan1974 | 1:0d25d9ddbe9f | 205 | if (!dot->getStandbyFlag()) { //if 0 => power-up/reset which should always be the case at this point |
alan1974 | 5:abfe25f0de33 | 206 | logInfo("mbed-os library version: %d", MBED_LIBRARY_VERSION); |
alan1974 | 5:abfe25f0de33 | 207 | frequency_sub_band = dot->getFrequencySubBand(); |
alan1974 | 5:abfe25f0de33 | 208 | printRadioCfg(); |
alan1974 | 5:abfe25f0de33 | 209 | cfg_network(true,public_network,frequency_sub_band); //force network cfg, |
alan1974 | 0:a91cd1b08360 | 210 | } else { |
alan1974 | 0:a91cd1b08360 | 211 | // restore the saved session (join OTAA info) if the dot woke from deepsleep mode |
alan1974 | 0:a91cd1b08360 | 212 | // useful to use with deepsleep because session info is otherwise lost when the dot enters deepsleep |
alan1974 | 0:a91cd1b08360 | 213 | logInfo("restoring network session from NVM"); |
alan1974 | 0:a91cd1b08360 | 214 | dot->restoreNetworkSession(); |
alan1974 | 0:a91cd1b08360 | 215 | } |
alan1974 | 0:a91cd1b08360 | 216 | //-------------------------------------------------------------------------------------------------------------------------------------------- |
alan1974 | 1:0d25d9ddbe9f | 217 | // configure network link check count |
alan1974 | 1:0d25d9ddbe9f | 218 | // declares the Dot disconnected if no acks received within link_check_treshold transmits |
alan1974 | 1:0d25d9ddbe9f | 219 | //update_network_link_check_config(3, 5); |
alan1974 | 1:0d25d9ddbe9f | 220 | dot->setLinkCheckThreshold(link_check_treshold); |
alan1974 | 0:a91cd1b08360 | 221 | //---------------------------------------------------------------------------------------------------------------------------------------------- |
alan1974 | 0:a91cd1b08360 | 222 | |
alan1974 | 0:a91cd1b08360 | 223 | // save changes to configuration |
alan1974 | 0:a91cd1b08360 | 224 | // logInfo("saving configuration"); |
alan1974 | 0:a91cd1b08360 | 225 | |
alan1974 | 1:0d25d9ddbe9f | 226 | eui = mts::Text::bin2hexString(dot->getDeviceId()).c_str(); |
alan1974 | 5:abfe25f0de33 | 227 | if(verbose)pc.printf("\r\nEUI: %s\r\n",eui); |
alan1974 | 1:0d25d9ddbe9f | 228 | bool joined = false; |
alan1974 | 8:a5316708e51d | 229 | |
alan1974 | 1:0d25d9ddbe9f | 230 | i2c_proc_init(); //init i2c comm |
alan1974 | 8:a5316708e51d | 231 | sleep_wake_interrupt_only(deep_sleep); //wake on rising edge of wake signal from proc |
alan1974 | 0:a91cd1b08360 | 232 | //scope test |
alan1974 | 10:061fab1195e7 | 233 | #ifdef GPIO_ENABLE |
alan1974 | 10:061fab1195e7 | 234 | gpio1 =1; |
alan1974 | 10:061fab1195e7 | 235 | #endif |
alan1974 | 0:a91cd1b08360 | 236 | //============================================================================== |
alan1974 | 0:a91cd1b08360 | 237 | // -loop here forever |
alan1974 | 0:a91cd1b08360 | 238 | // -sleep until LORA_WAKE goes hi => proc ready to send i2c cmd |
alan1974 | 0:a91cd1b08360 | 239 | // -start polling incoming i2c bus for proc cmd |
alan1974 | 0:a91cd1b08360 | 240 | // -execute cmd |
alan1974 | 0:a91cd1b08360 | 241 | // -take control of LORA_WAKE and toggle it hi to signal proc that xdot |
alan1974 | 0:a91cd1b08360 | 242 | // ready to send i2c ack message |
alan1974 | 0:a91cd1b08360 | 243 | // -go back to sleep |
alan1974 | 0:a91cd1b08360 | 244 | //============================================================================== |
alan1974 | 0:a91cd1b08360 | 245 | bool bPulseLoraWake = false; |
alan1974 | 0:a91cd1b08360 | 246 | while(1) |
alan1974 | 0:a91cd1b08360 | 247 | { |
alan1974 | 13:1f3a8d0be511 | 248 | if(verbose)pc.printf("\n\r***************************** "); |
alan1974 | 0:a91cd1b08360 | 249 | |
alan1974 | 18:d95e1a2c4303 | 250 | switch (i2c_proc_comm(buf_xmt,buf_rcv,BUFFER_SIZE_I2C)){ |
alan1974 | 7:fba1e8fc7693 | 251 | case I2C_WRITE: //xdot ack ->proc |
alan1974 | 5:abfe25f0de33 | 252 | if(verbose)pc.printf("\n\r xdot ack -> proc done,going to sleep\n\r "); |
alan1974 | 0:a91cd1b08360 | 253 | bPulseLoraWake = false; |
alan1974 | 10:061fab1195e7 | 254 | #ifdef GPIO_ENABLE |
alan1974 | 10:061fab1195e7 | 255 | gpio1 =0; |
alan1974 | 10:061fab1195e7 | 256 | #endif |
alan1974 | 15:ed77b752eaa9 | 257 | wait_us(wait_before_sleep_usec); //wait for i2c to complete data transfer before sleeping |
alan1974 | 17:74d60177c6b6 | 258 | |
alan1974 | 18:d95e1a2c4303 | 259 | if (bListen4Multicast){ //in ClassC and receiving multicst pkt, stay here until timeout or bListen4Multicast false |
alan1974 | 17:74d60177c6b6 | 260 | if(verbose)pc.printf("\n\r changed to class C, LISTEN ONLY,for max sec:%d\r\n",maxMulticastSessionTime); |
alan1974 | 17:74d60177c6b6 | 261 | uint16_t wait_cnt = maxMulticastSessionTime; |
alan1974 | 18:d95e1a2c4303 | 262 | while((wait_cnt > 0) && bListen4Multicast){ //stay in mcast listen only until either timeout or end of mcast session |
alan1974 | 17:74d60177c6b6 | 263 | wait_cnt--; |
alan1974 | 17:74d60177c6b6 | 264 | wait(1); |
alan1974 | 17:74d60177c6b6 | 265 | } |
alan1974 | 17:74d60177c6b6 | 266 | } |
alan1974 | 17:74d60177c6b6 | 267 | sleep_wake_interrupt_only(deep_sleep); //sleep until rising edge of wake signal from proc |
alan1974 | 17:74d60177c6b6 | 268 | |
alan1974 | 15:ed77b752eaa9 | 269 | |
alan1974 | 10:061fab1195e7 | 270 | #ifdef GPIO_ENABLE |
alan1974 | 10:061fab1195e7 | 271 | gpio1 =1; |
alan1974 | 10:061fab1195e7 | 272 | #endif |
alan1974 | 8:a5316708e51d | 273 | if(verbose)pc.printf("\n\r lora wake detected -> monitoring i2c bus\n\r "); |
alan1974 | 0:a91cd1b08360 | 274 | break; |
alan1974 | 0:a91cd1b08360 | 275 | case I2C_READ: //xdot <- proc |
alan1974 | 0:a91cd1b08360 | 276 | bPulseLoraWake = true; |
alan1974 | 0:a91cd1b08360 | 277 | switch (buf_rcv[0]) |
alan1974 | 0:a91cd1b08360 | 278 | { |
alan1974 | 1:0d25d9ddbe9f | 279 | case XDOT_CMD_XMIT_PKT: |
alan1974 | 7:fba1e8fc7693 | 280 | pkt_upstrm *pUp= (pkt_upstrm*)&buf_rcv[0]; |
alan1974 | 7:fba1e8fc7693 | 281 | for (i=0; i < sizeof(buf_xmt);i++)buf_xmt[i] = 0xff; //bfr fill |
alan1974 | 7:fba1e8fc7693 | 282 | pkt_ack *pAck = (pkt_ack*)&buf_xmt[0]; |
alan1974 | 0:a91cd1b08360 | 283 | pAck->ack = I2C_ACK_PROC; |
alan1974 | 5:abfe25f0de33 | 284 | pAck->cmd = XDOT_CMD_XMIT_PKT; |
alan1974 | 7:fba1e8fc7693 | 285 | pAck->dataLen = pUp->dataLen; //data len of xmitted pkt |
alan1974 | 7:fba1e8fc7693 | 286 | if(verbose)pc.printf("\r\npkt to xmit data len: %d\r\n",pAck->dataLen); |
alan1974 | 5:abfe25f0de33 | 287 | uint8_t chksum = chksum_proc(buf_rcv); |
alan1974 | 7:fba1e8fc7693 | 288 | if(verbose)pc.printf("\r\nI2C chksum rcvd/computer: %d/%d ",pUp->chksum,chksum); |
alan1974 | 0:a91cd1b08360 | 289 | pAck->bXmitAttempted = 1; |
alan1974 | 0:a91cd1b08360 | 290 | pAck->chksum_err = 0; |
alan1974 | 0:a91cd1b08360 | 291 | if(pUp->chksum != chksum){ |
alan1974 | 7:fba1e8fc7693 | 292 | if(verbose)pc.printf(" chksum err, aborting xmit"); |
alan1974 | 0:a91cd1b08360 | 293 | pAck->bXmitAttempted = 0; |
alan1974 | 11:77fe4f18a81b | 294 | pAck->mdot_ret = XDOT_ERR_I2C_CHKSUM; |
alan1974 | 11:77fe4f18a81b | 295 | pAck->chksum_err = 1; |
alan1974 | 11:77fe4f18a81b | 296 | break; |
alan1974 | 0:a91cd1b08360 | 297 | } |
alan1974 | 1:0d25d9ddbe9f | 298 | //rev 0307 parameters |
alan1974 | 5:abfe25f0de33 | 299 | if(verbose)pc.printf("\n\r setting application port %d ",pUp->appPort); //appPort not used in rev < 0307 |
alan1974 | 1:0d25d9ddbe9f | 300 | dot->setAppPort(pUp->appPort); |
alan1974 | 6:b2039a285d7f | 301 | uint8_t linkThresholdCnt = pUp->linkThreshCnt; |
alan1974 | 11:77fe4f18a81b | 302 | if(verbose)pc.printf("\r\n linkThreshCnt %d\r\n",linkThresholdCnt); |
alan1974 | 6:b2039a285d7f | 303 | dot->setLinkCheckThreshold(linkThresholdCnt); |
alan1974 | 11:77fe4f18a81b | 304 | |
alan1974 | 0:a91cd1b08360 | 305 | if (pUp->dataLen == 0){ //datalen non zero? |
alan1974 | 0:a91cd1b08360 | 306 | pAck->bXmitAttempted = 0; |
alan1974 | 0:a91cd1b08360 | 307 | break; |
alan1974 | 0:a91cd1b08360 | 308 | } |
alan1974 | 0:a91cd1b08360 | 309 | upstream_packet.clear(); //xfr data from incoming bfr to xmit bfr |
alan1974 | 0:a91cd1b08360 | 310 | for (i=0; i< pUp->dataLen;i++) upstream_packet.push_back(pUp->txData[i]); |
alan1974 | 0:a91cd1b08360 | 311 | |
alan1974 | 5:abfe25f0de33 | 312 | if(verbose){ |
alan1974 | 7:fba1e8fc7693 | 313 | pc.printf("\r\n[TEST],Upstream Packet Received"); |
alan1974 | 5:abfe25f0de33 | 314 | for(std::vector<uint8_t>::iterator it = upstream_packet.begin(); it != upstream_packet.end(); ++it) |
alan1974 | 5:abfe25f0de33 | 315 | pc.printf(",0x%x", *it); |
alan1974 | 5:abfe25f0de33 | 316 | pc.printf("\r\n"); // see i told you. |
alan1974 | 5:abfe25f0de33 | 317 | } |
alan1974 | 0:a91cd1b08360 | 318 | joined = dot->getNetworkJoinStatus(); //are we joined to Lorawan? |
alan1974 | 0:a91cd1b08360 | 319 | pAck->joinAttempts = 0; //no attempts made yet to join |
alan1974 | 1:0d25d9ddbe9f | 320 | pAck->bAck = 0; //won't know if we receive a lorawan ack until after xmit |
alan1974 | 1:0d25d9ddbe9f | 321 | pAck->bAckdata = 0; //won't know if we receive a lorawan ack downstream data until after xmit |
alan1974 | 7:fba1e8fc7693 | 322 | pAck->rssi = 0; //if not rx1/rx2 then no RSSI value |
alan1974 | 7:fba1e8fc7693 | 323 | pAck->snr = 0; //if not rx1/rx2 then no SNR value |
alan1974 | 1:0d25d9ddbe9f | 324 | if(!joined) { //if not previously joined, then need to join now |
alan1974 | 0:a91cd1b08360 | 325 | pAck->bJoined = 0; |
alan1974 | 5:abfe25f0de33 | 326 | if(verbose)pc.printf("\r\n----------- NETWORK NOT JOINED YET, WILL TRY TO JOIN %d TIMES\r\n",pUp->joinAttemps); |
alan1974 | 14:fc836a5a5d2f | 327 | joined = join_network_wbit(pUp->joinAttemps); //try joinAttemps times to join network |
alan1974 | 14:fc836a5a5d2f | 328 | pAck->joinAttempts = join_network_attempts_wbit(); //# of join attemps made |
alan1974 | 14:fc836a5a5d2f | 329 | pAck->mdot_ret = dot->send(upstream_packet); //<--------------------------------------- extra xmit ??????????????? |
alan1974 | 17:74d60177c6b6 | 330 | save_OTAA_session_keys(); |
alan1974 | 5:abfe25f0de33 | 331 | if (!joined) |
alan1974 | 5:abfe25f0de33 | 332 | if(verbose)pc.printf("\r\n----------- FAILED TO JOIN...GIVING UP\r\n"); // join network if not joined |
alan1974 | 17:74d60177c6b6 | 333 | //else { |
alan1974 | 17:74d60177c6b6 | 334 | // save_OTAA_session_keys(); |
alan1974 | 17:74d60177c6b6 | 335 | // plan.SetRx2DatarateIndex(8); //LORIOT FIX FOR RX2 & OTA !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! ---> doesn't work here???? |
alan1974 | 17:74d60177c6b6 | 336 | //} |
alan1974 | 0:a91cd1b08360 | 337 | } |
alan1974 | 11:77fe4f18a81b | 338 | if (joined) |
alan1974 | 11:77fe4f18a81b | 339 | { |
alan1974 | 1:0d25d9ddbe9f | 340 | pAck->bJoined = 1; //we are joined to the network |
alan1974 | 0:a91cd1b08360 | 341 | packets_sent++; |
alan1974 | 11:77fe4f18a81b | 342 | bRxDone = false; //true if callback function RxDone() triggered |
alan1974 | 11:77fe4f18a81b | 343 | bDownLinkCntrFail = false; //true if callback function RxDone() triggered and bad downlink frame count |
alan1974 | 11:77fe4f18a81b | 344 | |
alan1974 | 12:7944e4dbe853 | 345 | //send packet -> return code indicates results, send return code back to proc Dec14,2017 |
alan1974 | 15:ed77b752eaa9 | 346 | plan.SetRx2DatarateIndex(8); //LORIOT FIX FOR RX2 & OT --- work here????? |
alan1974 | 5:abfe25f0de33 | 347 | pAck->mdot_ret = dot->send(upstream_packet); //xmit the pkt in blocking mode, return false if no ack |
alan1974 | 7:fba1e8fc7693 | 348 | if (verbose)printf("\n\rdata->send() return code: %d\r\n",pAck->mdot_ret); |
alan1974 | 11:77fe4f18a81b | 349 | if (pAck->mdot_ret == mDot::MDOT_OK) |
alan1974 | 11:77fe4f18a81b | 350 | { |
alan1974 | 0:a91cd1b08360 | 351 | acks_rcvd++; |
alan1974 | 0:a91cd1b08360 | 352 | pAck->bAck = 1; //we got a Rx1 or Rx2 ack |
alan1974 | 7:fba1e8fc7693 | 353 | mDot::rssi_stats rssiStats = dot->getRssiStats(); //rssi stat |
alan1974 | 0:a91cd1b08360 | 354 | pAck->rssi = (int8_t)rssiStats.last; |
alan1974 | 7:fba1e8fc7693 | 355 | mDot::snr_stats snrStats = dot->getSnrStats(); //snr stat |
alan1974 | 7:fba1e8fc7693 | 356 | pAck->snr = (int8_t)snrStats.last; |
alan1974 | 7:fba1e8fc7693 | 357 | if (verbose)printf("\n\rdata->send()=true; ack:%d, rssi:%d snr:%d\r\n",pAck->bAck,pAck->rssi,pAck->snr); |
alan1974 | 7:fba1e8fc7693 | 358 | if (events.is_packet_received()){ //downstream data from the Rx1/Rx2 pkt? |
alan1974 | 5:abfe25f0de33 | 359 | if (verbose)printf("\n\revents.is_packet_received = true\r\n"); |
alan1974 | 0:a91cd1b08360 | 360 | pAck->bAckdata = 1; |
alan1974 | 0:a91cd1b08360 | 361 | upstream_packet.clear(); |
alan1974 | 0:a91cd1b08360 | 362 | upstream_packet = events.get_downstream_packet(); |
alan1974 | 12:7944e4dbe853 | 363 | pAck->rxLen = upstream_packet.size(); |
alan1974 | 12:7944e4dbe853 | 364 | pAck->appPort = events.port; |
alan1974 | 0:a91cd1b08360 | 365 | if (pAck->rxLen > I2C_MAX_ACK_DATA){ |
alan1974 | 5:abfe25f0de33 | 366 | if(verbose)pc.printf("\r\n got ack with pkt data too large.. rejected\r\n"); |
alan1974 | 0:a91cd1b08360 | 367 | break; |
alan1974 | 5:abfe25f0de33 | 368 | } |
alan1974 | 5:abfe25f0de33 | 369 | if(verbose){ |
alan1974 | 5:abfe25f0de33 | 370 | pc.printf("\r\n pkt data: "); |
alan1974 | 5:abfe25f0de33 | 371 | for (i=0; i< pAck->rxLen;i++) { |
alan1974 | 5:abfe25f0de33 | 372 | pAck->rxData[i]= upstream_packet[i]; |
alan1974 | 5:abfe25f0de33 | 373 | pc.printf(" %x",pAck->rxData[i]); |
alan1974 | 5:abfe25f0de33 | 374 | } |
alan1974 | 0:a91cd1b08360 | 375 | } |
alan1974 | 0:a91cd1b08360 | 376 | } //if downstream data rcvd |
alan1974 | 0:a91cd1b08360 | 377 | else{ |
alan1974 | 11:77fe4f18a81b | 378 | if (verbose)printf("\n\r ack rcvd without data\r\n"); |
alan1974 | 11:77fe4f18a81b | 379 | } //else |
alan1974 | 7:fba1e8fc7693 | 380 | } //send() |
alan1974 | 11:77fe4f18a81b | 381 | //rev 0308 parameters |
alan1974 | 11:77fe4f18a81b | 382 | else |
alan1974 | 11:77fe4f18a81b | 383 | { |
alan1974 | 11:77fe4f18a81b | 384 | if (verbose)printf("\n\r no ack rcvd \r\n"); //could be some other error |
alan1974 | 11:77fe4f18a81b | 385 | if ((pAck->mdot_ret != 0) && bRxDone) //chk if callback function triggered |
alan1974 | 11:77fe4f18a81b | 386 | { |
alan1974 | 11:77fe4f18a81b | 387 | if (bDownLinkCntrFail)pAck->mdot_ret = XDOT_ERR_FRAME_CNT; //bad downlink frame count return err code |
alan1974 | 11:77fe4f18a81b | 388 | } |
alan1974 | 0:a91cd1b08360 | 389 | } |
alan1974 | 0:a91cd1b08360 | 390 | }//if joined |
alan1974 | 0:a91cd1b08360 | 391 | break; |
alan1974 | 0:a91cd1b08360 | 392 | case XDOT_CMD_SET_RADIO: |
alan1974 | 5:abfe25f0de33 | 393 | if(verbose)pc.printf("\n\r proc cmd: CMD_SET_RADIO"); |
alan1974 | 0:a91cd1b08360 | 394 | pkt_setradiodwn *pDwnRadio= (pkt_setradiodwn*)&buf_xmt[0]; |
alan1974 | 0:a91cd1b08360 | 395 | pkt_setradioup *pUpRadio = (pkt_setradioup*)&buf_rcv[0]; |
alan1974 | 0:a91cd1b08360 | 396 | pDwnRadio->ack = I2C_ACK_PROC; |
alan1974 | 0:a91cd1b08360 | 397 | pDwnRadio->cmd = XDOT_CMD_SET_RADIO; |
alan1974 | 0:a91cd1b08360 | 398 | |
alan1974 | 0:a91cd1b08360 | 399 | if (pUpRadio->bSetParams){ |
alan1974 | 7:fba1e8fc7693 | 400 | if(verbose)pc.printf("\n\r setting radio params"); |
alan1974 | 7:fba1e8fc7693 | 401 | if(verbose)pc.printf("\n\r setting adr to %d ",pUpRadio->params.aDR); |
alan1974 | 7:fba1e8fc7693 | 402 | if (pUpRadio->params.aDR == 1) dot->setAdr(true); //test for adr problem |
alan1974 | 7:fba1e8fc7693 | 403 | else dot->setAdr(false); |
alan1974 | 7:fba1e8fc7693 | 404 | dot->setAdr((uint8_t)pUpRadio->params.aDR); // enable or disable Adaptive Data Rate |
alan1974 | 5:abfe25f0de33 | 405 | if(verbose)pc.printf("\n\r setting subband to %d ",pUpRadio->params.sub_band); |
alan1974 | 2:0af50f386eb2 | 406 | cfg_network(false,true,(uint8_t)pUpRadio->params.sub_band); |
alan1974 | 7:fba1e8fc7693 | 407 | |
alan1974 | 7:fba1e8fc7693 | 408 | if(verbose)pc.printf("\n\r setting public/private network to %d ",pUpRadio->params.public_network); |
alan1974 | 7:fba1e8fc7693 | 409 | //public_network = (bool)pUpRadio->params.public_network; |
alan1974 | 7:fba1e8fc7693 | 410 | dot->setPublicNetwork((bool)pUpRadio->params.public_network); |
alan1974 | 7:fba1e8fc7693 | 411 | |
alan1974 | 5:abfe25f0de33 | 412 | if(verbose)pc.printf("\n\r setting antenna gain to %d ",pUpRadio->params.antennaGaindBi); |
alan1974 | 2:0af50f386eb2 | 413 | dot->setAntennaGain(pUpRadio->params.antennaGaindBi); |
alan1974 | 10:061fab1195e7 | 414 | if(verbose)pc.printf("\n\r setting radio tx power to %d ",pUpRadio->params.txPower); |
alan1974 | 10:061fab1195e7 | 415 | dot->setTxPower(pUpRadio->params.txPower); |
alan1974 | 5:abfe25f0de33 | 416 | if(verbose)pc.printf("\n\r setting tx datarate to %d ",pUpRadio->params.dataRate); |
alan1974 | 2:0af50f386eb2 | 417 | dot->setTxDataRate(pUpRadio->params.dataRate); |
alan1974 | 5:abfe25f0de33 | 418 | if(verbose)pc.printf("\n\r setting tx inverted to %d ",(bool)pUpRadio->params.txInverted); |
alan1974 | 5:abfe25f0de33 | 419 | dot->setTxInverted((bool)pUpRadio->params.txInverted); |
alan1974 | 5:abfe25f0de33 | 420 | if(verbose)pc.printf("\n\r setting rx inverted to %d ",(bool)pUpRadio->params.rxInverted); |
alan1974 | 5:abfe25f0de33 | 421 | dot->setRxInverted((bool)pUpRadio->params.rxInverted); |
alan1974 | 5:abfe25f0de33 | 422 | if(verbose)pc.printf("\n\r setting rx delay to %d ",pUpRadio->params.rxDelay); |
alan1974 | 5:abfe25f0de33 | 423 | dot->setRxDelay(pUpRadio->params.rxDelay); |
alan1974 | 5:abfe25f0de33 | 424 | if(verbose)pc.printf("\n\r setting join delay to %d ",pUpRadio->params.join_delay); |
alan1974 | 7:fba1e8fc7693 | 425 | dot->setJoinDelay(pUpRadio->params.join_delay); |
alan1974 | 5:abfe25f0de33 | 426 | if(verbose)pc.printf("\n\r saving configuration"); |
alan1974 | 0:a91cd1b08360 | 427 | if (!dot->saveConfig())logError("failed to save configuration"); |
alan1974 | 7:fba1e8fc7693 | 428 | |
alan1974 | 0:a91cd1b08360 | 429 | display_config(); |
alan1974 | 0:a91cd1b08360 | 430 | } |
alan1974 | 7:fba1e8fc7693 | 431 | if(verbose)pc.printf("\n\r reading radio params"); |
alan1974 | 2:0af50f386eb2 | 432 | pDwnRadio->params.public_network = public_network; |
alan1974 | 2:0af50f386eb2 | 433 | pDwnRadio->params.sub_band = dot->getFrequencySubBand(); |
alan1974 | 5:abfe25f0de33 | 434 | pDwnRadio->params.join_delay = dot->getJoinDelay(); |
alan1974 | 5:abfe25f0de33 | 435 | pDwnRadio->params.txInverted = dot->getTxInverted(); |
alan1974 | 5:abfe25f0de33 | 436 | pDwnRadio->params.rxInverted = dot->getRxInverted(); |
alan1974 | 5:abfe25f0de33 | 437 | pDwnRadio->params.rxDelay = dot->getRxDelay(); |
alan1974 | 2:0af50f386eb2 | 438 | pDwnRadio->params.maxDataLen = dot->getMaxPacketLength(); |
alan1974 | 2:0af50f386eb2 | 439 | pDwnRadio->params.maxTxPowerdBm = dot->getMaxTxPower(); |
alan1974 | 2:0af50f386eb2 | 440 | pDwnRadio->params.minTxPowerdBm = dot->getMinTxPower(); |
alan1974 | 2:0af50f386eb2 | 441 | pDwnRadio->params.aDR = dot->getAdr(); |
alan1974 | 2:0af50f386eb2 | 442 | pDwnRadio->params.antennaGaindBi = dot->getAntennaGain(); |
alan1974 | 10:061fab1195e7 | 443 | pDwnRadio->params.txPower = dot->getTxPower(); //programmed tx power (non-adr) |
alan1974 | 10:061fab1195e7 | 444 | pDwnRadio->params.dataRate = dot->getTxDataRate(); //programmed data rate (non-adr) |
alan1974 | 10:061fab1195e7 | 445 | pDwnRadio->params.dataRateCurrent = dot->getSettings()->Session.TxDatarate; //presently used data rate (adr can change this);see Lora.h |
alan1974 | 10:061fab1195e7 | 446 | pDwnRadio->params.txPowerCurrent = dot->getSettings()->Session.TxPower;//presently used tx power (adr can change this);see Lora.h |
alan1974 | 10:061fab1195e7 | 447 | pDwnRadio->params.rx1DelayCurrent = dot->getSettings()->Session.RxDelay;//presently used rx1_delay;see Lora.h |
alan1974 | 10:061fab1195e7 | 448 | |
alan1974 | 10:061fab1195e7 | 449 | |
alan1974 | 0:a91cd1b08360 | 450 | break; |
alan1974 | 0:a91cd1b08360 | 451 | case XDOT_CMD_GET_EUI: //0307: modified to include radio parameter settings |
alan1974 | 5:abfe25f0de33 | 452 | if(verbose)pc.printf("\n\r proc cmd: get EUI"); |
alan1974 | 0:a91cd1b08360 | 453 | pkt_eui *peui = (pkt_eui*)&buf_xmt[0]; |
alan1974 | 0:a91cd1b08360 | 454 | peui->ack = I2C_ACK_PROC; |
alan1974 | 0:a91cd1b08360 | 455 | peui->cmd = XDOT_CMD_GET_EUI; |
alan1974 | 0:a91cd1b08360 | 456 | upstream_packet.clear(); |
alan1974 | 0:a91cd1b08360 | 457 | upstream_packet = dot->getDeviceId(); |
alan1974 | 0:a91cd1b08360 | 458 | peui->dataLen = upstream_packet.size(); |
alan1974 | 0:a91cd1b08360 | 459 | for (i=0; i< peui->dataLen;i++) peui->euiData[i] = upstream_packet[i]; |
alan1974 | 0:a91cd1b08360 | 460 | for (i=0; i< 4;i++) peui->apiLvlData[i] = api_level[i]; |
alan1974 | 0:a91cd1b08360 | 461 | for (i=0; i< 4;i++) peui->verLvlData[i] = ver_level[i]; |
alan1974 | 0:a91cd1b08360 | 462 | peui->dataLen = sizeof(pkt_eui)-3; //size of struc minus first 3 bytes |
alan1974 | 9:cc23b2049639 | 463 | if(verbose)pc.printf("\n\r eui data length: %d",peui->dataLen); |
alan1974 | 17:74d60177c6b6 | 464 | break; |
alan1974 | 9:cc23b2049639 | 465 | case XDOT_CMD_NVM: |
alan1974 | 12:7944e4dbe853 | 466 | if(verbose)pc.printf("\n\r proc cmd: NVM OTAA"); |
alan1974 | 9:cc23b2049639 | 467 | pkt_setnvmup *pUpNvm = (pkt_setnvmup*)&buf_rcv[0]; |
alan1974 | 9:cc23b2049639 | 468 | pkt_setnvmdwn *pDwnNvm= (pkt_setnvmdwn*)&buf_xmt[0]; |
alan1974 | 9:cc23b2049639 | 469 | pDwnNvm->ack = I2C_ACK_PROC; |
alan1974 | 9:cc23b2049639 | 470 | pDwnNvm->cmd = XDOT_CMD_NVM; |
alan1974 | 9:cc23b2049639 | 471 | pDwnNvm->dataLen = sizeof(nvm)-2; |
alan1974 | 9:cc23b2049639 | 472 | if (pUpNvm->nvm_option == XDOT_NVM_SET) nvmWrite(&pUpNvm->nvmData); |
alan1974 | 9:cc23b2049639 | 473 | if (pUpNvm->nvm_option == XDOT_NVM_RESTORE) nvmRestore(&pUpNvm->nvmData); |
alan1974 | 9:cc23b2049639 | 474 | |
alan1974 | 9:cc23b2049639 | 475 | pDwnNvm->bChkSumOK = 0; |
alan1974 | 9:cc23b2049639 | 476 | if (nvmRead(&pDwnNvm->nvmData)) |
alan1974 | 9:cc23b2049639 | 477 | pDwnNvm->bChkSumOK = 1; |
alan1974 | 9:cc23b2049639 | 478 | printNmvData(&pDwnNvm->nvmData); |
alan1974 | 17:74d60177c6b6 | 479 | break; |
alan1974 | 14:fc836a5a5d2f | 480 | case XDOT_CMD_SET_RADIO_CLASS: //multicast_change_class A or C (change only after a join!) |
alan1974 | 14:fc836a5a5d2f | 481 | if(verbose)pc.printf("\n\r proc cmd: change radio class\r\n"); |
alan1974 | 14:fc836a5a5d2f | 482 | pkt_setClassUp *pUpSetClass = (pkt_setClassUp*)&buf_rcv[0]; |
alan1974 | 14:fc836a5a5d2f | 483 | pkt_setClassDwn *pDwnSetClass = (pkt_setClassDwn*)&buf_xmt[0]; |
alan1974 | 14:fc836a5a5d2f | 484 | pDwnSetClass->ack = I2C_ACK_PROC; |
alan1974 | 14:fc836a5a5d2f | 485 | pDwnSetClass->cmd = XDOT_CMD_SET_RADIO_CLASS; |
alan1974 | 17:74d60177c6b6 | 486 | pDwnSetClass->dataLen = sizeof(class_switch)-2; |
alan1974 | 17:74d60177c6b6 | 487 | bool bOk = multicast_change_class(&pUpSetClass->classData); |
alan1974 | 17:74d60177c6b6 | 488 | if (bOk && pUpSetClass->classData.bListen4Multicast){ //go into listen only mode for multicast pkts? |
alan1974 | 17:74d60177c6b6 | 489 | bListen4Multicast = true;; |
alan1974 | 17:74d60177c6b6 | 490 | maxMulticastSessionTime = pUpSetClass->classData.maxMulticastSessionTime; |
alan1974 | 17:74d60177c6b6 | 491 | } |
alan1974 | 15:ed77b752eaa9 | 492 | pDwnSetClass->bSwitched = bOk; |
alan1974 | 14:fc836a5a5d2f | 493 | break; |
alan1974 | 14:fc836a5a5d2f | 494 | |
alan1974 | 12:7944e4dbe853 | 495 | |
alan1974 | 17:74d60177c6b6 | 496 | case XDOT_CMD_SET_NTWKSESS: //read or write network session to xdot flash |
alan1974 | 1:0d25d9ddbe9f | 497 | bool bWriteSession = (bool)buf_rcv[1]; |
alan1974 | 1:0d25d9ddbe9f | 498 | if (bWriteSession){ |
alan1974 | 5:abfe25f0de33 | 499 | if(verbose)pc.printf("\n\r proc cmd writing network sesion to flash"); |
alan1974 | 1:0d25d9ddbe9f | 500 | dot->saveNetworkSession(); |
alan1974 | 1:0d25d9ddbe9f | 501 | } |
alan1974 | 1:0d25d9ddbe9f | 502 | else{ |
alan1974 | 5:abfe25f0de33 | 503 | if(verbose)pc.printf("\n\r reading network session from flash"); |
alan1974 | 1:0d25d9ddbe9f | 504 | dot->restoreNetworkSession(); |
alan1974 | 1:0d25d9ddbe9f | 505 | } |
alan1974 | 1:0d25d9ddbe9f | 506 | pkt_ntwrk *pktwrk = (pkt_ntwrk*)&buf_xmt[0]; |
alan1974 | 1:0d25d9ddbe9f | 507 | pktwrk->ack = I2C_ACK_PROC; |
alan1974 | 1:0d25d9ddbe9f | 508 | pktwrk->cmd = XDOT_CMD_SET_NTWKSESS; |
alan1974 | 1:0d25d9ddbe9f | 509 | pktwrk->bSetNetwrk = (uint8_t)bWriteSession; |
alan1974 | 9:cc23b2049639 | 510 | break; |
alan1974 | 17:74d60177c6b6 | 511 | /* |
alan1974 | 0:a91cd1b08360 | 512 | case XDOT_CMD_SET_KEY_X: |
alan1974 | 7:fba1e8fc7693 | 513 | if(verbose)pc.printf("\n\r proc cmd: this command not used\r\n"); |
alan1974 | 0:a91cd1b08360 | 514 | wait_ms(I2C_MIN_WAIT_DELAY); |
alan1974 | 0:a91cd1b08360 | 515 | buf_xmt[0] = I2C_ACK_PROC; |
alan1974 | 0:a91cd1b08360 | 516 | buf_xmt[1] = XDOT_CMD_SET_KEY_X; |
alan1974 | 0:a91cd1b08360 | 517 | break; |
alan1974 | 17:74d60177c6b6 | 518 | */ |
alan1974 | 0:a91cd1b08360 | 519 | case XDOT_CMD_GATEWAY_PING: |
alan1974 | 5:abfe25f0de33 | 520 | if(verbose)pc.printf("\n\r proc cmd: xmit gateway ping\r\n"); |
alan1974 | 0:a91cd1b08360 | 521 | pkt_ping *pPing = (pkt_ping*)&buf_xmt[0]; |
alan1974 | 0:a91cd1b08360 | 522 | pPing->ack = I2C_ACK_PROC; |
alan1974 | 0:a91cd1b08360 | 523 | pPing->cmd = XDOT_CMD_GATEWAY_PING; |
alan1974 | 0:a91cd1b08360 | 524 | pPing->dataLen = 3; //only 3 bytes returned |
alan1974 | 5:abfe25f0de33 | 525 | if(verbose)pc.printf("\r\n----------- SENDING GATEWAY PING \r\n"); |
alan1974 | 0:a91cd1b08360 | 526 | mDot::ping_response ping_res; |
alan1974 | 0:a91cd1b08360 | 527 | ping_res = dot->ping(); |
alan1974 | 0:a91cd1b08360 | 528 | pPing->status = (int8_t)ping_res.status; |
alan1974 | 0:a91cd1b08360 | 529 | pPing->rssi = (int8_t)ping_res.rssi; |
alan1974 | 0:a91cd1b08360 | 530 | pPing->snr = (int8_t)ping_res.snr; |
alan1974 | 0:a91cd1b08360 | 531 | if (ping_res.status == 0) |
alan1974 | 5:abfe25f0de33 | 532 | if(verbose)pc.printf("\r\n----------- GATEWAY PING SUCCEEDED \r\n"); |
alan1974 | 0:a91cd1b08360 | 533 | else |
alan1974 | 5:abfe25f0de33 | 534 | if(verbose)pc.printf("\r\n----------- GATEWAY PING FAIL \r\n"); |
alan1974 | 0:a91cd1b08360 | 535 | break; |
alan1974 | 0:a91cd1b08360 | 536 | default: |
alan1974 | 5:abfe25f0de33 | 537 | if(verbose)pc.printf("\n\r proc cmd not recognized:%x",buf_rcv[0]); |
alan1974 | 0:a91cd1b08360 | 538 | wait_ms(I2C_MIN_WAIT_DELAY); |
alan1974 | 0:a91cd1b08360 | 539 | buf_xmt[0] = I2C_ACK_PROC; |
alan1974 | 0:a91cd1b08360 | 540 | buf_xmt[1] = XDOT_CMD_UNDEFINED; |
alan1974 | 0:a91cd1b08360 | 541 | } //switch buf_rcv[0] |
alan1974 | 0:a91cd1b08360 | 542 | //gpio1 =1; //test |
alan1974 | 0:a91cd1b08360 | 543 | if (bPulseLoraWake) i2c_pulse_wake(); //pulse wake-up lo->hi->lo to signal proc that xdot ready to send ack |
alan1974 | 0:a91cd1b08360 | 544 | |
alan1974 | 0:a91cd1b08360 | 545 | } //switch i2c_proc_comm |
alan1974 | 0:a91cd1b08360 | 546 | } //while |
alan1974 | 0:a91cd1b08360 | 547 | |
alan1974 | 0:a91cd1b08360 | 548 | } //main |
alan1974 | 0:a91cd1b08360 | 549 |