free(buf);
}
-static void attrib_callback_notify(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void attrib_callback_notify(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
uint8_t *buf;
struct attrib_callbacks *cb = user_data;
#define GATT_CHARAC_CLI_FEAT 0x2B29
#define GATT_CHARAC_DB_HASH 0x2B2A
+/* GATT Server Supported features */
+#define GATT_CHARAC_SERVER_FEAT 0x2B3A
+
typedef struct {
enum {
BT_UUID_UNSPEC = 0,
return NULL;
}
- conn->client = bt_gatt_client_new(gatt_cache, conn->att, mtu);
+ conn->client = bt_gatt_client_new(gatt_cache, conn->att, mtu, 0);
if (!conn->gatt) {
fprintf(stderr, "Failed to create GATT client\n");
bt_gatt_server_unref(conn->gatt);
}
device->client = bt_gatt_client_new(device->db, device->att,
- device->att_mtu);
+ device->att_mtu, 0);
if (!device->client) {
DBG("Failed to initialize");
return;
uint8_t type;
int sec_level; /* Only used for non-L2CAP */
+ struct queue *queue; /* Channel dedicated queue */
+
struct att_send_op *pending_req;
struct att_send_op *pending_ind;
bool writer_active;
struct bt_att *att = chan->att;
struct att_send_op *op;
- /* See if any operations are already in the write queue */
- op = queue_pop_head(att->write_queue);
+ /* Check if there is anything queued on the channel */
+ op = queue_pop_head(chan->queue);
if (op)
return op;
+ /* See if any operations are already in the write queue */
+ op = queue_peek_head(att->write_queue);
+ if (op && op->len <= chan->mtu)
+ return queue_pop_head(att->write_queue);
+
/* If there is no pending request, pick an operation from the
* request queue.
*/
if (!chan->pending_req) {
- op = queue_pop_head(att->req_queue);
- if (op)
- return op;
+ op = queue_peek_head(att->req_queue);
+ if (op && op->len <= chan->mtu)
+ return queue_pop_head(att->req_queue);
}
/* There is either a request pending or no requests queued. If there is
* no pending indication, pick an operation from the indication queue.
*/
if (!chan->pending_ind) {
- op = queue_pop_head(att->ind_queue);
- if (op)
- return op;
+ op = queue_peek_head(att->ind_queue);
+ if (op && op->len <= chan->mtu)
+ return queue_pop_head(att->ind_queue);
}
return NULL;
}
+static void disc_att_send_op(void *data)
+{
+ struct att_send_op *op = data;
+
+ if (op->callback)
+ op->callback(BT_ATT_OP_ERROR_RSP, NULL, 0, op->user_data);
+
+ destroy_att_send_op(op);
+}
+
struct timeout_data {
struct bt_att_chan *chan;
unsigned int id;
return false;
util_debug(att->debug_callback, att->debug_data,
- "Operation timed out: 0x%02x", op->opcode);
+ "(chan %p) Operation timed out: 0x%02x",
+ chan, op->opcode);
if (att->timeout_callback)
att->timeout_callback(op->id, op->opcode, att->timeout_data);
op->timeout_id = 0;
- destroy_att_send_op(op);
+ disc_att_send_op(op);
/*
* Directly terminate the connection as required by the ATT protocol.
chan->writer_active = false;
}
+static ssize_t bt_att_chan_write(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t len)
+{
+ struct bt_att *att = chan->att;
+ ssize_t ret;
+ struct iovec iov;
+
+ iov.iov_base = (void *) pdu;
+ iov.iov_len = len;
+
+ util_debug(att->debug_callback, att->debug_data,
+ "(chan %p) ATT op 0x%02x",
+ chan, opcode);
+
+ ret = io_send(chan->io, &iov, 1);
+ if (ret < 0) {
+ util_debug(att->debug_callback, att->debug_data,
+ "(chan %p) write failed: %s",
+ chan, strerror(-ret));
+
+ return ret;
+ }
+
+ util_hexdump('<', pdu, ret, att->debug_callback, att->debug_data);
+
+ return ret;
+}
+
static bool can_write_data(struct io *io, void *user_data)
{
struct bt_att_chan *chan = user_data;
- struct bt_att *att = chan->att;
struct att_send_op *op;
struct timeout_data *timeout;
- ssize_t ret;
- struct iovec iov;
op = pick_next_send_op(chan);
if (!op)
return false;
- iov.iov_base = op->pdu;
- iov.iov_len = op->len;
-
- ret = io_send(io, &iov, 1);
- if (ret < 0) {
- util_debug(att->debug_callback, att->debug_data,
- "write failed: %s", strerror(-ret));
+ if (!bt_att_chan_write(chan, op->opcode, op->pdu, op->len)) {
if (op->callback)
op->callback(BT_ATT_OP_ERROR_RSP, NULL, 0,
op->user_data);
return true;
}
- util_debug(att->debug_callback, att->debug_data,
- "ATT op 0x%02x", op->opcode);
-
- util_hexdump('<', op->pdu, ret, att->debug_callback, att->debug_data);
/* Based on the operation type, set either the pending request or the
* pending indication. If it came from the write queue, then there is
/* Set the write handler only if there is anything that can be sent
* at all.
*/
- if (queue_isempty(att->write_queue)) {
+ if (queue_isempty(chan->queue) && queue_isempty(att->write_queue)) {
if ((chan->pending_req || queue_isempty(att->req_queue)) &&
(chan->pending_ind || queue_isempty(att->ind_queue)))
return;
disconn->callback(err, disconn->user_data);
}
-static void disc_att_send_op(void *data)
-{
- struct att_send_op *op = data;
-
- if (op->callback)
- op->callback(BT_ATT_OP_ERROR_RSP, NULL, 0, op->user_data);
-
- destroy_att_send_op(op);
-}
-
static void bt_att_chan_free(void *data)
{
struct bt_att_chan *chan = data;
if (chan->pending_ind)
destroy_att_send_op(chan->pending_ind);
+ queue_destroy(chan->queue, destroy_att_send_op);
+
io_destroy(chan->io);
free(chan->buf);
if (getsockopt(chan->fd, SOL_SOCKET, SO_ERROR, &err, &len) < 0) {
util_debug(chan->att->debug_callback, chan->att->debug_data,
- "Failed to obtain disconnect error: %s",
- strerror(errno));
+ "(chan %p) Failed to obtain disconnect"
+ " error: %s", chan, strerror(errno));
err = 0;
}
}
util_debug(att->debug_callback, att->debug_data,
- "Retrying operation %p", op);
+ "(chan %p) Retrying operation "
+ "%p", chan, op);
chan->pending_req = NULL;
*/
if (!op) {
util_debug(att->debug_callback, att->debug_data,
- "Received unexpected ATT response");
+ "(chan %p) Received unexpected ATT "
+ "response", chan);
io_shutdown(chan->io);
return;
}
fail:
util_debug(att->debug_callback, att->debug_data,
- "Failed to handle response PDU; opcode: 0x%02x", opcode);
+ "(chan %p) Failed to handle response PDU; opcode: "
+ "0x%02x", chan, opcode);
rsp_opcode = BT_ATT_OP_ERROR_RSP;
*/
if (!op || pdu_len) {
util_debug(att->debug_callback, att->debug_data,
- "Received unexpected/invalid ATT confirmation");
+ "(chan %p) Received unexpected/invalid ATT "
+ "confirmation", chan);
io_shutdown(chan->io);
return;
}
found = true;
if (notify->callback)
- notify->callback(opcode, pdu, pdu_len,
+ notify->callback(chan, opcode, pdu, pdu_len,
notify->user_data);
/* callback could remove all entries from notify list */
if (bytes_read < 0)
return false;
+ util_debug(att->debug_callback, att->debug_data,
+ "(chan %p) ATT received: %zd",
+ chan, bytes_read);
+
util_hexdump('>', chan->buf, bytes_read,
att->debug_callback, att->debug_data);
switch (get_op_type(opcode)) {
case ATT_OP_TYPE_RSP:
util_debug(att->debug_callback, att->debug_data,
- "ATT response received: 0x%02x", opcode);
+ "(chan %p) ATT response received: 0x%02x",
+ chan, opcode);
handle_rsp(chan, opcode, pdu + 1, bytes_read - 1);
break;
case ATT_OP_TYPE_CONF:
util_debug(att->debug_callback, att->debug_data,
- "ATT confirmation received: 0x%02x", opcode);
+ "(chan %p) ATT confirmation received: 0x%02x",
+ chan, opcode);
handle_conf(chan, pdu + 1, bytes_read - 1);
break;
case ATT_OP_TYPE_REQ:
*/
if (chan->in_req) {
util_debug(att->debug_callback, att->debug_data,
- "Received request while another is "
- "pending: 0x%02x", opcode);
+ "(chan %p) Received request while "
+ "another is pending: 0x%02x",
+ chan, opcode);
io_shutdown(chan->io);
bt_att_unref(chan->att);
* let them act on it.
*/
util_debug(att->debug_callback, att->debug_data,
- "ATT PDU received: 0x%02x", opcode);
+ "(chan %p) ATT PDU received: 0x%02x",
+ chan, opcode);
handle_notify(chan, opcode, pdu + 1, bytes_read - 1);
break;
}
free(att);
}
-static uint16_t get_l2cap_mtu(int fd)
+static uint16_t io_get_mtu(int fd)
{
socklen_t len;
struct l2cap_options l2o;
len = sizeof(l2o);
- if (getsockopt(fd, SOL_L2CAP, L2CAP_OPTIONS, &l2o, &len) < 0)
- return 0;
+ if (!getsockopt(fd, SOL_L2CAP, L2CAP_OPTIONS, &l2o, &len))
+ return l2o.omtu;
+
+ if (!getsockopt(fd, SOL_BLUETOOTH, BT_SNDMTU, &l2o.omtu, &len))
+ return l2o.omtu;
- return l2o.omtu;
+ return 0;
}
static uint8_t io_get_type(int fd)
chan->mtu = BT_ATT_DEFAULT_LE_MTU;
break;
default:
- chan->mtu = get_l2cap_mtu(chan->fd);
+ chan->mtu = io_get_mtu(chan->fd);
}
if (chan->mtu < BT_ATT_DEFAULT_LE_MTU)
if (!chan->buf)
goto fail;
+ chan->queue = queue_new();
+
return chan;
fail:
return NULL;
}
+static void bt_att_attach_chan(struct bt_att *att, struct bt_att_chan *chan)
+{
+ /* Push to head as EATT channels have higher priority */
+ queue_push_head(att->chans, chan);
+ chan->att = att;
+
+ if (chan->mtu > att->mtu)
+ att->mtu = chan->mtu;
+
+ io_set_close_on_destroy(chan->io, att->close_on_unref);
+
+ util_debug(att->debug_callback, att->debug_data, "Channel %p attached",
+ chan);
+
+ wakeup_chan_writer(chan, NULL);
+}
+
struct bt_att *bt_att_new(int fd, bool ext_signed)
{
struct bt_att *att;
att->chans = queue_new();
att->mtu = chan->mtu;
- queue_push_head(att->chans, chan);
- chan->att = att;
-
/* crypto is optional, if not available leave it NULL */
if (!ext_signed)
att->crypto = bt_crypto_new();
att->notify_list = queue_new();
att->disconn_list = queue_new();
+ bt_att_attach_chan(att, chan);
+
return bt_att_ref(att);
}
if (!chan)
return -EINVAL;
- queue_push_tail(att->chans, chan);
- chan->att = att;
-
- if (chan->mtu > att->mtu)
- att->mtu = chan->mtu;
-
- io_set_close_on_destroy(chan->io, att->close_on_unref);
+ bt_att_attach_chan(att, chan);
return 0;
}
if (queue_isempty(att->chans))
return -ENOTCONN;
- chan = queue_peek_head(att->chans);
+ chan = queue_peek_tail(att->chans);
return chan->fd;
}
if (mtu < BT_ATT_DEFAULT_LE_MTU)
return false;
- chan = queue_peek_head(att->chans);
+ /* Original channel is always the last */
+ chan = queue_peek_tail(att->chans);
if (!chan)
return -ENOTCONN;
if (!att)
return -EINVAL;
- chan = queue_peek_head(att->chans);
+ chan = queue_peek_tail(att->chans);
if (!chan)
return -ENOTCONN;
return false;
/* Check if disconnect is running */
- if (!queue_isempty(att->chans)) {
+ if (queue_isempty(att->chans)) {
disconn = queue_find(att->disconn_list, match_disconn_id,
UINT_TO_PTR(id));
if (!disconn)
return op->id;
}
+unsigned int bt_att_chan_send(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t len,
+ bt_att_response_func_t callback,
+ void *user_data,
+ bt_att_destroy_func_t destroy)
+{
+ struct att_send_op *op;
+
+ if (!chan || !chan->att)
+ return -EINVAL;
+
+ op = create_att_send_op(chan->att, opcode, pdu, len, callback,
+ user_data, destroy);
+ if (!op)
+ return -EINVAL;
+
+ if (!queue_push_tail(chan->queue, op)) {
+ free(op->pdu);
+ free(op);
+ return 0;
+ }
+
+ wakeup_chan_writer(chan, NULL);
+
+ return op->id;
+}
+
static bool match_op_id(const void *a, const void *b)
{
const struct att_send_op *op = a;
return op->id == id;
}
+bool bt_att_chan_cancel(struct bt_att_chan *chan, unsigned int id)
+{
+ struct att_send_op *op;
+
+ if (chan->pending_req && chan->pending_req->id == id) {
+ /* Don't cancel the pending request; remove it's handlers */
+ cancel_att_send_op(chan->pending_req);
+ return true;
+ }
+
+ if (chan->pending_ind && chan->pending_ind->id == id) {
+ /* Don't cancel the pending indication; remove it's handlers. */
+ cancel_att_send_op(chan->pending_ind);
+ return true;
+ }
+
+ op = queue_remove_if(chan->queue, match_op_id, UINT_TO_PTR(id));
+ if (!op)
+ return false;
+
+ destroy_att_send_op(op);
+
+ wakeup_chan_writer(chan, NULL);
+
+ return true;
+}
+
bool bt_att_cancel(struct bt_att *att, unsigned int id)
{
const struct queue_entry *entry;
entry = entry->next) {
struct bt_att_chan *chan = entry->data;
- if (chan->pending_req && chan->pending_req->id == id) {
- /* Don't cancel the pending request; remove it's
- * handlers
- */
- cancel_att_send_op(chan->pending_req);
- return true;
- }
-
- if (chan->pending_ind && chan->pending_ind->id == id) {
- /* Don't cancel the pending indication; remove it's
- * handlers.
- */
- cancel_att_send_op(chan->pending_ind);
+ if (bt_att_chan_cancel(chan, id))
return true;
}
- }
op = queue_remove_if(att->req_queue, match_op_id, UINT_TO_PTR(id));
if (op)
return BT_ATT_ERROR_UNLIKELY;
}
-unsigned int bt_att_send_error_rsp(struct bt_att *att, uint8_t opcode,
+int bt_att_chan_send_error_rsp(struct bt_att_chan *chan, uint8_t opcode,
uint16_t handle, int error)
{
struct bt_att_pdu_error_rsp pdu;
uint8_t ecode;
- if (!att || !opcode)
- return 0;
+ if (!chan || !chan->att || !opcode)
+ return -EINVAL;
ecode = att_ecode_from_error(error);
put_le16(handle, &pdu.handle);
pdu.ecode = ecode;
- return bt_att_send(att, BT_ATT_OP_ERROR_RSP, &pdu, sizeof(pdu),
- NULL, NULL, NULL);
+ return bt_att_chan_send_rsp(chan, BT_ATT_OP_ERROR_RSP, &pdu,
+ sizeof(pdu));
}
unsigned int bt_att_register(struct bt_att *att, uint8_t opcode,
if (!att)
return -EINVAL;
- chan = queue_peek_head(att->chans);
+ chan = queue_peek_tail(att->chans);
if (!chan)
return -ENOTCONN;
level > BT_ATT_SECURITY_HIGH)
return false;
- chan = queue_peek_head(att->chans);
+ chan = queue_peek_tail(att->chans);
if (!chan)
return -ENOTCONN;
#endif
struct bt_att;
+struct bt_att_chan;
struct bt_att *bt_att_new(int fd, bool ext_signed);
typedef void (*bt_att_response_func_t)(uint8_t opcode, const void *pdu,
uint16_t length, void *user_data);
-typedef void (*bt_att_notify_func_t)(uint8_t opcode, const void *pdu,
+typedef void (*bt_att_notify_func_t)(struct bt_att_chan *chan,
+ uint8_t opcode, const void *pdu,
uint16_t length, void *user_data);
typedef void (*bt_att_destroy_func_t)(void *user_data);
typedef void (*bt_att_debug_func_t)(const char *str, void *user_data);
bt_att_response_func_t callback,
void *user_data,
bt_att_destroy_func_t destroy);
+unsigned int bt_att_chan_send(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t len,
+ bt_att_response_func_t callback,
+ void *user_data,
+ bt_att_destroy_func_t destroy);
+#define bt_att_chan_send_rsp(chan, opcode, pdu, len) \
+ bt_att_chan_send(chan, opcode, pdu, len, NULL, NULL, NULL)
+bool bt_att_chan_cancel(struct bt_att_chan *chan, unsigned int id);
bool bt_att_cancel(struct bt_att *att, unsigned int id);
bool bt_att_cancel_all(struct bt_att *att);
-unsigned int bt_att_send_error_rsp(struct bt_att *att, uint8_t opcode,
+int bt_att_chan_send_error_rsp(struct bt_att_chan *chan, uint8_t opcode,
uint16_t handle, int error);
unsigned int bt_att_register(struct bt_att *att, uint8_t opcode,
struct bt_gatt_client {
struct bt_att *att;
int ref_count;
+ uint8_t features;
struct bt_gatt_client *parent;
struct queue *clones;
uint16_t length;
};
-static void notify_cb(uint8_t opcode, const void *pdu, uint16_t length,
+static void notify_cb(struct bt_att_chan *chan, uint8_t opcode, const void *pdu, uint16_t length,
void *user_data);
static void notification_free(void *data)
struct queue *ext_prop_desc;
struct gatt_db_attribute *cur_svc;
struct gatt_db_attribute *hash;
+ uint8_t server_feat;
bool success;
uint16_t start;
uint16_t end;
bt_gatt_client_ref(client);
client->ready = success;
+ if (client->parent)
+ client->features = client->parent->features;
+
for (entry = queue_get_entries(client->ready_cbs); entry;
entry = entry->next) {
struct ready_cb *ready = entry->data;
return true;
}
+static void db_server_feat_read(bool success, uint8_t att_ecode,
+ struct bt_gatt_result *result, void *user_data)
+{
+ struct discovery_op *op = user_data;
+ struct bt_gatt_client *client = op->client;
+ const uint8_t *value;
+ uint16_t len, handle;
+ struct bt_gatt_iter iter;
+
+ if (!result)
+ return;
+
+ bt_gatt_iter_init(&iter, result);
+ bt_gatt_iter_next_read_by_type(&iter, &handle, &len, &value);
+
+ util_debug(client->debug_callback, client->debug_data,
+ "Server Features found: handle 0x%04x "
+ "length 0x%04x value 0x%02x", handle, len,
+ value[0]);
+
+ op->server_feat = value[0];
+}
+
+static void server_feat_read_value(struct gatt_db_attribute *attrib,
+ int err, const uint8_t *value,
+ size_t length, void *user_data)
+{
+ const uint8_t **feat = user_data;
+
+ if (err)
+ return;
+
+ *feat = value;
+}
+
+static void read_server_feat(struct discovery_op *op)
+{
+ struct bt_gatt_client *client = op->client;
+ struct gatt_db_attribute *attr = NULL;
+ const uint8_t *feat = NULL;
+ bt_uuid_t uuid;
+
+ bt_uuid16_create(&uuid, GATT_CHARAC_SERVER_FEAT);
+
+ gatt_db_find_by_type(client->db, 0x0001, 0xffff, &uuid,
+ get_first_attribute, &attr);
+ if (attr) {
+ /* Read stored value in the db */
+ gatt_db_attribute_read(attr, 0, BT_ATT_OP_READ_REQ, NULL,
+ server_feat_read_value, &feat);
+ if (feat)
+ return;
+ }
+
+ if (!bt_gatt_read_by_type(client->att, 0x0001, 0xffff, &uuid,
+ db_server_feat_read,
+ discovery_op_ref(op),
+ discovery_op_unref))
+ discovery_op_unref(op);
+}
+
static void exchange_mtu_cb(bool success, uint8_t att_ecode, void *user_data)
{
struct discovery_op *op = user_data;
#ifdef TIZEN_FEATURE_BLUEZ_MODIFY
op->success = false;
#endif
+ read_server_feat(op);
+
if (read_db_hash(op)) {
op->success = false;
- return;
+ return;
}
discover_all(op);
struct noti *noti;
while ((noti = queue_pop_head(client->pending_noti))) {
- notify_cb(noti->opcode, noti->pdu,
+ notify_cb(NULL, noti->opcode, noti->pdu,
noti->length, client);
notification_free(noti);
}
queue_push_tail(client->svc_chngd_queue, op);
}
+static void server_feat_write_value(struct gatt_db_attribute *attrib,
+ int err, void *user_data)
+{
+ struct bt_gatt_client *client = user_data;
+
+ util_debug(client->debug_callback, client->debug_data,
+ "Server Features Value set status: %d", err);
+}
+
+static void write_server_features(struct bt_gatt_client *client, uint8_t feat)
+{
+ bt_uuid_t uuid;
+ struct gatt_db_attribute *attr = NULL;
+
+ bt_uuid16_create(&uuid, GATT_CHARAC_SERVER_FEAT);
+
+ gatt_db_find_by_type(client->db, 0x0001, 0xffff, &uuid,
+ get_first_attribute, &attr);
+ if (!attr)
+ return;
+
+ /* Store value in the DB */
+ if (!gatt_db_attribute_write(attr, 0, &feat, sizeof(feat),
+ 0, NULL, server_feat_write_value,
+ client))
+ util_debug(client->debug_callback, client->debug_data,
+ "Unable to store Server Features");
+}
+
static void write_client_features(struct bt_gatt_client *client)
{
bt_uuid_t uuid;
struct gatt_db_attribute *attr = NULL;
uint16_t handle;
- uint8_t value;
+ const uint8_t *feat = NULL;
bt_uuid16_create(&uuid, GATT_CHARAC_CLI_FEAT);
return;
handle = gatt_db_attribute_get_handle(attr);
- value = BT_GATT_CHRC_CLI_FEAT_ROBUST_CACHING;
+ client->features = BT_GATT_CHRC_CLI_FEAT_ROBUST_CACHING;
+
+ bt_uuid16_create(&uuid, GATT_CHARAC_SERVER_FEAT);
+
+ attr = NULL;
+ gatt_db_find_by_type(client->db, 0x0001, 0xffff, &uuid,
+ get_first_attribute, &attr);
+ if (attr) {
+ /* Read stored value in the db */
+ gatt_db_attribute_read(attr, 0, BT_ATT_OP_READ_REQ,
+ NULL, server_feat_read_value,
+ &feat);
+ if (feat && feat[0] & BT_GATT_CHRC_SERVER_FEAT_EATT)
+ client->features |= BT_GATT_CHRC_CLI_FEAT_EATT;
+ }
+
+ util_debug(client->debug_callback, client->debug_data,
+ "Writing Client Features 0x%02x", client->features);
- bt_gatt_client_write_value(client, handle, &value, sizeof(value), NULL,
- NULL, NULL);
+ bt_gatt_client_write_value(client, handle, &client->features,
+ sizeof(client->features), NULL, NULL, NULL);
}
static void init_complete(struct discovery_op *op, bool success,
if (!success)
goto fail;
+ if (op->server_feat)
+ write_server_features(client, op->server_feat);
+
write_client_features(client);
if (register_service_changed(client))
struct noti *noti;
while ((noti = queue_pop_head(client->pending_noti))) {
- notify_cb(noti->opcode, noti->pdu,
+ notify_cb(NULL, noti->opcode, noti->pdu,
noti->length, client);
notification_free(noti);
}
return true;
discover:
+ read_server_feat(op);
+
if (read_db_hash(op)) {
op->success = false;
goto done;
notify_data->user_data);
}
-static void notify_cb(uint8_t opcode, const void *pdu, uint16_t length,
- void *user_data)
+static void notify_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_client *client = user_data;
struct pdu_data pdu_data;
queue_foreach(client->notify_list, notify_handler, &pdu_data);
- if (opcode == BT_ATT_OP_HANDLE_VAL_IND && !client->parent)
+ if (opcode == BT_ATT_OP_HANDLE_VAL_IND && !client->parent){
+#ifdef TIZEN_FEATURE_BLUEZ_MODIFY
+ if (!chan)
bt_att_send(client->att, BT_ATT_OP_HANDLE_VAL_CONF, NULL, 0,
NULL, NULL, NULL);
+ else
+ bt_att_chan_send(chan, BT_ATT_OP_HANDLE_VAL_CONF, NULL, 0,
+ NULL, NULL, NULL);
+ }
+#else
+ bt_att_chan_send(chan, BT_ATT_OP_HANDLE_VAL_CONF, NULL, 0,
+ NULL, NULL, NULL);
+ }
+#endif
bt_gatt_client_unref(client);
}
}
static struct bt_gatt_client *gatt_client_new(struct gatt_db *db,
- struct bt_att *att)
+ struct bt_att *att,
+ uint8_t features)
{
struct bt_gatt_client *client;
client->att = bt_att_ref(att);
client->db = gatt_db_ref(db);
+ client->features = features;
return client;
struct bt_gatt_client *bt_gatt_client_new(struct gatt_db *db,
struct bt_att *att,
- uint16_t mtu)
+ uint16_t mtu,
+ uint8_t features)
{
struct bt_gatt_client *client;
if (!att || !db)
return NULL;
- client = gatt_client_new(db, att);
+ client = gatt_client_new(db, att, features);
if (!client)
return NULL;
if (!client)
return NULL;
- clone = gatt_client_new(client->db, client->att);
+ clone = gatt_client_new(client->db, client->att, client->features);
if (!clone)
return NULL;
return bt_att_get_mtu(client->att);
}
+struct bt_att *bt_gatt_client_get_att(struct bt_gatt_client *client)
+{
+ if (!client)
+ return NULL;
+
+ return client->att;
+}
+
struct gatt_db *bt_gatt_client_get_db(struct bt_gatt_client *client)
{
if (!client || !client->db)
return client->db;
}
+uint8_t bt_gatt_client_get_features(struct bt_gatt_client *client)
+{
+ if (!client)
+ return 0;
+
+ if (client->parent)
+ return client->parent->features;
+
+ return client->features;
+}
+
static bool match_req_id(const void *a, const void *b)
{
const struct request *req = a;
struct bt_gatt_client *bt_gatt_client_new(struct gatt_db *db,
struct bt_att *att,
- uint16_t mtu);
+ uint16_t mtu,
+ uint8_t features);
struct bt_gatt_client *bt_gatt_client_clone(struct bt_gatt_client *client);
struct bt_gatt_client *bt_gatt_client_ref(struct bt_gatt_client *client);
bt_gatt_client_destroy_func_t destroy);
uint16_t bt_gatt_client_get_mtu(struct bt_gatt_client *client);
+struct bt_att *bt_gatt_client_get_att(struct bt_gatt_client *client);
struct gatt_db *bt_gatt_client_get_db(struct bt_gatt_client *client);
+uint8_t bt_gatt_client_get_features(struct bt_gatt_client *client);
bool bt_gatt_client_cancel(struct bt_gatt_client *client, unsigned int id);
bool bt_gatt_client_cancel_all(struct bt_gatt_client *client);
#define DEFAULT_MAX_PREP_QUEUE_LEN 30
struct async_read_op {
+ struct bt_att_chan *chan;
struct bt_gatt_server *server;
uint8_t opcode;
bool done;
};
struct async_write_op {
+ struct bt_att_chan *chan;
struct bt_gatt_server *server;
uint8_t opcode;
};
return true;
}
-static void read_by_grp_type_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void read_by_grp_type_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t start, end;
queue_destroy(q, NULL);
- bt_att_send(server->att, BT_ATT_OP_READ_BY_GRP_TYPE_RSP,
- rsp_pdu, rsp_len,
- NULL, NULL, NULL);
+ bt_att_chan_send_rsp(chan, BT_ATT_OP_READ_BY_GRP_TYPE_RSP,
+ rsp_pdu, rsp_len);
return;
error:
queue_destroy(q, NULL);
- bt_att_send_error_rsp(server->att, opcode, ehandle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, ehandle, ecode);
}
static void async_read_op_destroy(struct async_read_op *op)
/* Terminate the operation if there was an error */
if (err) {
- bt_att_send_error_rsp(server->att, BT_ATT_OP_READ_BY_TYPE_REQ,
+ bt_att_chan_send_error_rsp(op->chan, BT_ATT_OP_READ_BY_TYPE_REQ,
handle, err);
async_read_op_destroy(op);
return;
attr = queue_pop_head(op->db_data);
if (op->done || !attr) {
- bt_att_send(server->att, BT_ATT_OP_READ_BY_TYPE_RSP, op->pdu,
- op->pdu_len,
- NULL, NULL,
- NULL);
+ bt_att_chan_send_rsp(op->chan, BT_ATT_OP_READ_BY_TYPE_RSP,
+ op->pdu, op->pdu_len);
async_read_op_destroy(op);
return;
}
ecode = BT_ATT_ERROR_UNLIKELY;
error:
- bt_att_send_error_rsp(server->att, BT_ATT_OP_READ_BY_TYPE_REQ,
+ bt_att_chan_send_error_rsp(op->chan, BT_ATT_OP_READ_BY_TYPE_REQ,
gatt_db_attribute_get_handle(attr), ecode);
async_read_op_destroy(op);
}
-static void read_by_type_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void read_by_type_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t start, end;
goto error;
}
+ op->chan = chan;
op->opcode = opcode;
op->server = server;
op->db_data = q;
return;
error:
- bt_att_send_error_rsp(server->att, opcode, ehandle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, ehandle, ecode);
queue_destroy(q, NULL);
}
return true;
}
-static void find_info_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void find_info_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t start, end;
goto error;
}
- bt_att_send(server->att, BT_ATT_OP_FIND_INFO_RSP, rsp_pdu, rsp_len,
- NULL, NULL, NULL);
+ bt_att_chan_send_rsp(chan, BT_ATT_OP_FIND_INFO_RSP, rsp_pdu, rsp_len);
queue_destroy(q, NULL);
return;
error:
- bt_att_send_error_rsp(server->att, opcode, ehandle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, ehandle, ecode);
queue_destroy(q, NULL);
}
data->len += 4;
}
-static void find_by_type_val_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void find_by_type_val_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t start, end, uuid16;
if (data.ecode)
goto error;
- bt_att_send(server->att, BT_ATT_OP_FIND_BY_TYPE_RSP, data.pdu,
- data.len, NULL, NULL, NULL);
+ bt_att_chan_send_rsp(chan, BT_ATT_OP_FIND_BY_TYPE_RSP,
+ data.pdu, data.len);
return;
error:
- bt_att_send_error_rsp(server->att, opcode, ehandle, data.ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, ehandle, data.ecode);
}
static void async_write_op_destroy(struct async_write_op *op)
struct bt_gatt_server *server = op->server;
uint16_t handle;
+ util_debug(server->debug_callback, server->debug_data,
+ "Write Complete: err %d", err);
+
if (!server || op->opcode == BT_ATT_OP_WRITE_CMD) {
async_write_op_destroy(op);
return;
handle = gatt_db_attribute_get_handle(attr);
if (err)
- bt_att_send_error_rsp(server->att, op->opcode, handle, err);
+ bt_att_chan_send_error_rsp(op->chan, op->opcode, handle, err);
else
- bt_att_send(server->att, BT_ATT_OP_WRITE_RSP, NULL, 0,
- NULL, NULL, NULL);
+ bt_att_chan_send_rsp(op->chan, BT_ATT_OP_WRITE_RSP, NULL, 0);
async_write_op_destroy(op);
}
server->authorize_data);
}
-static void write_cb(uint8_t opcode, const void *pdu,
+static void write_cb(struct bt_att_chan *chan, uint8_t opcode, const void *pdu,
uint16_t length, void *user_data)
{
struct bt_gatt_server *server = user_data;
}
op = new0(struct async_write_op, 1);
+ op->chan = chan;
op->server = server;
op->opcode = opcode;
if (opcode == BT_ATT_OP_WRITE_CMD)
return;
- bt_att_send_error_rsp(server->att, opcode, handle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, handle, ecode);
}
static uint8_t get_read_rsp_opcode(uint8_t opcode)
uint16_t mtu;
uint16_t handle;
+ util_debug(server->debug_callback, server->debug_data,
+ "Read Complete: err %d", err);
+
if (!server) {
async_read_op_destroy(op);
return;
handle = gatt_db_attribute_get_handle(attr);
if (err) {
- bt_att_send_error_rsp(server->att, op->opcode, handle, err);
+ bt_att_chan_send_error_rsp(op->chan, op->opcode, handle, err);
async_read_op_destroy(op);
return;
}
rsp_opcode = get_read_rsp_opcode(op->opcode);
- bt_att_send(server->att, rsp_opcode, len ? value : NULL,
- MIN((unsigned) mtu - 1, len),
- NULL, NULL, NULL);
+ bt_att_chan_send_rsp(op->chan, rsp_opcode, len ? value : NULL,
+ MIN((unsigned int) mtu - 1, len));
async_read_op_destroy(op);
}
-static void handle_read_req(struct bt_gatt_server *server, uint8_t opcode,
- uint16_t handle,
- uint16_t offset)
+static void handle_read_req(struct bt_att_chan *chan,
+ struct bt_gatt_server *server, uint8_t opcode,
+ uint16_t handle, uint16_t offset)
{
struct gatt_db_attribute *attr;
uint8_t ecode;
}
op = new0(struct async_read_op, 1);
+ op->chan = chan;
op->opcode = opcode;
op->server = server;
server->pending_read_op = op;
if (op)
async_read_op_destroy(op);
- bt_att_send_error_rsp(server->att, opcode, handle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, handle, ecode);
}
-static void read_cb(uint8_t opcode, const void *pdu,
+static void read_cb(struct bt_att_chan *chan, uint8_t opcode, const void *pdu,
uint16_t length, void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t handle;
if (length != 2) {
- bt_att_send_error_rsp(server->att, opcode, 0,
+ bt_att_chan_send_error_rsp(chan, opcode, 0,
BT_ATT_ERROR_INVALID_PDU);
return;
}
handle = get_le16(pdu);
- handle_read_req(server, opcode, handle, 0);
+ handle_read_req(chan, server, opcode, handle, 0);
}
-static void read_blob_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void read_blob_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t handle, offset;
if (length != 4) {
- bt_att_send_error_rsp(server->att, opcode, 0,
+ bt_att_chan_send_error_rsp(chan, opcode, 0,
BT_ATT_ERROR_INVALID_PDU);
return;
}
handle = get_le16(pdu);
offset = get_le16(pdu + 2);
- handle_read_req(server, opcode, handle, offset);
+ handle_read_req(chan, server, opcode, handle, offset);
}
struct read_multiple_resp_data {
+ struct bt_att_chan *chan;
struct bt_gatt_server *server;
uint16_t *handles;
size_t cur_handle;
uint8_t ecode;
if (err != 0) {
- bt_att_send_error_rsp(data->server->att,
+ bt_att_chan_send_error_rsp(data->chan,
BT_ATT_OP_READ_MULT_REQ, handle, err);
read_multiple_resp_data_free(data);
return;
BT_ATT_PERM_READ_AUTHEN |
BT_ATT_PERM_READ_ENCRYPT);
if (ecode) {
- bt_att_send_error_rsp(data->server->att,
+ bt_att_chan_send_error_rsp(data->chan,
BT_ATT_OP_READ_MULT_REQ, handle, ecode);
read_multiple_resp_data_free(data);
return;
if ((data->length >= data->mtu - 1) ||
(data->cur_handle == data->num_handles)) {
- bt_att_send(data->server->att, BT_ATT_OP_READ_MULT_RSP,
- data->rsp_data, data->length, NULL, NULL, NULL);
+ bt_att_chan_send_rsp(data->chan, BT_ATT_OP_READ_MULT_RSP,
+ data->rsp_data, data->length);
read_multiple_resp_data_free(data);
return;
}
data->handles[data->cur_handle]);
if (!next_attr) {
- bt_att_send_error_rsp(data->server->att,
+ bt_att_chan_send_error_rsp(data->chan,
BT_ATT_OP_READ_MULT_REQ,
data->handles[data->cur_handle],
BT_ATT_ERROR_INVALID_HANDLE);
if (!gatt_db_attribute_read(next_attr, 0, BT_ATT_OP_READ_MULT_REQ,
data->server->att,
read_multiple_complete_cb, data)) {
- bt_att_send_error_rsp(data->server->att,
+ bt_att_chan_send_error_rsp(data->chan,
BT_ATT_OP_READ_MULT_REQ,
data->handles[data->cur_handle],
BT_ATT_ERROR_UNLIKELY);
}
}
-static void read_multiple_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void read_multiple_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
struct gatt_db_attribute *attr;
}
data = new0(struct read_multiple_resp_data, 1);
+ data->chan = chan;
data->handles = NULL;
data->rsp_data = NULL;
data->server = server;
if (data)
read_multiple_resp_data_free(data);
- bt_att_send_error_rsp(server->att, opcode, 0, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, 0, ecode);
}
static bool append_prep_data(struct prep_write_data *prep_data, uint16_t handle,
}
struct prep_write_complete_data {
+ struct bt_att_chan *chan;
void *pdu;
uint16_t length;
struct bt_gatt_server *server;
handle = get_le16(pwcd->pdu);
if (err) {
- bt_att_send_error_rsp(pwcd->server->att,
- BT_ATT_OP_PREP_WRITE_REQ, handle, err);
+ bt_att_chan_send_error_rsp(pwcd->chan, BT_ATT_OP_PREP_WRITE_REQ,
+ handle, err);
free(pwcd->pdu);
free(pwcd);
if (!store_prep_data(pwcd->server, handle, offset, pwcd->length - 4,
&((uint8_t *) pwcd->pdu)[4]))
- bt_att_send_error_rsp(pwcd->server->att,
- BT_ATT_OP_PREP_WRITE_RSP, handle,
+ bt_att_chan_send_error_rsp(pwcd->chan, BT_ATT_OP_PREP_WRITE_RSP,
+ handle,
BT_ATT_ERROR_INSUFFICIENT_RESOURCES);
- bt_att_send(pwcd->server->att, BT_ATT_OP_PREP_WRITE_RSP, pwcd->pdu,
- pwcd->length, NULL, NULL, NULL);
+ bt_att_chan_send_rsp(pwcd->chan, BT_ATT_OP_PREP_WRITE_RSP, pwcd->pdu,
+ pwcd->length);
free(pwcd->pdu);
free(pwcd);
}
-static void prep_write_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void prep_write_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t handle = 0;
goto error;
pwcd = new0(struct prep_write_complete_data, 1);
+ pwcd->chan = chan;
pwcd->pdu = malloc(length);
memcpy(pwcd->pdu, pdu, length);
pwcd->length = length;
ecode = BT_ATT_ERROR_UNLIKELY;
error:
- bt_att_send_error_rsp(server->att, opcode, handle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, handle, ecode);
}
-static void exec_next_prep_write(struct bt_gatt_server *server,
- uint16_t ehandle, int err);
+struct exec_data {
+ struct bt_att_chan *chan;
+ struct bt_gatt_server *server;
+};
+
+static void exec_next_prep_write(struct exec_data *data, uint16_t ehandle,
+ int err);
static void exec_write_complete_cb(struct gatt_db_attribute *attr, int err,
void *user_data)
{
- struct bt_gatt_server *server = user_data;
+ struct exec_data *data = user_data;
uint16_t handle = gatt_db_attribute_get_handle(attr);
- exec_next_prep_write(server, handle, err);
+ exec_next_prep_write(data, handle, err);
}
-static void exec_next_prep_write(struct bt_gatt_server *server,
- uint16_t ehandle, int err)
+static void exec_next_prep_write(struct exec_data *data, uint16_t ehandle,
+ int err)
{
struct prep_write_data *next = NULL;
struct gatt_db_attribute *attr;
if (err)
goto error;
- next = queue_pop_head(server->prep_queue);
+ next = queue_pop_head(data->server->prep_queue);
if (!next) {
- bt_att_send(server->att, BT_ATT_OP_EXEC_WRITE_RSP, NULL, 0,
- NULL, NULL, NULL);
+ bt_att_chan_send_rsp(data->chan, BT_ATT_OP_EXEC_WRITE_RSP,
+ NULL, 0);
+ free(data);
return;
}
- attr = gatt_db_get_attribute(server->db, next->handle);
+ attr = gatt_db_get_attribute(data->server->db, next->handle);
if (!attr) {
err = BT_ATT_ERROR_UNLIKELY;
goto error;
status = gatt_db_attribute_write(attr, next->offset,
next->value, next->length,
BT_ATT_OP_EXEC_WRITE_REQ,
- server->att,
- exec_write_complete_cb, server);
+ data->server->att,
+ exec_write_complete_cb, data);
prep_write_data_destroy(next);
err = BT_ATT_ERROR_UNLIKELY;
error:
- queue_remove_all(server->prep_queue, NULL, NULL,
+ queue_remove_all(data->server->prep_queue, NULL, NULL,
prep_write_data_destroy);
- bt_att_send_error_rsp(server->att, BT_ATT_OP_EXEC_WRITE_REQ,
+ bt_att_chan_send_error_rsp(data->chan, BT_ATT_OP_EXEC_WRITE_REQ,
ehandle, err);
+ free(data);
}
static bool find_no_reliable_characteristic(const void *data,
return !prep_data->reliable_supported;
}
-static void exec_write_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void exec_write_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
+ struct exec_data *data;
uint8_t flags;
uint8_t ecode;
bool write;
if (!write) {
queue_remove_all(server->prep_queue, NULL, NULL,
prep_write_data_destroy);
- bt_att_send(server->att, BT_ATT_OP_EXEC_WRITE_RSP, NULL, 0,
- NULL, NULL, NULL);
+ bt_att_chan_send_rsp(chan, BT_ATT_OP_EXEC_WRITE_RSP, NULL, 0);
return;
}
}
}
- exec_next_prep_write(server, 0, 0);
+ data = new0(struct exec_data, 1);
+ data->chan = chan;
+ data->server = server;
+ exec_next_prep_write(data, 0, 0);
return;
error:
queue_remove_all(server->prep_queue, NULL, NULL,
prep_write_data_destroy);
- bt_att_send_error_rsp(server->att, opcode, ehandle, ecode);
+ bt_att_chan_send_error_rsp(chan, opcode, ehandle, ecode);
}
-static void exchange_mtu_cb(uint8_t opcode, const void *pdu,
- uint16_t length, void *user_data)
+static void exchange_mtu_cb(struct bt_att_chan *chan, uint8_t opcode,
+ const void *pdu, uint16_t length,
+ void *user_data)
{
struct bt_gatt_server *server = user_data;
uint16_t client_rx_mtu;
uint8_t rsp_pdu[2];
if (length != 2) {
- bt_att_send_error_rsp(server->att, opcode, 0,
+ bt_att_chan_send_error_rsp(chan, opcode, 0,
BT_ATT_ERROR_INVALID_PDU);
return;
}
/* Respond with the server MTU */
put_le16(server->mtu, rsp_pdu);
- bt_att_send(server->att, BT_ATT_OP_MTU_RSP, rsp_pdu, 2, NULL, NULL,
- NULL);
+ bt_att_chan_send_rsp(chan, BT_ATT_OP_MTU_RSP, rsp_pdu, 2);
/* Set MTU to be the minimum */
server->mtu = final_mtu;
return NULL;
}
- cli->gatt = bt_gatt_client_new(cli->db, cli->att, mtu);
+ cli->gatt = bt_gatt_client_new(cli->db, cli->att, mtu, 0);
if (!cli->gatt) {
fprintf(stderr, "Failed to create GATT client\n");
gatt_db_unref(cli->db);
raw_pdu(0x03, 0x00, 0x02)
#ifdef TIZEN_FEATURE_BLUEZ_MODIFY
-#define SERVICE_DATA_1_PDUS \
+#define READ_SERVER_FEAT_PDUS \
+ raw_pdu(0x08, 0x01, 0x00, 0xff, 0xff, 0x3a, 0x2b), \
+ raw_pdu(0x01, 0x08, 0x01, 0x00, 0x0a)
+
+#define CLIENT_INIT_PDUS \
MTU_EXCHANGE_CLIENT_PDUS, \
+ READ_SERVER_FEAT_PDUS
+
+#define SERVICE_DATA_1_PDUS \
+ CLIENT_INIT_PDUS, \
raw_pdu(0x10, 0x01, 0x00, 0xff, 0xff, 0x00, 0x28), \
raw_pdu(0x11, 0x06, 0x01, 0x00, 0x04, 0x00, 0x01, 0x18),\
raw_pdu(0x10, 0x05, 0x00, 0xff, 0xff, 0x00, 0x28), \
raw_pdu(0x05, 0x01, 0x08, 0x00, 0x01, 0x29)
#else
#define SERVICE_DATA_1_PDUS \
- MTU_EXCHANGE_CLIENT_PDUS, \
+ CLIENT_INIT_PDUS, \
raw_pdu(0x10, 0x01, 0x00, 0xff, 0xff, 0x00, 0x28), \
raw_pdu(0x11, 0x06, 0x01, 0x00, 0x04, 0x00, 0x01, 0x18),\
raw_pdu(0x10, 0x05, 0x00, 0xff, 0xff, 0x00, 0x28), \
#ifdef TIZEN_FEATURE_BLUEZ_MODIFY
#define SERVICE_DATA_2_PDUS \
- MTU_EXCHANGE_CLIENT_PDUS, \
+ CLIENT_INIT_PDUS, \
raw_pdu(0x10, 0x01, 0x00, 0xff, 0xff, 0x00, 0x28), \
raw_pdu(0x11, 0x06, 0x01, 0x00, 0x04, 0x00, 0x01, 0x18),\
raw_pdu(0x10, 0x05, 0x00, 0xff, 0xff, 0x00, 0x28), \
g_assert(context->client_db);
context->client = bt_gatt_client_new(context->client_db,
- context->att, mtu);
+ context->att, mtu, 0);
g_assert(context->client);
bt_gatt_client_set_debug(context->client, print_debug,
define_test_att("/TP/GAD/CL/BV-01-C", test_search_primary, NULL, NULL,
raw_pdu(0x02, 0x00, 0x02),
raw_pdu(0x03, 0x00, 0x02),
+ MTU_EXCHANGE_CLIENT_PDUS,
raw_pdu(0x10, 0x01, 0x00, 0xff, 0xff, 0x00, 0x28),
raw_pdu(0x11, 0x06, 0x10, 0x00, 0x13, 0x00, 0x00, 0x18,
0x20, 0x00, 0x29, 0x00, 0xb0, 0x68,
define_test_client("/TP/GAN/CL/BV-01-C", test_client, ts_small_db,
&test_notification_1,
- MTU_EXCHANGE_CLIENT_PDUS,
+ CLIENT_INIT_PDUS,
SMALL_DB_DISCOVERY_PDUS,
raw_pdu(0x12, 0x04, 0x00, 0x03, 0x00),
raw_pdu(0x13),
define_test_client("/TP/GAI/CL/BV-01-C", test_client, ts_small_db,
&test_indication_1,
- MTU_EXCHANGE_CLIENT_PDUS,
+ CLIENT_INIT_PDUS,
SMALL_DB_DISCOVERY_PDUS,
raw_pdu(0x12, 0x04, 0x00, 0x03, 0x00),
raw_pdu(0x13),
projects / platform / upstream / bluez.git / commitdiff