/******************************************************************************
*
* Copyright (c) 2014 The Android Open Source Project
* Copyright 2004-2012 Broadcom Corporation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
******************************************************************************/
/******************************************************************************
*
* This file contains the audio gateway functions controlling the RFCOMM
* connections.
*
******************************************************************************/
#include <base/logging.h>
#include <string.h>
#include "bt_utils.h"
#include "bta_api.h"
#include "bta_hf_client_int.h"
#include "osi/include/osi.h"
#include "port_api.h"
/*******************************************************************************
*
* Function bta_hf_client_port_cback
*
* Description RFCOMM Port callback. The handle in this function is
* specified by BTA layer via the PORT_SetEventCallback
* method
*
* Returns void
*
******************************************************************************/
static void bta_hf_client_port_cback(UNUSED_ATTR uint32_t code,
uint16_t port_handle) {
/* ignore port events for port handles other than connected handle */
tBTA_HF_CLIENT_CB* client_cb =
bta_hf_client_find_cb_by_rfc_handle(port_handle);
if (client_cb == NULL) {
APPL_TRACE_ERROR("%s: cb not found for handle %d", __func__, port_handle);
return;
}
tBTA_HF_CLIENT_RFC* p_buf =
(tBTA_HF_CLIENT_RFC*)osi_malloc(sizeof(tBTA_HF_CLIENT_RFC));
p_buf->hdr.event = BTA_HF_CLIENT_RFC_DATA_EVT;
p_buf->hdr.layer_specific = client_cb->handle;
bta_sys_sendmsg(p_buf);
}
/*******************************************************************************
*
* Function bta_hf_client_mgmt_cback
*
* Description RFCOMM management callback
*
*
* Returns void
*
******************************************************************************/
static void bta_hf_client_mgmt_cback(uint32_t code, uint16_t port_handle) {
tBTA_HF_CLIENT_CB* client_cb =
bta_hf_client_find_cb_by_rfc_handle(port_handle);
APPL_TRACE_DEBUG("%s: code = %d, port_handle = %d serv = %d", __func__, code,
port_handle, bta_hf_client_cb_arr.serv_handle);
/* ignore close event for port handles other than connected handle */
if (code != PORT_SUCCESS && client_cb != NULL &&
port_handle != client_cb->conn_handle) {
APPL_TRACE_DEBUG("bta_hf_client_mgmt_cback ignoring handle:%d",
port_handle);
return;
}
tBTA_HF_CLIENT_RFC* p_buf =
(tBTA_HF_CLIENT_RFC*)osi_malloc(sizeof(tBTA_HF_CLIENT_RFC));
if (code == PORT_SUCCESS) {
if (client_cb && port_handle == client_cb->conn_handle) { /* out conn */
p_buf->hdr.event = BTA_HF_CLIENT_RFC_OPEN_EVT;
} else if (port_handle == bta_hf_client_cb_arr.serv_handle) {
p_buf->hdr.event = BTA_HF_CLIENT_RFC_OPEN_EVT;
APPL_TRACE_DEBUG("%s: allocating a new CB for incoming connection",
__func__);
// Find the BDADDR of the peer device
RawAddress peer_addr;
uint16_t lcid;
PORT_CheckConnection(port_handle, peer_addr, &lcid);
// Since we accepted a remote request we should allocate a handle first.
uint16_t tmp_handle = -1;
bta_hf_client_allocate_handle(peer_addr, &tmp_handle);
client_cb = bta_hf_client_find_cb_by_handle(tmp_handle);
// If allocation fails then we abort.
if (client_cb == NULL) {
APPL_TRACE_ERROR("%s: error allocating a new handle", __func__);
p_buf->hdr.event = BTA_HF_CLIENT_RFC_CLOSE_EVT;
} else {
// Set the connection fields for this new CB
client_cb->conn_handle = port_handle;
// Since we have accepted an incoming RFCOMM connection:
// a) Release the current server from it duties
// b) Start a new server for more new incoming connection
bta_hf_client_cb_arr.serv_handle = 0;
bta_hf_client_start_server();
}
} else {
APPL_TRACE_ERROR("%s: PORT_SUCCESS, ignoring handle = %d", __func__,
port_handle);
return;
}
} else if (client_cb != NULL &&
port_handle == client_cb->conn_handle) { /* code != PORT_SUC */
LOG(ERROR) << __func__ << ": closing port handle " << port_handle << "dev "
<< client_cb->peer_addr;
RFCOMM_RemoveServer(port_handle);
p_buf->hdr.event = BTA_HF_CLIENT_RFC_CLOSE_EVT;
}
p_buf->hdr.layer_specific = client_cb != NULL ? client_cb->handle : 0;
bta_sys_sendmsg(p_buf);
}
/*******************************************************************************
*
* Function bta_hf_client_setup_port
*
* Description Setup RFCOMM port for use by HF Client.
*
*
* Returns void
*
******************************************************************************/
void bta_hf_client_setup_port(uint16_t handle) {
PORT_SetEventMask(handle, PORT_EV_RXCHAR);
PORT_SetEventCallback(handle, bta_hf_client_port_cback);
}
/*******************************************************************************
*
* Function bta_hf_client_start_server
*
* Description Setup RFCOMM server for use by HF Client.
*
*
* Returns void
*
******************************************************************************/
void bta_hf_client_start_server() {
int port_status;
if (bta_hf_client_cb_arr.serv_handle > 0) {
APPL_TRACE_DEBUG("%s: already started, handle: %d", __func__,
bta_hf_client_cb_arr.serv_handle);
return;
}
BTM_SetSecurityLevel(false, "", BTM_SEC_SERVICE_HF_HANDSFREE,
bta_hf_client_cb_arr.serv_sec_mask, BT_PSM_RFCOMM,
BTM_SEC_PROTO_RFCOMM, bta_hf_client_cb_arr.scn);
port_status = RFCOMM_CreateConnection(
UUID_SERVCLASS_HF_HANDSFREE, bta_hf_client_cb_arr.scn, true,
BTA_HF_CLIENT_MTU, RawAddress::kAny, &(bta_hf_client_cb_arr.serv_handle),
bta_hf_client_mgmt_cback);
APPL_TRACE_DEBUG("%s: started rfcomm server with handle %d", __func__,
bta_hf_client_cb_arr.serv_handle);
if (port_status == PORT_SUCCESS) {
bta_hf_client_setup_port(bta_hf_client_cb_arr.serv_handle);
} else {
APPL_TRACE_DEBUG("%s: RFCOMM_CreateConnection returned error:%d", __func__,
port_status);
}
}
/*******************************************************************************
*
* Function bta_hf_client_close_server
*
* Description Close RFCOMM server port for use by HF Client.
*
*
* Returns void
*
******************************************************************************/
void bta_hf_client_close_server() {
APPL_TRACE_DEBUG("%s: %d", __func__, bta_hf_client_cb_arr.serv_handle);
if (bta_hf_client_cb_arr.serv_handle == 0) {
APPL_TRACE_DEBUG("%s: already stopped", __func__);
return;
}
RFCOMM_RemoveServer(bta_hf_client_cb_arr.serv_handle);
bta_hf_client_cb_arr.serv_handle = 0;
}
/*******************************************************************************
*
* Function bta_hf_client_rfc_do_open
*
* Description Open an RFCOMM connection to the peer device.
*
*
* Returns void
*
******************************************************************************/
void bta_hf_client_rfc_do_open(tBTA_HF_CLIENT_DATA* p_data) {
tBTA_HF_CLIENT_CB* client_cb =
bta_hf_client_find_cb_by_handle(p_data->hdr.layer_specific);
if (client_cb == NULL) {
APPL_TRACE_ERROR("%s: cb not found for handle %d", __func__,
p_data->hdr.layer_specific);
return;
}
BTM_SetSecurityLevel(true, "", BTM_SEC_SERVICE_HF_HANDSFREE,
client_cb->cli_sec_mask, BT_PSM_RFCOMM,
BTM_SEC_PROTO_RFCOMM, client_cb->peer_scn);
if (RFCOMM_CreateConnection(UUID_SERVCLASS_HF_HANDSFREE, client_cb->peer_scn,
false, BTA_HF_CLIENT_MTU, client_cb->peer_addr,
&(client_cb->conn_handle),
bta_hf_client_mgmt_cback) == PORT_SUCCESS) {
bta_hf_client_setup_port(client_cb->conn_handle);
APPL_TRACE_DEBUG("bta_hf_client_rfc_do_open : conn_handle = %d",
client_cb->conn_handle);
}
/* RFCOMM create connection failed; send ourselves RFCOMM close event */
else {
bta_hf_client_sm_execute(BTA_HF_CLIENT_RFC_CLOSE_EVT, p_data);
}
}
/*******************************************************************************
*
* Function bta_hf_client_rfc_do_close
*
* Description Close RFCOMM connection.
*
*
* Returns void
*
******************************************************************************/
void bta_hf_client_rfc_do_close(tBTA_HF_CLIENT_DATA* p_data) {
tBTA_HF_CLIENT_CB* client_cb =
bta_hf_client_find_cb_by_handle(p_data->hdr.layer_specific);
if (client_cb == NULL) {
APPL_TRACE_ERROR("%s: cb not found for handle %d", __func__,
p_data->hdr.layer_specific);
return;
}
if (client_cb->conn_handle) {
RFCOMM_RemoveConnection(client_cb->conn_handle);
} else {
/* Close API was called while HF Client is in Opening state. */
/* Need to trigger the state machine to send callback to the app */
/* and move back to INIT state. */
tBTA_HF_CLIENT_RFC* p_buf =
(tBTA_HF_CLIENT_RFC*)osi_malloc(sizeof(tBTA_HF_CLIENT_RFC));
p_buf->hdr.event = BTA_HF_CLIENT_RFC_CLOSE_EVT;
bta_sys_sendmsg(p_buf);
/* Cancel SDP if it had been started. */
if (client_cb->p_disc_db) {
(void)SDP_CancelServiceSearch(client_cb->p_disc_db);
osi_free_and_reset((void**)&client_cb->p_disc_db);
}
}
}