Ben MeadorsandGitHub
99abfebc4a
* Fix TransmitHistory to improve epoch handling * Enable epoch handling in unit tests * Improve comments and test handling for epoch persistence in TransmitHistory * Add boot-relative timestamp handling and unit tests for TransmitHistory * loadFromDisk should handle legacy entries and clean up old v1 files after migration * Revert "loadFromDisk should handle legacy entries and clean up old v1 files after migration" This reverts commit eb7e5c7acfa4ac077fe50980be752e4b42a739b8. * Add NodeInfoModule integration for RTC quality changes and trigger immediate checks * Update test conditions for RTC quality checks
36 lines
1.3 KiB
C++
36 lines
1.3 KiB
C++
#include "Throttle.h"
|
|
#include <Arduino.h>
|
|
|
|
/// @brief Execute a function throttled to a minimum interval
|
|
/// @param lastExecutionMs Pointer to the last execution time in milliseconds
|
|
/// @param minumumIntervalMs Minimum execution interval in milliseconds
|
|
/// @param throttleFunc Function to execute if the execution is not deferred
|
|
/// @param onDefer Default to NULL, execute the function if the execution is deferred
|
|
/// @return true if the function was executed, false if it was deferred
|
|
bool Throttle::execute(uint32_t *lastExecutionMs, uint32_t minumumIntervalMs, void (*throttleFunc)(void), void (*onDefer)(void))
|
|
{
|
|
if (*lastExecutionMs == 0) {
|
|
*lastExecutionMs = millis();
|
|
throttleFunc();
|
|
return true;
|
|
}
|
|
uint32_t now = millis();
|
|
|
|
if ((now - *lastExecutionMs) >= minumumIntervalMs) {
|
|
throttleFunc();
|
|
*lastExecutionMs = now;
|
|
return true;
|
|
} else if (onDefer != NULL) {
|
|
onDefer();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/// @brief Check if the last execution time is within the interval
|
|
/// @param lastExecutionMs The last execution time in milliseconds
|
|
/// @param timeSpanMs The interval in milliseconds of the timespan
|
|
bool Throttle::isWithinTimespanMs(uint32_t lastExecutionMs, uint32_t timeSpanMs)
|
|
{
|
|
uint32_t now = millis();
|
|
return (now - lastExecutionMs) < timeSpanMs;
|
|
} |