blob: 8771c395b8ec45ca35eda07eda0cde90d1e17844 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
#include <string.h>
#include <errno.h>
#include <assert.h>
#include "host/ble_gap.h"
#include "host/ble_gatt.h"
#include "console/console.h"
#include "services/gatt/ble_svc_gatt.h"
#include "../../../nimble/host/src/ble_att_priv.h"
#include "../../../nimble/host/src/ble_gatt_priv.h"
#include "btp/btp.h"
#define CONTROLLER_INDEX 0
#define MAX_BUFFER_SIZE 2048
/* Convert UUID from BTP command to bt_uuid */
static uint8_t
btp2bt_uuid(const uint8_t *uuid, uint8_t len,
ble_uuid_any_t *bt_uuid)
{
uint16_t le16;
switch (len) {
case 0x02: /* UUID 16 */
bt_uuid->u.type = BLE_UUID_TYPE_16;
memcpy(&le16, uuid, sizeof(le16));
BLE_UUID16(bt_uuid)->value = le16toh(le16);
break;
case 0x10: /* UUID 128*/
bt_uuid->u.type = BLE_UUID_TYPE_128;
memcpy(BLE_UUID128(bt_uuid)->value, uuid, 16);
break;
default:
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
/*
* gatt_buf - cache used by a gatt client (to cache data read/discovered)
* and gatt server (to store attribute user_data).
* It is not intended to be used by client and server at the same time.
*/
static struct {
uint16_t len;
uint8_t buf[MAX_BUFFER_SIZE];
uint16_t cnt;
} gatt_buf;
static struct bt_gatt_subscribe_params {
uint16_t ccc_handle;
uint16_t value;
uint16_t value_handle;
} subscribe_params;
static void *
gatt_buf_add(const void *data, size_t len)
{
void *ptr = gatt_buf.buf + gatt_buf.len;
if ((len + gatt_buf.len) > MAX_BUFFER_SIZE) {
return NULL;
}
if (data) {
memcpy(ptr, data, len);
} else {
(void) memset(ptr, 0, len);
}
gatt_buf.len += len;
SYS_LOG_DBG("%d/%d used", gatt_buf.len, MAX_BUFFER_SIZE);
return ptr;
}
static void *
gatt_buf_reserve(size_t len)
{
return gatt_buf_add(NULL, len);
}
static void
gatt_buf_clear(void)
{
(void) memset(&gatt_buf, 0, sizeof(gatt_buf));
}
static void
discover_destroy(void)
{
gatt_buf_clear();
}
static void
read_destroy()
{
gatt_buf_clear();
}
static int
tester_mtu_exchanged_ev(uint16_t conn_handle,
const struct ble_gatt_error *error,
uint16_t mtu, void *arg)
{
struct btp_gattc_exchange_mtu_ev *ev;
struct ble_gap_conn_desc conn;
struct os_mbuf *buf = os_msys_get(0, 0);
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
goto fail;
}
ev = os_mbuf_extend(buf, sizeof(*ev));
if (!ev) {
return 0;
}
memcpy(&ev->address, &conn.peer_ota_addr, sizeof(ev->address));
ev->mtu = mtu;
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_EV_MTU_EXCHANGED,
buf->om_data, buf->om_len);
fail:
os_mbuf_free_chain(buf);
return 0;
}
static uint8_t
exchange_mtu(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_exchange_mtu_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (ble_gattc_exchange_mtu(conn.conn_handle,
tester_mtu_exchanged_ev,
NULL)) {
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
disc_prim_svcs_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
const struct ble_gatt_svc *gatt_svc, void *arg)
{
struct btp_gattc_disc_prim_svcs_rp *rp;
struct ble_gap_conn_desc conn;
struct btp_gatt_service *service;
const ble_uuid_any_t *uuid;
uint8_t uuid_length;
struct os_mbuf *buf = os_msys_get(0, 0);
uint8_t opcode = (uint8_t) (int) arg;
uint8_t err = (uint8_t) error->status;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->services_count = 0;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
if (error->status == BLE_HS_EDONE) {
rp->status = 0;
rp->services_count = gatt_buf.cnt;
os_mbuf_append(buf, gatt_buf.buf, gatt_buf.len);
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
uuid = &gatt_svc->uuid;
uuid_length = (uint8_t) (uuid->u.type == BLE_UUID_TYPE_16 ? 2 : 16);
service = gatt_buf_reserve(sizeof(*service) + uuid_length);
if (!service) {
discover_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
service->start_handle = htole16(gatt_svc->start_handle);
service->end_handle = htole16(gatt_svc->end_handle);
service->uuid_length = uuid_length;
if (uuid->u.type == BLE_UUID_TYPE_16) {
uint16_t u16 = htole16(BLE_UUID16(uuid)->value);
memcpy(service->uuid, &u16, uuid_length);
} else {
memcpy(service->uuid, BLE_UUID128(uuid)->value,
uuid_length);
}
gatt_buf.cnt++;
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
disc_all_prim_svcs(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_disc_all_prim_svcs_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (ble_gattc_disc_all_svcs(conn.conn_handle, disc_prim_svcs_cb,
(void *) BTP_GATTC_DISC_ALL_PRIM_RP)) {
discover_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static uint8_t
disc_prim_uuid(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_disc_prim_uuid_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
ble_uuid_any_t uuid;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (btp2bt_uuid(cp->uuid, cp->uuid_length, &uuid)) {
return BTP_STATUS_FAILED;
}
if (ble_gattc_disc_svc_by_uuid(conn.conn_handle,
&uuid.u, disc_prim_svcs_cb,
(void *) BTP_GATTC_DISC_PRIM_UUID_RP)) {
discover_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
find_included_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
const struct ble_gatt_svc *gatt_svc, void *arg)
{
struct btp_gattc_find_included_rp *rp;
struct btp_gatt_included *included;
const ble_uuid_any_t *uuid;
int service_handle = (int) arg;
uint8_t uuid_length;
uint8_t err = (uint8_t) error->status;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
SYS_LOG_DBG("");
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->services_count = 0;
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_FIND_INCLUDED_RP,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
if (error->status == BLE_HS_EDONE) {
rp->status = 0;
rp->services_count = gatt_buf.cnt;
os_mbuf_append(buf, gatt_buf.buf, gatt_buf.len);
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_FIND_INCLUDED_RP,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
uuid = &gatt_svc->uuid;
uuid_length = (uint8_t) (uuid->u.type == BLE_UUID_TYPE_16 ? 2 : 16);
included = gatt_buf_reserve(sizeof(*included) + uuid_length);
if (!included) {
discover_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
included->included_handle = htole16(service_handle + 1 +
rp->services_count);
included->service.start_handle = htole16(gatt_svc->start_handle);
included->service.end_handle = htole16(gatt_svc->end_handle);
included->service.uuid_length = uuid_length;
if (uuid->u.type == BLE_UUID_TYPE_16) {
uint16_t u16 = htole16(BLE_UUID16(uuid)->value);
memcpy(included->service.uuid, &u16, uuid_length);
} else {
memcpy(included->service.uuid, BLE_UUID128(uuid)->value,
uuid_length);
}
gatt_buf.cnt++;
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
find_included(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_find_included_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
uint16_t start_handle, end_handle;
int service_handle_arg;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
start_handle = le16toh(cp->start_handle);
end_handle = le16toh(cp->end_handle);
service_handle_arg = start_handle;
if (ble_gattc_find_inc_svcs(conn.conn_handle, start_handle, end_handle,
find_included_cb,
(void *) service_handle_arg)) {
discover_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
disc_chrc_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
const struct ble_gatt_chr *gatt_chr, void *arg)
{
struct btp_gattc_disc_chrc_rp *rp;
struct btp_gatt_characteristic *chrc;
const ble_uuid_any_t *uuid;
uint8_t uuid_length;
uint8_t opcode = (uint8_t) (int) arg;
uint8_t err = (uint8_t) error->status;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->characteristics_count = 0;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
if (error->status == BLE_HS_EDONE) {
rp->status = 0;
rp->characteristics_count = gatt_buf.cnt;
os_mbuf_append(buf, gatt_buf.buf, gatt_buf.len);
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
uuid = &gatt_chr->uuid;
uuid_length = (uint8_t) (uuid->u.type == BLE_UUID_TYPE_16 ? 2 : 16);
chrc = gatt_buf_reserve(sizeof(*chrc) + uuid_length);
if (!chrc) {
discover_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
chrc->characteristic_handle = htole16(gatt_chr->def_handle);
chrc->properties = gatt_chr->properties;
chrc->value_handle = htole16(gatt_chr->val_handle);
chrc->uuid_length = uuid_length;
if (uuid->u.type == BLE_UUID_TYPE_16) {
uint16_t u16 = htole16(BLE_UUID16(uuid)->value);
memcpy(chrc->uuid, &u16, uuid_length);
} else {
memcpy(chrc->uuid, BLE_UUID128(uuid)->value,
uuid_length);
}
gatt_buf.cnt++;
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
disc_all_chrc(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_disc_all_chrc_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
uint16_t start_handle, end_handle;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
SYS_LOG_DBG("Conn find rsped");
return BTP_STATUS_FAILED;
}
start_handle = le16toh(cp->start_handle);
end_handle = le16toh(cp->end_handle);
rc = ble_gattc_disc_all_chrs(conn.conn_handle,
start_handle,
end_handle,
disc_chrc_cb,
(void *) BTP_GATTC_DISC_ALL_CHRC_RP);
if (rc) {
discover_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static uint8_t
disc_chrc_uuid(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_disc_chrc_uuid_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
uint16_t start_handle, end_handle;
ble_uuid_any_t uuid;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (btp2bt_uuid(cp->uuid, cp->uuid_length, &uuid)) {
return BTP_STATUS_FAILED;
}
start_handle = le16toh(cp->start_handle);
end_handle = le16toh(cp->end_handle);
rc = ble_gattc_disc_chrs_by_uuid(conn.conn_handle, start_handle,
end_handle, &uuid.u, disc_chrc_cb,
(void *) BTP_GATTC_DISC_CHRC_UUID_RP);
if (rc) {
discover_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
disc_all_desc_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
uint16_t chr_val_handle,
const struct ble_gatt_dsc *gatt_dsc,
void *arg)
{
struct btp_gattc_disc_all_desc_rp *rp;
struct btp_gatt_descriptor *dsc;
const ble_uuid_any_t *uuid;
uint8_t uuid_length;
uint8_t err = (uint8_t) error->status;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->descriptors_count = 0;
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_DISC_ALL_DESC_RP,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
if (error->status == BLE_HS_EDONE) {
rp->status = 0;
rp->descriptors_count = gatt_buf.cnt;
os_mbuf_append(buf, gatt_buf.buf, gatt_buf.len);
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_DISC_ALL_DESC_RP,
buf->om_data, buf->om_len);
discover_destroy();
goto free;
}
uuid = &gatt_dsc->uuid;
uuid_length = (uint8_t) (uuid->u.type == BLE_UUID_TYPE_16 ? 2 : 16);
dsc = gatt_buf_reserve(sizeof(*dsc) + uuid_length);
if (!dsc) {
discover_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
dsc->descriptor_handle = htole16(gatt_dsc->handle);
dsc->uuid_length = uuid_length;
if (uuid->u.type == BLE_UUID_TYPE_16) {
uint16_t u16 = htole16(BLE_UUID16(uuid)->value);
memcpy(dsc->uuid, &u16, uuid_length);
} else {
memcpy(dsc->uuid, BLE_UUID128(uuid)->value, uuid_length);
}
gatt_buf.cnt++;
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
disc_all_desc(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_disc_all_desc_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
uint16_t start_handle, end_handle;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
start_handle = le16toh(cp->start_handle) - 1;
end_handle = le16toh(cp->end_handle);
rc = ble_gattc_disc_all_dscs(conn.conn_handle,
start_handle,
end_handle,
disc_all_desc_cb,
(void *) BTP_GATTC_DISC_ALL_DESC);
SYS_LOG_DBG("rc=%d", rc);
if (rc) {
discover_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
read_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
struct ble_gatt_attr *attr,
void *arg)
{
struct btp_gattc_read_rp *rp;
uint8_t opcode = (uint8_t) (int) arg;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
SYS_LOG_DBG("status=%d", error->status);
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->status = (uint8_t) BLE_HS_ATT_ERR(error->status);
rp->data_length = 0;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
read_destroy();
goto free;
}
if (!gatt_buf_add(attr->om->om_data, attr->om->om_len)) {
read_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
rp->status = 0;
rp->data_length = attr->om->om_len;
os_mbuf_appendfrom(buf, attr->om, 0, os_mbuf_len(attr->om));
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
read_destroy();
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
read(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_read_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
/* Clear buffer */
read_destroy();
if (ble_gattc_read(conn.conn_handle, le16toh(cp->handle),
read_cb, (void *) BTP_GATTC_READ_RP)) {
read_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
read_uuid_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
struct ble_gatt_attr *attr,
void *arg)
{
struct btp_gattc_read_uuid_rp *rp;
struct btp_gatt_read_uuid_chr *chr;
uint8_t opcode = (uint8_t) (int) arg;
uint8_t err = (uint8_t) error->status;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
static uint16_t attr_len;
SYS_LOG_DBG("status=%d", error->status);
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->data_length = 0;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
read_destroy();
goto free;
}
if (error->status == BLE_HS_EDONE) {
rp->data_length = gatt_buf.len;
rp->value_length = attr_len;
rp->status = 0;
os_mbuf_append(buf, gatt_buf.buf, gatt_buf.len);
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
read_destroy();
goto free;
}
if (error->status == 0) {
attr_len = attr->om->om_len;
}
chr = gatt_buf_reserve(sizeof(*chr) + attr->om->om_len);
if (!chr) {
read_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
chr->handle = htobe16(attr->handle);
memcpy(chr->data, attr->om->om_data, attr->om->om_len);
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
read_uuid(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_read_uuid_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
ble_uuid_any_t uuid;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (btp2bt_uuid(cp->uuid, cp->uuid_length, &uuid)) {
return BTP_STATUS_FAILED;
}
/* Clear buffer */
read_destroy();
if (ble_gattc_read_by_uuid(conn.conn_handle,
le16toh(cp->start_handle),
le16toh(cp->end_handle), &uuid.u,
read_uuid_cb, (void *) BTP_GATTC_READ_UUID_RP)) {
read_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
read_long_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
struct ble_gatt_attr *attr,
void *arg)
{
struct btp_gattc_read_rp *rp;;
uint8_t opcode = (uint8_t) (int) arg;
uint8_t err = (uint8_t) error->status;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("status=%d", error->status);
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
if (error->status != 0 && error->status != BLE_HS_EDONE) {
rp->data_length = 0;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
read_destroy();
goto free;
}
if (error->status == BLE_HS_EDONE) {
rp->status = 0;
rp->data_length = gatt_buf.len;
os_mbuf_append(buf, gatt_buf.buf, gatt_buf.len);
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
read_destroy();
goto free;
}
if (gatt_buf_add(attr->om->om_data, attr->om->om_len) == NULL) {
read_destroy();
rc = BLE_HS_ENOMEM;
goto free;
}
rp->data_length += attr->om->om_len;
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
read_long(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_read_long_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
/* Clear buffer */
read_destroy();
if (ble_gattc_read_long(conn.conn_handle,
le16toh(cp->handle),
le16toh(cp->offset),
read_long_cb, (void *) BTP_GATTC_READ_LONG_RP)) {
read_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static uint8_t
read_multiple(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_read_multiple_cmd *cp = cmd;
uint16_t handles[cp->handles_count];
struct ble_gap_conn_desc conn;
int rc, i;
SYS_LOG_DBG("");
for (i = 0; i < ARRAY_SIZE(handles); i++) {
handles[i] = le16toh(cp->handles[i]);
}
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
/* Clear buffer */
read_destroy();
if (ble_gattc_read_mult(conn.conn_handle,
handles,
cp->handles_count,
read_cb,
(void *) BTP_GATTC_READ_MULTIPLE_RP)) {
read_destroy();
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static uint8_t
write_without_rsp(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_write_without_rsp_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
int rc;
SYS_LOG_DBG("");
if (cmd_len < sizeof(*cp) ||
cmd_len != sizeof(*cp) + le16toh(cp->data_length)) {
return BTP_STATUS_FAILED;
}
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (ble_gattc_write_no_rsp_flat(conn.conn_handle,
le16toh(cp->handle), cp->data,
le16toh(cp->data_length))) {
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static int
write_cb(uint16_t conn_handle, const struct ble_gatt_error *error,
struct ble_gatt_attr *attr,
void *arg)
{
struct btp_gattc_write_rp *rp;
uint8_t err = (uint8_t) error->status;
uint8_t opcode = (uint8_t) (int) arg;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
write(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_write_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
int rc;
SYS_LOG_DBG("");
if (cmd_len < sizeof(*cp) ||
cmd_len != sizeof(*cp) + le16toh(cp->data_length)) {
return BTP_STATUS_FAILED;
}
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (ble_gattc_write_flat(conn.conn_handle, le16toh(cp->handle),
cp->data, le16toh(cp->data_length),
write_cb, (void *) BTP_GATTC_WRITE_RP)) {
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
static uint8_t
write_long(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_write_long_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
struct os_mbuf *om = NULL;
int rc = 0;
SYS_LOG_DBG("");
if (cmd_len < sizeof(*cp) ||
cmd_len != sizeof(*cp) + le16toh(cp->data_length)) {
goto fail;
}
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
goto fail;
}
om = ble_hs_mbuf_from_flat(cp->data, le16toh(cp->data_length));
if (!om) {
SYS_LOG_ERR("Insufficient resources");
goto fail;
}
rc = ble_gattc_write_long(conn.conn_handle,
le16toh(cp->handle),
le16toh(cp->offset),
om, write_cb,
(void *) BTP_GATTC_WRITE_LONG_RP);
if (!rc) {
return BTP_STATUS_SUCCESS;
}
fail:
SYS_LOG_ERR("Failed to send Write Long request, rc=%d", rc);
os_mbuf_free_chain(om);
return BTP_STATUS_FAILED;
}
static int
reliable_write_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
struct ble_gatt_attr *attrs,
uint8_t num_attrs,
void *arg)
{
struct btp_gattc_write_rp *rp;
uint8_t err = (uint8_t) error->status;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_RELIABLE_WRITE_RP,
buf->om_data, buf->om_len);
free:
os_mbuf_free_chain(buf);
return rc;
}
static uint8_t
reliable_write(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_reliable_write_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
struct ble_gatt_attr attr;
struct os_mbuf *om = NULL;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_SUCCESS;
}
om = ble_hs_mbuf_from_flat(cp->data, le16toh(cp->data_length));
/* This is required, because Nimble checks if
* the data is longer than offset
*/
if (os_mbuf_extend(om, le16toh(cp->offset) + 1) == NULL) {
return BTP_STATUS_SUCCESS;
}
attr.handle = le16toh(cp->handle);
attr.offset = le16toh(cp->offset);
attr.om = om;
if (ble_gattc_write_reliable(conn.conn_handle, &attr, 1,
reliable_write_cb, NULL)) {
goto fail;
}
return BTP_STATUS_SUCCESS;
fail:
os_mbuf_free_chain(om);
return BTP_STATUS_FAILED;
}
static int
subscribe_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
struct ble_gatt_attr *attrs,
void *arg)
{
struct btp_subscribe_rp *rp;
uint8_t err = (uint8_t) error->status;
uint8_t opcode = (uint8_t) (int) arg;
struct os_mbuf *buf = os_msys_get(0, 0);
struct ble_gap_conn_desc conn;
int rc = 0;
SYS_LOG_DBG("");
if (ble_gap_conn_find(conn_handle, &conn)) {
rc = BLE_HS_EINVAL;
goto free;
}
rp = os_mbuf_extend(buf, sizeof(*rp));
if (!rp) {
rc = BLE_HS_ENOMEM;
goto free;
}
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = err;
tester_event(BTP_SERVICE_ID_GATTC, opcode,
buf->om_data, buf->om_len);
free:
os_mbuf_free_chain(buf);
return rc;
}
static int
enable_subscription(uint16_t conn_handle, uint16_t ccc_handle,
uint16_t value)
{
uint32_t opcode;
SYS_LOG_DBG("");
opcode = (uint32_t) (value == 0x0001 ? BTP_GATTC_CFG_NOTIFY_RP
: BTP_GATTC_CFG_INDICATE_RP);
if (ble_gattc_write_flat(conn_handle,
ccc_handle,
&value,
sizeof(value),
subscribe_cb,
(void *) opcode)) {
return -EINVAL;
}
subscribe_params.ccc_handle = value;
return 0;
}
static int
disable_subscription(uint16_t conn_handle, uint16_t ccc_handle)
{
uint16_t value = 0x00;
uint32_t opcode;
SYS_LOG_DBG("");
opcode = (uint32_t) (value == 0x0001 ? BTP_GATTC_CFG_NOTIFY_RP
: BTP_GATTC_CFG_INDICATE_RP);
/* Fail if CCC handle doesn't match */
if (ccc_handle != subscribe_params.ccc_handle) {
SYS_LOG_ERR("CCC handle doesn't match");
return -EINVAL;
}
if (ble_gattc_write_flat(conn_handle,
ccc_handle,
&value,
sizeof(value),
subscribe_cb,
(void *) opcode)) {
return -EINVAL;
}
subscribe_params.ccc_handle = 0;
return 0;
}
static uint8_t
config_subscription_notif(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_cfg_notify_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
uint16_t ccc_handle = le16toh(cp->ccc_handle);
uint8_t status;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (cp->enable) {
if (enable_subscription(conn.conn_handle,
ccc_handle, 0x0001) == 0) {
return BTP_STATUS_SUCCESS;
}
status = BTP_STATUS_FAILED;
} else {
if (disable_subscription(conn.conn_handle, ccc_handle) < 0) {
status = BTP_STATUS_FAILED;
} else {
status = BTP_STATUS_SUCCESS;
}
}
return status;
}
static uint8_t
config_subscription_ind(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_cfg_notify_cmd *cp = cmd;
struct ble_gap_conn_desc conn;
uint16_t ccc_handle = le16toh(cp->ccc_handle);
uint8_t status;
int rc;
SYS_LOG_DBG("");
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (cp->enable) {
if (enable_subscription(conn.conn_handle,
ccc_handle, 0x0002) == 0) {
return BTP_STATUS_SUCCESS;
}
status = BTP_STATUS_FAILED;
} else {
if (disable_subscription(conn.conn_handle, ccc_handle) < 0) {
status = BTP_STATUS_FAILED;
} else {
status = BTP_STATUS_SUCCESS;
}
}
return status;
}
static int
read_var_cb(uint16_t conn_handle,
const struct ble_gatt_error *error,
struct ble_gatt_attr *attr,
uint8_t num_attrs,
void *arg)
{
struct btp_gattc_read_rp *rp = (void *) gatt_buf.buf;
struct ble_gap_conn_desc conn;
uint8_t rp_data_off = 0;
struct ble_gatt_attr attrs[num_attrs];
SYS_LOG_DBG("status=%d", error->status);
if (ble_gap_conn_find(conn_handle, &conn)) {
return BTP_STATUS_FAILED;
}
memcpy(attrs, attr, sizeof(struct ble_gatt_attr) * num_attrs);
memcpy(&rp->address, &conn.peer_ota_addr, sizeof(rp->address));
rp->status = (uint8_t) BLE_HS_ATT_ERR(error->status);
if (error->status != 0) {
rp->data_length = 0;
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_READ_MULTIPLE_VAR_RP,
rp, sizeof(*rp));
return 0;
}
for (int i = 0; i < num_attrs; i++) {
memcpy(rp->data + rp_data_off, &attrs[i].om->om_len, 2);
rp_data_off += 2;
memcpy(rp->data + rp_data_off, attrs[i].om->om_data,
attrs[i].om->om_len);
rp_data_off += attrs[i].om->om_len;
}
rp->data_length = rp_data_off;
if (error->status == 0) {
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_READ_MULTIPLE_VAR_RP,
rp, sizeof(*rp) + rp->data_length);
read_destroy();
return 0;
}
return 0;
}
static uint8_t
read_multiple_var(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
const struct btp_gattc_read_multiple_var_cmd *cp = cmd;
uint16_t handles[cp->handles_count];
struct ble_gap_conn_desc conn;
int rc, i;
SYS_LOG_DBG("");
for (i = 0; i < ARRAY_SIZE(handles); i++) {
handles[i] = le16toh(cp->handles[i]);
}
rc = ble_gap_conn_find_by_addr(&cp->address, &conn);
if (rc) {
return BTP_STATUS_FAILED;
}
if (!gatt_buf_reserve(sizeof(struct btp_gatt_read_rp))) {
return BTP_STATUS_FAILED;
}
if (ble_gattc_read_mult_var(conn.conn_handle, handles,
cp->handles_count, read_var_cb,
NULL)) {
return BTP_STATUS_FAILED;
}
return BTP_STATUS_SUCCESS;
}
int
tester_gattc_notify_rx_ev(uint16_t conn_handle, uint16_t attr_handle,
uint8_t indication, struct os_mbuf *om)
{
struct btp_gattc_notification_ev *ev;
struct ble_gap_conn_desc conn;
struct os_mbuf *buf = os_msys_get(0, 0);
SYS_LOG_DBG("");
if (!subscribe_params.ccc_handle) {
goto fail;
}
if (ble_gap_conn_find(conn_handle, &conn)) {
goto fail;
}
ev = os_mbuf_extend(buf, sizeof(*ev));
if (!ev) {
return 0;
}
memcpy(&ev->address, &conn.peer_ota_addr, sizeof(ev->address));
ev->type = (uint8_t) (indication ? 0x02 : 0x01);
ev->handle = htole16(attr_handle);
ev->data_length = htole16(os_mbuf_len(om));
os_mbuf_appendfrom(buf, om, 0, os_mbuf_len(om));
tester_event(BTP_SERVICE_ID_GATTC, BTP_GATTC_EV_NOTIFICATION_RXED,
buf->om_data, buf->om_len);
fail:
os_mbuf_free_chain(buf);
return 0;
}
static uint8_t
supported_commands(const void *cmd, uint16_t cmd_len,
void *rsp, uint16_t *rsp_len)
{
struct btp_gattc_read_supported_commands_rp *rp = rsp;
*rsp_len = tester_supported_commands(BTP_SERVICE_ID_GATTC, rp->data);
*rsp_len += sizeof(*rp);
return BTP_STATUS_SUCCESS;
}
static const struct btp_handler handlers[] = {
{
.opcode = BTP_GATTC_READ_SUPPORTED_COMMANDS,
.index = BTP_INDEX_NONE,
.expect_len = 0,
.func = supported_commands,
},
{
.opcode = BTP_GATTC_EXCHANGE_MTU,
.expect_len = sizeof(struct btp_gattc_exchange_mtu_cmd),
.func = exchange_mtu,
},
{
.opcode = BTP_GATTC_DISC_ALL_PRIM_SVCS,
.expect_len = sizeof(struct btp_gattc_disc_all_prim_svcs_cmd),
.func = disc_all_prim_svcs,
},
{
.opcode = BTP_GATTC_DISC_PRIM_UUID,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = disc_prim_uuid,
},
{
.opcode = BTP_GATTC_FIND_INCLUDED,
.expect_len = sizeof(struct btp_gattc_find_included_cmd),
.func = find_included,
},
{
.opcode = BTP_GATTC_DISC_ALL_CHRC,
.expect_len = sizeof(struct btp_gattc_disc_all_chrc_cmd),
.func = disc_all_chrc,
},
{
.opcode = BTP_GATTC_DISC_CHRC_UUID,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = disc_chrc_uuid,
},
{
.opcode = BTP_GATTC_DISC_ALL_DESC,
.expect_len = sizeof(struct btp_gattc_disc_all_desc_cmd),
.func = disc_all_desc,
},
{
.opcode = BTP_GATTC_READ,
.expect_len = sizeof(struct btp_gattc_read_cmd),
.func = read,
},
{
.opcode = BTP_GATTC_READ_UUID,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = read_uuid,
},
{
.opcode = BTP_GATTC_READ_LONG,
.expect_len = sizeof(struct btp_gattc_read_long_cmd),
.func = read_long,
},
{
.opcode = BTP_GATTC_READ_MULTIPLE,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = read_multiple,
},
{
.opcode = BTP_GATTC_WRITE_WITHOUT_RSP,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = write_without_rsp,
},
#if 0
{
.opcode = BTP_GATTC_SIGNED_WRITE_WITHOUT_RSP,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = write_signed_without_rsp,
},
#endif
{
.opcode = BTP_GATTC_WRITE,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = write,
},
{
.opcode = BTP_GATTC_WRITE_LONG,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = write_long,
},
{
.opcode = BTP_GATTC_RELIABLE_WRITE,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = reliable_write,
},
{
.opcode = BTP_GATTC_CFG_NOTIFY,
.expect_len = sizeof(struct btp_gattc_cfg_notify_cmd),
.func = config_subscription_notif,
},
{
.opcode = BTP_GATTC_CFG_INDICATE,
.expect_len = sizeof(struct btp_gattc_cfg_notify_cmd),
.func = config_subscription_ind,
},
{
.opcode = BTP_GATTC_READ_MULTIPLE_VAR,
.expect_len = BTP_HANDLER_LENGTH_VARIABLE,
.func = read_multiple_var,
},
};
uint8_t
tester_init_gatt_cl(void)
{
tester_register_command_handlers(BTP_SERVICE_ID_GATTC, handlers,
ARRAY_SIZE(handlers));
return BTP_STATUS_SUCCESS;
}
uint8_t
tester_unregister_gatt_cl(void)
{
return BTP_STATUS_SUCCESS;
}