Users » mitea1 » Code » mDot_LoRa_Sensornode

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/mt_mdot_family_642px.png

Supported Sensors

MAX44009 (Lux Measurment) http://www.ebay.ie/itm/MAX44009-Ambient-Light-Sensor-Module-for-Arduino-with-4P-Pin-Header-/381676089124?hash=item58ddaaef24:g:-ecAAOSwzJ5XZm5E
BME280 (Temperature, Pressure and Humdity Measurment) At the moment there are some known problem using this. https://www.adafruit.com/product/2652 https://www.amazon.com/Diymall-Pressure-Temperature-Sensor-Arduino/dp/B0118XCKTG
MPU9250 (Acceleration, Gyroscope and Magnetometer) http://www.watterott.com/de/9-DOF-IMU-Module-With-MPU-9250
Si1143 (Proximity up to 50cm) https://moderndevice.com/product/si1143-proximity-sensors/
uBlox M8Q (GPS Position) http://www.dx.com/de/p/gygpsv3-m8n-u-blox-neo-m8n-001-flight-controller-gps-module-blue-394557#.V4lFW-uLRhE

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@1:fe242f3e341b, 2016-08-12 (annotated)

Committer:: mitea1
Date:: Fri Aug 12 11:19:14 2016 +0000
Revision:: 1:fe242f3e341b
Parent:: 0:f2815503561f
Child:: 7:87cbeafdba06

added OTAA Join Mode for LoRa Connection

Who changed what in which revision?

User	Revision	Line number	New 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	0:f2815503561f	149	// lora->recv(dataReceived);
mitea1	0:f2815503561f	150	mutexLora->unlock();
mitea1	0:f2815503561f	151
mitea1	0:f2815503561f	152	dataToSend.clear();
mitea1	0:f2815503561f	153	dataReceived.clear();
mitea1	0:f2815503561f	154
mitea1	0:f2815503561f	155	}
mitea1	0:f2815503561f	156
mitea1	0:f2815503561f	157	void TaskDatahandler::setMutex(Mutex* mutexLora){
mitea1	0:f2815503561f	158	this->mutexLora = mutexLora;
mitea1	0:f2815503561f	159	}
mitea1	0:f2815503561f	160
mitea1	0:f2815503561f	161	void TaskDatahandler::setQueueBundle(QueueBundle queueBundle){
mitea1	0:f2815503561f	162	this->queueBundle = queueBundle;
mitea1	0:f2815503561f	163	}
mitea1	0:f2815503561f	164
mitea1	0:f2815503561f	165	void TaskDatahandler::setPriority(osPriority priority){
mitea1	0:f2815503561f	166	this->priority = priority;
mitea1	0:f2815503561f	167	}
mitea1	0:f2815503561f	168
mitea1	0:f2815503561f	169	void TaskDatahandler::setStackSize(uint32_t stacksize){
mitea1	0:f2815503561f	170	this->stack_size = stacksize;
mitea1	0:f2815503561f	171	}
mitea1	0:f2815503561f	172
mitea1	0:f2815503561f	173	void TaskDatahandler::setStackPointer(unsigned char* stackPointer){
mitea1	0:f2815503561f	174	this->stack_pointer = stackPointer;
mitea1	0:f2815503561f	175	}
mitea1	0:f2815503561f	176
mitea1	0:f2815503561f	177	void TaskDatahandler::setDebugSerial(RawSerial* debugSerial){
mitea1	0:f2815503561f	178	this->debugSerial = debugSerial;
mitea1	0:f2815503561f	179	}
mitea1	0:f2815503561f	180
mitea1	0:f2815503561f	181	void TaskDatahandler::setLoRa(LoRa* lora){
mitea1	0:f2815503561f	182	this->lora = lora;
mitea1	0:f2815503561f	183	}
mitea1	0:f2815503561f	184
mitea1	0:f2815503561f	185	void TaskDatahandler::setState(TASK_STATE state){
mitea1	0:f2815503561f	186	this->state = state;
mitea1	0:f2815503561f	187	}
mitea1	0:f2815503561f	188
mitea1	0:f2815503561f	189	TASK_STATE TaskDatahandler::getState(){
mitea1	0:f2815503561f	190	return state;
mitea1	0:f2815503561f	191	}
mitea1	0:f2815503561f	192
mitea1	0:f2815503561f	193
mitea1	0:f2815503561f	194
mitea1	0:f2815503561f	195

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	06 Jul 2016
Imports:	228
Forks:	2
Commits:	11
Dependents:	0
Dependencies:	3
Followers:	11