blob: a9b644be736fac22970512c6841ebe52b84e92ce [file] [log] [blame]
/*
*
* BlueZ - Bluetooth protocol stack for Linux
*
* Copyright (C) 2006-2010 Nokia Corporation
* Copyright (C) 2004-2010 Marcel Holtmann <marcel@holtmann.org>
*
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*
*/
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdbool.h>
#include <errno.h>
#include <dirent.h>
#include <time.h>
#include <bluetooth/bluetooth.h>
#include <bluetooth/sdp.h>
#include <bluetooth/sdp_lib.h>
#include <glib.h>
#include <dbus/dbus.h>
#include <gdbus/gdbus.h>
#include "log.h"
#include "btio/btio.h"
#include "lib/uuid.h"
#include "lib/mgmt.h"
#include "attrib/att.h"
#include "hcid.h"
#include "adapter.h"
#include "attrib/gattrib.h"
#include "attio.h"
#include "device.h"
#include "profile.h"
#include "service.h"
#include "dbus-common.h"
#include "error.h"
#include "uuid-helper.h"
#include "sdp-client.h"
#include "attrib/gatt.h"
#include "agent.h"
#include "textfile.h"
#include "storage.h"
#include "attrib-server.h"
#define IO_CAPABILITY_NOINPUTNOOUTPUT 0x03
#define DISCONNECT_TIMER 2
#define DISCOVERY_TIMER 1
static DBusConnection *dbus_conn = NULL;
unsigned service_state_cb_id;
struct btd_disconnect_data {
guint id;
disconnect_watch watch;
void *user_data;
GDestroyNotify destroy;
};
struct bonding_req {
DBusMessage *msg;
guint listener_id;
struct btd_device *device;
uint8_t bdaddr_type;
struct agent *agent;
struct btd_adapter_pin_cb_iter *cb_iter;
uint8_t status;
guint retry_timer;
struct timespec attempt_start_time;
long last_attempt_duration_ms;
};
typedef enum {
AUTH_TYPE_PINCODE,
AUTH_TYPE_PASSKEY,
AUTH_TYPE_CONFIRM,
AUTH_TYPE_NOTIFY_PASSKEY,
AUTH_TYPE_NOTIFY_PINCODE,
} auth_type_t;
struct authentication_req {
auth_type_t type;
struct agent *agent;
struct btd_device *device;
uint32_t passkey;
char *pincode;
gboolean secure;
};
struct browse_req {
DBusMessage *msg;
struct btd_device *device;
GSList *match_uuids;
GSList *profiles_added;
sdp_list_t *records;
int search_uuid;
int reconnect_attempt;
guint listener_id;
uint16_t sdp_flags;
};
struct included_search {
struct browse_req *req;
GSList *services;
GSList *current;
};
struct attio_data {
guint id;
attio_connect_cb cfunc;
attio_disconnect_cb dcfunc;
gpointer user_data;
};
struct svc_callback {
unsigned int id;
guint idle_id;
struct btd_device *dev;
device_svc_cb_t func;
void *user_data;
};
typedef void (*attio_error_cb) (const GError *gerr, gpointer user_data);
typedef void (*attio_success_cb) (gpointer user_data);
struct att_callbacks {
attio_error_cb err; /* Callback for error */
attio_success_cb success; /* Callback for success */
gpointer user_data;
};
/* Per-bearer (LE or BR/EDR) device state */
struct bearer_state {
bool paired;
bool bonded;
bool connected;
bool svc_resolved;
};
struct btd_device {
int ref_count;
bdaddr_t bdaddr;
uint8_t bdaddr_type;
char *path;
bool bredr;
bool le;
bool pending_paired; /* "Paired" waiting for SDP */
bool svc_refreshed;
GSList *svc_callbacks;
GSList *eir_uuids;
char name[MAX_NAME_LENGTH + 1];
char *alias;
uint32_t class;
uint16_t vendor_src;
uint16_t vendor;
uint16_t product;
uint16_t version;
uint16_t appearance;
char *modalias;
struct btd_adapter *adapter;
GSList *uuids;
GSList *primaries; /* List of primary services */
GSList *services; /* List of btd_service */
GSList *pending; /* Pending services */
GSList *watches; /* List of disconnect_data */
gboolean temporary;
guint disconn_timer;
guint discov_timer;
struct browse_req *browse; /* service discover request */
struct bonding_req *bonding;
struct authentication_req *authr; /* authentication request */
GSList *disconnects; /* disconnects message */
DBusMessage *connect; /* connect message */
DBusMessage *disconnect; /* disconnect message */
GAttrib *attrib;
GSList *attios;
GSList *attios_offline;
guint attachid; /* Attrib server attach */
struct bearer_state bredr_state;
struct bearer_state le_state;
sdp_list_t *tmp_records;
time_t bredr_seen;
time_t le_seen;
gboolean trusted;
gboolean blocked;
gboolean auto_connect;
gboolean disable_auto_connect;
gboolean general_connect;
bool legacy;
int8_t rssi;
GIOChannel *att_io;
guint cleanup_id;
guint store_id;
};
static const uint16_t uuid_list[] = {
L2CAP_UUID,
PNP_INFO_SVCLASS_ID,
PUBLIC_BROWSE_GROUP,
0
};
static int device_browse_primary(struct btd_device *device, DBusMessage *msg);
static int device_browse_sdp(struct btd_device *device, DBusMessage *msg);
static struct bearer_state *get_state(struct btd_device *dev,
uint8_t bdaddr_type)
{
if (bdaddr_type == BDADDR_BREDR)
return &dev->bredr_state;
else
return &dev->le_state;
}
static GSList *find_service_with_profile(GSList *list, struct btd_profile *p)
{
GSList *l;
for (l = list; l != NULL; l = g_slist_next(l)) {
struct btd_service *service = l->data;
if (btd_service_get_profile(service) == p)
return l;
}
return NULL;
}
static GSList *find_service_with_state(GSList *list,
btd_service_state_t state)
{
GSList *l;
for (l = list; l != NULL; l = g_slist_next(l)) {
struct btd_service *service = l->data;
if (btd_service_get_state(service) == state)
return l;
}
return NULL;
}
static void update_technologies(GKeyFile *file, struct btd_device *dev)
{
const char *list[2];
size_t len = 0;
if (dev->bredr)
list[len++] = "BR/EDR";
if (dev->le) {
const char *type;
if (dev->bdaddr_type == BDADDR_LE_PUBLIC)
type = "public";
else
type = "static";
g_key_file_set_string(file, "General", "AddressType", type);
list[len++] = "LE";
}
g_key_file_set_string_list(file, "General", "SupportedTechnologies",
list, len);
}
static gboolean store_device_info_cb(gpointer user_data)
{
struct btd_device *device = user_data;
GKeyFile *key_file;
char filename[PATH_MAX + 1];
char adapter_addr[18];
char device_addr[18];
char *str;
char class[9];
char **uuids = NULL;
gsize length = 0;
device->store_id = 0;
ba2str(btd_adapter_get_address(device->adapter), adapter_addr);
ba2str(&device->bdaddr, device_addr);
snprintf(filename, PATH_MAX, STORAGEDIR "/%s/%s/info", adapter_addr,
device_addr);
filename[PATH_MAX] = '\0';
key_file = g_key_file_new();
g_key_file_load_from_file(key_file, filename, 0, NULL);
g_key_file_set_string(key_file, "General", "Name", device->name);
if (device->alias != NULL)
g_key_file_set_string(key_file, "General", "Alias",
device->alias);
else
g_key_file_remove_key(key_file, "General", "Alias", NULL);
if (device->class) {
sprintf(class, "0x%6.6x", device->class);
g_key_file_set_string(key_file, "General", "Class", class);
} else {
g_key_file_remove_key(key_file, "General", "Class", NULL);
}
if (device->appearance) {
sprintf(class, "0x%4.4x", device->appearance);
g_key_file_set_string(key_file, "General", "Appearance", class);
} else {
g_key_file_remove_key(key_file, "General", "Appearance", NULL);
}
update_technologies(key_file, device);
g_key_file_set_boolean(key_file, "General", "Trusted",
device->trusted);
g_key_file_set_boolean(key_file, "General", "Blocked",
device->blocked);
if (device->uuids) {
GSList *l;
int i;
uuids = g_new0(char *, g_slist_length(device->uuids) + 1);
for (i = 0, l = device->uuids; l; l = g_slist_next(l), i++)
uuids[i] = l->data;
g_key_file_set_string_list(key_file, "General", "Services",
(const char **)uuids, i);
} else {
g_key_file_remove_key(key_file, "General", "Services", NULL);
}
if (device->vendor_src) {
g_key_file_set_integer(key_file, "DeviceID", "Source",
device->vendor_src);
g_key_file_set_integer(key_file, "DeviceID", "Vendor",
device->vendor);
g_key_file_set_integer(key_file, "DeviceID", "Product",
device->product);
g_key_file_set_integer(key_file, "DeviceID", "Version",
device->version);
} else {
g_key_file_remove_group(key_file, "DeviceID", NULL);
}
create_file(filename, S_IRUSR | S_IWUSR);
str = g_key_file_to_data(key_file, &length, NULL);
g_file_set_contents(filename, str, length, NULL);
g_free(str);
g_key_file_free(key_file);
g_free(uuids);
return FALSE;
}
static bool device_address_is_private(struct btd_device *dev)
{
if (dev->bdaddr_type != BDADDR_LE_RANDOM)
return false;
switch (dev->bdaddr.b[5] >> 6) {
case 0x00: /* Private non-resolvable */
case 0x01: /* Private resolvable */
return true;
default:
return false;
}
}
static void store_device_info(struct btd_device *device)
{
if (device->temporary || device->store_id > 0)
return;
if (device_address_is_private(device)) {
warn("Can't store info for private addressed device %s",
device->path);
return;
}
device->store_id = g_idle_add(store_device_info_cb, device);
}
void device_store_cached_name(struct btd_device *dev, const char *name)
{
char filename[PATH_MAX + 1];
char s_addr[18], d_addr[18];
GKeyFile *key_file;
char *data;
gsize length = 0;
if (device_address_is_private(dev)) {
warn("Can't store name for private addressed device %s",
dev->path);
return;
}
ba2str(btd_adapter_get_address(dev->adapter), s_addr);
ba2str(&dev->bdaddr, d_addr);
snprintf(filename, PATH_MAX, STORAGEDIR "/%s/cache/%s", s_addr, d_addr);
filename[PATH_MAX] = '\0';
create_file(filename, S_IRUSR | S_IWUSR);
key_file = g_key_file_new();
g_key_file_load_from_file(key_file, filename, 0, NULL);
g_key_file_set_string(key_file, "General", "Name", name);
data = g_key_file_to_data(key_file, &length, NULL);
g_file_set_contents(filename, data, length, NULL);
g_free(data);
g_key_file_free(key_file);
}
static void browse_request_free(struct browse_req *req)
{
if (req->listener_id)
g_dbus_remove_watch(dbus_conn, req->listener_id);
if (req->msg)
dbus_message_unref(req->msg);
g_slist_free_full(req->profiles_added, g_free);
if (req->records)
sdp_list_free(req->records, (sdp_free_func_t) sdp_record_free);
g_free(req);
}
static void attio_cleanup(struct btd_device *device)
{
if (device->attachid) {
attrib_channel_detach(device->attrib, device->attachid);
device->attachid = 0;
}
if (device->cleanup_id) {
g_source_remove(device->cleanup_id);
device->cleanup_id = 0;
}
if (device->att_io) {
g_io_channel_shutdown(device->att_io, FALSE, NULL);
g_io_channel_unref(device->att_io);
device->att_io = NULL;
}
if (device->attrib) {
GAttrib *attrib = device->attrib;
device->attrib = NULL;
g_attrib_cancel_all(attrib);
g_attrib_unref(attrib);
}
}
static void browse_request_cancel(struct browse_req *req)
{
struct btd_device *device = req->device;
struct btd_adapter *adapter = device->adapter;
bt_cancel_discovery(btd_adapter_get_address(adapter), &device->bdaddr);
attio_cleanup(device);
device->browse = NULL;
browse_request_free(req);
}
static void svc_dev_remove(gpointer user_data)
{
struct svc_callback *cb = user_data;
if (cb->idle_id > 0)
g_source_remove(cb->idle_id);
cb->func(cb->dev, -ENODEV, cb->user_data);
g_free(cb);
}
static void device_free(gpointer user_data)
{
struct btd_device *device = user_data;
g_slist_free_full(device->uuids, g_free);
g_slist_free_full(device->primaries, g_free);
g_slist_free_full(device->attios, g_free);
g_slist_free_full(device->attios_offline, g_free);
g_slist_free_full(device->svc_callbacks, svc_dev_remove);
attio_cleanup(device);
if (device->tmp_records)
sdp_list_free(device->tmp_records,
(sdp_free_func_t) sdp_record_free);
if (device->disconn_timer)
g_source_remove(device->disconn_timer);
if (device->discov_timer)
g_source_remove(device->discov_timer);
if (device->connect)
dbus_message_unref(device->connect);
if (device->disconnect)
dbus_message_unref(device->disconnect);
DBG("%p", device);
if (device->authr) {
if (device->authr->agent)
agent_unref(device->authr->agent);
g_free(device->authr->pincode);
g_free(device->authr);
}
if (device->eir_uuids)
g_slist_free_full(device->eir_uuids, g_free);
g_free(device->path);
g_free(device->alias);
free(device->modalias);
g_free(device);
}
bool device_is_paired(struct btd_device *device, uint8_t bdaddr_type)
{
struct bearer_state *state = get_state(device, bdaddr_type);
return state->paired;
}
bool device_is_bonded(struct btd_device *device, uint8_t bdaddr_type)
{
struct bearer_state *state = get_state(device, bdaddr_type);
return state->bonded;
}
gboolean device_is_trusted(struct btd_device *device)
{
return device->trusted;
}
static gboolean dev_property_get_address(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
char dstaddr[18];
const char *ptr = dstaddr;
ba2str(&device->bdaddr, dstaddr);
dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &ptr);
return TRUE;
}
static gboolean dev_property_get_name(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
const char *empty = "", *ptr;
ptr = device->name ?: empty;
dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &ptr);
return TRUE;
}
static gboolean dev_property_exists_name(const GDBusPropertyTable *property,
void *data)
{
struct btd_device *dev = data;
return device_name_known(dev);
}
static gboolean dev_property_get_alias(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
char dstaddr[18];
const char *ptr;
/* Alias (fallback to name or address) */
if (device->alias != NULL)
ptr = device->alias;
else if (strlen(device->name) > 0) {
ptr = device->name;
} else {
ba2str(&device->bdaddr, dstaddr);
g_strdelimit(dstaddr, ":", '-');
ptr = dstaddr;
}
dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &ptr);
return TRUE;
}
static void set_alias(GDBusPendingPropertySet id, const char *alias,
void *data)
{
struct btd_device *device = data;
/* No change */
if ((device->alias == NULL && g_str_equal(alias, "")) ||
g_strcmp0(device->alias, alias) == 0) {
g_dbus_pending_property_success(id);
return;
}
g_free(device->alias);
device->alias = g_str_equal(alias, "") ? NULL : g_strdup(alias);
store_device_info(device);
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Alias");
g_dbus_pending_property_success(id);
}
static void dev_property_set_alias(const GDBusPropertyTable *property,
DBusMessageIter *value,
GDBusPendingPropertySet id, void *data)
{
const char *alias;
if (dbus_message_iter_get_arg_type(value) != DBUS_TYPE_STRING) {
g_dbus_pending_property_error(id,
ERROR_INTERFACE ".InvalidArguments",
"Invalid arguments in method call");
return;
}
dbus_message_iter_get_basic(value, &alias);
set_alias(id, alias, data);
}
static gboolean dev_property_exists_class(const GDBusPropertyTable *property,
void *data)
{
struct btd_device *device = data;
return device->class != 0;
}
static gboolean dev_property_get_class(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
if (device->class == 0)
return FALSE;
dbus_message_iter_append_basic(iter, DBUS_TYPE_UINT32, &device->class);
return TRUE;
}
static gboolean get_appearance(const GDBusPropertyTable *property, void *data,
uint16_t *appearance)
{
struct btd_device *device = data;
if (dev_property_exists_class(property, data))
return FALSE;
if (device->appearance) {
*appearance = device->appearance;
return TRUE;
}
return FALSE;
}
static gboolean dev_property_exists_appearance(
const GDBusPropertyTable *property, void *data)
{
uint16_t appearance;
return get_appearance(property, data, &appearance);
}
static gboolean dev_property_get_appearance(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
uint16_t appearance;
if (!get_appearance(property, data, &appearance))
return FALSE;
dbus_message_iter_append_basic(iter, DBUS_TYPE_UINT16, &appearance);
return TRUE;
}
static const char *get_icon(const GDBusPropertyTable *property, void *data)
{
struct btd_device *device = data;
const char *icon = NULL;
uint16_t appearance;
if (device->class != 0)
icon = class_to_icon(device->class);
else if (get_appearance(property, data, &appearance))
icon = gap_appearance_to_icon(appearance);
return icon;
}
static gboolean dev_property_exists_icon(
const GDBusPropertyTable *property, void *data)
{
return get_icon(property, data) != NULL;
}
static gboolean dev_property_get_icon(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
const char *icon;
icon = get_icon(property, data);
if (icon == NULL)
return FALSE;
dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &icon);
return TRUE;
}
static gboolean dev_property_get_paired(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *dev = data;
dbus_bool_t val;
if (dev->bredr_state.paired || dev->le_state.paired)
val = TRUE;
else
val = FALSE;
dbus_message_iter_append_basic(iter, DBUS_TYPE_BOOLEAN, &val);
return TRUE;
}
static gboolean dev_property_get_legacy(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
dbus_bool_t val = device->legacy;
dbus_message_iter_append_basic(iter, DBUS_TYPE_BOOLEAN, &val);
return TRUE;
}
static gboolean dev_property_get_rssi(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *dev = data;
dbus_int16_t val = dev->rssi;
dbus_message_iter_append_basic(iter, DBUS_TYPE_INT16, &val);
return TRUE;
}
static gboolean dev_property_exists_rssi(const GDBusPropertyTable *property,
void *data)
{
struct btd_device *dev = data;
if (dev->rssi == 0)
return FALSE;
return TRUE;
}
static gboolean dev_property_get_trusted(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
gboolean val = device_is_trusted(device);
dbus_message_iter_append_basic(iter, DBUS_TYPE_BOOLEAN, &val);
return TRUE;
}
static void set_trust(GDBusPendingPropertySet id, gboolean value, void *data)
{
struct btd_device *device = data;
btd_device_set_trusted(device, value);
g_dbus_pending_property_success(id);
}
static void dev_property_set_trusted(const GDBusPropertyTable *property,
DBusMessageIter *value,
GDBusPendingPropertySet id, void *data)
{
dbus_bool_t b;
if (dbus_message_iter_get_arg_type(value) != DBUS_TYPE_BOOLEAN) {
g_dbus_pending_property_error(id,
ERROR_INTERFACE ".InvalidArguments",
"Invalid arguments in method call");
return;
}
dbus_message_iter_get_basic(value, &b);
set_trust(id, b, data);
}
static gboolean dev_property_get_blocked(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
dbus_message_iter_append_basic(iter, DBUS_TYPE_BOOLEAN,
&device->blocked);
return TRUE;
}
static void set_blocked(GDBusPendingPropertySet id, gboolean value, void *data)
{
struct btd_device *device = data;
int err;
if (value)
err = device_block(device, FALSE);
else
err = device_unblock(device, FALSE, FALSE);
switch (-err) {
case 0:
g_dbus_pending_property_success(id);
break;
case EINVAL:
g_dbus_pending_property_error(id, ERROR_INTERFACE ".Failed",
"Kernel lacks blacklist support");
break;
default:
g_dbus_pending_property_error(id, ERROR_INTERFACE ".Failed",
strerror(-err));
break;
}
}
static void dev_property_set_blocked(const GDBusPropertyTable *property,
DBusMessageIter *value,
GDBusPendingPropertySet id, void *data)
{
dbus_bool_t b;
if (dbus_message_iter_get_arg_type(value) != DBUS_TYPE_BOOLEAN) {
g_dbus_pending_property_error(id,
ERROR_INTERFACE ".InvalidArguments",
"Invalid arguments in method call");
return;
}
dbus_message_iter_get_basic(value, &b);
set_blocked(id, b, data);
}
static gboolean dev_property_get_connected(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *dev = data;
dbus_bool_t connected;
if (dev->bredr_state.connected || dev->le_state.connected)
connected = TRUE;
else
connected = FALSE;
dbus_message_iter_append_basic(iter, DBUS_TYPE_BOOLEAN, &connected);
return TRUE;
}
static gboolean dev_property_get_uuids(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *dev = data;
DBusMessageIter entry;
GSList *l;
dbus_message_iter_open_container(iter, DBUS_TYPE_ARRAY,
DBUS_TYPE_STRING_AS_STRING, &entry);
if (dev->bredr_state.svc_resolved || dev->le_state.svc_resolved)
l = dev->uuids;
else if (dev->eir_uuids)
l = dev->eir_uuids;
else
l = dev->uuids;
for (; l != NULL; l = l->next)
dbus_message_iter_append_basic(&entry, DBUS_TYPE_STRING,
&l->data);
dbus_message_iter_close_container(iter, &entry);
return TRUE;
}
static gboolean dev_property_get_modalias(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
if (!device->modalias)
return FALSE;
dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING,
&device->modalias);
return TRUE;
}
static gboolean dev_property_exists_modalias(const GDBusPropertyTable *property,
void *data)
{
struct btd_device *device = data;
return device->modalias ? TRUE : FALSE;
}
static gboolean dev_property_get_adapter(const GDBusPropertyTable *property,
DBusMessageIter *iter, void *data)
{
struct btd_device *device = data;
const char *str = adapter_get_path(device->adapter);
dbus_message_iter_append_basic(iter, DBUS_TYPE_OBJECT_PATH, &str);
return TRUE;
}
static gboolean disconnect_all(gpointer user_data)
{
struct btd_device *device = user_data;
device->disconn_timer = 0;
if (device->bredr_state.connected)
btd_adapter_disconnect_device(device->adapter, &device->bdaddr,
BDADDR_BREDR);
if (device->le_state.connected)
btd_adapter_disconnect_device(device->adapter, &device->bdaddr,
device->bdaddr_type);
return FALSE;
}
int device_block(struct btd_device *device, gboolean update_only)
{
int err = 0;
if (device->blocked)
return 0;
disconnect_all(device);
while (device->services != NULL) {
struct btd_service *service = device->services->data;
device->services = g_slist_remove(device->services, service);
service_remove(service);
}
if (!update_only) {
if (device->le)
err = btd_adapter_block_address(device->adapter,
&device->bdaddr,
device->bdaddr_type);
if (!err && device->bredr)
err = btd_adapter_block_address(device->adapter,
&device->bdaddr,
BDADDR_BREDR);
}
if (err < 0)
return err;
device->blocked = TRUE;
store_device_info(device);
btd_device_set_temporary(device, FALSE);
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Blocked");
return 0;
}
int device_unblock(struct btd_device *device, gboolean silent,
gboolean update_only)
{
int err = 0;
if (!device->blocked)
return 0;
if (!update_only)
err = btd_adapter_unblock_address(device->adapter,
&device->bdaddr, device->bdaddr_type);
if (err < 0)
return err;
device->blocked = FALSE;
store_device_info(device);
if (!silent) {
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Blocked");
device_probe_profiles(device, device->uuids);
}
return 0;
}
static void discover_services_req_exit(DBusConnection *conn, void *user_data)
{
struct browse_req *req = user_data;
DBG("DiscoverServices requestor exited");
browse_request_cancel(req);
}
static void bonding_request_cancel(struct bonding_req *bonding)
{
struct btd_device *device = bonding->device;
struct btd_adapter *adapter = device->adapter;
adapter_cancel_bonding(adapter, &device->bdaddr, device->bdaddr_type);
}
static void dev_disconn_service(gpointer a, gpointer b)
{
btd_service_disconnect(a);
}
void device_request_disconnect(struct btd_device *device, DBusMessage *msg)
{
if (device->bonding)
bonding_request_cancel(device->bonding);
if (device->browse)
browse_request_cancel(device->browse);
if (device->connect) {
DBusMessage *reply = btd_error_failed(device->connect,
"Cancelled");
g_dbus_send_message(dbus_conn, reply);
dbus_message_unref(device->connect);
device->connect = NULL;
}
if (btd_device_is_connected(device) && msg)
device->disconnects = g_slist_append(device->disconnects,
dbus_message_ref(msg));
if (device->disconn_timer)
return;
g_slist_foreach(device->services, dev_disconn_service, NULL);
g_slist_free(device->pending);
device->pending = NULL;
while (device->watches) {
struct btd_disconnect_data *data = device->watches->data;
if (data->watch)
/* temporary is set if device is going to be removed */
data->watch(device, device->temporary,
data->user_data);
/* Check if the watch has been removed by callback function */
if (!g_slist_find(device->watches, data))
continue;
device->watches = g_slist_remove(device->watches, data);
g_free(data);
}
if (!btd_device_is_connected(device)) {
if (msg)
g_dbus_send_reply(dbus_conn, msg, DBUS_TYPE_INVALID);
return;
}
device->disconn_timer = g_timeout_add_seconds(DISCONNECT_TIMER,
disconnect_all,
device);
}
static DBusMessage *dev_disconnect(DBusConnection *conn, DBusMessage *msg,
void *user_data)
{
struct btd_device *device = user_data;
/*
* Disable connections through passive scanning until
* Device1.Connect is called
*/
if (device->auto_connect)
device->disable_auto_connect = TRUE;
device_request_disconnect(device, msg);
return NULL;
}
static int connect_next(struct btd_device *dev)
{
struct btd_service *service;
int err = -ENOENT;
while (dev->pending) {
service = dev->pending->data;
if (btd_service_connect(service) == 0)
return 0;
dev->pending = g_slist_delete_link(dev->pending, dev->pending);
}
return err;
}
static void device_profile_connected(struct btd_device *dev,
struct btd_profile *profile, int err)
{
struct btd_service *pending;
GSList *l;
DBG("%s %s (%d)", profile->name, strerror(-err), -err);
if (!err)
btd_device_set_temporary(dev, FALSE);
if (dev->pending == NULL)
return;
if (!btd_device_is_connected(dev)) {
switch (-err) {
case EHOSTDOWN: /* page timeout */
case EHOSTUNREACH: /* adapter not powered */
case ECONNABORTED: /* adapter powered down */
goto done;
}
}
pending = dev->pending->data;
l = find_service_with_profile(dev->pending, profile);
if (l != NULL)
dev->pending = g_slist_delete_link(dev->pending, l);
/* Only continue connecting the next profile if it matches the first
* pending, otherwise it will trigger another connect to the same
* profile
*/
if (profile != btd_service_get_profile(pending))
return;
if (connect_next(dev) == 0)
return;
done:
g_slist_free(dev->pending);
dev->pending = NULL;
if (!dev->connect)
return;
if (!err && dbus_message_is_method_call(dev->connect, DEVICE_INTERFACE,
"Connect"))
dev->general_connect = TRUE;
DBG("returning response to %s", dbus_message_get_sender(dev->connect));
l = find_service_with_state(dev->services, BTD_SERVICE_STATE_CONNECTED);
if (err && l == NULL)
g_dbus_send_message(dbus_conn,
btd_error_failed(dev->connect, strerror(-err)));
else {
/* Start passive SDP discovery to update known services */
if (dev->bredr && !dev->svc_refreshed)
device_browse_sdp(dev, NULL);
g_dbus_send_reply(dbus_conn, dev->connect, DBUS_TYPE_INVALID);
}
dbus_message_unref(dev->connect);
dev->connect = NULL;
}
void device_add_eir_uuids(struct btd_device *dev, GSList *uuids)
{
GSList *l;
bool added = false;
if (dev->bredr_state.svc_resolved || dev->le_state.svc_resolved)
return;
for (l = uuids; l != NULL; l = l->next) {
const char *str = l->data;
if (g_slist_find_custom(dev->eir_uuids, str, bt_uuid_strcmp))
continue;
added = true;
dev->eir_uuids = g_slist_append(dev->eir_uuids, g_strdup(str));
}
if (added)
g_dbus_emit_property_changed(dbus_conn, dev->path,
DEVICE_INTERFACE, "UUIDs");
}
static struct btd_service *find_connectable_service(struct btd_device *dev,
const char *uuid)
{
GSList *l;
for (l = dev->services; l != NULL; l = g_slist_next(l)) {
struct btd_service *service = l->data;
struct btd_profile *p = btd_service_get_profile(service);
if (!p->connect || !p->remote_uuid)
continue;
if (strcasecmp(uuid, p->remote_uuid) == 0)
return service;
}
return NULL;
}
static int service_prio_cmp(gconstpointer a, gconstpointer b)
{
struct btd_profile *p1 = btd_service_get_profile(a);
struct btd_profile *p2 = btd_service_get_profile(b);
return p2->priority - p1->priority;
}
static GSList *create_pending_list(struct btd_device *dev, const char *uuid)
{
struct btd_service *service;
struct btd_profile *p;
GSList *l;
if (uuid) {
service = find_connectable_service(dev, uuid);
if (service)
return g_slist_prepend(dev->pending, service);
return dev->pending;
}
for (l = dev->services; l != NULL; l = g_slist_next(l)) {
service = l->data;
p = btd_service_get_profile(service);
if (!p->auto_connect)
continue;
if (g_slist_find(dev->pending, service))
continue;
if (btd_service_get_state(service) !=
BTD_SERVICE_STATE_DISCONNECTED)
continue;
dev->pending = g_slist_insert_sorted(dev->pending, service,
service_prio_cmp);
}
return dev->pending;
}
int btd_device_connect_services(struct btd_device *dev, GSList *services)
{
GSList *l;
if (dev->pending || dev->connect || dev->browse)
return -EBUSY;
if (!btd_adapter_get_powered(dev->adapter))
return -ENETDOWN;
if (!dev->bredr_state.svc_resolved)
return -ENOENT;
for (l = services; l; l = g_slist_next(l)) {
struct btd_service *service = l->data;
dev->pending = g_slist_append(dev->pending,
btd_service_ref(service));
}
return connect_next(dev);
}
static DBusMessage *connect_profiles(struct btd_device *dev, uint8_t bdaddr_type,
DBusMessage *msg, const char *uuid)
{
struct bearer_state *state = get_state(dev, bdaddr_type);
int err;
DBG("%s %s, client %s", dev->path, uuid ? uuid : "(all)",
dbus_message_get_sender(msg));
if (dev->pending || dev->connect || dev->browse)
return btd_error_in_progress(msg);
if (!btd_adapter_get_powered(dev->adapter))
return btd_error_not_ready(msg);
btd_device_set_temporary(dev, FALSE);
if (!state->svc_resolved)
goto resolve_services;
dev->pending = create_pending_list(dev, uuid);
if (!dev->pending) {
if (dev->svc_refreshed) {
if (find_service_with_state(dev->services,
BTD_SERVICE_STATE_CONNECTED))
return dbus_message_new_method_return(msg);
else
return btd_error_not_available(msg);
}
goto resolve_services;
}
err = connect_next(dev);
if (err < 0)
return btd_error_failed(msg, strerror(-err));
dev->connect = dbus_message_ref(msg);
return NULL;
resolve_services:
DBG("Resolving services for %s", dev->path);
if (bdaddr_type == BDADDR_BREDR)
err = device_browse_sdp(dev, msg);
else
err = device_browse_primary(dev, msg);
if (err < 0)
return btd_error_failed(msg, strerror(-err));
return NULL;
}
#define NVAL_TIME ((time_t) -1)
#define SEEN_TRESHHOLD 300
static uint8_t select_conn_bearer(struct btd_device *dev)
{
time_t bredr_last = NVAL_TIME, le_last = NVAL_TIME;
time_t current = time(NULL);
if (dev->bredr_seen) {
bredr_last = current - dev->bredr_seen;
if (bredr_last > SEEN_TRESHHOLD)
bredr_last = NVAL_TIME;
}
if (dev->le_seen) {
le_last = current - dev->le_seen;
if (le_last > SEEN_TRESHHOLD)
le_last = NVAL_TIME;
}
if (dev->bredr && (!dev->le || le_last == NVAL_TIME))
return BDADDR_BREDR;
if (dev->le && (!dev->bredr || bredr_last == NVAL_TIME))
return dev->bdaddr_type;
if (bredr_last < le_last)
return BDADDR_BREDR;
return dev->bdaddr_type;
}
static DBusMessage *dev_connect(DBusConnection *conn, DBusMessage *msg,
void *user_data)
{
struct btd_device *dev = user_data;
uint8_t bdaddr_type;
if (dev->bredr_state.connected)
bdaddr_type = dev->bdaddr_type;
else if (dev->le_state.connected && dev->bredr)
bdaddr_type = BDADDR_BREDR;
else
bdaddr_type = select_conn_bearer(dev);
if (bdaddr_type != BDADDR_BREDR) {
int err;
if (dev->le_state.connected)
return dbus_message_new_method_return(msg);
btd_device_set_temporary(dev, FALSE);
dev->disable_auto_connect = FALSE;
err = device_connect_le(dev);
if (err < 0)
return btd_error_failed(msg, strerror(-err));
dev->connect = dbus_message_ref(msg);
return NULL;
}
return connect_profiles(dev, bdaddr_type, msg, NULL);
}
static DBusMessage *connect_profile(DBusConnection *conn, DBusMessage *msg,
void *user_data)
{
struct btd_device *dev = user_data;
const char *pattern;
char *uuid;
DBusMessage *reply;
if (!dbus_message_get_args(msg, NULL, DBUS_TYPE_STRING, &pattern,
DBUS_TYPE_INVALID))
return btd_error_invalid_args(msg);
uuid = bt_name2string(pattern);
reply = connect_profiles(dev, BDADDR_BREDR, msg, uuid);
free(uuid);
return reply;
}
static void device_profile_disconnected(struct btd_device *dev,
struct btd_profile *profile, int err)
{
if (!dev->disconnect)
return;
if (err)
g_dbus_send_message(dbus_conn,
btd_error_failed(dev->disconnect,
strerror(-err)));
else
g_dbus_send_reply(dbus_conn, dev->disconnect,
DBUS_TYPE_INVALID);
dbus_message_unref(dev->disconnect);
dev->disconnect = NULL;
}
static DBusMessage *disconnect_profile(DBusConnection *conn, DBusMessage *msg,
void *user_data)
{
struct btd_device *dev = user_data;
struct btd_service *service;
const char *pattern;
char *uuid;
int err;
if (!dbus_message_get_args(msg, NULL, DBUS_TYPE_STRING, &pattern,
DBUS_TYPE_INVALID))
return btd_error_invalid_args(msg);
uuid = bt_name2string(pattern);
if (uuid == NULL)
return btd_error_invalid_args(msg);
service = find_connectable_service(dev, uuid);
free(uuid);
if (!service)
return btd_error_invalid_args(msg);
if (dev->disconnect)
return btd_error_in_progress(msg);
dev->disconnect = dbus_message_ref(msg);
err = btd_service_disconnect(service);
if (err == 0)
return NULL;
dbus_message_unref(dev->disconnect);
dev->disconnect = NULL;
if (err == -ENOTSUP)
return btd_error_not_supported(msg);
return btd_error_failed(msg, strerror(-err));
}
static void device_svc_resolved(struct btd_device *dev, uint8_t bdaddr_type,
int err)
{
struct bearer_state *state = get_state(dev, bdaddr_type);
DBusMessage *reply;
struct browse_req *req = dev->browse;
DBG("%s err %d", dev->path, err);
state->svc_resolved = true;
dev->browse = NULL;
/* Disconnection notification can happen before this function
* gets called, so don't set svc_refreshed for a disconnected
* device.
*/
if (state->connected)
dev->svc_refreshed = true;
g_slist_free_full(dev->eir_uuids, g_free);
dev->eir_uuids = NULL;
if (dev->pending_paired) {
g_dbus_emit_property_changed(dbus_conn, dev->path,
DEVICE_INTERFACE, "Paired");
dev->pending_paired = false;
}
while (dev->svc_callbacks) {
struct svc_callback *cb = dev->svc_callbacks->data;
if (cb->idle_id > 0)
g_source_remove(cb->idle_id);
cb->func(dev, err, cb->user_data);
dev->svc_callbacks = g_slist_delete_link(dev->svc_callbacks,
dev->svc_callbacks);
g_free(cb);
}
if (!dev->temporary)
store_device_info(dev);
if (!req || !req->msg)
return;
if (dbus_message_is_method_call(req->msg, DEVICE_INTERFACE,
"Pair")) {
g_dbus_send_reply(dbus_conn, req->msg, DBUS_TYPE_INVALID);
return;
}
if (err) {
reply = btd_error_failed(req->msg, strerror(-err));
g_dbus_send_message(dbus_conn, reply);
return;
}
if (dbus_message_is_method_call(req->msg, DEVICE_INTERFACE, "Connect"))
reply = dev_connect(dbus_conn, req->msg, dev);
else if (dbus_message_is_method_call(req->msg, DEVICE_INTERFACE,
"ConnectProfile"))
reply = connect_profile(dbus_conn, req->msg, dev);
else
return;
dbus_message_unref(req->msg);
req->msg = NULL;
if (reply)
g_dbus_send_message(dbus_conn, reply);
}
static struct bonding_req *bonding_request_new(DBusMessage *msg,
struct btd_device *device,
uint8_t bdaddr_type,
struct agent *agent)
{
struct bonding_req *bonding;
char addr[18];
ba2str(&device->bdaddr, addr);
DBG("Requesting bonding for %s", addr);
bonding = g_new0(struct bonding_req, 1);
bonding->msg = dbus_message_ref(msg);
bonding->bdaddr_type = bdaddr_type;
bonding->cb_iter = btd_adapter_pin_cb_iter_new(device->adapter);
/* Marks the bonding start time for the first attempt on request
* construction. The following attempts will be updated on
* device_bonding_retry. */
clock_gettime(CLOCK_MONOTONIC, &bonding->attempt_start_time);
if (agent)
bonding->agent = agent_ref(agent);
return bonding;
}
void device_bonding_restart_timer(struct btd_device *device)
{
if (!device || !device->bonding)
return;
clock_gettime(CLOCK_MONOTONIC, &device->bonding->attempt_start_time);
}
static void bonding_request_stop_timer(struct bonding_req *bonding)
{
struct timespec current;
clock_gettime(CLOCK_MONOTONIC, &current);
/* Compute the time difference in ms. */
bonding->last_attempt_duration_ms =
(current.tv_sec - bonding->attempt_start_time.tv_sec) * 1000L +
(current.tv_nsec - bonding->attempt_start_time.tv_nsec)
/ 1000000L;
}
/* Returns the duration of the last bonding attempt in milliseconds. The
* duration is measured starting from the latest of the following three
* events and finishing when the Command complete event is received for the
* authentication request:
* - MGMT_OP_PAIR_DEVICE is sent,
* - MGMT_OP_PIN_CODE_REPLY is sent and
* - Command complete event is received for the sent MGMT_OP_PIN_CODE_REPLY.
*/
long device_bonding_last_duration(struct btd_device *device)
{
struct bonding_req *bonding = device->bonding;
if (!bonding)
return 0;
return bonding->last_attempt_duration_ms;
}
static void create_bond_req_exit(DBusConnection *conn, void *user_data)
{
struct btd_device *device = user_data;
char addr[18];
ba2str(&device->bdaddr, addr);
DBG("%s: requestor exited before bonding was completed", addr);
if (device->authr)
device_cancel_authentication(device, FALSE);
if (device->bonding) {
device->bonding->listener_id = 0;
device_request_disconnect(device, NULL);
}
}
static DBusMessage *pair_device(DBusConnection *conn, DBusMessage *msg,
void *data)
{
struct btd_device *device = data;
struct btd_adapter *adapter = device->adapter;
struct bearer_state *state;
uint8_t bdaddr_type;
const char *sender;
struct agent *agent;
struct bonding_req *bonding;
uint8_t io_cap;
int err;
btd_device_set_temporary(device, FALSE);
if (!dbus_message_get_args(msg, NULL, DBUS_TYPE_INVALID))
return btd_error_invalid_args(msg);
if (device->bonding)
return btd_error_in_progress(msg);
if (device->bredr_state.bonded)
bdaddr_type = device->bdaddr_type;
else if (device->le_state.bonded)
bdaddr_type = BDADDR_BREDR;
else
bdaddr_type = select_conn_bearer(device);
state = get_state(device, bdaddr_type);
if (state->bonded)
return btd_error_already_exists(msg);
sender = dbus_message_get_sender(msg);
agent = agent_get(sender);
if (agent)
io_cap = agent_get_io_capability(agent);
else
io_cap = IO_CAPABILITY_NOINPUTNOOUTPUT;
bonding = bonding_request_new(msg, device, bdaddr_type, agent);
if (agent)
agent_unref(agent);
bonding->listener_id = g_dbus_add_disconnect_watch(dbus_conn,
sender, create_bond_req_exit,
device, NULL);
device->bonding = bonding;
bonding->device = device;
/* Due to a bug in the kernel we might loose out on ATT commands
* that arrive during the SMP procedure, so connect the ATT
* channel first and only then start pairing (there's code for
* this in the ATT connect callback)
*/
if (bdaddr_type != BDADDR_BREDR) {
if (!state->connected)
err = device_connect_le(device);
else
err = adapter_create_bonding(adapter, &device->bdaddr,
device->bdaddr_type,
io_cap);
} else {
err = adapter_create_bonding(adapter, &device->bdaddr,
BDADDR_BREDR, io_cap);
}
if (err < 0)
return btd_error_failed(msg, strerror(-err));
return NULL;
}
static DBusMessage *new_authentication_return(DBusMessage *msg, uint8_t status)
{
switch (status) {
case MGMT_STATUS_SUCCESS:
return dbus_message_new_method_return(msg);
case MGMT_STATUS_CONNECT_FAILED:
return dbus_message_new_error(msg,
ERROR_INTERFACE ".ConnectionAttemptFailed",
"Page Timeout");
case MGMT_STATUS_TIMEOUT:
return dbus_message_new_error(msg,
ERROR_INTERFACE ".AuthenticationTimeout",
"Authentication Timeout");
case MGMT_STATUS_BUSY:
case MGMT_STATUS_REJECTED:
return dbus_message_new_error(msg,
ERROR_INTERFACE ".AuthenticationRejected",
"Authentication Rejected");
case MGMT_STATUS_CANCELLED:
case MGMT_STATUS_NO_RESOURCES:
case MGMT_STATUS_DISCONNECTED:
return dbus_message_new_error(msg,
ERROR_INTERFACE ".AuthenticationCanceled",
"Authentication Canceled");
default:
return dbus_message_new_error(msg,
ERROR_INTERFACE ".AuthenticationFailed",
"Authentication Failed");
}
}
static void bonding_request_free(struct bonding_req *bonding)
{
if (!bonding)
return;
if (bonding->listener_id)
g_dbus_remove_watch(dbus_conn, bonding->listener_id);
if (bonding->msg)
dbus_message_unref(bonding->msg);
if (bonding->cb_iter)
g_free(bonding->cb_iter);
if (bonding->agent) {
agent_unref(bonding->agent);
bonding->agent = NULL;
}
if (bonding->retry_timer)
g_source_remove(bonding->retry_timer);
if (bonding->device)
bonding->device->bonding = NULL;
g_free(bonding);
}
static void device_cancel_bonding(struct btd_device *device, uint8_t status)
{
struct bonding_req *bonding = device->bonding;
DBusMessage *reply;
char addr[18];
if (!bonding)
return;
ba2str(&device->bdaddr, addr);
DBG("Canceling bonding request for %s", addr);
if (device->authr)
device_cancel_authentication(device, FALSE);
reply = new_authentication_return(bonding->msg, status);
g_dbus_send_message(dbus_conn, reply);
bonding_request_cancel(bonding);
bonding_request_free(bonding);
}
static DBusMessage *cancel_pairing(DBusConnection *conn, DBusMessage *msg,
void *data)
{
struct btd_device *device = data;
struct bonding_req *req = device->bonding;
DBG("");
if (!req)
return btd_error_does_not_exist(msg);
device_cancel_bonding(device, MGMT_STATUS_CANCELLED);
return dbus_message_new_method_return(msg);
}
static const GDBusMethodTable device_methods[] = {
{ GDBUS_ASYNC_METHOD("Disconnect", NULL, NULL, dev_disconnect) },
{ GDBUS_ASYNC_METHOD("Connect", NULL, NULL, dev_connect) },
{ GDBUS_ASYNC_METHOD("ConnectProfile", GDBUS_ARGS({ "UUID", "s" }),
NULL, connect_profile) },
{ GDBUS_ASYNC_METHOD("DisconnectProfile", GDBUS_ARGS({ "UUID", "s" }),
NULL, disconnect_profile) },
{ GDBUS_ASYNC_METHOD("Pair", NULL, NULL, pair_device) },
{ GDBUS_METHOD("CancelPairing", NULL, NULL, cancel_pairing) },
{ }
};
static const GDBusPropertyTable device_properties[] = {
{ "Address", "s", dev_property_get_address },
{ "Name", "s", dev_property_get_name, NULL, dev_property_exists_name },
{ "Alias", "s", dev_property_get_alias, dev_property_set_alias },
{ "Class", "u", dev_property_get_class, NULL,
dev_property_exists_class },
{ "Appearance", "q", dev_property_get_appearance, NULL,
dev_property_exists_appearance },
{ "Icon", "s", dev_property_get_icon, NULL,
dev_property_exists_icon },
{ "Paired", "b", dev_property_get_paired },
{ "Trusted", "b", dev_property_get_trusted, dev_property_set_trusted },
{ "Blocked", "b", dev_property_get_blocked, dev_property_set_blocked },
{ "LegacyPairing", "b", dev_property_get_legacy },
{ "RSSI", "n", dev_property_get_rssi, NULL, dev_property_exists_rssi },
{ "Connected", "b", dev_property_get_connected },
{ "UUIDs", "as", dev_property_get_uuids },
{ "Modalias", "s", dev_property_get_modalias, NULL,
dev_property_exists_modalias },
{ "Adapter", "o", dev_property_get_adapter },
{ }
};
uint8_t btd_device_get_bdaddr_type(struct btd_device *dev)
{
return dev->bdaddr_type;
}
bool btd_device_is_connected(struct btd_device *dev)
{
return dev->bredr_state.connected || dev->le_state.connected;
}
void device_add_connection(struct btd_device *dev, uint8_t bdaddr_type)
{
struct bearer_state *state = get_state(dev, bdaddr_type);
device_update_last_seen(dev, bdaddr_type);
if (state->connected) {
char addr[18];
ba2str(&dev->bdaddr, addr);
error("Device %s is already connected", addr);
return;
}
/* If this is the first connection over this bearer */
if (bdaddr_type == BDADDR_BREDR)
device_set_bredr_support(dev);
else
device_set_le_support(dev, bdaddr_type);
state->connected = true;
if (dev->le_state.connected && dev->bredr_state.connected)
return;
g_dbus_emit_property_changed(dbus_conn, dev->path, DEVICE_INTERFACE,
"Connected");
}
void device_remove_connection(struct btd_device *device, uint8_t bdaddr_type)
{
struct bearer_state *state = get_state(device, bdaddr_type);
if (!state->connected)
return;
state->connected = false;
device->svc_refreshed = false;
device->general_connect = FALSE;
if (device->disconn_timer > 0) {
g_source_remove(device->disconn_timer);
device->disconn_timer = 0;
}
while (device->disconnects) {
DBusMessage *msg = device->disconnects->data;
g_dbus_send_reply(dbus_conn, msg, DBUS_TYPE_INVALID);
device->disconnects = g_slist_remove(device->disconnects, msg);
dbus_message_unref(msg);
}
if (state->paired && !state->bonded)
btd_adapter_remove_bonding(device->adapter, &device->bdaddr,
bdaddr_type);
if (device->bredr_state.connected || device->le_state.connected)
return;
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Connected");
}
guint device_add_disconnect_watch(struct btd_device *device,
disconnect_watch watch, void *user_data,
GDestroyNotify destroy)
{
struct btd_disconnect_data *data;
static guint id = 0;
data = g_new0(struct btd_disconnect_data, 1);
data->id = ++id;
data->watch = watch;
data->user_data = user_data;
data->destroy = destroy;
device->watches = g_slist_append(device->watches, data);
return data->id;
}
void device_remove_disconnect_watch(struct btd_device *device, guint id)
{
GSList *l;
for (l = device->watches; l; l = l->next) {
struct btd_disconnect_data *data = l->data;
if (data->id == id) {
device->watches = g_slist_remove(device->watches,
data);
if (data->destroy)
data->destroy(data->user_data);
g_free(data);
return;
}
}
}
static char *load_cached_name(struct btd_device *device, const char *local,
const char *peer)
{
char filename[PATH_MAX + 1];
GKeyFile *key_file;
char *str = NULL;
int len;
snprintf(filename, PATH_MAX, STORAGEDIR "/%s/cache/%s", local, peer);
filename[PATH_MAX] = '\0';
key_file = g_key_file_new();
if (!g_key_file_load_from_file(key_file, filename, 0, NULL))
goto failed;
str = g_key_file_get_string(key_file, "General", "Name", NULL);
if (str) {
len = strlen(str);
if (len > HCI_MAX_NAME_LENGTH)
str[HCI_MAX_NAME_LENGTH] = '\0';
}
failed:
g_key_file_free(key_file);
return str;
}
static void load_info(struct btd_device *device, const char *local,
const char *peer, GKeyFile *key_file)
{
char *str;
gboolean store_needed = FALSE;
gboolean blocked;
char **uuids;
int source, vendor, product, version;
char **techno, **t;
/* Load device name from storage info file, if that fails fall back to
* the cache.
*/
str = g_key_file_get_string(key_file, "General", "Name", NULL);
if (str == NULL) {
str = load_cached_name(device, local, peer);
if (str)
store_needed = TRUE;
}
if (str) {
strcpy(device->name, str);
g_free(str);
}
/* Load alias */
device->alias = g_key_file_get_string(key_file, "General", "Alias",
NULL);
/* Load class */
str = g_key_file_get_string(key_file, "General", "Class", NULL);
if (str) {
uint32_t class;
if (sscanf(str, "%x", &class) == 1)
device->class = class;
g_free(str);
}
/* Load appearance */
str = g_key_file_get_string(key_file, "General", "Appearance", NULL);
if (str) {
device->appearance = strtol(str, NULL, 16);
g_free(str);
}
/* Load device technology */
techno = g_key_file_get_string_list(key_file, "General",
"SupportedTechnologies", NULL, NULL);
if (!techno)
goto next;
for (t = techno; *t; t++) {
if (g_str_equal(*t, "BR/EDR"))
device->bredr = true;
else if (g_str_equal(*t, "LE"))
device->le = true;
else
error("Unknown device technology");
}
if (!device->le) {
device->bdaddr_type = BDADDR_BREDR;
} else {
str = g_key_file_get_string(key_file, "General",
"AddressType", NULL);
if (str && g_str_equal(str, "public"))
device->bdaddr_type = BDADDR_LE_PUBLIC;
else if (str && g_str_equal(str, "static"))
device->bdaddr_type = BDADDR_LE_RANDOM;
else
error("Unknown LE device technology");
g_free(str);
}
g_strfreev(techno);
next:
/* Load trust */
device->trusted = g_key_file_get_boolean(key_file, "General",
"Trusted", NULL);
/* Load device blocked */
blocked = g_key_file_get_boolean(key_file, "General", "Blocked", NULL);
if (blocked)
device_block(device, FALSE);
/* Load device profile list */
uuids = g_key_file_get_string_list(key_file, "General", "Services",
NULL, NULL);
if (uuids) {
char **uuid;
for (uuid = uuids; *uuid; uuid++) {
GSList *match;
match = g_slist_find_custom(device->uuids, *uuid,
bt_uuid_strcmp);
if (match)
continue;
device->uuids = g_slist_insert_sorted(device->uuids,
g_strdup(*uuid),
bt_uuid_strcmp);
}
g_strfreev(uuids);
/* Discovered services restored from storage */
device->bredr_state.svc_resolved = true;
}
/* Load device id */
source = g_key_file_get_integer(key_file, "DeviceID", "Source", NULL);
if (source) {
vendor = g_key_file_get_integer(key_file, "DeviceID",
"Vendor", NULL);
product = g_key_file_get_integer(key_file, "DeviceID",
"Product", NULL);
version = g_key_file_get_integer(key_file, "DeviceID",
"Version", NULL);
btd_device_set_pnpid(device, source, vendor, product, version);
}
if (store_needed)
store_device_info(device);
}
static void load_att_info(struct btd_device *device, const char *local,
const char *peer)
{
char filename[PATH_MAX + 1];
GKeyFile *key_file;
char *prim_uuid, *str;
char **groups, **handle, *service_uuid;
struct gatt_primary *prim;
uuid_t uuid;
char tmp[3];
int i;
sdp_uuid16_create(&uuid, GATT_PRIM_SVC_UUID);
prim_uuid = bt_uuid2string(&uuid);
snprintf(filename, PATH_MAX, STORAGEDIR "/%s/%s/attributes", local,
peer);
filename[PATH_MAX] = '\0';
key_file = g_key_file_new();
g_key_file_load_from_file(key_file, filename, 0, NULL);
groups = g_key_file_get_groups(key_file, NULL);
for (handle = groups; *handle; handle++) {
gboolean uuid_ok;
int end;
str = g_key_file_get_string(key_file, *handle, "UUID", NULL);
if (!str)
continue;
uuid_ok = g_str_equal(str, prim_uuid);
g_free(str);
if (!uuid_ok)
continue;
str = g_key_file_get_string(key_file, *handle, "Value", NULL);
if (!str)
continue;
end = g_key_file_get_integer(key_file, *handle,
"EndGroupHandle", NULL);
if (end == 0) {
g_free(str);
continue;
}
prim = g_new0(struct gatt_primary, 1);
prim->range.start = atoi(*handle);
prim->range.end = end;
switch (strlen(str)) {
case 4:
uuid.type = SDP_UUID16;
sscanf(str, "%04hx", &uuid.value.uuid16);
break;
case 8:
uuid.type = SDP_UUID32;
sscanf(str, "%08x", &uuid.value.uuid32);
break;
case 32:
uuid.type = SDP_UUID128;
memset(tmp, 0, sizeof(tmp));
for (i = 0; i < 16; i++) {
memcpy(tmp, str + (i * 2), 2);
uuid.value.uuid128.data[i] =
(uint8_t) strtol(tmp, NULL, 16);
}
break;
default:
g_free(str);
g_free(prim);
continue;
}
service_uuid = bt_uuid2string(&uuid);
memcpy(prim->uuid, service_uuid, MAX_LEN_UUID_STR);
free(service_uuid);
g_free(str);
device->primaries = g_slist_append(device->primaries, prim);
}
g_strfreev(groups);
g_key_file_free(key_file);
free(prim_uuid);
}
static struct btd_device *device_new(struct btd_adapter *adapter,
const char *address)
{
char *address_up;
struct btd_device *device;
const char *adapter_path = adapter_get_path(adapter);
DBG("address %s", address);
device = g_try_malloc0(sizeof(struct btd_device));
if (device == NULL)
return NULL;
address_up = g_ascii_strup(address, -1);
device->path = g_strdup_printf("%s/dev_%s", adapter_path, address_up);
g_strdelimit(device->path, ":", '_');
g_free(address_up);
DBG("Creating device %s", device->path);
if (g_dbus_register_interface(dbus_conn,
device->path, DEVICE_INTERFACE,
device_methods, NULL,
device_properties, device,
device_free) == FALSE) {
error("Unable to register device interface for %s", address);
device_free(device);
return NULL;
}
str2ba(address, &device->bdaddr);
device->adapter = adapter;
return btd_device_ref(device);
}
struct btd_device *device_create_from_storage(struct btd_adapter *adapter,
const char *address, GKeyFile *key_file)
{
struct btd_device *device;
const bdaddr_t *src;
char srcaddr[18];
DBG("address %s", address);
device = device_new(adapter, address);
if (device == NULL)
return NULL;
src = btd_adapter_get_address(adapter);
ba2str(src, srcaddr);
load_info(device, srcaddr, address, key_file);
load_att_info(device, srcaddr, address);
return device;
}
struct btd_device *device_create(struct btd_adapter *adapter,
const bdaddr_t *bdaddr, uint8_t bdaddr_type)
{
struct btd_device *device;
const bdaddr_t *sba;
char src[18], dst[18];
char *str;
ba2str(bdaddr, dst);
DBG("dst %s", dst);
device = device_new(adapter, dst);
if (device == NULL)
return NULL;
device->bdaddr_type = bdaddr_type;
if (bdaddr_type == BDADDR_BREDR)
device->bredr = true;
else
device->le = true;
sba = btd_adapter_get_address(adapter);
ba2str(sba, src);
str = load_cached_name(device, src, dst);
if (str) {
strcpy(device->name, str);
g_free(str);
}
return device;
}
char *btd_device_get_storage_path(struct btd_device *device,
const char *filename)
{
char srcaddr[18], dstaddr[18];
if (device_address_is_private(device)) {
warn("Refusing storage path for private addressed device %s",
device->path);
return NULL;
}
ba2str(btd_adapter_get_address(device->adapter), srcaddr);
ba2str(&device->bdaddr, dstaddr);
if (!filename)
return g_strdup_printf(STORAGEDIR "/%s/%s", srcaddr, dstaddr);
return g_strdup_printf(STORAGEDIR "/%s/%s/%s", srcaddr, dstaddr,
filename);
}
void btd_device_device_set_name(struct btd_device *device, const char *name)
{
if (strncmp(name, device->name, MAX_NAME_LENGTH) == 0)
return;
DBG("%s %s", device->path, name);
strncpy(device->name, name, MAX_NAME_LENGTH);
store_device_info(device);
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Name");
if (device->alias != NULL)
return;
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Alias");
}
void device_get_name(struct btd_device *device, char *name, size_t len)
{
if (name != NULL && len > 0) {
strncpy(name, device->name, len - 1);
name[len - 1] = '\0';
}
}
bool device_name_known(struct btd_device *device)
{
return device->name[0] != '\0';
}
void device_set_class(struct btd_device *device, uint32_t class)
{
if (device->class == class)
return;
DBG("%s 0x%06X", device->path, class);
device->class = class;
store_device_info(device);
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Class");
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Icon");
}
void device_update_addr(struct btd_device *device, const bdaddr_t *bdaddr,
uint8_t bdaddr_type)
{
if (!bacmp(bdaddr, &device->bdaddr) &&
bdaddr_type == device->bdaddr_type)
return;
/* Since this function is only used for LE SMP Identity
* Resolving purposes we can now assume LE is supported.
*/
device->le = true;
bacpy(&device->bdaddr, bdaddr);
device->bdaddr_type = bdaddr_type;
store_device_info(device);
g_dbus_emit_property_changed(dbus_conn, device->path,
DEVICE_INTERFACE, "Address");
}
void device_set_bredr_support(struct btd_device *device)
{
if (device->bredr)
return;
device->bredr = true;
store_device_info(device);
}
void device_set_le_support(struct btd_device *device, uint8_t bdaddr_type)
{
if (device->le)
return;
device->le = true;
device->bdaddr_type = bdaddr_type;
store_device_info(device);
}
void device_update_last_seen(struct btd_device *device, uint8_t bdaddr_type)
{
if (bdaddr_type == BDADDR_BREDR)
device->bredr_seen = time(NULL);
else
device->le_seen = time(NULL);
}
/* It is possible that we have two device objects for the same device in
* case it has first been discovered over BR/EDR and has a private
* address when discovered over LE for the first time. In such a case we
* need to inherit critical values from the duplicate so that we don't
* ovewrite them when writing to storage. The next time bluetoothd
* starts the device will show up as a single instance.
*/
void device_merge_duplicate(struct btd_device *dev, struct btd_device *dup)
{
GSList *l;
DBG("");
dev->bredr = dup->bredr;
dev->trusted = dup->trusted;
dev->blocked = dup->blocked;
for (l = dup->uuids; l; l = g_slist_next(l))
dev->uuids = g_slist_append(dev->uuids, g_strdup(l->data));
if (dev->name[0] == '\0')
strcpy(dev->name, dup->name);
if (!dev->alias)
dev->alias = g_strdup(dup->alias);
dev->class = dup->class;
dev->vendor_src = dup->vendor_src;
dev->vendor = dup->vendor;
dev->product = dup->product;
dev->version = dup->version;
}
uint32_t btd_device_get_class(struct btd_device *device)
{
return device->class;
}
uint16_t btd_device_get_vendor(struct btd_device *device)
{
return device->vendor;
}
uint16_t btd_device_get_vendor_src(struct btd_device *device)
{
return device->vendor_src;
}
uint16_t btd_device_get_product(struct btd_device *device)
{
return device->product;
}
uint16_t btd_device_get_version(struct btd_device *device)
{
return device->version;
}
static void delete_folder_tree(const char *dirname)
{
DIR *dir;
struct dirent *entry;
char filename[PATH_MAX + 1];
dir = opendir(dirname);
if (dir == NULL)
return;
while ((entry = readdir(dir)) != NULL) {
if (g_str_equal(entry->d_name, ".") ||
g_str_equal(entry->d_name, ".."))
continue;
snprintf(filename, PATH_MAX, "%s/%s", dirname, entry->d_name);
filename[PATH_MAX] = '\0';
if (entry->d_type == DT_DIR)
delete_folder_tree(filename);
else
unlink(filename);
}
closedir(dir);
rmdir(dirname);
}
static void device_remove_stored(struct btd_device *device)
{
const bdaddr_t *src = btd_adapter_get_address(device->adapter);
char adapter_addr[18];
char device_addr[18];
char filename[PATH_MAX + 1];
GKeyFile *key_file;
char *data;
gsize length = 0;
if (device->bredr_state.bonded) {
device->bredr_state.bonded = false;
btd_adapter_remove_bonding(device->adapter, &device->bdaddr,
BDADDR_BREDR);
}
if (device->le_state.bonded) {
device->le_state.bonded = false;
btd_adapter_remove_bonding(device->adapter, &device->bdaddr,
device->bdaddr_type);
}
device->bredr_state.paired = false;
device->le_state.paired = false;
if (device->blocked)
device_unblock(device, TRUE, FALSE);
ba2str(src, adapter_addr);
ba2str(&device->bdaddr, device_addr);
snprintf(filename, PATH_MAX, STORAGEDIR "/%s/%s", adapter_addr,
device_addr);
filename[PATH_MAX] = '\0';
delete_folder_tree(filename);
snprintf(filename, PATH_MAX, STORAGEDIR "/%s/cache/%s", adapter_addr,
device_addr);
filename[PATH_MAX] = '\0';
key_file = g_key_file_new();
g_key_file_load_from_file(key_file, filename, 0, NULL);
g_key_file_remove_group(key_file, "ServiceRecords", NULL);
data = g_key_file_to_data(key_file, &length, NULL);
if (length > 0) {
create_file(filename, S_IRUSR | S_IWUSR);
g_file_set_contents(filename, data, length, NULL);
}
g_free(data);
g_key_file_free(key_file);
}
void device_remove(struct btd_device *device, gboolean remove_stored)
{
DBG("Removing device %s", device->path);
if (device->bonding) {
uint8_t status;
if (device->bredr_state.connected)
status = MGMT_STATUS_DISCONNECTED;
else
status = MGMT_STATUS_CONNECT_FAILED;
device_cancel_bonding(device, status);
}
if (device->browse)
browse_request_cancel(device->browse);
while (device->services != NULL) {
struct btd_service *service = device->services->data;
device->services = g_slist_remove(device->services, service);
service_remove(service);
}
g_slist_free(device->pending);
device->pending = NULL;
if (btd_device_is_connected(device))
disconnect_all(device);
if (device->store_id > 0) {
g_source_remove(device->store_id);
device->store_id = 0;
if (!remove_stored)
store_device_info_cb(device);
}
if (remove_stored)
device_remove_stored(device);
btd_device_unref(device);
}
int device_address_cmp(gconstpointer a, gconstpointer b)
{
const struct btd_device *device = a;
const char *address = b;
char addr[18];
ba2str(&device->bdaddr, addr);
return strcasecmp(addr, address);
}
int device_bdaddr_cmp(gconstpointer a, gconstpointer b)
{
const struct btd_device *device = a;
const bdaddr_t *bdaddr = b;
return bacmp(&device->bdaddr, bdaddr);
}
static bool addr_is_public(uint8_t addr_type)
{
if (addr_type == BDADDR_BREDR || addr_type == BDADDR_LE_PUBLIC)
return true;
return false;
}
int device_addr_type_cmp(gconstpointer a, gconstpointer b)
{
const struct btd_device *dev = a;
const struct device_addr_type *addr = b;
int cmp;
cmp = bacmp(&dev->bdaddr, &addr->bdaddr);
/*
* Address matches and both old and new are public addresses
* (doesn't matter whether LE or BR/EDR, then consider this a
* match.
*/
if (!cmp && addr_is_public(addr->bdaddr_type) &&
addr_is_public(dev->bdaddr_type))
return 0;
if (addr->bdaddr_type == BDADDR_BREDR) {
if (!dev->bredr)
return -1;
return cmp;
}
if (!dev->le)
return -1;
if (addr->bdaddr_type != dev->bdaddr_type)
return -1;
return cmp;
}
static gboolean record_has_uuid(const sdp_record_t *rec,
const char *profile_uuid)
{
sdp_list_t *pat;
for (pat = rec->pattern; pat != NULL; pat = pat->next) {
char *uuid;
int ret;
uuid = bt_uuid2string(pat->data);
if (!uuid)
continue;
ret = strcasecmp(uuid, profile_uuid);
free(uuid);
if (ret == 0)
return TRUE;
}
return FALSE;
}
GSList *btd_device_get_uuids(struct btd_device *device)
{
return device->uuids;
}
static bool device_match_profile(struct btd_device *device,
struct btd_profile *profile,
GSList *uuids)
{
if (profile->remote_uuid == NULL)
return false;
if (g_slist_find_custom(uuids, profile->remote_uuid,
bt_uuid_strcmp) == NULL)
return false;
return true;
}
struct probe_data {
struct btd_device *dev;
GSList *uuids;
};
static void dev_probe(struct btd_profile *p, void *user_data)
{
struct probe_data *d = user_data;
struct btd_service *service;
if (p->device_probe == NULL)
return;
if (!device_match_profile(d->dev, p, d->uuids))
return;
service = service_create(d->dev, p);
if (service_probe(service) < 0) {
btd_service_unref(service);
return;
}
d->dev->services = g_slist_append(d->dev->services, service);
}