static pa_bool_t device_is_loaded(pa_bluetooth_device *d) {
pa_assert(d);
- /* FIXME: e83621724d7939b97b4f01f0d7e965d61ef8e55e, f1daa282f030e4e2381341e0f65faca47c4b891b is borked, probably needs to be reversed */
-
- return d->device_info_valid && (d->audio_sink_info_valid || d->headset_info_valid);
+ return
+ d->device_info_valid &&
+ d->audio_sink_info_valid &&
+ d->headset_info_valid;
}
static pa_bool_t device_is_audio(pa_bluetooth_device *d) {
pa_assert(d);
pa_assert(d->device_info_valid);
- pa_assert(d->audio_sink_info_valid || d->headset_info_valid);
-
- /* FIXME: e83621724d7939b97b4f01f0d7e965d61ef8e55e, f1daa282f030e4e2381341e0f65faca47c4b891b is borked, probably needs to be reversed */
+ pa_assert(d->audio_sink_info_valid);
+ pa_assert(d->headset_info_valid);
return d->device_info_valid > 0 &&
(d->audio_sink_info_valid > 0 || d->headset_info_valid > 0);
return;
y->callback(y->userdata, d, good);
-
}
static void get_properties_reply(DBusPendingCall *pending, void *userdata) {
pa_assert_se(dbus_connection_send_with_reply(y->connection, m, &call, -1));
- p = pa_dbus_pending_new(m, call, y, d);
+ p = pa_dbus_pending_new(y->connection, m, call, y, d);
PA_LLIST_PREPEND(pa_dbus_pending, y->pending, p);
dbus_pending_call_set_notify(call, func, p, NULL);
} else if (dbus_message_has_interface(m, "org.bluez.Headset")) {
if (parse_audio_property(y, &d->headset_connected, &arg_i) < 0)
goto fail;
- d->headset_info_valid = 1;
} else if (dbus_message_has_interface(m, "org.bluez.AudioSink")) {
if (parse_audio_property(y, &d->audio_sink_connected, &arg_i) < 0)
goto fail;
- d->audio_sink_info_valid = 1;
}
pa_assert_se(y->mode == MODE_DISCOVER);
va_end(ap);
}
-pa_dbus_pending *pa_dbus_pending_new(DBusMessage *m, DBusPendingCall *pending, void *context_data, void *call_data) {
+pa_dbus_pending *pa_dbus_pending_new(
+ DBusConnection *c,
+ DBusMessage *m,
+ DBusPendingCall *pending,
+ void *context_data,
+ void *call_data) {
+
pa_dbus_pending *p;
pa_assert(pending);
p = pa_xnew(pa_dbus_pending, 1);
+ p->connection = c;
p->message = m;
p->pending = pending;
p->context_data = context_data;
void pa_dbus_pending_free(pa_dbus_pending *p) {
pa_assert(p);
- if (p->pending) {
+ if (p->pending)
dbus_pending_call_cancel(p->pending); /* p->pending is freed by cancel() */
- }
if (p->message)
dbus_message_unref(p->message);
void pa_dbus_sync_pending_list(pa_dbus_pending **p) {
pa_assert(p);
- while (*p)
- dbus_pending_call_block((*p)->pending);
+ while (*p && dbus_connection_read_write_dispatch((*p)->connection, -1))
+ ;
}
void pa_dbus_free_pending_list(pa_dbus_pending **p) {
struct userdata; /* We leave the actual definition to the caller */
struct pa_dbus_pending {
+ DBusConnection *connection;
DBusMessage *message;
DBusPendingCall *pending;
PA_LLIST_FIELDS(pa_dbus_pending);
};
-pa_dbus_pending *pa_dbus_pending_new(DBusMessage *m, DBusPendingCall *pending, void *context_data, void *call_data);
+pa_dbus_pending *pa_dbus_pending_new(DBusConnection *c, DBusMessage *m, DBusPendingCall *pending, void *context_data, void *call_data);
void pa_dbus_pending_free(pa_dbus_pending *p);
/* Sync up a list of pa_dbus_pending_call objects */