| /* |
| * Copyright (C) 2014 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 <stdbool.h> |
| #include <string.h> |
| #include <stdlib.h> |
| |
| #include "hal-log.h" |
| #include "hal.h" |
| #include "hal-msg.h" |
| #include "ipc-common.h" |
| #include "hal-ipc.h" |
| #include "hal-utils.h" |
| |
| static const btgatt_callbacks_t *cbs = NULL; |
| |
| static bool interface_ready(void) |
| { |
| return cbs != NULL; |
| } |
| |
| static void gatt_id_from_hal(btgatt_gatt_id_t *to, |
| struct hal_gatt_gatt_id *from) |
| { |
| memcpy(&to->uuid, from->uuid, sizeof(to->uuid)); |
| to->inst_id = from->inst_id; |
| } |
| |
| static void gatt_id_to_hal(struct hal_gatt_gatt_id *to, btgatt_gatt_id_t *from) |
| { |
| memcpy(to->uuid, &from->uuid, sizeof(from->uuid)); |
| to->inst_id = from->inst_id; |
| } |
| |
| static void srvc_id_from_hal(btgatt_srvc_id_t *to, |
| struct hal_gatt_srvc_id *from) |
| { |
| memcpy(&to->id.uuid, from->uuid, sizeof(to->id.uuid)); |
| to->id.inst_id = from->inst_id; |
| to->is_primary = from->is_primary; |
| } |
| |
| static void srvc_id_to_hal(struct hal_gatt_srvc_id *to, btgatt_srvc_id_t *from) |
| { |
| memcpy(to->uuid, &from->id.uuid, sizeof(from->id.uuid)); |
| to->inst_id = from->id.inst_id; |
| to->is_primary = from->is_primary; |
| } |
| |
| /* Client Event Handlers */ |
| |
| static void handle_register_client(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_register_client *ev = buf; |
| |
| if (cbs->client->register_client_cb) |
| cbs->client->register_client_cb(ev->status, ev->client_if, |
| (bt_uuid_t *) ev->app_uuid); |
| } |
| |
| static void handle_scan_result(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_scan_result *ev = buf; |
| uint8_t ad[62]; |
| |
| if (len != sizeof(*ev) + ev->len) { |
| error("gatt: invalid scan result event, aborting"); |
| exit(EXIT_FAILURE); |
| } |
| |
| /* Java assumes that passed data has 62 bytes */ |
| memset(ad, 0, sizeof(ad)); |
| memcpy(ad, ev->adv_data, ev->len > sizeof(ad) ? sizeof(ad) : ev->len); |
| |
| if (cbs->client->scan_result_cb) |
| cbs->client->scan_result_cb((bt_bdaddr_t *) ev->bda, ev->rssi, |
| ad); |
| } |
| |
| static void handle_connect(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_connect *ev = buf; |
| |
| if (cbs->client->open_cb) |
| cbs->client->open_cb(ev->conn_id, ev->status, ev->client_if, |
| (bt_bdaddr_t *) ev->bda); |
| } |
| |
| static void handle_disconnect(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_disconnect *ev = buf; |
| |
| if (cbs->client->close_cb) |
| cbs->client->close_cb(ev->conn_id, ev->status, ev->client_if, |
| (bt_bdaddr_t *) ev->bda); |
| } |
| |
| static void handle_search_complete(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_search_complete *ev = buf; |
| |
| if (cbs->client->search_complete_cb) |
| cbs->client->search_complete_cb(ev->conn_id, ev->status); |
| } |
| |
| static void handle_search_result(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_search_result *ev = buf; |
| btgatt_srvc_id_t srvc_id; |
| |
| srvc_id_from_hal(&srvc_id, &ev->srvc_id); |
| |
| if (cbs->client->search_result_cb) |
| cbs->client->search_result_cb(ev->conn_id, &srvc_id); |
| } |
| |
| static void handle_get_characteristic(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_get_characteristic *ev = buf; |
| btgatt_gatt_id_t char_id; |
| btgatt_srvc_id_t srvc_id; |
| |
| srvc_id_from_hal(&srvc_id, &ev->srvc_id); |
| gatt_id_from_hal(&char_id, &ev->char_id); |
| |
| if (cbs->client->get_characteristic_cb) |
| cbs->client->get_characteristic_cb(ev->conn_id, ev->status, |
| &srvc_id, &char_id, |
| ev->char_prop); |
| } |
| |
| static void handle_get_descriptor(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_get_descriptor *ev = buf; |
| btgatt_gatt_id_t descr_id; |
| btgatt_gatt_id_t char_id; |
| btgatt_srvc_id_t srvc_id; |
| |
| srvc_id_from_hal(&srvc_id, &ev->srvc_id); |
| gatt_id_from_hal(&char_id, &ev->char_id); |
| gatt_id_from_hal(&descr_id, &ev->descr_id); |
| |
| if (cbs->client->get_descriptor_cb) |
| cbs->client->get_descriptor_cb(ev->conn_id, ev->status, |
| &srvc_id, &char_id, &descr_id); |
| } |
| |
| static void handle_get_included_service(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_get_inc_service *ev = buf; |
| btgatt_srvc_id_t srvc_id; |
| btgatt_srvc_id_t incl_srvc_id; |
| |
| srvc_id_from_hal(&srvc_id, &ev->srvc_id); |
| srvc_id_from_hal(&incl_srvc_id, &ev->incl_srvc_id); |
| |
| if (cbs->client->get_included_service_cb) |
| cbs->client->get_included_service_cb(ev->conn_id, ev->status, |
| &srvc_id, |
| &incl_srvc_id); |
| } |
| |
| static void handle_register_for_notification(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_reg_for_notif *ev = buf; |
| btgatt_gatt_id_t char_id; |
| btgatt_srvc_id_t srvc_id; |
| |
| srvc_id_from_hal(&srvc_id, &ev->srvc_id); |
| gatt_id_from_hal(&char_id, &ev->char_id); |
| |
| if (cbs->client->register_for_notification_cb) |
| cbs->client->register_for_notification_cb(ev->conn_id, |
| ev->registered, |
| ev->status, |
| &srvc_id, |
| &char_id); |
| } |
| |
| static void handle_notify(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_notify *ev = buf; |
| btgatt_notify_params_t params; |
| |
| if (len != sizeof(*ev) + ev->len) { |
| error("gatt: invalid notify event, aborting"); |
| exit(EXIT_FAILURE); |
| } |
| |
| memset(¶ms, 0, sizeof(params)); |
| memcpy(params.value, ev->value, ev->len); |
| memcpy(¶ms.bda, ev->bda, sizeof(params.bda)); |
| |
| srvc_id_from_hal(¶ms.srvc_id, &ev->srvc_id); |
| gatt_id_from_hal(¶ms.char_id, &ev->char_id); |
| |
| params.len = ev->len; |
| params.is_notify = ev->is_notify; |
| |
| if (cbs->client->notify_cb) |
| cbs->client->notify_cb(ev->conn_id, ¶ms); |
| } |
| |
| static void handle_read_characteristic(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_read_characteristic *ev = buf; |
| btgatt_read_params_t params; |
| |
| if (len != sizeof(*ev) + ev->data.len) { |
| error("gatt: invalid read characteristic event, aborting"); |
| exit(EXIT_FAILURE); |
| } |
| |
| memset(¶ms, 0, sizeof(params)); |
| |
| srvc_id_from_hal(¶ms.srvc_id, &ev->data.srvc_id); |
| gatt_id_from_hal(¶ms.char_id, &ev->data.char_id); |
| gatt_id_from_hal(¶ms.descr_id, &ev->data.descr_id); |
| |
| memcpy(¶ms.value.value, ev->data.value, ev->data.len); |
| |
| params.value_type = ev->data.value_type; |
| params.value.len = ev->data.len; |
| params.status = ev->data.status; |
| |
| if (cbs->client->read_characteristic_cb) |
| cbs->client->read_characteristic_cb(ev->conn_id, ev->status, |
| ¶ms); |
| } |
| |
| static void handle_write_characteristic(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_write_characteristic *ev = buf; |
| btgatt_write_params_t params; |
| |
| memset(¶ms, 0, sizeof(params)); |
| |
| srvc_id_from_hal(¶ms.srvc_id, &ev->data.srvc_id); |
| gatt_id_from_hal(¶ms.char_id, &ev->data.char_id); |
| gatt_id_from_hal(¶ms.descr_id, &ev->data.descr_id); |
| |
| params.status = ev->data.status; |
| |
| if (cbs->client->write_characteristic_cb) |
| cbs->client->write_characteristic_cb(ev->conn_id, ev->status, |
| ¶ms); |
| } |
| |
| static void handle_read_descriptor(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_read_descriptor *ev = buf; |
| btgatt_read_params_t params; |
| |
| if (len != sizeof(*ev) + ev->data.len) { |
| error("gatt: invalid read descriptor event, aborting"); |
| exit(EXIT_FAILURE); |
| } |
| |
| memset(¶ms, 0, sizeof(params)); |
| |
| srvc_id_from_hal(¶ms.srvc_id, &ev->data.srvc_id); |
| gatt_id_from_hal(¶ms.char_id, &ev->data.char_id); |
| gatt_id_from_hal(¶ms.descr_id, &ev->data.descr_id); |
| |
| memcpy(¶ms.value.value, ev->data.value, ev->data.len); |
| |
| params.value_type = ev->data.value_type; |
| params.value.len = ev->data.len; |
| params.status = ev->data.status; |
| |
| if (cbs->client->read_descriptor_cb) |
| cbs->client->read_descriptor_cb(ev->conn_id, ev->status, |
| ¶ms); |
| } |
| |
| static void handle_write_descriptor(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_write_descriptor *ev = buf; |
| btgatt_write_params_t params; |
| |
| memset(¶ms, 0, sizeof(params)); |
| |
| srvc_id_from_hal(¶ms.srvc_id, &ev->data.srvc_id); |
| gatt_id_from_hal(¶ms.char_id, &ev->data.char_id); |
| gatt_id_from_hal(¶ms.descr_id, &ev->data.descr_id); |
| |
| params.status = ev->data.status; |
| |
| if (cbs->client->write_descriptor_cb) |
| cbs->client->write_descriptor_cb(ev->conn_id, ev->status, |
| ¶ms); |
| } |
| |
| static void handle_execute_write(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_exec_write *ev = buf; |
| |
| if (cbs->client->execute_write_cb) |
| cbs->client->execute_write_cb(ev->conn_id, ev->status); |
| } |
| |
| static void handle_read_remote_rssi(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_read_remote_rssi *ev = buf; |
| |
| if (cbs->client->read_remote_rssi_cb) |
| cbs->client->read_remote_rssi_cb(ev->client_if, |
| (bt_bdaddr_t *) ev->address, |
| ev->rssi, ev->status); |
| } |
| |
| static void handle_listen(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_client_listen *ev = buf; |
| |
| if (cbs->client->listen_cb) |
| cbs->client->listen_cb(ev->status, ev->server_if); |
| } |
| |
| /* Server Event Handlers */ |
| |
| static void handle_register_server(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_register *ev = buf; |
| |
| if (cbs->server->register_server_cb) |
| cbs->server->register_server_cb(ev->status, ev->server_if, |
| (bt_uuid_t *) &ev->uuid); |
| } |
| |
| static void handle_connection(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_connection *ev = buf; |
| |
| if (cbs->server->connection_cb) |
| cbs->server->connection_cb(ev->conn_id, ev->server_if, |
| ev->connected, |
| (bt_bdaddr_t *) &ev->bdaddr); |
| } |
| |
| static void handle_service_added(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_service_added *ev = buf; |
| btgatt_srvc_id_t srvc_id; |
| |
| srvc_id_from_hal(&srvc_id, &ev->srvc_id); |
| |
| if (cbs->server->service_added_cb) |
| cbs->server->service_added_cb(ev->status, ev->server_if, |
| &srvc_id, ev->srvc_handle); |
| } |
| |
| static void handle_included_service_added(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_inc_srvc_added *ev = buf; |
| |
| if (cbs->server->included_service_added_cb) |
| cbs->server->included_service_added_cb(ev->status, |
| ev->server_if, |
| ev->srvc_handle, |
| ev->incl_srvc_handle); |
| } |
| |
| static void handle_characteristic_added(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_characteristic_added *ev = buf; |
| |
| if (cbs->server->characteristic_added_cb) |
| cbs->server->characteristic_added_cb(ev->status, ev->server_if, |
| (bt_uuid_t *) &ev->uuid, |
| ev->srvc_handle, |
| ev->char_handle); |
| } |
| |
| static void handle_descriptor_added(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_descriptor_added *ev = buf; |
| |
| if (cbs->server->descriptor_added_cb) |
| cbs->server->descriptor_added_cb(ev->status, ev->server_if, |
| (bt_uuid_t *) &ev->uuid, |
| ev->srvc_handle, |
| ev->descr_handle); |
| } |
| |
| static void handle_service_started(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_service_started *ev = buf; |
| |
| if (cbs->server->service_started_cb) |
| cbs->server->service_started_cb(ev->status, ev->server_if, |
| ev->srvc_handle); |
| } |
| |
| static void handle_service_stopped(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_service_stopped *ev = buf; |
| |
| if (cbs->server->service_stopped_cb) |
| cbs->server->service_stopped_cb(ev->status, ev->server_if, |
| ev->srvc_handle); |
| } |
| |
| static void handle_service_deleted(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_service_deleted *ev = buf; |
| |
| if (cbs->server->service_deleted_cb) |
| cbs->server->service_deleted_cb(ev->status, ev->server_if, |
| ev->srvc_handle); |
| } |
| |
| static void handle_request_read(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_request_read *ev = buf; |
| |
| if (cbs->server->request_read_cb) |
| cbs->server->request_read_cb(ev->conn_id, ev->trans_id, |
| (bt_bdaddr_t *) &ev->bdaddr, |
| ev->attr_handle, ev->offset, |
| ev->is_long); |
| } |
| |
| static void handle_request_write(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_request_write *ev = buf; |
| |
| if (len != sizeof(*ev) + ev->length) { |
| error("gatt: invalid request write event, aborting"); |
| exit(EXIT_FAILURE); |
| } |
| |
| if (cbs->server->request_write_cb) |
| cbs->server->request_write_cb(ev->conn_id, ev->trans_id, |
| (bt_bdaddr_t *) ev->bdaddr, |
| ev->attr_handle, ev->offset, |
| ev->length, ev->need_rsp, |
| ev->is_prep, ev->value); |
| } |
| |
| static void handle_request_exec_write(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_request_exec_write *ev = buf; |
| |
| if (cbs->server->request_exec_write_cb) |
| cbs->server->request_exec_write_cb(ev->conn_id, ev->trans_id, |
| (bt_bdaddr_t *) ev->bdaddr, |
| ev->exec_write); |
| } |
| |
| static void handle_response_confirmation(void *buf, uint16_t len, int fd) |
| { |
| struct hal_ev_gatt_server_rsp_confirmation *ev = buf; |
| |
| if (cbs->server->response_confirmation_cb) |
| cbs->server->response_confirmation_cb(ev->status, ev->handle); |
| } |
| |
| static void handle_configure_mtu(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_configure_mtu *ev = buf; |
| |
| if (cbs->client->configure_mtu_cb) |
| cbs->client->configure_mtu_cb(ev->conn_id, ev->status, ev->mtu); |
| #endif |
| } |
| |
| static void handle_filter_config(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_filter_config *ev = buf; |
| |
| if (cbs->client->scan_filter_cfg_cb) |
| cbs->client->scan_filter_cfg_cb(ev->action, ev->client_if, |
| ev->status, ev->type, |
| ev->space); |
| #endif |
| } |
| |
| static void handle_filter_params(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_filter_params *ev = buf; |
| |
| if (cbs->client->scan_filter_param_cb) |
| cbs->client->scan_filter_param_cb(ev->action, ev->client_if, |
| ev->status, ev->space); |
| #endif |
| } |
| |
| static void handle_filter_status(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_filter_status *ev = buf; |
| |
| if (cbs->client->scan_filter_status_cb) |
| cbs->client->scan_filter_status_cb(ev->enable, ev->client_if, |
| ev->status); |
| #endif |
| } |
| |
| static void handle__multi_adv_enable(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_multi_adv_enable *ev = buf; |
| |
| if (cbs->client->multi_adv_enable_cb) |
| cbs->client->multi_adv_enable_cb(ev->client_if, ev->status); |
| #endif |
| } |
| |
| static void handle_multi_adv_update(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_multi_adv_update *ev = buf; |
| |
| if (cbs->client->multi_adv_update_cb) |
| cbs->client->multi_adv_update_cb(ev->client_if, ev->status); |
| #endif |
| } |
| |
| static void handle_multi_adv_data(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_multi_adv_data *ev = buf; |
| |
| if (cbs->client->multi_adv_data_cb) |
| cbs->client->multi_adv_data_cb(ev->client_if, ev->status); |
| #endif |
| } |
| |
| static void handle_multi_adv_disable(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_multi_adv_disable *ev = buf; |
| |
| if (cbs->client->multi_adv_disable_cb) |
| cbs->client->multi_adv_disable_cb(ev->client_if, ev->status); |
| #endif |
| } |
| |
| static void handle_client_congestion(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_congestion *ev = buf; |
| |
| if (cbs->client->congestion_cb) |
| cbs->client->congestion_cb(ev->conn_id, ev->congested); |
| #endif |
| } |
| |
| static void handle_config_batchscan(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_config_batchscan *ev = buf; |
| |
| if (cbs->client->batchscan_cfg_storage_cb) |
| cbs->client->batchscan_cfg_storage_cb(ev->client_if, |
| ev->status); |
| #endif |
| } |
| |
| static void handle_enable_batchscan(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_enable_batchscan *ev = buf; |
| |
| if (cbs->client->batchscan_enb_disable_cb) |
| cbs->client->batchscan_enb_disable_cb(ev->action, ev->client_if, |
| ev->status); |
| #endif |
| } |
| |
| static void handle_client_batchscan_reports(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_batchscan_reports *ev = buf; |
| |
| if (cbs->client->batchscan_reports_cb) |
| cbs->client->batchscan_reports_cb(ev->client_if, ev->status, |
| ev->format, ev->num, |
| ev->data_len, ev->data); |
| #endif |
| } |
| |
| static void handle_batchscan_threshold(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_batchscan_threshold *ev = buf; |
| |
| if (cbs->client->batchscan_threshold_cb) |
| cbs->client->batchscan_threshold_cb(ev->client_if); |
| #endif |
| } |
| |
| static void handle_track_adv(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_client_track_adv *ev = buf; |
| |
| if (cbs->client->track_adv_event_cb) |
| cbs->client->track_adv_event_cb(ev->client_if, ev->filetr_index, |
| ev->address_type, |
| (bt_bdaddr_t *) ev->address, |
| ev->state); |
| #endif |
| } |
| |
| static void handle_indication_send(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_server_indication_sent *ev = buf; |
| |
| if (cbs->server->indication_sent_cb) |
| cbs->server->indication_sent_cb(ev->conn_id, ev->status); |
| #endif |
| } |
| |
| static void handle_server_congestion(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| struct hal_ev_gatt_server_congestion *ev = buf; |
| |
| if (cbs->server->congestion_cb) |
| cbs->server->congestion_cb(ev->conn_id, ev->congested); |
| #endif |
| } |
| |
| static void handle_server_mtu_changed(void *buf, uint16_t len, int fd) |
| { |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 1, 0) |
| struct hal_ev_gatt_server_mtu_changed *ev = buf; |
| |
| if (cbs->server->mtu_changed_cb) |
| cbs->server->mtu_changed_cb(ev->conn_id, ev->mtu); |
| #endif |
| } |
| |
| /* |
| * handlers will be called from notification thread context, |
| * index in table equals to 'opcode - HAL_MINIMUM_EVENT' |
| */ |
| static const struct hal_ipc_handler ev_handlers[] = { |
| /* HAL_EV_GATT_CLIENT_REGISTER_CLIENT */ |
| { handle_register_client, false, |
| sizeof(struct hal_ev_gatt_client_register_client) }, |
| /* HAL_EV_GATT_CLIENT_SCAN_RESULT */ |
| { handle_scan_result, true, |
| sizeof(struct hal_ev_gatt_client_scan_result) }, |
| /* HAL_EV_GATT_CLIENT_CONNECT */ |
| { handle_connect, false, sizeof(struct hal_ev_gatt_client_connect) }, |
| /* HAL_EV_GATT_CLIENT_DISCONNECT */ |
| { handle_disconnect, false, |
| sizeof(struct hal_ev_gatt_client_disconnect) }, |
| /* HAL_EV_GATT_CLIENT_SEARCH_COMPLETE */ |
| { handle_search_complete, false, |
| sizeof(struct hal_ev_gatt_client_search_complete) }, |
| /* HAL_EV_GATT_CLIENT_SEARCH_RESULT */ |
| { handle_search_result, false, |
| sizeof(struct hal_ev_gatt_client_search_result) }, |
| /* HAL_EV_GATT_CLIENT_GET_CHARACTERISTIC */ |
| { handle_get_characteristic, false, |
| sizeof(struct hal_ev_gatt_client_get_characteristic) }, |
| /* HAL_EV_GATT_CLIENT_GET_DESCRIPTOR */ |
| { handle_get_descriptor, false, |
| sizeof(struct hal_ev_gatt_client_get_descriptor) }, |
| /* HAL_EV_GATT_CLIENT_GET_INC_SERVICE */ |
| { handle_get_included_service, false, |
| sizeof(struct hal_ev_gatt_client_get_inc_service) }, |
| /* HAL_EV_GATT_CLIENT_REGISTER_FOR_NOTIF */ |
| { handle_register_for_notification, false, |
| sizeof(struct hal_ev_gatt_client_reg_for_notif) }, |
| /* HAL_EV_GATT_CLIENT_NOTIFY */ |
| { handle_notify, true, sizeof(struct hal_ev_gatt_client_notify) }, |
| /* HAL_EV_GATT_CLIENT_READ_CHARACTERISTIC */ |
| { handle_read_characteristic, true, |
| sizeof(struct hal_ev_gatt_client_read_characteristic) }, |
| /* HAL_EV_GATT_CLIENT_WRITE_CHARACTERISTIC */ |
| { handle_write_characteristic, false, |
| sizeof(struct hal_ev_gatt_client_write_characteristic) }, |
| /* HAL_EV_GATT_CLIENT_READ_DESCRIPTOR */ |
| { handle_read_descriptor, true, |
| sizeof(struct hal_ev_gatt_client_read_descriptor) }, |
| /* HAL_EV_GATT_CLIENT_WRITE_DESCRIPTOR */ |
| { handle_write_descriptor, false, |
| sizeof(struct hal_ev_gatt_client_write_descriptor) }, |
| /* HAL_EV_GATT_CLIENT_EXEC_WRITE */ |
| { handle_execute_write, false, |
| sizeof(struct hal_ev_gatt_client_exec_write) }, |
| /* HAL_EV_GATT_CLIENT_READ_REMOTE_RSSI */ |
| { handle_read_remote_rssi, false, |
| sizeof(struct hal_ev_gatt_client_read_remote_rssi) }, |
| /* HAL_EV_GATT_CLIENT_LISTEN */ |
| { handle_listen, false, sizeof(struct hal_ev_gatt_client_listen) }, |
| /* HAL_EV_GATT_SERVER_REGISTER */ |
| { handle_register_server, false, |
| sizeof(struct hal_ev_gatt_server_register) }, |
| /* HAL_EV_GATT_SERVER_CONNECTION */ |
| { handle_connection, false, |
| sizeof(struct hal_ev_gatt_server_connection) }, |
| /* HAL_EV_GATT_SERVER_SERVICE_ADDED */ |
| { handle_service_added, false, |
| sizeof(struct hal_ev_gatt_server_service_added) }, |
| /* HAL_EV_GATT_SERVER_INC_SRVC_ADDED */ |
| { handle_included_service_added, false, |
| sizeof(struct hal_ev_gatt_server_inc_srvc_added) }, |
| /* HAL_EV_GATT_SERVER_CHAR_ADDED */ |
| { handle_characteristic_added, false, |
| sizeof(struct hal_ev_gatt_server_characteristic_added) }, |
| /* HAL_EV_GATT_SERVER_DESCRIPTOR_ADDED */ |
| { handle_descriptor_added, false, |
| sizeof(struct hal_ev_gatt_server_descriptor_added) }, |
| /* HAL_EV_GATT_SERVER_SERVICE_STARTED */ |
| { handle_service_started, false, |
| sizeof(struct hal_ev_gatt_server_service_started) }, |
| /* HAL_EV_GATT_SERVER_SERVICE_STOPPED */ |
| { handle_service_stopped, false, |
| sizeof(struct hal_ev_gatt_server_service_stopped) }, |
| /* HAL_EV_GATT_SERVER_SERVICE_DELETED */ |
| { handle_service_deleted, false, |
| sizeof(struct hal_ev_gatt_server_service_deleted) }, |
| /* HAL_EV_GATT_SERVER_REQUEST_READ */ |
| { handle_request_read, false, |
| sizeof(struct hal_ev_gatt_server_request_read) }, |
| /* HAL_EV_GATT_SERVER_REQUEST_WRITE */ |
| { handle_request_write, true, |
| sizeof(struct hal_ev_gatt_server_request_write) }, |
| /* HAL_EV_GATT_SERVER_REQUEST_EXEC_WRITE */ |
| { handle_request_exec_write, false, |
| sizeof(struct hal_ev_gatt_server_request_exec_write) }, |
| /* HAL_EV_GATT_SERVER_RSP_CONFIRMATION */ |
| { handle_response_confirmation, false, |
| sizeof(struct hal_ev_gatt_server_rsp_confirmation) }, |
| /* HAL_EV_GATT_CLIENT_CONFIGURE_MTU */ |
| { handle_configure_mtu, false, |
| sizeof(struct hal_ev_gatt_client_configure_mtu) }, |
| /* HAL_EV_GATT_CLIENT_FILTER_CONFIG */ |
| { handle_filter_config, false, |
| sizeof(struct hal_ev_gatt_client_filter_config) }, |
| /* HAL_EV_GATT_CLIENT_FILTER_PARAMS */ |
| { handle_filter_params, false, |
| sizeof(struct hal_ev_gatt_client_filter_params) }, |
| /* HAL_EV_GATT_CLIENT_FILTER_STATUS */ |
| { handle_filter_status, false, |
| sizeof(struct hal_ev_gatt_client_filter_status) }, |
| /* HAL_EV_GATT_CLIENT_MULTI_ADV_ENABLE */ |
| { handle__multi_adv_enable, false, |
| sizeof(struct hal_ev_gatt_client_multi_adv_enable) }, |
| /* HAL_EV_GATT_CLIENT_MULTI_ADV_UPDATE */ |
| { handle_multi_adv_update, false, |
| sizeof(struct hal_ev_gatt_client_multi_adv_update) }, |
| /* HAL_EV_GATT_CLIENT_MULTI_ADV_DATA */ |
| { handle_multi_adv_data, false, |
| sizeof(struct hal_ev_gatt_client_multi_adv_data) }, |
| /* HAL_EV_GATT_CLIENT_MULTI_ADV_DISABLE */ |
| { handle_multi_adv_disable, false, |
| sizeof(struct hal_ev_gatt_client_multi_adv_disable) }, |
| /* HAL_EV_GATT_CLIENT_CONGESTION */ |
| { handle_client_congestion, false, |
| sizeof(struct hal_ev_gatt_client_congestion) }, |
| /* HAL_EV_GATT_CLIENT_CONFIG_BATCHSCAN */ |
| { handle_config_batchscan, false, |
| sizeof(struct hal_ev_gatt_client_config_batchscan) }, |
| /* HAL_EV_GATT_CLIENT_ENABLE_BATCHSCAN */ |
| { handle_enable_batchscan, false, |
| sizeof(struct hal_ev_gatt_client_enable_batchscan) }, |
| /* HAL_EV_GATT_CLIENT_BATCHSCAN_REPORTS */ |
| { handle_client_batchscan_reports, true, |
| sizeof(struct hal_ev_gatt_client_batchscan_reports) }, |
| /* HAL_EV_GATT_CLIENT_BATCHSCAN_THRESHOLD */ |
| { handle_batchscan_threshold, false, |
| sizeof(struct hal_ev_gatt_client_batchscan_threshold) }, |
| /* HAL_EV_GATT_CLIENT_TRACK_ADV */ |
| { handle_track_adv, false, |
| sizeof(struct hal_ev_gatt_client_track_adv) }, |
| /* HAL_EV_GATT_SERVER_INDICATION_SENT */ |
| { handle_indication_send, false, |
| sizeof(struct hal_ev_gatt_server_indication_sent) }, |
| /* HAL_EV_GATT_SERVER_CONGESTION */ |
| { handle_server_congestion, false, |
| sizeof(struct hal_ev_gatt_server_congestion) }, |
| /* HAL_EV_GATT_SERVER_MTU_CHANGED */ |
| { handle_server_mtu_changed, false, |
| sizeof(struct hal_ev_gatt_server_mtu_changed) }, |
| }; |
| |
| /* Client API */ |
| |
| static bt_status_t register_client(bt_uuid_t *uuid) |
| { |
| struct hal_cmd_gatt_client_register cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| memcpy(cmd.uuid, uuid, sizeof(*uuid)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_REGISTER, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t unregister_client(int client_if) |
| { |
| struct hal_cmd_gatt_client_unregister cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_UNREGISTER, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t scan_real(int client_if, bool start) |
| { |
| struct hal_cmd_gatt_client_scan cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.start = start; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_SCAN, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| static bt_status_t scan(bool start) |
| { |
| return scan_real(0, start); |
| } |
| #else |
| static bt_status_t scan(int client_if, bool start) |
| { |
| return scan_real(client_if, start); |
| } |
| #endif |
| |
| static bt_status_t connect_real(int client_if, const bt_bdaddr_t *bd_addr, |
| bool is_direct, int transport) |
| { |
| struct hal_cmd_gatt_client_connect cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.is_direct = is_direct; |
| cmd.transport = transport; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_CONNECT, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| static bt_status_t connect(int client_if, const bt_bdaddr_t *bd_addr, |
| bool is_direct, int transport) |
| { |
| return connect_real(client_if, bd_addr, is_direct, transport); |
| } |
| #else |
| static bt_status_t connect(int client_if, const bt_bdaddr_t *bd_addr, |
| bool is_direct) |
| { |
| return connect_real(client_if, bd_addr, is_direct, |
| BT_TRANSPORT_UNKNOWN); |
| } |
| #endif |
| |
| static bt_status_t disconnect(int client_if, const bt_bdaddr_t *bd_addr, |
| int conn_id) |
| { |
| struct hal_cmd_gatt_client_disconnect cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.conn_id = conn_id; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_DISCONNECT, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t listen(int client_if, bool start) |
| { |
| struct hal_cmd_gatt_client_listen cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.start = start; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_LISTEN, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t refresh(int client_if, const bt_bdaddr_t *bd_addr) |
| { |
| struct hal_cmd_gatt_client_refresh cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_REFRESH, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t search_service(int conn_id, bt_uuid_t *filter_uuid) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_search_service *cmd = (void *) buf; |
| size_t len = sizeof(*cmd); |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| memset(cmd, 0, sizeof(*cmd)); |
| |
| cmd->conn_id = conn_id; |
| |
| if (filter_uuid) { |
| memcpy(cmd->filter_uuid, filter_uuid, sizeof(*filter_uuid)); |
| len += sizeof(*filter_uuid); |
| cmd->filtered = 1; |
| } |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SEARCH_SERVICE, |
| len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t get_included_service(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_srvc_id_t *start_incl_srvc_id) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_get_included_service *cmd = (void *) buf; |
| size_t len = sizeof(*cmd); |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->conn_id = conn_id; |
| |
| srvc_id_to_hal(&cmd->srvc_id, srvc_id); |
| cmd->continuation = 0; |
| |
| if (start_incl_srvc_id) { |
| srvc_id_to_hal(&cmd->incl_srvc_id[0], start_incl_srvc_id); |
| len += sizeof(cmd->incl_srvc_id[0]); |
| cmd->continuation = 1; |
| } |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_GET_INCLUDED_SERVICE, |
| len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t get_characteristic(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *start_char_id) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_get_characteristic *cmd = (void *) buf; |
| size_t len = sizeof(*cmd); |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->conn_id = conn_id; |
| |
| srvc_id_to_hal(&cmd->srvc_id, srvc_id); |
| cmd->continuation = 0; |
| |
| if (start_char_id) { |
| gatt_id_to_hal(&cmd->char_id[0], start_char_id); |
| len += sizeof(cmd->char_id[0]); |
| cmd->continuation = 1; |
| } |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_GET_CHARACTERISTIC, |
| len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t get_descriptor(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id, |
| btgatt_gatt_id_t *start_descr_id) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_get_descriptor *cmd = (void *) buf; |
| size_t len = sizeof(*cmd); |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->conn_id = conn_id; |
| |
| srvc_id_to_hal(&cmd->srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd->char_id, char_id); |
| cmd->continuation = 0; |
| |
| if (start_descr_id) { |
| gatt_id_to_hal(&cmd->descr_id[0], start_descr_id); |
| len += sizeof(cmd->descr_id[0]); |
| cmd->continuation = 1; |
| } |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_GET_DESCRIPTOR, |
| len, cmd, NULL , NULL, NULL); |
| } |
| |
| static bt_status_t read_characteristic(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id, |
| int auth_req) |
| { |
| struct hal_cmd_gatt_client_read_characteristic cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.conn_id = conn_id; |
| cmd.auth_req = auth_req; |
| |
| srvc_id_to_hal(&cmd.srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd.char_id, char_id); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_READ_CHARACTERISTIC, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t write_characteristic(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id, |
| int write_type, int len, int auth_req, |
| char *p_value) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_write_characteristic *cmd = (void *) buf; |
| size_t cmd_len = sizeof(*cmd) + len; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->conn_id = conn_id; |
| cmd->write_type = write_type; |
| cmd->len = len; |
| cmd->auth_req = auth_req; |
| |
| srvc_id_to_hal(&cmd->srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd->char_id, char_id); |
| |
| memcpy(cmd->value, p_value, len); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_WRITE_CHARACTERISTIC, |
| cmd_len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t read_descriptor(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id, |
| btgatt_gatt_id_t *descr_id, |
| int auth_req) |
| { |
| struct hal_cmd_gatt_client_read_descriptor cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.conn_id = conn_id; |
| cmd.auth_req = auth_req; |
| |
| srvc_id_to_hal(&cmd.srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd.char_id, char_id); |
| gatt_id_to_hal(&cmd.descr_id, descr_id); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_READ_DESCRIPTOR, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t write_descriptor(int conn_id, btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id, |
| btgatt_gatt_id_t *descr_id, |
| int write_type, int len, int auth_req, |
| char *p_value) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_write_descriptor *cmd = (void *) buf; |
| size_t cmd_len = sizeof(*cmd) + len; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->conn_id = conn_id; |
| cmd->write_type = write_type; |
| cmd->len = len; |
| cmd->auth_req = auth_req; |
| |
| srvc_id_to_hal(&cmd->srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd->char_id, char_id); |
| gatt_id_to_hal(&cmd->descr_id, descr_id); |
| |
| memcpy(cmd->value, p_value, len); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_WRITE_DESCRIPTOR, |
| cmd_len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t execute_write(int conn_id, int execute) |
| { |
| struct hal_cmd_gatt_client_execute_write cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.conn_id = conn_id; |
| cmd.execute = execute; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_EXECUTE_WRITE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t register_for_notification(int client_if, |
| const bt_bdaddr_t *bd_addr, |
| btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id) |
| { |
| struct hal_cmd_gatt_client_register_for_notification cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| srvc_id_to_hal(&cmd.srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd.char_id, char_id); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_REGISTER_FOR_NOTIFICATION, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t deregister_for_notification(int client_if, |
| const bt_bdaddr_t *bd_addr, |
| btgatt_srvc_id_t *srvc_id, |
| btgatt_gatt_id_t *char_id) |
| { |
| struct hal_cmd_gatt_client_deregister_for_notification cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| srvc_id_to_hal(&cmd.srvc_id, srvc_id); |
| gatt_id_to_hal(&cmd.char_id, char_id); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_DEREGISTER_FOR_NOTIFICATION, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t read_remote_rssi(int client_if, const bt_bdaddr_t *bd_addr) |
| { |
| struct hal_cmd_gatt_client_read_remote_rssi cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_READ_REMOTE_RSSI, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static int get_device_type(const bt_bdaddr_t *bd_addr) |
| { |
| struct hal_cmd_gatt_client_get_device_type cmd; |
| uint8_t dev_type; |
| size_t resp_len = sizeof(dev_type); |
| bt_status_t status; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| status = hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_GET_DEVICE_TYPE, |
| sizeof(cmd), &cmd, &resp_len, &dev_type, NULL); |
| |
| if (status != BT_STATUS_SUCCESS || resp_len != sizeof(dev_type)) |
| return 0; |
| |
| return dev_type; |
| } |
| |
| static bt_status_t set_adv_data_real(int server_if, bool set_scan_rsp, |
| bool include_name, bool include_txpower, |
| int min_interval, int max_interval, |
| int appearance, uint16_t manufacturer_len, |
| char *manufacturer_data, |
| uint16_t service_data_len, char *service_data, |
| uint16_t service_uuid_len, char *service_uuid) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_set_adv_data *cmd = (void *) buf; |
| size_t cmd_len; |
| uint8_t *data; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd_len = sizeof(*cmd) + manufacturer_len + service_data_len + |
| service_uuid_len; |
| |
| if (cmd_len > IPC_MTU) |
| return BT_STATUS_FAIL; |
| |
| cmd->server_if = server_if; |
| cmd->set_scan_rsp = set_scan_rsp; |
| cmd->include_name = include_name; |
| cmd->include_txpower = include_txpower; |
| cmd->min_interval = min_interval; |
| cmd->max_interval = max_interval; |
| cmd->appearance = appearance; |
| cmd->manufacturer_len = manufacturer_len; |
| cmd->service_data_len = service_data_len; |
| cmd->service_uuid_len = service_uuid_len; |
| |
| data = cmd->data; |
| |
| if (manufacturer_data && manufacturer_len) { |
| memcpy(data, manufacturer_data, manufacturer_len); |
| data += manufacturer_len; |
| } |
| |
| if (service_data && service_data_len) { |
| memcpy(data, service_data, service_data_len); |
| data += service_data_len; |
| } |
| |
| if (service_uuid && service_uuid_len) |
| memcpy(data, service_uuid, service_uuid_len); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_SET_ADV_DATA, |
| cmd_len, cmd, NULL, NULL, NULL); |
| } |
| |
| /* |
| * This is temporary solution and support for older Android versions might |
| * be removed at any time. |
| */ |
| #if ANDROID_VERSION < PLATFORM_VER(4, 4, 3) |
| static bt_status_t set_adv_data(int server_if, bool set_scan_rsp, |
| bool include_name, bool include_txpower, |
| int min_interval, int max_interval, |
| int appearance, uint16_t manufacturer_len, |
| char *manufacturer_data) |
| { |
| return set_adv_data_real(server_if, set_scan_rsp, include_name, |
| include_txpower, min_interval, |
| max_interval, appearance, |
| manufacturer_len, manufacturer_data, |
| 0, NULL, 0, NULL); |
| } |
| #else |
| static bt_status_t set_adv_data(int server_if, bool set_scan_rsp, |
| bool include_name, bool include_txpower, |
| int min_interval, int max_interval, |
| int appearance, uint16_t manufacturer_len, |
| char *manufacturer_data, |
| uint16_t service_data_len, char *service_data, |
| uint16_t service_uuid_len, char *service_uuid) |
| { |
| return set_adv_data_real(server_if, set_scan_rsp, include_name, |
| include_txpower, min_interval, |
| max_interval, appearance, |
| manufacturer_len, manufacturer_data, |
| service_data_len, service_data, |
| service_uuid_len, service_uuid); |
| } |
| #endif |
| |
| static bt_status_t test_command(int command, btgatt_test_params_t *params) |
| { |
| struct hal_cmd_gatt_client_test_command cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.command = command; |
| |
| memcpy(cmd.bda1, params->bda1, sizeof(*params->bda1)); |
| memcpy(cmd.uuid1, params->uuid1, sizeof(*params->uuid1)); |
| |
| cmd.u1 = params->u1; |
| cmd.u2 = params->u2; |
| cmd.u3 = params->u3; |
| cmd.u4 = params->u4; |
| cmd.u5 = params->u5; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_CLIENT_TEST_COMMAND, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| static bt_status_t scan_filter_param_setup(int client_if, int action, |
| int filt_index, int feat_seln, |
| int list_logic_type, |
| int filt_logic_type, |
| int rssi_high_thres, |
| int rssi_low_thres, |
| int dely_mode, |
| int found_timeout, |
| int lost_timeout, |
| int found_timeout_cnt) |
| { |
| struct hal_cmd_gatt_client_scan_filter_setup cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.action = action; |
| cmd.filter_index = filt_index; |
| cmd.features = feat_seln; |
| cmd.list_type = list_logic_type; |
| cmd.filter_type = filt_logic_type; |
| cmd.rssi_hi = rssi_high_thres; |
| cmd.rssi_lo = rssi_low_thres; |
| cmd.delivery_mode = dely_mode; |
| cmd.found_timeout = found_timeout; |
| cmd.lost_timeout = lost_timeout; |
| cmd.found_timeout_cnt = found_timeout_cnt; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SCAN_FILTER_SETUP, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t scan_filter_add_remove(int client_if, int action, |
| int filt_type, int filt_index, |
| int company_id, |
| int company_id_mask, |
| const bt_uuid_t *p_uuid, |
| const bt_uuid_t *p_uuid_mask, |
| const bt_bdaddr_t *bd_addr, |
| char addr_type, |
| int data_len, char *p_data, |
| int mask_len, char *p_mask) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_scan_filter_add_remove *cmd = (void *) buf; |
| size_t cmd_len; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| if (!p_uuid || !p_uuid_mask || !bd_addr) |
| return BT_STATUS_PARM_INVALID; |
| |
| cmd_len = sizeof(*cmd) + data_len + mask_len; |
| if (cmd_len > IPC_MTU) |
| return BT_STATUS_FAIL; |
| |
| cmd->client_if = client_if; |
| cmd->action = action; |
| cmd->filter_type = filt_type; |
| cmd->filter_index = filt_index; |
| cmd->company_id = company_id; |
| cmd->company_id_mask = company_id_mask; |
| memcpy(cmd->uuid, p_uuid, sizeof(*p_uuid)); |
| memcpy(cmd->uuid_mask, p_uuid_mask, sizeof(*p_uuid_mask)); |
| memcpy(cmd->address, bd_addr, sizeof(*bd_addr)); |
| cmd->address_type = addr_type; |
| |
| cmd->data_len = data_len; |
| memcpy(cmd->data_mask, p_data, data_len); |
| |
| cmd->mask_len = mask_len; |
| memcpy(cmd->data_mask + data_len, p_mask, mask_len); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SCAN_FILTER_ADD_REMOVE, |
| cmd_len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t scan_filter_clear(int client_if, int filt_index) |
| { |
| struct hal_cmd_gatt_client_scan_filter_clear cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.index = filt_index; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SCAN_FILTER_CLEAR, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t scan_filter_enable(int client_if, bool enable) |
| { |
| struct hal_cmd_gatt_client_scan_filter_enable cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.enable = enable; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SCAN_FILTER_ENABLE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t configure_mtu(int conn_id, int mtu) |
| { |
| struct hal_cmd_gatt_client_configure_mtu cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.conn_id = conn_id; |
| cmd.mtu = mtu; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_CONFIGURE_MTU, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t conn_parameter_update(const bt_bdaddr_t *bd_addr, |
| int min_interval, |
| int max_interval, int latency, |
| int timeout) |
| { |
| struct hal_cmd_gatt_client_conn_param_update cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| if (!bd_addr) |
| return BT_STATUS_PARM_INVALID; |
| |
| memcpy(cmd.address, bd_addr, sizeof(*bd_addr)); |
| cmd.min_interval = min_interval; |
| cmd.max_interval = max_interval; |
| cmd.latency = latency; |
| cmd.timeout = timeout; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_CONN_PARAM_UPDATE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t set_scan_parameters(int scan_interval, int scan_window) |
| { |
| struct hal_cmd_gatt_client_set_scan_param cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.interval = scan_interval; |
| cmd.window = scan_window; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SET_SCAN_PARAM, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t multi_adv_enable(int client_if, int min_interval, |
| int max_interval, int adv_type, |
| int chnl_map, int tx_power, |
| int timeout_s) |
| { |
| struct hal_cmd_gatt_client_setup_multi_adv cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.min_interval = min_interval; |
| cmd.max_interval = max_interval; |
| cmd.type = adv_type; |
| cmd.channel_map = chnl_map; |
| cmd.tx_power = tx_power; |
| cmd.timeout = timeout_s; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SETUP_MULTI_ADV, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t multi_adv_update(int client_if, int min_interval, |
| int max_interval, int adv_type, |
| int chnl_map, int tx_power, |
| int timeout_s) |
| { |
| struct hal_cmd_gatt_client_update_multi_adv cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.min_interval = min_interval; |
| cmd.max_interval = max_interval; |
| cmd.type = adv_type; |
| cmd.channel_map = chnl_map; |
| cmd.tx_power = tx_power; |
| cmd.timeout = timeout_s; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_UPDATE_MULTI_ADV, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t multi_adv_set_inst_data(int client_if, bool set_scan_rsp, |
| bool include_name, |
| bool incl_txpower, |
| int appearance, |
| int manufacturer_len, |
| char *manufacturer_data, |
| int service_data_len, |
| char *service_data, |
| int service_uuid_len, |
| char *service_uuid) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_client_setup_multi_adv_inst *cmd = (void *) buf; |
| int off = 0; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| if (manufacturer_len > 0 && !manufacturer_data) |
| return BT_STATUS_PARM_INVALID; |
| |
| if (service_data_len > 0 && !service_data) |
| return BT_STATUS_PARM_INVALID; |
| |
| if (service_uuid_len > 0 && !service_uuid) |
| return BT_STATUS_PARM_INVALID; |
| |
| if (sizeof(*cmd) + manufacturer_len + service_data_len |
| + service_uuid_len > IPC_MTU) |
| return BT_STATUS_FAIL; |
| |
| cmd->client_if = client_if; |
| cmd->set_scan_rsp = set_scan_rsp; |
| cmd->include_name = include_name; |
| cmd->include_tx_power = incl_txpower; |
| cmd->appearance = appearance; |
| cmd->manufacturer_data_len = manufacturer_len; |
| cmd->service_data_len = service_data_len; |
| cmd->service_uuid_len = service_uuid_len; |
| |
| if (manufacturer_len > 0) { |
| memcpy(cmd->data_service_uuid, manufacturer_data, |
| manufacturer_len); |
| off += manufacturer_len; |
| } |
| |
| if (service_data_len > 0) { |
| memcpy(cmd->data_service_uuid + off, service_data, |
| service_data_len); |
| off += service_data_len; |
| } |
| |
| if (service_uuid_len > 0) { |
| memcpy(cmd->data_service_uuid + off, service_uuid, |
| service_uuid_len); |
| off += service_uuid_len; |
| } |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_SETUP_MULTI_ADV_INST, |
| sizeof(*cmd) + off, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t multi_adv_disable(int client_if) |
| { |
| struct hal_cmd_gatt_client_disable_multi_adv_inst cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_DISABLE_MULTI_ADV_INST, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t batchscan_cfg_storage(int client_if, int batch_scan_full_max, |
| int batch_scan_trunc_max, |
| int batch_scan_notify_threshold) |
| { |
| struct hal_cmd_gatt_client_configure_batchscan cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.full_max = batch_scan_full_max; |
| cmd.trunc_max = batch_scan_trunc_max; |
| cmd.notify_threshold = batch_scan_notify_threshold; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_CONFIGURE_BATCHSCAN, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t batchscan_enb_batch_scan(int client_if, int scan_mode, |
| int scan_interval, |
| int scan_window, int addr_type, |
| int discard_rule) |
| { |
| struct hal_cmd_gatt_client_enable_batchscan cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.mode = scan_mode; |
| cmd.interval = scan_interval; |
| cmd.window = scan_window; |
| cmd.address_type = addr_type; |
| cmd.discard_rule = discard_rule; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_ENABLE_BATCHSCAN, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t batchscan_dis_batch_scan(int client_if) |
| { |
| struct hal_cmd_gatt_client_disable_batchscan cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_DISABLE_BATCHSCAN, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t batchscan_read_reports(int client_if, int scan_mode) |
| { |
| struct hal_cmd_gatt_client_read_batchscan_reports cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.client_if = client_if; |
| cmd.scan_mode = scan_mode; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_CLIENT_READ_BATCHSCAN_REPORTS, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| #endif |
| |
| /* Server API */ |
| |
| static bt_status_t register_server(bt_uuid_t *uuid) |
| { |
| struct hal_cmd_gatt_server_register cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| memcpy(cmd.uuid, uuid, sizeof(*uuid)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_SERVER_REGISTER, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t unregister_server(int server_if) |
| { |
| struct hal_cmd_gatt_server_unregister cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_SERVER_UNREGISTER, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t server_connect_real(int server_if, |
| const bt_bdaddr_t *bd_addr, |
| bool is_direct, int transport) |
| { |
| struct hal_cmd_gatt_server_connect cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.is_direct = is_direct; |
| cmd.transport = transport; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_SERVER_CONNECT, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| static bt_status_t server_connect(int server_if, const bt_bdaddr_t *bd_addr, |
| bool is_direct, int transport) |
| { |
| return server_connect_real(server_if, bd_addr, is_direct, transport); |
| } |
| #else |
| static bt_status_t server_connect(int server_if, const bt_bdaddr_t *bd_addr, |
| bool is_direct) |
| { |
| return server_connect_real(server_if, bd_addr, is_direct, |
| BT_TRANSPORT_UNKNOWN); |
| } |
| #endif |
| |
| static bt_status_t server_disconnect(int server_if, const bt_bdaddr_t *bd_addr, |
| int conn_id) |
| { |
| struct hal_cmd_gatt_server_disconnect cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.conn_id = conn_id; |
| |
| memcpy(cmd.bdaddr, bd_addr, sizeof(*bd_addr)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_SERVER_DISCONNECT, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t add_service(int server_if, btgatt_srvc_id_t *srvc_id, |
| int num_handles) |
| { |
| struct hal_cmd_gatt_server_add_service cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.num_handles = num_handles; |
| |
| srvc_id_to_hal(&cmd.srvc_id, srvc_id); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_SERVER_ADD_SERVICE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t add_included_service(int server_if, int service_handle, |
| int included_handle) |
| { |
| struct hal_cmd_gatt_server_add_inc_service cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.service_handle = service_handle; |
| cmd.included_handle = included_handle; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_ADD_INC_SERVICE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t add_characteristic(int server_if, int service_handle, |
| bt_uuid_t *uuid, int properties, |
| int permissions) |
| { |
| struct hal_cmd_gatt_server_add_characteristic cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.service_handle = service_handle; |
| cmd.properties = properties; |
| cmd.permissions = permissions; |
| |
| memcpy(cmd.uuid, uuid, sizeof(*uuid)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_ADD_CHARACTERISTIC, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t add_descriptor(int server_if, int service_handle, |
| bt_uuid_t *uuid, int permissions) |
| { |
| struct hal_cmd_gatt_server_add_descriptor cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.service_handle = service_handle; |
| cmd.permissions = permissions; |
| |
| memcpy(cmd.uuid, uuid, sizeof(*uuid)); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_ADD_DESCRIPTOR, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t start_service_real(int server_if, int service_handle, |
| int transport) |
| { |
| struct hal_cmd_gatt_server_start_service cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.service_handle = service_handle; |
| cmd.transport = transport; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_START_SERVICE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| static bt_status_t start_service(int server_if, int service_handle, |
| int transport) |
| { |
| return start_service_real(server_if, service_handle, transport); |
| } |
| #else |
| static bt_status_t start_service(int server_if, int service_handle, |
| int transport) |
| { |
| int transport_mask = 0; |
| |
| /* Android 5 changes transport enum to bit mask. */ |
| switch (transport) { |
| case 0: |
| transport_mask = GATT_SERVER_TRANSPORT_LE_BIT; |
| break; |
| case 1: |
| transport_mask = GATT_SERVER_TRANSPORT_BREDR_BIT; |
| break; |
| case 2: |
| transport_mask = GATT_SERVER_TRANSPORT_LE_BIT | |
| GATT_SERVER_TRANSPORT_BREDR_BIT; |
| break; |
| } |
| |
| return start_service_real(server_if, service_handle, transport_mask); |
| } |
| #endif |
| |
| static bt_status_t stop_service(int server_if, int service_handle) |
| { |
| struct hal_cmd_gatt_server_stop_service cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.service_handle = service_handle; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, HAL_OP_GATT_SERVER_STOP_SERVICE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t delete_service(int server_if, int service_handle) |
| { |
| struct hal_cmd_gatt_server_delete_service cmd; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd.server_if = server_if; |
| cmd.service_handle = service_handle; |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_DELETE_SERVICE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t send_indication(int server_if, int attribute_handle, |
| int conn_id, int len, int confirm, |
| char *p_value) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_server_send_indication *cmd = (void *) buf; |
| size_t cmd_len = sizeof(*cmd) + len; |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->server_if = server_if; |
| cmd->attribute_handle = attribute_handle; |
| cmd->conn_id = conn_id; |
| cmd->len = len; |
| cmd->confirm = confirm; |
| |
| memcpy(cmd->value, p_value, len); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_SEND_INDICATION, |
| cmd_len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t send_response(int conn_id, int trans_id, int status, |
| btgatt_response_t *response) |
| { |
| char buf[IPC_MTU]; |
| struct hal_cmd_gatt_server_send_response *cmd = (void *) buf; |
| size_t cmd_len = sizeof(*cmd) + sizeof(*response); |
| |
| memset(buf, 0 , IPC_MTU); |
| |
| if (!interface_ready()) |
| return BT_STATUS_NOT_READY; |
| |
| cmd->conn_id = conn_id; |
| cmd->trans_id = trans_id; |
| cmd->status = status; |
| cmd->handle = response->attr_value.handle; |
| cmd->offset = response->attr_value.offset; |
| cmd->auth_req = response->attr_value.auth_req; |
| cmd->len = response->attr_value.len; |
| |
| memcpy(cmd->data, response->attr_value.value, cmd->len); |
| |
| return hal_ipc_cmd(HAL_SERVICE_ID_GATT, |
| HAL_OP_GATT_SERVER_SEND_RESPONSE, |
| cmd_len, cmd, NULL, NULL, NULL); |
| } |
| |
| static bt_status_t init(const btgatt_callbacks_t *callbacks) |
| { |
| struct hal_cmd_register_module cmd; |
| int ret; |
| |
| DBG(""); |
| |
| if (interface_ready()) |
| return BT_STATUS_DONE; |
| |
| cbs = callbacks; |
| |
| hal_ipc_register(HAL_SERVICE_ID_GATT, ev_handlers, |
| sizeof(ev_handlers)/sizeof(ev_handlers[0])); |
| |
| cmd.service_id = HAL_SERVICE_ID_GATT; |
| cmd.mode = HAL_MODE_DEFAULT; |
| cmd.max_clients = 1; |
| |
| ret = hal_ipc_cmd(HAL_SERVICE_ID_CORE, HAL_OP_REGISTER_MODULE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| |
| if (ret != BT_STATUS_SUCCESS) { |
| cbs = NULL; |
| hal_ipc_unregister(HAL_SERVICE_ID_GATT); |
| } |
| |
| return ret; |
| } |
| |
| static void cleanup(void) |
| { |
| struct hal_cmd_unregister_module cmd; |
| |
| DBG(""); |
| |
| if (!interface_ready()) |
| return; |
| |
| cmd.service_id = HAL_SERVICE_ID_GATT; |
| |
| hal_ipc_cmd(HAL_SERVICE_ID_CORE, HAL_OP_UNREGISTER_MODULE, |
| sizeof(cmd), &cmd, NULL, NULL, NULL); |
| |
| hal_ipc_unregister(HAL_SERVICE_ID_GATT); |
| |
| cbs = NULL; |
| } |
| |
| static btgatt_client_interface_t client_iface = { |
| .register_client = register_client, |
| .unregister_client = unregister_client, |
| .scan = scan, |
| .connect = connect, |
| .disconnect = disconnect, |
| .listen = listen, |
| .refresh = refresh, |
| .search_service = search_service, |
| .get_included_service = get_included_service, |
| .get_characteristic = get_characteristic, |
| .get_descriptor = get_descriptor, |
| .read_characteristic = read_characteristic, |
| .write_characteristic = write_characteristic, |
| .read_descriptor = read_descriptor, |
| .write_descriptor = write_descriptor, |
| .execute_write = execute_write, |
| .register_for_notification = register_for_notification, |
| .deregister_for_notification = deregister_for_notification, |
| .read_remote_rssi = read_remote_rssi, |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| .scan_filter_param_setup = scan_filter_param_setup, |
| .scan_filter_add_remove = scan_filter_add_remove, |
| .scan_filter_clear = scan_filter_clear, |
| .scan_filter_enable = scan_filter_enable, |
| #endif |
| .get_device_type = get_device_type, |
| .set_adv_data = set_adv_data, |
| #if ANDROID_VERSION >= PLATFORM_VER(5, 0, 0) |
| .configure_mtu = configure_mtu, |
| .conn_parameter_update = conn_parameter_update, |
| .set_scan_parameters = set_scan_parameters, |
| .multi_adv_enable = multi_adv_enable, |
| .multi_adv_update = multi_adv_update, |
| .multi_adv_set_inst_data = multi_adv_set_inst_data, |
| .multi_adv_disable = multi_adv_disable, |
| .batchscan_cfg_storage = batchscan_cfg_storage, |
| .batchscan_enb_batch_scan = batchscan_enb_batch_scan, |
| .batchscan_dis_batch_scan = batchscan_dis_batch_scan, |
| .batchscan_read_reports = batchscan_read_reports, |
| #endif |
| .test_command = test_command, |
| }; |
| |
| static btgatt_server_interface_t server_iface = { |
| .register_server = register_server, |
| .unregister_server = unregister_server, |
| .connect = server_connect, |
| .disconnect = server_disconnect, |
| .add_service = add_service, |
| .add_included_service = add_included_service, |
| .add_characteristic = add_characteristic, |
| .add_descriptor = add_descriptor, |
| .start_service = start_service, |
| .stop_service = stop_service, |
| .delete_service = delete_service, |
| .send_indication = send_indication, |
| .send_response = send_response, |
| }; |
| |
| static btgatt_interface_t iface = { |
| .size = sizeof(iface), |
| .init = init, |
| .cleanup = cleanup, |
| .client = &client_iface, |
| .server = &server_iface, |
| }; |
| |
| btgatt_interface_t *bt_get_gatt_interface(void) |
| { |
| return &iface; |
| } |