examples/wireless/sle/sample_ssap_server/main/xf_main.c

xf_wal sle ssap 服务端 示例。

 
/* ==================== [Includes] ========================================== */
 
#include "xf_hal.h"
#include "xf_sle_connection_manager.h"
#include "xf_sle_device_discovery.h"
#include "xf_sle_ssap_server.h"
#include "string.h"
 
/* ==================== [Defines] =========================================== */
 
#define TAG "sample_ssaps"
 
#define SAMPLE_ADV_ID       1
#define SAMPLE_ADV_HANDLE   1
 
/* 连接调度间隔12.5ms，单位125us */
#define SAMPLE_SLE_CONN_INTV_MIN                0x64
/* 连接调度间隔12.5ms，单位125us */
#define SAMPLE_SLE_CONN_INTV_MAX                0x64
/* 连接调度间隔25ms，单位125us */
#define SAMPLE_SLE_ADV_INTERVAL_MIN             0xC8
/* 连接调度间隔25ms，单位125us */
#define SAMPLE_SLE_ADV_INTERVAL_MAX             0xC8
/* 超时时间5000ms，单位10ms */
#define SAMPLE_SLE_CONN_SUPERVISION_TIMEOUT     0x1F4
/* 超时时间4990ms，单位10ms */
#define SAMPLE_SLE_CONN_MAX_LATENCY             0
/* 广播发送功率 */
#define SAMPLE_SLE_ADV_TX_POWER  10
 
/* ==================== [Typedefs] ========================================== */
 
/* ==================== [Static Prototypes] ================================= */
 
static xf_err_t sample_ssaps_event_cb(
    xf_sle_ssaps_event_t event,
    xf_sle_ssaps_evt_cb_param_t *param);
static void sample_sle_set_adv_data(void);
static void sample_sle_set_adv_param(void);
 
/* ==================== [Static Variables] ================================== */
 
static uint8_t s_local_name[] = "XF_SSAPS";
static xf_sle_uuid_info_t s_app_uuid = {0};
static uint8_t s_aap_id = 0;
static uint8_t s_prop_value[8] = {0xCC};
static uint8_t s_ntf_value[] = {0x01, 0x0};
static uint8_t s_rsp_value[] = "I M SSAPS RSP";
 
static uint8_t s_sle_mac_addr[XF_SLE_ADDR_LEN] = {0x33, 0x22, 0x22, 0x66, 0x11, 0x22};
static bool is_connected = false;
 
static xf_sle_ssaps_service_t service_struct = {
    .service_uuid = XF_SLE_DECLARE_UUID16(0xABCD),
    .service_type = XF_SLE_SSAP_SERVICE_TYPE_PRIMARY,
    .prop_set = (xf_sle_ssaps_property_t [])
    {
        {
            .prop_uuid = XF_SLE_DECLARE_UUID16(0x1122),
            .permissions = (XF_SLE_SSAP_PERMISSION_READ | XF_SLE_SSAP_PERMISSION_WRITE),
            .value = s_prop_value,
            .value_len = sizeof(s_prop_value),
            .desc_set = (xf_sle_ssaps_desc_t []) {
                {
                    .permissions = (XF_SLE_SSAP_PERMISSION_READ | XF_SLE_SSAP_PERMISSION_WRITE),
                    .value = s_ntf_value,
                    .value_len = sizeof(s_ntf_value),
                },
                {0}
            },
        },
        {0}
    }
};
 
/* ==================== [Macros] ============================================ */
 
/* ==================== [Global Functions] ================================== */
 
void xf_main(void)
{
    XF_LOGI(TAG, "XF SLE SSAP Server");
 
    xf_err_t ret = XF_OK;
    ret = xf_sle_enable();
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "xf_sle_enable error!:%#X", ret);
 
    // 注册 ssaps 事件回调
    xf_sle_ssaps_event_cb_register(sample_ssaps_event_cb, XF_SLE_EVT_ALL);
 
    // 设置本地设备名
    ret = xf_sle_set_local_name(s_local_name, sizeof(s_local_name));
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "xf_sle_set_local_name error:%#X", ret);
 
    // 注册 ssaps 服务端 app
    ret = xf_sle_ssaps_app_register(&s_app_uuid, &s_aap_id);
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "xf_sle_set_local_name error:%#X", ret);
 
    // 添加 服务（结构）到 服务端 app
    ret = xf_sle_ssaps_add_service_to_app(s_aap_id, &service_struct);
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "xf_sle_ssaps_add_service_to_app error:%#X", ret);
    XF_LOGI(TAG, "property handle:[0]:%d,uuid:%#X",
            service_struct.prop_set[0].prop_handle,
            service_struct.prop_set[0].prop_uuid->uuid16);
 
    // 启动服务
    ret = xf_sle_ssaps_start_service(s_aap_id, service_struct.service_handle);
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "xf_sle_ssaps_start_service error:%#X", ret);
 
    /* 设置广播数据及参数 */
    sample_sle_set_adv_param();
    sample_sle_set_adv_data();
 
    // 启动广播
    ret = xf_sle_start_announce(SAMPLE_ADV_ID);
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "xf_sle_start_announce error:%#X", ret);
    XF_LOGI(TAG, "ADV STAR CMPL");
}
 
/* ==================== [Static Functions] ================================== */
 
static xf_err_t sample_ssaps_event_cb(
    xf_sle_ssaps_event_t event,
    xf_sle_ssaps_evt_cb_param_t *param)
{
    switch (event) {
    case XF_SLE_CONN_EVT_DISCONNECT: {
        is_connected = false;
        XF_LOGI(TAG, "EV:disconnect, it will restart ADV");
        // 重新启动广播
        xf_err_t ret = xf_sle_start_announce(SAMPLE_ADV_ID);
        XF_CHECK(ret != XF_OK, ret, TAG,
                 "xf_sle_start_announce error:%#X", ret);
    } break;
    case XF_SLE_CONN_EVT_CONNECT: {
        is_connected = true;
    } break;
    case XF_SLE_SSAPS_EVT_REQ_WRITE: {
        XF_LOGI(TAG, "EV:REQ WRITE:need_rsp:%d,hdl:%d,conn_id:%d,trans_id:%d",
                param->req_write.need_rsp, param->req_write.handle,
                param->req_write.conn_id, param->req_write.trans_id);
        XF_LOG_BUFFER_HEXDUMP_ESCAPE(param->req_write.value, param->req_write.value_len);
 
    } break;
    case XF_SLE_SSAPS_EVT_REQ_READ: {
        XF_LOGI(TAG, "EV:REQ READ:need_rsp:%d,hdl:%d,conn_id:%d,trans_id:%d",
                param->req_read.need_rsp, param->req_read.handle,
                param->req_read.conn_id, param->req_read.trans_id);
 
        xf_sle_ssaps_response_value_t rsp = {
            .value = s_rsp_value,
            .value_len = sizeof(s_rsp_value),
        };
        xf_err_t ret = xf_sle_ssaps_send_response(s_aap_id,
                       param->req_read.conn_id, param->req_read.trans_id,
                       XF_OK, &rsp
                                                 );
        XF_CHECK(ret != XF_OK, ret, TAG,
                 "xf_sle_start_announce error:%#X", ret);
    } break;
    default:
        break;
    }
    return XF_OK;
}
 
static void sample_sle_set_adv_data(void)
{
    xf_sle_announce_data_t announce_data = {
        .announce_struct_set = (xf_sle_adv_struct_t [])
        {
            {
                .type = XF_SLE_ADV_STRUCT_TYPE_COMPLETE_LOCAL_NAME,
                .data.local_name = s_local_name,
                .struct_data_len = sizeof(s_local_name),
            }, {
                .type = XF_SLE_ADV_STRUCT_TYPE_DISCOVERY_LEVEL,
                .data.discovery_level = XF_SLE_ANNOUNCE_LEVEL_NORMAL,
                .struct_data_len = 1,
            },
            {.struct_data_len = 0}  // 结束标记，也可以直接填 0，struct_data_len为关键标记变量
        },
        .seek_rsp_data_len = 0,
        .seek_rsp_data = NULL,
    };
 
    xf_err_t ret = xf_sle_set_announce_data(SAMPLE_ADV_ID, &announce_data);
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "ADV set data error:%#X", ret);
}
 
static void sample_sle_set_adv_param(void)
{
    xf_sle_announce_param_t announce_param = {0};
    {
        announce_param.announce_type = XF_SLE_ANNOUNCE_TYPE_CONNECTABLE_SCANABLE;
        announce_param.announce_handle = SAMPLE_ADV_HANDLE;
        announce_param.announce_gt_role = XF_SLE_ANNOUNCE_ROLE_T_CAN_NEGO;
        announce_param.announce_level = XF_SLE_ANNOUNCE_LEVEL_NORMAL;
        announce_param.announce_channel_map = XF_SLE_ADV_CHANNEL_MAP_DEFAULT;
 
        announce_param.announce_interval_min = SAMPLE_SLE_ADV_INTERVAL_MIN;
        announce_param.announce_interval_max = SAMPLE_SLE_ADV_INTERVAL_MAX;
 
        announce_param.conn_interval_min = SAMPLE_SLE_CONN_INTV_MIN;
        announce_param.conn_interval_max = SAMPLE_SLE_CONN_INTV_MAX;
        announce_param.conn_max_latency = SAMPLE_SLE_CONN_MAX_LATENCY;
        announce_param.conn_supervision_timeout = SAMPLE_SLE_CONN_SUPERVISION_TIMEOUT;
    };
    xf_memcpy(announce_param.own_addr.addr, s_sle_mac_addr, XF_SLE_ADDR_LEN);
 
    xf_err_t ret = xf_sle_set_announce_param(SAMPLE_ADV_ID, &announce_param);
    XF_CHECK(ret != XF_OK, XF_RETURN_VOID, TAG,
             "ADV set param error:%#X", ret);
}