1 // Copyright 2022, The Android Open Source Project
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License");
4 // you may not use this file except in compliance with the License.
5 // You may obtain a copy of the License at
6 //
7 // http://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS,
11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 // See the License for the specific language governing permissions and
13 // limitations under the License.
14
15 #include "gatt_shim.h"
16
17 #include <base/functional/bind.h>
18 #include <base/location.h>
19
20 #include <cstdint>
21 #include <optional>
22
23 #include "include/hardware/bluetooth.h"
24 #include "include/hardware/bt_common_types.h"
25 #include "include/hardware/bt_gatt_client.h"
26 #include "include/hardware/bt_gatt_server.h"
27 #include "os/log.h"
28 #include "rust/cxx.h"
29 #include "stack/include/gatt_api.h"
30 #include "types/bluetooth/uuid.h"
31 #include "types/raw_address.h"
32
33 bt_status_t do_in_jni_thread(const base::Location& from_here,
34 base::OnceClosure task);
35
36 namespace {
AddressOfConnection(uint16_t conn_id)37 std::optional<RawAddress> AddressOfConnection(uint16_t conn_id) {
38 tGATT_IF gatt_if;
39 RawAddress remote_bda;
40 tBT_TRANSPORT transport;
41 auto valid =
42 GATT_GetConnectionInfor(conn_id, &gatt_if, remote_bda, &transport);
43 if (!valid) {
44 return std::nullopt;
45 }
46 return remote_bda;
47 }
48 } // namespace
49
50 namespace bluetooth {
51 namespace gatt {
52
OnServerRead(uint16_t conn_id,uint32_t trans_id,uint16_t attr_handle,AttributeBackingType attr_type,uint32_t offset,bool is_long) const53 void GattServerCallbacks::OnServerRead(uint16_t conn_id, uint32_t trans_id,
54 uint16_t attr_handle,
55 AttributeBackingType attr_type,
56 uint32_t offset, bool is_long) const {
57 auto addr = AddressOfConnection(conn_id);
58 if (!addr.has_value()) {
59 LOG_WARN(
60 "Dropping server read characteristic since connection %d not found",
61 conn_id);
62 return;
63 }
64
65 switch (attr_type) {
66 case AttributeBackingType::CHARACTERISTIC:
67 do_in_jni_thread(
68 FROM_HERE,
69 base::Bind(callbacks.request_read_characteristic_cb, conn_id,
70 trans_id, addr.value(), attr_handle, offset, is_long));
71 break;
72 case AttributeBackingType::DESCRIPTOR:
73 do_in_jni_thread(
74 FROM_HERE,
75 base::Bind(callbacks.request_read_descriptor_cb, conn_id, trans_id,
76 addr.value(), attr_handle, offset, is_long));
77 break;
78 default:
79 LOG_ALWAYS_FATAL("Unexpected backing type %d", attr_type);
80 }
81 }
82
OnServerWrite(uint16_t conn_id,uint32_t trans_id,uint16_t attr_handle,AttributeBackingType attr_type,uint32_t offset,bool need_response,bool is_prepare,::rust::Slice<const uint8_t> value) const83 void GattServerCallbacks::OnServerWrite(
84 uint16_t conn_id, uint32_t trans_id, uint16_t attr_handle,
85 AttributeBackingType attr_type, uint32_t offset, bool need_response,
86 bool is_prepare, ::rust::Slice<const uint8_t> value) const {
87 auto addr = AddressOfConnection(conn_id);
88 if (!addr.has_value()) {
89 LOG_WARN(
90 "Dropping server write characteristic since connection %d not found",
91 conn_id);
92 return;
93 }
94
95 auto buf = new uint8_t[value.size()];
96 std::copy(value.begin(), value.end(), buf);
97
98 switch (attr_type) {
99 case AttributeBackingType::CHARACTERISTIC:
100 do_in_jni_thread(
101 FROM_HERE,
102 base::Bind(callbacks.request_write_characteristic_cb, conn_id,
103 trans_id, addr.value(), attr_handle, offset, need_response,
104 is_prepare, base::Owned(buf), value.size()));
105 break;
106 case AttributeBackingType::DESCRIPTOR:
107 do_in_jni_thread(
108 FROM_HERE,
109 base::Bind(callbacks.request_write_descriptor_cb, conn_id, trans_id,
110 addr.value(), attr_handle, offset, need_response,
111 is_prepare, base::Owned(buf), value.size()));
112 break;
113 default:
114 LOG_ALWAYS_FATAL("Unexpected backing type %hhu", attr_type);
115 }
116 }
117
OnIndicationSentConfirmation(uint16_t conn_id,int status) const118 void GattServerCallbacks::OnIndicationSentConfirmation(uint16_t conn_id,
119 int status) const {
120 do_in_jni_thread(FROM_HERE,
121 base::Bind(callbacks.indication_sent_cb, conn_id, status));
122 }
123
OnExecute(uint16_t conn_id,uint32_t trans_id,bool execute) const124 void GattServerCallbacks::OnExecute(uint16_t conn_id, uint32_t trans_id,
125 bool execute) const {
126 auto addr = AddressOfConnection(conn_id);
127 if (!addr.has_value()) {
128 LOG_WARN("Dropping server execute write since connection %d not found",
129 conn_id);
130 return;
131 }
132
133 do_in_jni_thread(
134 FROM_HERE, base::Bind(callbacks.request_exec_write_cb, conn_id, trans_id,
135 addr.value(), execute));
136 }
137
138 } // namespace gatt
139 } // namespace bluetooth
140