You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
152 lines
4.0 KiB
152 lines
4.0 KiB
/*
|
|
|
|
SYSTEM MODULE
|
|
|
|
Copyright (C) 2018 by Xose Pérez <xose dot perez at gmail dot com>
|
|
|
|
Module key prefix: esp (shared with others)
|
|
|
|
*/
|
|
|
|
#include <EEPROM_Rotate.h>
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
unsigned long _loop_delay = 0;
|
|
bool _system_send_heartbeat = false;
|
|
|
|
// Calculated load average 0 to 100;
|
|
unsigned short int _load_average = 100;
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
#if SYSTEM_CHECK_ENABLED
|
|
|
|
// Call this method on boot with start=true to increase the crash counter
|
|
// Call it again once the system is stable to decrease the counter
|
|
// If the counter reaches SYSTEM_CHECK_MAX then the system is flagged as unstable
|
|
// setting _systemOK = false;
|
|
//
|
|
// An unstable system will only have serial access, WiFi in AP mode and OTA
|
|
|
|
bool _systemStable = true;
|
|
|
|
void systemCheck(bool stable) {
|
|
unsigned char value = EEPROMr.read(EEPROM_CRASH_COUNTER);
|
|
if (stable) {
|
|
value = 0;
|
|
DEBUG_MSG_P(PSTR("[MAIN] System OK\n"));
|
|
} else {
|
|
if (++value > SYSTEM_CHECK_MAX) {
|
|
_systemStable = false;
|
|
value = 0;
|
|
DEBUG_MSG_P(PSTR("[MAIN] System UNSTABLE\n"));
|
|
}
|
|
}
|
|
EEPROMr.write(EEPROM_CRASH_COUNTER, value);
|
|
EEPROMr.commit();
|
|
}
|
|
|
|
bool systemCheck() {
|
|
return _systemStable;
|
|
}
|
|
|
|
void systemCheckLoop() {
|
|
static bool checked = false;
|
|
if (!checked && (millis() > SYSTEM_CHECK_TIME)) {
|
|
// Check system as stable
|
|
systemCheck(true);
|
|
checked = true;
|
|
}
|
|
}
|
|
|
|
#endif //SYSTEM_CHECK_ENABLED
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
void systemSendHeartbeat() {
|
|
_system_send_heartbeat = true;
|
|
}
|
|
|
|
unsigned long systemLoopDelay() {
|
|
return _loop_delay;
|
|
}
|
|
|
|
unsigned long systemLoadAverage() {
|
|
return _load_average;
|
|
}
|
|
|
|
void systemLoop() {
|
|
|
|
// -------------------------------------------------------------------------
|
|
// Check system stability
|
|
// -------------------------------------------------------------------------
|
|
|
|
#if SYSTEM_CHECK_ENABLED
|
|
systemCheckLoop();
|
|
#endif
|
|
|
|
// -------------------------------------------------------------------------
|
|
// Heartbeat
|
|
// -------------------------------------------------------------------------
|
|
|
|
#if HEARTBEAT_ENABLED
|
|
// Heartbeat
|
|
static unsigned long last_hbeat = 0;
|
|
if (_system_send_heartbeat || (last_hbeat == 0) || (millis() - last_hbeat > HEARTBEAT_INTERVAL)) {
|
|
_system_send_heartbeat = false;
|
|
last_hbeat = millis();
|
|
heartbeat();
|
|
}
|
|
#endif // HEARTBEAT_ENABLED
|
|
|
|
// -------------------------------------------------------------------------
|
|
// Load Average calculation
|
|
// -------------------------------------------------------------------------
|
|
|
|
static unsigned long last_loadcheck = 0;
|
|
static unsigned long load_counter_temp = 0;
|
|
load_counter_temp++;
|
|
|
|
if (millis() - last_loadcheck > LOADAVG_INTERVAL) {
|
|
|
|
static unsigned long load_counter = 0;
|
|
static unsigned long load_counter_max = 1;
|
|
|
|
load_counter = load_counter_temp;
|
|
load_counter_temp = 0;
|
|
if (load_counter > load_counter_max) {
|
|
load_counter_max = load_counter;
|
|
}
|
|
_load_average = 100 - (100 * load_counter / load_counter_max);
|
|
last_loadcheck = millis();
|
|
|
|
}
|
|
|
|
// -------------------------------------------------------------------------
|
|
// Power saving delay
|
|
// -------------------------------------------------------------------------
|
|
|
|
delay(_loop_delay);
|
|
|
|
}
|
|
|
|
void systemSetup() {
|
|
|
|
#if SPIFFS_SUPPORT
|
|
SPIFFS.begin();
|
|
#endif
|
|
|
|
// Question system stability
|
|
#if SYSTEM_CHECK_ENABLED
|
|
systemCheck(false);
|
|
#endif
|
|
|
|
// Cache loop delay value to speed things (recommended max 250ms)
|
|
_loop_delay = atol(getSetting("loopDelay", LOOP_DELAY_TIME).c_str());
|
|
_loop_delay = constrain(_loop_delay, 0, 300);
|
|
|
|
// Register Loop
|
|
espurnaRegisterLoop(systemLoop);
|
|
|
|
}
|