From: zhiweijian Date: Thu, 18 Oct 2018 13:12:13 +0000 (+0800) Subject: Component/bt: add BLE Blocking APIs X-Git-Tag: v3.3-beta1~90^2 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=fb3aa885654baa3ad52102679fbfd737c31edd0c;p=esp-idf Component/bt: add BLE Blocking APIs --- diff --git a/components/bt/bluedroid/bta/dm/bta_dm_act.c b/components/bt/bluedroid/bta/dm/bta_dm_act.c index b9d230e52c..e1e34f37ce 100644 --- a/components/bt/bluedroid/bta/dm/bta_dm_act.c +++ b/components/bt/bluedroid/bta/dm/bta_dm_act.c @@ -4619,14 +4619,25 @@ void bta_dm_ble_set_scan_params(tBTA_DM_MSG *p_data) *******************************************************************************/ void bta_dm_ble_set_scan_fil_params(tBTA_DM_MSG *p_data) { - BTM_BleSetScanFilterParams (p_data->ble_set_scan_fil_params.client_if, + tBTA_STATUS status = BTA_FAILURE; + + if (BTM_BleSetScanFilterParams (p_data->ble_set_scan_fil_params.client_if, p_data->ble_set_scan_fil_params.scan_int, p_data->ble_set_scan_fil_params.scan_window, p_data->ble_set_scan_fil_params.scan_mode, p_data->ble_set_scan_fil_params.addr_type_own, p_data->ble_set_scan_fil_params.scan_duplicate_filter, p_data->ble_set_scan_fil_params.scan_filter_policy, - p_data->ble_set_scan_fil_params.scan_param_setup_cback); + p_data->ble_set_scan_fil_params.scan_param_setup_cback) == BTM_SUCCESS) { + status = BTA_SUCCESS; + + } else { + APPL_TRACE_ERROR("%s(), fail to set scan params.", __func__); + } + if (p_data->ble_set_scan_fil_params.scan_param_setup_cback != NULL) { + p_data->ble_set_scan_fil_params.scan_param_setup_cback(p_data->ble_set_scan_fil_params.client_if, status); + } + } @@ -4869,7 +4880,8 @@ void bta_dm_ble_set_adv_params (tBTA_DM_MSG *p_data) *******************************************************************************/ void bta_dm_ble_set_adv_params_all (tBTA_DM_MSG *p_data) { - if (BTM_BleSetAdvParamsStartAdv(p_data->ble_set_adv_params_all.adv_int_min, + tBTA_STATUS status = BTA_FAILURE; + if (BTM_BleSetAdvParamsAll(p_data->ble_set_adv_params_all.adv_int_min, p_data->ble_set_adv_params_all.adv_int_max, p_data->ble_set_adv_params_all.adv_type, p_data->ble_set_adv_params_all.addr_type_own, @@ -4877,10 +4889,20 @@ void bta_dm_ble_set_adv_params_all (tBTA_DM_MSG *p_data) p_data->ble_set_adv_params_all.channel_map, p_data->ble_set_adv_params_all.adv_filter_policy, p_data->ble_set_adv_params_all.p_start_adv_cback) == BTM_SUCCESS) { - APPL_TRACE_DEBUG("%s(), success to start ble adv.", __func__); + APPL_TRACE_DEBUG("%s(), success to set ble adv params.", __func__); } else { - APPL_TRACE_ERROR("%s(), fail to start ble adv.", __func__); + APPL_TRACE_ERROR("%s(), fail to set ble adv params.", __func__); + if(p_data->ble_set_adv_params_all.p_start_adv_cback) { + (*p_data->ble_set_adv_params_all.p_start_adv_cback)(status); + } + return; + } + if(BTM_BleStartAdv() == BTM_SUCCESS) { + status = BTA_SUCCESS; } + if(p_data->ble_set_adv_params_all.p_start_adv_cback) { + (*p_data->ble_set_adv_params_all.p_start_adv_cback)(status); + } } /******************************************************************************* @@ -5021,16 +5043,17 @@ void bta_dm_ble_set_data_length(tBTA_DM_MSG *p_data) *******************************************************************************/ void bta_dm_ble_broadcast (tBTA_DM_MSG *p_data) { - tBTM_STATUS status = 0; + tBTA_STATUS status = BTA_FAILURE; BOOLEAN start = p_data->ble_observe.start; - status = BTM_BleBroadcast(start, p_data->ble_observe.p_stop_adv_cback); + if (BTM_BleBroadcast(start, p_data->ble_observe.p_stop_adv_cback) == BTM_SUCCESS) { + status = BTA_SUCCESS; + } else { + APPL_TRACE_ERROR("%s failed\n", __FUNCTION__); + } if (p_data->ble_observe.p_stop_adv_cback){ - if (status != BTM_SUCCESS){ - APPL_TRACE_WARNING("%s, %s, status=0x%x\n", __func__,\ - (start == TRUE) ? "start adv failed" : "stop adv failed", status); - } + (*p_data->ble_observe.p_stop_adv_cback)(status); } } diff --git a/components/bt/bluedroid/stack/btm/btm_ble_gap.c b/components/bt/bluedroid/stack/btm/btm_ble_gap.c index a3d4b85126..0b04bd7461 100644 --- a/components/bt/bluedroid/stack/btm/btm_ble_gap.c +++ b/components/bt/bluedroid/stack/btm/btm_ble_gap.c @@ -44,6 +44,8 @@ #include "btm_ble_int.h" //#define LOG_TAG "bt_btm_ble" //#include "osi/include/log.h" +#include "osi/osi.h" +#include "osi/mutex.h" #define BTM_BLE_NAME_SHORT 0x01 #define BTM_BLE_NAME_CMPL 0x02 @@ -223,6 +225,58 @@ const UINT8 btm_le_state_combo_tbl[BTM_BLE_STATE_MAX][BTM_BLE_STATE_MAX][2] = { /* check LE combo state supported */ #define BTM_LE_STATES_SUPPORTED(x, y, z) ((x)[(z)] & (y)) +static osi_mutex_t adv_enable_lock; +static osi_mutex_t adv_data_lock; +static osi_mutex_t adv_param_lock; +static osi_mutex_t scan_enable_lock; +static osi_mutex_t scan_param_lock; +osi_sem_t adv_enable_sem; +osi_sem_t adv_data_sem; +osi_sem_t adv_param_sem; +osi_sem_t scan_enable_sem; +osi_sem_t scan_param_sem; +uint8_t adv_enable_status = 0; +uint8_t adv_data_status = 0; +uint8_t adv_param_status = 0; +uint8_t scan_enable_status = 0; +uint8_t scan_param_status = 0; + +void btm_lock_init(void) +{ + osi_mutex_new(&adv_enable_lock); + osi_mutex_new(&adv_data_lock); + osi_mutex_new(&adv_param_lock); + osi_mutex_new(&scan_enable_lock); + osi_mutex_new(&scan_param_lock); +} + +void btm_lock_free(void) +{ + osi_mutex_free(&adv_enable_lock); + osi_mutex_free(&adv_data_lock); + osi_mutex_free(&adv_param_lock); + osi_mutex_free(&scan_enable_lock); + osi_mutex_free(&scan_param_lock); +} + +void btm_sem_init(void) +{ + osi_sem_new(&adv_enable_sem, 1, 0); + osi_sem_new(&adv_data_sem, 1, 0); + osi_sem_new(&adv_param_sem, 1, 0); + osi_sem_new(&scan_enable_sem, 1, 0); + osi_sem_new(&scan_param_sem, 1, 0); +} + +void btm_sem_free(void) +{ + osi_sem_free(&adv_enable_sem); + osi_sem_free(&adv_data_sem); + osi_sem_free(&adv_param_sem); + osi_sem_free(&scan_enable_sem); + osi_sem_free(&scan_param_sem); +} + /******************************************************************************* ** ** Function BTM_BleRegiseterConnParamCallback @@ -529,13 +583,7 @@ tBTM_STATUS BTM_BleBroadcast(BOOLEAN start, tBTM_START_STOP_ADV_CMPL_CBACK *p_s evt_type = p_cb->scan_rsp ? BTM_BLE_CONNECT_EVT : BTM_BLE_NON_CONNECT_EVT; } #endif - // if adv state is BTM_BLE_ADV_PENDING, return immediately - if (p_cb->state == BTM_BLE_ADV_PENDING) { - if (p_stop_adv_cback) { - (*p_stop_adv_cback)(HCI_ERR_ILLEGAL_COMMAND); - } - return BTM_BUSY; - } + if (start && p_cb->adv_mode == BTM_BLE_ADV_DISABLE) { /* update adv params */ if (!btsnd_hcic_ble_write_adv_params ((UINT16)(p_cb->adv_interval_min ? p_cb->adv_interval_min : @@ -569,9 +617,6 @@ tBTM_STATUS BTM_BleBroadcast(BOOLEAN start, tBTM_START_STOP_ADV_CMPL_CBACK *p_s 2. stop adv shen adv has already stoped */ status = BTM_SUCCESS; - if (p_stop_adv_cback) { - (*p_stop_adv_cback)(status); - } } return status; } @@ -1197,7 +1242,7 @@ tBTM_STATUS BTM_BleSetAdvParams(UINT16 adv_int_min, UINT16 adv_int_max, /******************************************************************************* ** -** Function BTM_BleSetAdvParamsStartAdv +** Function BTM_BleSetAdvParamsAll ** ** Description This function is called to set all of the advertising parameters. ** @@ -1206,14 +1251,14 @@ tBTM_STATUS BTM_BleSetAdvParams(UINT16 adv_int_min, UINT16 adv_int_max, ** Returns void ** *******************************************************************************/ -tBTM_STATUS BTM_BleSetAdvParamsStartAdv(UINT16 adv_int_min, UINT16 adv_int_max, UINT8 adv_type, +tBTM_STATUS BTM_BleSetAdvParamsAll(UINT16 adv_int_min, UINT16 adv_int_max, UINT8 adv_type, tBLE_ADDR_TYPE own_bda_type, tBLE_BD_ADDR *p_dir_bda, tBTM_BLE_ADV_CHNL_MAP chnl_map, tBTM_BLE_AFP afp, tBTM_START_ADV_CMPL_CBACK *adv_cb) { tBTM_LE_RANDOM_CB *p_addr_cb = &btm_cb.ble_ctr_cb.addr_mgnt_cb; tBTM_BLE_INQ_CB *p_cb = &btm_cb.ble_ctr_cb.inq_var; - BTM_TRACE_EVENT ("BTM_BleSetAdvParamsStartAdv\n"); + BTM_TRACE_EVENT ("BTM_BleSetAdvParamsAll\n"); if (!controller_get_interface()->supports_ble()) { return BTM_ILLEGAL_VALUE; @@ -1290,6 +1335,9 @@ tBTM_STATUS BTM_BleSetAdvParamsStartAdv(UINT16 adv_int_min, UINT16 adv_int_max, return BTM_ILLEGAL_VALUE; } + btm_ble_stop_adv(); + + osi_mutex_lock(&adv_param_lock, OSI_MUTEX_MAX_TIMEOUT); if(adv_type == BTM_BLE_CONNECT_DIR_EVT){ btm_ble_set_topology_mask(BTM_BLE_STATE_HI_DUTY_DIR_ADV_BIT); }else if(adv_type == BTM_BLE_CONNECT_LO_DUTY_DIR_EVT){ @@ -1311,40 +1359,39 @@ tBTM_STATUS BTM_BleSetAdvParamsStartAdv(UINT16 adv_int_min, UINT16 adv_int_max, } BTM_TRACE_EVENT ("update params for an active adv\n"); - // if adv state is BTM_BLE_ADV_PENDING, return immediately - if (p_cb->state == BTM_BLE_ADV_PENDING) { - if (p_cb->p_adv_cb) { - (*p_cb->p_adv_cb)(HCI_ERR_ILLEGAL_COMMAND); - } - return BTM_BUSY; - } - /* host will stop adv first and then start adv again if adv has already started - it will get callback twice. - */ - if (p_cb->adv_mode == BTM_BLE_ADV_ENABLE) { - p_cb->adv_callback_twice = TRUE; - } - tBTM_STATUS status = btm_ble_stop_adv(); - if (status != BTM_SUCCESS) { - p_cb->adv_callback_twice = FALSE; - } - + + tBTM_STATUS status = BTM_SUCCESS; /* update adv params */ - btsnd_hcic_ble_write_adv_params (adv_int_min, - adv_int_max, - adv_type, - own_bda_type, - p_dir_bda->type, - p_dir_bda->bda, - chnl_map, - p_cb->afp); - - return btm_ble_start_adv(); + if (btsnd_hcic_ble_write_adv_params (adv_int_min, + adv_int_max, + adv_type, + own_bda_type, + p_dir_bda->type, + p_dir_bda->bda, + chnl_map, + p_cb->afp)) { + osi_sem_take(&adv_param_sem, OSI_SEM_MAX_TIMEOUT); + status = adv_param_status; + } else { + status = BTM_NO_RESOURCES; + } + osi_mutex_unlock(&adv_param_lock); + return status; } +tBTM_STATUS BTM_BleStartAdv(void) +{ + tBTM_STATUS status = BTM_SUCCESS; + if (!controller_get_interface()->supports_ble()) { + return BTM_ILLEGAL_VALUE; + } + btm_ble_stop_adv(); + + status = btm_ble_start_adv(); - + return status; +} /******************************************************************************* ** ** Function BTM_BleReadAdvParams @@ -1437,17 +1484,18 @@ void BTM_BleSetScanParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 scan_ } -void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 scan_window, +tBTM_STATUS BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 scan_window, tBLE_SCAN_MODE scan_mode, UINT8 addr_type_own, UINT8 scan_duplicate_filter, tBTM_BLE_SFP scan_filter_policy, tBLE_SCAN_PARAM_SETUP_CBACK scan_setup_status_cback) { tBTM_BLE_INQ_CB *p_cb = &btm_cb.ble_ctr_cb.inq_var; UINT32 max_scan_interval; UINT32 max_scan_window; + tBTM_STATUS ret = BTM_SUCCESS; BTM_TRACE_EVENT ("%s\n", __func__); if (!controller_get_interface()->supports_ble()) { - return; + return BTM_ILLEGAL_VALUE; } if(addr_type_own == BLE_ADDR_RANDOM) { @@ -1468,11 +1516,8 @@ void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 memcpy(btm_cb.ble_ctr_cb.addr_mgnt_cb.private_addr, btm_cb.ble_ctr_cb.addr_mgnt_cb.resolvale_addr, BD_ADDR_LEN); btsnd_hcic_ble_set_random_addr(btm_cb.ble_ctr_cb.addr_mgnt_cb.resolvale_addr); }else { - if (scan_setup_status_cback != NULL) { - scan_setup_status_cback(client_if, BTM_ILLEGAL_VALUE); - } BTM_TRACE_ERROR ("No random address yet, please set random address and try\n"); - return; + return BTM_ILLEGAL_VALUE; } } else if(addr_type_own == BLE_ADDR_PUBLIC_ID || addr_type_own == BLE_ADDR_RANDOM_ID) { if((btm_cb.ble_ctr_cb.addr_mgnt_cb.exist_addr_bit & BTM_BLE_GAP_ADDR_BIT_RESOLVABLE) == BTM_BLE_GAP_ADDR_BIT_RESOLVABLE) { @@ -1484,10 +1529,7 @@ void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 #if BLE_PRIVACY_SPT == TRUE if(btm_cb.ble_ctr_cb.privacy_mode != BTM_PRIVACY_NONE) { BTM_TRACE_ERROR ("Error state\n"); - if (scan_setup_status_cback != NULL) { - scan_setup_status_cback(client_if, BTM_ILLEGAL_VALUE); - } - return; + return BTM_ILLEGAL_VALUE; } #endif if(addr_type_own == BLE_ADDR_PUBLIC_ID) { @@ -1502,10 +1544,7 @@ void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 btsnd_hcic_ble_set_random_addr(btm_cb.ble_ctr_cb.addr_mgnt_cb.static_rand_addr); } else { BTM_TRACE_ERROR ("No RPA and no random address yet, please set RPA or random address and try\n"); - if (scan_setup_status_cback != NULL) { - scan_setup_status_cback(client_if, BTM_ILLEGAL_VALUE); - } - return; + return BTM_ILLEGAL_VALUE; } } } @@ -1523,6 +1562,8 @@ void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 max_scan_window = BTM_BLE_EXT_SCAN_WIN_MAX; } + osi_mutex_lock(&scan_param_lock, OSI_MUTEX_MAX_TIMEOUT); + if (BTM_BLE_ISVALID_PARAM(scan_interval, BTM_BLE_SCAN_INT_MIN, max_scan_interval) && BTM_BLE_ISVALID_PARAM(scan_window, BTM_BLE_SCAN_WIN_MIN, max_scan_window) && (scan_mode == BTM_BLE_SCAN_MODE_ACTI || scan_mode == BTM_BLE_SCAN_MODE_PASS) && @@ -1535,22 +1576,20 @@ void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 p_cb->scan_duplicate_filter = scan_duplicate_filter; - btsnd_hcic_ble_set_scan_params(p_cb->scan_type, (UINT16)scan_interval, + if (btsnd_hcic_ble_set_scan_params(p_cb->scan_type, (UINT16)scan_interval, (UINT16)scan_window, addr_type_own, - scan_filter_policy); - - if (scan_setup_status_cback != NULL) { - scan_setup_status_cback(client_if, BTM_SUCCESS); + scan_filter_policy)) { + osi_sem_take(&scan_param_sem, OSI_SEM_MAX_TIMEOUT); + ret = scan_param_status; } } else { - if (scan_setup_status_cback != NULL) { - scan_setup_status_cback(client_if, BTM_ILLEGAL_VALUE); - } - + ret = BTM_ILLEGAL_VALUE; BTM_TRACE_ERROR("Illegal params: scan_interval = %d scan_window = %d\n", scan_interval, scan_window); } + osi_mutex_unlock(&scan_param_lock); + return ret; } @@ -1567,7 +1606,7 @@ void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 *******************************************************************************/ tBTM_STATUS BTM_BleWriteScanRsp(tBTM_BLE_AD_MASK data_mask, tBTM_BLE_ADV_DATA *p_data) { - tBTM_STATUS status = BTM_NO_RESOURCES; + tBTM_STATUS ret; UINT8 rsp_data[BTM_BLE_AD_DATA_LEN], *p = rsp_data; @@ -1577,22 +1616,25 @@ tBTM_STATUS BTM_BleWriteScanRsp(tBTM_BLE_AD_MASK data_mask, tBTM_BLE_ADV_DATA *p return BTM_ILLEGAL_VALUE; } + osi_mutex_lock(&adv_data_lock, OSI_MUTEX_MAX_TIMEOUT); memset(rsp_data, 0, BTM_BLE_AD_DATA_LEN); btm_ble_build_adv_data(&data_mask, &p, p_data); if (btsnd_hcic_ble_set_scan_rsp_data((UINT8)(p - rsp_data), rsp_data)) { - status = BTM_SUCCESS; + osi_sem_take(&adv_data_sem, OSI_SEM_MAX_TIMEOUT); + ret = adv_data_status; - if (data_mask != 0) { + if (adv_data_status == BTM_SUCCESS && data_mask != 0) { btm_cb.ble_ctr_cb.inq_var.scan_rsp = TRUE; } else { btm_cb.ble_ctr_cb.inq_var.scan_rsp = FALSE; } } else { - status = BTM_ILLEGAL_VALUE; + ret = BTM_ILLEGAL_VALUE; } - return status; + osi_mutex_unlock(&adv_data_lock); + return ret; } /******************************************************************************* @@ -1608,11 +1650,18 @@ tBTM_STATUS BTM_BleWriteScanRsp(tBTM_BLE_AD_MASK data_mask, tBTM_BLE_ADV_DATA *p *******************************************************************************/ tBTM_STATUS BTM_BleWriteScanRspRaw(UINT8 *p_raw_scan_rsp, UINT32 raw_scan_rsp_len) { + tBTM_STATUS ret; + + osi_mutex_lock(&adv_data_lock, OSI_MUTEX_MAX_TIMEOUT); if (btsnd_hcic_ble_set_scan_rsp_data((UINT8)raw_scan_rsp_len, p_raw_scan_rsp)) { - return BTM_SUCCESS; + osi_sem_take(&adv_data_sem, OSI_SEM_MAX_TIMEOUT); + ret = adv_data_status; } else { - return BTM_NO_RESOURCES; + ret = BTM_NO_RESOURCES; } + osi_mutex_unlock(&adv_data_lock); + + return ret; } /******************************************************************************* @@ -1631,13 +1680,14 @@ tBTM_STATUS BTM_BleWriteAdvData(tBTM_BLE_AD_MASK data_mask, tBTM_BLE_ADV_DATA *p tBTM_BLE_LOCAL_ADV_DATA *p_cb_data = &btm_cb.ble_ctr_cb.inq_var.adv_data; UINT8 *p; tBTM_BLE_AD_MASK mask = data_mask; + tBTM_STATUS ret; BTM_TRACE_EVENT ("BTM_BleWriteAdvData "); if (!controller_get_interface()->supports_ble()) { return BTM_ILLEGAL_VALUE; } - + osi_mutex_lock(&adv_data_lock, OSI_MUTEX_MAX_TIMEOUT); memset(p_cb_data, 0, sizeof(tBTM_BLE_LOCAL_ADV_DATA)); p = p_cb_data->ad_data; p_cb_data->data_mask = data_mask; @@ -1654,11 +1704,13 @@ tBTM_STATUS BTM_BleWriteAdvData(tBTM_BLE_AD_MASK data_mask, tBTM_BLE_ADV_DATA *p if (btsnd_hcic_ble_set_adv_data((UINT8)(p_cb_data->p_pad - p_cb_data->ad_data), p_cb_data->ad_data)) { - return BTM_SUCCESS; + osi_sem_take(&adv_data_sem, OSI_SEM_MAX_TIMEOUT); + ret = adv_data_status; } else { - return BTM_NO_RESOURCES; + ret = BTM_NO_RESOURCES; } - + osi_mutex_unlock(&adv_data_lock); + return ret; } @@ -1675,11 +1727,17 @@ tBTM_STATUS BTM_BleWriteAdvData(tBTM_BLE_AD_MASK data_mask, tBTM_BLE_ADV_DATA *p *******************************************************************************/ tBTM_STATUS BTM_BleWriteAdvDataRaw(UINT8 *p_raw_adv, UINT32 raw_adv_len) { + tBTM_STATUS ret; + osi_mutex_lock(&adv_data_lock, OSI_MUTEX_MAX_TIMEOUT); if (btsnd_hcic_ble_set_adv_data((UINT8)raw_adv_len, p_raw_adv)) { - return BTM_SUCCESS; + osi_sem_take(&adv_data_sem, OSI_SEM_MAX_TIMEOUT); + ret = adv_data_status; } else { - return BTM_NO_RESOURCES; + ret = BTM_NO_RESOURCES; } + osi_mutex_unlock(&adv_data_lock); + + return ret; } @@ -3431,6 +3489,8 @@ tBTM_STATUS btm_ble_start_scan(void) tBTM_BLE_INQ_CB *p_inq = &btm_cb.ble_ctr_cb.inq_var; tBTM_STATUS status = BTM_CMD_STARTED; + osi_mutex_lock(&scan_enable_lock, OSI_MUTEX_MAX_TIMEOUT); + if(p_inq->scan_duplicate_filter > BTM_BLE_DUPLICATE_MAX) { p_inq->scan_duplicate_filter = BTM_BLE_DUPLICATE_DISABLE; } @@ -3438,6 +3498,10 @@ tBTM_STATUS btm_ble_start_scan(void) if (!btsnd_hcic_ble_set_scan_enable (BTM_BLE_SCAN_ENABLE, p_inq->scan_duplicate_filter)) { status = BTM_NO_RESOURCES; } else { + osi_sem_take(&scan_enable_sem, OSI_SEM_MAX_TIMEOUT); + if(scan_enable_status != BTM_SUCCESS) { + status = BTM_NO_RESOURCES; + } btm_cb.ble_ctr_cb.inq_var.state = BTM_BLE_SCANNING; if (p_inq->scan_type == BTM_BLE_SCAN_MODE_ACTI) { btm_ble_set_topology_mask(BTM_BLE_STATE_ACTIVE_SCAN_BIT); @@ -3445,7 +3509,7 @@ tBTM_STATUS btm_ble_start_scan(void) btm_ble_set_topology_mask(BTM_BLE_STATE_PASSIVE_SCAN_BIT); } } - + osi_mutex_unlock(&scan_enable_lock); return status; } @@ -3553,6 +3617,7 @@ static void btm_ble_stop_discover(void) tBTM_CMPL_CB *p_scan_cb = p_ble_cb->p_scan_cmpl_cb; btu_stop_timer (&p_ble_cb->scan_timer_ent); + osi_mutex_lock(&scan_enable_lock, OSI_MUTEX_MAX_TIMEOUT); p_ble_cb->scan_activity &= ~BTM_LE_DISCOVER_ACTIVE; p_ble_cb->p_scan_results_cb = NULL; @@ -3563,12 +3628,15 @@ static void btm_ble_stop_discover(void) btm_cb.ble_ctr_cb.inq_var.scan_type = BTM_BLE_SCAN_MODE_NONE; btm_cb.ble_ctr_cb.inq_var.state = BTM_BLE_STOP_SCAN; /* stop discovery now */ - btsnd_hcic_ble_set_scan_enable (BTM_BLE_SCAN_DISABLE, BTM_BLE_DUPLICATE_ENABLE); + if(btsnd_hcic_ble_set_scan_enable (BTM_BLE_SCAN_DISABLE, BTM_BLE_DUPLICATE_ENABLE)) { + osi_sem_take(&scan_enable_sem, OSI_SEM_MAX_TIMEOUT); + } } if (p_scan_cb) { (p_scan_cb)((tBTM_INQUIRY_CMPL *) &btm_cb.btm_inq_vars.inq_cmpl_info); } + osi_mutex_unlock(&scan_enable_lock); } /******************************************************************************* @@ -3634,6 +3702,8 @@ tBTM_STATUS btm_ble_start_adv(void) return BTM_WRONG_MODE; } + osi_mutex_lock(&adv_enable_lock, OSI_MUTEX_MAX_TIMEOUT); + #if (defined BLE_PRIVACY_SPT && BLE_PRIVACY_SPT == TRUE) /* To relax resolving list, always have resolving list enabled, unless directed adv */ if (p_cb->evt_type != BTM_BLE_CONNECT_LO_DUTY_DIR_EVT && @@ -3653,10 +3723,11 @@ tBTM_STATUS btm_ble_start_adv(void) tBTM_BLE_GAP_STATE temp_state = p_cb->state; UINT8 adv_mode = p_cb->adv_mode; p_cb->adv_mode = BTM_BLE_ADV_ENABLE; - p_cb->state = BTM_BLE_ADV_PENDING; + p_cb->state = BTM_BLE_ADVERTISING; btm_ble_adv_states_operation(btm_ble_set_topology_mask, p_cb->evt_type); if (btsnd_hcic_ble_set_adv_enable (BTM_BLE_ADV_ENABLE)) { - rt = BTM_SUCCESS; + osi_sem_take(&adv_enable_sem, OSI_SEM_MAX_TIMEOUT); + rt = adv_enable_status; BTM_TRACE_EVENT ("BTM_SUCCESS\n"); } else { p_cb->adv_mode = BTM_BLE_ADV_DISABLE; @@ -3665,6 +3736,11 @@ tBTM_STATUS btm_ble_start_adv(void) btm_ble_adv_states_operation(btm_ble_clear_topology_mask, p_cb->evt_type); btm_cb.ble_ctr_cb.wl_state &= ~BTM_BLE_WL_ADV; } + + if(adv_enable_status != HCI_SUCCESS) { + p_cb->adv_mode = adv_mode; + } + osi_mutex_unlock(&adv_enable_lock); return rt; } @@ -3681,8 +3757,8 @@ tBTM_STATUS btm_ble_stop_adv(void) { tBTM_BLE_INQ_CB *p_cb = &btm_cb.ble_ctr_cb.inq_var; tBTM_STATUS rt = BTM_SUCCESS; - if (p_cb->adv_mode == BTM_BLE_ADV_ENABLE) { + osi_mutex_lock(&adv_enable_lock, OSI_MUTEX_MAX_TIMEOUT); UINT8 temp_adv_mode = p_cb->adv_mode; BOOLEAN temp_fast_adv_on = p_cb->fast_adv_on; tBTM_BLE_GAP_STATE temp_state = p_cb->state; @@ -3691,14 +3767,15 @@ tBTM_STATUS btm_ble_stop_adv(void) p_cb->fast_adv_on = FALSE; p_cb->adv_mode = BTM_BLE_ADV_DISABLE; - p_cb->state = BTM_BLE_ADV_PENDING; + p_cb->state = BTM_BLE_STOP_ADV; btm_cb.ble_ctr_cb.wl_state &= ~BTM_BLE_WL_ADV; /* clear all adv states */ btm_ble_clear_topology_mask (BTM_BLE_STATE_ALL_ADV_MASK); if (btsnd_hcic_ble_set_adv_enable (BTM_BLE_ADV_DISABLE)) { - + osi_sem_take(&adv_enable_sem, OSI_SEM_MAX_TIMEOUT); + rt = adv_enable_status; } else { // reset state p_cb->fast_adv_on = temp_fast_adv_on; @@ -3709,6 +3786,10 @@ tBTM_STATUS btm_ble_stop_adv(void) rt = BTM_NO_RESOURCES; } + if(adv_enable_status != HCI_SUCCESS) { + p_cb->adv_mode = temp_adv_mode; + } + osi_mutex_unlock(&adv_enable_lock); } return rt; } @@ -3870,35 +3951,9 @@ void btm_ble_read_remote_features_complete(UINT8 *p) *******************************************************************************/ void btm_ble_write_adv_enable_complete(UINT8 *p) { - tBTM_BLE_INQ_CB *p_cb = &btm_cb.ble_ctr_cb.inq_var; - UINT8 status = *p; - - // callback to the APP after receive the adv complete from the controller. - if (p_cb->p_adv_cb && p_cb->adv_mode == BTM_BLE_ADV_ENABLE) { - if (p_cb->adv_callback_twice) { - p_cb->adv_callback_twice = FALSE; - }else { - p_cb->state = BTM_BLE_ADVERTISING; - (*p_cb->p_adv_cb)(status); - p_cb->p_adv_cb = NULL; - } - } else if (p_cb->p_stop_adv_cb && p_cb->adv_mode == BTM_BLE_ADV_DISABLE) { - p_cb->state = BTM_BLE_STOP_ADV; - (*p_cb->p_stop_adv_cb)(status); - p_cb->p_stop_adv_cb = NULL; - }else { - // p_cb->p_adv_cb is NULL or p_cb->p_stop_adv_cb is NULL - if (p_cb->adv_mode == BTM_BLE_ADV_ENABLE) { - p_cb->state = BTM_BLE_ADVERTISING; - }else { - p_cb->state = BTM_BLE_STOP_ADV; - } - p_cb->adv_callback_twice = FALSE; - } /* if write adv enable/disbale not succeed */ if (*p != HCI_SUCCESS) { - /* toggle back the adv mode */ - p_cb->adv_mode = !p_cb->adv_mode; + BTM_TRACE_ERROR("%s failed", __func__); } } diff --git a/components/bt/bluedroid/stack/btm/btm_main.c b/components/bt/bluedroid/stack/btm/btm_main.c index 579e8d6453..b6b853d5c6 100644 --- a/components/bt/bluedroid/stack/btm/btm_main.c +++ b/components/bt/bluedroid/stack/btm/btm_main.c @@ -75,6 +75,8 @@ void btm_init (void) #endif btm_dev_init(); /* Device Manager Structures & HCI_Reset */ + btm_lock_init(); + btm_sem_init(); } @@ -94,4 +96,6 @@ void btm_free(void) #if BTM_DYNAMIC_MEMORY FREE_AND_RESET(btm_cb_ptr); #endif + btm_lock_free(); + btm_sem_free(); } diff --git a/components/bt/bluedroid/stack/btm/include/btm_ble_int.h b/components/bt/bluedroid/stack/btm/include/btm_ble_int.h index b3b8ad10c2..7918a4fc16 100644 --- a/components/bt/bluedroid/stack/btm/include/btm_ble_int.h +++ b/components/bt/bluedroid/stack/btm/include/btm_ble_int.h @@ -152,7 +152,6 @@ typedef struct { tBTM_START_ADV_CMPL_CBACK *p_adv_cb; tBTM_START_STOP_ADV_CMPL_CBACK *p_stop_adv_cb; tBLE_ADDR_TYPE adv_addr_type; - BOOLEAN adv_callback_twice; UINT8 evt_type; UINT8 adv_mode; tBLE_BD_ADDR direct_bda; diff --git a/components/bt/bluedroid/stack/btm/include/btm_int.h b/components/bt/bluedroid/stack/btm/include/btm_int.h index 1dcaac4508..fbdc59c7ba 100644 --- a/components/bt/bluedroid/stack/btm/include/btm_int.h +++ b/components/bt/bluedroid/stack/btm/include/btm_int.h @@ -1135,6 +1135,14 @@ void btm_acl_paging (BT_HDR *p, BD_ADDR dest); UINT8 btm_sec_clr_service_by_psm (UINT16 psm); void btm_sec_clr_temp_auth_service (BD_ADDR bda); +void btm_lock_init(void); + +void btm_sem_init(void); + +void btm_sem_free(void); + +void btm_lock_free(void); + /* #ifdef __cplusplus } diff --git a/components/bt/bluedroid/stack/btu/btu_hcif.c b/components/bt/bluedroid/stack/btu/btu_hcif.c index 6374d0b0ae..a3bcc61b99 100644 --- a/components/bt/bluedroid/stack/btu/btu_hcif.c +++ b/components/bt/bluedroid/stack/btu/btu_hcif.c @@ -43,7 +43,7 @@ #include "common/bt_trace.h" #include "osi/thread.h" - +//#include "osi/mutex.h" // TODO(zachoverflow): remove this horrible hack #include "stack/btu.h" @@ -137,6 +137,17 @@ static void btu_ble_rc_param_req_evt(UINT8 *p); static void btu_ble_proc_enhanced_conn_cmpl (UINT8 *p, UINT16 evt_len); //#endif +extern osi_sem_t adv_enable_sem; +extern osi_sem_t adv_data_sem; +extern osi_sem_t adv_param_sem; +extern osi_sem_t scan_enable_sem; +extern osi_sem_t scan_param_sem; +extern uint8_t adv_enable_status; +extern uint8_t adv_data_status; +extern uint8_t adv_param_status; +extern uint8_t scan_enable_status; +extern uint8_t scan_param_status; + #endif /******************************************************************************* @@ -1026,6 +1037,40 @@ static void btu_hcif_command_complete_evt_on_task(BT_HDR *event) static void btu_hcif_command_complete_evt(BT_HDR *response, void *context) { +#if (BLE_INCLUDED == TRUE) + command_opcode_t opcode; + uint8_t *stream = response->data + response->offset + 3; + STREAM_TO_UINT16(opcode, stream); + switch (opcode) { + case HCI_BLE_WRITE_ADV_DATA: + adv_data_status = *stream; + osi_sem_give(&adv_data_sem); + break; + case HCI_BLE_WRITE_SCAN_RSP_DATA: + adv_data_status = *stream; + osi_sem_give(&adv_data_sem); + break; + case HCI_BLE_WRITE_ADV_ENABLE: { + adv_enable_status = *stream; + osi_sem_give(&adv_enable_sem); + break; + } + case HCI_BLE_WRITE_ADV_PARAMS: + adv_param_status = *stream; + osi_sem_give(&adv_param_sem); + break; + case HCI_BLE_WRITE_SCAN_PARAMS: + scan_param_status = *stream; + osi_sem_give(&scan_param_sem); + break; + case HCI_BLE_WRITE_SCAN_ENABLE: + scan_enable_status = *stream; + osi_sem_give(&scan_enable_sem); + break; + default: + break; + } +#endif BT_HDR *event = osi_calloc(sizeof(BT_HDR) + sizeof(command_complete_hack_t)); command_complete_hack_t *hack = (command_complete_hack_t *)&event->data[0]; diff --git a/components/bt/bluedroid/stack/include/stack/btm_ble_api.h b/components/bt/bluedroid/stack/include/stack/btm_ble_api.h index e0d67ee63b..2b5a107bb4 100644 --- a/components/bt/bluedroid/stack/include/stack/btm_ble_api.h +++ b/components/bt/bluedroid/stack/include/stack/btm_ble_api.h @@ -949,7 +949,7 @@ tBTM_STATUS BTM_BleSetAdvParams(UINT16 adv_int_min, UINT16 adv_int_max, /******************************************************************************* ** -** Function BTM_BleSetAdvParamsStartAdv +** Function BTM_BleSetAdvParamsAll ** ** Description This function is called to set all of the advertising parameters. ** @@ -958,10 +958,23 @@ tBTM_STATUS BTM_BleSetAdvParams(UINT16 adv_int_min, UINT16 adv_int_max, ** Returns void ** *******************************************************************************/ -tBTM_STATUS BTM_BleSetAdvParamsStartAdv(UINT16 adv_int_min, UINT16 adv_int_max, UINT8 adv_type, +tBTM_STATUS BTM_BleSetAdvParamsAll(UINT16 adv_int_min, UINT16 adv_int_max, UINT8 adv_type, tBLE_ADDR_TYPE own_bda_type, tBLE_BD_ADDR *p_dir_bda, tBTM_BLE_ADV_CHNL_MAP chnl_map, tBTM_BLE_AFP afp, tBTM_START_ADV_CMPL_CBACK *adv_cb); +/******************************************************************************* +** +** Function BTM_BleStartAdv +** +** Description This function is called to start adv. +** +** Parameters: None. +** +** Returns status +** +*******************************************************************************/ +tBTM_STATUS BTM_BleStartAdv(void); + /******************************************************************************* ** @@ -1071,9 +1084,9 @@ void BTM_BleSetScanParams(tGATT_IF client_if, UINT32 scan_interval, ** Returns void ** *******************************************************************************/ -void BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 scan_window, - tBLE_SCAN_MODE scan_mode, UINT8 addr_type_own, UINT8 scan_duplicate_filter, tBTM_BLE_SFP scan_filter_policy, - tBLE_SCAN_PARAM_SETUP_CBACK scan_setup_status_cback); +tBTM_STATUS BTM_BleSetScanFilterParams(tGATT_IF client_if, UINT32 scan_interval, UINT32 scan_window, + tBLE_SCAN_MODE scan_mode, UINT8 addr_type_own, UINT8 scan_duplicate_filter, tBTM_BLE_SFP scan_filter_policy, + tBLE_SCAN_PARAM_SETUP_CBACK scan_setup_status_cback); /*******************************************************************************