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@10:4051c38bf73f, 2018-11-02 (annotated)

Committer:: mitea1
Date:: Fri Nov 02 17:01:02 2018 +0000
Revision:: 10:4051c38bf73f
Parent:: 9:c4e378f4801d

wtf

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	9:c4e378f4801d	68	flowMeasureEvent = queueBundle.queueFlowMeter->get(0);
mitea1	0:f2815503561f	69	loraMeasureEvent = queueBundle.queueLoRaMeasurments->get(0);
mitea1	0:f2815503561f	70	}
mitea1	0:f2815503561f	71
mitea1	0:f2815503561f	72	void TaskDatahandler::forwardSensorMessages(){
mitea1	0:f2815503561f	73	std::string loraMessage;
mitea1	0:f2815503561f	74	std::vector<uint8_t> dataToSend;
mitea1	0:f2815503561f	75	std::vector<uint8_t> dataReceived;
mitea1	0:f2815503561f	76
mitea1	0:f2815503561f	77	int32_t ret;
mitea1	0:f2815503561f	78
mitea1	0:f2815503561f	79	debugSerial->printf("\n");
mitea1	0:f2815503561f	80	if (lightMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	81	MAX44009Message* luxMessage = (MAX44009Message*) lightMeasureEvent.value.p;
mitea1	0:f2815503561f	82	debugSerial->printf("%s\n",luxMessage->getLoRaMessageString());
mitea1	0:f2815503561f	83	loraMessage.append(luxMessage->getLoRaMessageString());
mitea1	0:f2815503561f	84	}
mitea1	0:f2815503561f	85
mitea1	0:f2815503561f	86	if (temperatureMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	87	BME280TemperatureMessage* temperatureMessage = (BME280TemperatureMessage*) temperatureMeasureEvent.value.p;
mitea1	0:f2815503561f	88	debugSerial->printf("%s\n",temperatureMessage->getLoRaMessageString());
mitea1	0:f2815503561f	89	loraMessage.append(temperatureMessage->getLoRaMessageString());
mitea1	0:f2815503561f	90	}
mitea1	0:f2815503561f	91
mitea1	0:f2815503561f	92	if (pressureMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	93	BME280PressureMessage* pressureMessage = (BME280PressureMessage*) pressureMeasureEvent.value.p;
mitea1	0:f2815503561f	94	debugSerial->printf("%s\n",pressureMessage->getLoRaMessageString());
mitea1	0:f2815503561f	95	loraMessage.append(pressureMessage->getLoRaMessageString());
mitea1	0:f2815503561f	96	}
mitea1	0:f2815503561f	97
mitea1	0:f2815503561f	98	if (humidityMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	99	BME280HumidityMessage* humidityMessage = (BME280HumidityMessage*) humidityMeasureEvent.value.p;
mitea1	0:f2815503561f	100	debugSerial->printf("%s\n",humidityMessage->getLoRaMessageString());
mitea1	0:f2815503561f	101	loraMessage.append(humidityMessage->getLoRaMessageString());
mitea1	0:f2815503561f	102	}
mitea1	0:f2815503561f	103
mitea1	0:f2815503561f	104	if (accelerationMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	105	MPU9250AccelerationMessage* accelerationMessage = (MPU9250AccelerationMessage*) accelerationMeasureEvent.value.p;
mitea1	0:f2815503561f	106	debugSerial->printf("%s\n",accelerationMessage->getLoRaMessageString());
mitea1	0:f2815503561f	107	loraMessage.append(accelerationMessage->getLoRaMessageString());
mitea1	0:f2815503561f	108	}
mitea1	0:f2815503561f	109
mitea1	0:f2815503561f	110	if (gyroscopeMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	111	MPU9250GyroscopeMessage* gyroscopeMessage = (MPU9250GyroscopeMessage*) gyroscopeMeasureEvent.value.p;
mitea1	0:f2815503561f	112	debugSerial->printf("%s\n",gyroscopeMessage->getLoRaMessageString());
mitea1	0:f2815503561f	113	loraMessage.append(gyroscopeMessage->getLoRaMessageString());
mitea1	0:f2815503561f	114	}
mitea1	0:f2815503561f	115
mitea1	0:f2815503561f	116	if (teslaMeasureEvent.status == osEventMessage) {
mitea1	0:f2815503561f	117	MPU9250TeslaMessage* teslaMessage = (MPU9250TeslaMessage*) teslaMeasureEvent.value.p;
mitea1	0:f2815503561f	118	debugSerial->printf("%s\n",teslaMessage->getLoRaMessageString());
mitea1	0:f2815503561f	119	loraMessage.append(teslaMessage->getLoRaMessageString());
mitea1	0:f2815503561f	120	}
mitea1	0:f2815503561f	121
mitea1	0:f2815503561f	122	if(proximityMeasureEvent.status == osEventMessage){
mitea1	0:f2815503561f	123	SI1143ProximityMessage* si1143ProximityMessage = (SI1143ProximityMessage*) proximityMeasureEvent.value.p;
mitea1	0:f2815503561f	124	debugSerial->printf("%s\n",si1143ProximityMessage->getLoRaMessageString());
mitea1	0:f2815503561f	125	loraMessage.append(si1143ProximityMessage->getLoRaMessageString());
mitea1	0:f2815503561f	126	}
mitea1	0:f2815503561f	127
mitea1	0:f2815503561f	128	if(gpsMeasureEvent.status == osEventMessage){
mitea1	0:f2815503561f	129	UBloxGPSMessage* uBloxGpsMessage = (UBloxGPSMessage*) gpsMeasureEvent.value.p;
mitea1	0:f2815503561f	130	debugSerial->printf("%s\n",uBloxGpsMessage->getLoRaMessageString());
mitea1	0:f2815503561f	131	loraMessage.append(uBloxGpsMessage->getLoRaMessageString());
mitea1	0:f2815503561f	132	}
mitea1	9:c4e378f4801d	133	if(flowMeasureEvent.status == osEventMessage){
mitea1	9:c4e378f4801d	134	FlowMeterMessage* flowMeterMessage = (FlowMeterMessage*) flowMeasureEvent.value.p;
mitea1	9:c4e378f4801d	135	debugSerial->printf("%s\n",flowMeterMessage->getLoRaMessageString());
mitea1	9:c4e378f4801d	136	loraMessage.append(flowMeterMessage->getLoRaMessageString());
mitea1	9:c4e378f4801d	137	}
mitea1	0:f2815503561f	138	if(loraMeasureEvent.status == osEventMessage){
mitea1	0:f2815503561f	139	LoRaMeasurementMessage* loraMeasurementMessage = (LoRaMeasurementMessage*) loraMeasureEvent.value.p;
mitea1	0:f2815503561f	140	debugSerial->printf("%s\n",loraMeasurementMessage->getLoRaMessageString());
mitea1	0:f2815503561f	141	loraMessage.append(loraMeasurementMessage->getLoRaMessageString());
mitea1	0:f2815503561f	142	}
mitea1	0:f2815503561f	143
mitea1	0:f2815503561f	144	debugSerial->printf("\n");
mitea1	0:f2815503561f	145
mitea1	0:f2815503561f	146	// format data for sending to the gateway
mitea1	0:f2815503561f	147	for (std::string::iterator it = loraMessage.begin(); it != loraMessage.end(); it++){
mitea1	0:f2815503561f	148	dataToSend.push_back((uint8_t) *it);
mitea1	0:f2815503561f	149	}
mitea1	0:f2815503561f	150	loraMessage.clear();
mitea1	0:f2815503561f	151
mitea1	0:f2815503561f	152	mutexLora->lock(osWaitForever);
mitea1	0:f2815503561f	153	lora->send(dataToSend);
mitea1	7:87cbeafdba06	154	lora->recv(dataReceived);
mitea1	0:f2815503561f	155	mutexLora->unlock();
mitea1	0:f2815503561f	156
mitea1	0:f2815503561f	157	dataToSend.clear();
mitea1	0:f2815503561f	158	dataReceived.clear();
mitea1	0:f2815503561f	159
mitea1	0:f2815503561f	160	}
mitea1	0:f2815503561f	161
mitea1	0:f2815503561f	162	void TaskDatahandler::setMutex(Mutex* mutexLora){
mitea1	0:f2815503561f	163	this->mutexLora = mutexLora;
mitea1	0:f2815503561f	164	}
mitea1	0:f2815503561f	165
mitea1	0:f2815503561f	166	void TaskDatahandler::setQueueBundle(QueueBundle queueBundle){
mitea1	0:f2815503561f	167	this->queueBundle = queueBundle;
mitea1	0:f2815503561f	168	}
mitea1	0:f2815503561f	169
mitea1	0:f2815503561f	170	void TaskDatahandler::setPriority(osPriority priority){
mitea1	0:f2815503561f	171	this->priority = priority;
mitea1	0:f2815503561f	172	}
mitea1	0:f2815503561f	173
mitea1	0:f2815503561f	174	void TaskDatahandler::setStackSize(uint32_t stacksize){
mitea1	0:f2815503561f	175	this->stack_size = stacksize;
mitea1	0:f2815503561f	176	}
mitea1	0:f2815503561f	177
mitea1	0:f2815503561f	178	void TaskDatahandler::setStackPointer(unsigned char* stackPointer){
mitea1	0:f2815503561f	179	this->stack_pointer = stackPointer;
mitea1	0:f2815503561f	180	}
mitea1	0:f2815503561f	181
mitea1	0:f2815503561f	182	void TaskDatahandler::setDebugSerial(RawSerial* debugSerial){
mitea1	0:f2815503561f	183	this->debugSerial = debugSerial;
mitea1	0:f2815503561f	184	}
mitea1	0:f2815503561f	185
mitea1	0:f2815503561f	186	void TaskDatahandler::setLoRa(LoRa* lora){
mitea1	0:f2815503561f	187	this->lora = lora;
mitea1	0:f2815503561f	188	}
mitea1	0:f2815503561f	189
mitea1	0:f2815503561f	190	void TaskDatahandler::setState(TASK_STATE state){
mitea1	0:f2815503561f	191	this->state = state;
mitea1	0:f2815503561f	192	}
mitea1	0:f2815503561f	193
mitea1	0:f2815503561f	194	TASK_STATE TaskDatahandler::getState(){
mitea1	0:f2815503561f	195	return state;
mitea1	0:f2815503561f	196	}
mitea1	0:f2815503561f	197
mitea1	0:f2815503561f	198
mitea1	0:f2815503561f	199
mitea1	0:f2815503561f	200

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