diff --git a/src/device.c b/src/device.c
index 998485b..40fd826 100644
--- a/src/device.c
+++ b/src/device.c
}
btd_gatt_client_connected(device->client_dbus);
+
+ /* Only initiate EATT connection when acting as initiator, as acceptor
+ * it shall be triggered only when ready to avoid possible clashes where
+ * both sides attempt to connection at same time.
+ */
+ if (device->connect)
+ btd_gatt_client_eatt_connect(device->client_dbus);
}
static void gatt_server_init(struct btd_device *device,
diff --git a/src/gatt-client.c b/src/gatt-client.c
index bec6e1e..6bed777 100644
--- a/src/gatt-client.c
+++ b/src/gatt-client.c
notify_client_free(notify_client);
}
+void btd_gatt_client_ready(struct btd_gatt_client *client)
+{
+ if (!client)
+ return;
+
+ if (!client->gatt) {
+ struct bt_gatt_client *gatt;
+
+ gatt = btd_device_get_gatt_client(client->device);
+ client->gatt = bt_gatt_client_clone(gatt);
+ if (!client->gatt) {
+ error("GATT client not initialized");
+ return;
+ }
+ }
+
+ client->ready = true;
+
+ DBG("GATT client ready");
+
+ create_services(client);
+
+ DBG("Features 0x%02x", client->features);
+
+ if (!client->features) {
+ client->features = bt_gatt_client_get_features(client->gatt);
+ DBG("Update Features 0x%02x", client->features);
+ if (client->features & BT_GATT_CHRC_CLI_FEAT_EATT)
+ btd_gatt_client_eatt_connect(client);
+ }
+}
+
static void eatt_connect_cb(GIOChannel *io, GError *gerr, gpointer user_data)
{
struct btd_gatt_client *client = user_data;
device_attach_att(client->device, io);
}
-static void eatt_connect(struct btd_gatt_client *client)
+void btd_gatt_client_eatt_connect(struct btd_gatt_client *client)
{
struct bt_att *att = bt_gatt_client_get_att(client->gatt);
struct btd_device *dev = client->device;
char addr[18];
int i;
+ if (!(client->features & BT_GATT_CHRC_CLI_FEAT_EATT))
+ return;
+
if (bt_att_get_channels(att) == btd_opts.gatt_channels)
return;
}
}
-void btd_gatt_client_ready(struct btd_gatt_client *client)
-{
- if (!client)
- return;
-
- if (!client->gatt) {
- struct bt_gatt_client *gatt;
-
- gatt = btd_device_get_gatt_client(client->device);
- client->gatt = bt_gatt_client_clone(gatt);
- if (!client->gatt) {
- error("GATT client not initialized");
- return;
- }
- }
-
- client->ready = true;
-
- DBG("GATT client ready");
-
- create_services(client);
-
- DBG("Features 0x%02x", client->features);
-
- if (!client->features) {
- client->features = bt_gatt_client_get_features(client->gatt);
- DBG("Update Features 0x%02x", client->features);
- if (client->features & BT_GATT_CHRC_CLI_FEAT_EATT)
- eatt_connect(client);
- }
-}
-
void btd_gatt_client_connected(struct btd_gatt_client *client)
{
struct bt_gatt_client *gatt;
* for any pre-registered notification sessions.
*/
queue_foreach(client->all_notify_clients, register_notify, client);
-
- if (!(client->features & BT_GATT_CHRC_CLI_FEAT_EATT))
- return;
-
- eatt_connect(client);
}
void btd_gatt_client_service_added(struct btd_gatt_client *client,
diff --git a/src/gatt-client.h b/src/gatt-client.h
index b653920..05b5ae3 100644
--- a/src/gatt-client.h
+++ b/src/gatt-client.h
void btd_gatt_client_service_removed(struct btd_gatt_client *client,
struct gatt_db_attribute *attrib);
void btd_gatt_client_disconnected(struct btd_gatt_client *client);
+void btd_gatt_client_eatt_connect(struct btd_gatt_client *client);
typedef void (*btd_gatt_client_service_path_t)(const char *service_path,
void *user_data);