+/* The PA_SINK_MESSAGE types that extend the predefined messages. */
+enum {
+ LADSPA_SINK_MESSAGE_UPDATE_PARAMETERS = PA_SINK_MESSAGE_MAX
+};
+
+static int write_control_parameters(struct userdata *u, double *control_values, bool *use_default);
+static void connect_control_ports(struct userdata *u);
+
+#ifdef HAVE_DBUS
+
+#define LADSPA_IFACE "org.PulseAudio.Ext.Ladspa1"
+#define LADSPA_ALGORITHM_PARAMETERS "AlgorithmParameters"
+
+/* TODO: add a PropertyChanged signal to tell that the algorithm parameters have been changed */
+
+enum ladspa_handler_index {
+ LADSPA_HANDLER_ALGORITHM_PARAMETERS,
+ LADSPA_HANDLER_MAX
+};
+
+static void get_algorithm_parameters(DBusConnection *conn, DBusMessage *msg, void *_u) {
+ struct userdata *u;
+ DBusMessage *reply = NULL;
+ DBusMessageIter msg_iter, struct_iter;
+ unsigned long i;
+ double *control;
+ dbus_bool_t *use_default;
+
+ pa_assert(conn);
+ pa_assert(msg);
+ pa_assert_se(u = _u);
+
+ pa_assert_se((reply = dbus_message_new_method_return(msg)));
+ dbus_message_iter_init_append(reply, &msg_iter);
+
+ dbus_message_iter_open_container(&msg_iter, DBUS_TYPE_STRUCT, NULL, &struct_iter);
+
+ /* copying because of the D-Bus type mapping */
+ control = pa_xnew(double, u->n_control);
+ use_default = pa_xnew(dbus_bool_t, u->n_control);
+
+ for (i = 0; i < u->n_control; i++) {
+ control[i] = (double) u->control[i];
+ use_default[i] = u->use_default[i];
+ }
+
+ pa_dbus_append_basic_array(&struct_iter, DBUS_TYPE_DOUBLE, control, u->n_control);
+ pa_dbus_append_basic_array(&struct_iter, DBUS_TYPE_BOOLEAN, use_default, u->n_control);
+
+ dbus_message_iter_close_container(&msg_iter, &struct_iter);
+
+ pa_assert_se(dbus_connection_send(conn, reply, NULL));
+
+ dbus_message_unref(reply);
+ pa_xfree(control);
+ pa_xfree(use_default);
+}
+
+static void set_algorithm_parameters(DBusConnection *conn, DBusMessage *msg, DBusMessageIter *iter, void *_u) {
+ struct userdata *u;
+ DBusMessageIter array_iter, struct_iter;
+ int n_control = 0, n_use_default;
+ unsigned n_dbus_control, n_dbus_use_default;
+ double *read_values = NULL;
+ dbus_bool_t *read_defaults = NULL;
+ bool *use_defaults = NULL;
+ unsigned long i;
+
+ pa_assert(conn);
+ pa_assert(msg);
+ pa_assert_se(u = _u);
+
+ /* The property we are expecting has signature (adab), meaning that it's a
+ struct of two arrays, the first containing doubles and the second containing
+ booleans. The first array has the algorithm configuration values and the
+ second array has booleans indicating whether the matching algorithm
+ configuration value should use (or try to use) the default value provided by
+ the algorithm module. The PulseAudio D-Bus infrastructure will take care of
+ checking the argument types for us. */
+
+ dbus_message_iter_recurse(iter, &struct_iter);
+
+ dbus_message_iter_recurse(&struct_iter, &array_iter);
+ dbus_message_iter_get_fixed_array(&array_iter, &read_values, &n_control);
+
+ dbus_message_iter_next(&struct_iter);
+ dbus_message_iter_recurse(&struct_iter, &array_iter);
+ dbus_message_iter_get_fixed_array(&array_iter, &read_defaults, &n_use_default);
+
+ n_dbus_control = n_control; /* handle the unsignedness */
+ n_dbus_use_default = n_use_default;
+
+ if (n_dbus_control != u->n_control || n_dbus_use_default != u->n_control) {
+ pa_dbus_send_error(conn, msg, DBUS_ERROR_INVALID_ARGS, "Wrong number of array values (expected %lu)", u->n_control);
+ return;
+ }
+
+ use_defaults = pa_xnew(bool, n_control);
+ for (i = 0; i < u->n_control; i++)
+ use_defaults[i] = read_defaults[i];
+
+ if (write_control_parameters(u, read_values, use_defaults) < 0) {
+ pa_log_warn("Failed writing control parameters");
+ goto error;
+ }
+
+ pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), LADSPA_SINK_MESSAGE_UPDATE_PARAMETERS, NULL, 0, NULL);
+
+ pa_dbus_send_empty_reply(conn, msg);
+
+ pa_xfree(use_defaults);
+ return;
+
+error:
+ pa_xfree(use_defaults);
+ pa_dbus_send_error(conn, msg, DBUS_ERROR_FAILED, "Internal error");
+}
+
+static pa_dbus_property_handler ladspa_property_handlers[LADSPA_HANDLER_MAX] = {
+ [LADSPA_HANDLER_ALGORITHM_PARAMETERS] = {
+ .property_name = LADSPA_ALGORITHM_PARAMETERS,
+ .type = "(adab)",
+ .get_cb = get_algorithm_parameters,
+ .set_cb = set_algorithm_parameters
+ }
+};
+
+static void ladspa_get_all(DBusConnection *conn, DBusMessage *msg, void *_u) {
+ struct userdata *u;
+ DBusMessage *reply = NULL;
+ DBusMessageIter msg_iter, dict_iter, dict_entry_iter, variant_iter, struct_iter;
+ const char *key = LADSPA_ALGORITHM_PARAMETERS;
+ double *control;
+ dbus_bool_t *use_default;
+ long unsigned i;
+
+ pa_assert(conn);
+ pa_assert(msg);
+ pa_assert_se(u = _u);
+
+ pa_assert_se((reply = dbus_message_new_method_return(msg)));
+
+ /* Currently, on this interface, only a single property is returned. */
+
+ dbus_message_iter_init_append(reply, &msg_iter);
+ pa_assert_se(dbus_message_iter_open_container(&msg_iter, DBUS_TYPE_ARRAY, "{sv}", &dict_iter));
+ pa_assert_se(dbus_message_iter_open_container(&dict_iter, DBUS_TYPE_DICT_ENTRY, NULL, &dict_entry_iter));
+ pa_assert_se(dbus_message_iter_append_basic(&dict_entry_iter, DBUS_TYPE_STRING, &key));
+
+ pa_assert_se(dbus_message_iter_open_container(&dict_entry_iter, DBUS_TYPE_VARIANT, "(adab)", &variant_iter));
+ pa_assert_se(dbus_message_iter_open_container(&variant_iter, DBUS_TYPE_STRUCT, NULL, &struct_iter));
+
+ control = pa_xnew(double, u->n_control);
+ use_default = pa_xnew(dbus_bool_t, u->n_control);
+
+ for (i = 0; i < u->n_control; i++) {
+ control[i] = (double) u->control[i];
+ use_default[i] = u->use_default[i];
+ }
+
+ pa_dbus_append_basic_array(&struct_iter, DBUS_TYPE_DOUBLE, control, u->n_control);
+ pa_dbus_append_basic_array(&struct_iter, DBUS_TYPE_BOOLEAN, use_default, u->n_control);
+
+ pa_assert_se(dbus_message_iter_close_container(&variant_iter, &struct_iter));
+ pa_assert_se(dbus_message_iter_close_container(&dict_entry_iter, &variant_iter));
+ pa_assert_se(dbus_message_iter_close_container(&dict_iter, &dict_entry_iter));
+ pa_assert_se(dbus_message_iter_close_container(&msg_iter, &dict_iter));
+
+ pa_assert_se(dbus_connection_send(conn, reply, NULL));
+ dbus_message_unref(reply);
+ pa_xfree(control);
+ pa_xfree(use_default);
+}
+
+static pa_dbus_interface_info ladspa_info = {
+ .name = LADSPA_IFACE,
+ .method_handlers = NULL,
+ .n_method_handlers = 0,
+ .property_handlers = ladspa_property_handlers,
+ .n_property_handlers = LADSPA_HANDLER_MAX,
+ .get_all_properties_cb = ladspa_get_all,
+ .signals = NULL,
+ .n_signals = 0
+};
+
+static void dbus_init(struct userdata *u) {
+ pa_assert_se(u);
+
+ u->dbus_protocol = pa_dbus_protocol_get(u->sink->core);
+ u->dbus_path = pa_sprintf_malloc("/org/pulseaudio/core1/sink%d", u->sink->index);
+
+ pa_dbus_protocol_add_interface(u->dbus_protocol, u->dbus_path, &ladspa_info, u);
+}
+
+static void dbus_done(struct userdata *u) {
+ pa_assert_se(u);
+
+ if (!u->dbus_protocol) {
+ pa_assert(!u->dbus_path);
+ return;
+ }
+
+ pa_dbus_protocol_remove_interface(u->dbus_protocol, u->dbus_path, ladspa_info.name);
+ pa_xfree(u->dbus_path);
+ pa_dbus_protocol_unref(u->dbus_protocol);
+
+ u->dbus_path = NULL;
+ u->dbus_protocol = NULL;
+}
+
+#endif /* HAVE_DBUS */
+