alan broad
arm studio build
src/main.cpp
- Committer:
- alan1974
- Date:
- 2018-08-04
- Revision:
- 2:0af50f386eb2
- Parent:
- 1:0d25d9ddbe9f
- Child:
- 5:abfe25f0de33
File content as of revision 2:0af50f386eb2:
#include "mbed.h"
#include "global.h"
#include "commI2C.h"
#include "dot_util.h"
#include "wbit_util.h"
#include "mDot.h"
#include "RadioEvent.h"
#include "Lora.h"
//nvm storage params
nvm nvmData;
nvm *pNvmData = &nvmData;
//=======================================================================================================
// enable some GPIO for scope trigger or led
//=======================================================================================================
//#define GPIO_ENABLE
//=======================================================================================================
// configure for either private (test only) or public network (standard)
//=======================================================================================================
//#define MT_PRIVATE_NETWORK //ENABLE THIS FOR PRIVATE NETWORK
//=======================================================================================================
//code api level and version
//api_level: proc code will not run if api level (last two bytess) greater than what it expects
//=======================================================================================================
uint8_t api_level[4] = { 0x00, 0x00, 0x00, 0x03 }; //api-level, determines if xdot code works with proc code
uint8_t ver_level[4] = { 0x00, 0x00, 0x00, 0x07 }; //updated for every code check-in
//=======================================================================================================
//configuring mbed pinsa; https://docs.mbed.com/docs/mbed-os-api-reference/en/latest/APIs/io/DigitalInOut/
// * these options must match the settings on your gateway //
// * edit their values to match your configuration //
// * frequency sub band is only relevant for the 915 bands //
// * either the network name and passphrase can be used or //
// the network ID (8 bytes) and KEY (16 bytes) //
//=======================================================================================================
static std::string network_name = "asdfqwer"; //not used
static std::string network_passphrase = "zxcvasdf"; //not used
/*
uint8_t network_id[] = { 0x90, 0xF1, 0x47, 0x90, 0x6C, 0x48, 0x1D, 0x29 }; //static id not used anymore but don't comment out
//OTAA keys
uint8_t network_key[] = { 0x0F, 0xF9, 0xA2, 0x90, 0x2E, 0xAA, 0x6B, 0x8C, 0x6A, 0x4E, 0xFD, 0x67, 0xF9, 0xA6, 0xF3, 0xD3 }; //appkey
*/
#ifdef MT_PRIVATE_NETWORK
static uint8_t frequency_sub_band = 4;
static bool public_network = false;
static uint8_t ack = 1; //0;
#else
uint8_t frequency_sub_band = 1;
bool public_network = true; //false
uint8_t ack = 1; //0;
uint8_t link_check_treshold = 100; //5;
#endif
bool adr = false; //set adaptive data rate
//=======================================================================================================
// deepsleep consumes slightly less current than sleep
// in sleep mode, IO state is maintained, RAM is retained, and application will resume after waking up
// in deepsleep mode, IOs float, RAM is lost, and application will start from beginning after waking up
// if deep_sleep == true, device will enter deepsleep mode
//=======================================================================================================
static bool deep_sleep = false; //false;
uint32_t packets_sent = 0;
uint32_t acks_rcvd = 0;
int8_t rssi =0; //rssi of last rcvd rx1/rx2
std::string eui = " ";
static bool led_enabled = false; //true; //false;
mDot* dot = NULL;
lora::ChannelPlan* plan = NULL;
uint8_t buf_xmt[BUFFER_SIZE_I2C]; //outgoing data
uint8_t buf_rcv[BUFFER_SIZE_I2C]; //incoming data
std::vector<uint8_t> upstream_packet;
#ifdef GPIO_ENABLE
DigitalOut led1(PB_0); //LED1);
DigitalInOut gpio1(PA_5); //scope debug PA-5 is connected to SW1 pads on Loren v04 and can be used for scope debug
#endif
Serial pc(USBTX, USBRX); //serial port output
//=================================================================================================
//LED_test
//=================================================================================================
void LED_test(int num)
{
#ifdef GPIO_ENABLE
if (led_enabled)
{
pc.printf("LED_test()\r\n");
int test;
for (test=0; test<num; test++)
{
led1 = 0;
wait_ms(500);
led1 = 1;
wait_ms(500);
}
}
#endif
}
//==================================================================================
//chksum
//compute checksum over i2c buffer except for last byte (chksum byte)
//==================================================================================
uint8_t chksum_proc(uint8_t *bfr_xdot){
uint8_t i;
uint8_t chksum = 0;
for (i=0; i < BUFFER_SIZE_I2C-1;i++)chksum += bfr_xdot[i];//good code
return chksum;
}
//=================================================================================================
//cfg_network:
// configure the network public/private and sub-band
// bForceCfg : true => force a network cfg
// false => only change if bPublic or sub_band have changed
// bPublic : true if network is public, else private
// sub_band: sub band number (1..8)
// NOTE: THIS ONLY WORKS WHEN THE XDOT BOOTS UP. IT DOES NOT WORK WHEN TRYING TO CHANGE AFTER.
// NOT SURE WHY...WHEN THE XDOT REJOINS IT SHOULD USE NEW SESSION SETTINGS... asb
//
//asb:dec 2017: try this later and see if it works:mdot.h:
// int32_t setPublicNetwork(const bool& on);
// bool getPublicNetwork();
// int32_t setFrequencySubBand(const uint8_t& band);
//=================================================================================================
bool cfg_network(bool bForceCfg,bool bPublic,uint8_t sub_band){
// if bForceCfg false and network parameters haven't changed then just exit
if (!bForceCfg){
pc.printf("no configuration change needed subband the same");
if ((public_network ==bPublic) && (frequency_sub_band ==sub_band))return true;
}
pc.printf("changing to subband: %d\r\n",sub_band);
// update network settings
public_network = bPublic;
frequency_sub_band =sub_band;
// start from a well-known state
logInfo("defaulting Dot configuration");
//dot->resetConfig(); //reset config to factory default not used for v0307
dot->resetNetworkSession(); //Reset current network session, essentially disconnecting from the network
if (dot->getJoinMode() != mDot::OTA) { // update configuration if necessary
logInfo("changing network join mode to OTA");
if (dot->setJoinMode(mDot::OTA) != mDot::MDOT_OK) {
logError("failed to set network join mode to OTA");
return false;
}
}
// 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
// only one method or the other should be used!
if (public_network){
// update_ota_config_id_key(network_id, network_key, frequency_sub_band, public_network, ack);
update_ota_config_id_key(nvmData.network_id,nvmData.network_key, frequency_sub_band, public_network, ack);
logInfo("-------------- network configured for public access -----------------------------");
}
else{
update_ota_config_name_phrase(network_name, network_passphrase, frequency_sub_band, public_network, ack);
logInfo("-------------- network configured for private access -------------------------------");
}
// configure network link check count
// declares the Dot disconnected if no acks received within link_check_treshold transmits
//update_network_link_check_config(3, 5);
dot->setLinkCheckThreshold(link_check_treshold);
/* done thru radio cmds
// save changes to configuration
logInfo("saving configuration");
if (!dot->saveConfig()) {
logError("failed to save configuration");
return false;
}
display_config();
*/
return true;
}
//=================================================================================================
//main()
// main() runs in its own thread in the OS
// (note the calls to wait below for delays)
//=================================================================================================
int main() {
uint8_t i;
RadioEvent events;
mDotEvent mdotevent; //used to get ping info????
plan = new lora::ChannelPlan_US915();
#ifdef GPIO_ENABLE
gpio1.output();
gpio1 =0;
led1 = 1;
#endif
pc.baud(115200);
pc.printf("\r\n**********************************************************\r\n");
pc.printf("\r\n XDOT BOOT\r\n");
pc.printf("COMM api_level = <HEX> %x.%x.%x.%x\r\n",api_level[0],api_level[1],api_level[2],api_level[3]);
pc.printf("COMM version = %x.%x.%x.%x\r\n",ver_level[0],ver_level[1],ver_level[2],ver_level[3]);
pc.printf("**********************************************************\r\n");
assert(plan);
dot = mDot::getInstance(plan);
assert(dot);
//dot->setLogLevel((true) ? mts::MTSLog::TRACE_LEVEL : mts::MTSLog::TRACE_LEVEL); // TRACE_LEVEL , INFO_LEVEL
bool bLogOutput = true;
dot->setLogLevel((bLogOutput) ? mts::MTSLog::TRACE_LEVEL : mts::MTSLog::TRACE_LEVEL); // TRACE_LEVEL , INFO_LEVEL
dot->setEvents(&events);
//nvm nvmData;
//nvm *pNvmData = &nvmData;
nvmRead(pNvmData);
/*
pc.printf("****NON-VOLATILE MEMORY TEST*********\r\n");
for (i = 0; i < sizeof(network_id);i++){
nvmData.network_id[i] = network_id[i];
}
for (i = 0; i < sizeof(network_key);i++){
nvmData.network_key[i] = network_key[i];
}
uint8_t databytesread[128];
dot->nvmWrite(0,pData,128);
dot->nvmRead(0, databytesread,128);
for (i = 0; i < 64; i++)
pc.printf("databyte %d: %x\r\n",i,databytesread[i]);
pc.printf("****NON-VOLATILE MEMORY TEST*********\r\n");
*/
// getStandbyFlag() should return the state of the standby flag directly from the processor
// 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)
// 0: Device has not been in Standby mode
// 1: Device has been in Standby mode
// 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.
if (!dot->getStandbyFlag()) { //if 0 => power-up/reset which should always be the case at this point
logInfo("mbed-os library version: %d", MBED_LIBRARY_VERSION);
pc.printf("\r\n saved configuration: ");
frequency_sub_band = dot->getFrequencySubBand();
pc.printf("\r\n subband: %d ",frequency_sub_band);
pc.printf("\r\n ADR: %d ",dot->getAdr());
pc.printf("\r\n antenna gain: %d ",dot->getAntennaGain());
pc.printf("\r\n transmit max pwr: %d ",dot->getMaxTxPower());
pc.printf("\r\n transmit min pwr: %d ",dot->getMinTxPower());
pc.printf("\r\n transmit pwr: %d ",dot->getTxPower());
pc.printf("\r\n TxDataRate: %d ",dot->getTxDataRate());
pc.printf("\r\n maxPktLen: %d ",dot->getMaxPacketLength());
// pc.printf("\r\n port nmb: %d ",dot->getAppPort());
pc.printf("\r\n link check count: %d ",dot->getLinkCheckThreshold());
pc.printf("\r\n");
cfg_network(true,public_network,frequency_sub_band); //force network cfg,
} else {
// restore the saved session (join OTAA info) if the dot woke from deepsleep mode
// useful to use with deepsleep because session info is otherwise lost when the dot enters deepsleep
logInfo("restoring network session from NVM");
dot->restoreNetworkSession();
}
//--------------------------------------------------------------------------------------------------------------------------------------------
// configure network link check count
// declares the Dot disconnected if no acks received within link_check_treshold transmits
//update_network_link_check_config(3, 5);
dot->setLinkCheckThreshold(link_check_treshold);
//----------------------------------------------------------------------------------------------------------------------------------------------
// save changes to configuration
// logInfo("saving configuration");
eui = mts::Text::bin2hexString(dot->getDeviceId()).c_str();
pc.printf("\r\nEUI: %s\r\n",eui);
bool joined = false;
i2c_proc_init(); //init i2c comm
sleep_wake_interrupt_only(deep_sleep);
//scope test
// gpio1 =1;
//==============================================================================
// -loop here forever
// -sleep until LORA_WAKE goes hi => proc ready to send i2c cmd
// -start polling incoming i2c bus for proc cmd
// -execute cmd
// -take control of LORA_WAKE and toggle it hi to signal proc that xdot
// ready to send i2c ack message
// -go back to sleep
//==============================================================================
bool bPulseLoraWake = false;
while(1)
{
pc.printf("\n\r ***************************** ");
switch (i2c_proc_comm()){
case I2C_WRITE: //xdot ack ->proc
pc.printf("\n\r xdot ack -> proc done,going to sleep\n\r ");
bPulseLoraWake = false;
// gpio1 =0;
sleep_wake_interrupt_only(deep_sleep); //wait for wake
// gpio1 =1;
pc.printf("\n\r lora wake detected -> monitoring i2c bus\n\r ");
break;
case I2C_READ: //xdot <- proc
bPulseLoraWake = true;
switch (buf_rcv[0])
{
case XDOT_CMD_XMIT_PKT:
pkt_upstrm *pUp= (pkt_upstrm*)&buf_rcv[0];
pkt_ack *pAck = (pkt_ack*)&buf_xmt[0];
pAck->ack = I2C_ACK_PROC;
pAck->cmd = XDOT_CMD_XMIT_PKT;
//pAck->dataLen = buf_rcv[1];
pAck->dataLen = pUp->dataLen; //data len of xmitted pkt
pc.printf("\r\npkt to xmit data len: %d\r\n",pAck->dataLen);
uint8_t chksum = chksum_proc(buf_rcv);
//pc.printf("\r\chksum rcvd: %d, chksum computed: %d\r\n",chksum,pkt_upstrm->chksum);
pc.printf("\r\nI2C chksum rcvd: %d",chksum);
pc.printf(" chksum computed: %d",pUp->chksum);
pAck->bXmitAttempted = 1;
pAck->chksum_err = 0;
if(pUp->chksum != chksum){
pc.printf(" chksum err, aborting xmit");
pAck->bXmitAttempted = 0;
pAck->mdot_ret = -2048; //wbit rtn code?
pAck->chksum_err = 1;
break;
}
//rev 0307 parameters
pc.printf("\n\r setting application port %d ",pUp->appPort); //appPort not used in rev < 0307
dot->setAppPort(pUp->appPort);
uint8_t linkFailcnt = dot->getLinkFailCount();
pc.printf("\r\n lINK fail count %d\r\n",linkFailcnt);
if (pUp->bResetLinkCCounter){
dot->setLinkFailCount(0);
pc.printf("\r\n reset link fail threshold to zero");
}
if (pUp->dataLen == 0){ //datalen non zero?
pAck->bXmitAttempted = 0;
break;
}
upstream_packet.clear(); //xfr data from incoming bfr to xmit bfr
for (i=0; i< pUp->dataLen;i++) upstream_packet.push_back(pUp->txData[i]);
pc.printf("\r\n[TEST],Upstream Packet Received"); // no \r\n because it comes below
for(std::vector<uint8_t>::iterator it = upstream_packet.begin(); it != upstream_packet.end(); ++it) pc.printf(",0x%x", *it);
pc.printf("\r\n"); // see i told you.
joined = dot->getNetworkJoinStatus(); //are we joined to Lorawan?
pAck->joinAttempts = 0; //no attempts made yet to join
pAck->bAck = 0; //won't know if we receive a lorawan ack until after xmit
pAck->bAckdata = 0; //won't know if we receive a lorawan ack downstream data until after xmit
pAck->rssi = 0; //if not rx1/rx2 then no RSSI value
if(!joined) { //if not previously joined, then need to join now
pAck->bJoined = 0;
pc.printf("\r\n----------- NETWORK NOT JOINED YET, WILL TRY TO JOIN %d TIMES\r\n",pUp->joinAttemps);
joined = join_network_wbit(pUp->joinAttemps);
pAck->joinAttempts = join_network_attempts_wbit();
pAck->mdot_ret = dot->send(upstream_packet);
if (!joined)pc.printf("\r\n----------- FAILED TO JOIN...GIVING UP\r\n"); // join network if not joined
}
if (joined){
pAck->bJoined = 1; //we are joined to the network
packets_sent++;
//send packet
//return code indicates results, send return code back to proc Dec14,2017
pAck->mdot_ret = dot->send(upstream_packet);
printf("\n\rdata->send() return code: %d\r\n",pAck->mdot_ret);
if (pAck->mdot_ret == mDot::MDOT_OK){ //xmit the pkt in blocking mode, return false if no ack
//if (dot->send(upstream_packet) == mDot::MDOT_OK){ //xmit the pkt in blocking mode, return false if no ack
acks_rcvd++;
pAck->bAck = 1; //we got a Rx1 or Rx2 ack
mDot::rssi_stats rssiStats = dot->getRssiStats(); //rssi stat
pAck->rssi = (int8_t)rssiStats.last;
printf("\n\rdata->send()= true => ack rcvd :ack=: %d, rssi=: %d\r\n",pAck->bAck,pAck->rssi);
if (events.is_packet_received()){ //any downstream data from the Rx1/Rx2 pkt?
printf("\n\revents.is_packet_received = true\r\n");
pAck->bAckdata = 1;
upstream_packet.clear();
upstream_packet = events.get_downstream_packet();
pAck->rxLen = upstream_packet.size();
if (pAck->rxLen > I2C_MAX_ACK_DATA){
pc.printf("\r\n got ack with pkt data too large.. rejected\r\n");
break;
}
pc.printf("\r\n pkt data: ");
for (i=0; i< pAck->rxLen;i++) {
pAck->rxData[i]= upstream_packet[i];
pc.printf(" %x",pAck->rxData[i]);
}
} //if downstream data rcvd
else{
printf("\n\revents.is_packet_received ()= false => ack rcvd but no data\r\n");
}
} //send() returns K
else{
printf("\n\rdata->send()= false => no ack\r\n"); //could be some other error
}
}//if joined
break;
case XDOT_CMD_SET_RADIO:
pc.printf("\n\r proc cmd: CMD_SET_RADIO");
pkt_setradiodwn *pDwnRadio= (pkt_setradiodwn*)&buf_xmt[0];
pkt_setradioup *pUpRadio = (pkt_setradioup*)&buf_rcv[0];
pDwnRadio->ack = I2C_ACK_PROC;
pDwnRadio->cmd = XDOT_CMD_SET_RADIO;
if (pUpRadio->bSetParams){
pc.printf("\n\r setting subband to %d ",pUpRadio->params.sub_band);
cfg_network(false,true,(uint8_t)pUpRadio->params.sub_band);
pc.printf("\n\r setting adr to %d ",pUpRadio->params.aDR);
dot->setAdr((uint8_t)pUpRadio->params.aDR); // enable or disable Adaptive Data Rate
pc.printf("\n\r setting antenna gain to %d ",pUpRadio->params.antennaGaindBi);
dot->setAntennaGain(pUpRadio->params.antennaGaindBi);
pc.printf("\n\r setting radio tx power to %d ",pUpRadio->params.txPowerdBm);
dot->setTxPower(pUpRadio->params.txPowerdBm);
pc.printf("\n\r setting tx datarate to %d ",pUpRadio->params.dataRate);
dot->setTxDataRate(pUpRadio->params.dataRate);
// pc.printf("\n\r setting application port %d ",pUpRadio->appPort);
// dot->setAppPort(pUpRadio->appPort);
pc.printf("\n\r setting link check threshold %d ",pUpRadio->params.linkChkCount);
dot->setLinkCheckThreshold(pUpRadio->params.linkChkCount);
pc.printf("\n\r saving configuration");
if (!dot->saveConfig())logError("failed to save configuration");
display_config();
}
pDwnRadio->params.public_network = public_network;
pDwnRadio->params.sub_band = dot->getFrequencySubBand();
pDwnRadio->params.linkChkCount = dot->getLinkCheckThreshold();
pDwnRadio->params.maxDataLen = dot->getMaxPacketLength();
pDwnRadio->params.maxTxPowerdBm = dot->getMaxTxPower();
pDwnRadio->params.minTxPowerdBm = dot->getMinTxPower();
pDwnRadio->params.aDR = dot->getAdr();
pDwnRadio->params.antennaGaindBi = dot->getAntennaGain();
pDwnRadio->params.txPowerdBm = dot->getTxPower();
pDwnRadio->params.dataRate = dot->getTxDataRate();
// pDwnRadio->appPort = dot->getAppPort();
break;
case XDOT_CMD_GET_EUI: //0307: modified to include radio parameter settings
pc.printf("\n\r proc cmd: get EUI");
pkt_eui *peui = (pkt_eui*)&buf_xmt[0];
peui->ack = I2C_ACK_PROC;
peui->cmd = XDOT_CMD_GET_EUI;
upstream_packet.clear();
upstream_packet = dot->getDeviceId();
peui->dataLen = upstream_packet.size();
for (i=0; i< peui->dataLen;i++) peui->euiData[i] = upstream_packet[i];
for (i=0; i< 4;i++) peui->apiLvlData[i] = api_level[i];
for (i=0; i< 4;i++) peui->verLvlData[i] = ver_level[i];
peui->dataLen = sizeof(pkt_eui)-3; //size of struc minus first 3 bytes
pc.printf("\n\r eui data length: %d",peui->dataLen);
break;
case XDOT_CMD_SET_NTWKSESS: //read or write network seesion to xdot flash
bool bWriteSession = (bool)buf_rcv[1];
if (bWriteSession){
pc.printf("\n\r proc cmd writing network sesion to flash");
dot->saveNetworkSession();
}
else{
pc.printf("\n\r reading network session from flash");
dot->restoreNetworkSession();
}
pkt_ntwrk *pktwrk = (pkt_ntwrk*)&buf_xmt[0];
pktwrk->ack = I2C_ACK_PROC;
pktwrk->cmd = XDOT_CMD_SET_NTWKSESS;
pktwrk->bSetNetwrk = (uint8_t)bWriteSession;
break;
case XDOT_CMD_SET_NVM:
pkt_setnvmdwn *pDwnNvm= (pkt_setnvmdwn*)&buf_xmt[0];
pkt_setnvmup *pUpNvm = (pkt_setnvmup*)&buf_rcv[0];
pDwnNvm->ack = I2C_ACK_PROC;
pDwnNvm->cmd = XDOT_CMD_SET_RADIO;
nvmWrite(&pUpNvm->nvmData);
nvmRead(&pDwnNvm->nvmData);
break;
case XDOT_CMD_SET_KEY_X:
pc.printf("\n\r proc cmd: set a key, simulating minm delay before wake pulse\r\n");
wait_ms(I2C_MIN_WAIT_DELAY);
buf_xmt[0] = I2C_ACK_PROC;
buf_xmt[1] = XDOT_CMD_SET_KEY_X;
break;
case XDOT_CMD_GATEWAY_PING:
pc.printf("\n\r proc cmd: xmit gateway ping\r\n");
pkt_ping *pPing = (pkt_ping*)&buf_xmt[0];
pPing->ack = I2C_ACK_PROC;
pPing->cmd = XDOT_CMD_GATEWAY_PING;
pPing->dataLen = 3; //only 3 bytes returned
pc.printf("\r\n----------- SENDING GATEWAY PING \r\n");
mDot::ping_response ping_res;
ping_res = dot->ping();
pPing->status = (int8_t)ping_res.status;
pPing->rssi = (int8_t)ping_res.rssi;
pPing->snr = (int8_t)ping_res.snr;
if (ping_res.status == 0)
pc.printf("\r\n----------- GATEWAY PING SUCCEEDED \r\n");
else
pc.printf("\r\n----------- GATEWAY PING FAIL \r\n");
break;
default:
pc.printf("\n\r proc cmd not recognized:%x",buf_rcv[0]);
wait_ms(I2C_MIN_WAIT_DELAY);
buf_xmt[0] = I2C_ACK_PROC;
buf_xmt[1] = XDOT_CMD_UNDEFINED;
} //switch buf_rcv[0]
//gpio1 =1; //test
if (bPulseLoraWake) i2c_pulse_wake(); //pulse wake-up lo->hi->lo to signal proc that xdot ready to send ack
} //switch i2c_proc_comm
} //while
} //main