OSDN Git Service

resolve merge conflicts of 316589aa to nyc-mr2-dev
[android-x86/system-bt.git] / bta / gatt / bta_gatts_act.c
1 /******************************************************************************
2  *
3  *  Copyright (C) 2003-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 GATT Server action functions for the state
22  *  machine.
23  *
24  ******************************************************************************/
25
26
27 #include "bt_target.h"
28
29 #if defined(BTA_GATT_INCLUDED) && (BTA_GATT_INCLUDED == TRUE)
30
31 #include "utl.h"
32 #include "bt_common.h"
33 #include "bta_sys.h"
34 #include "bta_gatts_int.h"
35 #include "bta_gatts_co.h"
36 #include "btm_ble_api.h"
37 #include "btif/include/btif_debug_conn.h"
38 #include <string.h>
39
40 static void bta_gatts_nv_save_cback(BOOLEAN is_saved, tGATTS_HNDL_RANGE *p_hndl_range);
41 static BOOLEAN bta_gatts_nv_srv_chg_cback(tGATTS_SRV_CHG_CMD cmd, tGATTS_SRV_CHG_REQ *p_req,
42                                                 tGATTS_SRV_CHG_RSP *p_rsp);
43
44 static void bta_gatts_conn_cback (tGATT_IF gatt_if, BD_ADDR bda, UINT16 conn_id,
45                                       BOOLEAN connected, tGATT_DISCONN_REASON reason,
46                                       tGATT_TRANSPORT transport);
47 static void bta_gatts_send_request_cback (UINT16 conn_id,
48                                           UINT32 trans_id,
49                                           tGATTS_REQ_TYPE req_type, tGATTS_DATA *p_data);
50 static void bta_gatts_cong_cback (UINT16 conn_id, BOOLEAN congested);
51
52 static tGATT_CBACK bta_gatts_cback =
53 {
54     bta_gatts_conn_cback,
55     NULL,
56     NULL,
57     NULL,
58     bta_gatts_send_request_cback,
59     NULL,
60     bta_gatts_cong_cback
61 };
62
63 tGATT_APPL_INFO bta_gatts_nv_cback =
64 {
65     bta_gatts_nv_save_cback,
66     bta_gatts_nv_srv_chg_cback
67 };
68
69 /*******************************************************************************
70 **
71 ** Function         bta_gatts_nv_save_cback
72 **
73 ** Description      NV save callback function.
74 **
75 ** Parameter        is_add: true is to add a handle range; otherwise is to delete.
76 ** Returns          none.
77 **
78 *******************************************************************************/
79 static void bta_gatts_nv_save_cback(BOOLEAN is_add, tGATTS_HNDL_RANGE *p_hndl_range)
80 {
81     bta_gatts_co_update_handle_range(is_add, (tBTA_GATTS_HNDL_RANGE *)p_hndl_range);
82 }
83
84
85 /*******************************************************************************
86 **
87 ** Function         bta_gatts_nv_srv_chg_cback
88 **
89 ** Description      NV save callback function.
90 **
91 ** Parameter        is_add: true is to add a handle range; otherwise is to delete.
92 ** Returns          none.
93 **
94 *******************************************************************************/
95 static BOOLEAN bta_gatts_nv_srv_chg_cback(tGATTS_SRV_CHG_CMD cmd,
96                                               tGATTS_SRV_CHG_REQ *p_req, tGATTS_SRV_CHG_RSP *p_rsp)
97 {
98     return bta_gatts_co_srv_chg((tBTA_GATTS_SRV_CHG_CMD) cmd,
99                                 (tBTA_GATTS_SRV_CHG_REQ *) p_req,
100                                 (tBTA_GATTS_SRV_CHG_RSP *) p_rsp);
101 }
102
103
104 /*******************************************************************************
105 **
106 ** Function         bta_gatts_enable
107 **
108 ** Description      enable BTA GATTS module.
109 **
110 ** Returns          none.
111 **
112 *******************************************************************************/
113 void bta_gatts_enable(tBTA_GATTS_CB *p_cb)
114 {
115     UINT8 index=0;
116     tBTA_GATTS_HNDL_RANGE handle_range;
117
118     if (p_cb->enabled)
119     {
120         APPL_TRACE_DEBUG("GATTS already enabled.");
121     }
122     else
123     {
124         memset(p_cb, 0, sizeof(tBTA_GATTS_CB));
125
126         p_cb->enabled = TRUE;
127
128         while ( bta_gatts_co_load_handle_range(index, &handle_range))
129         {
130             GATTS_AddHandleRange((tGATTS_HNDL_RANGE *)&handle_range);
131             memset(&handle_range, 0, sizeof(tGATTS_HNDL_RANGE));
132             index++;
133         }
134
135         APPL_TRACE_DEBUG("bta_gatts_enable: num of handle range added=%d", index);
136
137         if (!GATTS_NVRegister(&bta_gatts_nv_cback))
138         {
139             APPL_TRACE_ERROR("BTA GATTS NV register failed.");
140         }
141     }
142 }
143
144 /*******************************************************************************
145 **
146 ** Function         bta_gatts_api_disable
147 **
148 ** Description      disable BTA GATTS module.
149 **
150 ** Returns          none.
151 **
152 *******************************************************************************/
153 void bta_gatts_api_disable(tBTA_GATTS_CB *p_cb)
154 {
155     UINT8 i;
156
157     if (p_cb->enabled)
158     {
159         for (i = 0; i < BTA_GATTS_MAX_APP_NUM; i ++)
160         {
161             if (p_cb->rcb[i].in_use)
162             {
163                 GATT_Deregister(p_cb->rcb[i].gatt_if);
164             }
165         }
166         memset(p_cb, 0, sizeof(tBTA_GATTS_CB));
167     }
168     else
169     {
170         APPL_TRACE_ERROR("GATTS not enabled");
171     }
172 }
173
174 /*******************************************************************************
175 **
176 ** Function         bta_gatts_register
177 **
178 ** Description      register an application.
179 **
180 ** Returns          none.
181 **
182 *******************************************************************************/
183 void bta_gatts_register(tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA *p_msg)
184 {
185     tBTA_GATTS               cb_data;
186     tBTA_GATT_STATUS         status = BTA_GATT_OK;
187     UINT8                    i, first_unuse = 0xff;
188
189     if (p_cb->enabled == FALSE)
190     {
191         bta_gatts_enable(p_cb);
192     }
193
194     for (i = 0; i < BTA_GATTS_MAX_APP_NUM; i ++)
195     {
196         if (p_cb->rcb[i].in_use)
197         {
198             if (bta_gatts_uuid_compare(p_cb->rcb[i].app_uuid, p_msg->api_reg.app_uuid))
199             {
200                 APPL_TRACE_ERROR("application already registered.");
201                 status = BTA_GATT_DUP_REG;
202                 break;
203             }
204         }
205     }
206
207     if (status == BTA_GATT_OK)
208     {
209         for (i = 0; i < BTA_GATTS_MAX_APP_NUM; i ++)
210         {
211             if (first_unuse == 0xff && !p_cb->rcb[i].in_use)
212             {
213                 first_unuse = i;
214                 break;
215             }
216         }
217
218         cb_data.reg_oper.server_if = BTA_GATTS_INVALID_IF;
219         memcpy(&cb_data.reg_oper.uuid, &p_msg->api_reg.app_uuid, sizeof(tBT_UUID));
220         if (first_unuse != 0xff)
221         {
222             APPL_TRACE_ERROR("register application first_unuse rcb_idx = %d", first_unuse);
223
224             p_cb->rcb[first_unuse].in_use = TRUE;
225             p_cb->rcb[first_unuse].p_cback = p_msg->api_reg.p_cback;
226             memcpy(&p_cb->rcb[first_unuse].app_uuid, &p_msg->api_reg.app_uuid, sizeof(tBT_UUID));
227             cb_data.reg_oper.server_if      =
228             p_cb->rcb[first_unuse].gatt_if  =
229             GATT_Register(&p_msg->api_reg.app_uuid, &bta_gatts_cback);
230             if ( !p_cb->rcb[first_unuse].gatt_if) {
231                 status = BTA_GATT_NO_RESOURCES;
232             } else {
233               tBTA_GATTS_INT_START_IF *p_buf =
234                   (tBTA_GATTS_INT_START_IF *)osi_malloc(sizeof(tBTA_GATTS_INT_START_IF));
235                 p_buf->hdr.event = BTA_GATTS_INT_START_IF_EVT;
236                 p_buf->server_if = p_cb->rcb[first_unuse].gatt_if;
237
238                 bta_sys_sendmsg(p_buf);
239             }
240         } else {
241             status = BTA_GATT_NO_RESOURCES;
242         }
243
244     }
245     cb_data.reg_oper.status = status;
246     if (p_msg->api_reg.p_cback)
247         (*p_msg->api_reg.p_cback)(BTA_GATTS_REG_EVT, &cb_data);
248 }
249
250
251 /*******************************************************************************
252 **
253 ** Function         bta_gatts_start_if
254 **
255 ** Description      start an application interface.
256 **
257 ** Returns          none.
258 **
259 *******************************************************************************/
260 void bta_gatts_start_if(tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA *p_msg)
261 {
262     UNUSED(p_cb);
263
264     if (bta_gatts_find_app_rcb_by_app_if(p_msg->int_start_if.server_if))
265     {
266         GATT_StartIf(p_msg->int_start_if.server_if);
267     }
268     else
269     {
270         APPL_TRACE_ERROR("Unable to start app.: Unknown interface =%d",
271             p_msg->int_start_if.server_if );
272     }
273 }
274 /*******************************************************************************
275 **
276 ** Function         bta_gatts_deregister
277 **
278 ** Description      deregister an application.
279 **
280 ** Returns          none.
281 **
282 *******************************************************************************/
283 void bta_gatts_deregister(tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA *p_msg)
284 {
285     tBTA_GATT_STATUS    status = BTA_GATT_ERROR;
286     tBTA_GATTS_CBACK    *p_cback = NULL;
287     UINT8               i;
288     tBTA_GATTS          cb_data;
289
290     cb_data.reg_oper.server_if = p_msg->api_dereg.server_if;
291     cb_data.reg_oper.status = status;
292
293     for (i = 0; i < BTA_GATTS_MAX_APP_NUM; i ++)
294     {
295         if (p_cb->rcb[i].in_use && p_cb->rcb[i].gatt_if == p_msg->api_dereg.server_if)
296         {
297             p_cback = p_cb->rcb[i].p_cback;
298             status = BTA_GATT_OK;
299
300             /* deregister the app */
301             GATT_Deregister(p_cb->rcb[i].gatt_if);
302
303             /* reset cb */
304             memset(&p_cb->rcb[i], 0, sizeof(tBTA_GATTS_RCB));
305             cb_data.reg_oper.status = status;
306             break;
307         }
308     }
309
310     if (p_cback)
311     {
312         (*p_cback)(BTA_GATTS_DEREG_EVT, &cb_data);
313     }
314     else
315     {
316         APPL_TRACE_ERROR("application not registered.");
317     }
318 }
319 /*******************************************************************************
320 **
321 ** Function         bta_gatts_create_srvc
322 **
323 ** Description      action function to create a service.
324 **
325 ** Returns          none.
326 **
327 *******************************************************************************/
328 void bta_gatts_create_srvc(tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
329 {
330     UINT8               rcb_idx;
331     tBTA_GATTS          cb_data;
332     UINT8               srvc_idx;
333     UINT16              service_id = 0;
334
335     cb_data.create.status = BTA_GATT_ERROR;
336
337     rcb_idx = bta_gatts_find_app_rcb_idx_by_app_if(p_cb, p_msg->api_create_svc.server_if);
338
339     APPL_TRACE_ERROR("create service rcb_idx = %d", rcb_idx);
340
341     if (rcb_idx != BTA_GATTS_INVALID_APP)
342     {
343         if ((srvc_idx = bta_gatts_alloc_srvc_cb(p_cb, rcb_idx)) != BTA_GATTS_INVALID_APP)
344         {
345             /* create the service now */
346             service_id = GATTS_CreateService (p_cb->rcb[rcb_idx].gatt_if,
347                                               &p_msg->api_create_svc.service_uuid,
348                                               p_msg->api_create_svc.inst,
349                                               p_msg->api_create_svc.num_handle,
350                                               p_msg->api_create_svc.is_pri);
351
352             if (service_id != 0)
353             {
354                 memcpy(&p_cb->srvc_cb[srvc_idx].service_uuid,
355                     &p_msg->api_create_svc.service_uuid, sizeof(tBT_UUID));
356                 p_cb->srvc_cb[srvc_idx].service_id   = service_id;
357                 p_cb->srvc_cb[srvc_idx].inst_num     = p_msg->api_create_svc.inst;
358                 p_cb->srvc_cb[srvc_idx].idx          = srvc_idx;
359
360                 cb_data.create.status      = BTA_GATT_OK;
361                 cb_data.create.service_id  = service_id;
362                 cb_data.create.is_primary  = p_msg->api_create_svc.is_pri;
363                 cb_data.create.server_if   = p_cb->rcb[rcb_idx].gatt_if;
364             }
365             else
366             {
367                 cb_data.status  = BTA_GATT_ERROR;
368                 memset(&p_cb->srvc_cb[srvc_idx], 0, sizeof(tBTA_GATTS_SRVC_CB));
369                 APPL_TRACE_ERROR("service creation failed.");
370             }
371             memcpy(&cb_data.create.uuid, &p_msg->api_create_svc.service_uuid, sizeof(tBT_UUID));
372             cb_data.create.svc_instance= p_msg->api_create_svc.inst;
373         }
374         if (p_cb->rcb[rcb_idx].p_cback)
375             (* p_cb->rcb[rcb_idx].p_cback)(BTA_GATTS_CREATE_EVT, &cb_data);
376     }
377     else /* application not registered */
378     {
379         APPL_TRACE_ERROR("Application not registered");
380     }
381 }
382 /*******************************************************************************
383 **
384 ** Function         bta_gatts_add_include_srvc
385 **
386 ** Description      action function to add an included service.
387 **
388 ** Returns          none.
389 **
390 *******************************************************************************/
391 void bta_gatts_add_include_srvc(tBTA_GATTS_SRVC_CB *p_srvc_cb,tBTA_GATTS_DATA * p_msg)
392 {
393     tBTA_GATTS_RCB  *p_rcb = &bta_gatts_cb.rcb[p_srvc_cb->rcb_idx];
394     UINT16          attr_id = 0;
395     tBTA_GATTS      cb_data;
396
397     attr_id = GATTS_AddIncludeService(p_msg->api_add_incl_srvc.hdr.layer_specific,
398                                       p_msg->api_add_incl_srvc.included_service_id);
399
400     cb_data.add_result.server_if = p_rcb->gatt_if;
401     cb_data.add_result.service_id = p_msg->api_add_incl_srvc.hdr.layer_specific;
402     cb_data.add_result.attr_id = attr_id;
403
404     if (attr_id)
405     {
406         cb_data.add_result.status = BTA_GATT_OK;
407     }
408     else
409     {
410         cb_data.add_result.status = BTA_GATT_ERROR;
411     }
412
413     if (p_rcb->p_cback)
414         (*p_rcb->p_cback)(BTA_GATTS_ADD_INCL_SRVC_EVT, &cb_data);
415 }
416 /*******************************************************************************
417 **
418 ** Function         bta_gatts_add_char
419 **
420 ** Description      action function to add characteristic.
421 **
422 ** Returns          none.
423 **
424 *******************************************************************************/
425 void bta_gatts_add_char(tBTA_GATTS_SRVC_CB *p_srvc_cb, tBTA_GATTS_DATA * p_msg)
426 {
427     tBTA_GATTS_RCB  *p_rcb = &bta_gatts_cb.rcb[p_srvc_cb->rcb_idx];
428     UINT16          attr_id = 0;
429     tBTA_GATTS      cb_data;
430
431     attr_id = GATTS_AddCharacteristic(p_msg->api_add_char.hdr.layer_specific,
432                                       &p_msg->api_add_char.char_uuid,
433                                       p_msg->api_add_char.perm,
434                                       p_msg->api_add_char.property);
435     cb_data.add_result.server_if = p_rcb->gatt_if;
436     cb_data.add_result.service_id = p_msg->api_add_incl_srvc.hdr.layer_specific;
437     cb_data.add_result.attr_id = attr_id;
438     memcpy(&cb_data.add_result.char_uuid, &p_msg->api_add_char.char_uuid, sizeof(tBT_UUID));
439
440     if (attr_id)
441     {
442         cb_data.add_result.status = BTA_GATT_OK;
443     }
444     else
445     {
446         cb_data.add_result.status = BTA_GATT_ERROR;
447     }
448
449     if (p_rcb->p_cback)
450         (*p_rcb->p_cback)(BTA_GATTS_ADD_CHAR_EVT, &cb_data);
451 }
452 /*******************************************************************************
453 **
454 ** Function         bta_gatts_add_char_descr
455 **
456 ** Description      action function to add characteristic descriptor.
457 **
458 ** Returns          none.
459 **
460 *******************************************************************************/
461 void bta_gatts_add_char_descr(tBTA_GATTS_SRVC_CB *p_srvc_cb, tBTA_GATTS_DATA * p_msg)
462 {
463     tBTA_GATTS_RCB  *p_rcb = &bta_gatts_cb.rcb[p_srvc_cb->rcb_idx];
464     UINT16          attr_id = 0;
465     tBTA_GATTS      cb_data;
466
467     attr_id = GATTS_AddCharDescriptor(p_msg->api_add_char_descr.hdr.layer_specific,
468                                        p_msg->api_add_char_descr.perm,
469                                        &p_msg->api_add_char_descr.descr_uuid);
470
471     cb_data.add_result.server_if = p_rcb->gatt_if;
472     cb_data.add_result.service_id = p_msg->api_add_incl_srvc.hdr.layer_specific;
473     cb_data.add_result.attr_id = attr_id;
474     memcpy(&cb_data.add_result.char_uuid, &p_msg->api_add_char_descr.descr_uuid, sizeof(tBT_UUID));
475
476     if (attr_id)
477     {
478         cb_data.add_result.status = BTA_GATT_OK;
479     }
480     else
481     {
482         cb_data.add_result.status = BTA_GATT_ERROR;
483     }
484
485     if (p_rcb->p_cback)
486         (*p_rcb->p_cback)(BTA_GATTS_ADD_CHAR_DESCR_EVT, &cb_data);
487
488 }
489 /*******************************************************************************
490 **
491 ** Function         bta_gatts_delete_service
492 **
493 ** Description      action function to delete a service.
494 **
495 ** Returns          none.
496 **
497 *******************************************************************************/
498 void bta_gatts_delete_service(tBTA_GATTS_SRVC_CB *p_srvc_cb, tBTA_GATTS_DATA * p_msg)
499 {
500     tBTA_GATTS_RCB *p_rcb = &bta_gatts_cb.rcb[p_srvc_cb->rcb_idx];
501     tBTA_GATTS      cb_data;
502
503     cb_data.srvc_oper.server_if = p_rcb->gatt_if;
504     cb_data.srvc_oper.service_id = p_msg->api_add_incl_srvc.hdr.layer_specific;
505
506     if (GATTS_DeleteService(p_rcb->gatt_if,
507                             &p_srvc_cb->service_uuid,
508                             p_srvc_cb->inst_num))
509     {
510         cb_data.srvc_oper.status = BTA_GATT_OK;
511         memset(p_srvc_cb, 0, sizeof(tBTA_GATTS_SRVC_CB));
512     }
513     else
514     {
515         cb_data.srvc_oper.status = BTA_GATT_ERROR;
516     }
517
518     if (p_rcb->p_cback)
519         (*p_rcb->p_cback)(BTA_GATTS_DELELTE_EVT, &cb_data);
520
521 }
522 /*******************************************************************************
523 **
524 ** Function         bta_gatts_start_service
525 **
526 ** Description      action function to start a service.
527 **
528 ** Returns          none.
529 **
530 *******************************************************************************/
531 void bta_gatts_start_service(tBTA_GATTS_SRVC_CB *p_srvc_cb, tBTA_GATTS_DATA * p_msg)
532 {
533     tBTA_GATTS_RCB *p_rcb = &bta_gatts_cb.rcb[p_srvc_cb->rcb_idx];
534     tBTA_GATTS      cb_data;
535
536     cb_data.srvc_oper.server_if = p_rcb->gatt_if;
537     cb_data.srvc_oper.service_id = p_msg->api_add_incl_srvc.hdr.layer_specific;
538
539     if (GATTS_StartService(p_rcb->gatt_if,
540                            p_srvc_cb->service_id,
541                            p_msg->api_start.transport) ==  GATT_SUCCESS)
542     {
543         APPL_TRACE_DEBUG("bta_gatts_start_service service_id= %d", p_srvc_cb->service_id);
544         cb_data.srvc_oper.status = BTA_GATT_OK;
545     }
546     else
547     {
548         cb_data.srvc_oper.status = BTA_GATT_ERROR;
549     }
550
551     if (p_rcb->p_cback)
552         (*p_rcb->p_cback)(BTA_GATTS_START_EVT, &cb_data);
553
554 }
555 /*******************************************************************************
556 **
557 ** Function         bta_gatts_stop_service
558 **
559 ** Description      action function to stop a service.
560 **
561 ** Returns          none.
562 **
563 *******************************************************************************/
564 void bta_gatts_stop_service(tBTA_GATTS_SRVC_CB *p_srvc_cb, tBTA_GATTS_DATA * p_msg)
565 {
566     tBTA_GATTS_RCB *p_rcb = &bta_gatts_cb.rcb[p_srvc_cb->rcb_idx];
567     tBTA_GATTS      cb_data;
568     UNUSED(p_msg);
569
570     GATTS_StopService(p_srvc_cb->service_id);
571     cb_data.srvc_oper.server_if = p_rcb->gatt_if;
572     cb_data.srvc_oper.service_id = p_srvc_cb->service_id;
573     cb_data.srvc_oper.status = BTA_GATT_OK;
574     APPL_TRACE_ERROR("bta_gatts_stop_service service_id= %d", p_srvc_cb->service_id);
575
576     if (p_rcb->p_cback)
577         (*p_rcb->p_cback)(BTA_GATTS_STOP_EVT, &cb_data);
578
579 }
580 /*******************************************************************************
581 **
582 ** Function         bta_gatts_send_rsp
583 **
584 ** Description      GATTS send response.
585 **
586 ** Returns          none.
587 **
588 *******************************************************************************/
589 void bta_gatts_send_rsp (tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
590 {
591     UNUSED(p_cb);
592
593     if (GATTS_SendRsp (p_msg->api_rsp.hdr.layer_specific,
594                         p_msg->api_rsp.trans_id,
595                         p_msg->api_rsp.status,
596                         (tGATTS_RSP *)p_msg->api_rsp.p_rsp) != GATT_SUCCESS)
597     {
598         APPL_TRACE_ERROR("Sending response failed");
599     }
600
601 }
602 /*******************************************************************************
603 **
604 ** Function         bta_gatts_indicate_handle
605 **
606 ** Description      GATTS send handle value indication or notification.
607 **
608 ** Returns          none.
609 **
610 *******************************************************************************/
611 void bta_gatts_indicate_handle (tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
612 {
613     tBTA_GATTS_SRVC_CB  *p_srvc_cb;
614     tBTA_GATTS_RCB      *p_rcb = NULL;
615     tBTA_GATT_STATUS    status = BTA_GATT_ILLEGAL_PARAMETER;
616     tGATT_IF            gatt_if;
617     BD_ADDR             remote_bda;
618     tBTA_TRANSPORT transport;
619     tBTA_GATTS          cb_data;
620
621     p_srvc_cb = bta_gatts_find_srvc_cb_by_attr_id (p_cb, p_msg->api_indicate.attr_id);
622
623     if (p_srvc_cb )
624     {
625         if (GATT_GetConnectionInfor(p_msg->api_indicate.hdr.layer_specific,
626             &gatt_if, remote_bda, &transport))
627         {
628             p_rcb = bta_gatts_find_app_rcb_by_app_if(gatt_if);
629
630             if (p_msg->api_indicate.need_confirm)
631
632                 status = GATTS_HandleValueIndication (p_msg->api_indicate.hdr.layer_specific,
633                                                       p_msg->api_indicate.attr_id,
634                                                       p_msg->api_indicate.len,
635                                                       p_msg->api_indicate.value);
636             else
637                 status = GATTS_HandleValueNotification (p_msg->api_indicate.hdr.layer_specific,
638                                                         p_msg->api_indicate.attr_id,
639                                                         p_msg->api_indicate.len,
640                                                         p_msg->api_indicate.value);
641
642             /* if over BR_EDR, inform PM for mode change */
643             if (transport == BTA_TRANSPORT_BR_EDR)
644             {
645                 bta_sys_busy(BTA_ID_GATTS, BTA_ALL_APP_ID, remote_bda);
646                 bta_sys_idle(BTA_ID_GATTS, BTA_ALL_APP_ID, remote_bda);
647             }
648         }
649         else
650         {
651             APPL_TRACE_ERROR("Unknown connection ID: %d fail sending notification",
652                               p_msg->api_indicate.hdr.layer_specific);
653         }
654
655         if ((status != GATT_SUCCESS || !p_msg->api_indicate.need_confirm) &&
656             p_rcb && p_cb->rcb[p_srvc_cb->rcb_idx].p_cback)
657         {
658             cb_data.req_data.status = status;
659             cb_data.req_data.conn_id = p_msg->api_indicate.hdr.layer_specific;
660
661             (*p_rcb->p_cback)(BTA_GATTS_CONF_EVT, &cb_data);
662         }
663     }
664     else
665     {
666         APPL_TRACE_ERROR("Not an registered servce attribute ID: 0x%04x",
667                           p_msg->api_indicate.attr_id);
668     }
669 }
670
671
672 /*******************************************************************************
673 **
674 ** Function         bta_gatts_open
675 **
676 ** Description
677 **
678 ** Returns          none.
679 **
680 *******************************************************************************/
681 void bta_gatts_open (tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
682 {
683     tBTA_GATTS_RCB      *p_rcb=NULL;
684     tBTA_GATT_STATUS    status= BTA_GATT_ERROR;
685     UINT16              conn_id;
686     UNUSED(p_cb);
687
688     if ((p_rcb = bta_gatts_find_app_rcb_by_app_if(p_msg->api_open.server_if)) != NULL)
689     {
690         /* should always get the connection ID */
691         if (GATT_Connect(p_rcb->gatt_if, p_msg->api_open.remote_bda,
692                         p_msg->api_open.is_direct, p_msg->api_open.transport, false))
693         {
694             status = BTA_GATT_OK;
695
696             if (GATT_GetConnIdIfConnected(p_rcb->gatt_if, p_msg->api_open.remote_bda,
697                                             &conn_id, p_msg->api_open.transport))
698             {
699                 status = BTA_GATT_ALREADY_OPEN;
700             }
701         }
702     }
703     else
704     {
705         APPL_TRACE_ERROR("Inavlide server_if=%d", p_msg->api_open.server_if);
706     }
707
708     if (p_rcb && p_rcb->p_cback)
709         (*p_rcb->p_cback)(BTA_GATTS_OPEN_EVT,  (tBTA_GATTS *)&status);
710
711 }
712 /*******************************************************************************
713 **
714 ** Function         bta_gatts_cancel_open
715 **
716 ** Description
717 **
718 ** Returns          none.
719 **
720 *******************************************************************************/
721 void bta_gatts_cancel_open (tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
722 {
723     tBTA_GATTS_RCB      *p_rcb;
724     tBTA_GATT_STATUS    status= BTA_GATT_ERROR;
725     UNUSED(p_cb);
726
727     if ((p_rcb = bta_gatts_find_app_rcb_by_app_if(p_msg->api_cancel_open.server_if)) != NULL)
728     {
729         if (!GATT_CancelConnect(p_rcb->gatt_if, p_msg->api_cancel_open.remote_bda,
730                                 p_msg->api_cancel_open.is_direct))
731         {
732             APPL_TRACE_ERROR("bta_gatts_cancel_open failed for open request");
733         }
734         else
735         {
736             status= BTA_GATT_OK;
737         }
738     }
739     else
740     {
741         APPL_TRACE_ERROR("Inavlide server_if=%d", p_msg->api_cancel_open.server_if);
742     }
743
744     if (p_rcb && p_rcb->p_cback)
745         (*p_rcb->p_cback)(BTA_GATTS_CANCEL_OPEN_EVT,  (tBTA_GATTS *)&status);
746 }
747 /*******************************************************************************
748 **
749 ** Function         bta_gatts_close
750 **
751 ** Description
752 **
753 ** Returns          none.
754 **
755 *******************************************************************************/
756 void bta_gatts_close (tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
757 {
758     tBTA_GATTS_RCB     *p_rcb;
759     tBTA_GATT_STATUS    status= BTA_GATT_ERROR;
760     tGATT_IF            gatt_if;
761     BD_ADDR             remote_bda;
762     tBTA_GATT_TRANSPORT transport;
763
764     UNUSED(p_cb);
765
766     if (GATT_GetConnectionInfor(p_msg->hdr.layer_specific, &gatt_if, remote_bda, &transport))
767     {
768         if (GATT_Disconnect(p_msg->hdr.layer_specific) != GATT_SUCCESS)
769         {
770             APPL_TRACE_ERROR("bta_gatts_close fail conn_id=%d", p_msg->hdr.layer_specific);
771         }
772         else
773         {
774             status= BTA_GATT_OK;
775         }
776
777         p_rcb = bta_gatts_find_app_rcb_by_app_if(gatt_if);
778
779         if (p_rcb && p_rcb->p_cback)
780         {
781             if (transport == BTA_TRANSPORT_BR_EDR)
782                 bta_sys_conn_close( BTA_ID_GATTS ,BTA_ALL_APP_ID, remote_bda);
783
784             (*p_rcb->p_cback)(BTA_GATTS_CLOSE_EVT,  (tBTA_GATTS *)&status);
785         }
786     }
787     else
788     {
789         APPL_TRACE_ERROR("Unknown connection ID: %d", p_msg->hdr.layer_specific);
790     }
791
792 }
793 /*******************************************************************************
794 **
795 ** Function         bta_gatts_listen
796 **
797 ** Description      Start or stop listening for LE connection on a GATT server
798 **
799 ** Returns          none.
800 **
801 *******************************************************************************/
802 void bta_gatts_listen(tBTA_GATTS_CB *p_cb, tBTA_GATTS_DATA * p_msg)
803 {
804     tBTA_GATTS_RCB     *p_rcb = bta_gatts_find_app_rcb_by_app_if(p_msg->api_listen.server_if);
805     tBTA_GATTS          cb_data;
806     UNUSED(p_cb);
807
808     cb_data.reg_oper.status = BTA_GATT_OK;
809     cb_data.reg_oper.server_if = p_msg->api_listen.server_if;
810
811     if (p_rcb == NULL)
812     {
813         APPL_TRACE_ERROR("Unknown GATTS application");
814         return;
815     }
816
817     if (!GATT_Listen(p_msg->api_listen.server_if,
818                      p_msg->api_listen.start,
819                      p_msg->api_listen.remote_bda))
820     {
821         cb_data.status = BTA_GATT_ERROR;
822         APPL_TRACE_ERROR("bta_gatts_listen Listen failed");
823     }
824
825     if (p_rcb->p_cback)
826         (*p_rcb->p_cback)(BTA_GATTS_LISTEN_EVT, &cb_data);
827 }
828
829 /*******************************************************************************
830 **
831 ** Function         bta_gatts_request_cback
832 **
833 ** Description      GATTS attribute request callback.
834 **
835 ** Returns          none.
836 **
837 *******************************************************************************/
838 static void bta_gatts_send_request_cback (UINT16 conn_id,
839                                           UINT32 trans_id,
840                                           tGATTS_REQ_TYPE req_type, tGATTS_DATA *p_data)
841 {
842     tBTA_GATTS          cb_data;
843     tBTA_GATTS_RCB     *p_rcb;
844     tGATT_IF            gatt_if;
845     tBTA_GATT_TRANSPORT transport;
846
847     memset(&cb_data, 0 , sizeof(tBTA_GATTS));
848
849     if (GATT_GetConnectionInfor(conn_id, &gatt_if, cb_data.req_data.remote_bda, &transport))
850     {
851         p_rcb = bta_gatts_find_app_rcb_by_app_if(gatt_if);
852
853         APPL_TRACE_DEBUG ("bta_gatts_send_request_cback conn_id=%d trans_id=%d req_type=%d",
854                             conn_id, trans_id, req_type);
855
856         if (p_rcb && p_rcb->p_cback)
857         {
858             /* if over BR_EDR, inform PM for mode change */
859             if (transport == BTA_TRANSPORT_BR_EDR)
860             {
861                 bta_sys_busy(BTA_ID_GATTS, BTA_ALL_APP_ID, cb_data.req_data.remote_bda);
862                 bta_sys_idle(BTA_ID_GATTS, BTA_ALL_APP_ID, cb_data.req_data.remote_bda);
863             }
864
865             cb_data.req_data.conn_id    = conn_id;
866             cb_data.req_data.trans_id   = trans_id;
867             cb_data.req_data.p_data     = (tBTA_GATTS_REQ_DATA *)p_data;
868
869             (*p_rcb->p_cback)(req_type,  &cb_data);
870         }
871         else
872         {
873             APPL_TRACE_ERROR("connection request on gatt_if[%d] is not interested", gatt_if);
874         }
875     }
876     else
877     {
878         APPL_TRACE_ERROR("request received on unknown connectino ID: %d", conn_id);
879     }
880 }
881
882 /*******************************************************************************
883 **
884 ** Function         bta_gatts_conn_cback
885 **
886 ** Description      connection callback.
887 **
888 ** Returns          none.
889 **
890 *******************************************************************************/
891 static void bta_gatts_conn_cback (tGATT_IF gatt_if, BD_ADDR bda, UINT16 conn_id,
892                                   BOOLEAN connected, tGATT_DISCONN_REASON reason,
893                                   tGATT_TRANSPORT transport)
894 {
895     tBTA_GATTS      cb_data;
896     UINT8           evt = connected ? BTA_GATTS_CONNECT_EVT: BTA_GATTS_DISCONNECT_EVT;
897     tBTA_GATTS_RCB  *p_reg;
898
899     APPL_TRACE_DEBUG ("bta_gatts_conn_cback gatt_if=%d conn_id=%d connected=%d reason = 0x%04d",
900                         gatt_if, conn_id, connected, reason);
901     APPL_TRACE_DEBUG("bta_gatts_conn_cback  bda :%02x-%02x-%02x-%02x-%02x-%02x ",
902                       bda[0],  bda[1], bda[2],  bda[3], bda[4],  bda[5]);
903
904     bt_bdaddr_t bdaddr;
905     bdcpy(bdaddr.address, bda);
906     if (connected)
907         btif_debug_conn_state(bdaddr, BTIF_DEBUG_CONNECTED, GATT_CONN_UNKNOWN);
908     else
909         btif_debug_conn_state(bdaddr, BTIF_DEBUG_DISCONNECTED, reason);
910
911     p_reg = bta_gatts_find_app_rcb_by_app_if(gatt_if);
912
913     if (p_reg && p_reg->p_cback)
914     {
915         /* there is no RM for GATT */
916         if (transport == BTA_TRANSPORT_BR_EDR)
917         {
918             if (connected)
919                 bta_sys_conn_open(BTA_ID_GATTS, BTA_ALL_APP_ID, bda);
920             else
921                 bta_sys_conn_close( BTA_ID_GATTS ,BTA_ALL_APP_ID, bda);
922         }
923
924         cb_data.conn.conn_id = conn_id;
925         cb_data.conn.server_if = gatt_if;
926         cb_data.conn.reason = reason;
927         cb_data.conn.transport = transport;
928         memcpy(cb_data.conn.remote_bda, bda, BD_ADDR_LEN);
929         (*p_reg->p_cback)(evt, &cb_data);
930     }
931     else
932     {
933         APPL_TRACE_ERROR("bta_gatts_conn_cback server_if=%d not found",gatt_if);
934     }
935 }
936
937 /*******************************************************************************
938 **
939 ** Function         bta_gatts_cong_cback
940 **
941 ** Description      congestion callback.
942 **
943 ** Returns          none.
944 **
945 *******************************************************************************/
946 static void bta_gatts_cong_cback (UINT16 conn_id, BOOLEAN congested)
947 {
948     tBTA_GATTS_RCB *p_rcb;
949     tGATT_IF gatt_if;
950     tBTA_GATT_TRANSPORT transport;
951     tBTA_GATTS cb_data;
952
953     if (GATT_GetConnectionInfor(conn_id, &gatt_if, cb_data.req_data.remote_bda, &transport))
954     {
955         p_rcb = bta_gatts_find_app_rcb_by_app_if(gatt_if);
956
957         if (p_rcb && p_rcb->p_cback)
958         {
959             cb_data.congest.conn_id = conn_id;
960             cb_data.congest.congested = congested;
961
962             (*p_rcb->p_cback)(BTA_GATTS_CONGEST_EVT, &cb_data);
963         }
964     }
965 }
966 #endif /* BTA_GATT_INCLUDED */