problem with esp32 multitask

[federico-idili]

hi mobizt, thank you for this library and for your job,

I have a problem, I am using your library in a quite complex project. I did the tests with an esp32 16rom and an esp32 8rom 2ram.
Mainly if I use your library exclusively it works correct way without any problems,
while when I activate other tasks even on different cores, some times it fails to connect " Error, msg: TCP connection failed, code: -1" other reports Error task: task_1679, msg: JWT, private key signing failed, code: -111. I attach part of the code and log for better understanding

part of setup();

/////////////////BLE INIT//////////////////
#pragma region BLE INIT

BLE_Init(NVS_Matricola); //NimBLEDevice

#pragma endregion

////////////WATCHDOG///////////////

esp_task_wdt_init(TWDT_TIMEOUT_MS, true);

////////////////TASK////////////////

// Task core 1

xTaskCreatePinnedToCore(GestioneI2C, "GestioneI2C", 3096, NULL, 20, &Task_GestioneI2C, 1); // 5ms
xTaskCreatePinnedToCore(MS_Posizionamento, "MsPosizionamento", configMINIMAL_STACK_SIZE, NULL, 19, &Task_MS_Posizionamento, 1); // 5ms
xTaskCreatePinnedToCore(ReadADC, "ReadADC", 2048, NULL, 18, &Task_ReadADC, 1); // 2ms
xTaskCreatePinnedToCore(MS_ControlloVelocitaMotore, "MS_ControlloVelocitaMotore", 2048, NULL, 17, &Task_MS_ControlloVelocitaMotore, 1); // 5ms
xTaskCreatePinnedToCore(GestioneBatteria, "GestioneBatteria", configMINIMAL_STACK_SIZE, NULL, 16, &Task_GestioneBatteria, 1);
xTaskCreatePinnedToCore(GestionePannello, "GestionePannello", configMINIMAL_STACK_SIZE, NULL, 15, &Task_GestionePannello, 1);

// Task core 0

xTaskCreatePinnedToCore(GestioneWifiFirebase, "WifiFirebase", 8192, NULL, 21, NULL, 0);
xTaskCreatePinnedToCore(RF_Decode, "RF_Decode", 3096, NULL, 20, &Task_RF_Decode, 0);
xTaskCreatePinnedToCore(BLE_ElaborazioniDatiRicevuti, "BLE_ElaborazioniDatiRicevuti", 8192, NULL, 19, NULL, 0);
xTaskCreatePinnedToCore(BLE_DeQueueTask, "BLE_DeQueueTask", 8192, NULL, 18, NULL, 0);
xTaskCreatePinnedToCore(GestioneTempo, "GestioneTempo", 2048, NULL, 15, NULL, 0);
xTaskCreatePinnedToCore(InvioLogDebug, "InvioLogDebug", 1536, NULL, 11, NULL, 0);
xTaskCreatePinnedToCore(Lampeggio, "lampeggio", configMINIMAL_STACK_SIZE, NULL, 11, NULL, 0);
xTaskCreatePinnedToCore(Riavvio, "Riavvio", 2048, NULL, 10, NULL, 0);
xTaskCreatePinnedToCore(ReadSerialDebug, "ReadSerialDebug", 2048, NULL, 10, NULL, 0);

vTaskDelay(200);

xTaskCreatePinnedToCore(MS_ModalitaOperativa, "MS_ModalitaOperativa", 4096, NULL, 15, NULL, 1);

WifiFirebase task:

void Firebase_AddSync()
{
Firebase_PathBase = "/remotecontrol/" + NVS_Matricola;

CreaAccodaLogDebug("FIREBASE", "Attivo i sincronismi sui nodi " + Firebase_PathBase + "/msg/com");

// In SSE mode (HTTP Streaming) task, you can filter the Stream events by using AsyncClientClass::setSSEFilters(),
// which the is the comma separated events.
// The event keywords supported are:
// get - To allow the http get response (first put event since stream connected).
// put - To allow the put event.
// patch - To allow the patch event.
// keep-alive - To allow the keep-alive event.
// cancel - To allow the cancel event.
// auth_revoked - To allow the auth_revoked event.
// To clear all prevousely set filter to allow all Stream events, use AsyncClientClass::setSSEFilters().
Firebase_streamClient.setSSEFilters("get,put,patch,keep-alive,cancel,auth_revoked");
// Firebase_streamClient.setSSEFilters("");
// Firebase_streamClient.setSSEFilters("put");

// The "unauthenticate" error can be occurred in this case because we don't wait
// the app to be authenticated before connecting the stream.
// This is ok as stream task will be reconnected automatically when the app is authenticated.
// The streamClient must be used for Stream only.
Firebase_RealtimeDatabase.get(Firebase_streamClient, Firebase_PathBase + "/msg/com", Firebase_ElaborazioneDati, true /* SSE mode (HTTP Streaming) */, "ElaborazioneDati");
}

void Firebase_CheckDB()
{
CreaAccodaLogDebug("FIREBASE", "Controllo se esiste in DB");

Firebase_Status = Firebase_RealtimeDatabase.exists(Firebase_aClient, Firebase_PathBase);

if (Firebase_aClient.lastError().code() == 0)
Serial.println(Firebase_Status ? "Existed" : "Not exist");
else
{
Firebase_Status = false;
Firebase.printf("Error, msg: %s, code: %d\n", Firebase_aClient.lastError().message().c_str(), Firebase_aClient.lastError().code());
}

if (Firebase_Status)
{
CreaAccodaLogDebug("FIREBASE", "DB esiste");
Firebase_FlagCreateDB = false;
}
else
{
CreaAccodaLogDebug("FIREBASE", "DB non esiste");
Firebase_FlagCreateDB = true;
}
}

bool Firebase_CreaDB()
{
object_t json, com, feedback, msg, status, sync;
object_t dataTime0, payloadEmpty, statoEmpty, owner0, temp;

JsonWriter writer;

// com -> { "dataTime": 0, "payload": "" }
writer.create(dataTime0, "dataTime", number_t(0));
writer.create(payloadEmpty, "payload", string_t(""));
writer.join(com, 2, dataTime0, payloadEmpty);

// feedback -> { "dataTime": 0, "payload": "" }
writer.join(feedback, 2, dataTime0, payloadEmpty);

// msg -> { "com": {...}, "feedback": {...} }
writer.create(dataTime0, "com", com);
writer.create(payloadEmpty, "feedback", feedback);

writer.join(temp, 2, dataTime0, payloadEmpty);
writer.create(msg, "/msg/", temp);

// status -> { "stato": "" }
writer.create(status, "/status/stato", string_t(""));

// sync -> { "dataTime": 0, "owner": 0, "stato": "" }
writer.create(dataTime0, "dataTime", number_t(0));
writer.create(owner0, "owner", number_t(0));
writer.create(statoEmpty, "stato", string_t(""));
writer.join(temp, 3, dataTime0, owner0, statoEmpty);
writer.create(sync, "/sync", temp);

writer.join(json, 3, msg, status, sync);

// Stampa per debug
Serial.println(json);

// Invia al database Firebase
Serial.println("Setting the JSON value... ");
return Firebase_RealtimeDatabase.set<object_t>(Firebase_aClient, Firebase_PathBase, json);
}

void GestioneWifiFirebase(void *arg)
{
vTaskDelay(5000);

while (1)
{
if (NVS_WifiSID != "" && Bootloader_Attivo == false)
{
switch (Wifi_MS)
{
case WifiInit:

    CreaAccodaLogDebug("WIFI", "Connessione a " + NVS_WifiSID);

    // WiFi.onEvent(WiFiEvent);
    WiFi.begin(NVS_WifiSID, NVS_WifiPassword);

    Wifi_Riconnessione = 0;
    Wifi_MS = WifiCheckConnessione;

    break;

  case WifiCheckConnessione:

    if (WiFi.status() == WL_CONNECTED)
    {
      Wifi_MS = WifiInitNTP;
    }
    else
    {
      vTaskDelay(500);
      Wifi_Riconnessione++;
      if (Wifi_Riconnessione >= 10)
      {
        WiFi.disconnect();
        Wifi_MS = WifiInit;
      }
    }

    break;

  case WifiInitNTP:

    CreaAccodaLogDebug("WIFI", "Connesso");
    CreaAccodaLogDebug("NTP", "Init");

    // Attiva NTP con il timezone salvato
    configTzTime(NVS_Timezone.c_str(), "pool.ntp.org", "time.nist.gov");        

    NTP_TentativiSincronizzazione = 0;
    Wifi_MS = WifiWaitSyncNTP;

    break;

  case WifiWaitSyncNTP:

    CreaAccodaLogDebug("NTP", "Attesa sincronizzazione");

    struct tm timeinfo;
    if (getLocalTime(&timeinfo))
    {
      CreaAccodaLogDebug("NTP", "Sincronizzato");

      Wifi_MS = WifiInitFireBase;
    }
    else
    {
      vTaskDelay(500);
      NTP_TentativiSincronizzazione++;
      if (NTP_TentativiSincronizzazione >= 10)
      {
        WiFi.disconnect();
        Wifi_MS = WifiInit;
      }
    }

    break;

  case WifiInitFireBase:

    CreaAccodaLogDebug("FIREBASE", "Init");
    CreaAccodaLogDebug("FIREBASE", "Versione: " + String(FIREBASE_CLIENT_VERSION));

    Firebase_sslClient.setInsecure();
    Firebase_streamSslClient.setInsecure();

    // serve un orario valido per l'autentificazione come ServiceAuth

    //Firebase_app.setTime(get_ntp_time());
    Firebase_app.setTime(time(nullptr));

    initializeApp(Firebase_aClient, Firebase_app, getAuth(Firebase_saAuth), Firebase_authDebugPrint, "authTask");

    // inizializzo il realtimedatabase
    Firebase_app.getApp<RealtimeDatabase>(Firebase_RealtimeDatabase);
    Firebase_RealtimeDatabase.url(DATABASE_URL);

    Firebase_AddSync();

    Firebase_FlagCheckDB = true;

    Wifi_MS = WifiCheckFirebaseOnline;

    break;

  case WifiCheckFirebaseOnline:

    Firebase_app.loop();

    if (Firebase_app.ready())
    {
      if (Firebase_FlagCheckDB)
      {
        Firebase_FlagCheckDB = false;

        Firebase_CheckDB();
      }

      if (Firebase_FlagCreateDB)
      {
        Firebase_FlagCreateDB = false;

        Firebase_CreaDB();
      }
    }

    if (WiFi.status() == WL_DISCONNECTED)
    {
      WiFi.disconnect();
      Wifi_MS = WifiInit;
    }

    vTaskDelay(50);

    break;

  default:
    break;
  }
}
else
{
  vTaskDelay(500);
}

}
}

LOG:
01/01/70 00:00:00 [BLE]: Start init Duc 53230001
01/01/70 00:00:00 [BLE]: End init
01/01/70 00:00:05 [WIFI]: Connessione a Biamino
01/01/70 00:00:07 [WIFI]: Connesso
01/01/70 00:00:07 [NTP]: Init
01/01/70 01:00:07 [NTP]: Attesa sincronizzazione
06/10/25 14:25:54 [NTP]: Sincronizzato
06/10/25 14:25:54 [FIREBASE]: Init
06/10/25 14:25:54 [FIREBASE]: Versione: 2.1.5
Event task: authTask, msg: initializing, code: 1
Event task: authTask, msg: token signing, code: 6
06/10/25 14:25:54 [FIREBASE]: Attivo i sincronismi sui nodi /remotecontrol/53230001/msg/com
Error task: task_1679, msg: JWT, private key signing failed, code: -111
Error task: task_1330, msg: JWT process timed out, code: -121

01/01/70 00:00:00 [BLE]: Start init Duc 53230001
01/01/70 00:00:00 [BLE]: End init
01/01/70 00:00:05 [WIFI]: Connessione a Biamino
01/01/70 00:00:06 [WIFI]: Connesso
01/01/70 00:00:06 [NTP]: Init
01/01/70 01:00:06 [NTP]: Attesa sincronizzazione
06/10/25 15:05:16 [NTP]: Sincronizzato
06/10/25 15:05:16 [FIREBASE]: Init
06/10/25 15:05:16 [FIREBASE]: Versione: 2.1.5
Event task: authTask, msg: initializing, code: 1
Event task: authTask, msg: token signing, code: 6
06/10/25 15:05:17 [FIREBASE]: Attivo i sincronismi sui nodi /remotecontrol/53230001/msg/com
Event task: authTask, msg: authenticating, code: 7
Debug task: authTask, msg: Connecting to server...
Event task: authTask, msg: auth request sent, code: 8
Event task: authTask, msg: connection timed out, code: -1
Event task: authTask, msg: initializing, code: 1
Event task: authTask, msg: token signing, code: 6
Event task: authTask, msg: authenticating, code: 7
Debug task: authTask, msg: Connecting to server...
Event task: authTask, msg: auth request sent, code: 8
Event task: authTask, msg: connection timed out, code: -1
...

I've tried putting a delay on task startup to change priority and core,
but mainly the problem remains and I can't figure out what it might be due to.

Could it depend on ble?

Thank you bye

[mobizt]

The stack size for the FreeRTOS task is too small for SSL and cryptographic.

[federico-idili]

ah...what size do you recommend?
tnk

[mobizt]

I cannot recommend anything for your complicate code.

Normally library works on default 8k of main loop task stack.
https://github.com/espressif/arduino-esp32/blob/422e52684b824a3fde85989ea90abf6624f2b0eb/cores/esp32/main.cpp#L17

In your case, may fail because of MbedTLS memory allocation failure as it cannot parse the private key.

Anyway, I don't understand why you use too many delays in your task which is interrupted the authentication handler to run properly. It is bad idea, and you should remove it.

You will never see the delay in all library examples as it is not necessary and not recommended in networking application.

You should use UserAuth for Realtime Database. If you did not write the security rule, the ServiceAuth is not neccessary.

[mobizt]

As you see in all examples, the app.loop() is freely to run in the loop.

In the older version of examples and documentation, I write the example code comment to convince user to let the FrirebaseApp::loop() to run freely without any blocking code.

FirebaseClient/examples/RealtimeDatabase/Async/Callback/Set/Set.ino

Lines 119 to 124 in dbb6693

	void loop()
	{
	// The async task handler should run inside the main loop
	// without blocking delay or bypassing with millis code blocks.
	app.loop();

I think it is long enough for making this importance awareness.

[federico-idili]

I tried as you said , removed the task, moved the machine to states in the loop without blocking parts, and it seems to work, I did 5-6 reboots and all times it connected properly
thank you very much