Fix sgp unreliable value by only pause task when performing ota

This commit is contained in:
samuelbles07
2025-04-12 02:25:04 +07:00
parent 81945a358e
commit 9bba89722e
2 changed files with 26 additions and 26 deletions

View File

@ -117,7 +117,7 @@ enum NetworkOption {
}; };
NetworkOption networkOption; NetworkOption networkOption;
TaskHandle_t handleNetworkTask = NULL; TaskHandle_t handleNetworkTask = NULL;
static bool otaInProgress = false; static bool firmwareUpdateInProgress = false;
static uint32_t factoryBtnPressTime = 0; static uint32_t factoryBtnPressTime = 0;
static AgFirmwareMode fwMode = FW_MODE_I_9PSL; static AgFirmwareMode fwMode = FW_MODE_I_9PSL;
@ -318,8 +318,8 @@ void loop() {
// Schedule to feed external watchdog // Schedule to feed external watchdog
watchdogFeedSchedule.run(); watchdogFeedSchedule.run();
if (otaInProgress) { if (firmwareUpdateInProgress) {
// OTA currently in progress, temporarily disable running sensor schedules // Firmare update currently in progress, temporarily disable running sensor schedules
delay(10000); delay(10000);
return; return;
} }
@ -562,28 +562,17 @@ void checkForFirmwareUpdate(void) {
agOta = new AirgradientOTACellular(cellularCard); agOta = new AirgradientOTACellular(cellularCard);
} }
// Indicate main task that ota is performing // Indicate main task that firmware update is in progress
Serial.println("Check for firmware update, disabling main task"); firmwareUpdateInProgress = true;
otaInProgress = true;
if (configuration.hasSensorSGP && networkOption == UseCellular) {
// Only for cellular because it can disturb i2c line
Serial.println("Disable SGP41 task for cellular OTA");
ag->sgp41.end();
}
agOta->setHandlerCallback(otaHandlerCallback); agOta->setHandlerCallback(otaHandlerCallback);
agOta->updateIfAvailable(ag->deviceId().c_str(), GIT_VERSION); agOta->updateIfAvailable(ag->deviceId().c_str(), GIT_VERSION);
// Only goes to this line if OTA is not success // Only goes to this line if firmware update is not success
// Handled by otaHandlerCallback // Handled by otaHandlerCallback
otaInProgress = false; // Indicate main task that firmware update finish
if (configuration.hasSensorSGP && networkOption == UseCellular) { firmwareUpdateInProgress = false;
// Re-start SGP41 task
if (!sgp41Init()) {
Serial.println("Failed re-start SGP41 task");
}
}
delete agOta; delete agOta;
Serial.println(); Serial.println();
@ -591,9 +580,15 @@ void checkForFirmwareUpdate(void) {
void otaHandlerCallback(AirgradientOTA::OtaResult result, const char *msg) { void otaHandlerCallback(AirgradientOTA::OtaResult result, const char *msg) {
switch (result) { switch (result) {
case AirgradientOTA::Starting: case AirgradientOTA::Starting: {
Serial.println("Firmware update starting...");
if (configuration.hasSensorSGP && networkOption == UseCellular) {
// Temporary pause SGP41 task while cellular firmware update is in progress
ag->sgp41.pauseHandle();
}
displayExecuteOta(result, fwNewVersion, 0); displayExecuteOta(result, fwNewVersion, 0);
break; break;
}
case AirgradientOTA::InProgress: case AirgradientOTA::InProgress:
Serial.printf("OTA progress: %s\n", msg); Serial.printf("OTA progress: %s\n", msg);
displayExecuteOta(result, "", std::stoi(msg)); displayExecuteOta(result, "", std::stoi(msg));
@ -602,6 +597,10 @@ void otaHandlerCallback(AirgradientOTA::OtaResult result, const char *msg) {
case AirgradientOTA::Skipped: case AirgradientOTA::Skipped:
case AirgradientOTA::AlreadyUpToDate: case AirgradientOTA::AlreadyUpToDate:
displayExecuteOta(result, "", 0); displayExecuteOta(result, "", 0);
if (configuration.hasSensorSGP && networkOption == UseCellular) {
// Cellular firmware update finish, resuming SGP41 task
ag->sgp41.resumeHandle();
}
break; break;
case AirgradientOTA::Success: case AirgradientOTA::Success:
displayExecuteOta(result, "", 0); displayExecuteOta(result, "", 0);
@ -665,7 +664,11 @@ static void displayExecuteOta(AirgradientOTA::OtaResult result, String msg, int
} }
delay(1000); delay(1000);
} }
oledDisplay.setAirGradient(0);
if (ag->isOne()) {
oledDisplay.setAirGradient(0);
oledDisplay.setBrightness(0);
}
break; break;
} }
default: default:
@ -1548,10 +1551,7 @@ void restartIfCeClientIssueOverTwoHours() {
void networkingTask(void *args) { void networkingTask(void *args) {
// OTA check on boot // OTA check on boot
#ifdef ESP8266 #ifndef ESP8266
// ota not supported
#else
// because cellular it takes too long, watchdog triggered
checkForFirmwareUpdate(); checkForFirmwareUpdate();
checkForUpdateSchedule.update(); checkForUpdateSchedule.update();
#endif #endif