diff --git a/client/player.c b/client/player.c
index a399d82..e508496 100644
--- a/client/player.c
+++ b/client/player.c
struct iovec *caps;
struct iovec *meta;
bool auto_accept;
- bool acquiring;
uint8_t max_transports;
uint8_t iso_group;
uint8_t iso_stream;
- char *transport;
+ struct queue *acquiring;
+ struct queue *transports;
DBusMessage *msg;
struct preset *preset;
bool broadcast;
bt_shell_printf("\tTransport %s\n", path);
print_iter("\t", "Properties", &props);
- free(ep->transport);
-
if (!ep->max_transports) {
bt_shell_printf("Maximum transports reached: rejecting\n");
return g_dbus_create_error(msg,
ep->max_transports--;
- ep->transport = strdup(path);
+ if (!ep->transports)
+ ep->transports = queue_new();
+
+ queue_push_tail(ep->transports, strdup(path));
if (ep->auto_accept) {
bt_shell_printf("Auto Accepting...\n");
return reply;
}
+static bool match_str(const void *data, const void *user_data)
+{
+ return !strcmp(data, user_data);
+}
+
static DBusMessage *endpoint_clear_configuration(DBusConnection *conn,
DBusMessage *msg, void *user_data)
{
struct endpoint *ep = user_data;
+ DBusMessageIter args;
+ const char *path;
+
+ dbus_message_iter_init(msg, &args);
+
+ dbus_message_iter_get_basic(&args, &path);
if (ep->max_transports != UINT8_MAX)
ep->max_transports++;
- free(ep->transport);
- ep->transport = NULL;
+ queue_remove_if(ep->transports, match_str, (void *)path);
return g_dbus_create_reply(msg, DBUS_TYPE_INVALID);
}
free(ep->preset);
}
+ queue_destroy(ep->acquiring, NULL);
+ queue_destroy(ep->transports, free);
+
g_free(ep->path);
g_free(ep->uuid);
g_free(ep);
for (l = local_endpoints; l; l = g_list_next(l)) {
struct endpoint *ep = l->data;
- if (ep->transport && !strcmp(ep->transport, path))
+ if (queue_find(ep->transports, match_str, path))
return ep;
}
return NULL;
}
-static struct endpoint *find_link_by_proxy(GDBusProxy *proxy)
+static GDBusProxy *find_link_by_proxy(GDBusProxy *proxy)
{
DBusMessageIter iter, array;
while (dbus_message_iter_get_arg_type(&array) ==
DBUS_TYPE_OBJECT_PATH) {
const char *transport;
- struct endpoint *link;
dbus_message_iter_get_basic(&array, &transport);
- link = find_ep_by_transport(transport);
- if (link)
- return link;
+ proxy = g_dbus_proxy_lookup(transports, NULL, transport,
+ BLUEZ_MEDIA_TRANSPORT_INTERFACE);
+ if (proxy)
+ return proxy;
}
return NULL;
queue_push_tail(ios, transport);
}
+static void ep_set_acquiring(struct endpoint *ep, GDBusProxy *proxy, bool value)
+{
+ bt_shell_printf("Transport %s %s\n", g_dbus_proxy_get_path(proxy),
+ value ? "acquiring" : "acquiring complete");
+
+ if (value && !ep->acquiring)
+ ep->acquiring = queue_new();
+
+ if (value)
+ queue_push_tail(ep->acquiring, proxy);
+ else
+ queue_remove(ep->acquiring, proxy);
+}
+
+static void transport_set_acquiring(GDBusProxy *proxy, bool value)
+{
+ struct endpoint *ep;
+ GDBusProxy *link;
+
+ ep = find_ep_by_transport(g_dbus_proxy_get_path(proxy));
+ if (!ep)
+ return;
+
+ ep_set_acquiring(ep, proxy, value);
+
+ link = find_link_by_proxy(proxy);
+ if (link) {
+ ep = find_ep_by_transport(g_dbus_proxy_get_path(link));
+ if (!ep)
+ return;
+
+ ep_set_acquiring(ep, link, value);
+ }
+}
+
static void acquire_reply(DBusMessage *message, void *user_data)
{
GDBusProxy *proxy = user_data;
- struct endpoint *ep, *link;
DBusError error;
int sk;
uint16_t mtu[2];
- ep = find_ep_by_transport(g_dbus_proxy_get_path(proxy));
- if (ep) {
- ep->acquiring = false;
- link = find_link_by_proxy(proxy);
- if (link)
- link->acquiring = false;
- }
+ transport_set_acquiring(proxy, false);
dbus_error_init(&error);
return bt_shell_noninteractive_quit(EXIT_FAILURE);
}
-static void transport_acquire(const char *input, void *user_data)
+static void prompt_acquire(const char *input, void *user_data)
{
GDBusProxy *proxy = user_data;
- struct endpoint *ep, *link;
if (!strcasecmp(input, "y") || !strcasecmp(input, "yes")) {
if (g_dbus_proxy_method_call(proxy, "Acquire", NULL,
- acquire_reply, proxy, NULL))
+ acquire_reply, proxy, NULL)) {
+ transport_set_acquiring(proxy, true);
return;
+ }
bt_shell_printf("Failed acquire transport\n");
}
+}
- /* Reset acquiring */
+static void transport_acquire(GDBusProxy *proxy, bool prompt)
+{
+ struct endpoint *ep;
+ GDBusProxy *link;
+
+ /* only attempt to acquire if transport is configured with a local
+ * endpoint.
+ */
ep = find_ep_by_transport(g_dbus_proxy_get_path(proxy));
- if (ep) {
- ep->acquiring = false;
- link = find_link_by_proxy(proxy);
- if (link)
- link->acquiring = false;
+ if (!ep || queue_find(ep->acquiring, NULL, proxy))
+ return;
+
+ link = find_link_by_proxy(proxy);
+ if (link) {
+ ep = find_ep_by_transport(g_dbus_proxy_get_path(link));
+ /* if link already acquiring wait it to be complete */
+ if (!ep || queue_find(ep->acquiring, NULL, link))
+ return;
+ }
+
+ if (ep->auto_accept || !prompt) {
+ if (!prompt)
+ bt_shell_printf("auto acquiring...\n");
+ if (!g_dbus_proxy_method_call(proxy, "Acquire", NULL,
+ acquire_reply, proxy, NULL)) {
+ bt_shell_printf("failed acquire transport\n");
+ return;
+ }
+
+ transport_set_acquiring(proxy, true);
+ return;
}
+
+ bt_shell_prompt_input(g_dbus_proxy_get_path(proxy), "acquire (yes/no):",
+ prompt_acquire, proxy);
}
static void transport_property_changed(GDBusProxy *proxy, const char *name,
DBusMessageIter *iter)
{
char *str;
- struct endpoint *ep, *link;
str = proxy_description(proxy, "Transport", COLORED_CHG);
print_iter(str, name, iter);
if (strcmp(str, "pending"))
return;
- /* Only attempt to acquire if transport is configured with a local
- * endpoint.
- */
- ep = find_ep_by_transport(g_dbus_proxy_get_path(proxy));
- if (!ep || ep->acquiring)
- return;
-
- ep->acquiring = true;
-
- link = find_link_by_proxy(proxy);
- if (link) {
- bt_shell_printf("Link %s found\n", link->transport);
- /* If link already acquiring wait it to be complete */
- if (link->acquiring)
- return;
- link->acquiring = true;
- }
-
- if (ep->auto_accept) {
- bt_shell_printf("Auto Acquiring...\n");
- if (!g_dbus_proxy_method_call(proxy, "Acquire", NULL,
- acquire_reply, proxy, NULL)) {
- bt_shell_printf("Failed acquire transport\n");
- ep->acquiring = false;
- if (link)
- link->acquiring = false;
- }
- return;
- }
-
- bt_shell_prompt_input(g_dbus_proxy_get_path(proxy), "Acquire (yes/no):",
- transport_acquire, proxy);
+ transport_acquire(proxy, true);
}
static void property_changed(GDBusProxy *proxy, const char *name,
{
GDBusProxy *proxy;
int i;
- struct endpoint *ep, *link;
for (i = 1; i < argc; i++) {
proxy = g_dbus_proxy_lookup(transports, NULL, argv[i],
return bt_shell_noninteractive_quit(EXIT_FAILURE);
}
- ep = find_ep_by_transport(g_dbus_proxy_get_path(proxy));
- if (!ep || ep->acquiring) {
- bt_shell_printf(
- "Transport %s already in acquiring process\n",
- argv[i]);
- return bt_shell_noninteractive_quit(EXIT_FAILURE);
- }
-
- ep->acquiring = true;
-
- link = find_link_by_proxy(proxy);
- if (link) {
- bt_shell_printf("Link %s found\n", link->transport);
- /* If link already acquiring wait it to be complete */
- if (link->acquiring) {
- bt_shell_printf(
- "Link %s is in acquiring process\n",
- argv[i]);
- return bt_shell_noninteractive_quit(
- EXIT_FAILURE);
- }
- link->acquiring = true;
- }
-
- if (!g_dbus_proxy_method_call(proxy, "Acquire", NULL,
- acquire_reply, proxy, NULL)) {
- bt_shell_printf("Failed acquire transport\n");
- return bt_shell_noninteractive_quit(EXIT_FAILURE);
- }
+ transport_acquire(proxy, false);
}
return bt_shell_noninteractive_quit(EXIT_SUCCESS);
memset(&qos, 0, sizeof(qos));
len = sizeof(qos);
if (getsockopt(transport->sk, SOL_BLUETOOTH, BT_ISO_QOS, &qos,
- &len) < 0)
+ &len) < 0) {
+ bt_shell_printf("Unable to getsockopt(BT_ISO_QOS): %s",
+ strerror(errno));
err = transport_send(transport, fd, NULL);
- else
+ } else
err = transport_send(transport, fd, &qos);
if (err < 0) {