mirror of
https://git.kernel.org/pub/scm/bluetooth/bluez.git
synced 2024-12-23 02:43:29 +08:00
5af8d164ac
Create hal-utils helpers which helps to decode packets Android sends through HAL interface.
1759 lines
43 KiB
C
1759 lines
43 KiB
C
/*
|
|
* Copyright (C) 2013 Intel Corporation
|
|
*
|
|
* Licensed 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 <hardware/bluetooth.h>
|
|
|
|
#include "../hal-utils.h"
|
|
#include "if-main.h"
|
|
|
|
const btgatt_interface_t *if_gatt = NULL;
|
|
|
|
/* In version 19 some callback were changed.
|
|
* btgatt_char_id_t -> btgatt_gatt_id_t
|
|
* bt_uuid_t -> btgatt_gatt_id_t
|
|
*/
|
|
#if PLATFORM_SDK_VERSION > 18
|
|
#define str2btgatt_descr_id_t str2btgatt_gatt_id_t
|
|
#define btgatt_descr_id_t2str btgatt_gatt_id_t2str
|
|
#define btgatt_descr_id_t btgatt_gatt_id_t
|
|
#else
|
|
#define btgatt_descr_id_t2str gatt_uuid_t2str
|
|
#define str2btgatt_descr_id_t(a, b) gatt_str2bt_uuid_t(a, -1, b)
|
|
#define btgatt_gatt_id_t btgatt_char_id_t
|
|
#define btgatt_descr_id_t bt_uuid_t
|
|
#endif
|
|
|
|
#define MAX_CHAR_ID_STR_LEN (MAX_UUID_STR_LEN + 3 + 11)
|
|
#define MAX_SRVC_ID_STR_LEN (MAX_UUID_STR_LEN + 3 + 11 + 1 + 11)
|
|
/* How man characters print from binary objects (arbitrary) */
|
|
#define MAX_HEX_VAL_STR_LEN 100
|
|
#define MAX_NOTIFY_PARAMS_STR_LEN (MAX_SRVC_ID_STR_LEN + MAX_CHAR_ID_STR_LEN \
|
|
+ MAX_ADDR_STR_LEN + MAX_HEX_VAL_STR_LEN + 60)
|
|
#define MAX_READ_PARAMS_STR_LEN (MAX_SRVC_ID_STR_LEN + MAX_CHAR_ID_STR_LEN \
|
|
+ MAX_UUID_STR_LEN + MAX_HEX_VAL_STR_LEN + 80)
|
|
|
|
#define VERIFY_INT_ARG(n, v, err) \
|
|
do { \
|
|
if (n < argc) \
|
|
v = atoi(argv[n]); \
|
|
else { \
|
|
haltest_error(err); \
|
|
return;\
|
|
} \
|
|
} while (0)
|
|
|
|
#define VERIFY_HEX_ARG(n, v, err) \
|
|
do { \
|
|
if (n < argc) \
|
|
v = strtol(argv[n], NULL, 16); \
|
|
else { \
|
|
haltest_error(err); \
|
|
return;\
|
|
} \
|
|
} while (0)
|
|
|
|
/* Helper macros to verify arguments of methods */
|
|
#define VERIFY_CLIENT_IF(n, v) VERIFY_INT_ARG(n, v, "No client_if specified\n")
|
|
#define VERIFY_SERVER_IF(n, v) VERIFY_INT_ARG(n, v, "No server_if specified\n")
|
|
#define VERIFY_CONN_ID(n, v) VERIFY_INT_ARG(n, v, "No conn_if specified\n")
|
|
#define VERIFY_HANDLE(n, v) VERIFY_HEX_ARG(n, v, "No "#v" specified\n")
|
|
#define VERIFY_SERVICE_HANDLE(n, v) VERIFY_HANDLE(n, v)
|
|
|
|
#define VERIFY_UUID(n, v) \
|
|
do { \
|
|
if (n < argc) \
|
|
gatt_str2bt_uuid_t(argv[n], -1, v); \
|
|
else { \
|
|
haltest_error("No uuid specified\n"); \
|
|
return;\
|
|
} \
|
|
} while (0)
|
|
|
|
#define VERIFY_SRVC_ID(n, v) \
|
|
do { \
|
|
if (n < argc) \
|
|
str2btgatt_srvc_id_t(argv[n], v); \
|
|
else { \
|
|
haltest_error("No srvc_id specified\n"); \
|
|
return;\
|
|
} \
|
|
} while (0)
|
|
|
|
#define VERIFY_CHAR_ID(n, v) \
|
|
do { \
|
|
if (n < argc) \
|
|
str2btgatt_gatt_id_t(argv[n], v); \
|
|
else { \
|
|
haltest_error("No char_id specified\n"); \
|
|
return;\
|
|
} \
|
|
} while (0)
|
|
|
|
#define VERIFY_DESCR_ID(n, v) \
|
|
do { \
|
|
if (n < argc) \
|
|
str2btgatt_descr_id_t(argv[n], v); \
|
|
else { \
|
|
haltest_error("No descr_id specified\n"); \
|
|
return;\
|
|
} \
|
|
} while (0)
|
|
|
|
/* Gatt uses little endian uuid */
|
|
static const char GATT_BASE_UUID[] = {
|
|
0xfb, 0x34, 0x9b, 0x5f, 0x80, 0x00, 0x00, 0x80,
|
|
0x00, 0x10, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00
|
|
};
|
|
|
|
/*
|
|
* converts gatt uuid to string
|
|
* buf should be at least 39 bytes
|
|
*
|
|
* This function formats 16, 32 and 128 bits uuid
|
|
*
|
|
* returns string representation of uuid
|
|
*/
|
|
static char *gatt_uuid_t2str(const bt_uuid_t *uuid, char *buf)
|
|
{
|
|
int shift = 0;
|
|
int i = 16;
|
|
int limit = 0;
|
|
int j = 0;
|
|
|
|
/* for bluetooth uuid only 32 bits */
|
|
if (0 == memcmp(&uuid->uu, &GATT_BASE_UUID,
|
|
sizeof(bt_uuid_t) - 4)) {
|
|
limit = 12;
|
|
/* make it 16 bits */
|
|
if (uuid->uu[15] == 0 && uuid->uu[14] == 0)
|
|
i = 14;
|
|
}
|
|
|
|
while (i-- > limit) {
|
|
if (i == 11 || i == 9 || i == 7 || i == 5) {
|
|
buf[j * 2 + shift] = '-';
|
|
shift++;
|
|
}
|
|
|
|
sprintf(buf + j * 2 + shift, "%02x", uuid->uu[i]);
|
|
++j;
|
|
}
|
|
|
|
return buf;
|
|
}
|
|
|
|
/*
|
|
* Tries to convert hex string of given size into out buffer.
|
|
* Output buffer is little endian.
|
|
*/
|
|
static void scan_field(const char *str, int len, uint8_t *out, int out_size)
|
|
{
|
|
int i;
|
|
|
|
memset(out, 0, out_size);
|
|
if (out_size * 2 > len + 1)
|
|
out_size = (len + 1) / 2;
|
|
|
|
for (i = 0; i < out_size && len > 0; ++i) {
|
|
len -= 2;
|
|
if (len >= 0)
|
|
sscanf(str + len, "%02hhx", &out[i]);
|
|
else
|
|
sscanf(str, "%1hhx", &out[i]);
|
|
}
|
|
}
|
|
|
|
/* Like strchr but with upper limit instead of 0 terminated string */
|
|
static const char *strchrlimit(const char *p, const char *e, int c)
|
|
{
|
|
while (p < e && *p != (char) c)
|
|
++p;
|
|
|
|
return p < e ? p : NULL;
|
|
}
|
|
|
|
/*
|
|
* converts string to uuid
|
|
* it accepts uuid in following forms:
|
|
* 123
|
|
* 0000123
|
|
* 0000123-0014-1234-0000-000056789abc
|
|
* 0000123001412340000000056789abc
|
|
* 123-14-1234-0-56789abc
|
|
*/
|
|
static void gatt_str2bt_uuid_t(const char *str, int len, bt_uuid_t *uuid)
|
|
{
|
|
int dash_cnt = 0;
|
|
int dashes[6] = {-1}; /* indexes of '-' or \0 */
|
|
static uint8_t filed_offset[] = { 16, 12, 10, 8, 6, 0 };
|
|
const char *p = str;
|
|
const char *e;
|
|
int i;
|
|
|
|
e = str + ((len >= 0) ? len : (int) strlen(str));
|
|
|
|
while (p != NULL && dash_cnt < 5) {
|
|
const char *f = strchrlimit(p, e, '-');
|
|
|
|
if (f != NULL)
|
|
dashes[++dash_cnt] = f++ - str;
|
|
p = f;
|
|
}
|
|
|
|
/* get index of \0 to dashes table */
|
|
if (dash_cnt < 5)
|
|
dashes[++dash_cnt] = e - str;
|
|
|
|
memcpy(uuid, GATT_BASE_UUID, sizeof(bt_uuid_t));
|
|
|
|
/* whole uuid in one string without dashes */
|
|
if (dash_cnt == 1 && dashes[1] > 8) {
|
|
if (dashes[1] > 32)
|
|
dashes[1] = 32;
|
|
scan_field(str, dashes[1],
|
|
&uuid->uu[16 - (dashes[1] + 1) / 2],
|
|
(dashes[1] + 1) / 2);
|
|
} else {
|
|
for (i = 0; i < dash_cnt; ++i) {
|
|
scan_field(str + dashes[i] + 1,
|
|
dashes[i + 1] - dashes[i] - 1,
|
|
&uuid->uu[filed_offset[i + 1]],
|
|
filed_offset[i] - filed_offset[i + 1]);
|
|
}
|
|
}
|
|
}
|
|
|
|
/* char_id formating function */
|
|
static char *btgatt_gatt_id_t2str(const btgatt_gatt_id_t *char_id, char *buf)
|
|
{
|
|
char uuid_buf[MAX_UUID_STR_LEN];
|
|
|
|
sprintf(buf, "{%s,%d}", gatt_uuid_t2str(&char_id->uuid, uuid_buf),
|
|
char_id->inst_id);
|
|
return buf;
|
|
}
|
|
|
|
/* Parse btgatt_gatt_id_t */
|
|
static void str2btgatt_gatt_id_t(const char *buf, btgatt_gatt_id_t *char_id)
|
|
{
|
|
const char *e;
|
|
|
|
memcpy(&char_id->uuid, &GATT_BASE_UUID, sizeof(bt_uuid_t));
|
|
char_id->inst_id = 0;
|
|
|
|
if (*buf == '{')
|
|
buf++;
|
|
e = strpbrk(buf, " ,}");
|
|
if (e == NULL)
|
|
e = buf + strlen(buf);
|
|
|
|
gatt_str2bt_uuid_t(buf, e - buf, &char_id->uuid);
|
|
if (*e == ',') {
|
|
buf = e + 1;
|
|
e = strpbrk(buf, " ,}");
|
|
if (e == NULL)
|
|
e = buf + strlen(buf);
|
|
if (buf < e)
|
|
char_id->inst_id = atoi(buf);
|
|
}
|
|
}
|
|
|
|
/* service_id formating function */
|
|
static char *btgatt_srvc_id_t2str(const btgatt_srvc_id_t *srvc_id, char *buf)
|
|
{
|
|
char uuid_buf[MAX_UUID_STR_LEN];
|
|
|
|
sprintf(buf, "{%s,%d,%d}", gatt_uuid_t2str(&srvc_id->id.uuid, uuid_buf),
|
|
srvc_id->id.inst_id, srvc_id->is_primary);
|
|
return buf;
|
|
}
|
|
|
|
/* Parse btgatt_srvc_id_t */
|
|
static void str2btgatt_srvc_id_t(const char *buf, btgatt_srvc_id_t *srvc_id)
|
|
{
|
|
const char *e;
|
|
|
|
memcpy(&srvc_id->id.uuid, &GATT_BASE_UUID, sizeof(bt_uuid_t));
|
|
srvc_id->id.inst_id = 0;
|
|
srvc_id->is_primary = 1;
|
|
|
|
if (*buf == '{')
|
|
buf++;
|
|
e = strpbrk(buf, " ,}");
|
|
if (e == NULL)
|
|
e = buf + strlen(buf);
|
|
|
|
gatt_str2bt_uuid_t(buf, e - buf, &srvc_id->id.uuid);
|
|
if (*e == ',') {
|
|
buf = e + 1;
|
|
e = strpbrk(buf, " ,}");
|
|
if (e == NULL)
|
|
e = buf + strlen(buf);
|
|
if (buf < e)
|
|
srvc_id->id.inst_id = atoi(buf);
|
|
}
|
|
|
|
if (*e == ',') {
|
|
buf = e + 1;
|
|
e = strpbrk(buf, " ,}");
|
|
if (e == NULL)
|
|
e = buf + strlen(buf);
|
|
if (buf < e)
|
|
srvc_id->is_primary = atoi(buf);
|
|
}
|
|
}
|
|
|
|
/* Converts array of uint8_t to string representation */
|
|
static char *array2str(const uint8_t *v, int size, char *buf, int out_size)
|
|
{
|
|
int limit = size;
|
|
int i;
|
|
|
|
if (out_size > 0) {
|
|
*buf = '\0';
|
|
if (size >= 2 * out_size)
|
|
limit = (out_size - 2) / 2;
|
|
|
|
for (i = 0; i < limit; ++i)
|
|
sprintf(buf + 2 * i, "%02x", v[i]);
|
|
|
|
/* output buffer not enough to hold whole field fill with ...*/
|
|
if (limit < size)
|
|
sprintf(buf + 2 * i, "...");
|
|
}
|
|
|
|
return buf;
|
|
}
|
|
|
|
/* Converts btgatt_notify_params_t to string */
|
|
static char *btgatt_notify_params_t2str(const btgatt_notify_params_t *data,
|
|
char *buf)
|
|
{
|
|
char addr[MAX_ADDR_STR_LEN];
|
|
char srvc_id[MAX_SRVC_ID_STR_LEN];
|
|
char char_id[MAX_CHAR_ID_STR_LEN];
|
|
char value[MAX_HEX_VAL_STR_LEN];
|
|
|
|
sprintf(buf, "{bda=%s, srvc_id=%s, char_id=%s, val=%s, is_notify=%u}",
|
|
bt_bdaddr_t2str(&data->bda, addr),
|
|
btgatt_srvc_id_t2str(&data->srvc_id, srvc_id),
|
|
btgatt_gatt_id_t2str(&data->char_id, char_id),
|
|
array2str(data->value, data->len, value, sizeof(value)),
|
|
data->is_notify);
|
|
return buf;
|
|
}
|
|
|
|
static char *btgatt_unformatted_value_t2str(const btgatt_unformatted_value_t *v,
|
|
char *buf, int size)
|
|
{
|
|
return array2str(v->value, v->len, buf, size);
|
|
}
|
|
|
|
static char *btgatt_read_params_t2str(const btgatt_read_params_t *data,
|
|
char *buf)
|
|
{
|
|
char srvc_id[MAX_SRVC_ID_STR_LEN];
|
|
char char_id[MAX_CHAR_ID_STR_LEN];
|
|
char descr_id[MAX_UUID_STR_LEN];
|
|
char value[MAX_HEX_VAL_STR_LEN];
|
|
|
|
sprintf(buf, "{srvc_id=%s, char_id=%s, descr_id=%s, val=%s value_type=%d, status=%d}",
|
|
btgatt_srvc_id_t2str(&data->srvc_id, srvc_id),
|
|
btgatt_gatt_id_t2str(&data->char_id, char_id),
|
|
btgatt_descr_id_t2str(&data->descr_id, descr_id),
|
|
btgatt_unformatted_value_t2str(&data->value, value, 100),
|
|
data->value_type, data->status);
|
|
return buf;
|
|
}
|
|
|
|
/* BT-GATT Client callbacks. */
|
|
|
|
/* Cache client_if and conn_id for tab completion */
|
|
static char client_if_str[20];
|
|
static char conn_id_str[20];
|
|
/* Cache address for tab completion */
|
|
static char last_addr[MAX_ADDR_STR_LEN];
|
|
|
|
/* Callback invoked in response to register_client */
|
|
static void gattc_register_client_cb(int status, int client_if,
|
|
bt_uuid_t *app_uuid)
|
|
{
|
|
char buf[MAX_UUID_STR_LEN];
|
|
|
|
snprintf(client_if_str, sizeof(client_if_str), "%d", client_if);
|
|
|
|
haltest_info("%s: status=%d client_if=%d app_uuid=%s\n", __func__,
|
|
status, client_if,
|
|
gatt_uuid_t2str(app_uuid, buf));
|
|
}
|
|
|
|
/* Callback for scan results */
|
|
static void gattc_scan_result_cb(bt_bdaddr_t *bda, int rssi, uint8_t *adv_data)
|
|
{
|
|
char buf[MAX_ADDR_STR_LEN];
|
|
|
|
haltest_info("%s: bda=%s rssi=%d adv_data=%p\n", __func__,
|
|
bt_bdaddr_t2str(bda, buf), rssi, adv_data);
|
|
}
|
|
|
|
/* GATT open callback invoked in response to open */
|
|
static void gattc_connect_cb(int conn_id, int status, int client_if,
|
|
bt_bdaddr_t *bda)
|
|
{
|
|
haltest_info("%s: conn_id=%d status=%d, client_if=%d bda=%s\n",
|
|
__func__, conn_id, status, client_if,
|
|
bt_bdaddr_t2str(bda, last_addr));
|
|
}
|
|
|
|
/* Callback invoked in response to close */
|
|
static void gattc_disconnect_cb(int conn_id, int status, int client_if,
|
|
bt_bdaddr_t *bda)
|
|
{
|
|
char buf[MAX_ADDR_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d status=%d, client_if=%d bda=%s\n",
|
|
__func__, conn_id, status, client_if,
|
|
bt_bdaddr_t2str(bda, buf));
|
|
}
|
|
|
|
/*
|
|
* Invoked in response to search_service when the GATT service search
|
|
* has been completed.
|
|
*/
|
|
static void gattc_search_complete_cb(int conn_id, int status)
|
|
{
|
|
haltest_info("%s: conn_id=%d status=%s\n", __func__, conn_id, status);
|
|
}
|
|
|
|
/* Reports GATT services on a remote device */
|
|
static void gattc_search_result_cb(int conn_id, btgatt_srvc_id_t *srvc_id)
|
|
{
|
|
char srvc_id_buf[MAX_SRVC_ID_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d srvc_id=%s\n", __func__, conn_id,
|
|
btgatt_srvc_id_t2str(srvc_id, srvc_id_buf));
|
|
}
|
|
|
|
/* GATT characteristic enumeration result callback */
|
|
static void gattc_get_characteristic_cb(int conn_id, int status,
|
|
btgatt_srvc_id_t *srvc_id,
|
|
btgatt_gatt_id_t *char_id,
|
|
int char_prop)
|
|
{
|
|
char srvc_id_buf[MAX_SRVC_ID_STR_LEN];
|
|
char char_id_buf[MAX_CHAR_ID_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d status=%d srvc_id=%s char_id=%s, char_prop=%x\n",
|
|
__func__, conn_id, status,
|
|
btgatt_srvc_id_t2str(srvc_id, srvc_id_buf),
|
|
btgatt_gatt_id_t2str(char_id, char_id_buf), char_prop);
|
|
|
|
/* enumerate next characteristic */
|
|
if (status == 0)
|
|
EXEC(if_gatt->client->get_characteristic, conn_id, srvc_id,
|
|
char_id);
|
|
}
|
|
|
|
/* GATT descriptor enumeration result callback */
|
|
static void gattc_get_descriptor_cb(int conn_id, int status,
|
|
btgatt_srvc_id_t *srvc_id, btgatt_gatt_id_t *char_id,
|
|
btgatt_descr_id_t *descr_id)
|
|
{
|
|
char buf[MAX_UUID_STR_LEN];
|
|
char srvc_id_buf[MAX_SRVC_ID_STR_LEN];
|
|
char char_id_buf[MAX_CHAR_ID_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d status=%d srvc_id=%s char_id=%s, descr_id=%s\n",
|
|
__func__, conn_id, status,
|
|
btgatt_srvc_id_t2str(srvc_id, srvc_id_buf),
|
|
btgatt_gatt_id_t2str(char_id, char_id_buf),
|
|
btgatt_descr_id_t2str(descr_id, buf));
|
|
|
|
if (status == 0)
|
|
EXEC(if_gatt->client->get_descriptor, conn_id, srvc_id, char_id,
|
|
descr_id);
|
|
}
|
|
|
|
/* GATT included service enumeration result callback */
|
|
static void gattc_get_included_service_cb(int conn_id, int status,
|
|
btgatt_srvc_id_t *srvc_id,
|
|
btgatt_srvc_id_t *incl_srvc_id)
|
|
{
|
|
char srvc_id_buf[MAX_SRVC_ID_STR_LEN];
|
|
char incl_srvc_id_buf[MAX_SRVC_ID_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d status=%d srvc_id=%s incl_srvc_id=%s)\n",
|
|
__func__, conn_id, status,
|
|
btgatt_srvc_id_t2str(srvc_id, srvc_id_buf),
|
|
btgatt_srvc_id_t2str(incl_srvc_id, incl_srvc_id_buf));
|
|
|
|
if (status == 0)
|
|
EXEC(if_gatt->client->get_included_service, conn_id, srvc_id,
|
|
incl_srvc_id);
|
|
}
|
|
|
|
/* Callback invoked in response to [de]register_for_notification */
|
|
static void gattc_register_for_notification_cb(int conn_id, int registered,
|
|
int status,
|
|
btgatt_srvc_id_t *srvc_id,
|
|
btgatt_gatt_id_t *char_id)
|
|
{
|
|
char srvc_id_buf[MAX_SRVC_ID_STR_LEN];
|
|
char char_id_buf[MAX_CHAR_ID_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d registered=%d status=%d srvc_id=%s char_id=%s\n",
|
|
__func__, conn_id, registered, status,
|
|
btgatt_srvc_id_t2str(srvc_id, srvc_id_buf),
|
|
btgatt_gatt_id_t2str(char_id, char_id_buf));
|
|
}
|
|
|
|
/*
|
|
* Remote device notification callback, invoked when a remote device sends
|
|
* a notification or indication that a client has registered for.
|
|
*/
|
|
static void gattc_notify_cb(int conn_id, btgatt_notify_params_t *p_data)
|
|
{
|
|
char buf[MAX_NOTIFY_PARAMS_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d data=%s\n", __func__, conn_id,
|
|
btgatt_notify_params_t2str(p_data, buf));
|
|
}
|
|
|
|
/* Reports result of a GATT read operation */
|
|
static void gattc_read_characteristic_cb(int conn_id, int status,
|
|
btgatt_read_params_t *p_data)
|
|
{
|
|
char buf[MAX_READ_PARAMS_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d status=%d data=%s\n", __func__, conn_id,
|
|
status, btgatt_read_params_t2str(p_data, buf));
|
|
}
|
|
|
|
/* GATT write characteristic operation callback */
|
|
static void gattc_write_characteristic_cb(int conn_id, int status,
|
|
btgatt_write_params_t *p_data)
|
|
{
|
|
haltest_info("%s: conn_id=%d status=%d\n", __func__, conn_id, status);
|
|
}
|
|
|
|
/* GATT execute prepared write callback */
|
|
static void gattc_execute_write_cb(int conn_id, int status)
|
|
{
|
|
haltest_info("%s: conn_id=%d status=%d\n", __func__, conn_id, status);
|
|
}
|
|
|
|
/* Callback invoked in response to read_descriptor */
|
|
static void gattc_read_descriptor_cb(int conn_id, int status,
|
|
btgatt_read_params_t *p_data)
|
|
{
|
|
char buf[MAX_READ_PARAMS_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d status=%d data=%s\n", __func__, conn_id,
|
|
status, btgatt_read_params_t2str(p_data, buf));
|
|
}
|
|
|
|
/* Callback invoked in response to write_descriptor */
|
|
static void gattc_write_descriptor_cb(int conn_id, int status,
|
|
btgatt_write_params_t *p_data)
|
|
{
|
|
haltest_info("%s: conn_id=%d status=%d\n", __func__, conn_id, status);
|
|
}
|
|
|
|
/* Callback triggered in response to read_remote_rssi */
|
|
static void gattc_read_remote_rssi_cb(int client_if, bt_bdaddr_t *bda, int rssi,
|
|
int status)
|
|
{
|
|
char buf[MAX_ADDR_STR_LEN];
|
|
|
|
haltest_info("%s: client_if=%d bda=%s rssi=%d satus=%d\n", __func__,
|
|
client_if, bt_bdaddr_t2str(bda, buf), rssi, status);
|
|
}
|
|
|
|
static const btgatt_client_callbacks_t btgatt_client_callbacks = {
|
|
.register_client_cb = gattc_register_client_cb,
|
|
.scan_result_cb = gattc_scan_result_cb,
|
|
.open_cb = gattc_connect_cb,
|
|
.close_cb = gattc_disconnect_cb,
|
|
.search_complete_cb = gattc_search_complete_cb,
|
|
.search_result_cb = gattc_search_result_cb,
|
|
.get_characteristic_cb = gattc_get_characteristic_cb,
|
|
.get_descriptor_cb = gattc_get_descriptor_cb,
|
|
.get_included_service_cb = gattc_get_included_service_cb,
|
|
.register_for_notification_cb = gattc_register_for_notification_cb,
|
|
.notify_cb = gattc_notify_cb,
|
|
.read_characteristic_cb = gattc_read_characteristic_cb,
|
|
.write_characteristic_cb = gattc_write_characteristic_cb,
|
|
.read_descriptor_cb = gattc_read_descriptor_cb,
|
|
.write_descriptor_cb = gattc_write_descriptor_cb,
|
|
.execute_write_cb = gattc_execute_write_cb,
|
|
.read_remote_rssi_cb = gattc_read_remote_rssi_cb
|
|
};
|
|
|
|
/* BT-GATT Server callbacks */
|
|
|
|
/* Cache server_if and conn_id for tab completion */
|
|
static char server_if_str[20];
|
|
|
|
/* Callback invoked in response to register_server */
|
|
static void gatts_register_server_cb(int status, int server_if,
|
|
bt_uuid_t *app_uuid)
|
|
{
|
|
char buf[MAX_UUID_STR_LEN];
|
|
|
|
haltest_info("%s: status=%d server_if=%d app_uuid=%s\n", __func__,
|
|
status, server_if, gatt_uuid_t2str(app_uuid, buf));
|
|
}
|
|
|
|
/*
|
|
* Callback indicating that a remote device has connected
|
|
* or been disconnected
|
|
*/
|
|
static void gatts_connection_cb(int conn_id, int server_if, int connected,
|
|
bt_bdaddr_t *bda)
|
|
{
|
|
haltest_info("%s: conn_id=%d server_if=%d connected=%d bda=%s\n",
|
|
__func__, conn_id, server_if, connected,
|
|
bt_bdaddr_t2str(bda, last_addr));
|
|
snprintf(conn_id_str, sizeof(conn_id_str), "%d", conn_id);
|
|
}
|
|
|
|
/* Callback invoked in response to create_service */
|
|
static void gatts_service_added_cb(int status, int server_if,
|
|
btgatt_srvc_id_t *srvc_id, int srvc_handle)
|
|
{
|
|
char buf[MAX_SRVC_ID_STR_LEN];
|
|
|
|
snprintf(server_if_str, sizeof(server_if_str), "%d", server_if);
|
|
|
|
haltest_info("%s: status=%d server_if=%d srvc_id=%s handle=%x\n",
|
|
__func__, status, server_if,
|
|
btgatt_srvc_id_t2str(srvc_id, buf), srvc_handle);
|
|
}
|
|
|
|
/* Callback indicating that an included service has been added to a service */
|
|
static void gatts_included_service_added_cb(int status, int server_if,
|
|
int srvc_handle,
|
|
int incl_srvc_handle)
|
|
{
|
|
haltest_info("%s: status=%d server_if=%d srvc_handle=%x inc_srvc_handle=%x\n",
|
|
__func__, status, server_if,
|
|
srvc_handle, incl_srvc_handle);
|
|
}
|
|
|
|
/* Callback invoked when a characteristic has been added to a service */
|
|
static void gatts_characteristic_added_cb(int status, int server_if,
|
|
bt_uuid_t *uuid,
|
|
int srvc_handle,
|
|
int char_handle)
|
|
{
|
|
char buf[MAX_SRVC_ID_STR_LEN];
|
|
|
|
haltest_info("%s: status=%d server_if=%d uuid=%s srvc_handle=%x char_handle=%x\n",
|
|
__func__, status, server_if, gatt_uuid_t2str(uuid, buf),
|
|
srvc_handle, char_handle);
|
|
}
|
|
|
|
/* Callback invoked when a descriptor has been added to a characteristic */
|
|
static void gatts_descriptor_added_cb(int status, int server_if,
|
|
bt_uuid_t *uuid, int srvc_handle,
|
|
int descr_handle)
|
|
{
|
|
char buf[MAX_SRVC_ID_STR_LEN];
|
|
|
|
haltest_info("%s: status=%d server_if=%d uuid=%s srvc_handle=%x descr_handle=%x\n",
|
|
__func__, status, server_if, gatt_uuid_t2str(uuid, buf),
|
|
srvc_handle, descr_handle);
|
|
}
|
|
|
|
/* Callback invoked in response to start_service */
|
|
static void gatts_service_started_cb(int status, int server_if, int srvc_handle)
|
|
{
|
|
haltest_info("%s: status=%d server_if=%d srvc_handle=%x\n",
|
|
__func__, status, server_if, srvc_handle);
|
|
}
|
|
|
|
/* Callback invoked in response to stop_service */
|
|
static void gatts_service_stopped_cb(int status, int server_if, int srvc_handle)
|
|
{
|
|
haltest_info("%s: status=%d server_if=%d srvc_handle=%x\n",
|
|
__func__, status, server_if, srvc_handle);
|
|
}
|
|
|
|
/* Callback triggered when a service has been deleted */
|
|
static void gatts_service_deleted_cb(int status, int server_if, int srvc_handle)
|
|
{
|
|
haltest_info("%s: status=%d server_if=%d srvc_handle=%x\n",
|
|
__func__, status, server_if, srvc_handle);
|
|
}
|
|
|
|
/*
|
|
* Callback invoked when a remote device has requested to read a characteristic
|
|
* or descriptor. The application must respond by calling send_response
|
|
*/
|
|
static void gatts_request_read_cb(int conn_id, int trans_id, bt_bdaddr_t *bda,
|
|
int attr_handle, int offset,
|
|
bool is_long)
|
|
{
|
|
char buf[MAX_ADDR_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d trans_id=%d bda=%s attr_handle=%x offset=%d is_long=%d\n",
|
|
__func__, conn_id, trans_id, bt_bdaddr_t2str(bda, buf),
|
|
attr_handle, offset, is_long);
|
|
}
|
|
|
|
/*
|
|
* Callback invoked when a remote device has requested to write to a
|
|
* characteristic or descriptor.
|
|
*/
|
|
static void gatts_request_write_cb(int conn_id, int trans_id, bt_bdaddr_t *bda,
|
|
int attr_handle, int offset, int length,
|
|
bool need_rsp, bool is_prep,
|
|
uint8_t *value)
|
|
{
|
|
char buf[MAX_ADDR_STR_LEN];
|
|
char valbuf[100];
|
|
|
|
haltest_info("%s: conn_id=%d trans_id=%d bda=%s attr_handle=%x offset=%d length=%d need_rsp=%d is_prep=%d value=%s\n",
|
|
__func__, conn_id, trans_id, bt_bdaddr_t2str(bda, buf),
|
|
attr_handle, offset, length, need_rsp, is_prep,
|
|
array2str(value, length, valbuf, sizeof(valbuf)));
|
|
}
|
|
|
|
/* Callback invoked when a previously prepared write is to be executed */
|
|
static void gatts_request_exec_write_cb(int conn_id, int trans_id,
|
|
bt_bdaddr_t *bda, int exec_write)
|
|
{
|
|
char buf[MAX_ADDR_STR_LEN];
|
|
|
|
haltest_info("%s: conn_id=%d trans_id=%d bda=%s exec_write=%d\n",
|
|
__func__, conn_id, trans_id, bt_bdaddr_t2str(bda, buf),
|
|
exec_write);
|
|
}
|
|
|
|
/*
|
|
* Callback triggered in response to send_response if the remote device
|
|
* sends a confirmation.
|
|
*/
|
|
static void gatts_response_confirmation_cb(int status, int handle)
|
|
{
|
|
haltest_info("%s: status=%d handle=%x\n", __func__, status, handle);
|
|
}
|
|
|
|
static const btgatt_server_callbacks_t btgatt_server_callbacks = {
|
|
.register_server_cb = gatts_register_server_cb,
|
|
.connection_cb = gatts_connection_cb,
|
|
.service_added_cb = gatts_service_added_cb,
|
|
.included_service_added_cb = gatts_included_service_added_cb,
|
|
.characteristic_added_cb = gatts_characteristic_added_cb,
|
|
.descriptor_added_cb = gatts_descriptor_added_cb,
|
|
.service_started_cb = gatts_service_started_cb,
|
|
.service_stopped_cb = gatts_service_stopped_cb,
|
|
.service_deleted_cb = gatts_service_deleted_cb,
|
|
.request_read_cb = gatts_request_read_cb,
|
|
.request_write_cb = gatts_request_write_cb,
|
|
.request_exec_write_cb = gatts_request_exec_write_cb,
|
|
.response_confirmation_cb = gatts_response_confirmation_cb
|
|
};
|
|
|
|
static const btgatt_callbacks_t gatt_cbacks = {
|
|
.size = sizeof(gatt_cbacks),
|
|
.client = &btgatt_client_callbacks,
|
|
.server = &btgatt_server_callbacks
|
|
};
|
|
|
|
/* gatt client methods */
|
|
|
|
/* init */
|
|
|
|
static void init_p(int argc, const char **argv)
|
|
{
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
EXEC(if_gatt->init, &gatt_cbacks);
|
|
}
|
|
|
|
/* cleanup */
|
|
|
|
static void cleanup_p(int argc, const char **argv)
|
|
{
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
EXECV(if_gatt->cleanup);
|
|
|
|
if_gatt = NULL;
|
|
}
|
|
|
|
static struct method methods[] = {
|
|
STD_METHOD(init),
|
|
STD_METHOD(cleanup),
|
|
END_METHOD
|
|
};
|
|
|
|
const struct interface gatt_if = {
|
|
.name = "gatt",
|
|
.methods = methods
|
|
};
|
|
|
|
/* register_client */
|
|
|
|
static void register_client_p(int argc, const char **argv)
|
|
{
|
|
bt_uuid_t uuid;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
/* uuid */
|
|
if (argc <= 2)
|
|
gatt_str2bt_uuid_t("babe4bed", -1, &uuid);
|
|
else
|
|
gatt_str2bt_uuid_t(argv[2], -1, &uuid);
|
|
|
|
EXEC(if_gatt->client->register_client, &uuid);
|
|
}
|
|
|
|
/* unregister_client */
|
|
|
|
static void unregister_client_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = client_if_str;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void unregister_client_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
|
|
EXEC(if_gatt->client->unregister_client, client_if);
|
|
}
|
|
|
|
/* scan */
|
|
|
|
/* Same completion as unregister for now, start stop is not auto completed */
|
|
#define scan_c unregister_client_c
|
|
|
|
static void scan_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
int start = 1;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
|
|
/* start */
|
|
if (argc >= 3)
|
|
start = atoi(argv[3]);
|
|
|
|
EXEC(if_gatt->client->scan, client_if, start);
|
|
}
|
|
|
|
/* connect */
|
|
|
|
static void connect_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = client_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*user = NULL;
|
|
*enum_func = enum_devices;
|
|
}
|
|
}
|
|
|
|
static void connect_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
bt_bdaddr_t bd_addr;
|
|
int is_direct = 1;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
|
|
/* is_direct */
|
|
if (argc > 4)
|
|
is_direct = atoi(argv[4]);
|
|
|
|
EXEC(if_gatt->client->connect, client_if, &bd_addr, is_direct);
|
|
}
|
|
|
|
/* disconnect */
|
|
|
|
static void disconnect_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = client_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*user = last_addr;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 5) {
|
|
*user = conn_id_str;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void disconnect_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
bt_bdaddr_t bd_addr;
|
|
int conn_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
VERIFY_CONN_ID(4, conn_id);
|
|
|
|
EXEC(if_gatt->client->disconnect, client_if, &bd_addr, conn_id);
|
|
}
|
|
|
|
/* refresh */
|
|
|
|
static void refresh_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = client_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*enum_func = enum_devices;
|
|
}
|
|
}
|
|
|
|
static void refresh_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
bt_bdaddr_t bd_addr;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
|
|
EXEC(if_gatt->client->refresh, client_if, &bd_addr);
|
|
}
|
|
|
|
/* search_service */
|
|
|
|
static void search_service_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = conn_id_str;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void search_service_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
bt_uuid_t filter_uuid;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
|
|
/* uuid */
|
|
if (argc <= 3)
|
|
memset(&filter_uuid, 0, sizeof(bt_uuid_t));
|
|
else
|
|
gatt_str2bt_uuid_t(argv[3], -1, &filter_uuid);
|
|
|
|
EXEC(if_gatt->client->search_service, conn_id, &filter_uuid);
|
|
}
|
|
|
|
/* get_included_service */
|
|
|
|
static void get_included_service_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = conn_id_str;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void get_included_service_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
|
|
EXEC(if_gatt->client->get_included_service, conn_id, &srvc_id, NULL);
|
|
}
|
|
|
|
/* get_characteristic */
|
|
|
|
/* Same completion as get_included_service_c */
|
|
#define get_characteristic_c get_included_service_c
|
|
|
|
static void get_characteristic_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
|
|
EXEC(if_gatt->client->get_characteristic, conn_id, &srvc_id, NULL);
|
|
}
|
|
|
|
/* get_descriptor */
|
|
|
|
/* Same completion as get_included_service_c */
|
|
#define get_descriptor_c get_included_service_c
|
|
|
|
static void get_descriptor_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
VERIFY_CHAR_ID(4, &char_id);
|
|
|
|
EXEC(if_gatt->client->get_descriptor, conn_id, &srvc_id, &char_id,
|
|
NULL);
|
|
}
|
|
|
|
/* read_characteristic */
|
|
|
|
/* Same completion as get_included_service_c */
|
|
#define read_characteristic_c get_included_service_c
|
|
|
|
static void read_characteristic_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
int auth_req = 0;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
VERIFY_CHAR_ID(4, &char_id);
|
|
|
|
/* auth_req */
|
|
if (argc > 5)
|
|
auth_req = atoi(argv[5]);
|
|
|
|
EXEC(if_gatt->client->read_characteristic, conn_id, &srvc_id, &char_id,
|
|
auth_req);
|
|
}
|
|
|
|
/* write_characteristic */
|
|
|
|
static void write_characteristic_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
/*
|
|
* This should be from tGATT_WRITE_TYPE but it's burried
|
|
* inside bluedroid guts
|
|
*/
|
|
static const char *wrtypes[] = { "1", "2", "3", NULL };
|
|
|
|
if (argc == 3) {
|
|
*user = conn_id_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 6) {
|
|
*user = wrtypes;
|
|
*enum_func = enum_strings;
|
|
}
|
|
}
|
|
|
|
static void write_characteristic_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
int write_type;
|
|
int len;
|
|
int auth_req = 0;
|
|
uint8_t value[100];
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
VERIFY_CHAR_ID(4, &char_id);
|
|
|
|
/* write type */
|
|
if (argc <= 5) {
|
|
haltest_error("No write type specified\n");
|
|
return;
|
|
}
|
|
write_type = atoi(argv[5]);
|
|
|
|
/* value */
|
|
if (argc <= 6) {
|
|
haltest_error("No value specified\n");
|
|
return;
|
|
}
|
|
|
|
/* len in chars */
|
|
len = strlen(argv[6]);
|
|
scan_field(argv[6], len, value, sizeof(value));
|
|
/* len in bytes converted from ascii chars */
|
|
len = (len + 1) / 2;
|
|
|
|
/* auth_req */
|
|
if (argc > 7)
|
|
auth_req = atoi(argv[7]);
|
|
|
|
EXEC(if_gatt->client->write_characteristic, conn_id, &srvc_id, &char_id,
|
|
write_type, len, auth_req, (char *) value);
|
|
}
|
|
|
|
/* read_descriptor */
|
|
|
|
/* Same completion as get_included_service_c */
|
|
#define read_descriptor_c get_included_service_c
|
|
|
|
static void read_descriptor_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
btgatt_descr_id_t descr_id;
|
|
int auth_req = 0;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
VERIFY_CHAR_ID(4, &char_id);
|
|
VERIFY_DESCR_ID(5, &descr_id);
|
|
|
|
/* auth_req */
|
|
if (argc > 6)
|
|
auth_req = atoi(argv[6]);
|
|
|
|
EXEC(if_gatt->client->read_descriptor, conn_id, &srvc_id, &char_id,
|
|
&descr_id, auth_req);
|
|
}
|
|
|
|
/* write_descriptor */
|
|
|
|
static void write_descriptor_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
/*
|
|
* This should be from tGATT_WRITE_TYPE but it's burried
|
|
* inside bluedroid guts
|
|
*/
|
|
static const char *wrtypes[] = { "1", "2", "3", NULL };
|
|
|
|
if (argc == 3) {
|
|
*user = conn_id_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 7) {
|
|
*user = wrtypes;
|
|
*enum_func = enum_strings;
|
|
}
|
|
}
|
|
|
|
static void write_descriptor_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
btgatt_descr_id_t descr_id;
|
|
int write_type;
|
|
int len;
|
|
int auth_req = 0;
|
|
uint8_t value[200] = {0};
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
VERIFY_CHAR_ID(4, &char_id);
|
|
VERIFY_DESCR_ID(5, &descr_id);
|
|
|
|
/* write type */
|
|
if (argc <= 6) {
|
|
haltest_error("No write type specified\n");
|
|
return;
|
|
}
|
|
write_type = atoi(argv[6]);
|
|
|
|
/* value */
|
|
if (argc <= 7) {
|
|
haltest_error("No value specified\n");
|
|
return;
|
|
}
|
|
|
|
/* len in chars */
|
|
len = strlen(argv[7]);
|
|
scan_field(argv[7], len, value, sizeof(value));
|
|
/* len in bytes converted from ascii chars */
|
|
len = (len + 1) / 2;
|
|
|
|
/* auth_req */
|
|
if (argc > 8)
|
|
auth_req = atoi(argv[8]);
|
|
|
|
EXEC(if_gatt->client->write_descriptor, conn_id, &srvc_id, &char_id,
|
|
&descr_id, write_type, len, auth_req, (char *) value);
|
|
}
|
|
|
|
/* execute_write */
|
|
|
|
/* Same completion as search_service */
|
|
#define execute_write_c search_service_c
|
|
|
|
static void execute_write_p(int argc, const char **argv)
|
|
{
|
|
int conn_id;
|
|
int execute;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CONN_ID(2, conn_id);
|
|
|
|
/* execute */
|
|
if (argc <= 3) {
|
|
haltest_error("No execute specified\n");
|
|
return;
|
|
}
|
|
execute = atoi(argv[3]);
|
|
|
|
EXEC(if_gatt->client->execute_write, conn_id, execute);
|
|
}
|
|
|
|
/* register_for_notification */
|
|
|
|
static void register_for_notification_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = client_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*user = last_addr;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void register_for_notification_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
bt_bdaddr_t bd_addr;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
VERIFY_SRVC_ID(4, &srvc_id);
|
|
VERIFY_CHAR_ID(5, &char_id);
|
|
|
|
EXEC(if_gatt->client->register_for_notification, client_if, &bd_addr,
|
|
&srvc_id, &char_id);
|
|
}
|
|
|
|
/* deregister_for_notification */
|
|
|
|
/* Same completion as search_service */
|
|
#define deregister_for_notification_c register_for_notification_c
|
|
|
|
static void deregister_for_notification_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
bt_bdaddr_t bd_addr;
|
|
btgatt_srvc_id_t srvc_id;
|
|
btgatt_gatt_id_t char_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
VERIFY_SRVC_ID(4, &srvc_id);
|
|
VERIFY_CHAR_ID(5, &char_id);
|
|
|
|
EXEC(if_gatt->client->deregister_for_notification, client_if, &bd_addr,
|
|
&srvc_id, &char_id);
|
|
}
|
|
|
|
/* read_remote_rssi */
|
|
|
|
static void read_remote_rssi_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = client_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*enum_func = enum_devices;
|
|
}
|
|
}
|
|
|
|
static void read_remote_rssi_p(int argc, const char **argv)
|
|
{
|
|
int client_if;
|
|
bt_bdaddr_t bd_addr;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_CLIENT_IF(2, client_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
|
|
EXEC(if_gatt->client->read_remote_rssi, client_if, &bd_addr);
|
|
}
|
|
|
|
/* get_device_type */
|
|
|
|
static void get_device_type_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 3)
|
|
*enum_func = enum_devices;
|
|
}
|
|
|
|
static void get_device_type_p(int argc, const char **argv)
|
|
{
|
|
bt_bdaddr_t bd_addr;
|
|
int dev_type;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_ADDR_ARG(2, &bd_addr);
|
|
|
|
dev_type = if_gatt->client->get_device_type(&bd_addr);
|
|
haltest_info("%s: %d\n", "get_device_type", dev_type);
|
|
}
|
|
|
|
/* test_command */
|
|
|
|
static void test_command_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 4)
|
|
*enum_func = enum_devices;
|
|
}
|
|
|
|
static void test_command_p(int argc, const char **argv)
|
|
{
|
|
int command;
|
|
int i;
|
|
bt_bdaddr_t bd_addr;
|
|
bt_uuid_t uuid;
|
|
btgatt_test_params_t params = {
|
|
.bda1 = &bd_addr,
|
|
.uuid1 = &uuid
|
|
};
|
|
uint16_t *u = ¶ms.u1;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
/* command */
|
|
if (argc <= 2) {
|
|
haltest_error("No command specified\n");
|
|
return;
|
|
}
|
|
command = atoi(argv[2]);
|
|
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
VERIFY_UUID(4, &uuid);
|
|
|
|
for (i = 5; i < argc; i++)
|
|
*u++ = atoi(argv[i]);
|
|
|
|
EXEC(if_gatt->client->test_command, command, ¶ms);
|
|
}
|
|
|
|
static struct method client_methods[] = {
|
|
STD_METHODH(register_client, "[<uuid>]"),
|
|
STD_METHODCH(unregister_client, "<client_if>"),
|
|
STD_METHODCH(scan, "<client_if> [1|0]"),
|
|
STD_METHODCH(connect, "<client_if> <addr> [<is_direct>]"),
|
|
STD_METHODCH(disconnect, "<client_if> <addr> <conn_id>"),
|
|
STD_METHODCH(refresh, "<client_if> <addr>"),
|
|
STD_METHODCH(search_service, "<conn_id> [<uuid>]"),
|
|
STD_METHODCH(get_included_service, "<conn_id> <srvc_id>"),
|
|
STD_METHODCH(get_characteristic, "<conn_id> <srvc_id>"),
|
|
STD_METHODCH(get_descriptor, "<conn_id> <srvc_id> <char_id>"),
|
|
STD_METHODCH(read_characteristic,
|
|
"<conn_id> <srvc_id> <char_id> [<auth_req>]"),
|
|
STD_METHODCH(write_characteristic,
|
|
"<conn_id> <srvc_id> <char_id> <write_type> <hex_value> [<auth_req>]"),
|
|
STD_METHODCH(read_descriptor,
|
|
"<conn_id> <srvc_id> <char_id> <descr_id> [<auth_req>]"),
|
|
STD_METHODCH(write_descriptor,
|
|
"<conn_id> <srvc_id> <char_id> <descr_id> <write_type> <hex_value> [<auth_req>]"),
|
|
STD_METHODCH(execute_write, "<conn_id> <execute>"),
|
|
STD_METHODCH(register_for_notification,
|
|
"<client_if> <addr> <srvc_id> <char_id>"),
|
|
STD_METHODCH(deregister_for_notification,
|
|
"<client_if> <addr> <srvc_id> <char_id>"),
|
|
STD_METHODCH(read_remote_rssi, "<client_if> <addr>"),
|
|
STD_METHODCH(get_device_type, "<addr>"),
|
|
STD_METHODCH(test_command,
|
|
"<cmd> <addr> <uuid> [u1] [u2] [u3] [u4] [u5]"),
|
|
END_METHOD
|
|
};
|
|
|
|
const struct interface gatt_client_if = {
|
|
.name = "gattc",
|
|
.methods = client_methods
|
|
};
|
|
|
|
/* gatt server methods */
|
|
|
|
/* register_server */
|
|
|
|
static void gatts_register_server_p(int argc, const char *argv[])
|
|
{
|
|
bt_uuid_t uuid;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
|
|
/* uuid */
|
|
if (argc <= 2)
|
|
gatt_str2bt_uuid_t("bed4babe", -1, &uuid);
|
|
else
|
|
gatt_str2bt_uuid_t(argv[2], -1, &uuid);
|
|
|
|
EXEC(if_gatt->server->register_server, &uuid);
|
|
}
|
|
|
|
/* unregister_server */
|
|
|
|
static void gatts_unregister_server_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = server_if_str;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void gatts_unregister_server_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
|
|
EXEC(if_gatt->server->unregister_server, server_if);
|
|
}
|
|
|
|
/* connect */
|
|
|
|
static void gatts_connect_c(int argc, const char **argv, enum_func *enum_func,
|
|
void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = server_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*user = NULL;
|
|
*enum_func = enum_devices;
|
|
}
|
|
}
|
|
|
|
static void gatts_connect_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
bt_bdaddr_t bd_addr;
|
|
int is_direct = 1;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
|
|
/* is_direct */
|
|
if (argc > 4)
|
|
is_direct = atoi(argv[4]);
|
|
|
|
EXEC(if_gatt->server->connect, server_if, &bd_addr, is_direct);
|
|
}
|
|
|
|
/* disconnect */
|
|
|
|
static void gatts_disconnect_c(int argc, const char **argv,
|
|
enum_func *enum_func, void **user)
|
|
{
|
|
if (argc == 3) {
|
|
*user = server_if_str;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 4) {
|
|
*user = last_addr;
|
|
*enum_func = enum_one_string;
|
|
} else if (argc == 5) {
|
|
*user = conn_id_str;
|
|
*enum_func = enum_one_string;
|
|
}
|
|
}
|
|
|
|
static void gatts_disconnect_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
bt_bdaddr_t bd_addr;
|
|
int conn_id;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_ADDR_ARG(3, &bd_addr);
|
|
VERIFY_CONN_ID(4, conn_id);
|
|
|
|
EXEC(if_gatt->server->disconnect, server_if, &bd_addr, conn_id);
|
|
}
|
|
|
|
/* add_service */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_add_service_c gatts_unregister_server_c
|
|
|
|
static void gatts_add_service_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
btgatt_srvc_id_t srvc_id;
|
|
int num_handles;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SRVC_ID(3, &srvc_id);
|
|
|
|
/* num handles */
|
|
if (argc <= 4) {
|
|
haltest_error("No num_handles specified\n");
|
|
return;
|
|
}
|
|
num_handles = atoi(argv[4]);
|
|
|
|
EXEC(if_gatt->server->add_service, server_if, &srvc_id, num_handles);
|
|
}
|
|
|
|
/* add_included_service */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_add_included_service_c gatts_unregister_server_c
|
|
|
|
static void gatts_add_included_service_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int service_handle;
|
|
int included_handle;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SERVICE_HANDLE(3, service_handle);
|
|
VERIFY_HANDLE(4, included_handle);
|
|
|
|
EXEC(if_gatt->server->add_included_service, server_if, service_handle,
|
|
included_handle);
|
|
}
|
|
|
|
/* add_characteristic */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_add_characteristic_c gatts_unregister_server_c
|
|
|
|
static void gatts_add_characteristic_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int service_handle;
|
|
int properties;
|
|
int permissions;
|
|
bt_uuid_t uuid;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SERVICE_HANDLE(3, service_handle);
|
|
VERIFY_UUID(4, &uuid);
|
|
|
|
/* properties */
|
|
if (argc <= 5) {
|
|
haltest_error("No properties specified\n");
|
|
return;
|
|
}
|
|
properties = atoi(argv[5]);
|
|
|
|
/* permissions */
|
|
if (argc <= 6) {
|
|
haltest_error("No permissions specified\n");
|
|
return;
|
|
}
|
|
permissions = atoi(argv[6]);
|
|
|
|
EXEC(if_gatt->server->add_characteristic, server_if, service_handle,
|
|
&uuid, properties, permissions);
|
|
}
|
|
|
|
/* add_descriptor */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_add_descriptor_c gatts_unregister_server_c
|
|
|
|
static void gatts_add_descriptor_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int service_handle;
|
|
int permissions;
|
|
bt_uuid_t uuid;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SERVICE_HANDLE(3, service_handle);
|
|
VERIFY_UUID(4, &uuid);
|
|
|
|
/* permissions */
|
|
if (argc <= 5) {
|
|
haltest_error("No permissions specified\n");
|
|
return;
|
|
}
|
|
permissions = atoi(argv[5]);
|
|
|
|
EXEC(if_gatt->server->add_descriptor, server_if, service_handle, &uuid,
|
|
permissions);
|
|
}
|
|
|
|
/* start_service */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_start_service_c gatts_unregister_server_c
|
|
|
|
static void gatts_start_service_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int service_handle;
|
|
int transport;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SERVICE_HANDLE(3, service_handle);
|
|
|
|
/* transport */
|
|
if (argc <= 4) {
|
|
haltest_error("No transport specified\n");
|
|
return;
|
|
}
|
|
transport = atoi(argv[4]);
|
|
|
|
EXEC(if_gatt->server->start_service, server_if, service_handle,
|
|
transport);
|
|
}
|
|
|
|
/* stop_service */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_stop_service_c gatts_unregister_server_c
|
|
|
|
static void gatts_stop_service_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int service_handle;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SERVICE_HANDLE(3, service_handle);
|
|
|
|
EXEC(if_gatt->server->stop_service, server_if, service_handle);
|
|
}
|
|
|
|
/* delete_service */
|
|
|
|
/* Same completion as gatts_unregister_server_c */
|
|
#define gatts_delete_service_c gatts_unregister_server_c
|
|
|
|
static void gatts_delete_service_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int service_handle;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_SERVICE_HANDLE(3, service_handle);
|
|
|
|
EXEC(if_gatt->server->delete_service, server_if, service_handle);
|
|
}
|
|
|
|
/* send_indication */
|
|
|
|
static void gatts_send_indication_p(int argc, const char *argv[])
|
|
{
|
|
int server_if;
|
|
int attr_handle;
|
|
int conn_id;
|
|
int confirm;
|
|
char data[200];
|
|
int len = 0;
|
|
|
|
RETURN_IF_NULL(if_gatt);
|
|
VERIFY_SERVER_IF(2, server_if);
|
|
VERIFY_HANDLE(3, attr_handle);
|
|
VERIFY_CONN_ID(4, conn_id);
|
|
|
|
/* confirm */
|
|
if (argc <= 5) {
|
|
haltest_error("No transport specified\n");
|
|
return;
|
|
}
|
|
confirm = atoi(argv[5]);
|
|
|
|
if (argc > 6) {
|
|
len = strlen(argv[6]);
|
|
scan_field(argv[6], len, (uint8_t *) data, sizeof(data));
|
|
}
|
|
|
|
EXEC(if_gatt->server->send_indication, server_if, attr_handle, conn_id,
|
|
len, confirm, data);
|
|
}
|
|
|
|
/* send_response */
|
|
|
|
static void gatts_send_response_p(int argc, const char *argv[])
|
|
{
|
|
haltest_warn("%s is not implemented yet\n", __func__);
|
|
}
|
|
|
|
#define GATTS_METHODH(n, h) METHOD(#n, gatts_##n##_p, NULL, h)
|
|
#define GATTS_METHODCH(n, h) METHOD(#n, gatts_##n##_p, gatts_##n##_c, h)
|
|
|
|
static struct method server_methods[] = {
|
|
GATTS_METHODH(register_server, "[<uuid>]"),
|
|
GATTS_METHODCH(unregister_server, "<server_if>"),
|
|
GATTS_METHODCH(connect, "<server_if> <addr> [<is_direct>]"),
|
|
GATTS_METHODCH(disconnect, "<server_if> <addr> <conn_id>"),
|
|
GATTS_METHODCH(add_service, "<server_if> <srvc_id> <num_handles>"),
|
|
GATTS_METHODCH(add_included_service,
|
|
"<server_if> <service_handle> <included_handle>"),
|
|
GATTS_METHODCH(add_characteristic,
|
|
"<server_if> <service_handle> <uuid> <properites> <permissions>"),
|
|
GATTS_METHODCH(add_descriptor, "<server_if> <uuid> <permissions>"),
|
|
GATTS_METHODCH(start_service,
|
|
"<server_if> <service_handle> <transport>"),
|
|
GATTS_METHODCH(stop_service, "<server_if> <service_handle>"),
|
|
GATTS_METHODCH(delete_service, "<server_if> <service_handle>"),
|
|
GATTS_METHODH(send_indication,
|
|
"<server_if> <attr_handle> <conn_id> <confirm> [<data>]"),
|
|
GATTS_METHODH(send_response, "<conn_id> <trans_id> <status>"),
|
|
END_METHOD
|
|
};
|
|
|
|
const struct interface gatt_server_if = {
|
|
.name = "gatts",
|
|
.methods = server_methods
|
|
};
|