Archives
/
Farm-Data-Relay-System
mirror of https://github.com/timmbogner/Farm-Data-Relay-System
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #144 from aviateur17/release_2023_01_ifdefs

Browse Source 
move #ifdefs used to enable or disable features from function scope t…
pull/131/head
Timm Bogner 1 year ago committed by GitHub
parent 1d2d07dd4d 9b5323e447
commit e8b58d8c9b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
13 changed files with 215 additions and 184 deletions
Show Stats Download Patch File Download Diff File

4
src/fdrs_checkConfig.h
Unescape Escape View File

@ -79,8 +79,8 @@ void printLoggingInformation() {
#else
DBG("log buffer delay in ms: NOT SPECIFIED - check config!");
#endif
#ifdef FS_FILENAME
DBG("log filename : " + FS_FILENAME);
#ifdef LOG_FILENAME
DBG("log filename : " + LOG_FILENAME);
#else
DBG("log filename : NOT SPECIFIED - check config!");
#endif

3
src/fdrs_debug.h
Unescape Escape View File

@ -1,4 +1,3 @@
#ifdef FDRS_DEBUG
#ifdef USE_OLED
#define DBG(a) debug_OLED(String(a)); \
@ -12,4 +11,4 @@ Serial.println(a);
#else
#define DBG(a)
#endif
#endif
#endif

49
src/fdrs_gateway.h
Unescape Escape View File

@ -45,17 +45,39 @@ uint8_t newCmd = cmd_clear;
DataReading fdrsData[256]; // buffer for loadFDRS()
uint8_t data_count = 0;
#include "fdrs_oled.h"
// Function Prototypes needed due to #ifdefs being moved outside of function definitions in header files
void broadcastLoRa();
void sendLoRaNbr(uint8_t);
void timeFDRSLoRa(uint8_t *);
static uint16_t crc16_update(uint16_t, uint8_t);
void sendESPNowNbr(uint8_t);
void sendESPNowPeers();
void sendMQTT();
void sendLog();
void resendLog();
void releaseLogBuffer();
#ifdef USE_OLED
#include "fdrs_oled.h"
#endif
#include "fdrs_debug.h"
#include "fdrs_gateway_espnow.h"
#include "fdrs_gateway_lora.h"
#include "fdrs_gateway_wifi.h"
#include "fdrs_gateway_filesystem.h"
#include "fdrs_gateway_mqtt.h"
#include "fdrs_gateway_serial.h"
#include "fdrs_gateway_scheduler.h"
#ifdef USE_ESPNOW
#include "fdrs_gateway_espnow.h"
#endif
#ifdef USE_LORA
#include "fdrs_gateway_lora.h"
#endif
#ifdef USE_WIFI
#include "fdrs_gateway_wifi.h"
#include "fdrs_gateway_mqtt.h"
#endif
#if defined(USE_FS_LOG) || defined(USE_SD_LOG)
#include "fdrs_gateway_filesystem.h"
#endif
#ifdef DEBUG_CONFIG
#include "fdrs_checkConfig.h"
#include "fdrs_checkConfig.h"
#endif
void sendFDRS()
@ -193,3 +215,16 @@ void loopFDRS()
}
}
// "Skeleton Functions related to FDRS Actions"
#ifndef USE_LORA
void broadcastLoRa() {}
void sendLoRaNbr(uint8_t address) {}
void timeFDRSLoRa(uint8_t *address) {}
#endif
#ifndef USE_ESPNOW
void sendESPNowNbr(uint8_t interface) {}
void sendESPNowPeers() {}
#endif
#ifndef USE_WIFI
void sendMQTT() {}
#endif

128
src/fdrs_gateway_espnow.h
Unescape Escape View File

@ -15,7 +15,7 @@ const uint8_t espnow_size = 250 / sizeof(DataReading);
esp_now_peer_info_t peerInfo;
#endif
uint8_t broadcast_mac[] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
const uint8_t broadcast_mac[] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
const uint8_t mac_prefix[] = {MAC_PREFIX};
uint8_t selfAddress[] = {MAC_PREFIX, UNIT_MAC};
@ -24,7 +24,7 @@ uint8_t incMAC[6];
uint8_t ESPNOW1[] = {MAC_PREFIX, ESPNOW_NEIGHBOR_1};
uint8_t ESPNOW2[] = {MAC_PREFIX, ESPNOW_NEIGHBOR_2};
#ifdef USE_ESPNOW
// Set ESP-NOW send and receive callbacks for either ESP8266 or ESP32
#if defined(ESP8266)
void OnDataSent(uint8_t *mac_addr, uint8_t sendStatus)
@ -62,11 +62,9 @@ void OnDataRecv(const uint8_t *mac, const uint8_t *incomingData, int len)
}
newData = event_espnowg;
}
#endif // USE_ESPNOW
void begin_espnow()
{
#ifdef USE_ESPNOW
DBG("Initializing ESP-NOW!");
WiFi.mode(WIFI_STA);
WiFi.disconnect();
@ -110,11 +108,8 @@ void begin_espnow()
}
#endif // ESP8266
DBG(" ESP-NOW Initialized.");
#endif // USE_ESPNOW
}
#ifdef USE_ESPNOW
// Returns an expired entry in peer_list, -1 if full.
int find_espnow_peer()
{
@ -228,86 +223,81 @@ void pingback_espnow()
esp_now_send(incMAC, (uint8_t *)&sys_packet, sizeof(SystemPacket));
}
}
#endif // USE_ESPNOW
void sendESPNowNbr(uint8_t interface)
{
#ifdef USE_ESPNOW
switch (interface)
{
case 1:
{ // These brackets are required!
DBG("Sending to ESP-NOW Neighbor #1");
case 1:
{ // These brackets are required!
DBG("Sending to ESP-NOW Neighbor #1");
#if defined(ESP32)
esp_now_peer_info_t peerInfo;
peerInfo.ifidx = WIFI_IF_STA;
peerInfo.channel = 0;
peerInfo.encrypt = false;
memcpy(peerInfo.peer_addr, ESPNOW1, 6);
if (esp_now_add_peer(&peerInfo) != ESP_OK)
{
DBG("Failed to add peer");
return;
}
esp_now_peer_info_t peerInfo;
peerInfo.ifidx = WIFI_IF_STA;
peerInfo.channel = 0;
peerInfo.encrypt = false;
memcpy(peerInfo.peer_addr, ESPNOW1, 6);
if (esp_now_add_peer(&peerInfo) != ESP_OK)
{
DBG("Failed to add peer");
return;
}
#endif // ESP32
DataReading thePacket[ln];
int j = 0;
DataReading thePacket[ln];
int j = 0;
for (int i = 0; i < ln; i++)
{
if (j > espnow_size)
for (int i = 0; i < ln; i++)
{
j = 0;
esp_now_send(ESPNOW1, (uint8_t *)&thePacket, sizeof(thePacket));
if (j > espnow_size)
{
j = 0;
esp_now_send(ESPNOW1, (uint8_t *)&thePacket, sizeof(thePacket));
}
thePacket[j] = theData[i];
j++;
}
thePacket[j] = theData[i];
j++;
}
esp_now_send(ESPNOW1, (uint8_t *)&thePacket, j * sizeof(DataReading));
esp_now_del_peer(ESPNOW1);
esp_now_send(ESPNOW1, (uint8_t *)&thePacket, j * sizeof(DataReading));
esp_now_del_peer(ESPNOW1);
break;
} // These brackets are required!
case 2:
{
DBG("Sending to ESP-NOW Neighbor #2");
#if defined(ESP32)
esp_now_peer_info_t peerInfo;
peerInfo.ifidx = WIFI_IF_STA;
peerInfo.channel = 0;
peerInfo.encrypt = false;
memcpy(peerInfo.peer_addr, ESPNOW2, 6);
if (esp_now_add_peer(&peerInfo) != ESP_OK)
break;
} // These brackets are required!
case 2:
{
DBG("Failed to add peer");
return;
}
DBG("Sending to ESP-NOW Neighbor #2");
#if defined(ESP32)
esp_now_peer_info_t peerInfo;
peerInfo.ifidx = WIFI_IF_STA;
peerInfo.channel = 0;
peerInfo.encrypt = false;
memcpy(peerInfo.peer_addr, ESPNOW2, 6);
if (esp_now_add_peer(&peerInfo) != ESP_OK)
{
DBG("Failed to add peer");
return;
}
#endif // ESP32
DataReading thePacket[ln];
int j = 0;
for (int i = 0; i < ln; i++)
{
if (j > espnow_size)
DataReading thePacket[ln];
int j = 0;
for (int i = 0; i < ln; i++)
{
j = 0;
esp_now_send(ESPNOW2, (uint8_t *)&thePacket, sizeof(thePacket));
if (j > espnow_size)
{
j = 0;
esp_now_send(ESPNOW2, (uint8_t *)&thePacket, sizeof(thePacket));
}
thePacket[j] = theData[i];
j++;
}
thePacket[j] = theData[i];
j++;
}
esp_now_send(ESPNOW2, (uint8_t *)&thePacket, j * sizeof(DataReading));
esp_now_del_peer(ESPNOW2);
esp_now_send(ESPNOW2, (uint8_t *)&thePacket, j * sizeof(DataReading));
esp_now_del_peer(ESPNOW2);
break;
}
break;
}
}
#endif // USE_ESPNOW
}
void sendESPNowPeers()
{
#ifdef USE_ESPNOW
DBG("Sending to ESP-NOW peers.");
DataReading thePacket[ln];
int j = 0;
@ -322,12 +312,10 @@ void sendESPNowPeers()
j++;
}
esp_now_send(0, (uint8_t *)&thePacket, j * sizeof(DataReading));
#endif // USE_ESPNOW
}
void sendESPNow(uint8_t address)
{
#ifdef USE_ESPNOW
DBG("Sending ESP-NOW.");
uint8_t temp_peer[] = {MAC_PREFIX, address};
#if defined(ESP32)
@ -358,6 +346,4 @@ void sendESPNow(uint8_t address)
esp_now_send(temp_peer, (uint8_t *)&thePacket, j * sizeof(DataReading));
esp_now_del_peer(temp_peer);
#endif // USE_ESPNOW
}
}

77
src/fdrs_gateway_filesystem.h
Unescape Escape View File

@ -1,5 +1,4 @@
#ifdef USE_SD_LOG
#include <SPI.h>
#include <SD.h>
@ -7,28 +6,18 @@
#ifdef USE_FS_LOG
#include <LittleFS.h>
#endif
#if defined(USE_SD_LOG) || defined(USE_FS_LOG)
#include <time.h>
#endif
#if defined(USE_SD_LOG) || defined(USE_FS_LOG)
#define SD_MAX_FILESIZE 1024
#define FS_MAX_FILESIZE 1024
char logBuffer[512];
uint16_t logBufferPos = 0; // datatype depends on size of sdBuffer
uint32_t timeLOGBUF = 0;
time_t last_mqtt_success = 0;
time_t last_log_write = 0;
void handleLogger()
{
if ((millis() - timeLOGBUF) >= LOGBUF_DELAY)
{
timeLOGBUF = millis();
if (logBufferPos > 0)
releaseLogBuffer();
}
}
#endif
#if defined(USE_SD_LOG) || defined(USE_FS_LOG)
void releaseLogBuffer()
{
#ifdef USE_SD_LOG
@ -42,7 +31,7 @@ void releaseLogBuffer()
#endif
#ifdef USE_FS_LOG
DBG("Releasing Log buffer to internal flash.");
File logfile = LittleFS.open(FS_FILENAME, "a");
File logfile = LittleFS.open(LOG_FILENAME, "a");
if ((logfile.size() / 1024.0) < FS_MAX_FILESIZE)
{
logfile.print(logBuffer);
@ -52,7 +41,48 @@ void releaseLogBuffer()
memset(&(logBuffer[0]), 0, sizeof(logBuffer) / sizeof(char));
logBufferPos = 0;
}
#endif // USE_XX_LOG
void handleLogger()
{
if ((millis() - timeLOGBUF) >= LOGBUF_DELAY)
{
timeLOGBUF = millis();
if (logBufferPos > 0)
releaseLogBuffer();
}
}
#ifndef USE_LORA
// crc16_update used by both LoRa and filesystem
// CRC16 from https://github.com/4-20ma/ModbusMaster/blob/3a05ff87677a9bdd8e027d6906dc05ca15ca8ade/src/util/crc16.h#L71
/** @ingroup util_crc16
Processor-independent CRC-16 calculation.
Polynomial: x^16 + x^15 + x^2 + 1 (0xA001)<br>
Initial value: 0xFFFF
This CRC is normally used in disk-drive controllers.
@param uint16_t crc (0x0000..0xFFFF)
@param uint8_t a (0x00..0xFF)
@return calculated CRC (0x0000..0xFFFF)
*/
static uint16_t crc16_update(uint16_t crc, uint8_t a)
{
int i;
crc ^= a;
for (i = 0; i < 8; ++i)
{
if (crc & 1)
crc = (crc >> 1) ^ 0xA001;
else
crc = (crc >> 1);
}
return crc;
}
#endif
uint16_t stringCrc(const char input[])
{
@ -67,7 +97,6 @@ uint16_t stringCrc(const char input[])
void sendLog()
{
#if defined(USE_SD_LOG) || defined(USE_FS_LOG)
DBG("Logging to buffer");
for (int i = 0; i < ln; i++)
{
@ -88,12 +117,12 @@ void sendLog()
logBufferPos += outgoingString.length();
}
time(&last_log_write);
#endif // USE_xx_LOG
}
// Send loged values to MQTT so we depend upon network and MQTT
void resendLog()
{
#ifdef USE_SD_LOG
#if defined(USE_SD_LOG) && defined(USE_WIFI)
DBG("Resending logged values from SD card.");
File logfile = SD.open(LOG_FILENAME, FILE_READ);
while (1)
@ -119,9 +148,9 @@ void resendLog()
}
DBG(" Done");
#endif
#ifdef USE_FS_LOG
#if defined(USE_FS_LOG) && defined(USE_WIFI)
DBG("Resending logged values from internal flash.");
File logfile = LittleFS.open(FS_FILENAME, "r");
File logfile = LittleFS.open(LOG_FILENAME, "r");
while (1)
{
String line = logfile.readStringUntil('\n');
@ -146,7 +175,7 @@ void resendLog()
else
{
logfile.close();
LittleFS.remove(FS_FILENAME); // if all values are sent
LittleFS.remove(LOG_FILENAME); // if all values are sent
break;
}
}

54
src/fdrs_gateway_lora.h
Unescape Escape View File

@ -1,4 +1,3 @@
#ifdef USE_LORA
#include <RadioLib.h>
#define GLOBAL_ACK_TIMEOUT 400 // LoRa ACK timeout in ms. (Minimum = 200)
@ -84,6 +83,11 @@ RADIOLIB_MODULE radio = new Module(LORA_SS, LORA_DIO, LORA_RST, -1, LORA_SPI);
RADIOLIB_MODULE radio = new Module(LORA_SS, LORA_DIO, LORA_RST, -1);
#endif // CUSTOM_SPI
#ifndef USE_ESPNOW // mac_prefix used for both ESP-NOW and LoRa - avoid redefinition warnings
const uint8_t mac_prefix[] = {MAC_PREFIX};
const uint8_t selfAddress[] = {MAC_PREFIX, UNIT_MAC};
#endif
bool pingFlag = false;
bool transmitFlag = false; // flag to indicate transmission or reception state
volatile bool enableInterrupt = true; // disable interrupt when it's not needed
@ -118,13 +122,27 @@ uint8_t tx_buffer_position = 0;
uint32_t tx_start_time;
bool tx_time_set = false;
#endif // USE_LORA
// Function prototypes
crcResult transmitLoRa(uint16_t *, DataReading *, uint8_t);
crcResult transmitLoRa(uint16_t *, SystemPacket *, uint8_t);
static uint16_t crc16_update(uint16_t, uint8_t);
#if defined(ESP8266) || defined(ESP32)
ICACHE_RAM_ATTR
#endif
void setFlag(void)
{
// check if the interrupt is enabled
if (!enableInterrupt)
{
return;
}
// we sent or received packet, set the flag
operationDone = true;
}
// crc16_update used by both LoRa and filesystem
// CRC16 from https://github.com/4-20ma/ModbusMaster/blob/3a05ff87677a9bdd8e027d6906dc05ca15ca8ade/src/util/crc16.h#L71
/** @ingroup util_crc16
@ -152,21 +170,6 @@ static uint16_t crc16_update(uint16_t crc, uint8_t a)
return crc;
}
#ifdef USE_LORA
#if defined(ESP8266) || defined(ESP32)
ICACHE_RAM_ATTR
#endif
void setFlag(void)
{
// check if the interrupt is enabled
if (!enableInterrupt)
{
return;
}
// we sent or received packet, set the flag
operationDone = true;
}
crcResult transmitLoRa(uint16_t *destMac, DataReading *packet, uint8_t len)
{
@ -242,7 +245,6 @@ crcResult transmitLoRa(uint16_t *destMac, SystemPacket *packet, uint8_t len)
}
return crcReturned;
}
#endif // USE_LORA
void printLoraPacket(uint8_t *p, int size)
{
@ -256,7 +258,6 @@ void printLoraPacket(uint8_t *p, int size)
printf("\n");
}
#ifdef USE_LORA
void begin_lora()
{
#ifdef CUSTOM_SPI
@ -299,11 +300,9 @@ void begin_lora()
;
}
}
#endif // USE_LORA
crcResult getLoRa()
{
#ifdef USE_LORA
int packetSize = radio.getPacketLength();
if ((((packetSize - 6) % sizeof(DataReading) == 0) || ((packetSize - 6) % sizeof(SystemPacket) == 0)) && packetSize > 0)
@ -463,14 +462,12 @@ crcResult getLoRa()
return CRC_NULL;
}
}
#endif // USE_LORA
return CRC_NULL;
}
// Sends packet to any node that is paired to this gateway
void broadcastLoRa()
{
#ifdef USE_LORA
DBG("Sending to LoRa broadcast buffer");
for (int i = 0; i < ln; i++)
@ -478,14 +475,11 @@ void broadcastLoRa()
LORABBuffer.buffer[LORABBuffer.len + i] = theData[i];
}
LORABBuffer.len += ln;
#endif // USE_LORA
}
// Sends packet to neighbor gateways
void sendLoRaNbr(uint8_t interface)
{
#ifdef USE_LORA
DBG("Sending to LoRa neighbor buffer");
switch (interface)
{
@ -508,9 +502,7 @@ void sendLoRaNbr(uint8_t interface)
break;
}
}
#endif // USE_LORA
}
#ifdef USE_LORA
void asyncReleaseLoRa(bool first_run)
{
@ -596,6 +588,7 @@ void asyncReleaseLoRa(bool first_run)
}
}
}
void asyncReleaseLoRaFirst()
{
asyncReleaseLoRa(true);
@ -638,5 +631,4 @@ crcResult handleLoRa()
}
}
return crcReturned;
}
#endif // USE_LORA
}

14
src/fdrs_gateway_mqtt.h
Unescape Escape View File

@ -1,4 +1,3 @@
#ifdef USE_WIFI
#include <PubSubClient.h>
#include <ArduinoJson.h>
@ -41,11 +40,17 @@
#define FDRS_MQTT_AUTH
#endif // MQTT_AUTH
WiFiClient espClient;
PubSubClient client(espClient);
const char *mqtt_server = FDRS_MQTT_ADDR;
const int mqtt_port = FDRS_MQTT_PORT;
#if defined(USE_SD_LOG) || defined(USE_FS_LOG)
extern time_t last_log_write;
extern time_t last_mqtt_success;
#endif
#ifdef FDRS_MQTT_AUTH
const char *mqtt_user = FDRS_MQTT_USER;
@ -152,7 +157,9 @@ void mqtt_publish(const char *payload)
if (!client.publish(TOPIC_DATA, payload))
{
DBG(" Error on sending MQTT");
#if defined(USE_SD_LOG) || defined(USE_FS_LOG)
sendLog();
#endif
}
else
{
@ -166,11 +173,9 @@ void mqtt_publish(const char *payload)
#endif
}
}
#endif // USE_WIFI
void sendMQTT()
{
#ifdef USE_WIFI
DBG("Sending MQTT.");
DynamicJsonDocument doc(24576);
for (int i = 0; i < ln; i++)
@ -183,5 +188,4 @@ void sendMQTT()
String outgoingString;
serializeJson(doc, outgoingString);
mqtt_publish((char *)outgoingString.c_str());
#endif // USE_WIFI
}
}

4
src/fdrs_gateway_wifi.h
Unescape Escape View File

@ -4,7 +4,6 @@
#endif
#endif // USE_ETHERNET
#ifdef USE_WIFI
#include <WiFiUdp.h>
#ifdef ESP8266
#include <ESP8266WiFi.h>
@ -96,5 +95,4 @@ void begin_wifi()
delay(500);
}
#endif // USE_ETHERNET
}
#endif // USE_WIFI
}

3
src/fdrs_globals.h
Unescape Escape View File

@ -17,7 +17,8 @@
// MQTT Topics
#define TOPIC_DATA "fdrs/data"
#define TOPIC_STATUS "fdrs/status"
#define TOPIC_COMMAND "fdrs/command"
#define TOPIC_COMMAND "fdrs/command"
#define TOPIC_DATA_BACKLOG "fdrs/databacklog" // Used in filesystem module
#define GLOBAL_LORA_FREQUENCY 915.0 // Carrier frequency in MHz. Allowed values range from 137.0 MHz to 1020.0 MHz (varies by chip).
#define GLOBAL_LORA_SF 7 // LoRa link spreading factor. Allowed values range from 6 to 12.

23
src/fdrs_node.h
Unescape Escape View File

@ -36,10 +36,6 @@ static uint16_t crc16_update(uint16_t crc, uint8_t a)
return crc;
}
#ifdef DEBUG_CONFIG
// #include "fdrs_checkConfig.h"
#endif
SystemPacket theCmd;
DataReading theData[256];
uint8_t ln;
@ -60,10 +56,19 @@ void (*callback_ptr)(DataReading);
uint16_t subscription_list[256] = {};
bool active_subs[256] = {};
#include "fdrs_oled.h"
#include "fdrs_debug.h"
#include "fdrs_node_espnow.h"
#include "fdrs_node_lora.h"
#ifdef DEBUG_CONFIG
// #include "fdrs_checkConfig.h"
#endif
#ifdef USE_OLED
#include "fdrs_oled.h"
#endif
#ifdef USE_ESPNOW
#include "fdrs_node_espnow.h"
#endif
#ifdef USE_LORA
#include "fdrs_node_lora.h"
#endif
void beginFDRS()
{
@ -139,7 +144,9 @@ void beginFDRS()
#endif
DBG(" ESP-NOW Initialized.");
#endif // USE_ESPNOW
#ifdef USE_LORA
begin_lora();
#endif
#ifdef DEBUG_CONFIG
// if (resetReason != ESP_RST_DEEPSLEEP) {
// checkConfig();
@ -260,7 +267,9 @@ void sleepFDRS(int sleep_time)
void loopFDRS()
{
#ifdef USE_LORA
handleLoRa();
#endif
handleIncoming();
// // TO-DO:
// if (is_added)

17
src/fdrs_node_espnow.h
Unescape Escape View File

@ -1,18 +1,15 @@
#if defined(ESP8266)
#include <ESP8266WiFi.h>
#include <espnow.h>
#include <ESP8266WiFi.h>
#include <espnow.h>
#elif defined(ESP32)
#include <esp_now.h>
#include <WiFi.h>
#include <esp_wifi.h>
#include <esp_now.h>
#include <WiFi.h>
#include <esp_wifi.h>
#endif
uint8_t broadcast_mac[] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
crcResult esp_now_ack_flag;
bool is_added = false;
#ifdef USE_ESPNOW
bool pingFlag = false;
// Set ESP-NOW send and receive callbacks for either ESP8266 or ESP32
@ -89,6 +86,4 @@ uint32_t pingFDRSEspNow(uint8_t *address, uint32_t timeout) {
}
DBG("No ESP-NOW ping returned within " + String(timeout) + "ms.");
return UINT32_MAX;
}
#endif // USE_ESPNOW
}

18
src/fdrs_node_lora.h
Unescape Escape View File

@ -1,7 +1,6 @@
#ifdef USE_LORA
#include <ArduinoUniqueID.h>
#include <RadioLib.h>
#endif
// Internal Globals
// Default values: overridden by settings in config, if present
@ -10,7 +9,6 @@
#define GLOBAL_LORA_RETRIES 2 // LoRa ACK automatic retries [0 - 3]
#define GLOBAL_LORA_TXPWR 17 // LoRa TX power in dBm (: +2dBm - +17dBm (for SX1276-7) +20dBm (for SX1278))
#ifdef USE_LORA
// select LoRa band configuration
#if defined(LORA_FREQUENCY)
#define FDRS_LORA_FREQUENCY LORA_FREQUENCY
@ -111,11 +109,9 @@ void setFlag(void)
}
operationDone = true; // we sent or received packet, set the flag
}
#endif // USE_LORA
crcResult handleLoRa()
{
#ifdef USE_LORA
crcResult crcReturned = CRC_NULL;
if (operationDone)
{ // the interrupt was triggered
@ -138,14 +134,11 @@ crcResult handleLoRa()
enableInterrupt = true;
}
}
#endif // USE_LORA
return crcReturned;
}
void begin_lora()
{
#ifdef USE_LORA
#ifdef CUSTOM_SPI
#ifdef ESP32
LORA_SPI.begin(LORA_SPI_SCK, LORA_SPI_MISO, LORA_SPI_MOSI);
@ -187,7 +180,6 @@ void begin_lora()
while (true)
;
}
#endif // USE_LORA
}
// Transmits Lora data by calling RadioLib library function
@ -195,7 +187,6 @@ void begin_lora()
crcResult transmitLoRa(uint16_t *destMAC, DataReading *packet, uint8_t len)
{
#ifdef USE_LORA
crcResult crcReturned = CRC_NULL;
uint8_t pkt[6 + (len * sizeof(DataReading))];
uint16_t calcCRC = 0x0000;
@ -280,7 +271,6 @@ crcResult transmitLoRa(uint16_t *destMAC, DataReading *packet, uint8_t len)
}
transmitLoRaMsgwAck++;
#endif // LORA_ACK
#endif // USE_LORA
return crcReturned;
}
@ -288,7 +278,6 @@ crcResult transmitLoRa(uint16_t *destMAC, DataReading *packet, uint8_t len)
// Returns CRC_NULL ask SystemPackets do not use ACKS at current time
crcResult transmitLoRa(uint16_t *destMAC, SystemPacket *packet, uint8_t len)
{
#ifdef USE_LORA
crcResult crcReturned = CRC_NULL;
uint8_t pkt[6 + (len * sizeof(SystemPacket))];
uint16_t calcCRC = 0x0000;
@ -325,7 +314,6 @@ crcResult transmitLoRa(uint16_t *destMAC, SystemPacket *packet, uint8_t len)
while (true)
;
}
#endif // USE_LORA
return crcReturned;
}
@ -336,7 +324,6 @@ crcResult transmitLoRa(uint16_t *destMAC, SystemPacket *packet, uint8_t len)
crcResult getLoRa()
{
#ifdef USE_LORA
int packetSize = radio.getPacketLength();
if ((((packetSize - 6) % sizeof(DataReading) == 0) || ((packetSize - 6) % sizeof(SystemPacket) == 0)) && packetSize > 0)
{ // packet size should be 6 bytes plus multiple of size of DataReading
@ -484,7 +471,6 @@ crcResult getLoRa()
return CRC_NULL;
}
}
#endif // USE_LORA
return CRC_NULL;
}
@ -493,7 +479,6 @@ crcResult getLoRa()
// Returns the amount of time in ms that the ping takes or predefined value if ping fails within timeout
uint32_t pingFDRSLoRa(uint16_t *address, uint32_t timeout)
{
#ifdef USE_LORA
SystemPacket sys_packet = {.cmd = cmd_ping, .param = 0};
transmitLoRa(address, &sys_packet, 1);
@ -512,7 +497,6 @@ uint32_t pingFDRSLoRa(uint16_t *address, uint32_t timeout)
}
}
DBG("No LoRa ping returned within " + String(timeout) + "ms.");
#endif // USE_LORA
return UINT32_MAX;
}

5
src/fdrs_oled.h
Unescape Escape View File

@ -1,5 +1,5 @@
#ifdef USE_OLED
#include <ESP8266_and_ESP32_OLED_driver_for_SSD1306_displays/src/SSD1306Wire.h>
String debug_buffer[5] = {"", "", "", "", ""};
@ -68,5 +68,4 @@ void init_oled(){
draw_OLED_header();
}
#endif
}
Write Preview
Loading…
Cancel
Save