1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
|
/*
* Author: Sven Gothel <sgothel@jausoft.com>
* Copyright (c) 2020 Gothel Software e.K.
* Copyright (c) 2020 ZAFENA AB
*
* Permission is hereby granted, free of charge, to any person obtaining
* a copy of this software and associated documentation files (the
* "Software"), to deal in the Software without restriction, including
* without limitation the rights to use, copy, modify, merge, publish,
* distribute, sublicense, and/or sell copies of the Software, and to
* permit persons to whom the Software is furnished to do so, subject to
* the following conditions:
*
* The above copyright notice and this permission notice shall be
* included in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
* LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
#ifndef DBT_DEVICE_HPP_
#define DBT_DEVICE_HPP_
#include <cstring>
#include <string>
#include <memory>
#include <cstdint>
#include <vector>
#include <mutex>
#include <atomic>
#include "DBTTypes.hpp"
#include "HCIIoctl.hpp"
#include "GATTHandler.hpp"
namespace direct_bt {
// *************************************************
// *************************************************
// *************************************************
class DBTAdapter; // forward
class DBTDevice : public DBTObject
{
friend DBTAdapter; // managing us: ctor and update(..) during discovery
private:
static const int to_connect_ms = 5000;
DBTAdapter & adapter;
uint64_t ts_update;
std::string name;
int8_t rssi = 0;
int8_t tx_power = 0;
uint16_t appearance = 0;
uint16_t hciConnHandle = 0;
std::shared_ptr<ManufactureSpecificData> msd = nullptr;
std::vector<std::shared_ptr<uuid_t>> services;
std::shared_ptr<GATTHandler> gattHandler = nullptr;
std::recursive_mutex mtx_gatt;
DBTDevice(DBTAdapter & adapter, EInfoReport const & r);
bool addService(std::shared_ptr<uuid_t> const &uuid);
bool addServices(std::vector<std::shared_ptr<uuid_t>> const & services);
EIRDataType update(EInfoReport const & data);
void releaseSharedInstance() const;
public:
const uint64_t ts_creation;
/** Device mac address */
const EUI48 address;
const BDAddressType addressType;
/**
* Releases this instance after calling {@link #remove()}.
*/
~DBTDevice();
std::string get_java_class() const override {
return java_class();
}
static std::string java_class() {
return std::string(JAVA_DBT_PACKAGE "DBTDevice");
}
/** Returns the shared pointer of this instance managed by the adapter. */
std::shared_ptr<DBTDevice> getSharedInstance() const;
/** Returns the managing adapter */
DBTAdapter const & getAdapter() const { return adapter; }
uint64_t getCreationTimestamp() const { return ts_creation; }
uint64_t getUpdateTimestamp() const { return ts_update; }
uint64_t getLastUpdateAge(const uint64_t ts_now) const { return ts_now - ts_update; }
EUI48 const & getAddress() const { return address; }
std::string getAddressString() const { return address.toString(); }
BDAddressType getAddressType() const { return addressType; }
bool isLEAddressType() const { return BDADDR_LE_PUBLIC == addressType || BDADDR_LE_RANDOM == addressType; }
bool isBREDRAddressType() const { return BDADDR_BREDR == addressType; }
std::string const & getName() const { return name; }
bool hasName() const { return name.length()>0; }
int8_t getRSSI() const { return rssi; }
int8_t getTxPower() const { return tx_power; }
uint16_t getAppearance() const { return appearance; }
std::shared_ptr<ManufactureSpecificData> const getManufactureSpecificData() const { return msd; }
std::vector<std::shared_ptr<uuid_t>> getServices() const { return services; }
/** Returns index >= 0 if found, otherwise -1 */
int findService(std::shared_ptr<uuid_t> const &uuid) const;
std::string toString() const override;
/**
* Retrieves the current connection info for this device and returns the ConnectionInfo reference if successful,
* otherwise returns nullptr.
* <p>
* Before this method returns, the internal rssi and tx_power will be updated if any changed
* and therefore all DBTAdapterStatusListener's deviceUpdated(..) method called for notification.
* </p>
*/
std::shared_ptr<ConnectionInfo> getConnectionInfo();
/**
* Establish a HCI BDADDR_LE_PUBLIC or BDADDR_LE_RANDOM connection to this device.
* <p>
* If this device's addressType is not BDADDR_LE_PUBLIC or BDADDR_LE_RANDOM, 0 is being returned.
* </p>
* <p>
* Returns the new connection handle or 0 if not successful.
* </p>
* <p>
* The device is tracked by the managing adapter's HCISession instance.
* </p>
* <p>
* Default parameter values are chosen for using public address resolution
* and usual connection latency, interval etc.
* </p>
*/
uint16_t le_connectHCI(const HCIAddressType peer_mac_type=HCIAddressType::HCIADDR_LE_PUBLIC,
const HCIAddressType own_mac_type=HCIAddressType::HCIADDR_LE_PUBLIC,
const uint16_t interval=0x0004, const uint16_t window=0x0004,
const uint16_t min_interval=0x000F, const uint16_t max_interval=0x000F,
const uint16_t latency=0x0000, const uint16_t supervision_timeout=0x0C80,
const uint16_t min_ce_length=0x0001, const uint16_t max_ce_length=0x0001,
const uint8_t initiator_filter=0);
/**
* Establish a HCI BDADDR_BREDR connection to this device.
* <p>
* If this device's addressType is not BDADDR_BREDR, 0 is being returned.
* </p>
* <p>
* Returns the new connection handle or 0 if not successful.
* </p>
* <p>
* The device is tracked by the managing adapter's HCISession instance.
* </p>
*/
uint16_t connectHCI(const uint16_t pkt_type=HCI_DM1 | HCI_DM3 | HCI_DM5 | HCI_DH1 | HCI_DH3 | HCI_DH5,
const uint16_t clock_offset=0x0000, const uint8_t role_switch=0x01);
/**
* Establish a default HCI connection to this device, using certain default parameter.
* <p>
* Depending on this device's addressType,
* either a BDADDR_BREDR or BDADDR_LE_PUBLIC connection is attempted.
* </p>
* <p>
* Returns the new connection handle or 0 if not successful.
* </p>
* <p>
* The device is tracked by the managing adapter's HCISession instance.
* </p>
*/
uint16_t connectHCIDefault();
/** Return the HCI connection handle to the LE or BREDR peer, 0 if not connected. */
uint16_t getHCIConnectionHandle() const { return hciConnHandle; }
/**
* Disconnect the LE or BREDR peer's GATT and HCI connection.
* <p>
* The device will be removed from the managing adapter's HCISession instance.
* </p>
* <p>
* An open GATTHandler will also be closed via disconnectGATT()
* </p>
*/
void disconnect(const uint8_t reason=0);
/**
* Disconnects this device via disconnect(..) and
* removes its shared reference from the Adapter, not the discovered devices.
* <p>
* This method shall be issued to ensure no device reference will
* be leaked in a long lived adapter, as only the discovered devices
* are being flushed with a new discovery.
* </p>
* <p>
* After calling this method, the device shall no more being used.
* </p>
*/
void remove();
/**
* Returns a newly established GATT connection or an already open GATT connection.
* <p>
* The HCI le_connect or HCI connect (defaultConnect) must be performed first,
* to produce orderly behavior and best performance.
* </p>
* <p>
* The returned GATTHandler is managed by this device instance
* and closed @ disconnect() or explicitly @ disconnectGATT().
* May return nullptr if not connected or failure.
* </p>
*/
std::shared_ptr<GATTHandler> connectGATT(int timeoutMS=GATTHandler::Defaults::L2CAP_READER_THREAD_POLL_TIMEOUT);
/** Returns already opened GATTHandler, see connectGATT(..) and disconnectGATT(). */
std::shared_ptr<GATTHandler> getGATTHandler();
/**
* Returns a list of shared GATTServices available on this device if successful,
* otherwise returns an empty list.
* <p>
* In case no HCI connection has been established yet, connectHCIDefault() will be performed.
* </p>
* <p>
* In case no GATT connection has been established yet, connectGATT(..) will be performed.
* </p>
*/
std::vector<std::shared_ptr<GATTService>> getServices();
/**
* Explicit disconnecting an open GATTHandler, which is usually performed via disconnect()
* <p>
* Implementation will also discard the GATTHandler reference.
* </p>
*/
void disconnectGATT();
};
inline bool operator<(const DBTDevice& lhs, const DBTDevice& rhs)
{ return lhs.address < rhs.address; }
inline bool operator==(const DBTDevice& lhs, const DBTDevice& rhs)
{ return lhs.address == rhs.address; }
inline bool operator!=(const DBTDevice& lhs, const DBTDevice& rhs)
{ return !(lhs == rhs); }
} // namespace direct_bt
#endif /* DBT_DEVICE_HPP_ */
|