| /* |
| * 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; |
| } |