Received-SPF: pass (google.com: domain of linux-bluetooth-owner@vger.kernel.org designates 23.128.96.37 as permitted sender) client-ip=23.128.96.37;
From:   Silviu Florian Barbulescu <silviu.barbulescu@nxp.com>
To:     linux-bluetooth@vger.kernel.org
Cc:     claudia.rosu@nxp.com, mihai-octavian.urzica@nxp.com,
        silviu.barbulescu@nxp.com, vlad.pruteanu@nxp.com,
        andrei.istodorescu@nxp.com, iulia.tanasescu@nxp.com
Subject: [PATCH v3 2/2] bap:Update transport acquire/release flow for bcast src
Date:   Wed,  4 Oct 2023 10:56:46 +0300
Message-Id: <20231004075646.4277-3-silviu.barbulescu@nxp.com>
In-Reply-To: <20231004075646.4277-1-silviu.barbulescu@nxp.com>
References: <20231004075646.4277-1-silviu.barbulescu@nxp.com>
Content-Transfer-Encoding: 8bit
Content-Type: text/plain
MIME-Version: 1.0
X-MS-Exchange-AntiSpam-MessageData-ChunkCount: 1
X-MS-Exchange-AntiSpam-MessageData-0: =?us-ascii?Q?B7j5al9ie2b8/H5hUaU5RMWkRh+5MUbxGg26ZE0J1r2JTdyxtll+kOPUrVX0?=
 =?us-ascii?Q?fBtT6MuG0P77if0/OT/K273f9XHrGqKzc4AarzvLnkbr1KJdZ9htTb+9Yq3Y?=
 =?us-ascii?Q?zvlJvLpqs7KZYJJUY9I7MVy9sk87a6SGP05SFOPXRiYgPk5B5DnBPHLrqL93?=
 =?us-ascii?Q?VhuPrRHvq+bfZrJagZ4DCGVGKeA0E3x0wqH0Vv1KdbB24koZIY7/EfK4ajtK?=
 =?us-ascii?Q?gyITawlaIQbPsxzkS3tVtB42F++eEGIpvwfT1bkVRPqEboqo50uNRmg87INd?=
 =?us-ascii?Q?vjq9IiuPMb7tZhod+K2a07SQqI/tSitPVKy2XajS1mwT74vHZElFpV7vBi9C?=
 =?us-ascii?Q?nsdzM8OLqB1GGJsBDwO4tZj7GD1x72E9QrqxV6xDKMICElznLXU9oOjSE224?=
 =?us-ascii?Q?s5jeb9sagUhWN0hxN8gpe1Skyjaq1B69gxpEcMIK0ZUaUuIOey02WPeZf5Gd?=
 =?us-ascii?Q?s63vlfU7kJ3AtgLywnuDJ22xly/Z118Srmeq0R8kprzqH6J3ny9WRt2VxZH4?=
 =?us-ascii?Q?agLov4+GZQRF2lIh/ddCntGSTxokb7vq/AyvNrc1G7eRFJ56gNjDT3fJz/FN?=
 =?us-ascii?Q?cIDW8uwgAB5iT1pggyc5zqLdzvMT2OpIUWPBjeVlw6ksgogL5bcCuupjYJVj?=
 =?us-ascii?Q?8+IB1NKKTftkB+w4rkkJGYCqcU6xii9RAade+hQmI8EwAnCmwoaJ1lLea9aq?=
 =?us-ascii?Q?YtPBkDGMG+Y1jnl9AwbZ1uJABOBm3tocLiO1hdVT1nr7jsyZvSrX7S3CgCeo?=
 =?us-ascii?Q?xDbOcQ0o8NQpEtmfy9o1MHuNjrKKbq9/OTszBdaERCImqWsh3OnKGywF+0kZ?=
 =?us-ascii?Q?zH1RIFSAnBjgERgnSrcuCbdewZfpvKb9/SaUK50ZDsJ0imWmdNHvjKAJRMyV?=
 =?us-ascii?Q?KujChZmFvchh3QBWpt2Pd5zxMuEOOAoczse8Qvs8V+enNwitItYop1Xtni97?=
 =?us-ascii?Q?KdfIZJH+dhpRWL9Jchwjmo7tHigkz7hIjqGCjBsOCqDEQLgHEDMJDzQ/7PyV?=
 =?us-ascii?Q?TBcebA02RmT9cS9ZO+mSprKvU2yvHQfJD/cKS1v5F/C8npnyTQa1H8AiPm2E?=
 =?us-ascii?Q?zp0koQMT6pcSKZcsv6NBmC8H5VAfZ35WycNkJTsjMHopb1u389/9qvFPg0jN?=
 =?us-ascii?Q?WqqdMLJOZg4xet7EF7CWSKvxGz/5dBDYuLnQqB1AY4kLYyJiaQ0OgBCa3vFp?=
 =?us-ascii?Q?qE4W5vcQ8weKLNxC9qib0rSYFF0eCz8W990MVhgzWk+dkJCo6U0FVD4l0eSn?=
 =?us-ascii?Q?UQHdyNvh8HvfYXEMuIxCNe/ZBXRCspF60xOpZCun1WM4zI9OR2HYz7M6oESr?=
 =?us-ascii?Q?uKAUosUmrGniAoB8WeR00l7hpm8HyuS+Wg9dPrPXHLPevNx1Z/m4jJbcz93A?=
 =?us-ascii?Q?7R/olKan1/YBiZYVx7MSNIlXIq3mMXMd6H8k2UZFjFo428LvbEdaenKfLfUO?=
 =?us-ascii?Q?oo3++eka1P3IQoCBwEG/8yNlVtm5sx7BpcQW7h5mMjRgSrqD6M6HXg5oLVpe?=
 =?us-ascii?Q?ou40v3Gj9V776Gap+CblXPAOVZZJi98Fehp9jJwhUpZjWW8JQPziWob/RhVl?=
 =?us-ascii?Q?I/Gtsukdhgs87/LXUsrKyd+OuW5B/yCCrdYP30smRY2kirCgElhAj6K3JerE?=
 =?us-ascii?Q?Dg=3D=3D?=
X-OriginatorOrg: nxp.com
X-MS-Exchange-CrossTenant-Network-Message-Id: 128dd344-c52c-43b0-53ee-08dbc4af7db4
X-MS-Exchange-CrossTenant-AuthSource: DBBPR04MB6331.eurprd04.prod.outlook.com
X-MS-Exchange-CrossTenant-AuthAs: Internal
X-MS-Exchange-CrossTenant-OriginalArrivalTime: 04 Oct 2023 07:57:01.1570
 (UTC)
X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted
X-MS-Exchange-CrossTenant-Id: 686ea1d3-bc2b-4c6f-a92c-d99c5c301635
X-MS-Exchange-CrossTenant-MailboxType: HOSTED
X-MS-Exchange-CrossTenant-UserPrincipalName: 3JyB6f8eR70Xv7wCEhUne/oa5/5Bxt2JkjKAowZYrBEJtvUqr3iHlSRRTC3z8lQhHlBXsVGn51YC5vLdg6DzoHxRBzJ0xEi1Y/BhnYAaTJ0=
X-MS-Exchange-Transport-CrossTenantHeadersStamped: AS5PR04MB10017
X-Spam-Status: No, score=-2.7 required=5.0 tests=BAYES_00,DKIM_SIGNED,
        DKIM_VALID,DKIM_VALID_AU,DKIM_VALID_EF,RCVD_IN_DNSWL_NONE,
        RCVD_IN_MSPIKE_H2,SPF_HELO_PASS,SPF_PASS,URIBL_BLOCKED autolearn=ham
        autolearn_force=no version=3.4.6
X-Spam-Checker-Version: SpamAssassin 3.4.6 (2021-04-09) on
        lindbergh.monkeyblade.net
Precedence: bulk
List-ID: <linux-bluetooth.vger.kernel.org>
X-Mailing-List: linux-bluetooth@vger.kernel.org
X-Greylist: Sender passed SPF test, not delayed by milter-greylist-4.6.4 (snail.vger.email [0.0.0.0]); Wed, 04 Oct 2023 00:57:17 -0700 (PDT)

Update transport acquire/release flow for BAP bcast source

---
 profiles/audio/bap.c | 51 ++++++++++++++++++++++++++++++++++++++------
 1 file changed, 44 insertions(+), 7 deletions(-)

diff --git a/profiles/audio/bap.c b/profiles/audio/bap.c
index 48a1a4f86..f23e04f00 100644
--- a/profiles/audio/bap.c
+++ b/profiles/audio/bap.c
@@ -1312,6 +1312,32 @@ static struct bap_ep *bap_find_ep_by_stream(struct bap_data *data,
 	return NULL;
 }
 
+static void iso_connect_bcast_cb(GIOChannel *chan, GError *err,
+					gpointer user_data)
+{
+	struct bt_bap_stream *stream = user_data;
+	int fd;
+
+	if (err) {
+		error("%s", err->message);
+		bt_bap_stream_set_io(stream, -1);
+		return;
+	}
+
+	DBG("ISO connected");
+
+	fd = g_io_channel_unix_get_fd(chan);
+
+	if (bt_bap_stream_set_io(stream, fd)) {
+		bt_bap_stream_start(stream, NULL, NULL);
+		g_io_channel_set_close_on_unref(chan, FALSE);
+		return;
+	}
+
+	error("Unable to set IO");
+	bt_bap_stream_set_io(stream, -1);
+}
+
 static void iso_connect_cb(GIOChannel *chan, GError *err, gpointer user_data)
 {
 	struct bt_bap_stream *stream = user_data;
@@ -1560,6 +1586,17 @@ static gboolean bap_io_disconnected(GIOChannel *io, GIOCondition cond,
 	return FALSE;
 }
 
+static void bap_connect_bcast_io_cb(GIOChannel *chan, GError *err,
+					gpointer user_data)
+{
+	struct bap_ep *ep = user_data;
+
+	if (!ep->stream)
+		return;
+
+	iso_connect_bcast_cb(chan, err, ep->stream);
+}
+
 static void bap_connect_io_cb(GIOChannel *chan, GError *err, gpointer user_data)
 {
 	struct bap_ep *ep = user_data;
@@ -1661,7 +1698,7 @@ static void bap_connect_io_broadcast(struct bap_data *data, struct bap_ep *ep,
 	DBG("ep %p stream %p ", ep, stream);
 	ba2str(btd_adapter_get_address(adapter), addr);
 
-	io = bt_io_connect(bap_connect_io_cb, ep, NULL, &err,
+	io = bt_io_connect(bap_connect_bcast_io_cb, ep, NULL, &err,
 			BT_IO_OPT_SOURCE_BDADDR,
 			btd_adapter_get_address(adapter),
 			BT_IO_OPT_DEST_BDADDR,
@@ -1887,18 +1924,16 @@ static void bap_state(struct bt_bap_stream *stream, uint8_t old_state,
 		}
 		break;
 	case BT_BAP_STREAM_STATE_QOS:
-		bap_create_io(data, ep, stream, true);
+		if (bt_bap_stream_get_type(stream) ==
+					BT_BAP_STREAM_TYPE_UCAST) {
+			bap_create_io(data, ep, stream, true);
+		}
 		break;
 	case BT_BAP_STREAM_STATE_ENABLING:
 		if (ep)
 			bap_create_io(data, ep, stream, false);
 		break;
 	case BT_BAP_STREAM_STATE_STREAMING:
-		if (bt_bap_stream_get_type(stream) ==
-				BT_BAP_STREAM_TYPE_BCAST) {
-			if (ep)
-				bap_create_io(data, ep, stream, false);
-		}
 		break;
 	}
 }
@@ -2116,6 +2151,8 @@ static void bap_connecting(struct bt_bap_stream *stream, bool state, int fd,
 
 			ep->qos.bcast.big = qos.bcast.big;
 			ep->qos.bcast.bis = qos.bcast.bis;
+			bt_bap_stream_config(ep->stream, &ep->qos,
+					ep->caps, NULL, NULL);
 		}
 
 		DBG("stream %p fd %d: BIG 0x%02x BIS 0x%02x", stream, fd,
-- 
2.39.2