Lora Personalized device for Everynet
Dependencies: LMiCPersonalizedforEverynet SX1276Lib X_NUCLEO_IKS01A1 cantcoap lwip mbed-rtos mbed
Fork of LoRaWAN-test-10secs by
main.cpp@14:acbcd0b888ca, 2016-09-23 (annotated)
- Committer:
- pnysten
- Date:
- Fri Sep 23 09:13:06 2016 +0000
- Revision:
- 14:acbcd0b888ca
- Parent:
- 13:9de42df1d3d8
Lora Personalized device for Everynet
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
sam_grove | 3:ce28e3313a88 | 1 | /* |
mluis | 0:a2929fa6e4f0 | 2 | / _____) _ | | |
mluis | 0:a2929fa6e4f0 | 3 | ( (____ _____ ____ _| |_ _____ ____| |__ |
mluis | 0:a2929fa6e4f0 | 4 | \____ \| ___ | (_ _) ___ |/ ___) _ \ |
mluis | 0:a2929fa6e4f0 | 5 | _____) ) ____| | | || |_| ____( (___| | | | |
mluis | 0:a2929fa6e4f0 | 6 | (______/|_____)_|_|_| \__)_____)\____)_| |_| |
mluis | 1:60184eda0066 | 7 | (C)2015 Semtech |
mluis | 0:a2929fa6e4f0 | 8 | |
mluis | 1:60184eda0066 | 9 | Description: MBED LoRaWAN example application |
mluis | 0:a2929fa6e4f0 | 10 | |
mluis | 0:a2929fa6e4f0 | 11 | License: Revised BSD License, see LICENSE.TXT file include in the project |
mluis | 0:a2929fa6e4f0 | 12 | |
mluis | 0:a2929fa6e4f0 | 13 | Maintainer: Miguel Luis and Gregory Cristian |
mluis | 0:a2929fa6e4f0 | 14 | */ |
pnysten | 6:540c5d907c90 | 15 | |
pnysten | 4:5e274bf85bf0 | 16 | #include <cstdio> |
pnysten | 4:5e274bf85bf0 | 17 | #include <string> |
pnysten | 4:5e274bf85bf0 | 18 | #include <cassert> |
pnysten | 4:5e274bf85bf0 | 19 | |
mluis | 1:60184eda0066 | 20 | #include "mbed.h" |
pnysten | 6:540c5d907c90 | 21 | //#include "Node.h" |
pnysten | 4:5e274bf85bf0 | 22 | #include "cantcoap.h" |
pnysten | 10:155dc60fce79 | 23 | #include "x_nucleo_iks01a1.h" |
pnysten | 10:155dc60fce79 | 24 | #include "rtos.h" |
mluis | 1:60184eda0066 | 25 | |
mluis | 0:a2929fa6e4f0 | 26 | #include "lmic.h" |
mluis | 1:60184eda0066 | 27 | #include "debug.h" |
mluis | 0:a2929fa6e4f0 | 28 | |
pnysten | 10:155dc60fce79 | 29 | /* Instantiate the expansion board */ |
pnysten | 10:155dc60fce79 | 30 | static X_NUCLEO_IKS01A1 *mems_expansion_board = X_NUCLEO_IKS01A1::Instance(D14, D15); |
pnysten | 10:155dc60fce79 | 31 | |
pnysten | 10:155dc60fce79 | 32 | /* Retrieve the composing elements of the expansion board */ |
pnysten | 10:155dc60fce79 | 33 | static GyroSensor *gyroscope = mems_expansion_board->GetGyroscope(); |
pnysten | 10:155dc60fce79 | 34 | static MotionSensor *accelerometer = mems_expansion_board->GetAccelerometer(); |
pnysten | 10:155dc60fce79 | 35 | static MagneticSensor *magnetometer = mems_expansion_board->magnetometer; |
pnysten | 10:155dc60fce79 | 36 | static HumiditySensor *humidity_sensor = mems_expansion_board->ht_sensor; |
pnysten | 10:155dc60fce79 | 37 | static PressureSensor *pressure_sensor = mems_expansion_board->pt_sensor; |
pnysten | 10:155dc60fce79 | 38 | static TempSensor *temp_sensor1 = mems_expansion_board->ht_sensor; |
pnysten | 10:155dc60fce79 | 39 | static TempSensor *temp_sensor2 = mems_expansion_board->pt_sensor; |
pnysten | 10:155dc60fce79 | 40 | |
pnysten | 10:155dc60fce79 | 41 | uint8_t id; |
pnysten | 10:155dc60fce79 | 42 | float value1, value2; |
pnysten | 10:155dc60fce79 | 43 | char buffer1[32], buffer2[32], buffer3[32]; |
pnysten | 10:155dc60fce79 | 44 | int32_t axes[3]; |
pnysten | 10:155dc60fce79 | 45 | |
pnysten | 10:155dc60fce79 | 46 | static bool temp_sent = false; |
pnysten | 10:155dc60fce79 | 47 | static bool hum_sent = false; |
pnysten | 10:155dc60fce79 | 48 | static bool press_sent = false; |
pnysten | 10:155dc60fce79 | 49 | static bool gyro_sent = false; |
pnysten | 10:155dc60fce79 | 50 | static bool motion_sent = false; |
pnysten | 10:155dc60fce79 | 51 | static bool magn_sent = false; |
pnysten | 10:155dc60fce79 | 52 | |
pnysten | 4:5e274bf85bf0 | 53 | const std::string REGISTRATION_SEGMENT ="/rd"; |
pnysten | 4:5e274bf85bf0 | 54 | const std::string ENDPOINT_SEGMENT = "?ep="; |
pnysten | 4:5e274bf85bf0 | 55 | const std::string LIFETIME ="<="; |
pnysten | 4:5e274bf85bf0 | 56 | const std::string BINDING ="&b="; |
pnysten | 6:540c5d907c90 | 57 | |
pnysten | 4:5e274bf85bf0 | 58 | const std::string REGISTRATION_OPEN = "<"; |
pnysten | 4:5e274bf85bf0 | 59 | const std::string REGISTRATION_CLOSE = ">"; |
pnysten | 4:5e274bf85bf0 | 60 | const std::string REGISTRATION_SEPARATOR ="/"; |
pnysten | 6:540c5d907c90 | 61 | |
pnysten | 4:5e274bf85bf0 | 62 | int _node_Id=0; |
pnysten | 6:540c5d907c90 | 63 | |
pnysten | 4:5e274bf85bf0 | 64 | const std::string endPoint_Name = "loraDevice"; |
pnysten | 4:5e274bf85bf0 | 65 | const int lifeTime = 300; |
pnysten | 4:5e274bf85bf0 | 66 | const std::string binding = "U"; |
pnysten | 6:540c5d907c90 | 67 | |
pnysten | 4:5e274bf85bf0 | 68 | unsigned char * _payload; |
pnysten | 4:5e274bf85bf0 | 69 | long _payload_size; |
pnysten | 6:540c5d907c90 | 70 | |
mluis | 0:a2929fa6e4f0 | 71 | /*! |
mluis | 0:a2929fa6e4f0 | 72 | * When set to 1 the application uses the Over-the-Air activation procedure |
mluis | 0:a2929fa6e4f0 | 73 | * When set to 0 the application uses the Personalization activation procedure |
mluis | 0:a2929fa6e4f0 | 74 | */ |
mluis | 0:a2929fa6e4f0 | 75 | #define OVER_THE_AIR_ACTIVATION 0 |
mluis | 0:a2929fa6e4f0 | 76 | |
mluis | 1:60184eda0066 | 77 | #if( OVER_THE_AIR_ACTIVATION == 0 ) |
mluis | 1:60184eda0066 | 78 | |
mluis | 1:60184eda0066 | 79 | /*! |
mluis | 1:60184eda0066 | 80 | * Defines the network ID when using personalization activation procedure |
mluis | 1:60184eda0066 | 81 | */ |
mluis | 1:60184eda0066 | 82 | #define LORAWAN_NET_ID ( uint32_t )0x00000000 |
mluis | 1:60184eda0066 | 83 | |
mluis | 1:60184eda0066 | 84 | /*! |
mluis | 1:60184eda0066 | 85 | * Defines the device address when using personalization activation procedure |
mluis | 1:60184eda0066 | 86 | */ |
pnysten | 9:84a69ca4d35a | 87 | //To be changed when switching from one to another |
pnysten | 13:9de42df1d3d8 | 88 | #define LORAWAN_DEV_ADDR ( uint32_t )0x12342222 |
mluis | 1:60184eda0066 | 89 | |
mluis | 1:60184eda0066 | 90 | #endif |
mluis | 1:60184eda0066 | 91 | |
mluis | 1:60184eda0066 | 92 | /*! |
mluis | 1:60184eda0066 | 93 | * Defines the application data transmission duty cycle |
mluis | 1:60184eda0066 | 94 | */ |
pnysten | 12:f28b629d8a6e | 95 | //#define APP_TX_DUTYCYCLE 5000 // 5 [s] value in ms |
pnysten | 12:f28b629d8a6e | 96 | //PANY |
pnysten | 12:f28b629d8a6e | 97 | #define APP_TX_DUTYCYCLE 1000 // 1 [s] value in ms |
pnysten | 12:f28b629d8a6e | 98 | //PANY |
mluis | 1:60184eda0066 | 99 | #define APP_TX_DUTYCYCLE_RND 1000 // 1 [s] value in ms |
mluis | 1:60184eda0066 | 100 | |
mluis | 1:60184eda0066 | 101 | /*! |
mluis | 1:60184eda0066 | 102 | * LoRaWAN Adaptative Data Rate |
mluis | 1:60184eda0066 | 103 | */ |
mluis | 1:60184eda0066 | 104 | #define LORAWAN_ADR_ON 1 |
mluis | 1:60184eda0066 | 105 | |
mluis | 1:60184eda0066 | 106 | /*! |
mluis | 1:60184eda0066 | 107 | * LoRaWAN confirmed messages |
mluis | 1:60184eda0066 | 108 | */ |
pnysten | 9:84a69ca4d35a | 109 | #define LORAWAN_CONFIRMED_MSG_ON 0 |
mluis | 1:60184eda0066 | 110 | |
mluis | 1:60184eda0066 | 111 | /*! |
mluis | 1:60184eda0066 | 112 | * LoRaWAN application port |
mluis | 1:60184eda0066 | 113 | */ |
mluis | 1:60184eda0066 | 114 | #define LORAWAN_APP_PORT 15 |
mluis | 1:60184eda0066 | 115 | |
mluis | 1:60184eda0066 | 116 | /*! |
mluis | 1:60184eda0066 | 117 | * User application data buffer size |
mluis | 1:60184eda0066 | 118 | */ |
mluis | 1:60184eda0066 | 119 | #if ( LORAWAN_CONFIRMED_MSG_ON == 1 ) |
mluis | 1:60184eda0066 | 120 | #define LORAWAN_APP_DATA_SIZE 6 |
mluis | 1:60184eda0066 | 121 | |
mluis | 1:60184eda0066 | 122 | #else |
mluis | 1:60184eda0066 | 123 | #define LORAWAN_APP_DATA_SIZE 1 |
mluis | 1:60184eda0066 | 124 | |
mluis | 1:60184eda0066 | 125 | #endif |
mluis | 0:a2929fa6e4f0 | 126 | |
pnysten | 4:5e274bf85bf0 | 127 | #define UINT16_MAX (65535U) |
pnysten | 4:5e274bf85bf0 | 128 | #define UINT64_MAX (18446744073709551615ULL) |
pnysten | 6:540c5d907c90 | 129 | |
pnysten | 6:540c5d907c90 | 130 | //Node lwm2mNode("LR-test0");; |
pnysten | 6:540c5d907c90 | 131 | unsigned int LoRaWAN_data_size = 0; |
pnysten | 4:5e274bf85bf0 | 132 | |
pnysten | 10:155dc60fce79 | 133 | /* Helper function for printing floats & doubles */ |
pnysten | 10:155dc60fce79 | 134 | static char *printDouble(char* str, double v, int decimalDigits=2) |
pnysten | 10:155dc60fce79 | 135 | { |
pnysten | 10:155dc60fce79 | 136 | int i = 1; |
pnysten | 10:155dc60fce79 | 137 | int intPart, fractPart; |
pnysten | 10:155dc60fce79 | 138 | int len; |
pnysten | 10:155dc60fce79 | 139 | char *ptr; |
pnysten | 10:155dc60fce79 | 140 | |
pnysten | 10:155dc60fce79 | 141 | /* prepare decimal digits multiplicator */ |
pnysten | 10:155dc60fce79 | 142 | for (;decimalDigits!=0; i*=10, decimalDigits--); |
pnysten | 10:155dc60fce79 | 143 | |
pnysten | 10:155dc60fce79 | 144 | /* calculate integer & fractinal parts */ |
pnysten | 10:155dc60fce79 | 145 | intPart = (int)v; |
pnysten | 10:155dc60fce79 | 146 | fractPart = (int)((v-(double)(int)v)*i); |
pnysten | 10:155dc60fce79 | 147 | |
pnysten | 10:155dc60fce79 | 148 | /* fill in integer part */ |
pnysten | 10:155dc60fce79 | 149 | sprintf(str, "%i.", intPart); |
pnysten | 10:155dc60fce79 | 150 | |
pnysten | 10:155dc60fce79 | 151 | /* prepare fill in of fractional part */ |
pnysten | 10:155dc60fce79 | 152 | len = strlen(str); |
pnysten | 10:155dc60fce79 | 153 | ptr = &str[len]; |
pnysten | 10:155dc60fce79 | 154 | |
pnysten | 10:155dc60fce79 | 155 | /* fill in leading fractional zeros */ |
pnysten | 10:155dc60fce79 | 156 | for (i/=10;i>1; i/=10, ptr++) { |
pnysten | 10:155dc60fce79 | 157 | if(fractPart >= i) break; |
pnysten | 10:155dc60fce79 | 158 | *ptr = '0'; |
pnysten | 10:155dc60fce79 | 159 | } |
pnysten | 10:155dc60fce79 | 160 | |
pnysten | 10:155dc60fce79 | 161 | /* fill in (rest of) fractional part */ |
pnysten | 10:155dc60fce79 | 162 | sprintf(ptr, "%i", fractPart); |
pnysten | 10:155dc60fce79 | 163 | |
pnysten | 10:155dc60fce79 | 164 | return str; |
pnysten | 10:155dc60fce79 | 165 | } |
pnysten | 10:155dc60fce79 | 166 | |
pnysten | 10:155dc60fce79 | 167 | /* Helper function for printing integers */ |
pnysten | 10:155dc60fce79 | 168 | static char *printInt(char* str, int v) |
pnysten | 10:155dc60fce79 | 169 | { |
pnysten | 10:155dc60fce79 | 170 | /* fill in integer part */ |
pnysten | 10:155dc60fce79 | 171 | sprintf(str, "%i", v); |
pnysten | 10:155dc60fce79 | 172 | |
pnysten | 10:155dc60fce79 | 173 | return str; |
pnysten | 10:155dc60fce79 | 174 | } |
pnysten | 10:155dc60fce79 | 175 | |
pnysten | 10:155dc60fce79 | 176 | /* Thread for calling libNsdl exec function (cleanup, resendings etc..) */ |
pnysten | 10:155dc60fce79 | 177 | /* Node updates accelerometer every 60 seconds. Notification sending is done here. */ |
pnysten | 10:155dc60fce79 | 178 | static void exec_call_thread(void const *args) |
pnysten | 10:155dc60fce79 | 179 | { |
pnysten | 10:155dc60fce79 | 180 | uint8_t id; |
pnysten | 10:155dc60fce79 | 181 | float value1, value2; |
pnysten | 10:155dc60fce79 | 182 | char buffer1[32], buffer2[32]; |
pnysten | 10:155dc60fce79 | 183 | int32_t axes[3]; |
pnysten | 10:155dc60fce79 | 184 | |
pnysten | 10:155dc60fce79 | 185 | debug_str("--- Starting new run ---\r\n"); |
pnysten | 10:155dc60fce79 | 186 | |
pnysten | 10:155dc60fce79 | 187 | humidity_sensor->ReadID(&id); |
pnysten | 10:155dc60fce79 | 188 | debug_str("HTS221 humidity & temperature = "); |
pnysten | 10:155dc60fce79 | 189 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 190 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 191 | pressure_sensor->ReadID(&id); |
pnysten | 10:155dc60fce79 | 192 | debug_str("LPS25H pressure & temperature = "); |
pnysten | 10:155dc60fce79 | 193 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 194 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 195 | magnetometer->ReadID(&id); |
pnysten | 10:155dc60fce79 | 196 | debug_str("LIS3MDL magnetometer = "); |
pnysten | 10:155dc60fce79 | 197 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 198 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 199 | gyroscope->ReadID(&id); |
pnysten | 10:155dc60fce79 | 200 | debug_str("LSM6DS0 accelerometer & gyroscope = "); |
pnysten | 10:155dc60fce79 | 201 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 202 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 203 | |
pnysten | 10:155dc60fce79 | 204 | wait(3); |
pnysten | 10:155dc60fce79 | 205 | |
pnysten | 10:155dc60fce79 | 206 | while(1) { |
pnysten | 10:155dc60fce79 | 207 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 208 | |
pnysten | 10:155dc60fce79 | 209 | temp_sensor1->GetTemperature(&value1); |
pnysten | 10:155dc60fce79 | 210 | humidity_sensor->GetHumidity(&value2); |
pnysten | 10:155dc60fce79 | 211 | debug_str("HTS221: [temp] "); |
pnysten | 10:155dc60fce79 | 212 | debug_str(printDouble(buffer1, value1)); |
pnysten | 10:155dc60fce79 | 213 | debug_str("°C, [hum] "); |
pnysten | 10:155dc60fce79 | 214 | debug_str(printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 215 | debug_str("%\r\n"); |
pnysten | 10:155dc60fce79 | 216 | //pc.printf("HTS221: [temp] %7s°C, [hum] %s%%\r\n", printDouble(buffer1, value1), printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 217 | |
pnysten | 10:155dc60fce79 | 218 | temp_sensor2->GetFahrenheit(&value1); |
pnysten | 10:155dc60fce79 | 219 | pressure_sensor->GetPressure(&value2); |
pnysten | 10:155dc60fce79 | 220 | debug_str("LPS25H: [temp] "); |
pnysten | 10:155dc60fce79 | 221 | debug_str(printDouble(buffer1, value1)); |
pnysten | 10:155dc60fce79 | 222 | debug_str("°F, [press] "); |
pnysten | 10:155dc60fce79 | 223 | debug_str(printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 224 | debug_str("mbar\r\n"); |
pnysten | 10:155dc60fce79 | 225 | //pc.printf("LPS25H: [temp] %7s°F, [press] %smbar\r\n", printDouble(buffer1, value1), printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 226 | |
pnysten | 10:155dc60fce79 | 227 | debug_str("---\r\n"); |
pnysten | 10:155dc60fce79 | 228 | |
pnysten | 10:155dc60fce79 | 229 | magnetometer->Get_M_Axes(axes); |
pnysten | 10:155dc60fce79 | 230 | debug_str("LIS3MDL [mag/mgauss]: "); |
pnysten | 10:155dc60fce79 | 231 | debug_uint(axes[0]); |
pnysten | 10:155dc60fce79 | 232 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 233 | debug_uint(axes[1]); |
pnysten | 10:155dc60fce79 | 234 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 235 | debug_uint(axes[2]); |
pnysten | 10:155dc60fce79 | 236 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 237 | //pc.printf("LIS3MDL [mag/mgauss]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
pnysten | 10:155dc60fce79 | 238 | |
pnysten | 10:155dc60fce79 | 239 | accelerometer->Get_X_Axes(axes); |
pnysten | 10:155dc60fce79 | 240 | debug_str("LSM6DS0 [acc/mg]: "); |
pnysten | 10:155dc60fce79 | 241 | debug_uint(axes[0]); |
pnysten | 10:155dc60fce79 | 242 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 243 | debug_uint(axes[1]); |
pnysten | 10:155dc60fce79 | 244 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 245 | debug_uint(axes[2]); |
pnysten | 10:155dc60fce79 | 246 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 247 | //pc.printf("LSM6DS0 [acc/mg]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
pnysten | 10:155dc60fce79 | 248 | |
pnysten | 10:155dc60fce79 | 249 | gyroscope->Get_G_Axes(axes); |
pnysten | 10:155dc60fce79 | 250 | debug_str("LSM6DS0 [gyro/mdps]: "); |
pnysten | 10:155dc60fce79 | 251 | debug_uint(axes[0]); |
pnysten | 10:155dc60fce79 | 252 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 253 | debug_uint(axes[1]); |
pnysten | 10:155dc60fce79 | 254 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 255 | debug_uint(axes[2]); |
pnysten | 10:155dc60fce79 | 256 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 257 | //pc.printf("LSM6DS0 [gyro/mdps]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
pnysten | 10:155dc60fce79 | 258 | |
pnysten | 10:155dc60fce79 | 259 | wait(1.5); |
pnysten | 10:155dc60fce79 | 260 | } |
pnysten | 10:155dc60fce79 | 261 | } |
pnysten | 10:155dc60fce79 | 262 | |
pnysten | 4:5e274bf85bf0 | 263 | std::string to_string( int x ) { |
pnysten | 4:5e274bf85bf0 | 264 | int length = snprintf( NULL, 0, "%d", x ); |
pnysten | 14:acbcd0b888ca | 265 | //assert( length >= 0 ); |
pnysten | 4:5e274bf85bf0 | 266 | char* buf = new char[length + 1]; |
pnysten | 4:5e274bf85bf0 | 267 | snprintf( buf, length + 1, "%d", x ); |
pnysten | 4:5e274bf85bf0 | 268 | std::string str( buf ); |
pnysten | 4:5e274bf85bf0 | 269 | delete[] buf; |
pnysten | 4:5e274bf85bf0 | 270 | return str; |
pnysten | 4:5e274bf85bf0 | 271 | } |
pnysten | 10:155dc60fce79 | 272 | |
pnysten | 4:5e274bf85bf0 | 273 | unsigned char * get_Registration_Payload(long *payload_size){ |
pnysten | 6:540c5d907c90 | 274 | |
pnysten | 4:5e274bf85bf0 | 275 | string registration_Payload =""; |
pnysten | 6:540c5d907c90 | 276 | |
pnysten | 4:5e274bf85bf0 | 277 | string s=""; |
pnysten | 6:540c5d907c90 | 278 | |
pnysten | 4:5e274bf85bf0 | 279 | s.append(REGISTRATION_OPEN); |
pnysten | 4:5e274bf85bf0 | 280 | s.append(REGISTRATION_SEPARATOR); |
pnysten | 4:5e274bf85bf0 | 281 | s.append("3/0/0"); |
pnysten | 4:5e274bf85bf0 | 282 | s.append(REGISTRATION_CLOSE); |
pnysten | 4:5e274bf85bf0 | 283 | s.append(","); |
pnysten | 4:5e274bf85bf0 | 284 | s.append(REGISTRATION_OPEN); |
pnysten | 4:5e274bf85bf0 | 285 | s.append(REGISTRATION_SEPARATOR); |
pnysten | 4:5e274bf85bf0 | 286 | s.append("3/0/1"); |
pnysten | 4:5e274bf85bf0 | 287 | s.append(REGISTRATION_CLOSE); |
pnysten | 4:5e274bf85bf0 | 288 | s.append(","); |
pnysten | 4:5e274bf85bf0 | 289 | s.append(REGISTRATION_OPEN); |
pnysten | 4:5e274bf85bf0 | 290 | s.append(REGISTRATION_SEPARATOR); |
pnysten | 4:5e274bf85bf0 | 291 | s.append("3/0/2"); |
pnysten | 4:5e274bf85bf0 | 292 | s.append(REGISTRATION_CLOSE); |
pnysten | 6:540c5d907c90 | 293 | |
pnysten | 4:5e274bf85bf0 | 294 | registration_Payload.append(s); |
pnysten | 4:5e274bf85bf0 | 295 | |
pnysten | 4:5e274bf85bf0 | 296 | unsigned char *c = new unsigned char[registration_Payload.size()+1]; |
pnysten | 4:5e274bf85bf0 | 297 | copy(registration_Payload.begin(),registration_Payload.end(),c); |
pnysten | 4:5e274bf85bf0 | 298 | c[registration_Payload.size()]='\0'; |
pnysten | 4:5e274bf85bf0 | 299 | *payload_size=registration_Payload.size(); |
pnysten | 4:5e274bf85bf0 | 300 | |
pnysten | 4:5e274bf85bf0 | 301 | return c; |
pnysten | 6:540c5d907c90 | 302 | |
pnysten | 4:5e274bf85bf0 | 303 | } |
pnysten | 4:5e274bf85bf0 | 304 | uint8_t * get_Token(int * size){ |
pnysten | 4:5e274bf85bf0 | 305 | srand(time(0)+_node_Id); |
pnysten | 4:5e274bf85bf0 | 306 | long test=0; |
pnysten | 4:5e274bf85bf0 | 307 | bool exist=false; |
pnysten | 4:5e274bf85bf0 | 308 | |
pnysten | 4:5e274bf85bf0 | 309 | do{ |
pnysten | 4:5e274bf85bf0 | 310 | test=(rand() % UINT64_MAX); |
pnysten | 4:5e274bf85bf0 | 311 | |
pnysten | 4:5e274bf85bf0 | 312 | }while (exist==true); |
pnysten | 4:5e274bf85bf0 | 313 | uint8_t ones = 0xFF; |
pnysten | 4:5e274bf85bf0 | 314 | *size=1; |
pnysten | 4:5e274bf85bf0 | 315 | for (int i=0; i<8; ++i) { |
pnysten | 4:5e274bf85bf0 | 316 | if ( (test>>8*i & ones) =='\0' || i==8) { |
pnysten | 4:5e274bf85bf0 | 317 | *size=i; |
pnysten | 4:5e274bf85bf0 | 318 | break; |
pnysten | 4:5e274bf85bf0 | 319 | } |
pnysten | 4:5e274bf85bf0 | 320 | } |
pnysten | 4:5e274bf85bf0 | 321 | uint8_t * token =new uint8_t[*size]; |
pnysten | 4:5e274bf85bf0 | 322 | for (int i=0; i<*size; ++i){ |
pnysten | 4:5e274bf85bf0 | 323 | token[*size-1-i]=test>>8*i & ones; |
pnysten | 4:5e274bf85bf0 | 324 | } |
pnysten | 4:5e274bf85bf0 | 325 | return token; |
pnysten | 4:5e274bf85bf0 | 326 | } |
pnysten | 6:540c5d907c90 | 327 | |
pnysten | 4:5e274bf85bf0 | 328 | uint16_t get_Message_ID(){ |
pnysten | 4:5e274bf85bf0 | 329 | srand(time(0)+_node_Id); |
pnysten | 4:5e274bf85bf0 | 330 | int test=0; |
pnysten | 4:5e274bf85bf0 | 331 | bool exist=false; |
pnysten | 4:5e274bf85bf0 | 332 | do{ |
pnysten | 4:5e274bf85bf0 | 333 | |
pnysten | 4:5e274bf85bf0 | 334 | exist=false; |
pnysten | 4:5e274bf85bf0 | 335 | test=(rand() % UINT16_MAX); |
pnysten | 4:5e274bf85bf0 | 336 | |
pnysten | 4:5e274bf85bf0 | 337 | }while (exist==true); |
pnysten | 4:5e274bf85bf0 | 338 | |
pnysten | 4:5e274bf85bf0 | 339 | |
pnysten | 4:5e274bf85bf0 | 340 | return (uint16_t) test; |
pnysten | 4:5e274bf85bf0 | 341 | |
pnysten | 4:5e274bf85bf0 | 342 | } |
pnysten | 6:540c5d907c90 | 343 | |
pnysten | 4:5e274bf85bf0 | 344 | char * get_Registration_Query(){ |
pnysten | 4:5e274bf85bf0 | 345 | |
pnysten | 4:5e274bf85bf0 | 346 | string buffer; |
pnysten | 4:5e274bf85bf0 | 347 | buffer.append(REGISTRATION_SEGMENT); |
pnysten | 4:5e274bf85bf0 | 348 | buffer.append(ENDPOINT_SEGMENT); |
pnysten | 4:5e274bf85bf0 | 349 | buffer.append(endPoint_Name); |
pnysten | 4:5e274bf85bf0 | 350 | buffer.append(LIFETIME); |
pnysten | 4:5e274bf85bf0 | 351 | buffer.append(to_string(lifeTime)); |
pnysten | 4:5e274bf85bf0 | 352 | buffer.append(BINDING); |
pnysten | 4:5e274bf85bf0 | 353 | buffer.append(binding); |
pnysten | 4:5e274bf85bf0 | 354 | |
pnysten | 4:5e274bf85bf0 | 355 | char *c = new char[buffer.size()+1]; |
pnysten | 4:5e274bf85bf0 | 356 | copy(buffer.begin(),buffer.end(),c); |
pnysten | 4:5e274bf85bf0 | 357 | c[buffer.size()]='\0'; |
pnysten | 4:5e274bf85bf0 | 358 | return c; |
pnysten | 4:5e274bf85bf0 | 359 | |
pnysten | 6:540c5d907c90 | 360 | |
pnysten | 4:5e274bf85bf0 | 361 | } |
pnysten | 6:540c5d907c90 | 362 | |
mluis | 0:a2929fa6e4f0 | 363 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 364 | // CONFIGURATION (FOR APPLICATION CALLBACKS BELOW) |
mluis | 0:a2929fa6e4f0 | 365 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 366 | |
mluis | 0:a2929fa6e4f0 | 367 | // application router ID (LSBF) |
pnysten | 9:84a69ca4d35a | 368 | //To be changed when switching from one to another |
mluis | 1:60184eda0066 | 369 | static const uint8_t AppEui[8] = |
mluis | 0:a2929fa6e4f0 | 370 | { |
pnysten | 14:acbcd0b888ca | 371 | // 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 |
pnysten | 14:acbcd0b888ca | 372 | 0x01, 0x02, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00 |
mluis | 0:a2929fa6e4f0 | 373 | }; |
mluis | 0:a2929fa6e4f0 | 374 | |
mluis | 0:a2929fa6e4f0 | 375 | // unique device ID (LSBF) |
pnysten | 9:84a69ca4d35a | 376 | //To be changed when switching from one to another |
mluis | 0:a2929fa6e4f0 | 377 | static const u1_t DevEui[8] = |
mluis | 0:a2929fa6e4f0 | 378 | { |
pnysten | 13:9de42df1d3d8 | 379 | 0x33, 0x74, 0x73, 0x65, 0x74, 0x2D, 0x52, 0x4C // 4c522d7465737433 = "LR-test3" |
mluis | 0:a2929fa6e4f0 | 380 | }; |
mluis | 0:a2929fa6e4f0 | 381 | |
mluis | 0:a2929fa6e4f0 | 382 | // device-specific AES key (derived from device EUI) |
mluis | 1:60184eda0066 | 383 | static const uint8_t DevKey[16] = |
mluis | 0:a2929fa6e4f0 | 384 | { |
mluis | 1:60184eda0066 | 385 | 0x2B, 0x7E, 0x15, 0x16, 0x28, 0xAE, 0xD2, 0xA6, |
pnysten | 13:9de42df1d3d8 | 386 | 0xAB, 0xF7, 0x15, 0x88, 0x09, 0xCF, 0x4F, 0x3E |
mluis | 0:a2929fa6e4f0 | 387 | }; |
mluis | 0:a2929fa6e4f0 | 388 | |
mluis | 1:60184eda0066 | 389 | #if( OVER_THE_AIR_ACTIVATION == 0 ) |
mluis | 1:60184eda0066 | 390 | // network session key |
pnysten | 9:84a69ca4d35a | 391 | //To be changed when switching from one to another |
mluis | 0:a2929fa6e4f0 | 392 | static uint8_t NwkSKey[] = |
mluis | 0:a2929fa6e4f0 | 393 | { |
mluis | 0:a2929fa6e4f0 | 394 | 0x2B, 0x7E, 0x15, 0x16, 0x28, 0xAE, 0xD2, 0xA6, |
pnysten | 13:9de42df1d3d8 | 395 | 0xAB, 0xF7, 0x15, 0x88, 0x09, 0xCF, 0x4F, 0x3E |
mluis | 0:a2929fa6e4f0 | 396 | }; |
mluis | 0:a2929fa6e4f0 | 397 | |
mluis | 1:60184eda0066 | 398 | // application session key |
pnysten | 9:84a69ca4d35a | 399 | //To be changed when switching from one to another |
mluis | 0:a2929fa6e4f0 | 400 | static uint8_t ArtSKey[] = |
mluis | 0:a2929fa6e4f0 | 401 | { |
mluis | 0:a2929fa6e4f0 | 402 | 0x2B, 0x7E, 0x15, 0x16, 0x28, 0xAE, 0xD2, 0xA6, |
pnysten | 13:9de42df1d3d8 | 403 | 0xAB, 0xF7, 0x15, 0x88, 0x09, 0xCF, 0x4F, 0x3E |
mluis | 0:a2929fa6e4f0 | 404 | }; |
mluis | 0:a2929fa6e4f0 | 405 | |
mluis | 1:60184eda0066 | 406 | #endif |
mluis | 1:60184eda0066 | 407 | |
mluis | 0:a2929fa6e4f0 | 408 | // LEDs and Frame jobs |
mluis | 0:a2929fa6e4f0 | 409 | osjob_t rxLedJob; |
mluis | 0:a2929fa6e4f0 | 410 | osjob_t txLedJob; |
mluis | 0:a2929fa6e4f0 | 411 | osjob_t sendFrameJob; |
mluis | 0:a2929fa6e4f0 | 412 | |
mluis | 1:60184eda0066 | 413 | // LED state |
mluis | 0:a2929fa6e4f0 | 414 | static bool AppLedStateOn = false; |
mluis | 0:a2929fa6e4f0 | 415 | |
mluis | 0:a2929fa6e4f0 | 416 | ////////////////////////////////////////////////// |
mluis | 1:60184eda0066 | 417 | // Utility functions |
mluis | 1:60184eda0066 | 418 | ////////////////////////////////////////////////// |
mluis | 1:60184eda0066 | 419 | /*! |
mluis | 1:60184eda0066 | 420 | * \brief Computes a random number between min and max |
mluis | 1:60184eda0066 | 421 | * |
mluis | 1:60184eda0066 | 422 | * \param [IN] min range minimum value |
mluis | 1:60184eda0066 | 423 | * \param [IN] max range maximum value |
mluis | 1:60184eda0066 | 424 | * \retval random random value in range min..max |
mluis | 1:60184eda0066 | 425 | */ |
mluis | 1:60184eda0066 | 426 | int32_t randr( int32_t min, int32_t max ) |
mluis | 1:60184eda0066 | 427 | { |
mluis | 1:60184eda0066 | 428 | return ( int32_t )rand( ) % ( max - min + 1 ) + min; |
mluis | 1:60184eda0066 | 429 | } |
mluis | 1:60184eda0066 | 430 | |
mluis | 1:60184eda0066 | 431 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 432 | // APPLICATION CALLBACKS |
mluis | 0:a2929fa6e4f0 | 433 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 434 | |
mluis | 0:a2929fa6e4f0 | 435 | // provide application router ID (8 bytes, LSBF) |
mluis | 1:60184eda0066 | 436 | void os_getArtEui( uint8_t *buf ) |
mluis | 0:a2929fa6e4f0 | 437 | { |
mluis | 0:a2929fa6e4f0 | 438 | memcpy( buf, AppEui, 8 ); |
mluis | 0:a2929fa6e4f0 | 439 | } |
mluis | 0:a2929fa6e4f0 | 440 | |
mluis | 0:a2929fa6e4f0 | 441 | // provide device ID (8 bytes, LSBF) |
mluis | 1:60184eda0066 | 442 | void os_getDevEui( uint8_t *buf ) |
mluis | 0:a2929fa6e4f0 | 443 | { |
mluis | 0:a2929fa6e4f0 | 444 | memcpy( buf, DevEui, 8 ); |
mluis | 0:a2929fa6e4f0 | 445 | } |
mluis | 0:a2929fa6e4f0 | 446 | |
mluis | 0:a2929fa6e4f0 | 447 | // provide device key (16 bytes) |
mluis | 1:60184eda0066 | 448 | void os_getDevKey( uint8_t *buf ) |
mluis | 0:a2929fa6e4f0 | 449 | { |
mluis | 0:a2929fa6e4f0 | 450 | memcpy( buf, DevKey, 16 ); |
mluis | 0:a2929fa6e4f0 | 451 | } |
mluis | 0:a2929fa6e4f0 | 452 | |
mluis | 0:a2929fa6e4f0 | 453 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 454 | // MAIN - INITIALIZATION AND STARTUP |
mluis | 0:a2929fa6e4f0 | 455 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 456 | |
mluis | 0:a2929fa6e4f0 | 457 | static void onRxLed( osjob_t* j ) |
mluis | 0:a2929fa6e4f0 | 458 | { |
pnysten | 12:f28b629d8a6e | 459 | // debug_val("LED2 = ", 0 ); |
mluis | 0:a2929fa6e4f0 | 460 | } |
mluis | 0:a2929fa6e4f0 | 461 | |
mluis | 0:a2929fa6e4f0 | 462 | static void onTxLed( osjob_t* j ) |
mluis | 0:a2929fa6e4f0 | 463 | { |
pnysten | 12:f28b629d8a6e | 464 | // debug_val("LED1 = ", 0 ); |
mluis | 0:a2929fa6e4f0 | 465 | } |
mluis | 0:a2929fa6e4f0 | 466 | |
pnysten | 6:540c5d907c90 | 467 | static void prepareTxCoapFrame( void ) |
pnysten | 6:540c5d907c90 | 468 | { |
pnysten | 6:540c5d907c90 | 469 | // Create Registration PDU : |
pnysten | 6:540c5d907c90 | 470 | |
pnysten | 6:540c5d907c90 | 471 | CoapPDU *pdu = new CoapPDU(); |
pnysten | 6:540c5d907c90 | 472 | |
pnysten | 6:540c5d907c90 | 473 | pdu->setCode(CoapPDU::COAP_POST); |
pnysten | 6:540c5d907c90 | 474 | pdu->setType(CoapPDU::COAP_CONFIRMABLE); |
pnysten | 6:540c5d907c90 | 475 | int size; |
pnysten | 6:540c5d907c90 | 476 | uint8_t * token = get_Token(&size); |
pnysten | 6:540c5d907c90 | 477 | pdu->setToken(token,size); |
pnysten | 6:540c5d907c90 | 478 | pdu->setMessageID(get_Message_ID()); |
pnysten | 6:540c5d907c90 | 479 | pdu->setURI(get_Registration_Query()); |
pnysten | 6:540c5d907c90 | 480 | |
pnysten | 6:540c5d907c90 | 481 | _payload=get_Registration_Payload(&_payload_size); |
pnysten | 6:540c5d907c90 | 482 | pdu->setPayload(_payload, (int) _payload_size); |
pnysten | 6:540c5d907c90 | 483 | int PDUlength = pdu->getPDULength(); |
pnysten | 6:540c5d907c90 | 484 | |
pnysten | 6:540c5d907c90 | 485 | // strncpy((char*) LMIC.frame, (const char*)pdu->getPDUPointer(), PDUlength); |
pnysten | 6:540c5d907c90 | 486 | memcpy(LMIC.frame, pdu->getPDUPointer(), PDUlength * sizeof(uint8_t)); |
pnysten | 6:540c5d907c90 | 487 | |
pnysten | 6:540c5d907c90 | 488 | #if ( LORAWAN_CONFIRMED_MSG_ON == 1 ) |
pnysten | 6:540c5d907c90 | 489 | LMIC.frame[PDUlength] = LMIC.seqnoDn >> 8; |
pnysten | 6:540c5d907c90 | 490 | LMIC.frame[PDUlength+1] = LMIC.seqnoDn; |
pnysten | 6:540c5d907c90 | 491 | LMIC.frame[PDUlength+2] = LMIC.rssi >> 8; |
pnysten | 6:540c5d907c90 | 492 | LMIC.frame[PDUlength+3] = LMIC.rssi; |
pnysten | 6:540c5d907c90 | 493 | LMIC.frame[PDUlength+4] = LMIC.snr; |
pnysten | 6:540c5d907c90 | 494 | #endif |
pnysten | 6:540c5d907c90 | 495 | debug_str("Frame to be sent: "); |
pnysten | 6:540c5d907c90 | 496 | debug_buf(LMIC.frame, PDUlength + 5); |
pnysten | 6:540c5d907c90 | 497 | |
pnysten | 6:540c5d907c90 | 498 | LoRaWAN_data_size = PDUlength + 5; |
pnysten | 6:540c5d907c90 | 499 | } |
pnysten | 6:540c5d907c90 | 500 | |
pnysten | 8:8d9a49aaa323 | 501 | static void prepareTxLoraFrame( void ) |
pnysten | 8:8d9a49aaa323 | 502 | { |
pnysten | 8:8d9a49aaa323 | 503 | const char *frame = "LoRa"; |
pnysten | 9:84a69ca4d35a | 504 | // const char *frame = "Test"; |
pnysten | 8:8d9a49aaa323 | 505 | |
pnysten | 8:8d9a49aaa323 | 506 | strncpy((char*) LMIC.frame, frame, strlen(frame)); |
pnysten | 8:8d9a49aaa323 | 507 | |
pnysten | 8:8d9a49aaa323 | 508 | #if ( LORAWAN_CONFIRMED_MSG_ON == 1 ) |
pnysten | 8:8d9a49aaa323 | 509 | LMIC.frame[strlen(frame)] = LMIC.seqnoDn >> 8; |
pnysten | 8:8d9a49aaa323 | 510 | LMIC.frame[strlen(frame)+1] = LMIC.seqnoDn; |
pnysten | 8:8d9a49aaa323 | 511 | LMIC.frame[strlen(frame)+2] = LMIC.rssi >> 8; |
pnysten | 8:8d9a49aaa323 | 512 | LMIC.frame[strlen(frame)+3] = LMIC.rssi; |
pnysten | 8:8d9a49aaa323 | 513 | LMIC.frame[strlen(frame)+4] = LMIC.snr; |
pnysten | 8:8d9a49aaa323 | 514 | #endif |
pnysten | 8:8d9a49aaa323 | 515 | debug_str("Frame to be sent: "); |
pnysten | 9:84a69ca4d35a | 516 | // debug_buf(LMIC.frame, strlen(frame) + 5); |
pnysten | 9:84a69ca4d35a | 517 | debug_buf(LMIC.frame, strlen(frame)); |
pnysten | 8:8d9a49aaa323 | 518 | |
pnysten | 9:84a69ca4d35a | 519 | // LoRaWAN_data_size = strlen(frame) + 5; |
pnysten | 9:84a69ca4d35a | 520 | LoRaWAN_data_size = strlen(frame); |
pnysten | 8:8d9a49aaa323 | 521 | } |
pnysten | 8:8d9a49aaa323 | 522 | |
pnysten | 10:155dc60fce79 | 523 | static void prepareTxSensorsFrame( void ) |
pnysten | 10:155dc60fce79 | 524 | { |
pnysten | 10:155dc60fce79 | 525 | std::string frame = ""; |
pnysten | 10:155dc60fce79 | 526 | std::string tmp; |
pnysten | 14:acbcd0b888ca | 527 | // debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 528 | |
pnysten | 10:155dc60fce79 | 529 | temp_sensor1->GetTemperature(&value1); |
pnysten | 10:155dc60fce79 | 530 | humidity_sensor->GetHumidity(&value2); |
pnysten | 14:acbcd0b888ca | 531 | printDouble(buffer1, value1); |
pnysten | 14:acbcd0b888ca | 532 | // debug_str("HTS221: [temp] "); |
pnysten | 14:acbcd0b888ca | 533 | // debug_str(printDouble(buffer1, value1)); |
pnysten | 10:155dc60fce79 | 534 | tmp = "0,"; |
pnysten | 10:155dc60fce79 | 535 | tmp += buffer1; |
pnysten | 10:155dc60fce79 | 536 | tmp += ","; |
pnysten | 10:155dc60fce79 | 537 | |
pnysten | 10:155dc60fce79 | 538 | if ((!temp_sent) && (frame.length() + tmp.length() < 50)) |
pnysten | 10:155dc60fce79 | 539 | { |
pnysten | 10:155dc60fce79 | 540 | temp_sent = true; |
pnysten | 10:155dc60fce79 | 541 | frame += tmp; |
pnysten | 10:155dc60fce79 | 542 | } |
pnysten | 14:acbcd0b888ca | 543 | printDouble(buffer2, value2); |
pnysten | 14:acbcd0b888ca | 544 | // debug_str("Celsius, [hum] "); |
pnysten | 14:acbcd0b888ca | 545 | // debug_str(printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 546 | tmp = "1,"; |
pnysten | 10:155dc60fce79 | 547 | tmp += buffer2; |
pnysten | 10:155dc60fce79 | 548 | tmp += ","; |
pnysten | 10:155dc60fce79 | 549 | |
pnysten | 10:155dc60fce79 | 550 | if ((!hum_sent) && (frame.length() + tmp.length() < 50)) |
pnysten | 10:155dc60fce79 | 551 | { |
pnysten | 10:155dc60fce79 | 552 | hum_sent = true; |
pnysten | 10:155dc60fce79 | 553 | frame += tmp; |
pnysten | 10:155dc60fce79 | 554 | } |
pnysten | 10:155dc60fce79 | 555 | |
pnysten | 14:acbcd0b888ca | 556 | // debug_str("%\r\n"); |
pnysten | 10:155dc60fce79 | 557 | //pc.printf("HTS221: [temp] %7s°C, [hum] %s%%\r\n", printDouble(buffer1, value1), printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 558 | |
pnysten | 10:155dc60fce79 | 559 | temp_sensor2->GetFahrenheit(&value1); |
pnysten | 10:155dc60fce79 | 560 | pressure_sensor->GetPressure(&value2); |
pnysten | 14:acbcd0b888ca | 561 | printDouble(buffer1, value1); |
pnysten | 14:acbcd0b888ca | 562 | printDouble(buffer2, value2); |
pnysten | 14:acbcd0b888ca | 563 | /* debug_str("LPS25H: [temp] "); |
pnysten | 10:155dc60fce79 | 564 | debug_str(printDouble(buffer1, value1)); |
pnysten | 10:155dc60fce79 | 565 | debug_str("Farenheit, [press] "); |
pnysten | 14:acbcd0b888ca | 566 | debug_str(printDouble(buffer2, value2));*/ |
pnysten | 10:155dc60fce79 | 567 | tmp = "2,"; |
pnysten | 10:155dc60fce79 | 568 | tmp += buffer2; |
pnysten | 10:155dc60fce79 | 569 | tmp += ","; |
pnysten | 10:155dc60fce79 | 570 | |
pnysten | 10:155dc60fce79 | 571 | if ((!press_sent) && (frame.length() + tmp.length() < 50)) |
pnysten | 10:155dc60fce79 | 572 | { |
pnysten | 10:155dc60fce79 | 573 | press_sent = true; |
pnysten | 10:155dc60fce79 | 574 | frame += tmp; |
pnysten | 10:155dc60fce79 | 575 | } |
pnysten | 10:155dc60fce79 | 576 | |
pnysten | 14:acbcd0b888ca | 577 | // debug_str("mbar\r\n"); |
pnysten | 10:155dc60fce79 | 578 | //pc.printf("LPS25H: [temp] %7s°F, [press] %smbar\r\n", printDouble(buffer1, value1), printDouble(buffer2, value2)); |
pnysten | 10:155dc60fce79 | 579 | |
pnysten | 14:acbcd0b888ca | 580 | // debug_str("---\r\n"); |
pnysten | 10:155dc60fce79 | 581 | |
pnysten | 10:155dc60fce79 | 582 | magnetometer->Get_M_Axes(axes); |
pnysten | 14:acbcd0b888ca | 583 | printInt(buffer1, axes[0]); |
pnysten | 14:acbcd0b888ca | 584 | printInt(buffer2, axes[1]); |
pnysten | 14:acbcd0b888ca | 585 | printInt(buffer3, axes[2]); |
pnysten | 14:acbcd0b888ca | 586 | /* debug_str("LIS3MDL [mag/mgauss]: "); |
pnysten | 10:155dc60fce79 | 587 | debug_str(printInt(buffer1, axes[0])); |
pnysten | 10:155dc60fce79 | 588 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 589 | debug_str(printInt(buffer2, axes[1])); |
pnysten | 10:155dc60fce79 | 590 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 591 | debug_str(printInt(buffer3, axes[2])); |
pnysten | 14:acbcd0b888ca | 592 | debug_str("\r\n");*/ |
pnysten | 10:155dc60fce79 | 593 | tmp = "3,"; |
pnysten | 10:155dc60fce79 | 594 | tmp += buffer1; |
pnysten | 10:155dc60fce79 | 595 | tmp += ";"; |
pnysten | 10:155dc60fce79 | 596 | tmp += buffer2; |
pnysten | 10:155dc60fce79 | 597 | tmp += ";"; |
pnysten | 10:155dc60fce79 | 598 | tmp += buffer3; |
pnysten | 10:155dc60fce79 | 599 | tmp += ","; |
pnysten | 10:155dc60fce79 | 600 | |
pnysten | 10:155dc60fce79 | 601 | if ((!magn_sent) && (frame.length() + tmp.length() < 50)) |
pnysten | 10:155dc60fce79 | 602 | { |
pnysten | 10:155dc60fce79 | 603 | magn_sent = true; |
pnysten | 10:155dc60fce79 | 604 | frame += tmp; |
pnysten | 10:155dc60fce79 | 605 | } |
pnysten | 10:155dc60fce79 | 606 | |
pnysten | 10:155dc60fce79 | 607 | //pc.printf("LIS3MDL [mag/mgauss]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
pnysten | 10:155dc60fce79 | 608 | |
pnysten | 10:155dc60fce79 | 609 | accelerometer->Get_X_Axes(axes); |
pnysten | 14:acbcd0b888ca | 610 | printInt(buffer1, axes[0]); |
pnysten | 14:acbcd0b888ca | 611 | printInt(buffer2, axes[1]); |
pnysten | 14:acbcd0b888ca | 612 | printInt(buffer3, axes[2]); |
pnysten | 14:acbcd0b888ca | 613 | /* debug_str("LSM6DS0 [acc/mg]: "); |
pnysten | 14:acbcd0b888ca | 614 | |
pnysten | 10:155dc60fce79 | 615 | debug_str(printInt(buffer1, axes[0])); |
pnysten | 10:155dc60fce79 | 616 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 617 | debug_str(printInt(buffer2, axes[1])); |
pnysten | 10:155dc60fce79 | 618 | debug_str(", "); |
pnysten | 14:acbcd0b888ca | 619 | debug_str(printInt(buffer3, axes[2]));*/ |
pnysten | 10:155dc60fce79 | 620 | tmp = "4,"; |
pnysten | 10:155dc60fce79 | 621 | tmp += buffer1; |
pnysten | 10:155dc60fce79 | 622 | tmp += ";"; |
pnysten | 10:155dc60fce79 | 623 | tmp += buffer2; |
pnysten | 10:155dc60fce79 | 624 | tmp += ";"; |
pnysten | 10:155dc60fce79 | 625 | tmp += buffer3; |
pnysten | 10:155dc60fce79 | 626 | tmp += ","; |
pnysten | 10:155dc60fce79 | 627 | |
pnysten | 10:155dc60fce79 | 628 | if ((!motion_sent) && (frame.length() + tmp.length() < 50)) |
pnysten | 10:155dc60fce79 | 629 | { |
pnysten | 10:155dc60fce79 | 630 | motion_sent = true; |
pnysten | 10:155dc60fce79 | 631 | frame += tmp; |
pnysten | 10:155dc60fce79 | 632 | } |
pnysten | 10:155dc60fce79 | 633 | |
pnysten | 14:acbcd0b888ca | 634 | //debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 635 | //pc.printf("LSM6DS0 [acc/mg]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
pnysten | 10:155dc60fce79 | 636 | |
pnysten | 10:155dc60fce79 | 637 | gyroscope->Get_G_Axes(axes); |
pnysten | 14:acbcd0b888ca | 638 | printInt(buffer1, axes[0]); |
pnysten | 14:acbcd0b888ca | 639 | printInt(buffer2, axes[1]); |
pnysten | 14:acbcd0b888ca | 640 | printInt(buffer3, axes[2]); |
pnysten | 14:acbcd0b888ca | 641 | /* debug_str("LSM6DS0 [gyro/mdps]: "); |
pnysten | 10:155dc60fce79 | 642 | debug_str(printInt(buffer1, axes[0])); |
pnysten | 10:155dc60fce79 | 643 | debug_str(", "); |
pnysten | 10:155dc60fce79 | 644 | debug_str(printInt(buffer2, axes[1])); |
pnysten | 10:155dc60fce79 | 645 | debug_str(", "); |
pnysten | 14:acbcd0b888ca | 646 | debug_str(printInt(buffer3, axes[2]));*/ |
pnysten | 10:155dc60fce79 | 647 | tmp = "5,"; |
pnysten | 10:155dc60fce79 | 648 | tmp += buffer1; |
pnysten | 10:155dc60fce79 | 649 | tmp += ";"; |
pnysten | 10:155dc60fce79 | 650 | tmp += buffer2; |
pnysten | 10:155dc60fce79 | 651 | tmp += ";"; |
pnysten | 10:155dc60fce79 | 652 | tmp += buffer3; |
pnysten | 10:155dc60fce79 | 653 | |
pnysten | 10:155dc60fce79 | 654 | if ((!gyro_sent) && (frame.length() + tmp.length() < 50)) |
pnysten | 10:155dc60fce79 | 655 | { |
pnysten | 10:155dc60fce79 | 656 | gyro_sent = false; |
pnysten | 10:155dc60fce79 | 657 | temp_sent = false; |
pnysten | 10:155dc60fce79 | 658 | press_sent = false; |
pnysten | 10:155dc60fce79 | 659 | motion_sent = false; |
pnysten | 10:155dc60fce79 | 660 | magn_sent = false; |
pnysten | 11:59c160a8926d | 661 | hum_sent = false; |
pnysten | 10:155dc60fce79 | 662 | |
pnysten | 10:155dc60fce79 | 663 | frame += tmp; |
pnysten | 10:155dc60fce79 | 664 | } |
pnysten | 10:155dc60fce79 | 665 | |
pnysten | 14:acbcd0b888ca | 666 | //debug_str("\r\n Frame: "); |
pnysten | 14:acbcd0b888ca | 667 | //debug_str(frame.c_str()); |
pnysten | 14:acbcd0b888ca | 668 | //debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 669 | //pc.printf("LSM6DS0 [gyro/mdps]: %6ld, %6ld, %6ld\r\n", axes[0], axes[1], axes[2]); |
pnysten | 10:155dc60fce79 | 670 | |
pnysten | 10:155dc60fce79 | 671 | strncpy((char*) LMIC.frame, frame.c_str(), strlen(frame.c_str())); |
pnysten | 10:155dc60fce79 | 672 | |
pnysten | 10:155dc60fce79 | 673 | #if ( LORAWAN_CONFIRMED_MSG_ON == 1 ) |
pnysten | 10:155dc60fce79 | 674 | LMIC.frame[strlen(frame.c_str())] = LMIC.seqnoDn >> 8; |
pnysten | 10:155dc60fce79 | 675 | LMIC.frame[strlen(frame.c_str())+1] = LMIC.seqnoDn; |
pnysten | 10:155dc60fce79 | 676 | LMIC.frame[strlen(frame.c_str())+2] = LMIC.rssi >> 8; |
pnysten | 10:155dc60fce79 | 677 | LMIC.frame[strlen(frame.c_str())+3] = LMIC.rssi; |
pnysten | 10:155dc60fce79 | 678 | LMIC.frame[strlen(frame.c_str())+4] = LMIC.snr; |
pnysten | 10:155dc60fce79 | 679 | #endif |
pnysten | 14:acbcd0b888ca | 680 | //debug_str("Frame to be sent: "); |
pnysten | 10:155dc60fce79 | 681 | // debug_buf(LMIC.frame, strlen(frame) + 5); |
pnysten | 14:acbcd0b888ca | 682 | //debug_buf(LMIC.frame, strlen(frame.c_str())); |
pnysten | 10:155dc60fce79 | 683 | |
pnysten | 10:155dc60fce79 | 684 | // LoRaWAN_data_size = strlen(frame) + 5; |
pnysten | 10:155dc60fce79 | 685 | LoRaWAN_data_size = strlen(frame.c_str()); |
pnysten | 10:155dc60fce79 | 686 | } |
pnysten | 10:155dc60fce79 | 687 | |
mluis | 0:a2929fa6e4f0 | 688 | static void prepareTxFrame( void ) |
mluis | 0:a2929fa6e4f0 | 689 | { |
mluis | 0:a2929fa6e4f0 | 690 | LMIC.frame[0] = AppLedStateOn; |
mluis | 1:60184eda0066 | 691 | #if ( LORAWAN_CONFIRMED_MSG_ON == 1 ) |
mluis | 1:60184eda0066 | 692 | LMIC.frame[1] = LMIC.seqnoDn >> 8; |
mluis | 1:60184eda0066 | 693 | LMIC.frame[2] = LMIC.seqnoDn; |
mluis | 1:60184eda0066 | 694 | LMIC.frame[3] = LMIC.rssi >> 8; |
mluis | 1:60184eda0066 | 695 | LMIC.frame[4] = LMIC.rssi; |
mluis | 1:60184eda0066 | 696 | LMIC.frame[5] = LMIC.snr; |
mluis | 1:60184eda0066 | 697 | #endif |
pnysten | 14:acbcd0b888ca | 698 | //debug_str("Frame to be sent: "); |
pnysten | 14:acbcd0b888ca | 699 | //debug_buf(LMIC.frame, LORAWAN_APP_DATA_SIZE); |
pnysten | 6:540c5d907c90 | 700 | |
pnysten | 6:540c5d907c90 | 701 | LoRaWAN_data_size = LORAWAN_APP_DATA_SIZE; |
mluis | 0:a2929fa6e4f0 | 702 | } |
mluis | 0:a2929fa6e4f0 | 703 | |
mluis | 0:a2929fa6e4f0 | 704 | void processRxFrame( void ) |
mluis | 0:a2929fa6e4f0 | 705 | { |
pnysten | 8:8d9a49aaa323 | 706 | |
pnysten | 8:8d9a49aaa323 | 707 | char* frameToDisplay = (char*) (LMIC.frame + LMIC.dataBeg); |
pnysten | 8:8d9a49aaa323 | 708 | frameToDisplay[LMIC.dataLen] = '\0'; |
pnysten | 4:5e274bf85bf0 | 709 | |
mluis | 0:a2929fa6e4f0 | 710 | switch( LMIC.frame[LMIC.dataBeg - 1] ) // Check Rx port number |
mluis | 0:a2929fa6e4f0 | 711 | { |
pnysten | 4:5e274bf85bf0 | 712 | case 0: |
pnysten | 4:5e274bf85bf0 | 713 | // debug_str("Port 0!!!\r\n"); |
pnysten | 4:5e274bf85bf0 | 714 | // debug_val("Data Len: ", LMIC.dataLen); |
pnysten | 4:5e274bf85bf0 | 715 | |
mluis | 0:a2929fa6e4f0 | 716 | case 1: // The application LED can be controlled on port 1 or 2 |
pnysten | 8:8d9a49aaa323 | 717 | debug_str("Data received on port 1: "); |
pnysten | 8:8d9a49aaa323 | 718 | debug_str("Data in hexa: "); |
pnysten | 8:8d9a49aaa323 | 719 | debug_buf( LMIC.frame + LMIC.dataBeg, LMIC.dataLen ); |
pnysten | 8:8d9a49aaa323 | 720 | debug_str("Data in string: "); |
pnysten | 8:8d9a49aaa323 | 721 | |
pnysten | 8:8d9a49aaa323 | 722 | debug_str( frameToDisplay ); |
pnysten | 8:8d9a49aaa323 | 723 | debug_str("\r\n"); |
pnysten | 8:8d9a49aaa323 | 724 | |
pnysten | 8:8d9a49aaa323 | 725 | break; |
mluis | 0:a2929fa6e4f0 | 726 | case 2: |
pnysten | 8:8d9a49aaa323 | 727 | debug_str("Data received on port 2: "); |
pnysten | 8:8d9a49aaa323 | 728 | debug_str("Data in hexa: "); |
pnysten | 8:8d9a49aaa323 | 729 | debug_buf( LMIC.frame + LMIC.dataBeg, LMIC.dataLen ); |
pnysten | 8:8d9a49aaa323 | 730 | debug_str("Data in string: "); |
pnysten | 8:8d9a49aaa323 | 731 | |
pnysten | 8:8d9a49aaa323 | 732 | debug_str( frameToDisplay ); |
pnysten | 8:8d9a49aaa323 | 733 | debug_str("\r\n"); |
pnysten | 8:8d9a49aaa323 | 734 | |
mluis | 0:a2929fa6e4f0 | 735 | if( LMIC.dataLen == 1 ) |
mluis | 0:a2929fa6e4f0 | 736 | { |
pnysten | 4:5e274bf85bf0 | 737 | debug_str("Data received on port 2: "); |
pnysten | 4:5e274bf85bf0 | 738 | debug_hex(LMIC.frame[LMIC.dataBeg]); |
pnysten | 4:5e274bf85bf0 | 739 | debug_str("\r\n"); |
mluis | 0:a2929fa6e4f0 | 740 | AppLedStateOn = LMIC.frame[LMIC.dataBeg] & 0x01; |
pnysten | 12:f28b629d8a6e | 741 | //debug_val( "LED3 = ", AppLedStateOn ); |
mluis | 0:a2929fa6e4f0 | 742 | } |
mluis | 0:a2929fa6e4f0 | 743 | break; |
mluis | 0:a2929fa6e4f0 | 744 | default: |
mluis | 0:a2929fa6e4f0 | 745 | break; |
mluis | 0:a2929fa6e4f0 | 746 | } |
mluis | 0:a2929fa6e4f0 | 747 | } |
mluis | 0:a2929fa6e4f0 | 748 | |
mluis | 0:a2929fa6e4f0 | 749 | static void onSendFrame( osjob_t* j ) |
mluis | 0:a2929fa6e4f0 | 750 | { |
pnysten | 6:540c5d907c90 | 751 | //prepareTxFrame( ); |
pnysten | 8:8d9a49aaa323 | 752 | //prepareTxCoapFrame(); |
pnysten | 10:155dc60fce79 | 753 | prepareTxSensorsFrame(); |
pnysten | 10:155dc60fce79 | 754 | //prepareTxLoraFrame(); |
pnysten | 4:5e274bf85bf0 | 755 | |
pnysten | 14:acbcd0b888ca | 756 | #if( OVER_THE_AIR_ACTIVATION == 1 ) |
pnysten | 14:acbcd0b888ca | 757 | LMIC_setTxData2( LORAWAN_APP_PORT, LMIC.frame, LoRaWAN_data_size, LORAWAN_CONFIRMED_MSG_ON, 1 ); |
pnysten | 14:acbcd0b888ca | 758 | #endif |
pnysten | 14:acbcd0b888ca | 759 | #if( OVER_THE_AIR_ACTIVATION == 0 ) |
pnysten | 14:acbcd0b888ca | 760 | LMIC_setTxData2( LORAWAN_APP_PORT, LMIC.frame, LoRaWAN_data_size, LORAWAN_CONFIRMED_MSG_ON, 0 ); |
pnysten | 14:acbcd0b888ca | 761 | #endif |
mluis | 1:60184eda0066 | 762 | |
mluis | 1:60184eda0066 | 763 | // Blink Tx LED |
pnysten | 12:f28b629d8a6e | 764 | //debug_val( "LED1 = ", 1 ); |
mluis | 1:60184eda0066 | 765 | os_setTimedCallback( &txLedJob, os_getTime( ) + ms2osticks( 25 ), onTxLed ); |
pnysten | 12:f28b629d8a6e | 766 | /* os_setTimedCallback( &sendFrameJob, |
pnysten | 12:f28b629d8a6e | 767 | os_getTime( ) + ms2osticks( APP_TX_DUTYCYCLE + randr( -APP_TX_DUTYCYCLE_RND, APP_TX_DUTYCYCLE_RND ) ), |
pnysten | 12:f28b629d8a6e | 768 | onSendFrame );*/ |
mluis | 0:a2929fa6e4f0 | 769 | } |
mluis | 0:a2929fa6e4f0 | 770 | |
mluis | 1:60184eda0066 | 771 | // Initialization job |
mluis | 1:60184eda0066 | 772 | static void onInit( osjob_t* j ) |
mluis | 1:60184eda0066 | 773 | { |
pnysten | 10:155dc60fce79 | 774 | debug_str("--- Starting new run ---\r\n"); |
pnysten | 10:155dc60fce79 | 775 | |
pnysten | 10:155dc60fce79 | 776 | humidity_sensor->ReadID(&id); |
pnysten | 10:155dc60fce79 | 777 | debug_str("HTS221 humidity & temperature = "); |
pnysten | 10:155dc60fce79 | 778 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 779 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 780 | pressure_sensor->ReadID(&id); |
pnysten | 10:155dc60fce79 | 781 | debug_str("LPS25H pressure & temperature = "); |
pnysten | 10:155dc60fce79 | 782 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 783 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 784 | magnetometer->ReadID(&id); |
pnysten | 10:155dc60fce79 | 785 | debug_str("LIS3MDL magnetometer = "); |
pnysten | 10:155dc60fce79 | 786 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 787 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 788 | gyroscope->ReadID(&id); |
pnysten | 10:155dc60fce79 | 789 | debug_str("LSM6DS0 accelerometer & gyroscope = "); |
pnysten | 10:155dc60fce79 | 790 | debug_uint(id); |
pnysten | 10:155dc60fce79 | 791 | debug_str("\r\n"); |
pnysten | 10:155dc60fce79 | 792 | |
mluis | 1:60184eda0066 | 793 | // reset MAC state |
mluis | 1:60184eda0066 | 794 | LMIC_reset( ); |
mluis | 1:60184eda0066 | 795 | LMIC_setAdrMode( LORAWAN_ADR_ON ); |
mluis | 1:60184eda0066 | 796 | LMIC_setDrTxpow( DR_SF12, 14 ); |
mluis | 1:60184eda0066 | 797 | |
mluis | 1:60184eda0066 | 798 | // start joining |
mluis | 1:60184eda0066 | 799 | #if( OVER_THE_AIR_ACTIVATION != 0 ) |
mluis | 1:60184eda0066 | 800 | LMIC_startJoining( ); |
mluis | 1:60184eda0066 | 801 | #else |
mluis | 1:60184eda0066 | 802 | LMIC_setSession( LORAWAN_NET_ID, LORAWAN_DEV_ADDR, NwkSKey, ArtSKey ); |
mluis | 1:60184eda0066 | 803 | onSendFrame( NULL ); |
mluis | 1:60184eda0066 | 804 | #endif |
mluis | 1:60184eda0066 | 805 | // init done - onEvent( ) callback will be invoked... |
mluis | 1:60184eda0066 | 806 | } |
mluis | 1:60184eda0066 | 807 | |
mluis | 1:60184eda0066 | 808 | int main( void ) |
mluis | 0:a2929fa6e4f0 | 809 | { |
pnysten | 4:5e274bf85bf0 | 810 | debug_init(); |
mluis | 0:a2929fa6e4f0 | 811 | osjob_t initjob; |
pnysten | 6:540c5d907c90 | 812 | |
mluis | 0:a2929fa6e4f0 | 813 | // initialize runtime env |
mluis | 0:a2929fa6e4f0 | 814 | os_init( ); |
mluis | 0:a2929fa6e4f0 | 815 | // setup initial job |
mluis | 0:a2929fa6e4f0 | 816 | os_setCallback( &initjob, onInit ); |
mluis | 0:a2929fa6e4f0 | 817 | // execute scheduled jobs and events |
pnysten | 10:155dc60fce79 | 818 | |
pnysten | 10:155dc60fce79 | 819 | //static Thread exec_thread(exec_call_thread); |
pnysten | 10:155dc60fce79 | 820 | |
mluis | 0:a2929fa6e4f0 | 821 | os_runloop( ); |
mluis | 0:a2929fa6e4f0 | 822 | // (not reached) |
mluis | 0:a2929fa6e4f0 | 823 | } |
mluis | 0:a2929fa6e4f0 | 824 | |
mluis | 0:a2929fa6e4f0 | 825 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 826 | // LMIC EVENT CALLBACK |
mluis | 0:a2929fa6e4f0 | 827 | ////////////////////////////////////////////////// |
mluis | 0:a2929fa6e4f0 | 828 | void onEvent( ev_t ev ) |
mluis | 0:a2929fa6e4f0 | 829 | { |
mluis | 0:a2929fa6e4f0 | 830 | bool txOn = false; |
mluis | 1:60184eda0066 | 831 | debug_event( ev ); |
mluis | 0:a2929fa6e4f0 | 832 | |
mluis | 0:a2929fa6e4f0 | 833 | switch( ev ) |
mluis | 0:a2929fa6e4f0 | 834 | { |
mluis | 0:a2929fa6e4f0 | 835 | // network joined, session established |
mluis | 0:a2929fa6e4f0 | 836 | case EV_JOINED: |
mluis | 1:60184eda0066 | 837 | debug_val( "Net ID = ", LMIC.netid ); |
mluis | 0:a2929fa6e4f0 | 838 | txOn = true; |
mluis | 0:a2929fa6e4f0 | 839 | break; |
mluis | 0:a2929fa6e4f0 | 840 | // scheduled data sent (optionally data received) |
mluis | 0:a2929fa6e4f0 | 841 | case EV_TXCOMPLETE: |
mluis | 1:60184eda0066 | 842 | debug_val( "Datarate = ", LMIC.datarate ); |
mluis | 0:a2929fa6e4f0 | 843 | // Check if we have a downlink on either Rx1 or Rx2 windows |
mluis | 1:60184eda0066 | 844 | if( ( LMIC.txrxFlags & ( TXRX_DNW1 | TXRX_DNW2 ) ) != 0 ) |
mluis | 0:a2929fa6e4f0 | 845 | { |
pnysten | 12:f28b629d8a6e | 846 | // debug_val( "LED2 = ", 1 ); |
mluis | 1:60184eda0066 | 847 | os_setTimedCallback( &rxLedJob, os_getTime( ) + ms2osticks( 25 ), onRxLed ); |
mluis | 0:a2929fa6e4f0 | 848 | |
mluis | 1:60184eda0066 | 849 | if( LMIC.dataLen != 0 ) |
mluis | 0:a2929fa6e4f0 | 850 | { // data received in rx slot after tx |
pnysten | 4:5e274bf85bf0 | 851 | //debug_buf( LMIC.frame + LMIC.dataBeg, LMIC.dataLen ); |
mluis | 0:a2929fa6e4f0 | 852 | processRxFrame( ); |
mluis | 0:a2929fa6e4f0 | 853 | } |
mluis | 0:a2929fa6e4f0 | 854 | } |
mluis | 0:a2929fa6e4f0 | 855 | txOn = true; |
mluis | 0:a2929fa6e4f0 | 856 | break; |
mluis | 0:a2929fa6e4f0 | 857 | default: |
mluis | 0:a2929fa6e4f0 | 858 | break; |
mluis | 0:a2929fa6e4f0 | 859 | } |
mluis | 0:a2929fa6e4f0 | 860 | if( txOn == true ) |
mluis | 0:a2929fa6e4f0 | 861 | { |
mluis | 1:60184eda0066 | 862 | //Sends frame every APP_TX_DUTYCYCLE +/- APP_TX_DUTYCYCLE_RND random time (if not duty cycle limited) |
mluis | 1:60184eda0066 | 863 | os_setTimedCallback( &sendFrameJob, |
mluis | 1:60184eda0066 | 864 | os_getTime( ) + ms2osticks( APP_TX_DUTYCYCLE + randr( -APP_TX_DUTYCYCLE_RND, APP_TX_DUTYCYCLE_RND ) ), |
mluis | 1:60184eda0066 | 865 | onSendFrame ); |
pnysten | 12:f28b629d8a6e | 866 | //os_setCallback( &sendFrameJob, onSendFrame ); |
mluis | 1:60184eda0066 | 867 | ////Sends frame as soon as possible (duty cylce limitations) |
mluis | 1:60184eda0066 | 868 | //onSendFrame( NULL ); |
mluis | 0:a2929fa6e4f0 | 869 | } |
mluis | 0:a2929fa6e4f0 | 870 | } |
pnysten | 10:155dc60fce79 | 871 | |
pnysten | 10:155dc60fce79 | 872 |