tests: bsim: Bluetooth: Add param update to throughput test

Add connection parameter update to throughput test to cover
any connection timeout performing connection update while
subjected to high throughput scenarios.

Signed-off-by: Vinayak Kariappa Chettimada <vich@nordicsemi.no>

Author: cvinayak

samples/bluetooth/central_gatt_write/src/gatt_write_common.c

@@ -17,6 +17,10 @@
 static uint32_t phy_update_countdown;
 static uint8_t phy_param_idx;
 
+/* Count down number of metrics intervals before performing a param update */
+#define PARAM_UPDATE_COUNTDOWN PHY_UPDATE_COUNTDOWN
+static uint32_t param_update_countdown;
+
 static void phy_update_iterate(struct bt_conn *conn)
 {
 	const struct bt_conn_le_phy_param phy_param[] = {
@@ -178,6 +182,34 @@ static void write_cmd_cb(struct bt_conn *conn, void *user_data)
 			phy_update_iterate(conn);
 		}
 
+		const struct bt_le_conn_param update_params[2] = {{
+				.interval_min = 0x0029,
+				.interval_max = 0x0029,
+				.latency = 0,
+				.timeout = 31,
+			}, {
+				.interval_min = 0x0028,
+				.interval_max = 0x0028,
+				.latency = 0,
+				.timeout = 30,
+			},
+		};
+		static uint8_t param_update_count;
+		int err;
+
+		if ((param_update_countdown--) != 0U) {
+			return;
+		}
+
+		param_update_countdown = PARAM_UPDATE_COUNTDOWN;
+
+		err = bt_conn_le_param_update(conn, &update_params[param_update_count & 0x1]);
+		if (err != 0) {
+			printk("Parameter update failed (err %d)\n", err);
+		}
+
+		param_update_count++;
+
 	} else {
 		uint16_t len;
 
@@ -256,6 +288,9 @@ static void connected(struct bt_conn *conn, uint8_t conn_err)
 		phy_update_countdown = PHY_UPDATE_COUNTDOWN;
 		phy_param_idx = 0U;
 	}
+
+	/* Offset param update by 1 metric collection after PHY update */
+	param_update_countdown = PARAM_UPDATE_COUNTDOWN + 1U;
 }
 
 static void disconnected(struct bt_conn *conn, uint8_t reason)

tests/bsim/bluetooth/ll/throughput/src/main.c

@@ -67,7 +67,7 @@ static void test_central_main(void)
 	write_rate = central_gatt_write(COUNT);
 
 	printk("%s: Write Rate = %u bps\n", __func__, write_rate);
-	if (write_rate == WRITE_RATE) {
+	if (write_rate >= WRITE_RATE) {
 		PASS("Central tests passed\n");
 	} else {
 		FAIL("Central tests failed\n");
@@ -86,7 +86,7 @@ static void test_peripheral_main(void)
 	write_rate = peripheral_gatt_write(COUNT);
 
 	printk("%s: Write Rate = %u bps\n", __func__, write_rate);
-	if (write_rate == WRITE_RATE) {
+	if (write_rate >= WRITE_RATE) {
 		PASS("Peripheral tests passed\n");
 	} else {
 		FAIL("Peripheral tests failed\n");