Commit e80ff5ff authored by Vinayak Kariappa Chettimada's avatar Vinayak Kariappa Chettimada Committed by Carles Cufi
Browse files

samples: Bluetooth: Refactor observer for bsim test reuse 



Refactor the observer sample so that it can be reused as
bsim test to verify Extended advertisement chaining.

Signed-off-by: default avatarVinayak Kariappa Chettimada <vich@nordicsemi.no>
parent a5e62b09

samples/bluetooth/observer/CMakeLists.txt

+4 −4
Original line number Diff line number Diff line
@@ -4,7 +4,7 @@ cmake_minimum_required(VERSION 3.20.0) 
find_package(Zephyr REQUIRED HINTS $ENV{ZEPHYR_BASE})

project(observer)



FILE(GLOB app_sources src/*.c)

target_sources(app PRIVATE ${app_sources})



zephyr_library_include_directories(${ZEPHYR_BASE}/samples/bluetooth)
 
target_sources(app PRIVATE

  src/main.c

  src/observer.c

)

samples/bluetooth/observer/src/main.c

+5 −102
Original line number Diff line number Diff line 
/* main.c - Application main entry point */



/*

 * Copyright (c) 2015-2016 Intel Corporation

 * Copyright (c) 2022 Nordic Semiconductor ASA

 *

 * SPDX-License-Identifier: Apache-2.0

 */



#include <zephyr/types.h>

#include <stddef.h>

#include <zephyr/sys/printk.h>

#include <zephyr/sys/util.h>



#include <zephyr/bluetooth/bluetooth.h>

#include <zephyr/bluetooth/hci.h>



#define NAME_LEN 30



static void device_found(const bt_addr_le_t *addr, int8_t rssi, uint8_t type,

			 struct net_buf_simple *ad)

{

	char addr_str[BT_ADDR_LE_STR_LEN];



	bt_addr_le_to_str(addr, addr_str, sizeof(addr_str));

	printk("Device found: %s (RSSI %d), type %u, AD data len %u\n",

	       addr_str, rssi, type, ad->len);

}



#if defined(CONFIG_BT_EXT_ADV)

static bool data_cb(struct bt_data *data, void *user_data)

{

	char *name = user_data;

	uint8_t len;



	switch (data->type) {

	case BT_DATA_NAME_SHORTENED:

	case BT_DATA_NAME_COMPLETE:

		len = MIN(data->data_len, NAME_LEN - 1);

		(void)memcpy(name, data->data, len);

		name[len] = '\0';

		return false;

	default:

		return true;

	}

}



static const char *phy2str(uint8_t phy)

{

	switch (phy) {

	case BT_GAP_LE_PHY_NONE: return "No packets";

	case BT_GAP_LE_PHY_1M: return "LE 1M";

	case BT_GAP_LE_PHY_2M: return "LE 2M";

	case BT_GAP_LE_PHY_CODED: return "LE Coded";

	default: return "Unknown";

	}

}



static void scan_recv(const struct bt_le_scan_recv_info *info,

		      struct net_buf_simple *buf)

{

	char le_addr[BT_ADDR_LE_STR_LEN];

	char name[NAME_LEN];

	uint8_t data_status;

	uint16_t data_len;



	(void)memset(name, 0, sizeof(name));



	data_len = buf->len;

	bt_data_parse(buf, data_cb, name);



	data_status = BT_HCI_LE_ADV_EVT_TYPE_DATA_STATUS(info->adv_props);



	bt_addr_le_to_str(info->addr, le_addr, sizeof(le_addr));

	printk("[DEVICE]: %s, AD evt type %u, Tx Pwr: %i, RSSI %i "

	       "Data status: %u, AD data len: %u Name: %s "

	       "C:%u S:%u D:%u SR:%u E:%u Pri PHY: %s, Sec PHY: %s, "

	       "Interval: 0x%04x (%u ms), SID: %u\n",

	       le_addr, info->adv_type, info->tx_power, info->rssi,

	       data_status, data_len, name,

	       (info->adv_props & BT_GAP_ADV_PROP_CONNECTABLE) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_SCANNABLE) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_DIRECTED) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_SCAN_RESPONSE) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_EXT_ADV) != 0,

	       phy2str(info->primary_phy), phy2str(info->secondary_phy),

	       info->interval, info->interval * 5 / 4, info->sid);

}



static struct bt_le_scan_cb scan_callbacks = {

	.recv = scan_recv,

};

#endif /* CONFIG_BT_EXT_ADV */

int observer_start(void);



void main(void)

{

	struct bt_le_scan_param scan_param = {

		.type       = BT_LE_SCAN_TYPE_PASSIVE,

		.options    = BT_LE_SCAN_OPT_FILTER_DUPLICATE,

		.interval   = BT_GAP_SCAN_FAST_INTERVAL,

		.window     = BT_GAP_SCAN_FAST_WINDOW,

	};

	int err;



	printk("Starting Observer\n");

	printk("Starting Observer Demo\n");



	/* Initialize the Bluetooth Subsystem */

	err = bt_enable(NULL);
@@ -109,17 +21,8 @@ void main(void) 
		printk("Bluetooth init failed (err %d)\n", err);

		return;

	}

	printk("Bluetooth initialized\n");



#if defined(CONFIG_BT_EXT_ADV)

	bt_le_scan_cb_register(&scan_callbacks);

	printk("Registered scan callbacks\n");

#endif /* CONFIG_BT_EXT_ADV */

	(void)observer_start();



	err = bt_le_scan_start(&scan_param, device_found);

	if (err) {

		printk("Start scanning failed (err %d)\n", err);

		return;

	}

	printk("Scanning started, exiting %s thread.\n", __func__);

	printk("Exiting %s thread.\n", __func__);

}

samples/bluetooth/observer/src/observer.c

0 → 100644
+112 −0
Original line number Diff line number Diff line 
/*

 * Copyright (c) 2022 Nordic Semiconductor ASA

 * Copyright (c) 2015-2016 Intel Corporation

 *

 * SPDX-License-Identifier: Apache-2.0

 */



#include <zephyr/sys/printk.h>

#include <zephyr/bluetooth/bluetooth.h>

#include <zephyr/bluetooth/hci.h>



#define NAME_LEN 30



static void device_found(const bt_addr_le_t *addr, int8_t rssi, uint8_t type,

			 struct net_buf_simple *ad)

{

	char addr_str[BT_ADDR_LE_STR_LEN];



	bt_addr_le_to_str(addr, addr_str, sizeof(addr_str));

	printk("Device found: %s (RSSI %d), type %u, AD data len %u\n",

	       addr_str, rssi, type, ad->len);

}



#if defined(CONFIG_BT_EXT_ADV)

static bool data_cb(struct bt_data *data, void *user_data)

{

	char *name = user_data;

	uint8_t len;



	switch (data->type) {

	case BT_DATA_NAME_SHORTENED:

	case BT_DATA_NAME_COMPLETE:

		len = MIN(data->data_len, NAME_LEN - 1);

		(void)memcpy(name, data->data, len);

		name[len] = '\0';

		return false;

	default:

		return true;

	}

}



static const char *phy2str(uint8_t phy)

{

	switch (phy) {

	case BT_GAP_LE_PHY_NONE: return "No packets";

	case BT_GAP_LE_PHY_1M: return "LE 1M";

	case BT_GAP_LE_PHY_2M: return "LE 2M";

	case BT_GAP_LE_PHY_CODED: return "LE Coded";

	default: return "Unknown";

	}

}



static void scan_recv(const struct bt_le_scan_recv_info *info,

		      struct net_buf_simple *buf)

{

	char le_addr[BT_ADDR_LE_STR_LEN];

	char name[NAME_LEN];

	uint8_t data_status;

	uint16_t data_len;



	(void)memset(name, 0, sizeof(name));



	data_len = buf->len;

	bt_data_parse(buf, data_cb, name);



	data_status = BT_HCI_LE_ADV_EVT_TYPE_DATA_STATUS(info->adv_props);



	bt_addr_le_to_str(info->addr, le_addr, sizeof(le_addr));

	printk("[DEVICE]: %s, AD evt type %u, Tx Pwr: %i, RSSI %i "

	       "Data status: %u, AD data len: %u Name: %s "

	       "C:%u S:%u D:%u SR:%u E:%u Pri PHY: %s, Sec PHY: %s, "

	       "Interval: 0x%04x (%u ms), SID: %u\n",

	       le_addr, info->adv_type, info->tx_power, info->rssi,

	       data_status, data_len, name,

	       (info->adv_props & BT_GAP_ADV_PROP_CONNECTABLE) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_SCANNABLE) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_DIRECTED) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_SCAN_RESPONSE) != 0,

	       (info->adv_props & BT_GAP_ADV_PROP_EXT_ADV) != 0,

	       phy2str(info->primary_phy), phy2str(info->secondary_phy),

	       info->interval, info->interval * 5 / 4, info->sid);

}



static struct bt_le_scan_cb scan_callbacks = {

	.recv = scan_recv,

};

#endif /* CONFIG_BT_EXT_ADV */



int observer_start(void)

{

	struct bt_le_scan_param scan_param = {

		.type       = BT_LE_SCAN_TYPE_PASSIVE,

		.options    = BT_LE_SCAN_OPT_FILTER_DUPLICATE,

		.interval   = BT_GAP_SCAN_FAST_INTERVAL,

		.window     = BT_GAP_SCAN_FAST_WINDOW,

	};

	int err;



#if defined(CONFIG_BT_EXT_ADV)

	bt_le_scan_cb_register(&scan_callbacks);

	printk("Registered scan callbacks\n");

#endif /* CONFIG_BT_EXT_ADV */



	err = bt_le_scan_start(&scan_param, device_found);

	if (err) {

		printk("Start scanning failed (err %d)\n", err);

		return err;

	}

	printk("Started scanning...\n");



	return 0;

}

CRA Git | Maintained and supported by SUSTech CRA and CCSE