1 /******************************************************************************
2 *
3 * Copyright 2004-2012 Broadcom Corporation
4 *
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at:
8 *
9 * http://www.apache.org/licenses/LICENSE-2.0
10 *
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 *
17 ******************************************************************************/
18
19 /******************************************************************************
20 *
21 * This file contains the audio gateway functions controlling the RFCOMM
22 * connections.
23 *
24 ******************************************************************************/
25
26 #include <cstring>
27
28 #include <base/bind.h>
29
30 #include "bt_common.h"
31 #include "bta_ag_api.h"
32 #include "bta_ag_int.h"
33 #include "btm_api.h"
34 #include "osi/include/osi.h"
35 #include "port_api.h"
36 #include "rfcdefs.h"
37 #include "utl.h"
38
39 /* Event mask for RfCOMM port callback */
40 #define BTA_AG_PORT_EV_MASK PORT_EV_RXCHAR
41
42 /* each scb has its own rfcomm callbacks */
43 void bta_ag_port_cback_1(uint32_t code, uint16_t port_handle);
44 void bta_ag_port_cback_2(uint32_t code, uint16_t port_handle);
45 void bta_ag_port_cback_3(uint32_t code, uint16_t port_handle);
46 void bta_ag_port_cback_4(uint32_t code, uint16_t port_handle);
47 void bta_ag_port_cback_5(uint32_t code, uint16_t port_handle);
48 void bta_ag_port_cback_6(uint32_t code, uint16_t port_handle);
49 void bta_ag_mgmt_cback_1(uint32_t code, uint16_t port_handle);
50 void bta_ag_mgmt_cback_2(uint32_t code, uint16_t port_handle);
51 void bta_ag_mgmt_cback_3(uint32_t code, uint16_t port_handle);
52 void bta_ag_mgmt_cback_4(uint32_t code, uint16_t port_handle);
53 void bta_ag_mgmt_cback_5(uint32_t code, uint16_t port_handle);
54 void bta_ag_mgmt_cback_6(uint32_t code, uint16_t port_handle);
55
56 /* rfcomm callback function tables */
57 typedef tPORT_CALLBACK* tBTA_AG_PORT_CBACK;
58 const tBTA_AG_PORT_CBACK bta_ag_port_cback_tbl[] = {
59 bta_ag_port_cback_1, bta_ag_port_cback_2, bta_ag_port_cback_3,
60 bta_ag_port_cback_4, bta_ag_port_cback_5, bta_ag_port_cback_6};
61
62 const tBTA_AG_PORT_CBACK bta_ag_mgmt_cback_tbl[] = {
63 bta_ag_mgmt_cback_1, bta_ag_mgmt_cback_2, bta_ag_mgmt_cback_3,
64 bta_ag_mgmt_cback_4, bta_ag_mgmt_cback_5, bta_ag_mgmt_cback_6};
65
66 /*******************************************************************************
67 *
68 * Function bta_ag_port_cback
69 *
70 * Description RFCOMM Port callback
71 *
72 *
73 * Returns void
74 *
75 ******************************************************************************/
bta_ag_port_cback(UNUSED_ATTR uint32_t code,uint16_t port_handle,uint16_t handle)76 static void bta_ag_port_cback(UNUSED_ATTR uint32_t code, uint16_t port_handle,
77 uint16_t handle) {
78 tBTA_AG_SCB* p_scb = bta_ag_scb_by_idx(handle);
79 if (p_scb != nullptr) {
80 /* ignore port events for port handles other than connected handle */
81 if (port_handle != p_scb->conn_handle) {
82 APPL_TRACE_ERROR(
83 "ag_port_cback ignoring handle:%d conn_handle = %d other handle = %d",
84 port_handle, p_scb->conn_handle, handle);
85 return;
86 }
87 if (!bta_ag_scb_open(p_scb)) {
88 LOG(ERROR) << __func__ << ": rfcomm data on an unopened control block "
89 << handle << " peer_addr " << p_scb->peer_addr << " state "
90 << std::to_string(p_scb->state);
91 }
92 do_in_bta_thread(FROM_HERE,
93 base::Bind(&bta_ag_sm_execute_by_handle, handle,
94 BTA_AG_RFC_DATA_EVT, tBTA_AG_DATA::kEmpty));
95 }
96 }
97
98 /*******************************************************************************
99 *
100 * Function bta_ag_mgmt_cback
101 *
102 * Description RFCOMM management callback
103 *
104 *
105 * Returns void
106 *
107 ******************************************************************************/
bta_ag_mgmt_cback(uint32_t code,uint16_t port_handle,uint16_t handle)108 static void bta_ag_mgmt_cback(uint32_t code, uint16_t port_handle,
109 uint16_t handle) {
110 tBTA_AG_SCB* p_scb = bta_ag_scb_by_idx(handle);
111 APPL_TRACE_DEBUG("%s: code=%d, port_handle=%d, scb_handle=%d, p_scb=0x%08x",
112 __func__, code, port_handle, handle, p_scb);
113 if (p_scb == nullptr) {
114 LOG(WARNING) << __func__ << ": cannot find scb, code=" << code
115 << ", port_handle=" << port_handle << ", handle=" << handle;
116 return;
117 }
118 /* ignore close event for port handles other than connected handle */
119 if ((code != PORT_SUCCESS) && (port_handle != p_scb->conn_handle)) {
120 LOG(WARNING) << __func__ << ": ignore open failure for unmatched "
121 << "port_handle " << port_handle << ", scb_handle=" << handle;
122 return;
123 }
124 uint16_t event;
125 if (code == PORT_SUCCESS) {
126 bool found_handle = false;
127 if (p_scb->conn_handle) {
128 /* Outgoing connection */
129 if (port_handle == p_scb->conn_handle) {
130 found_handle = true;
131 }
132 } else {
133 /* Incoming connection */
134 for (uint16_t service_port_handle : p_scb->serv_handle) {
135 if (port_handle == service_port_handle) {
136 found_handle = true;
137 break;
138 }
139 }
140 }
141 if (!found_handle) {
142 LOG(ERROR) << __func__ << ": port opened successfully, but port_handle "
143 << port_handle << " is unknown"
144 << ", scb_handle=" << handle;
145 return;
146 }
147 event = BTA_AG_RFC_OPEN_EVT;
148 } else if (port_handle == p_scb->conn_handle) {
149 /* distinguish server close events */
150 event = BTA_AG_RFC_CLOSE_EVT;
151 } else {
152 event = BTA_AG_RFC_SRV_CLOSE_EVT;
153 }
154
155 tBTA_AG_DATA data = {};
156 data.rfc.port_handle = port_handle;
157 do_in_bta_thread(
158 FROM_HERE, base::Bind(&bta_ag_sm_execute_by_handle, handle, event, data));
159 }
160
161 /*******************************************************************************
162 *
163 * Function bta_ag_port_cback_1 to 6
164 * bta_ag_mgmt_cback_1 to 6
165 *
166 * Description RFCOMM callback functions. This is an easy way to
167 * distinguish scb from the callback.
168 *
169 *
170 * Returns void
171 *
172 ******************************************************************************/
bta_ag_mgmt_cback_1(uint32_t code,uint16_t port_handle)173 void bta_ag_mgmt_cback_1(uint32_t code, uint16_t port_handle) {
174 bta_ag_mgmt_cback(code, port_handle, 1);
175 }
bta_ag_mgmt_cback_2(uint32_t code,uint16_t port_handle)176 void bta_ag_mgmt_cback_2(uint32_t code, uint16_t port_handle) {
177 bta_ag_mgmt_cback(code, port_handle, 2);
178 }
bta_ag_mgmt_cback_3(uint32_t code,uint16_t port_handle)179 void bta_ag_mgmt_cback_3(uint32_t code, uint16_t port_handle) {
180 bta_ag_mgmt_cback(code, port_handle, 3);
181 }
bta_ag_mgmt_cback_4(uint32_t code,uint16_t port_handle)182 void bta_ag_mgmt_cback_4(uint32_t code, uint16_t port_handle) {
183 bta_ag_mgmt_cback(code, port_handle, 4);
184 }
bta_ag_mgmt_cback_5(uint32_t code,uint16_t port_handle)185 void bta_ag_mgmt_cback_5(uint32_t code, uint16_t port_handle) {
186 bta_ag_mgmt_cback(code, port_handle, 5);
187 }
bta_ag_mgmt_cback_6(uint32_t code,uint16_t port_handle)188 void bta_ag_mgmt_cback_6(uint32_t code, uint16_t port_handle) {
189 bta_ag_mgmt_cback(code, port_handle, 6);
190 }
bta_ag_port_cback_1(uint32_t code,uint16_t port_handle)191 void bta_ag_port_cback_1(uint32_t code, uint16_t port_handle) {
192 bta_ag_port_cback(code, port_handle, 1);
193 }
bta_ag_port_cback_2(uint32_t code,uint16_t port_handle)194 void bta_ag_port_cback_2(uint32_t code, uint16_t port_handle) {
195 bta_ag_port_cback(code, port_handle, 2);
196 }
bta_ag_port_cback_3(uint32_t code,uint16_t port_handle)197 void bta_ag_port_cback_3(uint32_t code, uint16_t port_handle) {
198 bta_ag_port_cback(code, port_handle, 3);
199 }
bta_ag_port_cback_4(uint32_t code,uint16_t port_handle)200 void bta_ag_port_cback_4(uint32_t code, uint16_t port_handle) {
201 bta_ag_port_cback(code, port_handle, 4);
202 }
bta_ag_port_cback_5(uint32_t code,uint16_t port_handle)203 void bta_ag_port_cback_5(uint32_t code, uint16_t port_handle) {
204 bta_ag_port_cback(code, port_handle, 5);
205 }
bta_ag_port_cback_6(uint32_t code,uint16_t port_handle)206 void bta_ag_port_cback_6(uint32_t code, uint16_t port_handle) {
207 bta_ag_port_cback(code, port_handle, 6);
208 }
209
210 /*******************************************************************************
211 *
212 * Function bta_ag_setup_port
213 *
214 * Description Setup RFCOMM port for use by AG.
215 *
216 *
217 * Returns void
218 *
219 ******************************************************************************/
bta_ag_setup_port(tBTA_AG_SCB * p_scb,uint16_t handle)220 void bta_ag_setup_port(tBTA_AG_SCB* p_scb, uint16_t handle) {
221 int port_callback_index = bta_ag_scb_to_idx(p_scb) - 1;
222 CHECK_GE(port_callback_index, 0)
223 << "invalid callback index, handle=" << handle << ", bd_addr"
224 << p_scb->peer_addr;
225 CHECK_LT(port_callback_index,
226 static_cast<int>(sizeof(bta_ag_port_cback_tbl) /
227 sizeof(bta_ag_port_cback_tbl[0])))
228 << "callback index out of bound, handle=" << handle << ", bd_addr"
229 << p_scb->peer_addr;
230 PORT_SetEventMask(handle, BTA_AG_PORT_EV_MASK);
231 PORT_SetEventCallback(handle, bta_ag_port_cback_tbl[port_callback_index]);
232 }
233
234 /*******************************************************************************
235 *
236 * Function bta_ag_start_servers
237 *
238 * Description Setup RFCOMM servers for use by AG.
239 *
240 *
241 * Returns void
242 *
243 ******************************************************************************/
bta_ag_start_servers(tBTA_AG_SCB * p_scb,tBTA_SERVICE_MASK services)244 void bta_ag_start_servers(tBTA_AG_SCB* p_scb, tBTA_SERVICE_MASK services) {
245 services >>= BTA_HSP_SERVICE_ID;
246 for (int i = 0; i < BTA_AG_NUM_IDX && services != 0; i++, services >>= 1) {
247 /* if service is set in mask */
248 if (services & 1) {
249 BTM_SetSecurityLevel(false, "", bta_ag_sec_id[i], p_scb->serv_sec_mask,
250 BT_PSM_RFCOMM, BTM_SEC_PROTO_RFCOMM,
251 bta_ag_cb.profile[i].scn);
252 int management_callback_index = bta_ag_scb_to_idx(p_scb) - 1;
253 CHECK_GE(management_callback_index, 0)
254 << "invalid callback index, services=" << loghex(services)
255 << ", bd_addr=" << p_scb->peer_addr;
256 CHECK_LT(management_callback_index,
257 static_cast<int>(sizeof(bta_ag_mgmt_cback_tbl) /
258 sizeof(bta_ag_mgmt_cback_tbl[0])))
259 << "callback index out of bound, services=" << loghex(services)
260 << ", bd_addr" << p_scb->peer_addr;
261 int status = RFCOMM_CreateConnection(
262 bta_ag_uuid[i], bta_ag_cb.profile[i].scn, true, BTA_AG_MTU,
263 RawAddress::kAny, &(p_scb->serv_handle[i]),
264 bta_ag_mgmt_cback_tbl[management_callback_index]);
265 if (status == PORT_SUCCESS) {
266 bta_ag_setup_port(p_scb, p_scb->serv_handle[i]);
267 } else {
268 /* TODO: CR#137125 to handle to error properly */
269 LOG(ERROR) << __func__ << ": RFCOMM_CreateConnection ERROR " << status
270 << ", p_scb=" << p_scb << ", services=" << loghex(services)
271 << ", mgmt_cback_index=" << management_callback_index;
272 }
273 APPL_TRACE_DEBUG("%s: p_scb=0x%08x, services=0x%04x, mgmt_cback_index=%d",
274 __func__, p_scb, services, management_callback_index);
275 }
276 }
277 }
278
279 /*******************************************************************************
280 *
281 * Function bta_ag_close_servers
282 *
283 * Description Close RFCOMM servers port for use by AG.
284 *
285 *
286 * Returns void
287 *
288 ******************************************************************************/
bta_ag_close_servers(tBTA_AG_SCB * p_scb,tBTA_SERVICE_MASK services)289 void bta_ag_close_servers(tBTA_AG_SCB* p_scb, tBTA_SERVICE_MASK services) {
290 services >>= BTA_HSP_SERVICE_ID;
291 for (int i = 0; i < BTA_AG_NUM_IDX && services != 0; i++, services >>= 1) {
292 /* if service is set in mask */
293 if (services & 1) {
294 RFCOMM_RemoveServer(p_scb->serv_handle[i]);
295 p_scb->serv_handle[i] = 0;
296 }
297 }
298 }
299
300 /*******************************************************************************
301 *
302 * Function bta_ag_is_server_closed
303 *
304 * Description Returns true if all servers are closed.
305 *
306 *
307 * Returns true if all servers are closed, false otherwise
308 *
309 ******************************************************************************/
bta_ag_is_server_closed(tBTA_AG_SCB * p_scb)310 bool bta_ag_is_server_closed(tBTA_AG_SCB* p_scb) {
311 uint8_t xx;
312 bool is_closed = true;
313
314 for (xx = 0; xx < BTA_AG_NUM_IDX; xx++) {
315 if (p_scb->serv_handle[xx] != 0) is_closed = false;
316 }
317
318 return is_closed;
319 }
320
321 /*******************************************************************************
322 *
323 * Function bta_ag_rfc_do_open
324 *
325 * Description Open an RFCOMM connection to the peer device.
326 *
327 *
328 * Returns void
329 *
330 ******************************************************************************/
bta_ag_rfc_do_open(tBTA_AG_SCB * p_scb,const tBTA_AG_DATA & data)331 void bta_ag_rfc_do_open(tBTA_AG_SCB* p_scb, const tBTA_AG_DATA& data) {
332 BTM_SetSecurityLevel(true, "", bta_ag_sec_id[p_scb->conn_service],
333 p_scb->cli_sec_mask, BT_PSM_RFCOMM, BTM_SEC_PROTO_RFCOMM,
334 p_scb->peer_scn);
335
336 int management_callback_index = bta_ag_scb_to_idx(p_scb) - 1;
337 int status = RFCOMM_CreateConnection(
338 bta_ag_uuid[p_scb->conn_service], p_scb->peer_scn, false, BTA_AG_MTU,
339 p_scb->peer_addr, &(p_scb->conn_handle),
340 bta_ag_mgmt_cback_tbl[management_callback_index]);
341 APPL_TRACE_DEBUG(
342 "%s: p_scb=0x%08x, conn_handle=%d, mgmt_cback_index=%d,"
343 " status=%d",
344 __func__, p_scb, p_scb->conn_handle, management_callback_index, status);
345 if (status == PORT_SUCCESS) {
346 bta_ag_setup_port(p_scb, p_scb->conn_handle);
347 } else {
348 /* RFCOMM create connection failed; send ourselves RFCOMM close event */
349 LOG(ERROR) << __func__ << ": RFCOMM_CreateConnection ERROR " << status
350 << " for " << p_scb->peer_addr;
351 bta_ag_sm_execute(p_scb, BTA_AG_RFC_CLOSE_EVT, data);
352 }
353 }
354
355 /*******************************************************************************
356 *
357 * Function bta_ag_rfc_do_close
358 *
359 * Description Close RFCOMM connection.
360 *
361 *
362 * Returns void
363 *
364 ******************************************************************************/
bta_ag_rfc_do_close(tBTA_AG_SCB * p_scb,UNUSED_ATTR const tBTA_AG_DATA & data)365 void bta_ag_rfc_do_close(tBTA_AG_SCB* p_scb,
366 UNUSED_ATTR const tBTA_AG_DATA& data) {
367 if (p_scb->conn_handle) {
368 RFCOMM_RemoveConnection(p_scb->conn_handle);
369 } else {
370 /* Close API was called while AG is in Opening state. */
371 /* Need to trigger the state machine to send callback to the app */
372 /* and move back to INIT state. */
373 do_in_bta_thread(
374 FROM_HERE,
375 base::Bind(&bta_ag_sm_execute_by_handle, bta_ag_scb_to_idx(p_scb),
376 BTA_AG_RFC_CLOSE_EVT, tBTA_AG_DATA::kEmpty));
377
378 /* Cancel SDP if it had been started. */
379 /*
380 if(p_scb->p_disc_db)
381 {
382 (void)SDP_CancelServiceSearch (p_scb->p_disc_db);
383 }
384 */
385 }
386 }
387