floss: implement |cras_lea_manager|

This CL implements |cras_lea_manager|, the component that resolves
events and issues requests while managing iodev resources for LEA.

BUG=b:317682584
TEST=Apply full patch series and verify unicast works

Change-Id: I014b5295d3740be9f25a1356faf84d234fadca04
Reviewed-on: https://chromium-review.googlesource.com/c/chromiumos/third_party/adhd/+/5467607
Tested-by: [email protected] <[email protected]>
Commit-Queue: Jeremy Wu <[email protected]>
Reviewed-by: Hsinyu Chao <[email protected]>

Author: Jeremy Wu

cras/src/server/BUILD.bazel

@@ -439,6 +439,8 @@ cc_library(
         "cras_audio_thread_monitor.h",
         "cras_lea_iodev.c",
         "cras_lea_iodev.h",
+        "cras_lea_manager.c",
+        "cras_lea_manager.h",
         "cras_bt_adapter.c",
         "cras_bt_adapter.h",
         "cras_bt_battery_provider.c",

cras/src/server/cras_fl_media_adapter.c

@@ -16,6 +16,7 @@
 #include "cras/common/check.h"
 #include "cras/server/platform/features/features.h"
 #include "cras/src/server/cras_a2dp_manager.h"
+#include "cras/src/server/cras_lea_manager.h"
 #include "cras/src/server/cras_bt_io.h"
 #include "cras/src/server/cras_bt_log.h"
 #include "cras/src/server/cras_bt_policy.h"
@@ -74,7 +75,11 @@ int handle_on_lea_group_connected(struct fl_media* active_fm,
     return -EINVAL;
   }
 
-  // TODO: notify BLE manager
+  if (!active_fm->lea) {
+    active_fm->lea = cras_floss_lea_create(active_fm);
+  }
+
+  cras_floss_lea_add_group(active_fm->lea, name, group_id);
 
   return 0;
 }
@@ -91,7 +96,7 @@ int handle_on_lea_group_disconnected(struct fl_media* active_fm, int group_id) {
     return -EINVAL;
   }
 
-  // TODO: notify BLE manager
+  cras_floss_lea_remove_group(active_fm->lea, group_id);
 
   return 0;
 }
@@ -117,7 +122,9 @@ int handle_on_lea_audio_conf(struct fl_media* active_fm,
     return -EINVAL;
   }
 
-  // TODO: notify BLE manager
+  cras_floss_lea_audio_conf_updated(active_fm->lea, direction, group_id,
+                                    snk_audio_location, src_audio_location,
+                                    available_contexts);
 
   return 0;
 }

cras/src/server/cras_fl_media_adapter.h

@@ -36,6 +36,8 @@ struct fl_media {
   DBusConnection* conn;
   // Object representing the connected A2DP headset.
   struct cras_a2dp* a2dp;
+  // Object representing the LEA service.
+  struct cras_lea* lea;
   // Object representing the connected HFP headset.
   struct cras_hfp* hfp;
   struct bt_io_manager* bt_io_mgr;

cras/src/server/cras_lea_iodev.c

@@ -19,6 +19,7 @@
 #include "cras/src/server/audio_thread_log.h"
 #include "cras/src/server/cras_audio_area.h"
 #include "cras/src/server/cras_audio_thread_monitor.h"
+#include "cras/src/server/cras_lea_manager.h"
 #include "cras/src/server/cras_iodev.h"
 #include "cras/src/server/cras_iodev_list.h"
 #include "cras/src/server/cras_utf8.h"
@@ -41,6 +42,8 @@ struct lea_io {
   // How many frames of audio samples we prefer to write in one
   // socket write.
   unsigned int write_block;
+  // The associated |cras_lea| object.
+  struct cras_lea* lea;
   // The associated ID of the corresponding LE audio group.
   int group_id;
   // If the device has been configured and attached with any stream.
@@ -59,7 +62,8 @@ static void lea_free_base_resources(struct lea_io* leaio) {
   free(leaio->base.supported_formats);
 }
 
-struct cras_iodev* lea_iodev_create(const char* name,
+struct cras_iodev* lea_iodev_create(struct cras_lea* lea,
+                                    const char* name,
                                     int group_id,
                                     enum CRAS_STREAM_DIRECTION dir) {
   struct lea_io* leaio;
@@ -73,6 +77,7 @@ struct cras_iodev* lea_iodev_create(const char* name,
   }
 
   leaio->started = 0;
+  leaio->lea = lea;
   leaio->group_id = group_id;
 
   iodev = &leaio->base;

cras/src/server/cras_lea_iodev.h

@@ -18,11 +18,13 @@ extern "C" {
  * Note that if a group supports both input and output, two `lea_iodev`s
  * will be instantiated.
  * Args:
+ *    lea - The associated |cras_lea| object.
  *    name - Name associated to the LE audio group.
  *    group - ID of the associated group.
  *    dir - The direction of the iodev.
  */
-struct cras_iodev* lea_iodev_create(const char* name,
+struct cras_iodev* lea_iodev_create(struct cras_lea* lea,
+                                    const char* name,
                                     int group_id,
                                     enum CRAS_STREAM_DIRECTION dir);