Revision 61:ebe1838a9301, committed 2018-03-10

Comitter:

NataliaRequejo

Date:

Sat Mar 10 14:05:32 2018 +0000

Parent:

60:fda7696090e1

Commit message:

Ejemplo Peer-To-Peer y OTA

Changed in this revision

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/ISL29011.lib	Sat Mar 10 14:05:32 2018 +0000
@@ -0,0 +1,1 @@
+http://os.mbed.com/teams/Multi-Hackers/code/ISL29011/#953adca17438

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/RadioEvent.h	Sat Mar 10 14:05:32 2018 +0000
@@ -0,0 +1,28 @@
+#ifndef __RADIO_EVENT_H__
+#define __RADIO_EVENT_H__
+
+#include "mDotEvent.h"
+
+class RadioEvent : public mDotEvent
+{
+ 
+public:
+    RadioEvent() {}
+ 
+    virtual ~RadioEvent() {}
+ 
+    virtual void MacEvent(LoRaMacEventFlags* flags, LoRaMacEventInfo* info) {
+        if (flags->Bits.Rx) {
+ 
+            logDebug("Rx %d bytes", info->RxBufferSize);
+            if (info->RxBufferSize > 0) {
+                // print RX data as string and hexadecimal 
+                std::string rx((const char*)info->RxBuffer, info->RxBufferSize);
+                printf("Rx data: %s [%s]\r\n", rx.c_str(), mts::Text::bin2hexString(info->RxBuffer, info->RxBufferSize).c_str());
+            }
+        }
+    }
+};
+
+#endif
+

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/libxDot-dev-mbed5.lib	Sat Mar 10 14:05:32 2018 +0000
@@ -0,0 +1,1 @@
+http://os.mbed.com/teams/MultiTech/code/libxDot-dev-mbed5/#8e7bfa8973b4

--- a/main.cpp	Mon Feb 26 13:30:02 2018 +0000
+++ b/main.cpp	Sat Mar 10 14:05:32 2018 +0000
@@ -1,12 +1,220 @@
 #include "mbed.h"
+#include "mDot.h"
+#include "MTSLog.h"
+#include "MTSText.h"
+#include "RadioEvent.h"
+#include "ChannelPlans.h"
+#include <string>
+#include <vector>
+
+//#define PEER_TO_PEER_SAMPLE 1
+ #define OTA
+using namespace mts;
+#if defined(PEER_TO_PEER_SAMPLE)
+static uint8_t network_address[] = { 0x01, 0x02, 0x03, 0x04 };
+static uint8_t network_session_key[] = { 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04 };
+static uint8_t data_session_key[] = { 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04, 0x01, 0x02, 0x03, 0x04 };
+#else
 
-DigitalOut led1(LED1);
+static std::string config_network_name = "conduitUNSAM";
+static std::string config_network_pass = "conduitUNSAM";
+static uint8_t config_frequency_sub_band = 4;
+#endif
+
+mDot* dot;
+lora::ChannelPlan* plan = NULL;
+
+void update_peer_to_peer_config(uint8_t *network_address, uint8_t *network_session_key, uint8_t *data_session_key, uint32_t tx_frequency, uint8_t tx_datarate, uint8_t tx_power) {
+    std::vector<uint8_t> current_network_address = dot->getNetworkAddress();
+    std::vector<uint8_t> current_network_session_key = dot->getNetworkSessionKey();
+    std::vector<uint8_t> current_data_session_key = dot->getDataSessionKey();
+    uint32_t current_tx_frequency = dot->getTxFrequency();
+    uint8_t current_tx_datarate = dot->getTxDataRate();
+    uint8_t current_tx_power = dot->getTxPower();
+
+    std::vector<uint8_t> network_address_vector(network_address, network_address + 4);
+    std::vector<uint8_t> network_session_key_vector(network_session_key, network_session_key + 16);
+    std::vector<uint8_t> data_session_key_vector(data_session_key, data_session_key + 16);
 
-// main() runs in its own thread in the OS
-int main() {
-    while (true) {
-        led1 = !led1;
-        wait(0.5);
+    if (current_network_address != network_address_vector) {
+        logInfo("changing network address from \"%s\" to \"%s\"", mts::Text::bin2hexString(current_network_address).c_str(), mts::Text::bin2hexString(network_address_vector).c_str());
+        if (dot->setNetworkAddress(network_address_vector) != mDot::MDOT_OK) {
+            logError("failed to set network address to \"%s\"", mts::Text::bin2hexString(network_address_vector).c_str());
+        }
+    }
+    
+    if (current_network_session_key != network_session_key_vector) {
+        logInfo("changing network session key from \"%s\" to \"%s\"", mts::Text::bin2hexString(current_network_session_key).c_str(), mts::Text::bin2hexString(network_session_key_vector).c_str());
+        if (dot->setNetworkSessionKey(network_session_key_vector) != mDot::MDOT_OK) {
+            logError("failed to set network session key to \"%s\"", mts::Text::bin2hexString(network_session_key_vector).c_str());
+        }
+    }
+    
+    if (current_data_session_key != data_session_key_vector) {
+        logInfo("changing data session key from \"%s\" to \"%s\"", mts::Text::bin2hexString(current_data_session_key).c_str(), mts::Text::bin2hexString(data_session_key_vector).c_str());
+        if (dot->setDataSessionKey(data_session_key_vector) != mDot::MDOT_OK) {
+            logError("failed to set data session key to \"%s\"", mts::Text::bin2hexString(data_session_key_vector).c_str());
+        }
+    }
+    
+    if (current_tx_frequency != tx_frequency) {
+    logInfo("changing TX frequency from %lu to %lu", current_tx_frequency, tx_frequency);
+    if (dot->setTxFrequency(tx_frequency) != mDot::MDOT_OK) {
+        logError("failed to set TX frequency to %lu", tx_frequency);
+    }
+    }
+
+    if (current_tx_datarate != tx_datarate) {
+    logInfo("changing TX datarate from %u to %u", current_tx_datarate, tx_datarate);
+    if (dot->setTxDataRate(tx_datarate) != mDot::MDOT_OK) {
+        logError("failed to set TX datarate to %u", tx_datarate);
+    }
+    }
+
+    if (current_tx_power != tx_power) {
+    logInfo("changing TX power from %u to %u", current_tx_power, tx_power);
+    if (dot->setTxPower(tx_power) != mDot::MDOT_OK) {
+        logError("failed to set TX power to %u", tx_power);
+    }
     }
 }
 
+int main() {
+    Serial debug(USBTX, USBRX);
+    debug.baud(115200);
+    
+    RadioEvent events;
+    
+    int32_t ret;
+    int32_t next_tx;
+    int32_t wait_time = 2;
+    
+    std::vector<uint8_t> send_data;
+    std::vector<uint8_t> recv_data;
+    uint8_t recv = 0;
+    uint8_t recv_mismatch = 0;
+    uint8_t send_failure = 0;
+    uint8_t iterations = 5;
+    
+    send_data.push_back(0x00);
+    send_data.push_back('N');
+    send_data.push_back('A');
+    send_data.push_back('T');
+    send_data.push_back('I');
+    send_data.push_back(' ');
+    send_data.push_back(' ');
+    send_data.push_back(' ');
+    
+    plan = new lora::ChannelPlan_US915();
+
+    dot = mDot::getInstance(plan);
+    logInfo("defaulting Dot configuration");
+    dot->resetConfig();
+    //si se hace un deep sleep la aplicacion inicia desde el principio.
+    //Y no desde el punto donde se ejecuto el deep_sleep
+    //Por esto es necesario salvar la sesion y luego recuperarla para continuar trabajando
+    //dot->resetNetworkSession();
+    //dot->restoreNetworkSession();
+    //dot->saveNetworkSession();
+    dot->setLogLevel(MTSLog::TRACE_LEVEL);
+    
+ #if defined(PEER_TO_PEER_SAMPLE)
+    // attach the custom events handler
+     dot->setEvents(&events);
+    
+    //Peer-to-peer    
+    // Actualizamos la configuracion de Join unicamente si es diferente 
+     //( 0= Manual, 1 = OTA, 2= AUTO_OTA, 3=Peer to Peer)
+    if (dot->getJoinMode() != mDot::PEER_TO_PEER) {
+        logInfo("changing network join mode to PEER_TO_PEER");
+        if (dot->setJoinMode(mDot::PEER_TO_PEER) != mDot::MDOT_OK) {
+            logError("failed to set network join mode to PEER_TO_PEER");
+        }
+    }
+    uint32_t tx_frequency= 915500000;
+    uint8_t tx_datarate = lora::DR_13;
+    uint8_t tx_power = 20;
+    
+    update_peer_to_peer_config(network_address, network_session_key, data_session_key, tx_frequency, tx_datarate, tx_power);
+
+ #else
+    // Actualizamos la configuracion de Join unicamente si es diferente 
+    //( 0= Manual, 1 = OTA, 2= AUTO_OTA, 3=Peer to Peer)
+    if (dot->getJoinMode() != mDot::AUTO_OTA) {
+        logInfo("changing network join mode to AUTO_OTA");
+        if (dot->setJoinMode(mDot::AUTO_OTA) != mDot::MDOT_OK) {
+            logError("failed to set network join mode to AUTO_OTA");
+        }
+    }
+    while ((ret = dot->setFrequencySubBand(config_frequency_sub_band)) != mDot::MDOT_OK) {
+        logError("failed to set frequency sub band: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+    }
+    while ((ret = dot->setNetworkName(config_network_name)) != mDot::MDOT_OK) {
+        logError("failed to set network name: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+    }
+    while ((ret = dot->setNetworkPassphrase(config_network_pass)) != mDot::MDOT_OK) {
+        logError("failed to set network password: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+    }
+    while ((ret = dot->setPublicNetwork(1)) != mDot::MDOT_OK) {
+        logError("failed to set public network : [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+    }
+    
+ #endif
+        
+    // save changes to configuration
+    logInfo("saving configuration");
+    if (!dot->saveConfig()) {
+        logError("failed to save configuration");
+    }
+    
+    //logInfo("enabling activity LED");
+    dot->setActivityLedEnable(true);
+ 
+    logInfo("joining network");
+    while ((ret = dot->joinNetwork()) != mDot::MDOT_OK) {
+        logError("failed to join network: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+        wait_ms(dot->getNextTxMs() + 1);
+    }
+    logInfo("joined");
+ 
+    for (uint8_t i = 0; i < iterations; i++) {
+        send_data[0] = i;//Envio en que iteracion estoy
+        if ((ret = dot->send(send_data)) != mDot::MDOT_OK) {
+            logError("failed to send: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+            send_failure++;
+        } else {
+            logInfo("send data: %s", Text::bin2hexString(send_data).c_str());
+            //La funcion RECV() No funciona en peer to peer. La ventana de tiempo en que esta abierto 
+            //el canal despues de hacer el send, para escuchar la respuesta es
+            //muy corta y seria muy dificil hacer la sincronizacion 
+            //En peer to peer el dispositivo nunca se pone en deep sleep y esta escuchando continumente.
+            //Por lo tanto la respuesta unicamente vendra a traves de un evento.
+            //Por el contrario cuando la comunicacion es OTA, con el gateway aqui si deberiamos obtener el mensaje.
+            if ((ret = dot->recv(recv_data)) != mDot::MDOT_OK) {
+                logError("failed to recv: [%d][%s]", ret, mDot::getReturnCodeString(ret).c_str());
+            } else {
+                logInfo("recv data: %s", Text::bin2hexString(recv_data).c_str());
+                if (recv_data == send_data) {
+                    recv++;
+                } else {
+                    recv_mismatch++;
+                }
+            }
+            recv_data.clear();
+        }
+        
+        next_tx = dot->getNextTxMs() + 1;
+        logInfo("waiting %ld ms to transmit again", next_tx);
+        wait_ms(next_tx);
+        logInfo("waiting another %d seconds", wait_time);
+        wait(wait_time);
+    }
+    
+    logInfo("Version: %s", dot->getId().c_str());
+    logInfo("Recv: %d/%d", recv, iterations);
+    logInfo("Recv Mismatch: %d/%d", recv_mismatch, iterations);
+    logInfo("Send Failure: %d/%d", send_failure, iterations);
+    logInfo("Dropped: %d/%d", iterations - (recv + recv_mismatch + send_failure), iterations);
+ 
+    return 0;
+}