airgradienthq/arduino
1
0
Fork 1
mirror of https://github.com/airgradienthq/arduino.git synced 2025-07-28 16:07:16 +02:00
Code Issues Packages Projects Releases Wiki Activity

Handle reconnection when network option is cellular

Browse Source
This commit is contained in:
samuelbles07
2025-03-16 22:47:21 +07:00
parent b5c67cb0b1
commit bf09b746c7
2 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
examples/OneOpenAir/OneOpenAir.ino
View File

@ -1383,21 +1383,31 @@ int calculateMaxPeriod(int updateInterval) {
}
void networkingTask(void *args) {
// TODO: Need to better define delay value
// Reset scheduler
configSchedule.update();
transmissionSchedule.update();
while (1) {
// Handle reconnection based on mode
if (networkOption == UseWifi) {
wifiConnector.handle();
if (wifiConnector.isConnected() == false) {
// NOTE: If not connect while mode is not offline, skip the rest of code
delay(1000);
continue;
}
}
else if (networkOption == UseCellular) {
/// Handle reconnection cellular here
/// If failed fetch config or transmission it is an indication that the module might have a problem
/// cellular-client or the cell module it self need an inteface for last operation success or not
/// For example, httpGet() failed, then there's a state like isLastOperationSuccess
// Check if last fetch config and post measures failed
// It can be an indication that module has a problem
if (agClient->isLastFetchConfigSucceed() == false ||
agClient->isLastPostMeasureSucceed() == false) {
if (agClient->ensureClientConnection() == false) {
Serial.println("Cellular client connection not ready, retry in 5s...");
delay(5000);
continue;
}
}
}
// If connection to AirGradient server disable don't run config and transmission schedule
@ -1418,7 +1428,6 @@ void networkingTask(void *args) {
void newMeasurementCycle() {
// TODO: Need to check max queue
// NOTE: Maybe define acquire mutex timeout
if (xSemaphoreTake(mutexMeasurementCycleQueue, portMAX_DELAY) == pdTRUE) {
Measurements::MeasurementCycle mc = measurements.getMeasurementCycle();
mc.wifi = wifiConnector.RSSI();