1 /******************************************************************************
2  *
3  *  Copyright (C) 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 <string.h>
27 #include "bta_api.h"
28 #include "bta_sys.h"
29 #include "bta_ag_api.h"
30 #include "bta_ag_int.h"
31 #include "bta_ag_co.h"
32 #include "btm_api.h"
33 #include "port_api.h"
34 #include "rfcdefs.h"
35 #include "gki.h"
36 #include "utl.h"
37 
38 /* Event mask for RfCOMM port callback */
39 #define BTA_AG_PORT_EV_MASK         PORT_EV_RXCHAR
40 
41 /* each scb has its own rfcomm callbacks */
42 void bta_ag_port_cback_1(UINT32 code, UINT16 port_handle);
43 void bta_ag_port_cback_2(UINT32 code, UINT16 port_handle);
44 void bta_ag_port_cback_3(UINT32 code, UINT16 port_handle);
45 
46 void bta_ag_mgmt_cback_1(UINT32 code, UINT16 port_handle);
47 void bta_ag_mgmt_cback_2(UINT32 code, UINT16 port_handle);
48 void bta_ag_mgmt_cback_3(UINT32 code, UINT16 port_handle);
49 
50 int bta_ag_data_cback_1(UINT16 port_handle, void *p_data, UINT16 len);
51 int bta_ag_data_cback_2(UINT16 port_handle, void *p_data, UINT16 len);
52 int bta_ag_data_cback_3(UINT16 port_handle, void *p_data, UINT16 len);
53 
54 /* rfcomm callback function tables */
55 typedef tPORT_CALLBACK *tBTA_AG_PORT_CBACK;
56 const tBTA_AG_PORT_CBACK bta_ag_port_cback_tbl[] =
57 {
58     bta_ag_port_cback_1,
59     bta_ag_port_cback_2,
60     bta_ag_port_cback_3
61 };
62 
63 const tBTA_AG_PORT_CBACK bta_ag_mgmt_cback_tbl[] =
64 {
65     bta_ag_mgmt_cback_1,
66     bta_ag_mgmt_cback_2,
67     bta_ag_mgmt_cback_3
68 };
69 
70 typedef tPORT_DATA_CALLBACK *tBTA_AG_DATA_CBACK;
71 const tBTA_AG_DATA_CBACK bta_ag_data_cback_tbl[] =
72 {
73     bta_ag_data_cback_1,
74     bta_ag_data_cback_2,
75     bta_ag_data_cback_3
76 };
77 
78 /*******************************************************************************
79 **
80 ** Function         bta_ag_port_cback
81 **
82 ** Description      RFCOMM Port callback
83 **
84 **
85 ** Returns          void
86 **
87 *******************************************************************************/
bta_ag_port_cback(UINT32 code,UINT16 port_handle,UINT16 handle)88 static void bta_ag_port_cback(UINT32 code, UINT16 port_handle, UINT16 handle)
89 {
90     BT_HDR      *p_buf;
91     tBTA_AG_SCB *p_scb;
92     UNUSED(code);
93 
94     if ((p_scb = bta_ag_scb_by_idx(handle)) != NULL)
95     {
96         /* ignore port events for port handles other than connected handle */
97         if (port_handle != p_scb->conn_handle)
98         {
99             APPL_TRACE_DEBUG("ag_port_cback ignoring handle:%d conn_handle = %d other handle = %d",
100                               port_handle, p_scb->conn_handle, handle);
101             return;
102         }
103 
104         if ((p_buf = (BT_HDR *) GKI_getbuf(sizeof(BT_HDR))) != NULL)
105         {
106             p_buf->event = BTA_AG_RFC_DATA_EVT;
107             p_buf->layer_specific = handle;
108             bta_sys_sendmsg(p_buf);
109         }
110     }
111 }
112 
113 /*******************************************************************************
114 **
115 ** Function         bta_ag_mgmt_cback
116 **
117 ** Description      RFCOMM management callback
118 **
119 **
120 ** Returns          void
121 **
122 *******************************************************************************/
bta_ag_mgmt_cback(UINT32 code,UINT16 port_handle,UINT16 handle)123 static void bta_ag_mgmt_cback(UINT32 code, UINT16 port_handle, UINT16 handle)
124 {
125     tBTA_AG_RFC     *p_buf;
126     tBTA_AG_SCB     *p_scb;
127     UINT16          event;
128     UINT8           i;
129     BOOLEAN         found_handle = FALSE;
130 
131     APPL_TRACE_DEBUG("ag_mgmt_cback : code = %d, port_handle = %d, handle = %d",
132                         code, port_handle, handle);
133 
134     if ((p_scb = bta_ag_scb_by_idx(handle)) != NULL)
135     {
136         /* ignore close event for port handles other than connected handle */
137         if ((code != PORT_SUCCESS) && (port_handle != p_scb->conn_handle))
138         {
139             APPL_TRACE_DEBUG("ag_mgmt_cback ignoring handle:%d", port_handle);
140             return;
141         }
142 
143         if (code == PORT_SUCCESS)
144         {
145             if (p_scb->conn_handle)     /* Outgoing connection */
146             {
147                 if (port_handle == p_scb->conn_handle)
148                     found_handle = TRUE;
149             }
150             else                        /* Incoming connection */
151             {
152                 for (i = 0; i < BTA_AG_NUM_IDX; i++)
153                 {
154                     if (port_handle == p_scb->serv_handle[i])
155                         found_handle = TRUE;
156                 }
157             }
158 
159             if (!found_handle)
160             {
161                 APPL_TRACE_ERROR ("bta_ag_mgmt_cback: PORT_SUCCESS, ignoring handle = %d", port_handle);
162                 return;
163             }
164 
165             event = BTA_AG_RFC_OPEN_EVT;
166         }
167         /* distinguish server close events */
168         else if (port_handle == p_scb->conn_handle)
169         {
170             event = BTA_AG_RFC_CLOSE_EVT;
171         }
172         else
173         {
174             event = BTA_AG_RFC_SRV_CLOSE_EVT;
175         }
176 
177         if ((p_buf = (tBTA_AG_RFC *) GKI_getbuf(sizeof(tBTA_AG_RFC))) != NULL)
178         {
179             p_buf->hdr.event = event;
180             p_buf->hdr.layer_specific = handle;
181             p_buf->port_handle = port_handle;
182             bta_sys_sendmsg(p_buf);
183         }
184     }
185 }
186 
187 /*******************************************************************************
188 **
189 ** Function         bta_ag_data_cback
190 **
191 ** Description      RFCOMM data callback
192 **
193 **
194 ** Returns          void
195 **
196 *******************************************************************************/
bta_ag_data_cback(UINT16 port_handle,void * p_data,UINT16 len,UINT16 handle)197 static int bta_ag_data_cback(UINT16 port_handle, void *p_data, UINT16 len, UINT16 handle)
198 {
199     UNUSED(port_handle);
200 
201     /* call data call-out directly */
202     bta_ag_co_tx_write(handle, (UINT8 *) p_data, len);
203     return 0;
204 }
205 
206 /*******************************************************************************
207 **
208 ** Function         bta_ag_port_cback_1 to 3
209 **                  bta_ag_mgmt_cback_1 to 3
210 **
211 ** Description      RFCOMM callback functions.  This is an easy way to
212 **                  distinguish scb from the callback.
213 **
214 **
215 ** Returns          void
216 **
217 *******************************************************************************/
bta_ag_mgmt_cback_1(UINT32 code,UINT16 handle)218 void bta_ag_mgmt_cback_1(UINT32 code, UINT16 handle) {bta_ag_mgmt_cback(code, handle, 1);}
bta_ag_mgmt_cback_2(UINT32 code,UINT16 handle)219 void bta_ag_mgmt_cback_2(UINT32 code, UINT16 handle) {bta_ag_mgmt_cback(code, handle, 2);}
bta_ag_mgmt_cback_3(UINT32 code,UINT16 handle)220 void bta_ag_mgmt_cback_3(UINT32 code, UINT16 handle) {bta_ag_mgmt_cback(code, handle, 3);}
bta_ag_port_cback_1(UINT32 code,UINT16 handle)221 void bta_ag_port_cback_1(UINT32 code, UINT16 handle) {bta_ag_port_cback(code, handle, 1);}
bta_ag_port_cback_2(UINT32 code,UINT16 handle)222 void bta_ag_port_cback_2(UINT32 code, UINT16 handle) {bta_ag_port_cback(code, handle, 2);}
bta_ag_port_cback_3(UINT32 code,UINT16 handle)223 void bta_ag_port_cback_3(UINT32 code, UINT16 handle) {bta_ag_port_cback(code, handle, 3);}
224 
225 /*******************************************************************************
226 **
227 ** Function         bta_ag_data_cback_1 to 3
228 **
229 ** Description      RFCOMM data callback functions.  This is an easy way to
230 **                  distinguish scb from the callback.
231 **
232 **
233 ** Returns          void
234 **
235 *******************************************************************************/
bta_ag_data_cback_1(UINT16 port_handle,void * p_data,UINT16 len)236 int bta_ag_data_cback_1(UINT16 port_handle, void *p_data, UINT16 len)
237 {
238     return bta_ag_data_cback(port_handle, p_data, len, 1);
239 }
bta_ag_data_cback_2(UINT16 port_handle,void * p_data,UINT16 len)240 int bta_ag_data_cback_2(UINT16 port_handle, void *p_data, UINT16 len)
241 {
242     return bta_ag_data_cback(port_handle, p_data, len, 2);
243 }
bta_ag_data_cback_3(UINT16 port_handle,void * p_data,UINT16 len)244 int bta_ag_data_cback_3(UINT16 port_handle, void *p_data, UINT16 len)
245 {
246     return bta_ag_data_cback(port_handle, p_data, len, 3);
247 }
248 
249 /*******************************************************************************
250 **
251 ** Function         bta_ag_setup_port
252 **
253 ** Description      Setup RFCOMM port for use by AG.
254 **
255 **
256 ** Returns          void
257 **
258 *******************************************************************************/
bta_ag_setup_port(tBTA_AG_SCB * p_scb,UINT16 handle)259 void bta_ag_setup_port(tBTA_AG_SCB *p_scb, UINT16 handle)
260 {
261     UINT16 i = bta_ag_scb_to_idx(p_scb) - 1;
262 
263     /* set up data callback if using pass through mode */
264     if (bta_ag_cb.parse_mode == BTA_AG_PASS_THROUGH)
265     {
266         PORT_SetDataCallback(handle, bta_ag_data_cback_tbl[i]);
267     }
268 
269     PORT_SetEventMask(handle, BTA_AG_PORT_EV_MASK);
270     PORT_SetEventCallback(handle, bta_ag_port_cback_tbl[i]);
271 }
272 
273 /*******************************************************************************
274 **
275 ** Function         bta_ag_start_servers
276 **
277 ** Description      Setup RFCOMM servers for use by AG.
278 **
279 **
280 ** Returns          void
281 **
282 *******************************************************************************/
bta_ag_start_servers(tBTA_AG_SCB * p_scb,tBTA_SERVICE_MASK services)283 void bta_ag_start_servers(tBTA_AG_SCB *p_scb, tBTA_SERVICE_MASK services)
284 {
285     int i;
286     int bta_ag_port_status;
287 
288     services >>= BTA_HSP_SERVICE_ID;
289     for (i = 0; i < BTA_AG_NUM_IDX && services != 0; i++, services >>= 1)
290     {
291         /* if service is set in mask */
292         if (services & 1)
293         {
294             BTM_SetSecurityLevel(FALSE, "", bta_ag_sec_id[i], p_scb->serv_sec_mask,
295                 BT_PSM_RFCOMM, BTM_SEC_PROTO_RFCOMM, bta_ag_cb.profile[i].scn);
296 
297             bta_ag_port_status =  RFCOMM_CreateConnection(bta_ag_uuid[i], bta_ag_cb.profile[i].scn,
298                 TRUE, BTA_AG_MTU, (UINT8 *) bd_addr_any, &(p_scb->serv_handle[i]),
299                 bta_ag_mgmt_cback_tbl[bta_ag_scb_to_idx(p_scb) - 1]);
300 
301             if( bta_ag_port_status  == PORT_SUCCESS )
302             {
303                 bta_ag_setup_port(p_scb, p_scb->serv_handle[i]);
304             }
305             else
306             {
307                 /* TODO: CR#137125 to handle to error properly */
308                 APPL_TRACE_DEBUG("bta_ag_start_servers: RFCOMM_CreateConnection returned error:%d", bta_ag_port_status);
309             }
310         }
311     }
312 }
313 
314 /*******************************************************************************
315 **
316 ** Function         bta_ag_close_servers
317 **
318 ** Description      Close RFCOMM servers port for use by AG.
319 **
320 **
321 ** Returns          void
322 **
323 *******************************************************************************/
bta_ag_close_servers(tBTA_AG_SCB * p_scb,tBTA_SERVICE_MASK services)324 void bta_ag_close_servers(tBTA_AG_SCB *p_scb, tBTA_SERVICE_MASK services)
325 {
326     int i;
327 
328     services >>= BTA_HSP_SERVICE_ID;
329     for (i = 0; i < BTA_AG_NUM_IDX && services != 0; i++, services >>= 1)
330     {
331         /* if service is set in mask */
332         if (services & 1)
333         {
334             RFCOMM_RemoveServer(p_scb->serv_handle[i]);
335             p_scb->serv_handle[i] = 0;
336         }
337     }
338 }
339 
340 /*******************************************************************************
341 **
342 ** Function         bta_ag_is_server_closed
343 **
344 ** Description      Returns TRUE if all servers are closed.
345 **
346 **
347 ** Returns          TRUE if all servers are closed, FALSE otherwise
348 **
349 *******************************************************************************/
bta_ag_is_server_closed(tBTA_AG_SCB * p_scb)350 BOOLEAN bta_ag_is_server_closed (tBTA_AG_SCB *p_scb)
351 {
352     UINT8 xx;
353     BOOLEAN is_closed = TRUE;
354 
355     for (xx = 0; xx < BTA_AG_NUM_IDX; xx++)
356     {
357         if (p_scb->serv_handle[xx] != 0)
358             is_closed = FALSE;
359     }
360 
361     return is_closed;
362 }
363 
364 /*******************************************************************************
365 **
366 ** Function         bta_ag_rfc_do_open
367 **
368 ** Description      Open an RFCOMM connection to the peer device.
369 **
370 **
371 ** Returns          void
372 **
373 *******************************************************************************/
bta_ag_rfc_do_open(tBTA_AG_SCB * p_scb,tBTA_AG_DATA * p_data)374 void bta_ag_rfc_do_open(tBTA_AG_SCB *p_scb, tBTA_AG_DATA *p_data)
375 {
376     BTM_SetSecurityLevel(TRUE, "", bta_ag_sec_id[p_scb->conn_service],
377         p_scb->cli_sec_mask, BT_PSM_RFCOMM, BTM_SEC_PROTO_RFCOMM, p_scb->peer_scn);
378 
379     if (RFCOMM_CreateConnection(bta_ag_uuid[p_scb->conn_service], p_scb->peer_scn,
380             FALSE, BTA_AG_MTU, p_scb->peer_addr, &(p_scb->conn_handle),
381             bta_ag_mgmt_cback_tbl[bta_ag_scb_to_idx(p_scb) - 1]) == PORT_SUCCESS)
382     {
383         bta_ag_setup_port(p_scb, p_scb->conn_handle);
384         APPL_TRACE_DEBUG("bta_ag_rfc_do_open : conn_handle = %d", p_scb->conn_handle);
385     }
386     /* RFCOMM create connection failed; send ourselves RFCOMM close event */
387     else
388     {
389         bta_ag_sm_execute(p_scb, BTA_AG_RFC_CLOSE_EVT, p_data);
390     }
391 }
392 
393 /*******************************************************************************
394 **
395 ** Function         bta_ag_rfc_do_close
396 **
397 ** Description      Close RFCOMM connection.
398 **
399 **
400 ** Returns          void
401 **
402 *******************************************************************************/
bta_ag_rfc_do_close(tBTA_AG_SCB * p_scb,tBTA_AG_DATA * p_data)403 void bta_ag_rfc_do_close(tBTA_AG_SCB *p_scb, tBTA_AG_DATA *p_data)
404 {
405     tBTA_AG_RFC     *p_buf;
406     UNUSED(p_data);
407 
408     if (p_scb->conn_handle)
409     {
410         RFCOMM_RemoveConnection(p_scb->conn_handle);
411     }
412     else
413     {
414         /* Close API was called while AG is in Opening state.               */
415         /* Need to trigger the state machine to send callback to the app    */
416         /* and move back to INIT state.                                     */
417         if ((p_buf = (tBTA_AG_RFC *) GKI_getbuf(sizeof(tBTA_AG_RFC))) != NULL)
418         {
419             p_buf->hdr.event = BTA_AG_RFC_CLOSE_EVT;
420             p_buf->hdr.layer_specific = bta_ag_scb_to_idx(p_scb);
421             bta_sys_sendmsg(p_buf);
422         }
423 
424         /* Cancel SDP if it had been started. */
425         /*
426         if(p_scb->p_disc_db)
427         {
428             (void)SDP_CancelServiceSearch (p_scb->p_disc_db);
429         }
430         */
431     }
432 }
433 
434