Fix task notification

Signed-off-by: Luca Arato <[email protected]>

Author: lucaato

examples/edgehog_app/edgehog_partition_example.csv

@@ -21,6 +21,7 @@
 
 # ESP-IDF Partition Table
 # Name,   Type, SubType, Offset,  Size, Flags
+nvs,      data, nvs,     0x9000,  0x4000,
 otadata,  data, ota,     0xd000,  0x2000,
 phy_init, data, phy,     0xf000,  0x1000,
 factory,  app,  factory, ,        0x12c000,

examples/edgehog_app/main/src/example_task.c

@@ -47,9 +47,10 @@ static edgehog_device_handle_t edgehog_device;
 /**
  * @brief Initialize an Astarte device.
  *
+ * @param notify_handle Task to be notified when the device gets connected.
  * @return The Astarte device instance handle.
  */
-static astarte_device_handle_t astarte_device_sdk_init(void);
+static astarte_device_handle_t astarte_device_sdk_init(TaskHandle_t notify_handle);
 /**
  * @brief Initialize an Edgehog device and starts the associated astarte device.
  *
@@ -93,7 +94,8 @@ static void astarte_disconnection_events_handler(astarte_device_disconnection_ev
 
 void edgehog_example_task(void *ctx)
 {
-    astarte_device_handle_t astarte_handle = astarte_device_sdk_init();
+    TaskHandle_t current_task_handle = xTaskGetCurrentTaskHandle();
+    astarte_device_handle_t astarte_handle = astarte_device_sdk_init(current_task_handle);
     assert(astarte_handle);
     edgehog_device_handle_t edgehog_device = edgehog_device_init(astarte_handle);
     assert(edgehog_device);
@@ -103,9 +105,10 @@ void edgehog_example_task(void *ctx)
         ESP_LOGE(TAG, "Failed starting the Astarte device.");
         return;
     }
-    // Wait until the Astarte device is connected
+
+    // Wait until the Astarte device is connected and the current task gets notified
     (void) ulTaskNotifyTake(pdTRUE, portMAX_DELAY);
-    ESP_LOGI(TAG, "Astarte device started");
+    ESP_LOGI(TAG, "Astarte device started and connected, starting edgehog device...");
 
     // Start the Edgehog device
     edgehog_err_t edgehog_err = edgehog_device_start(edgehog_device);
@@ -125,7 +128,7 @@ void edgehog_example_task(void *ctx)
  * Static functions definitions
  ***********************************************/
 
-static astarte_device_handle_t astarte_device_sdk_init(void)
+static astarte_device_handle_t astarte_device_sdk_init(TaskHandle_t notify_handle)
 {
     // Set up storage for the Astarte device
     if (astarte_credentials_use_nvs_storage(ASTARTE_PARTITION_NAME) != ASTARTE_OK) {
@@ -143,6 +146,7 @@ static astarte_device_handle_t astarte_device_sdk_init(void)
         .connection_event_callback = astarte_connection_events_handler,
         .disconnection_event_callback = astarte_disconnection_events_handler,
         .data_event_callback = astarte_data_events_handler,
+        .callbacks_user_data = notify_handle,
     };
 
     astarte_device_handle_t astarte_device = astarte_device_init(&astarte_device_cfg);
@@ -226,6 +230,8 @@ static void edgehog_event_handler(
 static void astarte_connection_events_handler(astarte_device_connection_event_t *event)
 {
     ESP_LOGI(TAG, "Astarte device connected, session_present: %d", event->session_present);
+    // notifying the passed task
+    xTaskNotifyGive(event->user_data);
 }
 
 static void astarte_data_events_handler(astarte_device_data_event_t *event)