diff --git a/src/adapter.c b/src/adapter.c
index 41f706a..7550eb2 100644
--- a/src/adapter.c
+++ b/src/adapter.c
DBG("%s", address);
- device = device_create(conn, adapter, address, bdaddr_type);
+ device = device_create(adapter, address, bdaddr_type);
if (!device)
return NULL;
goto failed;
if (device_is_bredr(device))
- err = device_browse_sdp(device, conn, msg, NULL, FALSE);
+ err = device_browse_sdp(device, msg, NULL, FALSE);
else
- err = device_browse_primary(device, conn, msg, FALSE);
+ err = device_browse_primary(device, msg, FALSE);
if (err < 0) {
adapter_remove_device(conn, adapter, device, TRUE);
return btd_error_failed(msg, strerror(-err));
}
- return device_create_bonding(device, conn, msg, agent_path, cap);
+ return device_create_bonding(device, msg, agent_path, cap);
}
static gint device_path_cmp(struct btd_device *device, const gchar *path)
address, (GCompareFunc) device_address_cmp))
return;
- device = device_create(connection, adapter, address, bdaddr_type);
+ device = device_create(adapter, address, bdaddr_type);
if (!device)
return;
list = device_services_from_record(device, uuids);
if (list)
- device_register_services(connection, device, list, ATT_PSM);
+ device_register_services(device, list, ATT_PSM);
device_probe_profiles(device, uuids);
(GCompareFunc) device_address_cmp))
return;
- device = device_create(connection, adapter, address, bdaddr_type);
+ device = device_create(adapter, address, bdaddr_type);
if (device) {
device_set_temporary(device, FALSE);
adapter->devices = g_slist_append(adapter->devices, device);
if (g_strcmp0(srcaddr, address) == 0)
return;
- device = device_create(connection, adapter, address, bdaddr_type);
+ device = device_create(adapter, address, bdaddr_type);
if (device) {
device_set_temporary(device, FALSE);
adapter->devices = g_slist_append(adapter->devices, device);
key, (GCompareFunc) device_address_cmp))
return;
- device = device_create(connection, adapter, key, BDADDR_BREDR);
+ device = device_create(adapter, key, BDADDR_BREDR);
if (device) {
device_set_temporary(device, FALSE);
adapter->devices = g_slist_append(adapter->devices, device);
address, (GCompareFunc) device_address_cmp))
return;
- device = device_create(connection, adapter, address, bdaddr_type);
+ device = device_create(adapter, address, bdaddr_type);
if (!device)
return;
uuids = g_slist_append(uuids, prim->uuid);
}
- device_register_services(connection, device, services, -1);
+ device_register_services(device, services, -1);
device_probe_profiles(device, uuids);
return;
}
- device_add_connection(device, connection);
+ device_add_connection(device);
adapter->connections = g_slist_append(adapter->connections, device);
}
return;
}
- device_remove_connection(device, connection);
+ device_remove_connection(device);
adapter->connections = g_slist_remove(adapter->connections, device);
diff --git a/src/device.c b/src/device.c
index ac31a87..5a82e02 100644
--- a/src/device.c
+++ b/src/device.c
};
struct bonding_req {
- DBusConnection *conn;
DBusMessage *msg;
guint listener_id;
struct btd_device *device;
};
struct browse_req {
- DBusConnection *conn;
DBusMessage *msg;
struct btd_device *device;
GSList *match_uuids;
static void browse_request_free(struct browse_req *req)
{
if (req->listener_id)
- g_dbus_remove_watch(req->conn, req->listener_id);
+ g_dbus_remove_watch(btd_get_dbus_connection(),
+ req->listener_id);
if (req->msg)
dbus_message_unref(req->msg);
- if (req->conn)
- dbus_connection_unref(req->conn);
if (req->device)
btd_device_unref(req->device);
g_slist_free_full(req->profiles_added, g_free);
return reply;
}
-static DBusMessage *set_alias(DBusConnection *conn, DBusMessage *msg,
- const char *alias, void *data)
+static DBusMessage *set_alias(DBusMessage *msg, const char *alias, void *data)
{
struct btd_device *device = data;
struct btd_adapter *adapter = device->adapter;
return dbus_message_new_method_return(msg);
}
-static DBusMessage *set_trust(DBusConnection *conn, DBusMessage *msg,
- gboolean value, void *data)
+static DBusMessage *set_trust(DBusMessage *msg, gboolean value, void *data)
{
struct btd_device *device = data;
struct btd_adapter *adapter = device->adapter;
return FALSE;
}
-int device_block(DBusConnection *conn, struct btd_device *device,
- gboolean update_only)
+int device_block(struct btd_device *device, gboolean update_only)
{
int err = 0;
bdaddr_t src;
return 0;
}
-int device_unblock(DBusConnection *conn, struct btd_device *device,
- gboolean silent, gboolean update_only)
+int device_unblock(struct btd_device *device, gboolean silent,
+ gboolean update_only)
{
int err = 0;
bdaddr_t src;
return 0;
}
-static DBusMessage *set_blocked(DBusConnection *conn, DBusMessage *msg,
- gboolean value, void *data)
+static DBusMessage *set_blocked(DBusMessage *msg, gboolean value, void *data)
{
struct btd_device *device = data;
int err;
if (value)
- err = device_block(conn, device, FALSE);
+ err = device_block(device, FALSE);
else
- err = device_unblock(conn, device, FALSE, FALSE);
+ err = device_unblock(device, FALSE, FALSE);
switch (-err) {
case 0:
return btd_error_invalid_args(msg);
dbus_message_iter_get_basic(&sub, &value);
- return set_trust(conn, msg, value, data);
+ return set_trust(msg, value, data);
} else if (g_str_equal("Alias", property)) {
const char *alias;
return btd_error_invalid_args(msg);
dbus_message_iter_get_basic(&sub, &alias);
- return set_alias(conn, msg, alias, data);
+ return set_alias(msg, alias, data);
} else if (g_str_equal("Blocked", property)) {
dbus_bool_t value;
dbus_message_iter_get_basic(&sub, &value);
- return set_blocked(conn, msg, value, data);
+ return set_blocked(msg, value, data);
}
return btd_error_invalid_args(msg);
return btd_error_invalid_args(msg);
if (strlen(pattern) == 0) {
- err = device_browse_sdp(device, conn, msg, NULL, FALSE);
+ err = device_browse_sdp(device, msg, NULL, FALSE);
if (err < 0)
goto fail;
} else {
sdp_uuid128_to_uuid(&uuid);
- err = device_browse_sdp(device, conn, msg, &uuid, FALSE);
+ err = device_browse_sdp(device, msg, &uuid, FALSE);
if (err < 0)
goto fail;
}
static void discover_services_reply(struct browse_req *req, int err,
sdp_list_t *recs)
{
+ DBusConnection *conn = btd_get_dbus_connection();
DBusMessage *reply;
DBusMessageIter iter, dict;
sdp_list_t *seq;
reply = dbus_message_new_error(req->msg, err_if,
strerror(-err));
- g_dbus_send_message(req->conn, reply);
+ g_dbus_send_message(conn, reply);
return;
}
dbus_message_iter_close_container(&iter, &dict);
- g_dbus_send_message(req->conn, reply);
+ g_dbus_send_message(conn, reply);
}
static DBusMessage *cancel_discover(DBusConnection *conn,
void device_request_disconnect(struct btd_device *device, DBusMessage *msg)
{
- DBusConnection *conn = btd_get_dbus_connection();
-
if (device->bonding)
bonding_request_cancel(device->bonding);
device->disconn_timer = g_timeout_add_seconds(DISCONNECT_TIMER,
do_disconnect, device);
- g_dbus_emit_signal(conn, device->path,
- DEVICE_INTERFACE, "DisconnectRequested",
- DBUS_TYPE_INVALID);
+ g_dbus_emit_signal(btd_get_dbus_connection(),
+ device->path,
+ DEVICE_INTERFACE, "DisconnectRequested",
+ DBUS_TYPE_INVALID);
}
static DBusMessage *disconnect(DBusConnection *conn, DBusMessage *msg,
return device->connected;
}
-void device_add_connection(struct btd_device *device, DBusConnection *conn)
+void device_add_connection(struct btd_device *device)
{
if (device->connected) {
char addr[18];
DBUS_TYPE_BOOLEAN, &device->connected);
}
-void device_remove_connection(struct btd_device *device, DBusConnection *conn)
+void device_remove_connection(struct btd_device *device)
{
if (!device->connected) {
char addr[18];
while (device->disconnects) {
DBusMessage *msg = device->disconnects->data;
- g_dbus_send_reply(conn, msg, DBUS_TYPE_INVALID);
+ g_dbus_send_reply(btd_get_dbus_connection(),
+ msg, DBUS_TYPE_INVALID);
device->disconnects = g_slist_remove(device->disconnects, msg);
}
DBUS_TYPE_UINT16, &value);
}
-struct btd_device *device_create(DBusConnection *conn,
- struct btd_adapter *adapter,
+struct btd_device *device_create(struct btd_adapter *adapter,
const gchar *address, uint8_t bdaddr_type)
{
gchar *address_up;
DBG("Creating device %s", device->path);
- if (g_dbus_register_interface(conn, device->path, DEVICE_INTERFACE,
- device_methods, device_signals, NULL,
- device, device_free) == FALSE) {
+ if (g_dbus_register_interface(btd_get_dbus_connection(),
+ device->path, DEVICE_INTERFACE,
+ device_methods, device_signals, NULL,
+ device, device_free) == FALSE) {
device_free(device);
return NULL;
}
device->trusted = read_trust(&src, address, device->bdaddr_type);
if (read_blocked(&src, &device->bdaddr, device->bdaddr_type))
- device_block(conn, device, FALSE);
+ device_block(device, FALSE);
if (read_link_key(&src, &device->bdaddr, device->bdaddr_type, NULL,
NULL) == 0) {
{
bdaddr_t src, dst;
uint8_t dst_type;
- DBusConnection *conn = btd_get_dbus_connection();
adapter_get_address(device->adapter, &src);
device_get_address(device, &dst, &dst_type);
delete_device_service(&src, &dst, dst_type);
if (device->blocked)
- device_unblock(conn, device, TRUE, FALSE);
+ device_unblock(device, TRUE, FALSE);
}
void device_remove(struct btd_device *device, gboolean remove_stored)
dbus_message_append_args(reply, DBUS_TYPE_OBJECT_PATH, &device->path,
DBUS_TYPE_INVALID);
- g_dbus_send_message(req->conn, reply);
+ g_dbus_send_message(btd_get_dbus_connection(), reply);
}
GSList *device_services_from_record(struct btd_device *device, GSList *profiles)
list = device_services_from_record(device, req->profiles_added);
if (list)
- device_register_services(req->conn, device, list,
- ATT_PSM);
+ device_register_services(device, list, ATT_PSM);
device_probe_profiles(device, req->profiles_added);
}
if (err < 0) {
DBusMessage *reply;
reply = btd_error_failed(req->msg, strerror(-err));
- g_dbus_send_message(req->conn, reply);
+ g_dbus_send_message(btd_get_dbus_connection(), reply);
goto cleanup;
}
DBusMessage *reply;
reply = btd_error_failed(req->msg,
att_ecode2str(status));
- g_dbus_send_message(req->conn, reply);
+ g_dbus_send_message(btd_get_dbus_connection(), reply);
}
goto done;
}
g_slist_free_full(device->primaries, g_free);
device->primaries = NULL;
- device_register_services(req->conn, device, g_slist_copy(services), -1);
+ device_register_services(device, g_slist_copy(services), -1);
if (req->profiles_removed)
device_remove_profiles(device, req->profiles_removed);
DBusMessage *reply;
reply = btd_error_failed(req->msg, gerr->message);
- g_dbus_send_message(req->conn, reply);
+ g_dbus_send_message(btd_get_dbus_connection(), reply);
}
device->browse = NULL;
device->browse);
}
-int device_browse_primary(struct btd_device *device, DBusConnection *conn,
- DBusMessage *msg, gboolean secure)
+int device_browse_primary(struct btd_device *device, DBusMessage *msg,
+ gboolean secure)
{
struct btd_adapter *adapter = device->adapter;
struct att_callbacks *attcb;
}
done:
- if (conn == NULL)
- conn = btd_get_dbus_connection();
-
- req->conn = dbus_connection_ref(conn);
if (msg) {
const char *sender = dbus_message_get_sender(msg);
req->msg = dbus_message_ref(msg);
/* Track the request owner to cancel it
* automatically if the owner exits */
- req->listener_id = g_dbus_add_disconnect_watch(conn,
+ req->listener_id = g_dbus_add_disconnect_watch(
+ btd_get_dbus_connection(),
sender,
discover_services_req_exit,
req, NULL);
return 0;
}
-int device_browse_sdp(struct btd_device *device, DBusConnection *conn,
- DBusMessage *msg, uuid_t *search, gboolean reverse)
+int device_browse_sdp(struct btd_device *device, DBusMessage *msg,
+ uuid_t *search, gboolean reverse)
{
struct btd_adapter *adapter = device->adapter;
struct browse_req *req;
return err;
}
- if (conn == NULL)
- conn = btd_get_dbus_connection();
-
- req->conn = dbus_connection_ref(conn);
device->browse = req;
if (msg) {
req->msg = dbus_message_ref(msg);
/* Track the request owner to cancel it
* automatically if the owner exits */
- req->listener_id = g_dbus_add_disconnect_watch(conn,
+ req->listener_id = g_dbus_add_disconnect_watch(
+ btd_get_dbus_connection(),
sender,
discover_services_req_exit,
req, NULL);
struct btd_device *device = user_data;
if (device_is_bredr(device))
- device_browse_sdp(device, NULL, NULL, NULL, TRUE);
+ device_browse_sdp(device, NULL, NULL, TRUE);
else
- device_browse_primary(device, NULL, NULL, FALSE);
+ device_browse_primary(device, NULL, FALSE);
device->discov_timer = 0;
return;
if (bonding->listener_id)
- g_dbus_remove_watch(bonding->conn, bonding->listener_id);
+ g_dbus_remove_watch(btd_get_dbus_connection(),
+ bonding->listener_id);
if (bonding->msg)
dbus_message_unref(bonding->msg);
- if (bonding->conn)
- dbus_connection_unref(bonding->conn);
-
device = bonding->device;
g_free(bonding);
device->authr->agent = NULL;
}
-static struct bonding_req *bonding_request_new(DBusConnection *conn,
- DBusMessage *msg,
+static struct bonding_req *bonding_request_new(DBusMessage *msg,
struct btd_device *device,
const char *agent_path,
uint8_t capability)
proceed:
bonding = g_new0(struct bonding_req, 1);
- bonding->conn = dbus_connection_ref(conn);
bonding->msg = dbus_message_ref(msg);
return bonding;
}
DBusMessage *device_create_bonding(struct btd_device *device,
- DBusConnection *conn,
DBusMessage *msg,
const char *agent_path,
uint8_t capability)
if (err < 0)
return btd_error_failed(msg, strerror(-err));
- bonding = bonding_request_new(conn, msg, device, agent_path,
+ bonding = bonding_request_new(msg, device, agent_path,
capability);
- bonding->listener_id = g_dbus_add_disconnect_watch(conn,
+ bonding->listener_id = g_dbus_add_disconnect_watch(
+ btd_get_dbus_connection(),
dbus_message_get_sender(msg),
create_bond_req_exit, device,
NULL);
}
if (device_is_bredr(device))
- device_browse_sdp(device, bonding->conn, bonding->msg,
- NULL, FALSE);
+ device_browse_sdp(device, bonding->msg, NULL, FALSE);
else
- device_browse_primary(device, bonding->conn,
- bonding->msg, FALSE);
+ device_browse_primary(device, bonding->msg, FALSE);
bonding_request_free(bonding);
} else {
device_cancel_authentication(device, FALSE);
reply = new_authentication_return(bonding->msg, status);
- g_dbus_send_message(bonding->conn, reply);
+ g_dbus_send_message(btd_get_dbus_connection(), reply);
bonding_request_cancel(bonding);
bonding_request_free(bonding);
device->authorizing = auth;
}
-void device_register_services(DBusConnection *conn, struct btd_device *device,
+void device_register_services(struct btd_device *device,
GSList *prim_list, int psm)
{
device->primaries = g_slist_concat(device->primaries, prim_list);
- device->services = attrib_client_register(conn, device, psm, NULL,
- prim_list);
+ device->services = attrib_client_register(btd_get_dbus_connection(),
+ device, psm, NULL,
+ prim_list);
}
GSList *btd_device_get_primaries(struct btd_device *device)
prim->changed = TRUE;
}
- device_browse_primary(device, NULL, NULL, FALSE);
+ device_browse_primary(device, NULL, FALSE);
}
void btd_device_add_uuid(struct btd_device *device, const char *uuid)
void btd_device_unref(struct btd_device *device)
{
- DBusConnection *conn = btd_get_dbus_connection();
gchar *path;
device->ref--;
path = g_strdup(device->path);
- g_dbus_unregister_interface(conn, path, DEVICE_INTERFACE);
+ g_dbus_unregister_interface(btd_get_dbus_connection(),
+ path, DEVICE_INTERFACE);
g_free(path);
}
diff --git a/src/device.h b/src/device.h
index 0195a9a..aee6d13 100644
--- a/src/device.h
+++ b/src/device.h
AUTH_TYPE_NOTIFY_PINCODE,
} auth_type_t;
-struct btd_device *device_create(DBusConnection *conn,
- struct btd_adapter *adapter,
- const char *address, uint8_t bdaddr_type);
+struct btd_device *device_create(struct btd_adapter *adapter,
+ const char *address, uint8_t bdaddr_type);
void device_set_name(struct btd_device *device, const char *name);
void device_get_name(struct btd_device *device, char *name, size_t len);
void device_remove(struct btd_device *device, gboolean remove_stored);
gint device_address_cmp(struct btd_device *device, const gchar *address);
gint device_bdaddr_cmp(struct btd_device *device, bdaddr_t *bdaddr);
-int device_browse_primary(struct btd_device *device, DBusConnection *conn,
- DBusMessage *msg, gboolean secure);
-int device_browse_sdp(struct btd_device *device, DBusConnection *conn,
- DBusMessage *msg, uuid_t *search, gboolean reverse);
+int device_browse_primary(struct btd_device *device, DBusMessage *msg,
+ gboolean secure);
+int device_browse_sdp(struct btd_device *device, DBusMessage *msg,
+ uuid_t *search, gboolean reverse);
void device_probe_profiles(struct btd_device *device, GSList *profiles);
const sdp_record_t *btd_device_get_record(struct btd_device *device,
const char *uuid);
GSList *btd_device_get_primaries(struct btd_device *device);
void btd_device_gatt_set_service_changed(struct btd_device *device,
uint16_t start, uint16_t end);
-void device_register_services(DBusConnection *conn, struct btd_device *device,
+void device_register_services(struct btd_device *device,
GSList *prim_list, int psm);
GSList *device_services_from_record(struct btd_device *device,
GSList *profiles);
void device_set_bonded(struct btd_device *device, gboolean bonded);
void device_set_auto_connect(struct btd_device *device, gboolean enable);
gboolean device_is_connected(struct btd_device *device);
-DBusMessage *device_create_bonding(struct btd_device *device,
- DBusConnection *conn, DBusMessage *msg,
+DBusMessage *device_create_bonding(struct btd_device *device, DBusMessage *msg,
const char *agent_path, uint8_t capability);
void device_bonding_complete(struct btd_device *device, uint8_t status);
void device_simple_pairing_complete(struct btd_device *device, uint8_t status);
gboolean device_is_authenticating(struct btd_device *device);
gboolean device_is_authorizing(struct btd_device *device);
void device_set_authorizing(struct btd_device *device, gboolean auth);
-void device_add_connection(struct btd_device *device, DBusConnection *conn);
-void device_remove_connection(struct btd_device *device, DBusConnection *conn);
+void device_add_connection(struct btd_device *device);
+void device_remove_connection(struct btd_device *device);
void device_request_disconnect(struct btd_device *device, DBusMessage *msg);
typedef void (*disconnect_watch) (struct btd_device *device, gboolean removal,
struct btd_device *btd_device_ref(struct btd_device *device);
void btd_device_unref(struct btd_device *device);
-int device_block(DBusConnection *conn, struct btd_device *device,
- gboolean update_only);
-int device_unblock(DBusConnection *conn, struct btd_device *device,
- gboolean silent, gboolean update_only);
+int device_block(struct btd_device *device, gboolean update_only);
+int device_unblock(struct btd_device *device, gboolean silent,
+ gboolean update_only);
void device_set_pnpid(struct btd_device *device, uint8_t vendor_id_src,
uint16_t vendor_id, uint16_t product_id,
uint16_t product_ver);
diff --git a/src/event.c b/src/event.c
index e720b26..f1f5aaf 100644
--- a/src/event.c
+++ b/src/event.c
struct btd_adapter *adapter;
struct btd_device *device;
- DBusConnection *conn = btd_get_dbus_connection();
-
if (!get_adapter_and_device(local, peer, &adapter, &device, FALSE))
return;
if (device)
- device_block(conn, device, TRUE);
+ device_block(device, TRUE);
}
void btd_event_device_unblocked(bdaddr_t *local, bdaddr_t *peer)
struct btd_adapter *adapter;
struct btd_device *device;
- DBusConnection *conn = btd_get_dbus_connection();
-
if (!get_adapter_and_device(local, peer, &adapter, &device, FALSE))
return;
if (device)
- device_unblock(conn, device, FALSE, TRUE);
+ device_unblock(device, FALSE, TRUE);
}
void btd_event_device_unpaired(bdaddr_t *local, bdaddr_t *peer)