|
@ -10,7 +10,7 @@ Copyright (C) 2018 by Xose Pérez <xose dot perez at gmail dot com> |
|
|
|
|
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
unsigned long _loopDelay = 0; |
|
|
|
|
|
|
|
|
unsigned long _loop_delay = 0; |
|
|
bool _system_send_heartbeat = false; |
|
|
bool _system_send_heartbeat = false; |
|
|
|
|
|
|
|
|
// Calculated load average 0 to 100;
|
|
|
// Calculated load average 0 to 100;
|
|
@ -66,13 +66,24 @@ void systemSendHeartbeat() { |
|
|
_system_send_heartbeat = true; |
|
|
_system_send_heartbeat = true; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
unsigned long systemLoopDelay() { |
|
|
|
|
|
return _loop_delay; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
void systemLoop() { |
|
|
void systemLoop() { |
|
|
|
|
|
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
// Check system stability
|
|
|
// Check system stability
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
#if SYSTEM_CHECK_ENABLED
|
|
|
#if SYSTEM_CHECK_ENABLED
|
|
|
systemCheckLoop(); |
|
|
systemCheckLoop(); |
|
|
#endif
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
|
|
|
// Heartbeat
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
#if HEARTBEAT_ENABLED
|
|
|
#if HEARTBEAT_ENABLED
|
|
|
// Heartbeat
|
|
|
// Heartbeat
|
|
|
static unsigned long last_hbeat = 0; |
|
|
static unsigned long last_hbeat = 0; |
|
@ -83,26 +94,33 @@ void systemLoop() { |
|
|
} |
|
|
} |
|
|
#endif // HEARTBEAT_ENABLED
|
|
|
#endif // HEARTBEAT_ENABLED
|
|
|
|
|
|
|
|
|
// Increase temporary loop counter
|
|
|
|
|
|
static unsigned long load_counter_temp = 0; |
|
|
|
|
|
static unsigned long last_loadcheck = 0; |
|
|
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
|
|
|
// Load Average calculation
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
|
|
static unsigned long last_loadcheck = 0; |
|
|
|
|
|
static unsigned long load_counter_temp = 0; |
|
|
|
|
|
static unsigned long load_counter = 0; |
|
|
|
|
|
static unsigned long load_counter_max = 1; |
|
|
load_counter_temp++; |
|
|
load_counter_temp++; |
|
|
|
|
|
|
|
|
if (millis() - last_loadcheck > LOADAVG_INTERVAL) { |
|
|
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(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
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
|
|
|
// Power saving delay
|
|
|
delay(_loopDelay); |
|
|
|
|
|
|
|
|
// -------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
|
|
delay(_loop_delay); |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -135,7 +153,8 @@ void systemSetup() { |
|
|
#endif
|
|
|
#endif
|
|
|
|
|
|
|
|
|
// Cache loop delay value to speed things (recommended max 250ms)
|
|
|
// Cache loop delay value to speed things (recommended max 250ms)
|
|
|
_loopDelay = atol(getSetting("loopDelay", LOOP_DELAY_TIME).c_str()); |
|
|
|
|
|
|
|
|
_loop_delay = atol(getSetting("loopDelay", LOOP_DELAY_TIME).c_str()); |
|
|
|
|
|
_loop_delay = constrain(_loop_delay, 0, 300); |
|
|
|
|
|
|
|
|
// Register Loop
|
|
|
// Register Loop
|
|
|
espurnaRegisterLoop(systemLoop); |
|
|
espurnaRegisterLoop(systemLoop); |
|
@ -143,5 +162,5 @@ void systemSetup() { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
unsigned long getLoadAverage() { |
|
|
unsigned long getLoadAverage() { |
|
|
return _load_average; |
|
|
|
|
|
|
|
|
return _load_average; |
|
|
} |
|
|
} |