Adrian Mitevski / Mbed 2 deprecated mDot_LoRa_Sensornode

A multifunctional and modular Firmware for Multitech's mDot based on ARM mBed provides a widerange of functionality for several Sensors such as MAX44009, BME280, MPU9250, SI1143 and uBlox. It allows you to quickly build a Sensornode that measures specific data with its sensors and sends it via LoRaWAN.

Dependencies:   mDot_LoRa_Sensornode_Flowmeter_impl mbed-rtos mbed

LoRa-Sensornode Firmware for Multitech mDot

A multifunctional and modular Firmware for Multitech's mDot which provides a widerange of functionality for several Sensors. It allows you to quickly build a Sensornode that measures specific data with its sensors and sends it via LoRaWAN.

/media/uploads/mitea1/logo-lora-600x370.png /media/uploads/mitea1/mt_mdot_family_642px.png

Supported Sensors

Idea

The Firmware has some predefined Application Modes running different Tasks(Measurements). Each mode can be used in a different Scenario. Application_Modes define which sensors are used, how often they aquire data and how often the data has to be sent via LoRa. Lets say you just want to measure the Light then you choose an Application_Mode (or define one) that only runs TaskLight for light measurement. As a standard all measurements are taken every second and sent via LoRa but you can change that interval depending on your usage Scenario

app/TaskDatahandler.cpp@7:87cbeafdba06, 2016-10-08 (annotated)

Committer:
mitea1
Date:
Sat Oct 08 09:55:41 2016 +0000
Revision:
7:87cbeafdba06
Parent:
1:fe242f3e341b
Child:
9:c4e378f4801d
LoRa Downlink Messages can now be received. Command Receiver and Handler implemented.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
mitea1 0:f2815503561f 1 /*
mitea1 0:f2815503561f 2 * TaskDatahandler.cpp
mitea1 0:f2815503561f 3 *
mitea1 0:f2815503561f 4 * Created on: May 27, 2016
mitea1 0:f2815503561f 5 * Author: Adrian
mitea1 0:f2815503561f 6 */
mitea1 0:f2815503561f 7
mitea1 0:f2815503561f 8 #include "TaskDatahandler.h"
mitea1 0:f2815503561f 9
mitea1 0:f2815503561f 10 TaskDatahandler::TaskDatahandler(LoRa* lora,Mutex* mutexLora, QueueBundle queueBundle,
mitea1 0:f2815503561f 11 osPriority priority,uint32_t stackSize, unsigned char* stackPointer){
mitea1 0:f2815503561f 12 setLoRa(lora);
mitea1 0:f2815503561f 13 setMutex(mutexLora);
mitea1 0:f2815503561f 14 setQueueBundle(queueBundle);
mitea1 0:f2815503561f 15 setPriority(priority);
mitea1 0:f2815503561f 16 setStackSize(stackSize);
mitea1 0:f2815503561f 17 setStackPointer(stackPointer);
mitea1 0:f2815503561f 18 setState(SLEEPING);
mitea1 0:f2815503561f 19 }
mitea1 0:f2815503561f 20
mitea1 0:f2815503561f 21 TaskDatahandler::~TaskDatahandler() {
mitea1 0:f2815503561f 22 // TODO Auto-generated destructor stub
mitea1 0:f2815503561f 23 }
mitea1 0:f2815503561f 24
mitea1 0:f2815503561f 25 osStatus TaskDatahandler::start(){
mitea1 0:f2815503561f 26 setState(RUNNING);
mitea1 0:f2815503561f 27 this->thread = new rtos::Thread(callBack,this);
mitea1 1:fe242f3e341b 28 attachIdleHook(NULL);
mitea1 0:f2815503561f 29 }
mitea1 0:f2815503561f 30
mitea1 0:f2815503561f 31 osStatus TaskDatahandler::stop(){
mitea1 0:f2815503561f 32 thread->terminate();
mitea1 0:f2815503561f 33 setState(SLEEPING);
mitea1 0:f2815503561f 34 delete this->thread;
mitea1 0:f2815503561f 35 }
mitea1 0:f2815503561f 36
mitea1 0:f2815503561f 37 void TaskDatahandler::callBack(void const* data){
mitea1 0:f2815503561f 38 // WOODHAMMER METHOD of Casting!
mitea1 0:f2815503561f 39 const TaskDatahandler* constInstance = static_cast<const TaskDatahandler* >(data);
mitea1 0:f2815503561f 40 TaskDatahandler* instance = const_cast<TaskDatahandler*>(constInstance);
mitea1 0:f2815503561f 41
mitea1 0:f2815503561f 42 instance->handleData();
mitea1 0:f2815503561f 43 }
mitea1 0:f2815503561f 44
mitea1 1:fe242f3e341b 45 void TaskDatahandler::attachIdleHook(void (*fptr) (void)){
mitea1 1:fe242f3e341b 46 this->thread->attach_idle_hook(fptr);
mitea1 1:fe242f3e341b 47 }
mitea1 1:fe242f3e341b 48
mitea1 0:f2815503561f 49 void TaskDatahandler::handleData(){
mitea1 0:f2815503561f 50
mitea1 0:f2815503561f 51 while(true){
mitea1 0:f2815503561f 52 getMessagesFromSensorQueues();
mitea1 0:f2815503561f 53 forwardSensorMessages();
mitea1 1:fe242f3e341b 54 osDelay(std::max((uint32_t)DATAHANLDER_TASK_DELAY_MS,(uint32_t)lora->getNextTxMs()));
mitea1 0:f2815503561f 55 }
mitea1 0:f2815503561f 56 }
mitea1 0:f2815503561f 57
mitea1 0:f2815503561f 58 void TaskDatahandler::getMessagesFromSensorQueues(){
mitea1 0:f2815503561f 59 lightMeasureEvent = queueBundle.queueLight->get(0);
mitea1 0:f2815503561f 60 temperatureMeasureEvent = queueBundle.queueTemperature->get(0);
mitea1 0:f2815503561f 61 pressureMeasureEvent = queueBundle.queuePressure->get(0);
mitea1 0:f2815503561f 62 humidityMeasureEvent = queueBundle.queueHumidity->get(0);
mitea1 0:f2815503561f 63 accelerationMeasureEvent = queueBundle.queueAcceleration->get(0);
mitea1 0:f2815503561f 64 gyroscopeMeasureEvent = queueBundle.queueGyro->get(0);
mitea1 0:f2815503561f 65 teslaMeasureEvent = queueBundle.queueTesla->get(0);
mitea1 0:f2815503561f 66 proximityMeasureEvent = queueBundle.queueProximity->get(0);
mitea1 0:f2815503561f 67 gpsMeasureEvent = queueBundle.queueGps->get(0);
mitea1 0:f2815503561f 68 loraMeasureEvent = queueBundle.queueLoRaMeasurments->get(0);
mitea1 0:f2815503561f 69 }
mitea1 0:f2815503561f 70
mitea1 0:f2815503561f 71 void TaskDatahandler::forwardSensorMessages(){
mitea1 0:f2815503561f 72 std::string loraMessage;
mitea1 0:f2815503561f 73 std::vector<uint8_t> dataToSend;
mitea1 0:f2815503561f 74 std::vector<uint8_t> dataReceived;
mitea1 0:f2815503561f 75
mitea1 0:f2815503561f 76 int32_t ret;
mitea1 0:f2815503561f 77
mitea1 0:f2815503561f 78 debugSerial->printf("\n");
mitea1 0:f2815503561f 79 if (lightMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 80 MAX44009Message* luxMessage = (MAX44009Message*) lightMeasureEvent.value.p;
mitea1 0:f2815503561f 81 debugSerial->printf("%s\n",luxMessage->getLoRaMessageString());
mitea1 0:f2815503561f 82 loraMessage.append(luxMessage->getLoRaMessageString());
mitea1 0:f2815503561f 83 }
mitea1 0:f2815503561f 84
mitea1 0:f2815503561f 85 if (temperatureMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 86 BME280TemperatureMessage* temperatureMessage = (BME280TemperatureMessage*) temperatureMeasureEvent.value.p;
mitea1 0:f2815503561f 87 debugSerial->printf("%s\n",temperatureMessage->getLoRaMessageString());
mitea1 0:f2815503561f 88 loraMessage.append(temperatureMessage->getLoRaMessageString());
mitea1 0:f2815503561f 89 }
mitea1 0:f2815503561f 90
mitea1 0:f2815503561f 91 if (pressureMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 92 BME280PressureMessage* pressureMessage = (BME280PressureMessage*) pressureMeasureEvent.value.p;
mitea1 0:f2815503561f 93 debugSerial->printf("%s\n",pressureMessage->getLoRaMessageString());
mitea1 0:f2815503561f 94 loraMessage.append(pressureMessage->getLoRaMessageString());
mitea1 0:f2815503561f 95 }
mitea1 0:f2815503561f 96
mitea1 0:f2815503561f 97 if (humidityMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 98 BME280HumidityMessage* humidityMessage = (BME280HumidityMessage*) humidityMeasureEvent.value.p;
mitea1 0:f2815503561f 99 debugSerial->printf("%s\n",humidityMessage->getLoRaMessageString());
mitea1 0:f2815503561f 100 loraMessage.append(humidityMessage->getLoRaMessageString());
mitea1 0:f2815503561f 101 }
mitea1 0:f2815503561f 102
mitea1 0:f2815503561f 103 if (accelerationMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 104 MPU9250AccelerationMessage* accelerationMessage = (MPU9250AccelerationMessage*) accelerationMeasureEvent.value.p;
mitea1 0:f2815503561f 105 debugSerial->printf("%s\n",accelerationMessage->getLoRaMessageString());
mitea1 0:f2815503561f 106 loraMessage.append(accelerationMessage->getLoRaMessageString());
mitea1 0:f2815503561f 107 }
mitea1 0:f2815503561f 108
mitea1 0:f2815503561f 109 if (gyroscopeMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 110 MPU9250GyroscopeMessage* gyroscopeMessage = (MPU9250GyroscopeMessage*) gyroscopeMeasureEvent.value.p;
mitea1 0:f2815503561f 111 debugSerial->printf("%s\n",gyroscopeMessage->getLoRaMessageString());
mitea1 0:f2815503561f 112 loraMessage.append(gyroscopeMessage->getLoRaMessageString());
mitea1 0:f2815503561f 113 }
mitea1 0:f2815503561f 114
mitea1 0:f2815503561f 115 if (teslaMeasureEvent.status == osEventMessage) {
mitea1 0:f2815503561f 116 MPU9250TeslaMessage* teslaMessage = (MPU9250TeslaMessage*) teslaMeasureEvent.value.p;
mitea1 0:f2815503561f 117 debugSerial->printf("%s\n",teslaMessage->getLoRaMessageString());
mitea1 0:f2815503561f 118 loraMessage.append(teslaMessage->getLoRaMessageString());
mitea1 0:f2815503561f 119 }
mitea1 0:f2815503561f 120
mitea1 0:f2815503561f 121 if(proximityMeasureEvent.status == osEventMessage){
mitea1 0:f2815503561f 122 SI1143ProximityMessage* si1143ProximityMessage = (SI1143ProximityMessage*) proximityMeasureEvent.value.p;
mitea1 0:f2815503561f 123 debugSerial->printf("%s\n",si1143ProximityMessage->getLoRaMessageString());
mitea1 0:f2815503561f 124 loraMessage.append(si1143ProximityMessage->getLoRaMessageString());
mitea1 0:f2815503561f 125 }
mitea1 0:f2815503561f 126
mitea1 0:f2815503561f 127 if(gpsMeasureEvent.status == osEventMessage){
mitea1 0:f2815503561f 128 UBloxGPSMessage* uBloxGpsMessage = (UBloxGPSMessage*) gpsMeasureEvent.value.p;
mitea1 0:f2815503561f 129 debugSerial->printf("%s\n",uBloxGpsMessage->getLoRaMessageString());
mitea1 0:f2815503561f 130 loraMessage.append(uBloxGpsMessage->getLoRaMessageString());
mitea1 0:f2815503561f 131 }
mitea1 0:f2815503561f 132
mitea1 0:f2815503561f 133 if(loraMeasureEvent.status == osEventMessage){
mitea1 0:f2815503561f 134 LoRaMeasurementMessage* loraMeasurementMessage = (LoRaMeasurementMessage*) loraMeasureEvent.value.p;
mitea1 0:f2815503561f 135 debugSerial->printf("%s\n",loraMeasurementMessage->getLoRaMessageString());
mitea1 0:f2815503561f 136 loraMessage.append(loraMeasurementMessage->getLoRaMessageString());
mitea1 0:f2815503561f 137 }
mitea1 0:f2815503561f 138
mitea1 0:f2815503561f 139 debugSerial->printf("\n");
mitea1 0:f2815503561f 140
mitea1 0:f2815503561f 141 // format data for sending to the gateway
mitea1 0:f2815503561f 142 for (std::string::iterator it = loraMessage.begin(); it != loraMessage.end(); it++){
mitea1 0:f2815503561f 143 dataToSend.push_back((uint8_t) *it);
mitea1 0:f2815503561f 144 }
mitea1 0:f2815503561f 145 loraMessage.clear();
mitea1 0:f2815503561f 146
mitea1 0:f2815503561f 147 mutexLora->lock(osWaitForever);
mitea1 0:f2815503561f 148 lora->send(dataToSend);
mitea1 7:87cbeafdba06 149 lora->recv(dataReceived);
mitea1 0:f2815503561f 150 mutexLora->unlock();
mitea1 0:f2815503561f 151
mitea1 7:87cbeafdba06 152 if(!dataReceived.empty()){
mitea1 7:87cbeafdba06 153 commandMessage.setCommandString(dataReceived);
mitea1 7:87cbeafdba06 154 commandMessage.setCommandHex(dataReceived.at(0));
mitea1 7:87cbeafdba06 155 queueBundle.queueCommands->put(&commandMessage,osWaitForever);
mitea1 7:87cbeafdba06 156 }
mitea1 7:87cbeafdba06 157
mitea1 0:f2815503561f 158 dataToSend.clear();
mitea1 0:f2815503561f 159 dataReceived.clear();
mitea1 0:f2815503561f 160
mitea1 0:f2815503561f 161 }
mitea1 0:f2815503561f 162
mitea1 0:f2815503561f 163 void TaskDatahandler::setMutex(Mutex* mutexLora){
mitea1 0:f2815503561f 164 this->mutexLora = mutexLora;
mitea1 0:f2815503561f 165 }
mitea1 0:f2815503561f 166
mitea1 0:f2815503561f 167 void TaskDatahandler::setQueueBundle(QueueBundle queueBundle){
mitea1 0:f2815503561f 168 this->queueBundle = queueBundle;
mitea1 0:f2815503561f 169 }
mitea1 0:f2815503561f 170
mitea1 0:f2815503561f 171 void TaskDatahandler::setPriority(osPriority priority){
mitea1 0:f2815503561f 172 this->priority = priority;
mitea1 0:f2815503561f 173 }
mitea1 0:f2815503561f 174
mitea1 0:f2815503561f 175 void TaskDatahandler::setStackSize(uint32_t stacksize){
mitea1 0:f2815503561f 176 this->stack_size = stacksize;
mitea1 0:f2815503561f 177 }
mitea1 0:f2815503561f 178
mitea1 0:f2815503561f 179 void TaskDatahandler::setStackPointer(unsigned char* stackPointer){
mitea1 0:f2815503561f 180 this->stack_pointer = stackPointer;
mitea1 0:f2815503561f 181 }
mitea1 0:f2815503561f 182
mitea1 0:f2815503561f 183 void TaskDatahandler::setDebugSerial(RawSerial* debugSerial){
mitea1 0:f2815503561f 184 this->debugSerial = debugSerial;
mitea1 0:f2815503561f 185 }
mitea1 0:f2815503561f 186
mitea1 0:f2815503561f 187 void TaskDatahandler::setLoRa(LoRa* lora){
mitea1 0:f2815503561f 188 this->lora = lora;
mitea1 0:f2815503561f 189 }
mitea1 0:f2815503561f 190
mitea1 0:f2815503561f 191 void TaskDatahandler::setState(TASK_STATE state){
mitea1 0:f2815503561f 192 this->state = state;
mitea1 0:f2815503561f 193 }
mitea1 0:f2815503561f 194
mitea1 0:f2815503561f 195 TASK_STATE TaskDatahandler::getState(){
mitea1 0:f2815503561f 196 return state;
mitea1 0:f2815503561f 197 }
mitea1 0:f2815503561f 198
mitea1 0:f2815503561f 199
mitea1 0:f2815503561f 200
mitea1 0:f2815503561f 201