1/******************************************************************************
2 *
3 *  Copyright (C) 2009-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 *  Filename:      btif_profile_queue.c
22 *
23 *  Description:   Bluetooth remote device connection queuing implementation.
24 *
25 ******************************************************************************/
26
27#include <hardware/bluetooth.h>
28
29#define LOG_TAG "BTIF_QUEUE"
30#include "btif_common.h"
31#include "btif_profile_queue.h"
32#include "gki.h"
33#include "list.h"
34
35/*******************************************************************************
36**  Local type definitions
37*******************************************************************************/
38
39typedef enum {
40  BTIF_QUEUE_CONNECT_EVT,
41  BTIF_QUEUE_ADVANCE_EVT,
42} btif_queue_event_t;
43
44typedef struct {
45    bt_bdaddr_t bda;
46    uint16_t uuid;
47    bool busy;
48    btif_connect_cb_t connect_cb;
49} connect_node_t;
50
51/*******************************************************************************
52**  Static variables
53*******************************************************************************/
54
55static list_t *connect_queue;
56
57/*******************************************************************************
58**  Queue helper functions
59*******************************************************************************/
60
61static void queue_int_add(connect_node_t *p_param) {
62    connect_node_t *p_node = GKI_getbuf(sizeof(connect_node_t));
63    ASSERTC(p_node != NULL, "Failed to allocate new list node", 0);
64
65    memcpy(p_node, p_param, sizeof(connect_node_t));
66
67    if (!connect_queue) {
68        connect_queue = list_new(GKI_freebuf);
69        ASSERTC(connect_queue != NULL, "Failed to allocate list", 0);
70    }
71
72    list_append(connect_queue, p_node);
73}
74
75static void queue_int_advance() {
76    if (connect_queue && !list_is_empty(connect_queue))
77        list_remove(connect_queue, list_front(connect_queue));
78}
79
80static bt_status_t queue_int_connect_next() {
81    if (!connect_queue || list_is_empty(connect_queue))
82        return BT_STATUS_FAIL;
83
84    connect_node_t *p_head = list_front(connect_queue);
85
86    // If the queue is currently busy, we return success anyway,
87    // since the connection has been queued...
88    if (p_head->busy)
89        return BT_STATUS_SUCCESS;
90
91    p_head->busy = true;
92    return p_head->connect_cb(&p_head->bda, p_head->uuid);
93}
94
95static void queue_int_handle_evt(UINT16 event, char *p_param) {
96    switch(event) {
97        case BTIF_QUEUE_CONNECT_EVT:
98            queue_int_add((connect_node_t *)p_param);
99            break;
100
101        case BTIF_QUEUE_ADVANCE_EVT:
102            queue_int_advance();
103            break;
104    }
105
106    queue_int_connect_next();
107}
108
109/*******************************************************************************
110**
111** Function         btif_queue_connect
112**
113** Description      Add a new connection to the queue and trigger the next
114**                  scheduled connection.
115**
116** Returns          BT_STATUS_SUCCESS if successful
117**
118*******************************************************************************/
119bt_status_t btif_queue_connect(uint16_t uuid, const bt_bdaddr_t *bda, btif_connect_cb_t connect_cb) {
120    connect_node_t node;
121    memset(&node, 0, sizeof(connect_node_t));
122    memcpy(&node.bda, bda, sizeof(bt_bdaddr_t));
123    node.uuid = uuid;
124    node.connect_cb = connect_cb;
125
126    return btif_transfer_context(queue_int_handle_evt, BTIF_QUEUE_CONNECT_EVT,
127                          (char *)&node, sizeof(connect_node_t), NULL);
128}
129
130/*******************************************************************************
131**
132** Function         btif_queue_advance
133**
134** Description      Clear the queue's busy status and advance to the next
135**                  scheduled connection.
136**
137** Returns          void
138**
139*******************************************************************************/
140void btif_queue_advance() {
141    btif_transfer_context(queue_int_handle_evt, BTIF_QUEUE_ADVANCE_EVT,
142                          NULL, 0, NULL);
143}
144
145/*******************************************************************************
146**
147** Function         btif_queue_release
148**
149** Description      Free up all the queue nodes and set the queue head to NULL
150**
151** Returns          void
152**
153*******************************************************************************/
154void btif_queue_release() {
155    list_free(connect_queue);
156    connect_queue = NULL;
157}
158