Adding upstream version 0.3.65.upstream/0.3.65upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

12 files changed, 8351 insertions, 0 deletions

diff --git a/pipewire-jack/src/control.c b/pipewire-jack/src/control.c
new file mode 100644
index 0000000..da06e2c
--- /dev/null
+++ b/pipewire-jack/src/control.c
@@ -0,0 +1,472 @@
+/* PipeWire
+ *
+ * Copyright © 2021 Florian Hülsmann <fh@cbix.de>
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <signal.h>
+
+#include <jack/control.h>
+#include <jack/jslist.h>
+
+#include <pipewire/pipewire.h>
+
+struct jackctl_sigmask
+{
+	sigset_t signals;
+};
+
+struct jackctl_sigmask sigmask;
+
+SPA_EXPORT
+jackctl_sigmask_t * jackctl_setup_signals(unsigned int flags)
+{
+	// stub
+	pw_log_warn("not implemented %d", flags);
+	sigemptyset(&sigmask.signals);
+	return &sigmask;
+}
+
+SPA_EXPORT
+void jackctl_wait_signals(jackctl_sigmask_t * signals)
+{
+	// stub
+	pw_log_warn("not implemented %p", signals);
+}
+
+SPA_EXPORT
+jackctl_server_t * jackctl_server_create(
+	bool (* on_device_acquire)(const char * device_name),
+	void (* on_device_release)(const char * device_name))
+{
+	pw_log_error("deprecated");
+	return jackctl_server_create2(on_device_acquire, on_device_release, NULL);
+}
+
+struct jackctl_server
+{
+	// stub
+	JSList * empty;
+	JSList * drivers;
+};
+
+struct jackctl_driver
+{
+	// stub
+};
+
+SPA_EXPORT
+jackctl_server_t * jackctl_server_create2(
+	bool (* on_device_acquire)(const char * device_name),
+	void (* on_device_release)(const char * device_name),
+	void (* on_device_reservation_loop)(void))
+{
+	// stub
+	pw_log_warn("not implemented %p %p %p", on_device_acquire, on_device_release, on_device_reservation_loop);
+
+	// setup server
+	jackctl_server_t * server;
+	server = (jackctl_server_t *)malloc(sizeof(jackctl_server_t));
+	if (server == NULL) {
+		return NULL;
+	}
+	server->empty = NULL;
+	server->drivers = NULL;
+
+	// setup dummy (default) driver
+	jackctl_driver_t * dummy;
+	dummy = (jackctl_driver_t *)malloc(sizeof(jackctl_driver_t));
+	if (dummy == NULL) {
+		free(server);
+		return NULL;
+	}
+	server->drivers = jack_slist_append (server->drivers, dummy);
+
+	return server;
+}
+
+SPA_EXPORT
+void jackctl_server_destroy(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+
+	if (server) {
+		if (server->drivers) {
+			free(server->drivers->data);
+		}
+		jack_slist_free(server->empty);
+		jack_slist_free(server->drivers);
+		free(server);
+	}
+}
+
+SPA_EXPORT
+bool jackctl_server_open(jackctl_server_t * server, jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p", server, driver);
+	return true;
+}
+
+SPA_EXPORT
+bool jackctl_server_start(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+	return true;
+}
+
+SPA_EXPORT
+bool jackctl_server_stop(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_server_close(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+	return false;
+}
+
+SPA_EXPORT
+const JSList * jackctl_server_get_drivers_list(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+	if (server == NULL) {
+		pw_log_warn("server == NULL");
+		return NULL;
+	}
+	return server->drivers;
+}
+
+SPA_EXPORT
+const JSList * jackctl_server_get_parameters(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+	if (server == NULL) {
+		return NULL;
+	}
+	return server->empty;
+}
+
+SPA_EXPORT
+const JSList * jackctl_server_get_internals_list(jackctl_server_t * server)
+{
+	// stub
+	pw_log_warn("%p: not implemented", server);
+	if (server == NULL) {
+		return NULL;
+	}
+	return server->empty;
+}
+
+SPA_EXPORT
+bool jackctl_server_load_internal(jackctl_server_t * server, jackctl_internal_t * internal)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p", server, internal);
+	return true;
+}
+
+SPA_EXPORT
+bool jackctl_server_unload_internal(jackctl_server_t * server, jackctl_internal_t * internal)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p", server, internal);
+	return true;
+}
+
+SPA_EXPORT
+bool jackctl_server_load_session_file(jackctl_server_t * server_ptr, const char * file)
+{
+	// stub
+	pw_log_warn("%p: not implemented %s", server_ptr, file);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_server_add_slave(jackctl_server_t * server, jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p", server, driver);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_server_remove_slave(jackctl_server_t * server, jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p", server, driver);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_server_switch_master(jackctl_server_t * server, jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p", server, driver);
+	return false;
+}
+
+
+SPA_EXPORT
+const char * jackctl_driver_get_name(jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented", driver);
+	return "dummy";
+}
+
+SPA_EXPORT
+jackctl_driver_type_t jackctl_driver_get_type(jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented", driver);
+	return (jackctl_driver_type_t)0;
+}
+
+SPA_EXPORT
+const JSList * jackctl_driver_get_parameters(jackctl_driver_t * driver)
+{
+	// stub
+	pw_log_warn("%p: not implemented", driver);
+	return NULL;
+}
+
+SPA_EXPORT
+int jackctl_driver_params_parse(jackctl_driver_t * driver, int argc, char* argv[])
+{
+	// stub
+	pw_log_warn("%p: not implemented %d %p", driver, argc, argv);
+	return 1;
+}
+
+SPA_EXPORT
+const char * jackctl_internal_get_name(jackctl_internal_t * internal)
+{
+	// stub
+	pw_log_warn("not implemented %p", internal);
+	return "pipewire-jack-stub";
+}
+
+SPA_EXPORT
+const JSList * jackctl_internal_get_parameters(jackctl_internal_t * internal)
+{
+	// stub
+	pw_log_warn("not implemented %p", internal);
+	return NULL;
+}
+
+SPA_EXPORT
+const char * jackctl_parameter_get_name(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return "pipewire-jack-stub";
+}
+
+SPA_EXPORT
+const char * jackctl_parameter_get_short_description(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return "pipewire-jack-stub";
+}
+
+SPA_EXPORT
+const char * jackctl_parameter_get_long_description(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return "pipewire-jack-stub";
+}
+
+SPA_EXPORT
+jackctl_param_type_t jackctl_parameter_get_type(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return (jackctl_param_type_t)0;
+}
+
+SPA_EXPORT
+char jackctl_parameter_get_id(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return 0;
+}
+
+SPA_EXPORT
+bool jackctl_parameter_is_set(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_parameter_reset(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return false;
+}
+
+SPA_EXPORT
+union jackctl_parameter_value jackctl_parameter_get_value(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	union jackctl_parameter_value value;
+	memset(&value, 0, sizeof(value));
+	return value;
+}
+
+SPA_EXPORT
+bool jackctl_parameter_set_value(
+	jackctl_parameter_t * parameter,
+	const union jackctl_parameter_value * value_ptr)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return false;
+}
+
+SPA_EXPORT
+union jackctl_parameter_value jackctl_parameter_get_default_value(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	union jackctl_parameter_value value;
+	memset(&value, 0, sizeof(value));
+	return value;
+}
+
+SPA_EXPORT
+bool jackctl_parameter_has_range_constraint(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_parameter_has_enum_constraint(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return false;
+}
+
+SPA_EXPORT
+uint32_t jackctl_parameter_get_enum_constraints_count(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("%p: not implemented", parameter);
+	return 0;
+}
+
+SPA_EXPORT
+union jackctl_parameter_value jackctl_parameter_get_enum_constraint_value(
+	jackctl_parameter_t * parameter,
+	uint32_t index)
+{
+	// stub
+	pw_log_warn("%p: not implemented %d", parameter, index);
+	union jackctl_parameter_value value;
+	memset(&value, 0, sizeof(value));
+	return value;
+}
+
+SPA_EXPORT
+const char * jackctl_parameter_get_enum_constraint_description(
+	jackctl_parameter_t * parameter,
+	uint32_t index)
+{
+	// stub
+	pw_log_warn("%p: not implemented %d", parameter, index);
+	return "pipewire-jack-stub";
+}
+
+SPA_EXPORT
+void jackctl_parameter_get_range_constraint(
+	jackctl_parameter_t * parameter,
+	union jackctl_parameter_value * min_ptr,
+	union jackctl_parameter_value * max_ptr)
+{
+	// stub
+	pw_log_warn("%p: not implemented %p %p", parameter, min_ptr, max_ptr);
+}
+
+SPA_EXPORT
+bool jackctl_parameter_constraint_is_strict(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("not implemented %p", parameter);
+	return false;
+}
+
+SPA_EXPORT
+bool jackctl_parameter_constraint_is_fake_value(jackctl_parameter_t * parameter)
+{
+	// stub
+	pw_log_warn("not implemented %p", parameter);
+	return false;
+}
+
+SPA_EXPORT SPA_PRINTF_FUNC(1, 2)
+void jack_error(const char *format, ...)
+{
+	va_list args;
+	va_start(args, format);
+	pw_log_logv(SPA_LOG_LEVEL_ERROR, "", 0, "", format, args);
+	va_end(args);
+}
+
+SPA_EXPORT SPA_PRINTF_FUNC(1, 2)
+void jack_info(const char *format, ...)
+{
+	va_list args;
+	va_start(args, format);
+	pw_log_logv(SPA_LOG_LEVEL_INFO, "", 0, "", format, args);
+	va_end(args);
+}
+
+SPA_EXPORT SPA_PRINTF_FUNC(1, 2)
+void jack_log(const char *format, ...)
+{
+	va_list args;
+	va_start(args, format);
+	pw_log_logv(SPA_LOG_LEVEL_DEBUG, "", 0, "", format, args);
+	va_end(args);
+}
diff --git a/pipewire-jack/src/dummy.c b/pipewire-jack/src/dummy.c
new file mode 100644
index 0000000..1d6bb57
--- /dev/null
+++ b/pipewire-jack/src/dummy.c
@@ -0,0 +1,39 @@
+/* PipeWire
+ *
+ * Copyright © 2020 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <sys/mman.h>
+#include <regex.h>
+#include <math.h>
+
+#include <pipewire/pipewire.h>
+
+static void reg(void) __attribute__ ((constructor));
+static void reg(void)
+{
+	pw_init(NULL, NULL);
+}
diff --git a/pipewire-jack/src/export.c b/pipewire-jack/src/export.c
new file mode 100644
index 0000000..4c9daf0
--- /dev/null
+++ b/pipewire-jack/src/export.c
@@ -0,0 +1,36 @@
+/* PipeWire
+ *
+ * Copyright © 2020 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ */
+
+#include <spa/utils/defs.h>
+
+#define JACK_METADATA_PREFIX "http://jackaudio.org/metadata/"
+SPA_EXPORT const char *JACK_METADATA_CONNECTED   = JACK_METADATA_PREFIX "connected";
+SPA_EXPORT const char *JACK_METADATA_EVENT_TYPES = JACK_METADATA_PREFIX "event-types";
+SPA_EXPORT const char *JACK_METADATA_HARDWARE    = JACK_METADATA_PREFIX "hardware";
+SPA_EXPORT const char *JACK_METADATA_ICON_LARGE  = JACK_METADATA_PREFIX "icon-large";
+SPA_EXPORT const char *JACK_METADATA_ICON_NAME   = JACK_METADATA_PREFIX "icon-name";
+SPA_EXPORT const char *JACK_METADATA_ICON_SMALL  = JACK_METADATA_PREFIX "icon-small";
+SPA_EXPORT const char *JACK_METADATA_ORDER       = JACK_METADATA_PREFIX "order";
+SPA_EXPORT const char *JACK_METADATA_PORT_GROUP  = JACK_METADATA_PREFIX "port-group";
+SPA_EXPORT const char *JACK_METADATA_PRETTY_NAME = JACK_METADATA_PREFIX "pretty-name";
+SPA_EXPORT const char *JACK_METADATA_SIGNAL_TYPE = JACK_METADATA_PREFIX "signal-type";
+#undef JACK_METADATA_PREFIX
diff --git a/pipewire-jack/src/meson.build b/pipewire-jack/src/meson.build
new file mode 100644
index 0000000..20d1ccf
--- /dev/null
+++ b/pipewire-jack/src/meson.build
@@ -0,0 +1,98 @@
+pipewire_jack_sources = [
+  'export.c',
+  'pipewire-jack.c',
+  'ringbuffer.c',
+  'uuid.c',
+]
+
+pipewire_jackserver_sources = pipewire_jack_sources
+pipewire_jackserver_sources += [
+  'control.c',
+]
+
+pipewire_net_sources = [
+  'net.c',
+]
+pipewire_jack_c_args = [
+  '-DPIC',
+]
+
+libjack_path = get_option('libjack-path')
+if libjack_path == ''
+  libjack_path = modules_install_dir / 'jack'
+  libjack_path_dlopen = modules_install_dir_dlopen / 'jack'
+else
+  libjack_path_dlopen = libjack_path
+endif
+
+tools_config = configuration_data()
+tools_config.set('LIBJACK_PATH', libjack_path_dlopen)
+
+configure_file(input : 'pw-jack.in',
+               output : 'pw-jack',
+               configuration : tools_config,
+               install_dir : pipewire_bindir)
+
+pipewire_jack = shared_library('jack',
+    pipewire_jack_sources,
+    soversion : soversion,
+    version : libversion,
+    c_args : pipewire_jack_c_args,
+    include_directories : [configinc, jack_inc],
+    dependencies : [pipewire_dep, mathlib],
+    install : true,
+    install_dir : libjack_path,
+)
+
+pipewire_jackserver = shared_library('jackserver',
+    pipewire_jackserver_sources,
+    soversion : soversion,
+    version : libversion,
+    c_args : pipewire_jack_c_args,
+    include_directories : [configinc, jack_inc],
+    dependencies : [pipewire_dep, mathlib],
+    install : true,
+    install_dir : libjack_path,
+)
+
+pipewire_jacknet = shared_library('jacknet',
+    pipewire_net_sources,
+    soversion : soversion,
+    version : libversion,
+    c_args : pipewire_jack_c_args,
+    include_directories : [configinc, jack_inc],
+    dependencies : [pipewire_dep, mathlib],
+    install : true,
+    install_dir : libjack_path,
+)
+
+
+if get_option('jack-devel') == true
+  if meson.version().version_compare('<0.59.0')
+    error(
+          '''
+          Before version 0.59.0 Meson creates a wrong jack pkg-config file.
+          For that reason this is now an error. Please update Meson,
+          if you want to have JACK development files.
+          ''')
+  endif
+
+  pkgconfig.generate(filebase : 'jack',
+  libraries : [pipewire_jack],
+  name : 'jack',
+  description : 'PipeWire JACK API',
+  version : '1.9.17',
+  extra_cflags : '-D_REENTRANT',
+  unescaped_variables: ['server_libs=-L${libdir} -ljackserver', 'jack_implementation=pipewire'])
+endif
+
+if sdl_dep.found()
+  executable('video-dsp-play',
+    '../examples/video-dsp-play.c',
+    include_directories : [jack_inc],
+    install : installed_tests_enabled,
+    install_dir : installed_tests_execdir / 'examples' / 'jack',
+    dependencies : [sdl_dep, mathlib],
+    link_with: pipewire_jack,
+  )
+endif
diff --git a/pipewire-jack/src/metadata.c b/pipewire-jack/src/metadata.c
new file mode 100644
index 0000000..da3d75f
--- /dev/null
+++ b/pipewire-jack/src/metadata.c
@@ -0,0 +1,421 @@
+/* PipeWire
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <sys/mman.h>
+
+#include <spa/utils/string.h>
+
+#include <jack/metadata.h>
+#include <jack/uuid.h>
+
+#include <pipewire/pipewire.h>
+#include <pipewire/extensions/metadata.h>
+
+static jack_description_t *find_description(jack_uuid_t subject)
+{
+	jack_description_t *desc;
+	pw_array_for_each(desc, &globals.descriptions) {
+		if (jack_uuid_compare(desc->subject, subject) == 0)
+			return desc;
+	}
+	return NULL;
+}
+
+static void set_property(jack_property_t *prop, const char *key, const char *value, const char *type)
+{
+	prop->key = strdup(key);
+	prop->data = strdup(value);
+	prop->type = strdup(type);
+}
+
+static void clear_property(jack_property_t *prop)
+{
+	free((char*)prop->key);
+	free((char*)prop->data);
+	free((char*)prop->type);
+}
+
+static jack_property_t *copy_properties(jack_property_t *src, uint32_t cnt)
+{
+	jack_property_t *dst;
+	uint32_t i;
+	dst = malloc(sizeof(jack_property_t) * cnt);
+	if (dst != NULL) {
+		for (i = 0; i < cnt; i++)
+			set_property(&dst[i], src[i].key, src[i].data, src[i].type);
+	}
+	return dst;
+}
+
+static int copy_description(jack_description_t *dst, jack_description_t *src)
+{
+	dst->properties = copy_properties(src->properties, src->property_cnt);
+	if (dst->properties == NULL)
+		return -errno;
+	jack_uuid_copy(&dst->subject, src->subject);
+	dst->property_cnt = src->property_cnt;
+	dst->property_size = src->property_size;
+	return dst->property_cnt;
+}
+
+static jack_description_t *add_description(jack_uuid_t subject)
+{
+	jack_description_t *desc;
+	desc = pw_array_add(&globals.descriptions, sizeof(*desc));
+	if (desc != NULL) {
+		spa_zero(*desc);
+		jack_uuid_copy(&desc->subject, subject);
+	}
+	return desc;
+}
+
+static void remove_description(jack_description_t *desc)
+{
+	jack_free_description(desc, false);
+	pw_array_remove(&globals.descriptions, desc);
+}
+
+static jack_property_t *find_property(jack_description_t *desc, const char *key)
+{
+	uint32_t i;
+	for (i = 0; i < desc->property_cnt; i++) {
+		jack_property_t *prop = &desc->properties[i];
+		if (spa_streq(prop->key, key))
+			return prop;
+	}
+	return NULL;
+}
+
+static jack_property_t *add_property(jack_description_t *desc, const char *key,
+		const char *value, const char *type)
+{
+	jack_property_t *prop;
+	void *np;
+	size_t ns;
+
+	if (desc->property_cnt == desc->property_size) {
+		ns = desc->property_size > 0 ? desc->property_size * 2 : 8;
+		np = pw_reallocarray(desc->properties, ns, sizeof(*prop));
+		if (np == NULL)
+			return NULL;
+		desc->property_size = ns;
+		desc->properties = np;
+	}
+	prop = &desc->properties[desc->property_cnt++];
+	set_property(prop, key, value, type);
+	return prop;
+}
+
+static void remove_property(jack_description_t *desc, jack_property_t *prop)
+{
+	clear_property(prop);
+	desc->property_cnt--;
+        memmove(desc->properties, SPA_PTROFF(prop, sizeof(*prop), void),
+                SPA_PTRDIFF(SPA_PTROFF(desc->properties, sizeof(*prop) * desc->property_cnt, void),
+			prop));
+
+	if (desc->property_cnt == 0)
+		remove_description(desc);
+}
+
+static int change_property(jack_property_t *prop, const char *value, const char *type)
+{
+	int changed = 0;
+	if (!spa_streq(prop->data, value)) {
+		free((char*)prop->data);
+		prop->data = strdup(value);
+		changed++;
+	}
+	if (!spa_streq(prop->type, type)) {
+		free((char*)prop->type);
+		prop->type = strdup(type);
+		changed++;
+	}
+	return changed;
+}
+
+static int update_property(struct client *c,
+		      jack_uuid_t subject,
+		      const char* key,
+		      const char* type,
+		      const char* value)
+{
+	jack_property_change_t change;
+	jack_description_t *desc;
+	int changed = 0;
+
+	pthread_mutex_lock(&globals.lock);
+	desc = find_description(subject);
+
+	if (key == NULL) {
+		if (desc != NULL) {
+			remove_description(desc);
+			change = PropertyDeleted;
+			changed++;
+		}
+	} else {
+		jack_property_t *prop;
+
+		prop = desc ? find_property(desc, key) : NULL;
+
+		if (value == NULL || type == NULL) {
+			if (prop != NULL) {
+				remove_property(desc, prop);
+				change = PropertyDeleted;
+				changed++;
+			}
+		} else if (prop == NULL) {
+			if (desc == NULL)
+				desc = add_description(subject);
+			if (desc == NULL) {
+				changed = -errno;
+				pw_log_warn("add_description failed: %m");
+			} else if (add_property(desc, key, value, type) == NULL) {
+				changed = -errno;
+				pw_log_warn("add_property failed: %m");
+			} else {
+				change = PropertyCreated;
+				changed++;
+			}
+		} else {
+			changed = change_property(prop, value, type);
+			change = PropertyChanged;
+		}
+	}
+	pthread_mutex_unlock(&globals.lock);
+
+	if (c->property_callback && changed > 0) {
+		pw_log_info("emit %"PRIu64" %s", (uint64_t)subject, key);
+		c->property_callback(subject, key, change, c->property_arg);
+	}
+	return changed;
+}
+
+
+SPA_EXPORT
+int jack_set_property(jack_client_t*client,
+		      jack_uuid_t subject,
+		      const char* key,
+		      const char* value,
+		      const char* type)
+{
+	struct client *c = (struct client *) client;
+	struct object *o;
+	uint32_t serial;
+	int res = -1;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(key != NULL, -EINVAL);
+	spa_return_val_if_fail(value != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+	if (c->metadata == NULL)
+		goto done;
+
+	if (subject & (1<<30))
+		goto done;
+
+	serial = jack_uuid_to_index(subject);
+	if ((o = find_by_serial(c, serial)) == NULL)
+		goto done;
+
+	if (type == NULL)
+		type = "";
+
+	pw_log_info("set id:%u (%"PRIu64") '%s' to '%s@%s'", o->id, subject, key, value, type);
+	if (update_property(c, subject, key, type, value))
+		pw_metadata_set_property(c->metadata->proxy, o->id, key, type, value);
+	res = 0;
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_get_property(jack_uuid_t subject,
+		      const char* key,
+		      char**      value,
+		      char**      type)
+{
+	jack_description_t *desc;
+	jack_property_t *prop;
+	int res = -1;
+
+	pthread_mutex_lock(&globals.lock);
+	desc = find_description(subject);
+	if (desc == NULL)
+		goto done;
+
+	prop = find_property(desc, key);
+	if (prop == NULL)
+		goto done;
+
+	*value = strdup(prop->data);
+	*type = strdup(prop->type);
+	res = 0;
+
+	pw_log_debug("subject:%"PRIu64" key:'%s' value:'%s' type:'%s'",
+			subject, key, *value, *type);
+done:
+	pthread_mutex_unlock(&globals.lock);
+	return res;
+}
+
+SPA_EXPORT
+void jack_free_description (jack_description_t* desc, int free_description_itself)
+{
+	uint32_t n;
+
+	for (n = 0; n < desc->property_cnt; ++n)
+		clear_property(&desc->properties[n]);
+	free(desc->properties);
+	if (free_description_itself)
+		free(desc);
+}
+
+SPA_EXPORT
+int jack_get_properties (jack_uuid_t         subject,
+			 jack_description_t* desc)
+{
+	jack_description_t *d;
+	int res = -1;
+
+	spa_return_val_if_fail(desc != NULL, -EINVAL);
+
+	pthread_mutex_lock(&globals.lock);
+	d = find_description(subject);
+	if (d == NULL)
+		goto done;
+
+	res = copy_description(desc, d);
+done:
+	pthread_mutex_unlock(&globals.lock);
+	return res;
+}
+
+SPA_EXPORT
+int jack_get_all_properties (jack_description_t** result)
+{
+	uint32_t i;
+	jack_description_t *dst, *src;
+	struct pw_array *descriptions;
+	uint32_t len;
+
+	pthread_mutex_lock(&globals.lock);
+	descriptions = &globals.descriptions;
+	len = pw_array_get_len(descriptions, jack_description_t);
+	src = descriptions->data;
+	dst = malloc(descriptions->size);
+	for (i = 0; i < len; i++)
+		copy_description(&dst[i], &src[i]);
+	*result = dst;
+	pthread_mutex_unlock(&globals.lock);
+
+	return len;
+}
+
+SPA_EXPORT
+int jack_remove_property (jack_client_t* client, jack_uuid_t subject, const char* key)
+{
+	struct client *c = (struct client *) client;
+	uint32_t id;
+	int res = -1;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(key != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	if (c->metadata == NULL)
+		goto done;
+
+	id = jack_uuid_to_index(subject);
+
+	pw_log_info("remove id:%u (%"PRIu64") '%s'", id, subject, key);
+	pw_metadata_set_property(c->metadata->proxy,
+			id, key, NULL, NULL);
+	res = 0;
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_remove_properties (jack_client_t* client, jack_uuid_t subject)
+{
+	struct client *c = (struct client *) client;
+	uint32_t id;
+	int res = -1;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+	if (c->metadata == NULL)
+		goto done;
+
+	id = jack_uuid_to_index(subject);
+
+	pw_log_info("remove id:%u (%"PRIu64")", id, subject);
+	pw_metadata_set_property(c->metadata->proxy,
+			id, NULL, NULL, NULL);
+	res = 0;
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_remove_all_properties (jack_client_t* client)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+	pw_metadata_clear(c->metadata->proxy);
+	pw_thread_loop_unlock(c->context.loop);
+
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_property_change_callback (jack_client_t*             client,
+                                       JackPropertyChangeCallback callback,
+                                       void*                      arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	c->property_callback = callback;
+	c->property_arg = arg;
+	return 0;
+}
diff --git a/pipewire-jack/src/net.c b/pipewire-jack/src/net.c
new file mode 100644
index 0000000..e48b76b
--- /dev/null
+++ b/pipewire-jack/src/net.c
@@ -0,0 +1,169 @@
+/* PipeWire
+ *
+ * Copyright © 2022 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <errno.h>
+
+#include <jack/net.h>
+
+#include <pipewire/pipewire.h>
+
+SPA_EXPORT
+jack_net_slave_t* jack_net_slave_open(const char* ip, int port, const char* name,
+		jack_slave_t* request, jack_master_t* result)
+{
+	return NULL;
+}
+
+SPA_EXPORT
+int jack_net_slave_close(jack_net_slave_t* net)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_set_net_slave_process_callback(jack_net_slave_t * net, JackNetSlaveProcessCallback net_callback, void *arg)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_slave_activate(jack_net_slave_t* net)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_slave_deactivate(jack_net_slave_t* net)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_slave_is_active(jack_net_slave_t* net)
+{
+	return false;
+}
+
+SPA_EXPORT
+int jack_set_net_slave_buffer_size_callback(jack_net_slave_t *net, JackNetSlaveBufferSizeCallback bufsize_callback, void *arg)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_set_net_slave_sample_rate_callback(jack_net_slave_t *net, JackNetSlaveSampleRateCallback samplerate_callback, void *arg)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_set_net_slave_shutdown_callback(jack_net_slave_t *net, JackNetSlaveShutdownCallback shutdown_callback, void *arg)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_set_net_slave_restart_callback(jack_net_slave_t *net, JackNetSlaveRestartCallback restart_callback, void *arg)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_set_net_slave_error_callback(jack_net_slave_t *net, JackNetSlaveErrorCallback error_callback, void *arg)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+jack_net_master_t* jack_net_master_open(const char* ip, int port, jack_master_t* request, jack_slave_t* result)
+{
+	return NULL;
+}
+
+SPA_EXPORT
+int jack_net_master_close(jack_net_master_t* net)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_master_recv(jack_net_master_t* net, int audio_input, float** audio_input_buffer, int midi_input, void** midi_input_buffer)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_master_recv_slice(jack_net_master_t* net, int audio_input, float** audio_input_buffer, int midi_input, void** midi_input_buffer, int frames)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_master_send(jack_net_master_t* net, int audio_output, float** audio_output_buffer, int midi_output, void** midi_output_buffer)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_net_master_send_slice(jack_net_master_t* net, int audio_output, float** audio_output_buffer, int midi_output, void** midi_output_buffer, int frames)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+jack_adapter_t* jack_create_adapter(int input, int output,
+                                    jack_nframes_t host_buffer_size,
+                                    jack_nframes_t host_sample_rate,
+                                    jack_nframes_t adapted_buffer_size,
+                                    jack_nframes_t adapted_sample_rate)
+{
+	return NULL;
+}
+
+SPA_EXPORT
+int jack_destroy_adapter(jack_adapter_t* adapter)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+void jack_flush_adapter(jack_adapter_t* adapter)
+{
+}
+
+SPA_EXPORT
+int jack_adapter_push_and_pull(jack_adapter_t* adapter, float** input, float** output, unsigned int frames)
+{
+	return ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_adapter_pull_and_push(jack_adapter_t* adapter, float** input, float** output, unsigned int frames)
+{
+	return ENOTSUP;
+}
diff --git a/pipewire-jack/src/pipewire-jack-extensions.h b/pipewire-jack/src/pipewire-jack-extensions.h
new file mode 100644
index 0000000..8e38e9e
--- /dev/null
+++ b/pipewire-jack/src/pipewire-jack-extensions.h
@@ -0,0 +1,50 @@
+/* PipeWire JACK extensions
+ *
+ * Copyright © 2020 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#ifndef PIPEWIRE_JACK_EXTENSIONS_H
+#define PIPEWIRE_JACK_EXTENSIONS_H
+#include <stdint.h>
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+/** 1.0 gamma, full range HDR 0.0 -> 1.0, pre-multiplied
+ * alpha, BT.2020 primaries, progressive */
+#define JACK_DEFAULT_VIDEO_TYPE	"32 bit float RGBA video"
+
+typedef struct jack_image_size {
+	uint32_t width;
+	uint32_t height;
+	uint32_t stride;
+	uint32_t flags;
+} jack_image_size_t;
+
+int jack_get_video_image_size(jack_client_t *client, jack_image_size_t *size);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* PIPEWIRE_JACK_EXTENSIONS_H */
diff --git a/pipewire-jack/src/pipewire-jack.c b/pipewire-jack/src/pipewire-jack.c
new file mode 100644
index 0000000..2e82677
--- /dev/null
+++ b/pipewire-jack/src/pipewire-jack.c
@@ -0,0 +1,6509 @@
+/* PipeWire
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <sys/mman.h>
+#include <regex.h>
+#include <math.h>
+
+#include <jack/jack.h>
+#include <jack/session.h>
+#include <jack/thread.h>
+#include <jack/midiport.h>
+#include <jack/uuid.h>
+#include <jack/metadata.h>
+
+#include <spa/support/cpu.h>
+#include <spa/param/audio/format-utils.h>
+#include <spa/param/video/format-utils.h>
+#include <spa/debug/types.h>
+#include <spa/debug/pod.h>
+#include <spa/utils/json.h>
+#include <spa/utils/string.h>
+
+#include <pipewire/pipewire.h>
+#include <pipewire/private.h>
+#include <pipewire/thread.h>
+#include <pipewire/data-loop.h>
+
+#include "pipewire/extensions/client-node.h"
+#include "pipewire/extensions/metadata.h"
+#include "pipewire-jack-extensions.h"
+
+#define JACK_DEFAULT_VIDEO_TYPE	"32 bit float RGBA video"
+
+/* use 512KB stack per thread - the default is way too high to be feasible
+ * with mlockall() on many systems */
+#define THREAD_STACK 524288
+
+#define DEFAULT_RT_MAX	88
+
+#define JACK_CLIENT_NAME_SIZE		256
+#define JACK_PORT_NAME_SIZE		256
+#define JACK_PORT_TYPE_SIZE             32
+#define MONITOR_EXT			" Monitor"
+
+#define MAX_MIX				1024
+#define MAX_BUFFER_FRAMES		8192
+
+#define MAX_ALIGN			16
+#define MAX_BUFFERS			2
+#define MAX_BUFFER_DATAS		1u
+
+#define REAL_JACK_PORT_NAME_SIZE (JACK_CLIENT_NAME_SIZE + JACK_PORT_NAME_SIZE)
+
+PW_LOG_TOPIC_STATIC(jack_log_topic, "jack");
+#define PW_LOG_TOPIC_DEFAULT jack_log_topic
+
+#define TYPE_ID_AUDIO	0
+#define TYPE_ID_MIDI	1
+#define TYPE_ID_VIDEO	2
+#define TYPE_ID_OTHER	3
+
+#define SELF_CONNECT_ALLOW	0
+#define SELF_CONNECT_FAIL_EXT	-1
+#define SELF_CONNECT_IGNORE_EXT	1
+#define SELF_CONNECT_FAIL_ALL	-2
+#define SELF_CONNECT_IGNORE_ALL	2
+
+struct client;
+struct port;
+
+struct globals {
+	jack_thread_creator_t creator;
+	pthread_mutex_t lock;
+	struct pw_array descriptions;
+	struct spa_list free_objects;
+	struct spa_thread_utils *thread_utils;
+};
+
+static struct globals globals;
+static bool mlock_warned = false;
+
+#define OBJECT_CHUNK		8
+#define RECYCLE_THRESHOLD	128
+
+typedef void (*mix_func) (float *dst, float *src[], uint32_t n_src, bool aligned, uint32_t n_samples);
+
+static mix_func mix_function;
+
+struct object {
+	struct spa_list link;
+
+	struct client *client;
+
+#define INTERFACE_Port		0
+#define INTERFACE_Node		1
+#define INTERFACE_Link		2
+	uint32_t type;
+	uint32_t id;
+	uint32_t serial;
+
+	union {
+		struct {
+			char name[JACK_CLIENT_NAME_SIZE+1];
+			char node_name[512];
+			int32_t priority;
+			uint32_t client_id;
+		} node;
+		struct {
+			uint32_t src;
+			uint32_t dst;
+			uint32_t src_serial;
+			uint32_t dst_serial;
+			bool src_ours;
+			bool dst_ours;
+			bool is_complete;
+			struct port *our_input;
+			struct port *our_output;
+		} port_link;
+		struct {
+			unsigned long flags;
+			char name[REAL_JACK_PORT_NAME_SIZE+1];
+			char alias1[REAL_JACK_PORT_NAME_SIZE+1];
+			char alias2[REAL_JACK_PORT_NAME_SIZE+1];
+			char system[REAL_JACK_PORT_NAME_SIZE+1];
+			uint32_t system_id;
+			uint32_t type_id;
+			uint32_t node_id;
+			uint32_t monitor_requests;
+			int32_t priority;
+			struct port *port;
+			bool is_monitor;
+			struct object *node;
+			struct spa_latency_info latency[2];
+		} port;
+	};
+	struct pw_proxy *proxy;
+	struct spa_hook proxy_listener;
+	struct spa_hook object_listener;
+	unsigned int removing:1;
+	unsigned int removed:1;
+};
+
+struct midi_buffer {
+#define MIDI_BUFFER_MAGIC 0x900df00d
+	uint32_t magic;
+	int32_t buffer_size;
+	uint32_t nframes;
+	int32_t write_pos;
+	uint32_t event_count;
+	uint32_t lost_events;
+};
+
+#define MIDI_INLINE_MAX	4
+
+struct midi_event {
+	uint16_t time;
+        uint16_t size;
+        union {
+		uint32_t byte_offset;
+		uint8_t inline_data[MIDI_INLINE_MAX];
+	};
+};
+
+struct buffer {
+	struct spa_list link;
+#define BUFFER_FLAG_OUT		(1<<0)
+#define BUFFER_FLAG_MAPPED	(1<<1)
+	uint32_t flags;
+	uint32_t id;
+
+	struct spa_data datas[MAX_BUFFER_DATAS];
+	uint32_t n_datas;
+
+	struct pw_memmap *mem[MAX_BUFFER_DATAS+1];
+	uint32_t n_mem;
+};
+
+struct mix {
+	struct spa_list link;
+	struct spa_list port_link;
+	uint32_t id;
+	uint32_t peer_id;
+	struct port *port;
+	struct port *peer_port;
+
+	struct spa_io_buffers *io;
+
+	struct buffer buffers[MAX_BUFFERS];
+	uint32_t n_buffers;
+	struct spa_list queue;
+};
+
+struct port {
+	bool valid;
+	struct spa_list link;
+
+	struct client *client;
+
+	enum spa_direction direction;
+	uint32_t port_id;
+	struct object *object;
+	struct pw_properties *props;
+	struct spa_port_info info;
+#define IDX_EnumFormat	0
+#define IDX_Buffers	1
+#define IDX_IO		2
+#define IDX_Format	3
+#define IDX_Latency	4
+#define N_PORT_PARAMS	5
+	struct spa_param_info params[N_PORT_PARAMS];
+
+	struct spa_io_buffers io;
+	struct spa_list mix;
+	struct mix *global_mix;
+
+	unsigned int empty_out:1;
+	unsigned int zeroed:1;
+
+	float *emptyptr;
+	float empty[MAX_BUFFER_FRAMES + MAX_ALIGN];
+
+	void *(*get_buffer) (struct port *p, jack_nframes_t frames);
+};
+
+struct link {
+	struct spa_list link;
+	struct spa_list target_link;
+	struct client *client;
+	uint32_t node_id;
+	struct pw_memmap *mem;
+	struct pw_node_activation *activation;
+	int signalfd;
+};
+
+struct context {
+	struct pw_loop *l;
+	struct pw_thread_loop *loop;	/* thread_lock protects all below */
+	struct pw_context *context;
+
+	struct spa_thread_utils *old_thread_utils;
+	struct spa_thread_utils thread_utils;
+	pthread_mutex_t lock;		/* protects map and lists below, in addition to thread_lock */
+	struct spa_list objects;
+	uint32_t free_count;
+};
+
+#define GET_DIRECTION(f)	((f) & JackPortIsInput ? SPA_DIRECTION_INPUT : SPA_DIRECTION_OUTPUT)
+
+#define GET_PORT(c,d,p)		(pw_map_lookup(&c->ports[d], p))
+
+struct metadata {
+	struct pw_metadata *proxy;
+	struct spa_hook proxy_listener;
+	struct spa_hook listener;
+
+	char default_audio_sink[1024];
+	char default_audio_source[1024];
+};
+
+struct client {
+	char name[JACK_CLIENT_NAME_SIZE+1];
+
+	struct context context;
+
+	char *server_name;
+	char *load_name;		/* load module name */
+	char *load_init;		/* initialization string */
+	jack_uuid_t session_id;		/* requested session_id */
+
+	struct pw_data_loop *loop;
+	struct pw_properties *props;
+
+	struct pw_core *core;
+	struct spa_hook core_listener;
+	struct pw_mempool *pool;
+	int pending_sync;
+	int last_sync;
+	int last_res;
+
+	struct spa_node_info info;
+
+	struct pw_registry *registry;
+	struct spa_hook registry_listener;
+
+	struct pw_client_node *node;
+	struct spa_hook node_listener;
+        struct spa_hook proxy_listener;
+
+	struct metadata *metadata;
+	struct metadata *settings;
+
+	uint32_t node_id;
+	uint32_t serial;
+	struct spa_source *socket_source;
+
+	JackThreadCallback thread_callback;
+	void *thread_arg;
+	JackThreadInitCallback thread_init_callback;
+	void *thread_init_arg;
+	JackShutdownCallback shutdown_callback;
+	void *shutdown_arg;
+	JackInfoShutdownCallback info_shutdown_callback;
+	void *info_shutdown_arg;
+	JackProcessCallback process_callback;
+	void *process_arg;
+	JackFreewheelCallback freewheel_callback;
+	void *freewheel_arg;
+	JackBufferSizeCallback bufsize_callback;
+	void *bufsize_arg;
+	JackSampleRateCallback srate_callback;
+	void *srate_arg;
+	JackClientRegistrationCallback registration_callback;
+	void *registration_arg;
+	JackPortRegistrationCallback portregistration_callback;
+	void *portregistration_arg;
+	JackPortConnectCallback connect_callback;
+	void *connect_arg;
+	JackPortRenameCallback rename_callback;
+	void *rename_arg;
+	JackGraphOrderCallback graph_callback;
+	void *graph_arg;
+	JackXRunCallback xrun_callback;
+	void *xrun_arg;
+	JackLatencyCallback latency_callback;
+	void *latency_arg;
+	JackSyncCallback sync_callback;
+	void *sync_arg;
+	JackTimebaseCallback timebase_callback;
+	void *timebase_arg;
+	JackPropertyChangeCallback property_callback;
+	void *property_arg;
+
+	struct spa_io_position *position;
+	uint32_t sample_rate;
+	uint32_t buffer_frames;
+	struct spa_fraction latency;
+
+	struct spa_list mix;
+	struct spa_list free_mix;
+
+	struct spa_list free_ports;
+	struct pw_map ports[2];
+
+	struct spa_list links;
+	uint32_t driver_id;
+	struct pw_node_activation *driver_activation;
+
+	struct pw_memmap *mem;
+	struct pw_node_activation *activation;
+	uint32_t xrun_count;
+
+	struct {
+		struct spa_io_position *position;
+		struct pw_node_activation *driver_activation;
+		struct spa_list target_links;
+	} rt;
+
+	pthread_mutex_t rt_lock;
+	unsigned int rt_locked:1;
+	unsigned int data_locked:1;
+
+	unsigned int started:1;
+	unsigned int active:1;
+	unsigned int destroyed:1;
+	unsigned int first:1;
+	unsigned int thread_entered:1;
+	unsigned int has_transport:1;
+	unsigned int allow_mlock:1;
+	unsigned int warn_mlock:1;
+	unsigned int timeowner_conditional:1;
+	unsigned int show_monitor:1;
+	unsigned int merge_monitor:1;
+	unsigned int short_name:1;
+	unsigned int filter_name:1;
+	unsigned int freewheeling:1;
+	unsigned int locked_process:1;
+	unsigned int default_as_system:1;
+	int self_connect_mode;
+	int rt_max;
+	unsigned int fix_midi_events:1;
+	unsigned int global_buffer_size:1;
+	char filter_char;
+
+	jack_position_t jack_position;
+	jack_transport_state_t jack_state;
+};
+
+static int do_sync(struct client *client);
+static struct object *find_by_serial(struct client *c, uint32_t serial);
+
+#include "metadata.c"
+
+int pw_jack_match_rules(const char *rules, size_t size, const struct spa_dict *props,
+		int (*matched) (void *data, const char *action, const char *val, int len),
+		void *data);
+
+static struct object * alloc_object(struct client *c, int type)
+{
+	struct object *o;
+	int i;
+
+	pthread_mutex_lock(&globals.lock);
+	if (spa_list_is_empty(&globals.free_objects)) {
+		o = calloc(OBJECT_CHUNK, sizeof(struct object));
+		if (o == NULL) {
+			pthread_mutex_unlock(&globals.lock);
+			return NULL;
+		}
+		for (i = 0; i < OBJECT_CHUNK; i++)
+			spa_list_append(&globals.free_objects, &o[i].link);
+	}
+	o = spa_list_first(&globals.free_objects, struct object, link);
+	spa_list_remove(&o->link);
+	pthread_mutex_unlock(&globals.lock);
+
+	o->client = c;
+	o->removed = false;
+	o->type = type;
+	pw_log_debug("%p: object:%p type:%d", c, o, type);
+
+	return o;
+}
+
+static void recycle_objects(struct client *c, uint32_t remain)
+{
+	struct object *o, *t;
+	pthread_mutex_lock(&globals.lock);
+	spa_list_for_each_safe(o, t, &c->context.objects, link) {
+		if (o->removed) {
+			pw_log_info("%p: recycle object:%p type:%d id:%u/%u",
+					c, o, o->type, o->id, o->serial);
+			spa_list_remove(&o->link);
+			memset(o, 0, sizeof(struct object));
+			spa_list_append(&globals.free_objects, &o->link);
+			if (--c->context.free_count == remain)
+				break;
+		}
+	}
+	pthread_mutex_unlock(&globals.lock);
+}
+
+/* JACK clients expect the objects to hang around after
+ * they are unregistered and freed. We mark the object removed and
+ * move it to the end of the queue. */
+static void free_object(struct client *c, struct object *o)
+{
+	pw_log_debug("%p: object:%p type:%d", c, o, o->type);
+	pthread_mutex_lock(&c->context.lock);
+	spa_list_remove(&o->link);
+	o->removed = true;
+	o->id = SPA_ID_INVALID;
+	spa_list_append(&c->context.objects, &o->link);
+	if (++c->context.free_count > RECYCLE_THRESHOLD)
+		recycle_objects(c, RECYCLE_THRESHOLD / 2);
+	pthread_mutex_unlock(&c->context.lock);
+
+}
+
+static void init_mix(struct mix *mix, uint32_t mix_id, struct port *port)
+{
+	mix->id = mix_id;
+	mix->port = port;
+	mix->io = NULL;
+	mix->n_buffers = 0;
+	spa_list_init(&mix->queue);
+	if (mix_id == SPA_ID_INVALID)
+		port->global_mix = mix;
+}
+static struct mix *find_mix_peer(struct client *c, uint32_t peer_id)
+{
+	struct mix *mix;
+	spa_list_for_each(mix, &c->mix, link) {
+		if (mix->peer_id == peer_id)
+			return mix;
+	}
+	return NULL;
+}
+
+static struct mix *find_mix(struct client *c, struct port *port, uint32_t mix_id)
+{
+	struct mix *mix;
+
+	spa_list_for_each(mix, &port->mix, port_link) {
+		if (mix->id == mix_id)
+			return mix;
+	}
+	return NULL;
+}
+
+static struct mix *ensure_mix(struct client *c, struct port *port, uint32_t mix_id)
+{
+	struct mix *mix;
+	uint32_t i;
+
+	if ((mix = find_mix(c, port, mix_id)) != NULL)
+		return mix;
+
+	if (spa_list_is_empty(&c->free_mix)) {
+		mix = calloc(OBJECT_CHUNK, sizeof(struct mix));
+		if (mix == NULL)
+			return NULL;
+		for (i = 0; i < OBJECT_CHUNK; i++)
+			spa_list_append(&c->free_mix, &mix[i].link);
+	}
+	mix = spa_list_first(&c->free_mix, struct mix, link);
+	spa_list_remove(&mix->link);
+	spa_list_append(&c->mix, &mix->link);
+
+	spa_list_append(&port->mix, &mix->port_link);
+
+	init_mix(mix, mix_id, port);
+
+	return mix;
+}
+
+static int clear_buffers(struct client *c, struct mix *mix)
+{
+	struct port *port = mix->port;
+	struct buffer *b;
+	uint32_t i, j;
+
+	pw_log_debug("%p: port %p clear buffers", c, port);
+
+	for (i = 0; i < mix->n_buffers; i++) {
+		b = &mix->buffers[i];
+
+		for (j = 0; j < b->n_mem; j++)
+			pw_memmap_free(b->mem[j]);
+
+		b->n_mem = 0;
+	}
+	mix->n_buffers = 0;
+	spa_list_init(&mix->queue);
+	return 0;
+}
+
+static void free_mix(struct client *c, struct mix *mix)
+{
+	clear_buffers(c, mix);
+	spa_list_remove(&mix->port_link);
+	if (mix->id == SPA_ID_INVALID)
+		mix->port->global_mix = NULL;
+	spa_list_remove(&mix->link);
+	spa_list_append(&c->free_mix, &mix->link);
+}
+
+static struct port * alloc_port(struct client *c, enum spa_direction direction)
+{
+	struct port *p;
+	struct object *o;
+	uint32_t i;
+
+	if (spa_list_is_empty(&c->free_ports)) {
+		p = calloc(OBJECT_CHUNK, sizeof(struct port));
+		if (p == NULL)
+			return NULL;
+		for (i = 0; i < OBJECT_CHUNK; i++)
+			spa_list_append(&c->free_ports, &p[i].link);
+	}
+	p = spa_list_first(&c->free_ports, struct port, link);
+	spa_list_remove(&p->link);
+
+	o = alloc_object(c, INTERFACE_Port);
+	o->id = SPA_ID_INVALID;
+	o->port.node_id = c->node_id;
+	o->port.port = p;
+	o->port.latency[SPA_DIRECTION_INPUT] = SPA_LATENCY_INFO(SPA_DIRECTION_INPUT);
+	o->port.latency[SPA_DIRECTION_OUTPUT] = SPA_LATENCY_INFO(SPA_DIRECTION_OUTPUT);
+
+	p->valid = true;
+	p->zeroed = false;
+	p->client = c;
+	p->object = o;
+	spa_list_init(&p->mix);
+	p->props = pw_properties_new(NULL, NULL);
+
+	p->direction = direction;
+	p->emptyptr = SPA_PTR_ALIGN(p->empty, MAX_ALIGN, float);
+	p->port_id = pw_map_insert_new(&c->ports[direction], p);
+
+	pthread_mutex_lock(&c->context.lock);
+	spa_list_append(&c->context.objects, &o->link);
+	pthread_mutex_unlock(&c->context.lock);
+
+	return p;
+}
+
+static void free_port(struct client *c, struct port *p)
+{
+	struct mix *m;
+
+	spa_list_consume(m, &p->mix, port_link)
+		free_mix(c, m);
+
+	pw_map_remove(&c->ports[p->direction], p->port_id);
+	free_object(c, p->object);
+	pw_properties_free(p->props);
+	spa_list_append(&c->free_ports, &p->link);
+}
+
+static struct object *find_node(struct client *c, const char *name)
+{
+	struct object *o;
+
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->removing || o->removed || o->type != INTERFACE_Node)
+			continue;
+		if (spa_streq(o->node.name, name))
+			return o;
+	}
+	return NULL;
+}
+
+static bool is_port_default(struct client *c, struct object *o)
+{
+	struct object *ot;
+
+	if (c->metadata == NULL)
+		return false;
+
+	if ((ot = o->port.node) != NULL &&
+	    (spa_streq(ot->node.node_name, c->metadata->default_audio_source) ||
+	     spa_streq(ot->node.node_name, c->metadata->default_audio_sink)))
+		return true;
+
+	return false;
+}
+
+static struct object *find_port_by_name(struct client *c, const char *name)
+{
+	struct object *o;
+
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->type != INTERFACE_Port || o->removed)
+			continue;
+		if (spa_streq(o->port.name, name) ||
+		    spa_streq(o->port.alias1, name) ||
+		    spa_streq(o->port.alias2, name))
+			return o;
+		if (is_port_default(c, o) && spa_streq(o->port.system, name))
+			return o;
+	}
+	return NULL;
+}
+
+static struct object *find_by_id(struct client *c, uint32_t id)
+{
+	struct object *o;
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->id == id)
+			return o;
+	}
+	return NULL;
+}
+
+static struct object *find_by_serial(struct client *c, uint32_t serial)
+{
+	struct object *o;
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->serial == serial)
+			return o;
+	}
+	return NULL;
+}
+
+static struct object *find_id(struct client *c, uint32_t id, bool valid)
+{
+	struct object *o = find_by_id(c, id);
+	if (o != NULL && (!valid || o->client == c))
+		return o;
+	return NULL;
+}
+
+static struct object *find_type(struct client *c, uint32_t id, uint32_t type, bool valid)
+{
+	struct object *o = find_id(c, id, valid);
+	if (o != NULL && o->type == type)
+		return o;
+	return NULL;
+}
+
+static struct object *find_link(struct client *c, uint32_t src, uint32_t dst)
+{
+	struct object *l;
+
+	spa_list_for_each(l, &c->context.objects, link) {
+		if (l->type != INTERFACE_Link || l->removed)
+			continue;
+		if (l->port_link.src == src &&
+		    l->port_link.dst == dst) {
+			return l;
+		}
+	}
+	return NULL;
+}
+
+static struct buffer *dequeue_buffer(struct client *c, struct mix *mix)
+{
+	struct buffer *b;
+
+	if (SPA_UNLIKELY(spa_list_is_empty(&mix->queue)))
+		return NULL;
+
+	b = spa_list_first(&mix->queue, struct buffer, link);
+	spa_list_remove(&b->link);
+	SPA_FLAG_SET(b->flags, BUFFER_FLAG_OUT);
+	pw_log_trace_fp("%p: port %p: dequeue buffer %d", c, mix->port, b->id);
+
+	return b;
+}
+
+#if defined (__SSE__)
+#include <xmmintrin.h>
+static void mix_sse(float *dst, float *src[], uint32_t n_src, bool aligned, uint32_t n_samples)
+{
+	uint32_t i, n, unrolled;
+	__m128 in[1];
+
+	if (SPA_IS_ALIGNED(dst, 16) && aligned)
+		unrolled = n_samples & ~3;
+	else
+		unrolled = 0;
+
+	for (n = 0; n < unrolled; n += 4) {
+		in[0] = _mm_load_ps(&src[0][n]);
+		for (i = 1; i < n_src; i++)
+			in[0] = _mm_add_ps(in[0], _mm_load_ps(&src[i][n]));
+		_mm_store_ps(&dst[n], in[0]);
+	}
+	for (; n < n_samples; n++) {
+		in[0] = _mm_load_ss(&src[0][n]);
+		for (i = 1; i < n_src; i++)
+			in[0] = _mm_add_ss(in[0], _mm_load_ss(&src[i][n]));
+		_mm_store_ss(&dst[n], in[0]);
+	}
+}
+#endif
+
+static void mix_c(float *dst, float *src[], uint32_t n_src, bool aligned, uint32_t n_samples)
+{
+	uint32_t n, i;
+	for (n = 0; n < n_samples; n++)  {
+		float t = src[0][n];
+		for (i = 1; i < n_src; i++)
+			t += src[i][n];
+		dst[n] = t;
+	}
+}
+
+SPA_EXPORT
+void jack_get_version(int *major_ptr, int *minor_ptr, int *micro_ptr, int *proto_ptr)
+{
+	if (major_ptr)
+		*major_ptr = 3;
+	if (minor_ptr)
+		*minor_ptr = 0;
+	if (micro_ptr)
+		*micro_ptr = 0;
+	if (proto_ptr)
+		*proto_ptr = 0;
+}
+
+#define do_callback_expr(c,expr,callback,...)			\
+({								\
+	if (c->callback && c->active) {				\
+		pw_thread_loop_unlock(c->context.loop);		\
+		if (c->locked_process)				\
+			pthread_mutex_lock(&c->rt_lock);	\
+		(expr);						\
+		pw_log_debug("emit " #callback);		\
+		c->callback(__VA_ARGS__);			\
+		if (c->locked_process)				\
+			pthread_mutex_unlock(&c->rt_lock);	\
+		pw_thread_loop_lock(c->context.loop);		\
+	} else {						\
+		if (c->active)					\
+			(expr);					\
+		pw_log_debug("skip " #callback			\
+			" cb:%p active:%d", c->callback,	\
+			c->active);				\
+	}							\
+})
+
+#define do_callback(c,callback,...) do_callback_expr(c,(void)0,callback,__VA_ARGS__)
+
+#define do_rt_callback_res(c,callback,...)			\
+({								\
+	int res = 0;						\
+	if (c->callback) {					\
+		if (pthread_mutex_trylock(&c->rt_lock) == 0) {	\
+			c->rt_locked = true;			\
+			res = c->callback(__VA_ARGS__);		\
+			c->rt_locked = false;			\
+			pthread_mutex_unlock(&c->rt_lock);	\
+		} else {					\
+			pw_log_debug("skip " #callback		\
+				" cb:%p", c->callback);		\
+		}						\
+	}							\
+	res;							\
+})
+
+SPA_EXPORT
+const char *
+jack_get_version_string(void)
+{
+	static char name[1024];
+	snprintf(name, sizeof(name), "3.0.0.0 (using PipeWire %s)", pw_get_library_version());
+	return name;
+}
+
+static void on_sync_reply(void *data, uint32_t id, int seq)
+{
+	struct client *client = data;
+	if (id != PW_ID_CORE)
+		return;
+	client->last_sync = seq;
+	if (client->pending_sync == seq)
+		pw_thread_loop_signal(client->context.loop, false);
+}
+
+
+static void on_error(void *data, uint32_t id, int seq, int res, const char *message)
+{
+	struct client *client = data;
+
+	pw_log_warn("%p: error id:%u seq:%d res:%d (%s): %s", client,
+			id, seq, res, spa_strerror(res), message);
+
+	if (id == PW_ID_CORE) {
+		client->last_res = res;
+		if (!client->destroyed)
+			do_callback(client, shutdown_callback, client->shutdown_arg);
+	}
+	pw_thread_loop_signal(client->context.loop, false);
+}
+
+static const struct pw_core_events core_events = {
+	PW_VERSION_CORE_EVENTS,
+	.done = on_sync_reply,
+	.error = on_error,
+};
+
+static int do_sync(struct client *client)
+{
+	bool in_data_thread = pw_data_loop_in_thread(client->loop);
+
+	if (pw_thread_loop_in_thread(client->context.loop)) {
+		pw_log_warn("sync requested from callback");
+		return 0;
+	}
+	if (client->last_res == -EPIPE)
+		return -EPIPE;
+
+	client->last_res = 0;
+	client->pending_sync = pw_proxy_sync((struct pw_proxy*)client->core, client->pending_sync);
+
+	while (true) {
+		if (in_data_thread) {
+			if (client->rt_locked)
+				pthread_mutex_unlock(&client->rt_lock);
+			client->data_locked = true;
+		}
+	        pw_thread_loop_wait(client->context.loop);
+
+		if (in_data_thread) {
+			client->data_locked = false;
+			if (client->rt_locked)
+				pthread_mutex_lock(&client->rt_lock);
+		}
+
+		if (client->last_res < 0)
+			return client->last_res;
+
+		if (client->pending_sync == client->last_sync)
+			break;
+	}
+	return 0;
+}
+
+static void on_node_removed(void *data)
+{
+	struct client *client = data;
+	pw_proxy_destroy((struct pw_proxy*)client->node);
+}
+
+static void on_node_destroy(void *data)
+{
+	struct client *client = data;
+	client->node = NULL;
+	spa_hook_remove(&client->proxy_listener);
+	spa_hook_remove(&client->node_listener);
+}
+
+static void on_node_bound(void *data, uint32_t global_id)
+{
+	struct client *client = data;
+	client->node_id = global_id;
+}
+
+static const struct pw_proxy_events node_proxy_events = {
+	PW_VERSION_PROXY_EVENTS,
+	.removed = on_node_removed,
+	.destroy = on_node_destroy,
+	.bound = on_node_bound,
+};
+
+static struct link *find_activation(struct spa_list *links, uint32_t node_id)
+{
+	struct link *l;
+
+	spa_list_for_each(l, links, link) {
+		if (l->node_id == node_id)
+			return l;
+	}
+	return NULL;
+}
+
+static void client_remove_source(struct client *c)
+{
+	if (c->socket_source) {
+		pw_loop_destroy_source(c->loop->loop, c->socket_source);
+		c->socket_source = NULL;
+	}
+}
+
+static int
+do_remove_sources(struct spa_loop *loop,
+                  bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct client *c = user_data;
+	client_remove_source(c);
+	return 0;
+}
+
+static inline void reuse_buffer(struct client *c, struct mix *mix, uint32_t id)
+{
+	struct buffer *b;
+
+	b = &mix->buffers[id];
+
+	if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_OUT)) {
+		pw_log_trace_fp("%p: port %p: recycle buffer %d", c, mix->port, id);
+		spa_list_append(&mix->queue, &b->link);
+		SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_OUT);
+	}
+}
+
+
+static size_t convert_from_midi(void *midi, void *buffer, size_t size)
+{
+	struct spa_pod_builder b = { 0, };
+	uint32_t i, count;
+	struct spa_pod_frame f;
+
+	count = jack_midi_get_event_count(midi);
+
+	spa_pod_builder_init(&b, buffer, size);
+	spa_pod_builder_push_sequence(&b, &f, 0);
+
+	for (i = 0; i < count; i++) {
+		jack_midi_event_t ev;
+		jack_midi_event_get(&ev, midi, i);
+		spa_pod_builder_control(&b, ev.time, SPA_CONTROL_Midi);
+		spa_pod_builder_bytes(&b, ev.buffer, ev.size);
+	}
+	spa_pod_builder_pop(&b, &f);
+	return b.state.offset;
+}
+
+static inline void fix_midi_event(uint8_t *data, size_t size)
+{
+	/* fixup NoteOn with vel 0 */
+	if (size > 2 && (data[0] & 0xF0) == 0x90 && data[2] == 0x00) {
+		data[0] = 0x80 + (data[0] & 0x0F);
+		data[2] = 0x40;
+	}
+}
+
+static inline int event_sort(struct spa_pod_control *a, struct spa_pod_control *b)
+{
+	if (a->offset < b->offset)
+		return -1;
+	if (a->offset > b->offset)
+		return 1;
+	if (a->type != b->type)
+		return 0;
+	switch(a->type) {
+	case SPA_CONTROL_Midi:
+	{
+		/* 11 (controller) > 12 (program change) >
+		 * 8 (note off) > 9 (note on) > 10 (aftertouch) >
+		 * 13 (channel pressure) > 14 (pitch bend) */
+		static int priotab[] = { 5,4,3,7,6,2,1,0 };
+		uint8_t *da, *db;
+
+		if (SPA_POD_BODY_SIZE(&a->value) < 1 ||
+		    SPA_POD_BODY_SIZE(&b->value) < 1)
+			return 0;
+
+		da = SPA_POD_BODY(&a->value);
+		db = SPA_POD_BODY(&b->value);
+		if ((da[0] & 0xf) != (db[0] & 0xf))
+			return 0;
+		return priotab[(db[0]>>4) & 7] - priotab[(da[0]>>4) & 7];
+	}
+	default:
+		return 0;
+	}
+}
+
+static void convert_to_midi(struct spa_pod_sequence **seq, uint32_t n_seq, void *midi, bool fix)
+{
+	struct spa_pod_control *c[n_seq];
+	uint32_t i;
+	int res;
+
+	for (i = 0; i < n_seq; i++)
+		c[i] = spa_pod_control_first(&seq[i]->body);
+
+	while (true) {
+		struct spa_pod_control *next = NULL;
+		uint32_t next_index = 0;
+
+		for (i = 0; i < n_seq; i++) {
+			if (!spa_pod_control_is_inside(&seq[i]->body,
+						SPA_POD_BODY_SIZE(seq[i]), c[i]))
+				continue;
+
+			if (next == NULL || event_sort(c[i], next) <= 0) {
+				next = c[i];
+				next_index = i;
+			}
+		}
+		if (SPA_UNLIKELY(next == NULL))
+			break;
+
+		switch(next->type) {
+		case SPA_CONTROL_Midi:
+		{
+			uint8_t *data = SPA_POD_BODY(&next->value);
+			size_t size = SPA_POD_BODY_SIZE(&next->value);
+
+			if (fix)
+				fix_midi_event(data, size);
+
+			if ((res = jack_midi_event_write(midi, next->offset, data, size)) < 0)
+				pw_log_warn("midi %p: can't write event: %s", midi,
+						spa_strerror(res));
+			break;
+		}
+		}
+		c[next_index] = spa_pod_control_next(c[next_index]);
+	}
+}
+
+
+static inline void *get_buffer_output(struct port *p, uint32_t frames, uint32_t stride, struct buffer **buf)
+{
+	struct mix *mix;
+	struct client *c = p->client;
+	void *ptr = NULL;
+	struct buffer *b;
+	struct spa_data *d;
+
+	if (frames == 0 || !p->valid)
+		return NULL;
+
+	if (SPA_UNLIKELY((mix = p->global_mix) == NULL))
+		return NULL;
+
+	pw_log_trace_fp("%p: port %s %d get buffer %d n_buffers:%d",
+			c, p->object->port.name, p->port_id, frames, mix->n_buffers);
+
+	if (SPA_UNLIKELY(mix->n_buffers == 0))
+		return NULL;
+
+	if (p->io.status == SPA_STATUS_HAVE_DATA &&
+	    p->io.buffer_id < mix->n_buffers) {
+		b = &mix->buffers[p->io.buffer_id];
+		d = &b->datas[0];
+	} else {
+		if (p->io.buffer_id < mix->n_buffers) {
+			reuse_buffer(c, mix, p->io.buffer_id);
+			p->io.buffer_id = SPA_ID_INVALID;
+		}
+		if (SPA_UNLIKELY((b = dequeue_buffer(c, mix)) == NULL)) {
+			pw_log_warn("port %p: out of buffers", p);
+			return NULL;
+		}
+		d = &b->datas[0];
+		d->chunk->offset = 0;
+		d->chunk->size = frames * sizeof(float);
+		d->chunk->stride = stride;
+
+		p->io.status = SPA_STATUS_HAVE_DATA;
+		p->io.buffer_id = b->id;
+	}
+	ptr = d->data;
+	if (buf)
+		*buf = b;
+	return ptr;
+}
+
+static inline void process_empty(struct port *p, uint32_t frames)
+{
+	void *ptr;
+
+	switch (p->object->port.type_id) {
+	case TYPE_ID_AUDIO:
+		ptr = get_buffer_output(p, frames, sizeof(float), NULL);
+		if (SPA_LIKELY(ptr != NULL))
+			memcpy(ptr, p->emptyptr, frames * sizeof(float));
+		break;
+	case TYPE_ID_MIDI:
+	{
+		struct buffer *b;
+		ptr = get_buffer_output(p, MAX_BUFFER_FRAMES, 1, &b);
+		if (SPA_LIKELY(ptr != NULL)) {
+			b->datas[0].chunk->size = convert_from_midi(p->emptyptr,
+					ptr, MAX_BUFFER_FRAMES * sizeof(float));
+		}
+		break;
+	}
+	default:
+		pw_log_warn("port %p: unhandled format %d", p, p->object->port.type_id);
+		break;
+	}
+}
+
+static void prepare_output(struct port *p, uint32_t frames)
+{
+	struct mix *mix;
+
+	if (SPA_UNLIKELY(p->empty_out))
+		process_empty(p, frames);
+
+	spa_list_for_each(mix, &p->mix, port_link) {
+		if (SPA_LIKELY(mix->io != NULL))
+			*mix->io = p->io;
+	}
+}
+
+static void complete_process(struct client *c, uint32_t frames)
+{
+	struct port *p;
+	struct mix *mix;
+	union pw_map_item *item;
+
+	pw_array_for_each(item, &c->ports[SPA_DIRECTION_INPUT].items) {
+                if (pw_map_item_is_free(item))
+			continue;
+		p = item->data;
+		if (!p->valid)
+			continue;
+		spa_list_for_each(mix, &p->mix, port_link) {
+			if (SPA_LIKELY(mix->io != NULL))
+				mix->io->status = SPA_STATUS_NEED_DATA;
+		}
+        }
+	pw_array_for_each(item, &c->ports[SPA_DIRECTION_OUTPUT].items) {
+                if (pw_map_item_is_free(item))
+			continue;
+		p = item->data;
+		if (!p->valid)
+			continue;
+		prepare_output(p, frames);
+		p->io.status = SPA_STATUS_NEED_DATA;
+	}
+}
+
+static inline void debug_position(struct client *c, jack_position_t *p)
+{
+	pw_log_trace("usecs:       %"PRIu64, p->usecs);
+	pw_log_trace("frame_rate:  %u", p->frame_rate);
+	pw_log_trace("frame:       %u", p->frame);
+	pw_log_trace("valid:       %08x", p->valid);
+
+	if (p->valid & JackPositionBBT) {
+		pw_log_trace("BBT");
+		pw_log_trace(" bar:              %u", p->bar);
+		pw_log_trace(" beat:             %u", p->beat);
+		pw_log_trace(" tick:             %u", p->tick);
+		pw_log_trace(" bar_start_tick:   %f", p->bar_start_tick);
+		pw_log_trace(" beats_per_bar:    %f", p->beats_per_bar);
+		pw_log_trace(" beat_type:        %f", p->beat_type);
+		pw_log_trace(" ticks_per_beat:   %f", p->ticks_per_beat);
+		pw_log_trace(" beats_per_minute: %f", p->beats_per_minute);
+	}
+	if (p->valid & JackPositionTimecode) {
+		pw_log_trace("Timecode:");
+		pw_log_trace(" frame_time:       %f", p->frame_time);
+		pw_log_trace(" next_time:        %f", p->next_time);
+	}
+	if (p->valid & JackBBTFrameOffset) {
+		pw_log_trace("BBTFrameOffset:");
+		pw_log_trace(" bbt_offset:       %u", p->bbt_offset);
+	}
+	if (p->valid & JackAudioVideoRatio) {
+		pw_log_trace("AudioVideoRatio:");
+		pw_log_trace(" audio_frames_per_video_frame: %f", p->audio_frames_per_video_frame);
+	}
+	if (p->valid & JackVideoFrameOffset) {
+		pw_log_trace("JackVideoFrameOffset:");
+		pw_log_trace(" video_offset:     %u", p->video_offset);
+	}
+}
+
+static inline void jack_to_position(jack_position_t *s, struct pw_node_activation *a)
+{
+	struct spa_io_segment *d = &a->segment;
+
+	if (s->valid & JackPositionBBT) {
+		d->bar.flags = SPA_IO_SEGMENT_BAR_FLAG_VALID;
+		if (s->valid & JackBBTFrameOffset)
+			d->bar.offset = s->bbt_offset;
+		else
+			d->bar.offset = 0;
+		d->bar.signature_num = s->beats_per_bar;
+		d->bar.signature_denom = s->beat_type;
+		d->bar.bpm = s->beats_per_minute;
+		d->bar.beat = (s->bar - 1) * s->beats_per_bar + (s->beat - 1) +
+			(s->tick / s->ticks_per_beat);
+	}
+}
+
+static inline jack_transport_state_t position_to_jack(struct pw_node_activation *a, jack_position_t *d)
+{
+	struct spa_io_position *s = &a->position;
+	jack_transport_state_t state;
+	struct spa_io_segment *seg = &s->segments[0];
+	uint64_t running;
+
+	switch (s->state) {
+	default:
+	case SPA_IO_POSITION_STATE_STOPPED:
+		state = JackTransportStopped;
+		break;
+	case SPA_IO_POSITION_STATE_STARTING:
+		state = JackTransportStarting;
+		break;
+	case SPA_IO_POSITION_STATE_RUNNING:
+		if (seg->flags & SPA_IO_SEGMENT_FLAG_LOOPING)
+			state = JackTransportLooping;
+		else
+			state = JackTransportRolling;
+		break;
+	}
+	if (SPA_UNLIKELY(d == NULL))
+		return state;
+
+	d->unique_1++;
+	d->usecs = s->clock.nsec / SPA_NSEC_PER_USEC;
+	d->frame_rate = s->clock.rate.denom;
+
+	if ((int64_t)s->clock.position < s->offset) {
+		d->frame = seg->position;
+	} else {
+		running = s->clock.position - s->offset;
+		if (running >= seg->start &&
+		    (seg->duration == 0 || running < seg->start + seg->duration))
+			d->frame = (running - seg->start) * seg->rate + seg->position;
+		else
+			d->frame = seg->position;
+	}
+	d->valid = 0;
+	if (a->segment_owner[0] && SPA_FLAG_IS_SET(seg->bar.flags, SPA_IO_SEGMENT_BAR_FLAG_VALID)) {
+		double abs_beat;
+		long beats;
+
+		d->valid |= JackPositionBBT;
+
+		d->bbt_offset = seg->bar.offset;
+		if (seg->bar.offset)
+			d->valid |= JackBBTFrameOffset;
+
+		d->beats_per_bar = seg->bar.signature_num;
+		d->beat_type = seg->bar.signature_denom;
+		d->ticks_per_beat = 1920.0f;
+		d->beats_per_minute = seg->bar.bpm;
+
+		abs_beat = seg->bar.beat;
+
+		d->bar = abs_beat / d->beats_per_bar;
+		beats = d->bar * d->beats_per_bar;
+		d->bar_start_tick = beats * d->ticks_per_beat;
+		d->beat = abs_beat - beats;
+		beats += d->beat;
+		d->tick = (abs_beat - beats) * d->ticks_per_beat;
+		d->bar++;
+		d->beat++;
+	}
+	d->unique_2 = d->unique_1;
+	return state;
+}
+
+static void recompute_latencies(struct client *c)
+{
+	do_callback(c, latency_callback, JackCaptureLatency, c->latency_arg);
+	do_callback(c, latency_callback, JackPlaybackLatency, c->latency_arg);
+}
+
+static int
+do_buffer_frames(struct spa_loop *loop,
+		bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	uint32_t buffer_frames = *((uint32_t*)data);
+	struct client *c = user_data;
+	if (c->buffer_frames != buffer_frames)
+		do_callback_expr(c, c->buffer_frames = buffer_frames, bufsize_callback, buffer_frames, c->bufsize_arg);
+	recompute_latencies(c);
+	return 0;
+}
+
+static inline int check_buffer_frames(struct client *c, struct spa_io_position *pos)
+{
+	uint32_t buffer_frames = pos->clock.duration;
+	if (SPA_UNLIKELY(buffer_frames != c->buffer_frames)) {
+		pw_log_info("%p: bufferframes old:%d new:%d cb:%p", c,
+				c->buffer_frames, buffer_frames, c->bufsize_callback);
+		if (c->buffer_frames != (uint32_t)-1)
+			pw_loop_invoke(c->context.l, do_buffer_frames, 0,
+					&buffer_frames, sizeof(buffer_frames), false, c);
+		else
+			c->buffer_frames = buffer_frames;
+	}
+	return c->buffer_frames == buffer_frames;
+}
+
+static int
+do_sample_rate(struct spa_loop *loop,
+		bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct client *c = user_data;
+	uint32_t sample_rate = *((uint32_t*)data);
+	do_callback_expr(c, c->sample_rate = sample_rate, srate_callback, sample_rate, c->srate_arg);
+	return 0;
+}
+
+static inline int check_sample_rate(struct client *c, struct spa_io_position *pos)
+{
+	uint32_t sample_rate = pos->clock.rate.denom;
+	if (SPA_UNLIKELY(sample_rate != c->sample_rate)) {
+		pw_log_info("%p: sample_rate old:%d new:%d cb:%p", c,
+				c->sample_rate, sample_rate, c->srate_callback);
+		if (c->srate_callback != NULL) {
+			pw_loop_invoke(c->context.l, do_sample_rate, 0,
+					&sample_rate, sizeof(sample_rate), false, c);
+		} else {
+			c->sample_rate = sample_rate;
+		}
+	}
+	return c->sample_rate == sample_rate;
+}
+
+static inline uint32_t cycle_run(struct client *c)
+{
+	uint64_t cmd;
+	struct timespec ts;
+	int fd = c->socket_source->fd;
+	struct spa_io_position *pos = c->rt.position;
+	struct pw_node_activation *activation = c->activation;
+	struct pw_node_activation *driver = c->rt.driver_activation;
+
+	while (true) {
+		if (SPA_UNLIKELY(read(fd, &cmd, sizeof(cmd)) != sizeof(cmd))) {
+			if (errno == EINTR)
+				continue;
+			if (errno == EWOULDBLOCK || errno == EAGAIN)
+				return 0;
+			pw_log_warn("%p: read failed %m", c);
+		}
+		break;
+	}
+	if (SPA_UNLIKELY(cmd > 1))
+		pw_log_info("%p: missed %"PRIu64" wakeups", c, cmd - 1);
+
+	clock_gettime(CLOCK_MONOTONIC, &ts);
+	activation->status = PW_NODE_ACTIVATION_AWAKE;
+	activation->awake_time = SPA_TIMESPEC_TO_NSEC(&ts);
+
+	if (SPA_UNLIKELY(c->first)) {
+		if (c->thread_init_callback)
+			c->thread_init_callback(c->thread_init_arg);
+		c->first = false;
+	}
+
+	if (SPA_UNLIKELY(pos == NULL)) {
+		pw_log_error("%p: missing position", c);
+		return 0;
+	}
+
+	if (check_buffer_frames(c, pos) == 0)
+		return 0;
+	if (check_sample_rate(c, pos) == 0)
+		return 0;
+
+	if (SPA_LIKELY(driver)) {
+		c->jack_state = position_to_jack(driver, &c->jack_position);
+
+		if (SPA_UNLIKELY(activation->pending_sync)) {
+			if (c->sync_callback == NULL ||
+			    c->sync_callback(c->jack_state, &c->jack_position, c->sync_arg))
+				activation->pending_sync = false;
+		}
+		if (SPA_UNLIKELY(c->xrun_count != driver->xrun_count &&
+		    c->xrun_count != 0 && c->xrun_callback))
+			c->xrun_callback(c->xrun_arg);
+		c->xrun_count = driver->xrun_count;
+	}
+	pw_log_trace_fp("%p: wait %"PRIu64" frames:%d rate:%d pos:%d delay:%"PRIi64" corr:%f", c,
+			activation->awake_time, c->buffer_frames, c->sample_rate,
+			c->jack_position.frame, pos->clock.delay, pos->clock.rate_diff);
+
+	return c->buffer_frames;
+}
+
+static inline uint32_t cycle_wait(struct client *c)
+{
+	int res;
+	uint32_t nframes;
+
+	do {
+		res = pw_data_loop_wait(c->loop, -1);
+		if (SPA_UNLIKELY(res <= 0)) {
+			pw_log_warn("%p: wait error %m", c);
+			return 0;
+		}
+		nframes = cycle_run(c);
+	} while (!nframes);
+
+	return nframes;
+}
+
+static inline void signal_sync(struct client *c)
+{
+	struct timespec ts;
+	uint64_t cmd, nsec;
+	struct link *l;
+	struct pw_node_activation *activation = c->activation;
+
+	complete_process(c, c->buffer_frames);
+
+	clock_gettime(CLOCK_MONOTONIC, &ts);
+	nsec = SPA_TIMESPEC_TO_NSEC(&ts);
+	activation->status = PW_NODE_ACTIVATION_FINISHED;
+	activation->finish_time = nsec;
+
+	cmd = 1;
+	spa_list_for_each(l, &c->rt.target_links, target_link) {
+		struct pw_node_activation_state *state;
+
+		if (SPA_UNLIKELY(l->activation == NULL))
+			continue;
+
+		state = &l->activation->state[0];
+
+		pw_log_trace_fp("%p: link %p %p %d/%d", c, l, state,
+				state->pending, state->required);
+
+		if (pw_node_activation_state_dec(state, 1)) {
+			l->activation->status = PW_NODE_ACTIVATION_TRIGGERED;
+			l->activation->signal_time = nsec;
+
+			pw_log_trace_fp("%p: signal %p %p", c, l, state);
+
+			if (SPA_UNLIKELY(write(l->signalfd, &cmd, sizeof(cmd)) != sizeof(cmd)))
+				pw_log_warn("%p: write failed %m", c);
+		}
+	}
+}
+
+static inline void cycle_signal(struct client *c, int status)
+{
+	struct pw_node_activation *driver = c->rt.driver_activation;
+	struct pw_node_activation *activation = c->activation;
+
+	if (SPA_LIKELY(status == 0)) {
+		if (c->timebase_callback && driver && driver->segment_owner[0] == c->node_id) {
+			if (activation->pending_new_pos ||
+			    c->jack_state == JackTransportRolling ||
+			    c->jack_state == JackTransportLooping) {
+				c->timebase_callback(c->jack_state,
+						     c->buffer_frames,
+						     &c->jack_position,
+						     activation->pending_new_pos,
+						     c->timebase_arg);
+
+				activation->pending_new_pos = false;
+
+				debug_position(c, &c->jack_position);
+				jack_to_position(&c->jack_position, activation);
+			}
+		}
+	}
+	signal_sync(c);
+}
+
+static void
+on_rtsocket_condition(void *data, int fd, uint32_t mask)
+{
+	struct client *c = data;
+
+	if (SPA_UNLIKELY(mask & (SPA_IO_ERR | SPA_IO_HUP))) {
+		pw_log_warn("%p: got error", c);
+		client_remove_source(c);
+		return;
+	}
+	if (SPA_UNLIKELY(c->thread_callback)) {
+		if (!c->thread_entered) {
+			c->thread_entered = true;
+			c->thread_callback(c->thread_arg);
+		}
+	} else if (SPA_LIKELY(mask & SPA_IO_IN)) {
+		uint32_t buffer_frames;
+		int status = 0;
+
+		buffer_frames = cycle_run(c);
+
+		if (buffer_frames > 0)
+			status = do_rt_callback_res(c, process_callback, buffer_frames, c->process_arg);
+
+		cycle_signal(c, status);
+	}
+}
+
+static int
+do_clear_link(struct spa_loop *loop,
+                  bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct link *link = user_data;
+	spa_list_remove(&link->target_link);
+	return 0;
+}
+
+static void clear_link(struct client *c, struct link *link)
+{
+	pw_data_loop_invoke(c->loop,
+			do_clear_link, 1, NULL, 0, !c->data_locked, link);
+	pw_memmap_free(link->mem);
+	close(link->signalfd);
+	spa_list_remove(&link->link);
+	free(link);
+}
+
+static void clean_transport(struct client *c)
+{
+	struct link *l;
+
+	if (!c->has_transport)
+		return;
+
+	pw_data_loop_invoke(c->loop,
+			do_remove_sources, 1, NULL, 0, !c->data_locked, c);
+
+	spa_list_consume(l, &c->links, link)
+		clear_link(c, l);
+
+	c->has_transport = false;
+}
+
+static int client_node_transport(void *data,
+                           int readfd, int writefd,
+			   uint32_t mem_id, uint32_t offset, uint32_t size)
+{
+	struct client *c = (struct client *) data;
+
+	clean_transport(c);
+
+	c->mem = pw_mempool_map_id(c->pool, mem_id,
+				PW_MEMMAP_FLAG_READWRITE, offset, size, NULL);
+	if (c->mem == NULL) {
+		pw_log_debug("%p: can't map activation: %m", c);
+		return -errno;
+	}
+	c->activation = c->mem->ptr;
+
+	pw_log_debug("%p: create client transport with fds %d %d for node %u",
+			c, readfd, writefd, c->node_id);
+
+	close(writefd);
+	c->socket_source = pw_loop_add_io(c->loop->loop,
+					  readfd,
+					  SPA_IO_ERR | SPA_IO_HUP,
+					  true, on_rtsocket_condition, c);
+
+	c->has_transport = true;
+	c->position = &c->activation->position;
+	pw_thread_loop_signal(c->context.loop, false);
+
+	return 0;
+}
+
+static int client_node_set_param(void *data,
+			uint32_t id, uint32_t flags,
+			const struct spa_pod *param)
+{
+	struct client *c = (struct client *) data;
+	pw_proxy_error((struct pw_proxy*)c->node, -ENOTSUP, "not supported");
+	return -ENOTSUP;
+}
+
+static int install_timeowner(struct client *c)
+{
+	struct pw_node_activation *a;
+	uint32_t owner;
+
+	if (!c->timebase_callback)
+		return 0;
+
+	if ((a = c->driver_activation) == NULL)
+		return -EIO;
+
+	pw_log_debug("%p: activation %p", c, a);
+
+	/* was ok */
+	owner = ATOMIC_LOAD(a->segment_owner[0]);
+	if (owner == c->node_id)
+		return 0;
+
+	/* try to become owner */
+	if (c->timeowner_conditional) {
+		if (!ATOMIC_CAS(a->segment_owner[0], 0, c->node_id)) {
+			pw_log_debug("%p: owner:%u id:%u", c, owner, c->node_id);
+			return -EBUSY;
+		}
+	} else {
+		ATOMIC_STORE(a->segment_owner[0], c->node_id);
+	}
+
+	pw_log_debug("%p: timebase installed for id:%u", c, c->node_id);
+
+	return 0;
+}
+
+static int
+do_update_driver_activation(struct spa_loop *loop,
+                bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct client *c = user_data;
+	c->rt.position = c->position;
+	c->rt.driver_activation = c->driver_activation;
+	if (c->position) {
+		pw_log_info("%p: driver:%d clock:%s", c,
+				c->driver_id, c->position->clock.name);
+		check_sample_rate(c, c->position);
+		check_buffer_frames(c, c->position);
+	}
+	return 0;
+}
+
+static int update_driver_activation(struct client *c)
+{
+	jack_client_t *client = (jack_client_t*)c;
+	struct link *link;
+	bool freewheeling;
+
+	pw_log_debug("%p: driver %d", c, c->driver_id);
+
+	freewheeling = SPA_FLAG_IS_SET(c->position->clock.flags, SPA_IO_CLOCK_FLAG_FREEWHEEL);
+	if (c->freewheeling != freewheeling) {
+		jack_native_thread_t thr = jack_client_thread_id(client);
+
+		c->freewheeling = freewheeling;
+		if (freewheeling && thr) {
+			jack_drop_real_time_scheduling(thr);
+		}
+
+		do_callback(c, freewheel_callback, freewheeling, c->freewheel_arg);
+
+		if (!freewheeling && thr) {
+			jack_acquire_real_time_scheduling(thr,
+					jack_client_real_time_priority(client));
+		}
+	}
+
+	link = find_activation(&c->links, c->driver_id);
+	c->driver_activation = link ? link->activation : NULL;
+	pw_data_loop_invoke(c->loop,
+                       do_update_driver_activation, SPA_ID_INVALID, NULL, 0, false, c);
+	install_timeowner(c);
+
+	return 0;
+}
+
+static int client_node_set_io(void *data,
+			uint32_t id,
+			uint32_t mem_id,
+			uint32_t offset,
+			uint32_t size)
+{
+	struct client *c = (struct client *) data;
+	struct pw_memmap *old, *mm;
+	void *ptr;
+	uint32_t tag[5] = { c->node_id, id, };
+
+	old = pw_mempool_find_tag(c->pool, tag, sizeof(tag));
+
+	if (mem_id == SPA_ID_INVALID) {
+		mm = ptr = NULL;
+	} else {
+		mm = pw_mempool_map_id(c->pool, mem_id,
+				PW_MEMMAP_FLAG_READWRITE, offset, size, tag);
+		if (mm == NULL) {
+                        pw_log_warn("%p: can't map memory id %u", c, mem_id);
+			return -errno;
+		}
+		ptr = mm->ptr;
+	}
+	pw_log_debug("%p: set io %s %p", c,
+			spa_debug_type_find_name(spa_type_io, id), ptr);
+
+	switch (id) {
+	case SPA_IO_Position:
+		c->position = ptr;
+		c->driver_id = ptr ? c->position->clock.id : SPA_ID_INVALID;
+		update_driver_activation(c);
+		break;
+	default:
+		break;
+	}
+	pw_memmap_free(old);
+
+	return 0;
+}
+
+static int client_node_event(void *data, const struct spa_event *event)
+{
+	return -ENOTSUP;
+}
+
+static int client_node_command(void *data, const struct spa_command *command)
+{
+	struct client *c = (struct client *) data;
+
+	pw_log_debug("%p: got command %d", c, SPA_COMMAND_TYPE(command));
+
+	switch (SPA_NODE_COMMAND_ID(command)) {
+	case SPA_NODE_COMMAND_Suspend:
+	case SPA_NODE_COMMAND_Pause:
+		if (c->started) {
+			pw_loop_update_io(c->loop->loop,
+					  c->socket_source, SPA_IO_ERR | SPA_IO_HUP);
+
+			c->started = false;
+		}
+		break;
+
+	case SPA_NODE_COMMAND_Start:
+		if (!c->started) {
+			pw_loop_update_io(c->loop->loop,
+					  c->socket_source,
+					  SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP);
+			c->started = true;
+			c->first = true;
+			c->thread_entered = false;
+		}
+		break;
+	default:
+		pw_log_warn("%p: unhandled node command %d", c, SPA_COMMAND_TYPE(command));
+		pw_proxy_errorf((struct pw_proxy*)c->node, -ENOTSUP,
+				"unhandled command %d", SPA_COMMAND_TYPE(command));
+	}
+	return 0;
+}
+
+static int client_node_add_port(void *data,
+                          enum spa_direction direction,
+                          uint32_t port_id, const struct spa_dict *props)
+{
+	struct client *c = (struct client *) data;
+	pw_proxy_error((struct pw_proxy*)c->node, -ENOTSUP, "add port not supported");
+	return -ENOTSUP;
+}
+
+static int client_node_remove_port(void *data,
+                             enum spa_direction direction,
+                             uint32_t port_id)
+{
+	struct client *c = (struct client *) data;
+	pw_proxy_error((struct pw_proxy*)c->node, -ENOTSUP, "remove port not supported");
+	return -ENOTSUP;
+}
+
+static int param_enum_format(struct client *c, struct port *p,
+		struct spa_pod **param, struct spa_pod_builder *b)
+{
+	switch (p->object->port.type_id) {
+	case TYPE_ID_AUDIO:
+		*param = spa_pod_builder_add_object(b,
+			SPA_TYPE_OBJECT_Format, SPA_PARAM_EnumFormat,
+			SPA_FORMAT_mediaType,      SPA_POD_Id(SPA_MEDIA_TYPE_audio),
+			SPA_FORMAT_mediaSubtype,   SPA_POD_Id(SPA_MEDIA_SUBTYPE_dsp),
+	                SPA_FORMAT_AUDIO_format,   SPA_POD_Id(SPA_AUDIO_FORMAT_DSP_F32));
+		break;
+	case TYPE_ID_MIDI:
+		*param = spa_pod_builder_add_object(b,
+			SPA_TYPE_OBJECT_Format, SPA_PARAM_EnumFormat,
+			SPA_FORMAT_mediaType,      SPA_POD_Id(SPA_MEDIA_TYPE_application),
+			SPA_FORMAT_mediaSubtype,   SPA_POD_Id(SPA_MEDIA_SUBTYPE_control));
+		break;
+	case TYPE_ID_VIDEO:
+		*param = spa_pod_builder_add_object(b,
+			SPA_TYPE_OBJECT_Format, SPA_PARAM_EnumFormat,
+			SPA_FORMAT_mediaType,      SPA_POD_Id(SPA_MEDIA_TYPE_video),
+			SPA_FORMAT_mediaSubtype,   SPA_POD_Id(SPA_MEDIA_SUBTYPE_dsp),
+	                SPA_FORMAT_VIDEO_format,   SPA_POD_Id(SPA_VIDEO_FORMAT_DSP_F32));
+		break;
+	default:
+		return -EINVAL;
+	}
+	return 1;
+}
+
+static int param_format(struct client *c, struct port *p,
+		struct spa_pod **param, struct spa_pod_builder *b)
+{
+	switch (p->object->port.type_id) {
+	case TYPE_ID_AUDIO:
+		*param = spa_pod_builder_add_object(b,
+				SPA_TYPE_OBJECT_Format, SPA_PARAM_Format,
+				SPA_FORMAT_mediaType,      SPA_POD_Id(SPA_MEDIA_TYPE_audio),
+				SPA_FORMAT_mediaSubtype,   SPA_POD_Id(SPA_MEDIA_SUBTYPE_dsp),
+		                SPA_FORMAT_AUDIO_format,   SPA_POD_Id(SPA_AUDIO_FORMAT_DSP_F32));
+		break;
+	case TYPE_ID_MIDI:
+		*param = spa_pod_builder_add_object(b,
+				SPA_TYPE_OBJECT_Format, SPA_PARAM_Format,
+				SPA_FORMAT_mediaType,      SPA_POD_Id(SPA_MEDIA_TYPE_application),
+				SPA_FORMAT_mediaSubtype,   SPA_POD_Id(SPA_MEDIA_SUBTYPE_control));
+		break;
+	case TYPE_ID_VIDEO:
+		*param = spa_pod_builder_add_object(b,
+				SPA_TYPE_OBJECT_Format, SPA_PARAM_Format,
+				SPA_FORMAT_mediaType,      SPA_POD_Id(SPA_MEDIA_TYPE_video),
+				SPA_FORMAT_mediaSubtype,   SPA_POD_Id(SPA_MEDIA_SUBTYPE_dsp),
+		                SPA_FORMAT_VIDEO_format,   SPA_POD_Id(SPA_VIDEO_FORMAT_DSP_F32));
+		break;
+	default:
+		return -EINVAL;
+	}
+	return 1;
+}
+
+static int param_buffers(struct client *c, struct port *p,
+		struct spa_pod **param, struct spa_pod_builder *b)
+{
+	switch (p->object->port.type_id) {
+	case TYPE_ID_AUDIO:
+	case TYPE_ID_MIDI:
+		*param = spa_pod_builder_add_object(b,
+			SPA_TYPE_OBJECT_ParamBuffers, SPA_PARAM_Buffers,
+			SPA_PARAM_BUFFERS_buffers, SPA_POD_CHOICE_RANGE_Int(2, 1, MAX_BUFFERS),
+			SPA_PARAM_BUFFERS_blocks,  SPA_POD_Int(1),
+			SPA_PARAM_BUFFERS_size,    SPA_POD_CHOICE_STEP_Int(
+								MAX_BUFFER_FRAMES * sizeof(float),
+								sizeof(float),
+								INT32_MAX,
+								sizeof(float)),
+			SPA_PARAM_BUFFERS_stride,  SPA_POD_Int(p->object->port.type_id == TYPE_ID_AUDIO ?
+									sizeof(float) : 1));
+		break;
+	case TYPE_ID_VIDEO:
+		*param = spa_pod_builder_add_object(b,
+			SPA_TYPE_OBJECT_ParamBuffers, SPA_PARAM_Buffers,
+			SPA_PARAM_BUFFERS_buffers, SPA_POD_CHOICE_RANGE_Int(2, 1, MAX_BUFFERS),
+			SPA_PARAM_BUFFERS_blocks,  SPA_POD_Int(1),
+			SPA_PARAM_BUFFERS_size,    SPA_POD_CHOICE_RANGE_Int(
+								320 * 240 * 4 * 4,
+								0,
+								INT32_MAX),
+			SPA_PARAM_BUFFERS_stride,  SPA_POD_CHOICE_RANGE_Int(4, 4, INT32_MAX));
+		break;
+	default:
+		return -EINVAL;
+	}
+	return 1;
+}
+
+static int param_io(struct client *c, struct port *p,
+		struct spa_pod **param, struct spa_pod_builder *b)
+{
+	*param = spa_pod_builder_add_object(b,
+		SPA_TYPE_OBJECT_ParamIO, SPA_PARAM_IO,
+		SPA_PARAM_IO_id,	SPA_POD_Id(SPA_IO_Buffers),
+		SPA_PARAM_IO_size,	SPA_POD_Int(sizeof(struct spa_io_buffers)));
+	return 1;
+}
+
+static int param_latency(struct client *c, struct port *p,
+		struct spa_pod **param, struct spa_pod_builder *b)
+{
+	*param = spa_latency_build(b, SPA_PARAM_Latency,
+			&p->object->port.latency[p->direction]);
+	return 1;
+}
+
+static int param_latency_other(struct client *c, struct port *p,
+		struct spa_pod **param, struct spa_pod_builder *b)
+{
+	*param = spa_latency_build(b, SPA_PARAM_Latency,
+			&p->object->port.latency[SPA_DIRECTION_REVERSE(p->direction)]);
+	return 1;
+}
+
+/* called from thread-loop */
+static int port_set_format(struct client *c, struct port *p,
+		uint32_t flags, const struct spa_pod *param)
+{
+	struct spa_pod *params[6];
+	uint8_t buffer[4096];
+	struct spa_pod_builder b = SPA_POD_BUILDER_INIT(buffer, sizeof(buffer));
+
+	if (param == NULL) {
+		struct mix *mix;
+
+		pw_log_debug("%p: port %p clear format", c, p);
+
+		spa_list_for_each(mix, &p->mix, port_link)
+			clear_buffers(c, mix);
+
+		p->params[IDX_Format] = SPA_PARAM_INFO(SPA_PARAM_Format, SPA_PARAM_INFO_WRITE);
+	}
+	else {
+		struct spa_audio_info info = { 0 };
+		if (spa_format_parse(param, &info.media_type, &info.media_subtype) < 0)
+			return -EINVAL;
+
+		switch (info.media_type) {
+		case SPA_MEDIA_TYPE_audio:
+		{
+			if (info.media_subtype != SPA_MEDIA_SUBTYPE_dsp)
+				return -EINVAL;
+
+			if (spa_format_audio_dsp_parse(param, &info.info.dsp) < 0)
+				return -EINVAL;
+			if (info.info.dsp.format != SPA_AUDIO_FORMAT_DSP_F32)
+				return -EINVAL;
+			break;
+		}
+		case SPA_MEDIA_TYPE_application:
+			if (info.media_subtype != SPA_MEDIA_SUBTYPE_control)
+				return -EINVAL;
+			break;
+		case SPA_MEDIA_TYPE_video:
+		{
+			struct spa_video_info vinfo = { 0 };
+
+			if (info.media_subtype != SPA_MEDIA_SUBTYPE_dsp)
+				return -EINVAL;
+			if (spa_format_video_dsp_parse(param, &vinfo.info.dsp) < 0)
+				return -EINVAL;
+			if (vinfo.info.dsp.format != SPA_VIDEO_FORMAT_DSP_F32)
+				return -EINVAL;
+			break;
+		}
+		default:
+			return -EINVAL;
+		}
+		p->params[IDX_Format] = SPA_PARAM_INFO(SPA_PARAM_Format, SPA_PARAM_INFO_READWRITE);
+	}
+
+	pw_log_info("port %s: update", p->object->port.name);
+
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PARAMS;
+
+	param_enum_format(c, p, &params[0], &b);
+	param_format(c, p, &params[1], &b);
+	param_buffers(c, p, &params[2], &b);
+	param_io(c, p, &params[3], &b);
+	param_latency(c, p, &params[4], &b);
+	param_latency_other(c, p, &params[5], &b);
+
+	pw_client_node_port_update(c->node,
+					 p->direction,
+					 p->port_id,
+					 PW_CLIENT_NODE_PORT_UPDATE_PARAMS |
+					 PW_CLIENT_NODE_PORT_UPDATE_INFO,
+					 SPA_N_ELEMENTS(params),
+					 (const struct spa_pod **) params,
+					 &p->info);
+	p->info.change_mask = 0;
+	return 0;
+}
+
+/* called from thread-loop */
+static void port_update_latency(struct port *p)
+{
+	struct client *c = p->client;
+	struct spa_pod *params[6];
+	uint8_t buffer[4096];
+	struct spa_pod_builder b = SPA_POD_BUILDER_INIT(buffer, sizeof(buffer));
+
+	param_enum_format(c, p, &params[0], &b);
+	param_format(c, p, &params[1], &b);
+	param_buffers(c, p, &params[2], &b);
+	param_io(c, p, &params[3], &b);
+	param_latency(c, p, &params[4], &b);
+	param_latency_other(c, p, &params[5], &b);
+
+	pw_log_info("port %s: update", p->object->port.name);
+
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PARAMS;
+	p->params[IDX_Latency].flags ^= SPA_PARAM_INFO_SERIAL;
+
+	pw_client_node_port_update(c->node,
+					 p->direction,
+					 p->port_id,
+					 PW_CLIENT_NODE_PORT_UPDATE_PARAMS |
+					 PW_CLIENT_NODE_PORT_UPDATE_INFO,
+					 SPA_N_ELEMENTS(params),
+					 (const struct spa_pod **) params,
+					 &p->info);
+	p->info.change_mask = 0;
+}
+
+/* called from thread-loop */
+static void default_latency(struct client *c, enum spa_direction direction,
+		struct spa_latency_info *latency)
+{
+	enum spa_direction other;
+	union pw_map_item *item;
+	struct port *p;
+
+	other = SPA_DIRECTION_REVERSE(direction);
+
+	spa_latency_info_combine_start(latency, direction);
+
+	pw_array_for_each(item, &c->ports[other].items) {
+                if (pw_map_item_is_free(item))
+			continue;
+		p = item->data;
+		spa_latency_info_combine(latency, &p->object->port.latency[direction]);
+	}
+
+	spa_latency_info_combine_finish(latency);
+}
+
+/* called from thread-loop */
+static void default_latency_callback(jack_latency_callback_mode_t mode, struct client *c)
+{
+	struct spa_latency_info latency, *current;
+	enum spa_direction direction;
+	union pw_map_item *item;
+	struct port *p;
+
+	if (mode == JackPlaybackLatency)
+		direction = SPA_DIRECTION_INPUT;
+	else
+		direction = SPA_DIRECTION_OUTPUT;
+
+	default_latency(c, direction, &latency);
+
+	pw_log_info("client %p: update %s latency %f-%f %d-%d %"PRIu64"-%"PRIu64, c,
+			latency.direction == SPA_DIRECTION_INPUT ? "playback" : "capture",
+			latency.min_quantum, latency.max_quantum,
+			latency.min_rate, latency.max_rate,
+			latency.min_ns, latency.max_ns);
+
+	pw_array_for_each(item, &c->ports[direction].items) {
+                if (pw_map_item_is_free(item))
+			continue;
+		p = item->data;
+		current = &p->object->port.latency[direction];
+		if (spa_latency_info_compare(current, &latency) == 0)
+			continue;
+		*current = latency;
+		port_update_latency(p);
+	}
+}
+
+/* called from thread-loop */
+static int port_set_latency(struct client *c, struct port *p,
+		uint32_t flags, const struct spa_pod *param)
+{
+	struct spa_latency_info info;
+	jack_latency_callback_mode_t mode;
+	struct spa_latency_info *current;
+	int res;
+
+	if (param == NULL)
+		return 0;
+
+	if ((res = spa_latency_parse(param, &info)) < 0)
+		return res;
+
+	current = &p->object->port.latency[info.direction];
+	if (spa_latency_info_compare(current, &info) == 0)
+		return 0;
+
+	*current = info;
+
+	pw_log_info("port %s: set %s latency %f-%f %d-%d %"PRIu64"-%"PRIu64, p->object->port.name,
+			info.direction == SPA_DIRECTION_INPUT ? "playback" : "capture",
+			info.min_quantum, info.max_quantum,
+			info.min_rate, info.max_rate,
+			info.min_ns, info.max_ns);
+
+	if (info.direction == p->direction)
+		return 0;
+
+	if (info.direction == SPA_DIRECTION_INPUT)
+		mode = JackPlaybackLatency;
+	else
+		mode = JackCaptureLatency;
+
+	if (c->latency_callback)
+		do_callback(c, latency_callback, mode, c->latency_arg);
+	else
+		default_latency_callback(mode, c);
+
+	port_update_latency(p);
+
+	return 0;
+}
+
+/* called from thread-loop */
+static int client_node_port_set_param(void *data,
+                                enum spa_direction direction,
+                                uint32_t port_id,
+                                uint32_t id, uint32_t flags,
+                                const struct spa_pod *param)
+{
+	struct client *c = (struct client *) data;
+	struct port *p = GET_PORT(c, direction, port_id);
+
+	if (p == NULL || !p->valid)
+		return -EINVAL;
+
+	pw_log_info("client %p: port %s %d.%d id:%d (%s) %p", c, p->object->port.name,
+			direction, port_id, id,
+			spa_debug_type_find_name(spa_type_param, id), param);
+
+	switch (id) {
+	case SPA_PARAM_Format:
+		return port_set_format(c, p, flags, param);
+		break;
+	case SPA_PARAM_Latency:
+		return port_set_latency(c, p, flags, param);
+	default:
+		break;
+	}
+	return 0;
+}
+
+static inline void *init_buffer(struct port *p)
+{
+	void *data = p->emptyptr;
+	if (p->zeroed)
+		return data;
+
+	if (p->object->port.type_id == TYPE_ID_MIDI) {
+		struct midi_buffer *mb = data;
+		mb->magic = MIDI_BUFFER_MAGIC;
+		mb->buffer_size = MAX_BUFFER_FRAMES * sizeof(float);
+		mb->nframes = MAX_BUFFER_FRAMES;
+		mb->write_pos = 0;
+		mb->event_count = 0;
+		mb->lost_events = 0;
+		pw_log_debug("port %p: init midi buffer size:%d", p, mb->buffer_size);
+	} else
+		memset(data, 0, MAX_BUFFER_FRAMES * sizeof(float));
+
+	p->zeroed = true;
+	return data;
+}
+
+static int client_node_port_use_buffers(void *data,
+                                  enum spa_direction direction,
+                                  uint32_t port_id,
+                                  uint32_t mix_id,
+                                  uint32_t flags,
+                                  uint32_t n_buffers,
+                                  struct pw_client_node_buffer *buffers)
+{
+	struct client *c = (struct client *) data;
+	struct port *p = GET_PORT(c, direction, port_id);
+	struct buffer *b;
+	uint32_t i, j, fl;
+	int res;
+	struct mix *mix;
+
+	if (p == NULL || !p->valid) {
+		res = -EINVAL;
+		goto done;
+	}
+	if ((mix = ensure_mix(c, p, mix_id)) == NULL) {
+		res = -ENOMEM;
+		goto done;
+	}
+
+	pw_log_debug("%p: port %p %d %d.%d use_buffers %d", c, p, direction,
+			port_id, mix_id, n_buffers);
+
+	if (n_buffers > MAX_BUFFERS) {
+		pw_log_error("%p: too many buffers %u > %u", c, n_buffers, MAX_BUFFERS);
+		return -ENOSPC;
+	}
+
+	if (p->object->port.type_id == TYPE_ID_VIDEO && direction == SPA_DIRECTION_INPUT) {
+		fl = PW_MEMMAP_FLAG_READ;
+	} else {
+		/* some apps write to the input buffer so we want everything readwrite */
+		fl = PW_MEMMAP_FLAG_READWRITE;
+	}
+
+	/* clear previous buffers */
+	clear_buffers(c, mix);
+
+	for (i = 0; i < n_buffers; i++) {
+		off_t offset;
+		struct spa_buffer *buf;
+		struct pw_memmap *mm;
+
+		mm = pw_mempool_map_id(c->pool, buffers[i].mem_id,
+				fl, buffers[i].offset, buffers[i].size, NULL);
+		if (mm == NULL) {
+			pw_log_warn("%p: can't map memory id %u: %m", c, buffers[i].mem_id);
+			continue;
+		}
+
+		buf = buffers[i].buffer;
+
+		b = &mix->buffers[i];
+		b->id = i;
+		b->flags = 0;
+		b->n_mem = 0;
+		b->mem[b->n_mem++] = mm;
+
+		pw_log_debug("%p: add buffer id:%u offset:%u size:%u map:%p ptr:%p",
+				c, buffers[i].mem_id, buffers[i].offset,
+				buffers[i].size, mm, mm->ptr);
+
+		offset = 0;
+		for (j = 0; j < buf->n_metas; j++) {
+			struct spa_meta *m = &buf->metas[j];
+			offset += SPA_ROUND_UP_N(m->size, 8);
+		}
+
+		b->n_datas = SPA_MIN(buf->n_datas, MAX_BUFFER_DATAS);
+
+		for (j = 0; j < b->n_datas; j++) {
+			struct spa_data *d = &b->datas[j];
+
+			memcpy(d, &buf->datas[j], sizeof(struct spa_data));
+			d->chunk =
+			    SPA_PTROFF(mm->ptr, offset + sizeof(struct spa_chunk) * j,
+				       struct spa_chunk);
+
+			if (d->type == SPA_DATA_MemId) {
+				uint32_t mem_id = SPA_PTR_TO_UINT32(d->data);
+				struct pw_memblock *bm;
+				struct pw_memmap *bmm;
+
+				bm = pw_mempool_find_id(c->pool, mem_id);
+				if (bm == NULL) {
+					pw_log_error("%p: unknown buffer mem %u", c, mem_id);
+					res = -ENODEV;
+					goto done;
+
+				}
+
+				d->fd = bm->fd;
+				d->type = bm->type;
+				d->data = NULL;
+
+				bmm = pw_memblock_map(bm, fl, d->mapoffset, d->maxsize, NULL);
+				if (bmm == NULL) {
+					res = -errno;
+					pw_log_error("%p: failed to map buffer mem %m", c);
+					d->data = NULL;
+					goto done;
+				}
+				b->mem[b->n_mem++] = bmm;
+				d->data = bmm->ptr;
+
+				pw_log_debug("%p: data %d %u -> fd %d %d",
+						c, j, bm->id, bm->fd, d->maxsize);
+			} else if (d->type == SPA_DATA_MemPtr) {
+				int offs = SPA_PTR_TO_INT(d->data);
+				d->data = SPA_PTROFF(mm->ptr, offs, void);
+				d->fd = -1;
+				pw_log_debug("%p: data %d %u -> mem %p %d",
+						c, j, b->id, d->data, d->maxsize);
+			} else {
+				pw_log_warn("unknown buffer data type %d", d->type);
+			}
+			if (c->allow_mlock && mlock(d->data, d->maxsize) < 0) {
+				if (errno != ENOMEM  || !mlock_warned) {
+					pw_log(c->warn_mlock ? SPA_LOG_LEVEL_WARN : SPA_LOG_LEVEL_DEBUG,
+						"%p: Failed to mlock memory %p %u: %s", c,
+						d->data, d->maxsize,
+						errno == ENOMEM ?
+						"This is not a problem but for best performance, "
+						"consider increasing RLIMIT_MEMLOCK" : strerror(errno));
+					mlock_warned |= errno == ENOMEM;
+				}
+			}
+		}
+		SPA_FLAG_SET(b->flags, BUFFER_FLAG_OUT);
+		if (direction == SPA_DIRECTION_OUTPUT)
+			reuse_buffer(c, mix, b->id);
+
+	}
+	pw_log_debug("%p: have %d buffers", c, n_buffers);
+	mix->n_buffers = n_buffers;
+	res = 0;
+
+      done:
+	if (res < 0)
+		pw_proxy_error((struct pw_proxy*)c->node, res, spa_strerror(res));
+	return res;
+}
+
+static int client_node_port_set_io(void *data,
+                             enum spa_direction direction,
+                             uint32_t port_id,
+                             uint32_t mix_id,
+                             uint32_t id,
+                             uint32_t mem_id,
+                             uint32_t offset,
+                             uint32_t size)
+{
+	struct client *c = (struct client *) data;
+	struct port *p = GET_PORT(c, direction, port_id);
+        struct pw_memmap *mm, *old;
+        struct mix *mix;
+	uint32_t tag[5] = { c->node_id, direction, port_id, mix_id, id };
+        void *ptr;
+	int res = 0;
+
+	if (p == NULL || !p->valid) {
+		res = -EINVAL;
+		goto exit;
+	}
+
+	if ((mix = ensure_mix(c, p, mix_id)) == NULL) {
+		res = -ENOMEM;
+		goto exit;
+	}
+
+	old = pw_mempool_find_tag(c->pool, tag, sizeof(tag));
+
+        if (mem_id == SPA_ID_INVALID) {
+                mm = ptr = NULL;
+        }
+        else {
+		mm = pw_mempool_map_id(c->pool, mem_id,
+				PW_MEMMAP_FLAG_READWRITE, offset, size, tag);
+                if (mm == NULL) {
+                        pw_log_warn("%p: can't map memory id %u", c, mem_id);
+			res = -EINVAL;
+                        goto exit_free;
+                }
+		ptr = mm->ptr;
+        }
+
+	pw_log_debug("%p: port %p mix:%d set io:%s id:%u ptr:%p", c, p, mix_id,
+			spa_debug_type_find_name(spa_type_io, id), id, ptr);
+
+	switch (id) {
+	case SPA_IO_Buffers:
+                mix->io = ptr;
+		break;
+	default:
+		break;
+	}
+exit_free:
+	pw_memmap_free(old);
+exit:
+	if (res < 0)
+		pw_proxy_error((struct pw_proxy*)c->node, res, spa_strerror(res));
+	return res;
+}
+
+static int
+do_activate_link(struct spa_loop *loop,
+                bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct link *link = user_data;
+	struct client *c = link->client;
+	pw_log_trace("link %p activate", link);
+	spa_list_append(&c->rt.target_links, &link->target_link);
+	return 0;
+}
+
+static int client_node_set_activation(void *data,
+                             uint32_t node_id,
+                             int signalfd,
+                             uint32_t mem_id,
+                             uint32_t offset,
+                             uint32_t size)
+{
+	struct client *c = (struct client *) data;
+	struct pw_memmap *mm;
+	struct link *link;
+	void *ptr;
+	int res = 0;
+
+	if (c->node_id == node_id) {
+		pw_log_debug("%p: our activation %u: %u %u %u", c, node_id,
+				mem_id, offset, size);
+		close(signalfd);
+		return 0;
+	}
+
+	if (mem_id == SPA_ID_INVALID) {
+		mm = ptr = NULL;
+		size = 0;
+	}
+	else {
+		mm = pw_mempool_map_id(c->pool, mem_id,
+				PW_MEMMAP_FLAG_READWRITE, offset, size, NULL);
+		if (mm == NULL) {
+			pw_log_warn("%p: can't map memory id %u", c, mem_id);
+			res = -EINVAL;
+			goto exit;
+		}
+		ptr = mm->ptr;
+	}
+
+	pw_log_debug("%p: set activation %u: %u %u %u %p", c, node_id,
+			mem_id, offset, size, ptr);
+
+	if (ptr) {
+		link = calloc(1, sizeof(struct link));
+		if (link == NULL) {
+			res = -errno;
+			goto exit;
+		}
+		link->client = c;
+		link->node_id = node_id;
+		link->mem = mm;
+		link->activation = ptr;
+		link->signalfd = signalfd;
+		spa_list_append(&c->links, &link->link);
+
+		pw_data_loop_invoke(c->loop,
+                       do_activate_link, SPA_ID_INVALID, NULL, 0, false, link);
+	}
+	else {
+		link = find_activation(&c->links, node_id);
+		if (link == NULL) {
+			res = -EINVAL;
+			goto exit;
+		}
+		clear_link(c, link);
+	}
+
+	if (c->driver_id == node_id)
+		update_driver_activation(c);
+
+      exit:
+	if (res < 0)
+		pw_proxy_error((struct pw_proxy*)c->node, res, spa_strerror(res));
+	return res;
+}
+
+static int client_node_port_set_mix_info(void *data,
+                                  enum spa_direction direction,
+                                  uint32_t port_id,
+                                  uint32_t mix_id,
+                                  uint32_t peer_id,
+                                  const struct spa_dict *props)
+{
+	struct client *c = (struct client *) data;
+	struct port *p = GET_PORT(c, direction, port_id);
+	struct mix *mix;
+	struct object *l;
+	uint32_t src, dst;
+	int res = 0;
+
+	if (p == NULL || !p->valid) {
+		res = -EINVAL;
+		goto exit;
+	}
+
+	if ((mix = ensure_mix(c, p, mix_id)) == NULL) {
+		res = -ENOMEM;
+		goto exit;
+	}
+	mix->peer_id = peer_id;
+
+	if (direction == SPA_DIRECTION_INPUT) {
+		src = peer_id;
+		dst = p->object->id;
+	} else {
+		src = p->object->id;
+		dst = peer_id;
+	}
+
+	if ((l = find_link(c, src, dst)) != NULL) {
+		if (direction == SPA_DIRECTION_INPUT)
+			mix->peer_port = l->port_link.our_output;
+		else
+			mix->peer_port = l->port_link.our_input;
+
+		pw_log_debug("peer port %p %p %p", mix->peer_port,
+				l->port_link.our_output, l->port_link.our_input);
+
+		if (!l->port_link.is_complete) {
+			l->port_link.is_complete = true;
+			pw_log_info("%p: our link %u/%u -> %u/%u completed", c,
+					l->port_link.src, l->port_link.src_serial,
+					l->port_link.dst, l->port_link.dst_serial);
+			do_callback(c, connect_callback,
+					l->port_link.src_serial, l->port_link.dst_serial, 1, c->connect_arg);
+			recompute_latencies(c);
+			do_callback(c, graph_callback, c->graph_arg);
+		}
+	}
+
+exit:
+	if (res < 0)
+		pw_proxy_error((struct pw_proxy*)c->node, res, spa_strerror(res));
+	return res;
+}
+
+static const struct pw_client_node_events client_node_events = {
+	PW_VERSION_CLIENT_NODE_EVENTS,
+	.transport = client_node_transport,
+	.set_param = client_node_set_param,
+	.set_io = client_node_set_io,
+	.event = client_node_event,
+	.command = client_node_command,
+	.add_port = client_node_add_port,
+	.remove_port = client_node_remove_port,
+	.port_set_param = client_node_port_set_param,
+	.port_use_buffers = client_node_port_use_buffers,
+	.port_set_io = client_node_port_set_io,
+	.set_activation = client_node_set_activation,
+	.port_set_mix_info = client_node_port_set_mix_info,
+};
+
+#define CHECK(expression,label)						\
+do {									\
+	if ((errno = expression) != 0) {				\
+		res = -errno;						\
+		pw_log_error(#expression ": %s", strerror(errno));	\
+		goto label;						\
+	}								\
+} while(false);
+
+static struct spa_thread *impl_create(void *object,
+			const struct spa_dict *props,
+			void *(*start)(void*), void *arg)
+{
+	struct client *c = (struct client *) object;
+	struct spa_thread *thr;
+	int res = 0;
+
+	pw_log_info("create thread");
+	if (globals.creator != NULL) {
+		pthread_t pt;
+		pthread_attr_t *attr = NULL, attributes;
+
+		attr = pw_thread_fill_attr(props, &attributes);
+
+		res = -globals.creator(&pt, attr, start, arg);
+		if (attr)
+			pthread_attr_destroy(attr);
+		if (res != 0)
+			goto error;
+		thr = (struct spa_thread*)pt;
+	} else {
+		thr = spa_thread_utils_create(c->context.old_thread_utils, props, start, arg);
+	}
+	return thr;
+error:
+	pw_log_warn("create RT thread failed: %s", strerror(res));
+	errno = -res;
+	return NULL;
+
+}
+
+static int impl_join(void *object,
+		struct spa_thread *thread, void **retval)
+{
+	struct client *c = (struct client *) object;
+	pw_log_info("join thread");
+	return spa_thread_utils_join(c->context.old_thread_utils, thread, retval);
+}
+
+static int impl_acquire_rt(void *object, struct spa_thread *thread, int priority)
+{
+	struct client *c = (struct client *) object;
+	return spa_thread_utils_acquire_rt(c->context.old_thread_utils, thread, priority);
+}
+
+static int impl_drop_rt(void *object, struct spa_thread *thread)
+{
+	struct client *c = (struct client *) object;
+	return spa_thread_utils_drop_rt(c->context.old_thread_utils, thread);
+}
+
+static struct spa_thread_utils_methods thread_utils_impl = {
+	SPA_VERSION_THREAD_UTILS_METHODS,
+	.create = impl_create,
+	.join = impl_join,
+	.acquire_rt = impl_acquire_rt,
+	.drop_rt = impl_drop_rt,
+};
+
+static jack_port_type_id_t string_to_type(const char *port_type)
+{
+	if (spa_streq(JACK_DEFAULT_AUDIO_TYPE, port_type))
+		return TYPE_ID_AUDIO;
+	else if (spa_streq(JACK_DEFAULT_MIDI_TYPE, port_type))
+		return TYPE_ID_MIDI;
+	else if (spa_streq(JACK_DEFAULT_VIDEO_TYPE, port_type))
+		return TYPE_ID_VIDEO;
+	else if (spa_streq("other", port_type))
+		return TYPE_ID_OTHER;
+	else
+		return SPA_ID_INVALID;
+}
+
+static const char* type_to_string(jack_port_type_id_t type_id)
+{
+	switch(type_id) {
+	case TYPE_ID_AUDIO:
+		return JACK_DEFAULT_AUDIO_TYPE;
+	case TYPE_ID_MIDI:
+		return JACK_DEFAULT_MIDI_TYPE;
+	case TYPE_ID_VIDEO:
+		return JACK_DEFAULT_VIDEO_TYPE;
+	case TYPE_ID_OTHER:
+		return "other";
+	default:
+		return NULL;
+	}
+}
+
+static jack_uuid_t client_make_uuid(uint32_t id, bool monitor)
+{
+	jack_uuid_t uuid = 0x2; /* JackUUIDClient */
+	uuid = (uuid << 32) | (id + 1);
+	if (monitor)
+		uuid |= (1 << 30);
+	pw_log_debug("uuid %d -> %"PRIu64, id, uuid);
+	return uuid;
+}
+
+static int json_object_find(const char *obj, const char *key, char *value, size_t len)
+{
+	struct spa_json it[2];
+	const char *v;
+	char k[128];
+
+	spa_json_init(&it[0], obj, strlen(obj));
+	if (spa_json_enter_object(&it[0], &it[1]) <= 0)
+		return -EINVAL;
+
+	while (spa_json_get_string(&it[1], k, sizeof(k)) > 0) {
+		if (spa_streq(k, key)) {
+			if (spa_json_get_string(&it[1], value, len) <= 0)
+				continue;
+			return 0;
+		} else {
+			if (spa_json_next(&it[1], &v) <= 0)
+				break;
+		}
+	}
+	return -ENOENT;
+}
+
+static int metadata_property(void *data, uint32_t id,
+		const char *key, const char *type, const char *value)
+{
+	struct client *c = (struct client *) data;
+	struct object *o;
+	jack_uuid_t uuid;
+
+	pw_log_debug("set id:%u key:'%s' value:'%s' type:'%s'", id, key, value, type);
+
+	if (id == PW_ID_CORE) {
+		if (key == NULL || spa_streq(key, "default.audio.sink")) {
+			if (value != NULL) {
+				if (json_object_find(value, "name",
+						c->metadata->default_audio_sink,
+						sizeof(c->metadata->default_audio_sink)) < 0)
+					value = NULL;
+			}
+			if (value == NULL)
+				c->metadata->default_audio_sink[0] = '\0';
+		}
+		if (key == NULL || spa_streq(key, "default.audio.source")) {
+			if (value != NULL) {
+				if (json_object_find(value, "name",
+						c->metadata->default_audio_source,
+						sizeof(c->metadata->default_audio_source)) < 0)
+					value = NULL;
+			}
+			if (value == NULL)
+				c->metadata->default_audio_source[0] = '\0';
+		}
+	} else {
+		if ((o = find_id(c, id, true)) == NULL)
+			return -EINVAL;
+
+		switch (o->type) {
+		case INTERFACE_Node:
+			uuid = client_make_uuid(o->serial, false);
+			break;
+		case INTERFACE_Port:
+			uuid = jack_port_uuid_generate(o->serial);
+			break;
+		default:
+			return -EINVAL;
+		}
+		update_property(c, uuid, key, type, value);
+	}
+
+	return 0;
+}
+
+static const struct pw_metadata_events metadata_events = {
+	PW_VERSION_METADATA_EVENTS,
+	.property = metadata_property
+};
+
+static void metadata_proxy_removed(void *data)
+{
+	struct client *c = data;
+	pw_proxy_destroy((struct pw_proxy*)c->metadata->proxy);
+}
+
+static void metadata_proxy_destroy(void *data)
+{
+	struct client *c = data;
+	spa_hook_remove(&c->metadata->proxy_listener);
+	spa_hook_remove(&c->metadata->listener);
+	c->metadata = NULL;
+}
+
+static const struct pw_proxy_events metadata_proxy_events = {
+	PW_VERSION_PROXY_EVENTS,
+	.removed = metadata_proxy_removed,
+	.destroy = metadata_proxy_destroy,
+};
+
+static void settings_proxy_removed(void *data)
+{
+	struct client *c = data;
+	pw_proxy_destroy((struct pw_proxy*)c->settings->proxy);
+}
+
+static void settings_proxy_destroy(void *data)
+{
+	struct client *c = data;
+	spa_hook_remove(&c->settings->proxy_listener);
+	c->settings = NULL;
+}
+
+static const struct pw_proxy_events settings_proxy_events = {
+	PW_VERSION_PROXY_EVENTS,
+	.removed = settings_proxy_removed,
+	.destroy = settings_proxy_destroy,
+};
+static void proxy_removed(void *data)
+{
+	struct object *o = data;
+	pw_proxy_destroy(o->proxy);
+}
+
+static void proxy_destroy(void *data)
+{
+	struct object *o = data;
+	spa_hook_remove(&o->proxy_listener);
+	spa_hook_remove(&o->object_listener);
+	o->proxy = NULL;
+}
+
+static const struct pw_proxy_events proxy_events = {
+	PW_VERSION_PROXY_EVENTS,
+	.removed = proxy_removed,
+	.destroy = proxy_destroy,
+};
+
+static void port_param(void *data, int seq,
+			uint32_t id, uint32_t index, uint32_t next,
+			const struct spa_pod *param)
+{
+	struct object *o = data;
+
+	switch (id) {
+	case SPA_PARAM_Latency:
+	{
+		struct spa_latency_info info;
+		if (spa_latency_parse(param, &info) < 0)
+			return;
+		o->port.latency[info.direction] = info;
+		break;
+	}
+	default:
+		break;
+	}
+}
+
+static const struct pw_port_events port_events = {
+	PW_VERSION_PORT,
+	.param = port_param,
+};
+
+#define FILTER_NAME	" ()[].:*$"
+#define FILTER_PORT	" ()[].*$"
+
+static void filter_name(char *str, const char *filter, char filter_char)
+{
+	char *p;
+	for (p = str; *p; p++) {
+		if (strchr(filter, *p) != NULL)
+			*p = filter_char;
+	}
+}
+
+static void registry_event_global(void *data, uint32_t id,
+                                  uint32_t permissions, const char *type, uint32_t version,
+                                  const struct spa_dict *props)
+{
+	struct client *c = (struct client *) data;
+	struct object *o, *ot, *op;
+	const char *str;
+	bool is_first = false, graph_changed = false;
+	uint32_t serial;
+
+	if (props == NULL)
+		return;
+
+	str = spa_dict_lookup(props, PW_KEY_OBJECT_SERIAL);
+	if (!spa_atou32(str, &serial, 0))
+		serial = SPA_ID_INVALID;
+
+	pw_log_debug("new %s id:%u serial:%u", type, id, serial);
+
+	if (spa_streq(type, PW_TYPE_INTERFACE_Node)) {
+		const char *app, *node_name;
+		char tmp[JACK_CLIENT_NAME_SIZE+1];
+
+		o = alloc_object(c, INTERFACE_Node);
+
+		if ((str = spa_dict_lookup(props, PW_KEY_CLIENT_ID)) != NULL)
+			o->node.client_id = atoi(str);
+
+		node_name = spa_dict_lookup(props, PW_KEY_NODE_NAME);
+
+		if (id == c->node_id) {
+			pw_log_debug("%p: add our node %d", c, id);
+			if (node_name != NULL)
+				snprintf(c->name, sizeof(c->name), "%s", node_name);
+			c->serial = serial;
+		}
+		snprintf(o->node.node_name, sizeof(o->node.node_name),
+				"%s", node_name);
+
+		app = spa_dict_lookup(props, PW_KEY_APP_NAME);
+
+		if (c->short_name) {
+			str = spa_dict_lookup(props, PW_KEY_NODE_NICK);
+			if (str == NULL)
+				str = spa_dict_lookup(props, PW_KEY_NODE_DESCRIPTION);
+		} else {
+			str = spa_dict_lookup(props, PW_KEY_NODE_DESCRIPTION);
+			if (str == NULL)
+				str = spa_dict_lookup(props, PW_KEY_NODE_NICK);
+		}
+		if (str == NULL)
+			str = node_name;
+		if (str == NULL)
+			str = "node";
+
+		if (app && !spa_streq(app, str))
+			snprintf(tmp, sizeof(tmp), "%s/%s", app, str);
+		else
+			snprintf(tmp, sizeof(tmp), "%s", str);
+
+		if (c->filter_name)
+			filter_name(tmp, FILTER_NAME, c->filter_char);
+
+		ot = find_node(c, tmp);
+		if (ot != NULL && o->node.client_id != ot->node.client_id) {
+			snprintf(o->node.name, sizeof(o->node.name), "%.*s-%d",
+					(int)(sizeof(tmp)-11), tmp, id);
+		} else {
+			is_first = ot == NULL;
+			snprintf(o->node.name, sizeof(o->node.name), "%s", tmp);
+		}
+
+		if ((str = spa_dict_lookup(props, PW_KEY_PRIORITY_SESSION)) != NULL)
+			o->node.priority = pw_properties_parse_int(str);
+
+		pw_log_debug("%p: add node %d", c, id);
+
+		pthread_mutex_lock(&c->context.lock);
+		spa_list_append(&c->context.objects, &o->link);
+		pthread_mutex_unlock(&c->context.lock);
+	}
+	else if (spa_streq(type, PW_TYPE_INTERFACE_Port)) {
+		const struct spa_dict_item *item;
+		unsigned long flags = 0;
+		jack_port_type_id_t type_id;
+		uint32_t node_id;
+		bool is_monitor = false;
+		char tmp[REAL_JACK_PORT_NAME_SIZE+1];
+
+		if ((str = spa_dict_lookup(props, PW_KEY_FORMAT_DSP)) == NULL)
+			str = "other";
+		if ((type_id = string_to_type(str)) == SPA_ID_INVALID)
+			goto exit;
+
+		if ((str = spa_dict_lookup(props, PW_KEY_NODE_ID)) == NULL)
+			goto exit;
+
+		node_id = atoi(str);
+
+		if ((str = spa_dict_lookup(props, PW_KEY_PORT_EXTRA)) != NULL &&
+		    spa_strstartswith(str, "jack:flags:"))
+			flags = atoi(str+11);
+
+		if ((str = spa_dict_lookup(props, PW_KEY_PORT_NAME)) == NULL)
+			goto exit;
+
+		spa_dict_for_each(item, props) {
+	                if (spa_streq(item->key, PW_KEY_PORT_DIRECTION)) {
+				if (spa_streq(item->value, "in"))
+					flags |= JackPortIsInput;
+				else if (spa_streq(item->value, "out"))
+					flags |= JackPortIsOutput;
+			}
+			else if (spa_streq(item->key, PW_KEY_PORT_PHYSICAL)) {
+				if (pw_properties_parse_bool(item->value))
+					flags |= JackPortIsPhysical;
+			}
+			else if (spa_streq(item->key, PW_KEY_PORT_TERMINAL)) {
+				if (pw_properties_parse_bool(item->value))
+					flags |= JackPortIsTerminal;
+			}
+			else if (spa_streq(item->key, PW_KEY_PORT_CONTROL)) {
+				if (pw_properties_parse_bool(item->value))
+					type_id = TYPE_ID_MIDI;
+			}
+			else if (spa_streq(item->key, PW_KEY_PORT_MONITOR)) {
+				is_monitor = pw_properties_parse_bool(item->value);
+			}
+		}
+		if (is_monitor && !c->show_monitor)
+			goto exit;
+
+		o = NULL;
+		if (node_id == c->node_id) {
+			snprintf(tmp, sizeof(tmp), "%s:%s", c->name, str);
+			o = find_port_by_name(c, tmp);
+			if (o != NULL)
+				pw_log_info("%p: %s found our port %p", c, tmp, o);
+		}
+		if (o == NULL) {
+			if ((ot = find_type(c, node_id, INTERFACE_Node, true)) == NULL)
+				goto exit;
+
+			o = alloc_object(c, INTERFACE_Port);
+			if (o == NULL)
+				goto exit;
+
+			o->port.system_id = 0;
+			o->port.priority = ot->node.priority;
+			o->port.node = ot;
+			o->port.latency[SPA_DIRECTION_INPUT] = SPA_LATENCY_INFO(SPA_DIRECTION_INPUT);
+			o->port.latency[SPA_DIRECTION_OUTPUT] = SPA_LATENCY_INFO(SPA_DIRECTION_OUTPUT);
+
+			o->proxy = pw_registry_bind(c->registry,
+				id, type, PW_VERSION_PORT, 0);
+			if (o->proxy) {
+				uint32_t ids[1] = { SPA_PARAM_Latency };
+
+				pw_proxy_add_listener(o->proxy,
+						&o->proxy_listener, &proxy_events, o);
+				pw_proxy_add_object_listener(o->proxy,
+						&o->object_listener, &port_events, o);
+
+				pw_port_subscribe_params((struct pw_port*)o->proxy,
+						ids, 1);
+			}
+			pthread_mutex_lock(&c->context.lock);
+			spa_list_append(&c->context.objects, &o->link);
+			pthread_mutex_unlock(&c->context.lock);
+
+			if (is_monitor && !c->merge_monitor)
+				snprintf(tmp, sizeof(tmp), "%.*s%s:%s",
+					(int)(JACK_CLIENT_NAME_SIZE-(sizeof(MONITOR_EXT)-1)),
+					ot->node.name, MONITOR_EXT, str);
+			else
+				snprintf(tmp, sizeof(tmp), "%s:%s", ot->node.name, str);
+
+			if (c->filter_name)
+				filter_name(tmp, FILTER_PORT, c->filter_char);
+
+			op = find_port_by_name(c, tmp);
+			if (op != NULL)
+				snprintf(o->port.name, sizeof(o->port.name), "%.*s-%u",
+						(int)(sizeof(tmp)-11), tmp, serial);
+			else
+				snprintf(o->port.name, sizeof(o->port.name), "%s", tmp);
+		}
+
+		if ((str = spa_dict_lookup(props, PW_KEY_OBJECT_PATH)) != NULL)
+			snprintf(o->port.alias1, sizeof(o->port.alias1), "%s", str);
+
+		if ((str = spa_dict_lookup(props, PW_KEY_PORT_ALIAS)) != NULL)
+			snprintf(o->port.alias2, sizeof(o->port.alias2), "%s", str);
+
+		if ((str = spa_dict_lookup(props, PW_KEY_PORT_ID)) != NULL) {
+			o->port.system_id = atoi(str);
+			snprintf(o->port.system, sizeof(o->port.system), "system:%s_%d",
+					flags & JackPortIsInput ? "playback" :
+					is_monitor ? "monitor" : "capture",
+					o->port.system_id+1);
+		}
+
+		o->port.flags = flags;
+		o->port.type_id = type_id;
+		o->port.node_id = node_id;
+		o->port.is_monitor = is_monitor;
+
+		pw_log_debug("%p: %p add port %d name:%s %d", c, o, id,
+				o->port.name, type_id);
+	}
+	else if (spa_streq(type, PW_TYPE_INTERFACE_Link)) {
+		struct object *p;
+
+		o = alloc_object(c, INTERFACE_Link);
+
+		pthread_mutex_lock(&c->context.lock);
+		spa_list_append(&c->context.objects, &o->link);
+		pthread_mutex_unlock(&c->context.lock);
+
+		if ((str = spa_dict_lookup(props, PW_KEY_LINK_OUTPUT_PORT)) == NULL)
+			goto exit_free;
+		o->port_link.src = pw_properties_parse_int(str);
+
+		if ((p = find_type(c, o->port_link.src, INTERFACE_Port, true)) == NULL)
+			goto exit_free;
+		o->port_link.src_serial = p->serial;
+
+		o->port_link.src_ours = p->port.port != NULL &&
+			p->port.port->client == c;
+		if (o->port_link.src_ours)
+			o->port_link.our_output = p->port.port;
+
+		if ((str = spa_dict_lookup(props, PW_KEY_LINK_INPUT_PORT)) == NULL)
+			goto exit_free;
+		o->port_link.dst = pw_properties_parse_int(str);
+
+		if ((p = find_type(c, o->port_link.dst, INTERFACE_Port, true)) == NULL)
+			goto exit_free;
+		o->port_link.dst_serial = p->serial;
+
+		o->port_link.dst_ours = p->port.port != NULL &&
+			p->port.port->client == c;
+		if (o->port_link.dst_ours)
+			o->port_link.our_input = p->port.port;
+
+		o->port_link.is_complete = !o->port_link.src_ours && !o->port_link.dst_ours;
+		pw_log_debug("%p: add link %d %u/%u->%u/%u", c, id,
+				o->port_link.src, o->port_link.src_serial,
+				o->port_link.dst, o->port_link.dst_serial);
+	}
+	else if (spa_streq(type, PW_TYPE_INTERFACE_Metadata)) {
+		struct pw_proxy *proxy;
+
+		if (c->metadata != NULL)
+			goto exit;
+		if ((str = spa_dict_lookup(props, PW_KEY_METADATA_NAME)) == NULL)
+			goto exit;
+
+		if (spa_streq(str, "default")) {
+			proxy = pw_registry_bind(c->registry,
+					id, type, PW_VERSION_METADATA, sizeof(struct metadata));
+
+			c->metadata = pw_proxy_get_user_data(proxy);
+			c->metadata->proxy = (struct pw_metadata*)proxy;
+			c->metadata->default_audio_sink[0] = '\0';
+			c->metadata->default_audio_source[0] = '\0';
+
+			pw_proxy_add_listener(proxy,
+					&c->metadata->proxy_listener,
+					&metadata_proxy_events, c);
+			pw_metadata_add_listener(proxy,
+					&c->metadata->listener,
+					&metadata_events, c);
+		} else if (spa_streq(str, "settings")) {
+			proxy = pw_registry_bind(c->registry,
+					id, type, PW_VERSION_METADATA, sizeof(struct metadata));
+
+			c->settings = pw_proxy_get_user_data(proxy);
+			c->settings->proxy = (struct pw_metadata*)proxy;
+			pw_proxy_add_listener(proxy,
+					&c->settings->proxy_listener,
+					&settings_proxy_events, c);
+		}
+		goto exit;
+	}
+	else {
+		goto exit;
+	}
+
+	o->id = id;
+	o->serial = serial;
+
+	switch (o->type) {
+	case INTERFACE_Node:
+		if (is_first) {
+			pw_log_info("%p: client added \"%s\"", c, o->node.name);
+			do_callback(c, registration_callback,
+					o->node.name, 1, c->registration_arg);
+			graph_changed = true;
+		}
+		break;
+
+	case INTERFACE_Port:
+		pw_log_info("%p: port added %u/%u \"%s\"", c, o->id, o->serial, o->port.name);
+		do_callback(c, portregistration_callback,
+				o->serial, 1, c->portregistration_arg);
+		graph_changed = true;
+		break;
+
+	case INTERFACE_Link:
+		pw_log_info("%p: link %u %u/%u -> %u/%u added complete:%d", c,
+				o->id, o->port_link.src, o->port_link.src_serial,
+				o->port_link.dst, o->port_link.dst_serial,
+				o->port_link.is_complete);
+		if (o->port_link.is_complete) {
+			do_callback(c, connect_callback,
+					o->port_link.src_serial,
+					o->port_link.dst_serial, 1, c->connect_arg);
+			graph_changed = true;
+		}
+		break;
+	}
+	if (graph_changed) {
+		recompute_latencies(c);
+		do_callback(c, graph_callback, c->graph_arg);
+	}
+
+      exit:
+	return;
+      exit_free:
+	free_object(c, o);
+	return;
+}
+
+static void registry_event_global_remove(void *data, uint32_t id)
+{
+	struct client *c = (struct client *) data;
+	struct object *o;
+	bool graph_changed = false;
+
+	pw_log_debug("%p: removed: %u", c, id);
+
+	if ((o = find_id(c, id, true)) == NULL)
+		return;
+
+	if (o->proxy) {
+		pw_proxy_destroy(o->proxy);
+		o->proxy = NULL;
+	}
+	o->removing = true;
+
+	switch (o->type) {
+	case INTERFACE_Node:
+		if (c->metadata) {
+			if (spa_streq(o->node.node_name, c->metadata->default_audio_sink))
+				c->metadata->default_audio_sink[0] = '\0';
+			if (spa_streq(o->node.node_name, c->metadata->default_audio_source))
+				c->metadata->default_audio_source[0] = '\0';
+		}
+		if (find_node(c, o->node.name) == NULL) {
+			pw_log_info("%p: client %u removed \"%s\"", c, o->id, o->node.name);
+			do_callback(c, registration_callback,
+					o->node.name, 0, c->registration_arg);
+			graph_changed = true;
+		}
+		break;
+	case INTERFACE_Port:
+		pw_log_info("%p: port %u/%u removed \"%s\"", c, o->id, o->serial, o->port.name);
+		do_callback(c, portregistration_callback,
+				o->serial, 0, c->portregistration_arg);
+		graph_changed = true;
+		break;
+	case INTERFACE_Link:
+		if (o->port_link.is_complete &&
+		    find_type(c, o->port_link.src, INTERFACE_Port, true) != NULL &&
+		    find_type(c, o->port_link.dst, INTERFACE_Port, true) != NULL) {
+			pw_log_info("%p: link %u %u/%u -> %u/%u removed", c, o->id,
+					o->port_link.src, o->port_link.src_serial,
+					o->port_link.dst, o->port_link.dst_serial);
+			o->port_link.is_complete = false;
+			do_callback(c, connect_callback,
+					o->port_link.src_serial, o->port_link.dst_serial, 0, c->connect_arg);
+			graph_changed = true;
+		} else
+			pw_log_warn("unlink between unknown ports %d and %d",
+					o->port_link.src, o->port_link.dst);
+		break;
+	}
+	if (graph_changed) {
+		recompute_latencies(c);
+		do_callback(c, graph_callback, c->graph_arg);
+	}
+
+	o->removing = false;
+	free_object(c, o);
+
+	return;
+}
+
+static const struct pw_registry_events registry_events = {
+        PW_VERSION_REGISTRY_EVENTS,
+        .global = registry_event_global,
+        .global_remove = registry_event_global_remove,
+};
+
+static void varargs_parse (struct client *c, jack_options_t options, va_list ap)
+{
+	if ((options & JackServerName))
+		c->server_name = va_arg(ap, char *);
+	if ((options & JackLoadName))
+		c->load_name = va_arg(ap, char *);
+	if ((options & JackLoadInit))
+		c->load_init = va_arg(ap, char *);
+	if ((options & JackSessionID)) {
+		char *sid = va_arg(ap, char *);
+		if (sid) {
+			const long long id = atoll(sid);
+			if (id > 0)
+				c->session_id = id;
+		}
+	}
+}
+
+
+static int execute_match(void *data, const char *location, const char *action,
+		const char *val, size_t len)
+{
+	struct client *client = data;
+	if (spa_streq(action, "update-props"))
+		pw_properties_update_string(client->props, val, len);
+	return 1;
+}
+
+SPA_EXPORT
+jack_client_t * jack_client_open (const char *client_name,
+                                  jack_options_t options,
+                                  jack_status_t *status, ...)
+{
+	struct client *client;
+	const struct spa_support *support;
+	uint32_t n_support;
+	const char *str;
+	struct spa_cpu *cpu_iface;
+	va_list ap;
+
+        if (getenv("PIPEWIRE_NOJACK") != NULL ||
+            getenv("PIPEWIRE_INTERNAL") != NULL ||
+	    strstr(pw_get_library_version(), "0.2") != NULL)
+		goto disabled;
+
+	spa_return_val_if_fail(client_name != NULL, NULL);
+
+	client = calloc(1, sizeof(struct client));
+	if (client == NULL)
+		goto disabled;
+
+	pw_log_info("%p: open '%s' options:%d", client, client_name, options);
+
+	va_start(ap, status);
+	varargs_parse(client, options, ap);
+	va_end(ap);
+
+	snprintf(client->name, sizeof(client->name), "pw-%s", client_name);
+
+	pthread_mutex_init(&client->context.lock, NULL);
+	spa_list_init(&client->context.objects);
+
+	client->node_id = SPA_ID_INVALID;
+
+	client->buffer_frames = (uint32_t)-1;
+	client->sample_rate = (uint32_t)-1;
+	client->latency = SPA_FRACTION(-1, -1);
+
+	spa_list_init(&client->mix);
+	spa_list_init(&client->free_mix);
+
+	spa_list_init(&client->free_ports);
+	pw_map_init(&client->ports[SPA_DIRECTION_INPUT], 32, 32);
+	pw_map_init(&client->ports[SPA_DIRECTION_OUTPUT], 32, 32);
+
+	spa_list_init(&client->links);
+	client->driver_id = SPA_ID_INVALID;
+
+	spa_list_init(&client->rt.target_links);
+	pthread_mutex_init(&client->rt_lock, NULL);
+
+	if (client->server_name != NULL &&
+	    spa_streq(client->server_name, "default"))
+		client->server_name = NULL;
+
+	client->props = pw_properties_new(
+			"loop.cancel", "true",
+			PW_KEY_REMOTE_NAME, client->server_name,
+			PW_KEY_CLIENT_NAME, client_name,
+			PW_KEY_CLIENT_API, "jack",
+			PW_KEY_CONFIG_NAME, "jack.conf",
+			NULL);
+	if (client->props == NULL)
+		goto no_props;
+
+	client->context.loop = pw_thread_loop_new(client->name, NULL);
+	client->context.l = pw_thread_loop_get_loop(client->context.loop);
+	client->context.context = pw_context_new(
+			client->context.l,
+			pw_properties_copy(client->props),
+			0);
+	if (client->context.context == NULL)
+		goto no_props;
+
+	client->allow_mlock = client->context.context->settings.mem_allow_mlock;
+	client->warn_mlock = client->context.context->settings.mem_warn_mlock;
+
+	pw_context_conf_update_props(client->context.context,
+			"jack.properties", client->props);
+
+	pw_context_conf_section_match_rules(client->context.context, "jack.rules",
+			&client->context.context->properties->dict, execute_match, client);
+
+	support = pw_context_get_support(client->context.context, &n_support);
+
+	mix_function = mix_c;
+	cpu_iface = spa_support_find(support, n_support, SPA_TYPE_INTERFACE_CPU);
+	if (cpu_iface) {
+#if defined (__SSE__)
+		uint32_t flags = spa_cpu_get_flags(cpu_iface);
+		if (flags & SPA_CPU_FLAG_SSE)
+			mix_function = mix_sse;
+#endif
+	}
+	client->context.old_thread_utils =
+		pw_context_get_object(client->context.context,
+				SPA_TYPE_INTERFACE_ThreadUtils);
+	if (client->context.old_thread_utils == NULL)
+		client->context.old_thread_utils = pw_thread_utils_get();
+
+	globals.thread_utils = client->context.old_thread_utils;
+
+	client->context.thread_utils.iface = SPA_INTERFACE_INIT(
+			SPA_TYPE_INTERFACE_ThreadUtils,
+			SPA_VERSION_THREAD_UTILS,
+			&thread_utils_impl, client);
+
+	client->loop = client->context.context->data_loop_impl;
+	pw_data_loop_stop(client->loop);
+
+	pw_context_set_object(client->context.context,
+			SPA_TYPE_INTERFACE_ThreadUtils,
+			&client->context.thread_utils);
+
+	pw_thread_loop_start(client->context.loop);
+
+	pw_thread_loop_lock(client->context.loop);
+
+        client->core = pw_context_connect(client->context.context,
+				pw_properties_copy(client->props), 0);
+	if (client->core == NULL)
+		goto server_failed;
+
+	client->pool = pw_core_get_mempool(client->core);
+
+	pw_core_add_listener(client->core,
+			&client->core_listener,
+			&core_events, client);
+	client->registry = pw_core_get_registry(client->core,
+			PW_VERSION_REGISTRY, 0);
+	pw_registry_add_listener(client->registry,
+			&client->registry_listener,
+			&registry_events, client);
+
+	if ((str = getenv("PIPEWIRE_PROPS")) != NULL)
+		pw_properties_update_string(client->props, str, strlen(str));
+	if ((str = getenv("PIPEWIRE_QUANTUM")) != NULL) {
+		struct spa_fraction q;
+		if (sscanf(str, "%u/%u", &q.num, &q.denom) == 2 && q.denom != 0) {
+			pw_properties_setf(client->props, PW_KEY_NODE_RATE,
+					"1/%u", q.denom);
+			pw_properties_setf(client->props, PW_KEY_NODE_LATENCY,
+					"%u/%u", q.num, q.denom);
+		} else {
+			pw_log_warn("invalid PIPEWIRE_QUANTUM: %s", str);
+		}
+	}
+	if ((str = getenv("PIPEWIRE_LATENCY")) != NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_LATENCY, str);
+	if ((str = getenv("PIPEWIRE_RATE")) != NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_RATE, str);
+	if ((str = getenv("PIPEWIRE_LINK_PASSIVE")) != NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_PASSIVE, str);
+
+	if ((str = pw_properties_get(client->props, PW_KEY_NODE_LATENCY)) != NULL) {
+		uint32_t num, denom;
+		if (sscanf(str, "%u/%u", &num, &denom) == 2 && denom != 0) {
+			client->latency = SPA_FRACTION(num, denom);
+		}
+	}
+	if (pw_properties_get(client->props, PW_KEY_NODE_NAME) == NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_NAME, client_name);
+	if (pw_properties_get(client->props, PW_KEY_NODE_GROUP) == NULL)
+		pw_properties_setf(client->props, PW_KEY_NODE_GROUP, "jack-%d", getpid());
+	if (pw_properties_get(client->props, PW_KEY_NODE_DESCRIPTION) == NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_DESCRIPTION, client_name);
+	if (pw_properties_get(client->props, PW_KEY_MEDIA_TYPE) == NULL)
+		pw_properties_set(client->props, PW_KEY_MEDIA_TYPE, "Audio");
+	if (pw_properties_get(client->props, PW_KEY_MEDIA_CATEGORY) == NULL)
+		pw_properties_set(client->props, PW_KEY_MEDIA_CATEGORY, "Duplex");
+	if (pw_properties_get(client->props, PW_KEY_MEDIA_ROLE) == NULL)
+		pw_properties_set(client->props, PW_KEY_MEDIA_ROLE, "DSP");
+	if (pw_properties_get(client->props, PW_KEY_NODE_ALWAYS_PROCESS) == NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_ALWAYS_PROCESS, "true");
+	if (pw_properties_get(client->props, PW_KEY_NODE_LOCK_QUANTUM) == NULL)
+		pw_properties_set(client->props, PW_KEY_NODE_LOCK_QUANTUM, "true");
+	pw_properties_set(client->props, PW_KEY_NODE_TRANSPORT_SYNC, "true");
+
+	client->node = pw_core_create_object(client->core,
+				"client-node",
+				PW_TYPE_INTERFACE_ClientNode,
+				PW_VERSION_CLIENT_NODE,
+				&client->props->dict,
+				0);
+	if (client->node == NULL)
+		goto init_failed;
+
+	pw_client_node_add_listener(client->node,
+			&client->node_listener, &client_node_events, client);
+        pw_proxy_add_listener((struct pw_proxy*)client->node,
+			&client->proxy_listener, &node_proxy_events, client);
+
+	client->info = SPA_NODE_INFO_INIT();
+	client->info.max_input_ports = UINT32_MAX;
+	client->info.max_output_ports = UINT32_MAX;
+	client->info.change_mask = SPA_NODE_CHANGE_MASK_FLAGS |
+		SPA_NODE_CHANGE_MASK_PROPS;
+	client->info.flags = SPA_NODE_FLAG_RT;
+	client->info.props = &client->props->dict;
+
+	pw_client_node_update(client->node,
+			PW_CLIENT_NODE_UPDATE_INFO,
+			0, NULL, &client->info);
+	client->info.change_mask = 0;
+
+	client->show_monitor = pw_properties_get_bool(client->props, "jack.show-monitor", true);
+	client->merge_monitor = pw_properties_get_bool(client->props, "jack.merge-monitor", true);
+	client->short_name = pw_properties_get_bool(client->props, "jack.short-name", false);
+	client->filter_name = pw_properties_get_bool(client->props, "jack.filter-name", false);
+	client->filter_char = ' ';
+	if ((str = pw_properties_get(client->props, "jack.filter-char")) != NULL && str[0] != '\0')
+		client->filter_char = str[0];
+	client->locked_process = pw_properties_get_bool(client->props, "jack.locked-process", true);
+	client->default_as_system = pw_properties_get_bool(client->props, "jack.default-as-system", false);
+	client->fix_midi_events = pw_properties_get_bool(client->props, "jack.fix-midi-events", true);
+	client->global_buffer_size = pw_properties_get_bool(client->props, "jack.global-buffer-size", false);
+
+	client->self_connect_mode = SELF_CONNECT_ALLOW;
+	if ((str = pw_properties_get(client->props, "jack.self-connect-mode")) != NULL) {
+		if (spa_streq(str, "fail-external"))
+			client->self_connect_mode = SELF_CONNECT_FAIL_EXT;
+		else if (spa_streq(str, "ignore-external"))
+			client->self_connect_mode = SELF_CONNECT_IGNORE_EXT;
+		else if (spa_streq(str, "fail-all"))
+			client->self_connect_mode = SELF_CONNECT_FAIL_ALL;
+		else if (spa_streq(str, "ignore-all"))
+			client->self_connect_mode = SELF_CONNECT_IGNORE_ALL;
+	}
+	client->rt_max = pw_properties_get_int32(client->props, "rt.prio", DEFAULT_RT_MAX);
+
+	if (status)
+		*status = 0;
+
+	while (true) {
+	        pw_thread_loop_wait(client->context.loop);
+
+		if (client->last_res < 0)
+			goto init_failed;
+
+		if (client->has_transport)
+			break;
+	}
+
+	if (!spa_streq(client->name, client_name)) {
+		if (status)
+			*status |= JackNameNotUnique;
+		if (options & JackUseExactName)
+			goto exit_unlock;
+	}
+	pw_thread_loop_unlock(client->context.loop);
+
+	pw_log_info("%p: opened", client);
+	return (jack_client_t *)client;
+
+no_props:
+	if (status)
+		*status = JackFailure | JackInitFailure;
+	goto exit;
+init_failed:
+	if (status)
+		*status = JackFailure | JackInitFailure;
+	goto exit_unlock;
+server_failed:
+	if (status)
+		*status = JackFailure | JackServerFailed;
+	goto exit_unlock;
+exit_unlock:
+	pw_thread_loop_unlock(client->context.loop);
+exit:
+	jack_client_close((jack_client_t *) client);
+	return NULL;
+disabled:
+	if (status)
+		*status = JackFailure | JackInitFailure;
+	return NULL;
+}
+
+SPA_EXPORT
+jack_client_t * jack_client_new (const char *client_name)
+{
+	jack_options_t options = JackUseExactName;
+	jack_status_t status;
+
+        if (getenv("JACK_START_SERVER") == NULL)
+		options |= JackNoStartServer;
+
+	return jack_client_open(client_name, options, &status, NULL);
+}
+
+SPA_EXPORT
+int jack_client_close (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	struct object *o;
+	int res;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_log_info("%p: close", client);
+
+	c->destroyed = true;
+
+	res = jack_deactivate(client);
+
+	clean_transport(c);
+
+	if (c->context.loop)
+		pw_thread_loop_stop(c->context.loop);
+
+	if (c->registry) {
+		spa_hook_remove(&c->registry_listener);
+		pw_proxy_destroy((struct pw_proxy*)c->registry);
+	}
+	if (c->metadata && c->metadata->proxy) {
+		pw_proxy_destroy((struct pw_proxy*)c->metadata->proxy);
+	}
+	if (c->settings && c->settings->proxy) {
+		pw_proxy_destroy((struct pw_proxy*)c->settings->proxy);
+	}
+
+	if (c->core) {
+		spa_hook_remove(&c->core_listener);
+		pw_core_disconnect(c->core);
+	}
+
+	if (c->context.context)
+		pw_context_destroy(c->context.context);
+
+	if (c->context.loop)
+		pw_thread_loop_destroy(c->context.loop);
+
+	pw_log_debug("%p: free", client);
+
+	spa_list_consume(o, &c->context.objects, link)
+		free_object(c, o);
+	recycle_objects(c, 0);
+
+	pw_map_clear(&c->ports[SPA_DIRECTION_INPUT]);
+	pw_map_clear(&c->ports[SPA_DIRECTION_OUTPUT]);
+
+	pthread_mutex_destroy(&c->context.lock);
+	pthread_mutex_destroy(&c->rt_lock);
+	pw_properties_free(c->props);
+	free(c);
+
+	return res;
+}
+
+SPA_EXPORT
+jack_intclient_t jack_internal_client_handle (jack_client_t *client,
+		const char *client_name, jack_status_t *status)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, 0);
+	if (status)
+		*status = JackNoSuchClient | JackFailure;
+	return 0;
+}
+
+SPA_EXPORT
+jack_intclient_t jack_internal_client_load (jack_client_t *client,
+		const char *client_name, jack_options_t options,
+		jack_status_t *status, ...)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, 0);
+	if (status)
+		*status = JackNoSuchClient | JackFailure;
+	return 0;
+}
+
+SPA_EXPORT
+jack_status_t jack_internal_client_unload (jack_client_t *client,
+        jack_intclient_t intclient)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, 0);
+	return JackFailure | JackNoSuchClient;
+}
+
+SPA_EXPORT
+char *jack_get_internal_client_name (jack_client_t *client,
+		jack_intclient_t intclient)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, NULL);
+	return strdup(c->name);
+}
+
+SPA_EXPORT
+int jack_client_name_size (void)
+{
+	/* The JACK API specifies that this value includes the final NULL character. */
+	pw_log_trace("%d", JACK_CLIENT_NAME_SIZE+1);
+	return JACK_CLIENT_NAME_SIZE+1;
+}
+
+SPA_EXPORT
+char * jack_get_client_name (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, NULL);
+	return c->name;
+}
+
+SPA_EXPORT
+char *jack_get_uuid_for_client_name (jack_client_t *client,
+                                     const char    *client_name)
+{
+	struct client *c = (struct client *) client;
+	struct object *o;
+	char *uuid = NULL;
+	bool monitor;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+	spa_return_val_if_fail(client_name != NULL, NULL);
+
+	monitor = spa_strendswith(client_name, MONITOR_EXT);
+
+	pthread_mutex_lock(&c->context.lock);
+
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->type != INTERFACE_Node)
+			continue;
+		if (spa_streq(o->node.name, client_name) ||
+		    (monitor && spa_strneq(o->node.name, client_name,
+			    strlen(client_name) - strlen(MONITOR_EXT)))) {
+			uuid = spa_aprintf( "%" PRIu64, client_make_uuid(o->serial, monitor));
+			break;
+		}
+	}
+	pw_log_debug("%p: name %s -> %s", client, client_name, uuid);
+	pthread_mutex_unlock(&c->context.lock);
+	return uuid;
+}
+
+SPA_EXPORT
+char *jack_get_client_name_by_uuid (jack_client_t *client,
+                                    const char    *client_uuid )
+{
+	struct client *c = (struct client *) client;
+	struct object *o;
+	jack_uuid_t uuid;
+	char *name = NULL;
+	bool monitor;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+	spa_return_val_if_fail(client_uuid != NULL, NULL);
+
+	if (jack_uuid_parse(client_uuid, &uuid) < 0)
+		return NULL;
+
+	monitor = uuid & (1 << 30);
+
+	pthread_mutex_lock(&c->context.lock);
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->type != INTERFACE_Node)
+			continue;
+		if (client_make_uuid(o->serial, monitor) == uuid) {
+			pw_log_debug("%p: uuid %s (%"PRIu64")-> %s",
+					client, client_uuid, uuid, o->node.name);
+			name = spa_aprintf("%s%s", o->node.name, monitor ? MONITOR_EXT : "");
+			break;
+		}
+	}
+	pthread_mutex_unlock(&c->context.lock);
+	return name;
+}
+
+SPA_EXPORT
+int jack_internal_client_new (const char *client_name,
+                              const char *load_name,
+                              const char *load_init)
+{
+	pw_log_warn("not implemented %s %s %s", client_name, load_name, load_init);
+	return -ENOTSUP;
+}
+
+SPA_EXPORT
+void jack_internal_client_close (const char *client_name)
+{
+	pw_log_warn("not implemented %s", client_name);
+}
+
+static int do_activate(struct client *c)
+{
+	int res;
+	pw_client_node_set_active(c->node, true);
+	res = do_sync(c);
+	return res;
+}
+
+SPA_EXPORT
+int jack_activate (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	int res = 0;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_log_info("%p: active:%d", c, c->active);
+
+	if (c->active)
+		return 0;
+
+	pw_thread_loop_lock(c->context.loop);
+	pw_data_loop_start(c->loop);
+
+	if ((res = do_activate(c)) < 0)
+		goto done;
+
+	c->activation->pending_new_pos = true;
+	c->activation->pending_sync = true;
+
+	c->active = true;
+
+	do_callback(c, graph_callback, c->graph_arg);
+
+done:
+	if (res < 0)
+		pw_data_loop_stop(c->loop);
+
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_deactivate (jack_client_t *client)
+{
+	struct object *l;
+	struct client *c = (struct client *) client;
+	int res;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_log_info("%p: active:%d", c, c->active);
+
+	if (!c->active)
+		return 0;
+
+	pw_thread_loop_lock(c->context.loop);
+	pw_data_loop_stop(c->loop);
+
+	pw_client_node_set_active(c->node, false);
+
+	c->activation->pending_new_pos = false;
+	c->activation->pending_sync = false;
+
+	spa_list_for_each(l, &c->context.objects, link) {
+		if (l->type != INTERFACE_Link || l->removed)
+			continue;
+		if (l->port_link.src_ours || l->port_link.dst_ours)
+			pw_registry_destroy(c->registry, l->id);
+	}
+
+	res = do_sync(c);
+
+	pw_thread_loop_unlock(c->context.loop);
+
+	if (res < 0)
+		return res;
+
+	c->active = false;
+
+	return 0;
+}
+
+SPA_EXPORT
+int jack_get_client_pid (const char *name)
+{
+	pw_log_error("not implemented on library side");
+	return 0;
+}
+
+SPA_EXPORT
+jack_native_thread_t jack_client_thread_id (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, (pthread_t){0});
+
+	return (jack_native_thread_t)pw_data_loop_get_thread(c->loop);
+}
+
+SPA_EXPORT
+int jack_is_realtime (jack_client_t *client)
+{
+	return 1;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_thread_wait (jack_client_t *client, int status)
+{
+	pw_log_error("%p: jack_thread_wait: deprecated, use jack_cycle_wait/jack_cycle_signal", client);
+	return 0;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_cycle_wait (jack_client_t* client)
+{
+	struct client *c = (struct client *) client;
+	jack_nframes_t res;
+
+	spa_return_val_if_fail(c != NULL, 0);
+
+	res = cycle_wait(c);
+	pw_log_trace("%p: result:%d", c, res);
+	return res;
+}
+
+SPA_EXPORT
+void jack_cycle_signal (jack_client_t* client, int status)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_if_fail(c != NULL);
+
+	pw_log_trace("%p: status:%d", c, status);
+	cycle_signal(c, status);
+}
+
+SPA_EXPORT
+int jack_set_process_thread(jack_client_t* client, JackThreadCallback thread_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	} else if (c->process_callback) {
+		pw_log_error("%p: process callback was already set", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, thread_callback, arg);
+	c->thread_callback = thread_callback;
+	c->thread_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_thread_init_callback (jack_client_t *client,
+                                   JackThreadInitCallback thread_init_callback,
+                                   void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_log_debug("%p: %p %p", c, thread_init_callback, arg);
+	c->thread_init_callback = thread_init_callback;
+	c->thread_init_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+void jack_on_shutdown (jack_client_t *client,
+                       JackShutdownCallback shutdown_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_if_fail(c != NULL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+	} else {
+		pw_log_debug("%p: %p %p", c, shutdown_callback, arg);
+		c->shutdown_callback = shutdown_callback;
+		c->shutdown_arg = arg;
+	}
+}
+
+SPA_EXPORT
+void jack_on_info_shutdown (jack_client_t *client,
+                            JackInfoShutdownCallback shutdown_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_if_fail(c != NULL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+	} else {
+		pw_log_debug("%p: %p %p", c, shutdown_callback, arg);
+		c->info_shutdown_callback = shutdown_callback;
+		c->info_shutdown_arg = arg;
+	}
+}
+
+SPA_EXPORT
+int jack_set_process_callback (jack_client_t *client,
+                               JackProcessCallback process_callback,
+                               void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	} else if (c->thread_callback) {
+		pw_log_error("%p: thread callback was already set", c);
+		return -EIO;
+	}
+
+	pw_log_debug("%p: %p %p", c, process_callback, arg);
+	c->process_callback = process_callback;
+	c->process_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_freewheel_callback (jack_client_t *client,
+                                 JackFreewheelCallback freewheel_callback,
+                                 void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, freewheel_callback, arg);
+	c->freewheel_callback = freewheel_callback;
+	c->freewheel_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_buffer_size_callback (jack_client_t *client,
+                                   JackBufferSizeCallback bufsize_callback,
+                                   void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, bufsize_callback, arg);
+	c->bufsize_callback = bufsize_callback;
+	c->bufsize_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_sample_rate_callback (jack_client_t *client,
+                                   JackSampleRateCallback srate_callback,
+                                   void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, srate_callback, arg);
+	c->srate_callback = srate_callback;
+	c->srate_arg = arg;
+	if (c->srate_callback && c->sample_rate != (uint32_t)-1)
+		c->srate_callback(c->sample_rate, c->srate_arg);
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_client_registration_callback (jack_client_t *client,
+                                            JackClientRegistrationCallback
+                                            registration_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, registration_callback, arg);
+	c->registration_callback = registration_callback;
+	c->registration_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_port_registration_callback (jack_client_t *client,
+                                          JackPortRegistrationCallback
+                                          registration_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, registration_callback, arg);
+	c->portregistration_callback = registration_callback;
+	c->portregistration_arg = arg;
+	return 0;
+}
+
+
+SPA_EXPORT
+int jack_set_port_connect_callback (jack_client_t *client,
+                                    JackPortConnectCallback
+                                    connect_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, connect_callback, arg);
+	c->connect_callback = connect_callback;
+	c->connect_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_port_rename_callback (jack_client_t *client,
+                                   JackPortRenameCallback rename_callback,
+				   void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, rename_callback, arg);
+	c->rename_callback = rename_callback;
+	c->rename_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_graph_order_callback (jack_client_t *client,
+                                   JackGraphOrderCallback graph_callback,
+                                   void *data)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, graph_callback, data);
+	c->graph_callback = graph_callback;
+	c->graph_arg = data;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_xrun_callback (jack_client_t *client,
+                            JackXRunCallback xrun_callback, void *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, xrun_callback, arg);
+	c->xrun_callback = xrun_callback;
+	c->xrun_arg = arg;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_latency_callback (jack_client_t *client,
+			       JackLatencyCallback latency_callback,
+			       void *data)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_debug("%p: %p %p", c, latency_callback, data);
+	c->latency_callback = latency_callback;
+	c->latency_arg = data;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_freewheel(jack_client_t* client, int onoff)
+{
+	struct client *c = (struct client *) client;
+
+	pw_log_info("%p: freewheel %d", client, onoff);
+
+	pw_thread_loop_lock(c->context.loop);
+	pw_properties_set(c->props, "node.group",
+			onoff ? "pipewire.freewheel" : "");
+
+	c->info.change_mask |= SPA_NODE_CHANGE_MASK_PROPS;
+	c->info.props = &c->props->dict;
+
+	pw_client_node_update(c->node,
+                                    PW_CLIENT_NODE_UPDATE_INFO,
+				    0, NULL, &c->info);
+	c->info.change_mask = 0;
+	pw_thread_loop_unlock(c->context.loop);
+
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_buffer_size (jack_client_t *client, jack_nframes_t nframes)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_log_info("%p: buffer-size %u", client, nframes);
+
+	pw_thread_loop_lock(c->context.loop);
+	if (c->global_buffer_size && c->settings && c->settings->proxy) {
+		char val[256];
+		snprintf(val, sizeof(val), "%u", nframes == 1 ? 0: nframes);
+		pw_metadata_set_property(c->settings->proxy, 0,
+				"clock.force-quantum", "", val);
+	} else {
+		pw_properties_setf(c->props, PW_KEY_NODE_FORCE_QUANTUM, "%u", nframes);
+
+		c->info.change_mask |= SPA_NODE_CHANGE_MASK_PROPS;
+		c->info.props = &c->props->dict;
+
+		pw_client_node_update(c->node,
+	                                    PW_CLIENT_NODE_UPDATE_INFO,
+					    0, NULL, &c->info);
+		c->info.change_mask = 0;
+	}
+	pw_thread_loop_unlock(c->context.loop);
+
+	return 0;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_get_sample_rate (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	jack_nframes_t res = -1;
+
+	spa_return_val_if_fail(c != NULL, 0);
+
+	if (!c->active)
+		res = c->latency.denom;
+	if (c->active || res == (uint32_t)-1) {
+		res = c->sample_rate;
+		if (res == (uint32_t)-1) {
+			if (c->rt.position)
+				res = c->rt.position->clock.rate.denom;
+			else if (c->position)
+				res = c->position->clock.rate.denom;
+		}
+	}
+	pw_log_debug("sample_rate: %u", res);
+	return res;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_get_buffer_size (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	jack_nframes_t res = -1;
+
+	spa_return_val_if_fail(c != NULL, 0);
+
+	if (!c->active)
+		res = c->latency.num;
+	if (c->active || res == (uint32_t)-1) {
+		res = c->buffer_frames;
+		if (res == (uint32_t)-1) {
+			if (c->rt.position)
+				res = c->rt.position->clock.duration;
+			else if (c->position)
+				res = c->position->clock.duration;
+		}
+	}
+	c->buffer_frames = res;
+	pw_log_debug("buffer_frames: %u", res);
+	return res;
+}
+
+SPA_EXPORT
+int jack_engine_takeover_timebase (jack_client_t *client)
+{
+	pw_log_error("%p: deprecated", client);
+	return 0;
+}
+
+SPA_EXPORT
+float jack_cpu_load (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	float res = 0.0f;
+
+	spa_return_val_if_fail(c != NULL, 0.0);
+
+	if (c->driver_activation)
+		res = c->driver_activation->cpu_load[0] * 100.0f;
+
+	pw_log_trace("%p: cpu load %f", client, res);
+	return res;
+}
+
+#include "statistics.c"
+
+static void *get_buffer_input_float(struct port *p, jack_nframes_t frames);
+static void *get_buffer_input_midi(struct port *p, jack_nframes_t frames);
+static void *get_buffer_input_empty(struct port *p, jack_nframes_t frames);
+static void *get_buffer_output_float(struct port *p, jack_nframes_t frames);
+static void *get_buffer_output_midi(struct port *p, jack_nframes_t frames);
+static void *get_buffer_output_empty(struct port *p, jack_nframes_t frames);
+
+SPA_EXPORT
+jack_port_t * jack_port_register (jack_client_t *client,
+                                  const char *port_name,
+                                  const char *port_type,
+                                  unsigned long flags,
+                                  unsigned long buffer_frames)
+{
+	struct client *c = (struct client *) client;
+	enum spa_direction direction;
+	struct object *o;
+	jack_port_type_id_t type_id;
+	uint8_t buffer[1024];
+	struct spa_pod_builder b = SPA_POD_BUILDER_INIT(buffer, sizeof(buffer));
+	struct spa_pod *params[6];
+	uint32_t n_params = 0;
+	struct port *p;
+	int res;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+	spa_return_val_if_fail(port_name != NULL, NULL);
+	spa_return_val_if_fail(port_type != NULL, NULL);
+
+	pw_log_info("%p: port register \"%s:%s\" \"%s\" %08lx %ld",
+			c, c->name, port_name, port_type, flags, buffer_frames);
+
+	if (flags & JackPortIsInput)
+		direction = PW_DIRECTION_INPUT;
+	else if (flags & JackPortIsOutput)
+		direction = PW_DIRECTION_OUTPUT;
+	else {
+		pw_log_warn("invalid port flags %lu for %s", flags, port_name);
+		return NULL;
+	}
+
+	if ((type_id = string_to_type(port_type)) == SPA_ID_INVALID) {
+		pw_log_warn("unknown port type %s", port_type);
+		return NULL;
+	}
+
+	if ((p = alloc_port(c, direction)) == NULL) {
+		pw_log_warn("can't allocate port %s: %m", port_name);
+		return NULL;
+	}
+
+	o = p->object;
+	o->port.flags = flags;
+	snprintf(o->port.name, sizeof(o->port.name), "%s:%s", c->name, port_name);
+	o->port.type_id = type_id;
+
+	init_buffer(p);
+
+	if (direction == SPA_DIRECTION_INPUT) {
+		switch (type_id) {
+		case TYPE_ID_AUDIO:
+		case TYPE_ID_VIDEO:
+			p->get_buffer = get_buffer_input_float;
+			break;
+		case TYPE_ID_MIDI:
+			p->get_buffer = get_buffer_input_midi;
+			break;
+		default:
+			p->get_buffer = get_buffer_input_empty;
+			break;
+		}
+	} else {
+		switch (type_id) {
+		case TYPE_ID_AUDIO:
+		case TYPE_ID_VIDEO:
+			p->get_buffer = get_buffer_output_float;
+			break;
+		case TYPE_ID_MIDI:
+			p->get_buffer = get_buffer_output_midi;
+			break;
+		default:
+			p->get_buffer = get_buffer_output_empty;
+			break;
+		}
+	}
+
+	pw_log_debug("%p: port %p", c, p);
+
+	spa_list_init(&p->mix);
+
+	pw_properties_set(p->props, PW_KEY_FORMAT_DSP, port_type);
+	pw_properties_set(p->props, PW_KEY_PORT_NAME, port_name);
+	if (flags > 0x1f) {
+		pw_properties_setf(p->props, PW_KEY_PORT_EXTRA,
+				"jack:flags:%lu", flags & ~0x1f);
+	}
+	if (flags & JackPortIsPhysical)
+		pw_properties_set(p->props, PW_KEY_PORT_PHYSICAL, "true");
+	if (flags & JackPortIsTerminal)
+		pw_properties_set(p->props, PW_KEY_PORT_TERMINAL, "true");
+
+	p->info = SPA_PORT_INFO_INIT();
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_FLAGS;
+	p->info.flags = SPA_PORT_FLAG_NO_REF;
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PROPS;
+	p->info.props = &p->props->dict;
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PARAMS;
+	p->params[IDX_EnumFormat] = SPA_PARAM_INFO(SPA_PARAM_EnumFormat, SPA_PARAM_INFO_READ);
+	p->params[IDX_Buffers] = SPA_PARAM_INFO(SPA_PARAM_Buffers, SPA_PARAM_INFO_READ);
+	p->params[IDX_IO] = SPA_PARAM_INFO(SPA_PARAM_IO, SPA_PARAM_INFO_READ);
+	p->params[IDX_Format] = SPA_PARAM_INFO(SPA_PARAM_Format, SPA_PARAM_INFO_WRITE);
+	p->params[IDX_Latency] = SPA_PARAM_INFO(SPA_PARAM_Latency, SPA_PARAM_INFO_READWRITE);
+	p->info.params = p->params;
+	p->info.n_params = N_PORT_PARAMS;
+
+	param_enum_format(c, p, &params[n_params++], &b);
+	param_buffers(c, p, &params[n_params++], &b);
+	param_io(c, p, &params[n_params++], &b);
+	param_latency(c, p, &params[n_params++], &b);
+	param_latency_other(c, p, &params[n_params++], &b);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	pw_client_node_port_update(c->node,
+					 direction,
+					 p->port_id,
+					 PW_CLIENT_NODE_PORT_UPDATE_PARAMS |
+					 PW_CLIENT_NODE_PORT_UPDATE_INFO,
+					 n_params,
+					 (const struct spa_pod **) params,
+					 &p->info);
+
+	p->info.change_mask = 0;
+
+	res = do_sync(c);
+
+	pw_thread_loop_unlock(c->context.loop);
+
+	if (res < 0) {
+		pw_log_warn("can't create port %s: %s", port_name,
+				spa_strerror(res));
+		return NULL;
+	}
+
+	return (jack_port_t *) o;
+}
+
+static int
+do_invalidate_port(struct spa_loop *loop,
+                  bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct port *p = user_data;
+	p->valid = false;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_port_unregister (jack_client_t *client, jack_port_t *port)
+{
+	struct client *c = (struct client *) client;
+	struct object *o = (struct object *) port;
+	struct port *p;
+	int res;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	p = o->port.port;
+	if (o->type != INTERFACE_Port || p == NULL || !p->valid ||
+	    o->client != c) {
+		pw_log_error("%p: invalid port %p", client, port);
+		res = -EINVAL;
+		goto done;
+	}
+	pw_data_loop_invoke(c->loop,
+			do_invalidate_port, 1, NULL, 0, !c->data_locked, p);
+
+	pw_log_info("%p: port %p unregister \"%s\"", client, port, o->port.name);
+
+	pw_client_node_port_update(c->node,
+					 p->direction,
+					 p->port_id,
+					 0, 0, NULL, NULL);
+
+	res = do_sync(c);
+	if (res < 0) {
+		pw_log_warn("can't unregister port %s: %s", o->port.name,
+				spa_strerror(res));
+	}
+	free_port(c, p);
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+static struct buffer *get_mix_buffer(struct mix *mix, jack_nframes_t frames)
+{
+	struct spa_io_buffers *io;
+
+	if (mix->peer_port != NULL)
+		prepare_output(mix->peer_port, frames);
+
+	io = mix->io;
+	if (io == NULL ||
+	    io->status != SPA_STATUS_HAVE_DATA ||
+	    io->buffer_id >= mix->n_buffers)
+		return NULL;
+
+	return &mix->buffers[io->buffer_id];
+}
+
+static void *get_buffer_input_float(struct port *p, jack_nframes_t frames)
+{
+	struct mix *mix;
+	struct buffer *b;
+	void *ptr = NULL;
+	float *mix_ptr[MAX_MIX], *np;
+	uint32_t n_ptr = 0;
+	bool ptr_aligned = true;
+
+	spa_list_for_each(mix, &p->mix, port_link) {
+		struct spa_data *d;
+		uint32_t offset, size;
+
+		pw_log_trace_fp("%p: port %s mix %d.%d get buffer %d",
+				p->client, p->object->port.name, p->port_id, mix->id, frames);
+
+		if ((b = get_mix_buffer(mix, frames)) == NULL)
+			continue;
+
+		d = &b->datas[0];
+		offset = SPA_MIN(d->chunk->offset, d->maxsize);
+		size = SPA_MIN(d->chunk->size, d->maxsize - offset);
+		if (size / sizeof(float) < frames)
+			continue;
+
+		np = SPA_PTROFF(d->data, offset, float);
+		if (!SPA_IS_ALIGNED(np, 16))
+			ptr_aligned = false;
+
+		mix_ptr[n_ptr++] = np;
+		if (n_ptr == MAX_MIX)
+			break;
+	}
+	if (n_ptr == 1) {
+		ptr = mix_ptr[0];
+	} else if (n_ptr > 1) {
+		ptr = p->emptyptr;
+		mix_function(ptr, mix_ptr, n_ptr, ptr_aligned, frames);
+		p->zeroed = false;
+	}
+	if (ptr == NULL)
+		ptr = init_buffer(p);
+	return ptr;
+}
+
+static void *get_buffer_input_midi(struct port *p, jack_nframes_t frames)
+{
+	struct mix *mix;
+	void *ptr = p->emptyptr;
+	struct spa_pod_sequence *seq[MAX_MIX];
+	uint32_t n_seq = 0;
+
+	jack_midi_clear_buffer(ptr);
+
+	spa_list_for_each(mix, &p->mix, port_link) {
+		struct spa_data *d;
+		struct buffer *b;
+		void *pod;
+
+		pw_log_trace_fp("%p: port %p mix %d.%d get buffer %d",
+				p->client, p, p->port_id, mix->id, frames);
+
+		if ((b = get_mix_buffer(mix, frames)) == NULL)
+			continue;
+
+		d = &b->datas[0];
+
+		if ((pod = spa_pod_from_data(d->data, d->maxsize, d->chunk->offset, d->chunk->size)) == NULL)
+			continue;
+		if (!spa_pod_is_sequence(pod))
+			continue;
+
+		seq[n_seq++] = pod;
+		if (n_seq == MAX_MIX)
+			break;
+	}
+	convert_to_midi(seq, n_seq, ptr, p->client->fix_midi_events);
+
+	return ptr;
+}
+
+static void *get_buffer_output_float(struct port *p, jack_nframes_t frames)
+{
+	void *ptr;
+
+	ptr = get_buffer_output(p, frames, sizeof(float), NULL);
+	if (SPA_UNLIKELY(p->empty_out = (ptr == NULL)))
+		ptr = p->emptyptr;
+	return ptr;
+}
+
+static void *get_buffer_output_midi(struct port *p, jack_nframes_t frames)
+{
+	p->empty_out = true;
+	return p->emptyptr;
+}
+
+static void *get_buffer_output_empty(struct port *p, jack_nframes_t frames)
+{
+	p->empty_out = true;
+	return p->emptyptr;
+}
+
+static void *get_buffer_input_empty(struct port *p, jack_nframes_t frames)
+{
+	return init_buffer(p);
+}
+
+SPA_EXPORT
+void * jack_port_get_buffer (jack_port_t *port, jack_nframes_t frames)
+{
+	struct object *o = (struct object *) port;
+	struct port *p;
+	void *ptr;
+
+	spa_return_val_if_fail(o != NULL, NULL);
+
+	if (o->type != INTERFACE_Port || o->client == NULL)
+		return NULL;
+
+	if ((p = o->port.port) == NULL) {
+		struct mix *mix;
+		struct buffer *b;
+		struct spa_data *d;
+		uint32_t offset, size;
+
+		if ((mix = find_mix_peer(o->client, o->id)) == NULL)
+			return NULL;
+
+		pw_log_trace("peer mix: %p %d", mix, mix->peer_id);
+
+		if ((b = get_mix_buffer(mix, frames)) == NULL)
+			return NULL;
+
+		d = &b->datas[0];
+		offset = SPA_MIN(d->chunk->offset, d->maxsize);
+		size = SPA_MIN(d->chunk->size, d->maxsize - offset);
+		if (size / sizeof(float) < frames)
+			return NULL;
+
+		return SPA_PTROFF(d->data, offset, void);
+	}
+	if (!p->valid)
+		return NULL;
+
+	ptr = p->get_buffer(p, frames);
+	pw_log_trace_fp("%p: port %p buffer %p empty:%u", p->client, p, ptr, p->empty_out);
+	return ptr;
+}
+
+SPA_EXPORT
+jack_uuid_t jack_port_uuid (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, 0);
+	return jack_port_uuid_generate(o->serial);
+}
+
+static const char *port_name(struct object *o)
+{
+	const char *name;
+	struct client *c = o->client;
+	if (c->default_as_system && is_port_default(c, o))
+		name = o->port.system;
+	else
+		name = o->port.name;
+	return name;
+}
+
+SPA_EXPORT
+const char * jack_port_name (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, NULL);
+	return port_name(o);
+}
+
+SPA_EXPORT
+const char * jack_port_short_name (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, NULL);
+	return strchr(port_name(o), ':') + 1;
+}
+
+SPA_EXPORT
+int jack_port_flags (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, 0);
+	return o->port.flags;
+}
+
+SPA_EXPORT
+const char * jack_port_type (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, NULL);
+	return type_to_string(o->port.type_id);
+}
+
+SPA_EXPORT
+jack_port_type_id_t jack_port_type_id (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, 0);
+	return o->port.type_id;
+}
+
+SPA_EXPORT
+int jack_port_is_mine (const jack_client_t *client, const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, 0);
+	return o->type == INTERFACE_Port &&
+		o->port.port != NULL &&
+		o->port.port->client == (struct client*)client;
+}
+
+SPA_EXPORT
+int jack_port_connected (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	struct object *l;
+	int res = 0;
+
+	spa_return_val_if_fail(o != NULL, 0);
+	if (o->type != INTERFACE_Port || o->client == NULL)
+		return 0;
+
+	c = o->client;
+
+	pthread_mutex_lock(&c->context.lock);
+	spa_list_for_each(l, &c->context.objects, link) {
+		if (l->type != INTERFACE_Link || l->removed)
+			continue;
+		if (!l->port_link.is_complete)
+			continue;
+		if (l->port_link.src_serial == o->serial ||
+		    l->port_link.dst_serial == o->serial)
+			res++;
+	}
+	pthread_mutex_unlock(&c->context.lock);
+
+	pw_log_debug("%p: id:%u/%u res:%d", port, o->id, o->serial, res);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_port_connected_to (const jack_port_t *port,
+                            const char *port_name)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	struct object *p, *l;
+	int res = 0;
+
+	spa_return_val_if_fail(o != NULL, 0);
+	spa_return_val_if_fail(port_name != NULL, 0);
+	if (o->type != INTERFACE_Port || o->client == NULL)
+		return 0;
+
+	c = o->client;
+
+	pthread_mutex_lock(&c->context.lock);
+
+	p = find_port_by_name(c, port_name);
+	if (p == NULL)
+		goto exit;
+
+	if (GET_DIRECTION(p->port.flags) == GET_DIRECTION(o->port.flags))
+		goto exit;
+
+	if (p->port.flags & JackPortIsOutput) {
+		l = p;
+		p = o;
+		o = l;
+	}
+	if ((l = find_link(c, o->id, p->id)) != NULL &&
+	    l->port_link.is_complete)
+		res = 1;
+
+     exit:
+	pthread_mutex_unlock(&c->context.lock);
+	pw_log_debug("%p: id:%u/%u name:%s res:%d", port, o->id,
+			o->serial, port_name, res);
+
+	return res;
+}
+
+SPA_EXPORT
+const char ** jack_port_get_connections (const jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+
+	spa_return_val_if_fail(o != NULL, NULL);
+	if (o->type != INTERFACE_Port || o->client == NULL)
+		return NULL;
+
+	return jack_port_get_all_connections((jack_client_t *)o->client, port);
+}
+
+SPA_EXPORT
+const char ** jack_port_get_all_connections (const jack_client_t *client,
+                                             const jack_port_t *port)
+{
+	struct client *c = (struct client *) client;
+	struct object *o = (struct object *) port;
+	struct object *p, *l;
+	const char **res;
+	int count = 0;
+	struct pw_array tmp;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+	spa_return_val_if_fail(o != NULL, NULL);
+
+	pw_array_init(&tmp, sizeof(void*) * 32);
+
+	pthread_mutex_lock(&c->context.lock);
+	spa_list_for_each(l, &c->context.objects, link) {
+		if (l->type != INTERFACE_Link || l->removed)
+			continue;
+		if (l->port_link.src_serial == o->serial)
+			p = find_type(c, l->port_link.dst, INTERFACE_Port, true);
+		else if (l->port_link.dst_serial == o->serial)
+			p = find_type(c, l->port_link.src, INTERFACE_Port, true);
+		else
+			continue;
+
+		if (p == NULL)
+			continue;
+
+		pw_array_add_ptr(&tmp, (void*)port_name(p));
+		count++;
+	}
+	pthread_mutex_unlock(&c->context.lock);
+
+	if (count == 0) {
+		pw_array_clear(&tmp);
+		res = NULL;
+	} else {
+		pw_array_add_ptr(&tmp, NULL);
+		res = tmp.data;
+	}
+	return res;
+}
+
+SPA_EXPORT
+int jack_port_tie (jack_port_t *src, jack_port_t *dst)
+{
+	pw_log_warn("not implemented %p %p", src, dst);
+	return -ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_port_untie (jack_port_t *port)
+{
+	pw_log_warn("not implemented %p", port);
+	return -ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_port_set_name (jack_port_t *port, const char *port_name)
+{
+	pw_log_warn("deprecated");
+	return 0;
+}
+
+SPA_EXPORT
+int jack_port_rename (jack_client_t* client, jack_port_t *port, const char *port_name)
+{
+	struct client *c = (struct client *) client;
+	struct object *o = (struct object *) port;
+	struct port *p;
+	int res = 0;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+	spa_return_val_if_fail(port_name != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	pw_log_info("%p: port rename %p %s -> %s:%s",
+			client, port, o->port.name, c->name, port_name);
+
+	p = o->port.port;
+	if (p == NULL || !p->valid) {
+		res = -EINVAL;
+		goto done;
+	}
+
+	pw_properties_set(p->props, PW_KEY_PORT_NAME, port_name);
+	snprintf(o->port.name, sizeof(o->port.name), "%s:%s", c->name, port_name);
+
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PROPS;
+	p->info.props = &p->props->dict;
+
+	pw_client_node_port_update(c->node,
+					 p->direction,
+					 p->port_id,
+					 PW_CLIENT_NODE_PORT_UPDATE_INFO,
+					 0, NULL,
+					 &p->info);
+	p->info.change_mask = 0;
+
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_port_set_alias (jack_port_t *port, const char *alias)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	struct port *p;
+	const char *key;
+	int res = 0;
+
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+	spa_return_val_if_fail(alias != NULL, -EINVAL);
+
+	c = o->client;
+	if (o->type != INTERFACE_Port || c == NULL)
+		return -EINVAL;
+
+	pw_thread_loop_lock(c->context.loop);
+
+	p = o->port.port;
+	if (p == NULL || !p->valid) {
+		res = -EINVAL;
+		goto done;
+	}
+
+	if (o->port.alias1[0] == '\0') {
+		key = PW_KEY_OBJECT_PATH;
+		snprintf(o->port.alias1, sizeof(o->port.alias1), "%s", alias);
+	}
+	else if (o->port.alias2[0] == '\0') {
+		key = PW_KEY_PORT_ALIAS;
+		snprintf(o->port.alias2, sizeof(o->port.alias2), "%s", alias);
+	}
+	else {
+		res = -1;
+		goto done;
+	}
+
+	pw_properties_set(p->props, key, alias);
+
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PROPS;
+	p->info.props = &p->props->dict;
+
+	pw_client_node_port_update(c->node,
+					 p->direction,
+					 p->port_id,
+					 PW_CLIENT_NODE_PORT_UPDATE_INFO,
+					 0, NULL,
+					 &p->info);
+	p->info.change_mask = 0;
+
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_port_unset_alias (jack_port_t *port, const char *alias)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	struct port *p;
+	const char *key;
+	int res = 0;
+
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+	spa_return_val_if_fail(alias != NULL, -EINVAL);
+
+	c = o->client;
+	if (o->type != INTERFACE_Port || c == NULL)
+		return -EINVAL;
+
+	pw_thread_loop_lock(c->context.loop);
+	p = o->port.port;
+	if (p == NULL || !p->valid) {
+		res = -EINVAL;
+		goto done;
+	}
+
+	if (spa_streq(o->port.alias1, alias))
+		key = PW_KEY_OBJECT_PATH;
+	else if (spa_streq(o->port.alias2, alias))
+		key = PW_KEY_PORT_ALIAS;
+	else {
+		res = -1;
+		goto done;
+	}
+
+	pw_properties_set(p->props, key, NULL);
+
+	p->info.change_mask |= SPA_PORT_CHANGE_MASK_PROPS;
+	p->info.props = &p->props->dict;
+
+	pw_client_node_port_update(c->node,
+					 p->direction,
+					 p->port_id,
+					 PW_CLIENT_NODE_PORT_UPDATE_INFO,
+					 0, NULL,
+					 &p->info);
+	p->info.change_mask = 0;
+
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_port_get_aliases (const jack_port_t *port, char* const aliases[2])
+{
+	struct object *o = (struct object *) port;
+	int res = 0;
+
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+	spa_return_val_if_fail(aliases != NULL, -EINVAL);
+	spa_return_val_if_fail(aliases[0] != NULL, -EINVAL);
+	spa_return_val_if_fail(aliases[1] != NULL, -EINVAL);
+
+	if (o->port.alias1[0] != '\0') {
+		snprintf(aliases[0], REAL_JACK_PORT_NAME_SIZE+1, "%s", o->port.alias1);
+		res++;
+	}
+	if (o->port.alias2[0] != '\0') {
+		snprintf(aliases[1], REAL_JACK_PORT_NAME_SIZE+1, "%s", o->port.alias2);
+		res++;
+	}
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_port_request_monitor (jack_port_t *port, int onoff)
+{
+	struct object *o = (struct object *) port;
+
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+
+	if (onoff)
+		o->port.monitor_requests++;
+	else if (o->port.monitor_requests > 0)
+		o->port.monitor_requests--;
+	return 0;
+}
+
+SPA_EXPORT
+int jack_port_request_monitor_by_name (jack_client_t *client,
+                                       const char *port_name, int onoff)
+{
+	struct client *c = (struct client *) client;
+	struct object *p;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(port_name != NULL, -EINVAL);
+
+	pthread_mutex_lock(&c->context.lock);
+	p = find_port_by_name(c, port_name);
+	pthread_mutex_unlock(&c->context.lock);
+
+	if (p == NULL) {
+		pw_log_error("%p: jack_port_request_monitor_by_name called"
+				" with an incorrect port %s", client, port_name);
+		return -1;
+	}
+
+	return jack_port_request_monitor((jack_port_t*)p, onoff);
+}
+
+SPA_EXPORT
+int jack_port_ensure_monitor (jack_port_t *port, int onoff)
+{
+	struct object *o = (struct object *) port;
+
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+
+	if (onoff) {
+		if (o->port.monitor_requests == 0)
+			o->port.monitor_requests++;
+	} else {
+		if (o->port.monitor_requests > 0)
+			o->port.monitor_requests = 0;
+	}
+	return 0;
+}
+
+SPA_EXPORT
+int jack_port_monitoring_input (jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+	return o->port.monitor_requests > 0;
+}
+
+static void link_proxy_error(void *data, int seq, int res, const char *message)
+{
+	int *link_res = data;
+	*link_res = res;
+}
+
+static const struct pw_proxy_events link_proxy_events = {
+	PW_VERSION_PROXY_EVENTS,
+	.error = link_proxy_error,
+};
+
+static int check_connect(struct client *c, struct object *src, struct object *dst)
+{
+	int src_self, dst_self, sum;
+
+	if (c->self_connect_mode == SELF_CONNECT_ALLOW)
+		return 1;
+
+	src_self = src->port.node_id == c->node_id ? 1 : 0;
+	dst_self = dst->port.node_id == c->node_id ? 1 : 0;
+	sum = src_self + dst_self;
+	/* check for no self connection first */
+	if (sum == 0)
+		return 1;
+
+	/* internal connection */
+	if (sum == 2 &&
+	    (c->self_connect_mode == SELF_CONNECT_FAIL_EXT ||
+	     c->self_connect_mode == SELF_CONNECT_IGNORE_EXT))
+		return 1;
+
+	/* failure -> -1 */
+	if (c->self_connect_mode < 0)
+		return -1;
+
+	/* ignore -> 0 */
+	return 0;
+}
+
+SPA_EXPORT
+int jack_connect (jack_client_t *client,
+                  const char *source_port,
+                  const char *destination_port)
+{
+	struct client *c = (struct client *) client;
+	struct object *src, *dst;
+	struct spa_dict props;
+	struct spa_dict_item items[6];
+	struct pw_proxy *proxy;
+	struct spa_hook listener;
+	char val[4][16];
+	const char *str;
+	int res, link_res = 0;
+
+	spa_return_val_if_fail(c != NULL, EINVAL);
+	spa_return_val_if_fail(source_port != NULL, EINVAL);
+	spa_return_val_if_fail(destination_port != NULL, EINVAL);
+
+	pw_log_info("%p: connect %s %s", client, source_port, destination_port);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	src = find_port_by_name(c, source_port);
+	dst = find_port_by_name(c, destination_port);
+
+	if (src == NULL || dst == NULL ||
+	    !(src->port.flags & JackPortIsOutput) ||
+	    !(dst->port.flags & JackPortIsInput) ||
+	    src->port.type_id != dst->port.type_id) {
+		res = -EINVAL;
+		goto exit;
+	}
+	if ((res = check_connect(c, src, dst)) != 1)
+		goto exit;
+
+	snprintf(val[0], sizeof(val[0]), "%d", src->port.node_id);
+	snprintf(val[1], sizeof(val[1]), "%d", src->id);
+	snprintf(val[2], sizeof(val[2]), "%d", dst->port.node_id);
+	snprintf(val[3], sizeof(val[3]), "%d", dst->id);
+
+	props = SPA_DICT_INIT(items, 0);
+	items[props.n_items++] = SPA_DICT_ITEM_INIT(PW_KEY_LINK_OUTPUT_NODE, val[0]);
+	items[props.n_items++] = SPA_DICT_ITEM_INIT(PW_KEY_LINK_OUTPUT_PORT, val[1]);
+	items[props.n_items++] = SPA_DICT_ITEM_INIT(PW_KEY_LINK_INPUT_NODE, val[2]);
+	items[props.n_items++] = SPA_DICT_ITEM_INIT(PW_KEY_LINK_INPUT_PORT, val[3]);
+	items[props.n_items++] = SPA_DICT_ITEM_INIT(PW_KEY_OBJECT_LINGER, "true");
+	if ((str = pw_properties_get(c->props, PW_KEY_NODE_PASSIVE)) != NULL &&
+	    pw_properties_parse_bool(str))
+		items[props.n_items++] = SPA_DICT_ITEM_INIT(PW_KEY_LINK_PASSIVE, "true");
+
+	proxy = pw_core_create_object(c->core,
+				    "link-factory",
+				    PW_TYPE_INTERFACE_Link,
+				    PW_VERSION_LINK,
+				    &props,
+				    0);
+	if (proxy == NULL) {
+		res = -errno;
+		goto exit;
+	}
+
+	spa_zero(listener);
+	pw_proxy_add_listener(proxy, &listener, &link_proxy_events, &link_res);
+
+	res = do_sync(c);
+
+	spa_hook_remove(&listener);
+
+	if (link_res < 0)
+		res = link_res;
+
+	pw_proxy_destroy(proxy);
+
+      exit:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return -res;
+}
+
+SPA_EXPORT
+int jack_disconnect (jack_client_t *client,
+                     const char *source_port,
+                     const char *destination_port)
+{
+	struct client *c = (struct client *) client;
+	struct object *src, *dst, *l;
+	int res;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(source_port != NULL, -EINVAL);
+	spa_return_val_if_fail(destination_port != NULL, -EINVAL);
+
+	pw_log_info("%p: disconnect %s %s", client, source_port, destination_port);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	src = find_port_by_name(c, source_port);
+	dst = find_port_by_name(c, destination_port);
+
+	pw_log_debug("%p: %d %d", client, src->id, dst->id);
+
+	if (src == NULL || dst == NULL ||
+	    !(src->port.flags & JackPortIsOutput) ||
+	    !(dst->port.flags & JackPortIsInput)) {
+		res = -EINVAL;
+		goto exit;
+	}
+
+	if ((res = check_connect(c, src, dst)) != 1)
+		goto exit;
+
+	if ((l = find_link(c, src->id, dst->id)) == NULL) {
+		res = -ENOENT;
+		goto exit;
+	}
+
+	pw_registry_destroy(c->registry, l->id);
+
+	res = do_sync(c);
+
+      exit:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return -res;
+}
+
+SPA_EXPORT
+int jack_port_disconnect (jack_client_t *client, jack_port_t *port)
+{
+	struct client *c = (struct client *) client;
+	struct object *o = (struct object *) port;
+	struct object *l;
+	int res;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(o != NULL, -EINVAL);
+
+	pw_log_debug("%p: disconnect %p", client, port);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	spa_list_for_each(l, &c->context.objects, link) {
+		if (l->type != INTERFACE_Link || l->removed)
+			continue;
+		if (l->port_link.src_serial == o->serial ||
+		    l->port_link.dst_serial == o->serial) {
+			pw_registry_destroy(c->registry, l->id);
+		}
+	}
+	res = do_sync(c);
+
+	pw_thread_loop_unlock(c->context.loop);
+
+	return -res;
+}
+
+SPA_EXPORT
+int jack_port_name_size(void)
+{
+	return REAL_JACK_PORT_NAME_SIZE+1;
+}
+
+SPA_EXPORT
+int jack_port_type_size(void)
+{
+	return JACK_PORT_TYPE_SIZE+1;
+}
+
+SPA_EXPORT
+size_t jack_port_type_get_buffer_size (jack_client_t *client, const char *port_type)
+{
+	spa_return_val_if_fail(client != NULL, 0);
+	spa_return_val_if_fail(port_type != NULL, 0);
+
+	if (spa_streq(JACK_DEFAULT_AUDIO_TYPE, port_type))
+		return jack_get_buffer_size(client) * sizeof(float);
+	else if (spa_streq(JACK_DEFAULT_MIDI_TYPE, port_type))
+		return MAX_BUFFER_FRAMES * sizeof(float);
+	else if (spa_streq(JACK_DEFAULT_VIDEO_TYPE, port_type))
+		return 320 * 240 * 4 * sizeof(float);
+	else
+		return 0;
+}
+
+SPA_EXPORT
+void jack_port_set_latency (jack_port_t *port, jack_nframes_t frames)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	jack_latency_range_t range = { frames, frames };
+
+	spa_return_if_fail(o != NULL);
+	c = o->client;
+
+	pw_log_debug("%p: %s set latency %d", c, o->port.name, frames);
+
+	if (o->port.flags & JackPortIsOutput) {
+		jack_port_set_latency_range(port, JackCaptureLatency, &range);
+        }
+        if (o->port.flags & JackPortIsInput) {
+		jack_port_set_latency_range(port, JackPlaybackLatency, &range);
+        }
+}
+
+SPA_EXPORT
+void jack_port_get_latency_range (jack_port_t *port, jack_latency_callback_mode_t mode, jack_latency_range_t *range)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	jack_nframes_t nframes, rate;
+	int direction;
+	struct spa_latency_info *info;
+
+	spa_return_if_fail(o != NULL);
+	if (o->type != INTERFACE_Port || o->client == NULL)
+		return;
+	c = o->client;
+
+	if (mode == JackCaptureLatency)
+		direction = SPA_DIRECTION_OUTPUT;
+	else
+		direction = SPA_DIRECTION_INPUT;
+
+	nframes = jack_get_buffer_size((jack_client_t*)c);
+	rate = jack_get_sample_rate((jack_client_t*)c);
+	info = &o->port.latency[direction];
+
+	range->min = (info->min_quantum * nframes) +
+		info->min_rate + (info->min_ns * rate) / SPA_NSEC_PER_SEC;
+	range->max = (info->max_quantum * nframes) +
+		info->max_rate + (info->max_ns * rate) / SPA_NSEC_PER_SEC;
+
+	pw_log_debug("%p: %s get %d latency range %d %d", c, o->port.name,
+			mode, range->min, range->max);
+}
+
+static int
+do_port_update_latency(struct spa_loop *loop,
+		bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct port *p = user_data;
+	port_update_latency(p);
+	return 0;
+}
+
+SPA_EXPORT
+void jack_port_set_latency_range (jack_port_t *port, jack_latency_callback_mode_t mode, jack_latency_range_t *range)
+{
+	struct object *o = (struct object *) port;
+	struct client *c;
+	enum spa_direction direction;
+	struct spa_latency_info *current, latency;
+	jack_nframes_t nframes;
+	struct port *p;
+
+	spa_return_if_fail(o != NULL);
+	if (o->type != INTERFACE_Port || o->client == NULL)
+		return;
+	c = o->client;
+
+	if (mode == JackCaptureLatency)
+		direction = SPA_DIRECTION_OUTPUT;
+	else
+		direction = SPA_DIRECTION_INPUT;
+
+	pw_log_info("%p: %s set %d latency range %d %d", c, o->port.name, mode, range->min, range->max);
+
+	latency = SPA_LATENCY_INFO(direction);
+
+	nframes = jack_get_buffer_size((jack_client_t*)c);
+
+	latency.min_rate = range->min;
+	if (latency.min_rate >= nframes) {
+		latency.min_quantum = latency.min_rate / nframes;
+		latency.min_rate %= nframes;
+	}
+
+	latency.max_rate = range->max;
+	if (latency.max_rate >= nframes) {
+		latency.max_quantum = latency.max_rate / nframes;
+		latency.max_rate %= nframes;
+	}
+
+	current = &o->port.latency[direction];
+
+	if ((p = o->port.port) == NULL)
+		return;
+	if (spa_latency_info_compare(current, &latency) == 0)
+		return;
+
+	pw_log_info("%p: %s update %s latency %f-%f %d-%d %"PRIu64"-%"PRIu64, c,
+			o->port.name,
+			latency.direction == SPA_DIRECTION_INPUT ? "playback" : "capture",
+			latency.min_quantum, latency.max_quantum,
+			latency.min_rate, latency.max_rate,
+			latency.min_ns, latency.max_ns);
+
+	*current = latency;
+
+	pw_loop_invoke(c->context.l, do_port_update_latency, 0,
+			NULL, 0, false, p);
+}
+
+static int
+do_recompute_latencies(struct spa_loop *loop,
+		bool async, uint32_t seq, const void *data, size_t size, void *user_data)
+{
+	struct client *c = user_data;
+	pw_log_debug("start");
+	recompute_latencies(c);
+	pw_log_debug("stop");
+	return 0;
+}
+
+SPA_EXPORT
+int jack_recompute_total_latencies (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	pw_loop_invoke(c->context.l, do_recompute_latencies, 0,
+			NULL, 0, false, c);
+	return 0;
+}
+
+static jack_nframes_t port_get_latency (jack_port_t *port)
+{
+	struct object *o = (struct object *) port;
+	jack_latency_range_t range = { 0, 0 };
+
+	spa_return_val_if_fail(o != NULL, 0);
+
+	if (o->port.flags & JackPortIsOutput) {
+		jack_port_get_latency_range(port, JackCaptureLatency, &range);
+        }
+        if (o->port.flags & JackPortIsInput) {
+		jack_port_get_latency_range(port, JackPlaybackLatency, &range);
+        }
+	return (range.min + range.max) / 2;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_port_get_latency (jack_port_t *port)
+{
+	return port_get_latency(port);
+}
+
+SPA_EXPORT
+jack_nframes_t jack_port_get_total_latency (jack_client_t *client,
+					    jack_port_t *port)
+{
+	return port_get_latency(port);
+}
+
+SPA_EXPORT
+int jack_recompute_total_latency (jack_client_t *client, jack_port_t* port)
+{
+	pw_log_warn("%p: not implemented %p", client, port);
+	return 0;
+}
+
+static int port_compare_func(const void *v1, const void *v2)
+{
+	const struct object *const*o1 = v1, *const*o2 = v2;
+	struct client *c = (*o1)->client;
+	int res;
+	bool is_cap1, is_cap2, is_def1 = false, is_def2 = false;
+
+	is_cap1 = ((*o1)->port.flags & JackPortIsOutput) == JackPortIsOutput &&
+		!(*o1)->port.is_monitor;
+	is_cap2 = ((*o2)->port.flags & JackPortIsOutput) == JackPortIsOutput &&
+		!(*o2)->port.is_monitor;
+
+	if (c->metadata) {
+		struct object *ot1, *ot2;
+
+		ot1 = (*o1)->port.node;
+
+		if (is_cap1)
+			is_def1 = ot1 != NULL && spa_streq(ot1->node.node_name,
+					c->metadata->default_audio_source);
+		else if (!is_cap1)
+			is_def1 = ot1 != NULL && spa_streq(ot1->node.node_name,
+					c->metadata->default_audio_sink);
+		ot2 = (*o2)->port.node;
+
+		if (is_cap2)
+			is_def2 = ot2 != NULL && spa_streq(ot2->node.node_name,
+					c->metadata->default_audio_source);
+		else if (!is_cap2)
+			is_def2 = ot2 != NULL && spa_streq(ot2->node.node_name,
+					c->metadata->default_audio_sink);
+	}
+	if ((*o1)->port.type_id != (*o2)->port.type_id)
+		res = (*o1)->port.type_id - (*o2)->port.type_id;
+	else if ((is_cap1 || is_cap2) && is_cap1 != is_cap2)
+		res = is_cap2 - is_cap1;
+	else if ((is_def1 || is_def2) && is_def1 != is_def2)
+		res = is_def2 - is_def1;
+	else if ((*o1)->port.priority != (*o2)->port.priority)
+		res = (*o2)->port.priority - (*o1)->port.priority;
+	else if ((res = (*o1)->port.node_id - (*o2)->port.node_id) == 0) {
+		if ((*o1)->port.is_monitor != (*o2)->port.is_monitor)
+			res = (*o1)->port.is_monitor - (*o2)->port.is_monitor;
+		if (res == 0)
+			res = (*o1)->port.system_id - (*o2)->port.system_id;
+		if (res == 0)
+			res = (*o1)->serial - (*o2)->serial;
+	}
+	pw_log_debug("port %s<->%s type:%d<->%d def:%d<->%d prio:%d<->%d id:%d<->%d res:%d",
+			(*o1)->port.name, (*o2)->port.name,
+			(*o1)->port.type_id, (*o2)->port.type_id,
+			is_def1, is_def2,
+			(*o1)->port.priority, (*o2)->port.priority,
+			(*o1)->serial, (*o2)->serial, res);
+	return res;
+}
+
+SPA_EXPORT
+const char ** jack_get_ports (jack_client_t *client,
+                              const char *port_name_pattern,
+                              const char *type_name_pattern,
+                              unsigned long flags)
+{
+	struct client *c = (struct client *) client;
+	const char **res;
+	struct object *o;
+	struct pw_array tmp;
+	const char *str;
+	uint32_t i, count;
+	int r;
+	regex_t port_regex, type_regex;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+
+	str = getenv("PIPEWIRE_NODE");
+
+	if (port_name_pattern && port_name_pattern[0]) {
+		if ((r = regcomp(&port_regex, port_name_pattern, REG_EXTENDED | REG_NOSUB)) != 0) {
+			pw_log_error("cant compile regex %s: %d", port_name_pattern, r);
+			return NULL;
+		}
+	}
+	if (type_name_pattern && type_name_pattern[0]) {
+		if ((r = regcomp(&type_regex, type_name_pattern, REG_EXTENDED | REG_NOSUB)) != 0) {
+			pw_log_error("cant compile regex %s: %d", type_name_pattern, r);
+			return NULL;
+		}
+	}
+
+	pw_log_debug("%p: ports target:%s name:\"%s\" type:\"%s\" flags:%08lx", c, str,
+			port_name_pattern, type_name_pattern, flags);
+
+	pthread_mutex_lock(&c->context.lock);
+	pw_array_init(&tmp, sizeof(void*) * 32);
+	count = 0;
+
+	spa_list_for_each(o, &c->context.objects, link) {
+		if (o->type != INTERFACE_Port || o->removed)
+			continue;
+		pw_log_debug("%p: check port type:%d flags:%08lx name:\"%s\"", c,
+				o->port.type_id, o->port.flags, o->port.name);
+		if (o->port.type_id > TYPE_ID_VIDEO)
+			continue;
+		if (!SPA_FLAG_IS_SET(o->port.flags, flags))
+			continue;
+		if (str != NULL && o->port.node != NULL) {
+			if (!spa_strstartswith(o->port.name, str) &&
+			    o->port.node->serial != atoll(str))
+				continue;
+		}
+
+		if (port_name_pattern && port_name_pattern[0]) {
+			bool match;
+			match = regexec(&port_regex, o->port.name, 0, NULL, 0) == 0;
+			if (!match && is_port_default(c, o))
+				match = regexec(&port_regex, o->port.system, 0, NULL, 0) == 0;
+			if (!match)
+				continue;
+		}
+		if (type_name_pattern && type_name_pattern[0]) {
+			if (regexec(&type_regex, type_to_string(o->port.type_id),
+						0, NULL, 0) == REG_NOMATCH)
+				continue;
+		}
+		pw_log_debug("%p: port \"%s\" prio:%d matches (%d)",
+				c, o->port.name, o->port.priority, count);
+
+		pw_array_add_ptr(&tmp, o);
+		count++;
+	}
+	pthread_mutex_unlock(&c->context.lock);
+
+	if (count > 0) {
+		qsort(tmp.data, count, sizeof(struct object *), port_compare_func);
+		pw_array_add_ptr(&tmp, NULL);
+		res = tmp.data;
+		for (i = 0; i < count; i++)
+			res[i] = port_name((struct object*)res[i]);
+	} else {
+		pw_array_clear(&tmp);
+		res = NULL;
+	}
+
+	if (port_name_pattern && port_name_pattern[0])
+		regfree(&port_regex);
+	if (type_name_pattern && type_name_pattern[0])
+		regfree(&type_regex);
+
+	return res;
+}
+
+SPA_EXPORT
+jack_port_t * jack_port_by_name (jack_client_t *client, const char *port_name)
+{
+	struct client *c = (struct client *) client;
+	struct object *res;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+
+	pthread_mutex_lock(&c->context.lock);
+	res = find_port_by_name(c, port_name);
+	pthread_mutex_unlock(&c->context.lock);
+
+	if (res == NULL)
+		pw_log_info("%p: port \"%s\" not found", c, port_name);
+
+	return (jack_port_t *)res;
+}
+
+SPA_EXPORT
+jack_port_t * jack_port_by_id (jack_client_t *client,
+                               jack_port_id_t port_id)
+{
+	struct client *c = (struct client *) client;
+	struct object *res = NULL;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+
+	pthread_mutex_lock(&c->context.lock);
+	res = find_by_serial(c, port_id);
+	if (res && res->type != INTERFACE_Port)
+		res = NULL;
+	pw_log_debug("%p: port %d -> %p", c, port_id, res);
+	pthread_mutex_unlock(&c->context.lock);
+
+	if (res == NULL)
+		pw_log_info("%p: port %d not found", c, port_id);
+
+	return (jack_port_t *)res;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_frames_since_cycle_start (const jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	struct spa_io_position *pos;
+	struct timespec ts;
+	uint64_t diff;
+
+	spa_return_val_if_fail(c != NULL, 0);
+
+	if (SPA_UNLIKELY((pos = c->rt.position) == NULL))
+		return 0;
+
+	clock_gettime(CLOCK_MONOTONIC, &ts);
+	diff = SPA_TIMESPEC_TO_NSEC(&ts) - pos->clock.nsec;
+	return (jack_nframes_t) floor(((double)c->sample_rate * diff) / SPA_NSEC_PER_SEC);
+}
+
+SPA_EXPORT
+jack_nframes_t jack_frame_time (const jack_client_t *client)
+{
+	struct timespec ts;
+	clock_gettime(CLOCK_MONOTONIC, &ts);
+	return jack_time_to_frames(client, SPA_TIMESPEC_TO_USEC(&ts));
+}
+
+SPA_EXPORT
+jack_nframes_t jack_last_frame_time (const jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	struct spa_io_position *pos;
+
+	spa_return_val_if_fail(c != NULL, 0);
+
+	if (SPA_UNLIKELY((pos = c->rt.position) == NULL))
+		return 0;
+
+	return pos->clock.position;
+}
+
+SPA_EXPORT
+int jack_get_cycle_times(const jack_client_t *client,
+                        jack_nframes_t *current_frames,
+                        jack_time_t    *current_usecs,
+                        jack_time_t    *next_usecs,
+                        float          *period_usecs)
+{
+	struct client *c = (struct client *) client;
+	struct spa_io_position *pos;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (SPA_UNLIKELY((pos = c->rt.position) == NULL))
+		return -EIO;
+
+	*current_frames = pos->clock.position;
+	*current_usecs = pos->clock.nsec / SPA_NSEC_PER_USEC;
+	*period_usecs = pos->clock.duration * (float)SPA_USEC_PER_SEC / (c->sample_rate * pos->clock.rate_diff);
+	*next_usecs = pos->clock.next_nsec / SPA_NSEC_PER_USEC;
+
+	pw_log_trace("%p: %d %"PRIu64" %"PRIu64" %f", c, *current_frames,
+			*current_usecs, *next_usecs, *period_usecs);
+	return 0;
+}
+
+SPA_EXPORT
+jack_time_t jack_frames_to_time(const jack_client_t *client, jack_nframes_t frames)
+{
+	struct client *c = (struct client *) client;
+	struct spa_io_position *pos;
+	double df;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (SPA_UNLIKELY((pos = c->rt.position) == NULL))
+		return 0;
+
+	df = (frames - pos->clock.position) * (double)SPA_NSEC_PER_SEC / c->sample_rate;
+	return (pos->clock.nsec + (int64_t)rint(df)) / SPA_NSEC_PER_USEC;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_time_to_frames(const jack_client_t *client, jack_time_t usecs)
+{
+	struct client *c = (struct client *) client;
+	struct spa_io_position *pos;
+	double du;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (SPA_UNLIKELY((pos = c->rt.position) == NULL))
+		return 0;
+
+	du = (usecs - pos->clock.nsec/SPA_NSEC_PER_USEC) * (double)c->sample_rate / SPA_USEC_PER_SEC;
+	return pos->clock.position + (int32_t)rint(du);
+}
+
+SPA_EXPORT
+jack_time_t jack_get_time(void)
+{
+	struct timespec ts;
+	clock_gettime(CLOCK_MONOTONIC, &ts);
+	return SPA_TIMESPEC_TO_USEC(&ts);
+}
+
+SPA_EXPORT
+void default_jack_error_callback(const char *desc)
+{
+	pw_log_error("pw jack error: %s",desc);
+}
+
+SPA_EXPORT
+void silent_jack_error_callback(const char *desc)
+{
+}
+
+SPA_EXPORT
+void (*jack_error_callback)(const char *msg);
+
+SPA_EXPORT
+void jack_set_error_function (void (*func)(const char *))
+{
+	jack_error_callback = (func == NULL) ? &default_jack_error_callback : func;
+}
+
+SPA_EXPORT
+void default_jack_info_callback(const char *desc)
+{
+	pw_log_info("pw jack info: %s", desc);
+}
+
+SPA_EXPORT
+void silent_jack_info_callback(const char *desc)
+{
+}
+
+SPA_EXPORT
+void (*jack_info_callback)(const char *msg);
+
+
+SPA_EXPORT
+void jack_set_info_function (void (*func)(const char *))
+{
+	jack_info_callback = (func == NULL) ? &default_jack_info_callback : func;
+}
+
+SPA_EXPORT
+void jack_free(void* ptr)
+{
+	free(ptr);
+}
+
+SPA_EXPORT
+int jack_release_timebase (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	struct pw_node_activation *a;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if ((a = c->driver_activation) == NULL)
+		return -EIO;
+
+	if (!ATOMIC_CAS(a->segment_owner[0], c->node_id, 0))
+		return -EINVAL;
+
+	c->timebase_callback = NULL;
+	c->timebase_arg = NULL;
+	c->activation->pending_new_pos = false;
+
+	return 0;
+}
+
+SPA_EXPORT
+int jack_set_sync_callback (jack_client_t *client,
+			    JackSyncCallback sync_callback,
+			    void *arg)
+{
+	int res = 0;
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	c->sync_callback = sync_callback;
+	c->sync_arg = arg;
+
+	if ((res = do_activate(c)) < 0)
+		goto done;
+
+	c->activation->pending_sync = true;
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int jack_set_sync_timeout (jack_client_t *client,
+			   jack_time_t timeout)
+{
+	int res = 0;
+	struct client *c = (struct client *) client;
+	struct pw_node_activation *a;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	if ((a = c->activation) == NULL)
+		res = -EIO;
+	else
+		a->sync_timeout = timeout;
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int  jack_set_timebase_callback (jack_client_t *client,
+				 int conditional,
+				 JackTimebaseCallback timebase_callback,
+				 void *arg)
+{
+	int res = 0;
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+	spa_return_val_if_fail(timebase_callback != NULL, -EINVAL);
+
+	pw_thread_loop_lock(c->context.loop);
+
+	c->timebase_callback = timebase_callback;
+	c->timebase_arg = arg;
+	c->timeowner_conditional = conditional;
+	install_timeowner(c);
+
+	pw_log_debug("%p: timebase set id:%u", c, c->node_id);
+
+	if ((res = do_activate(c)) < 0)
+		goto done;
+
+	c->activation->pending_new_pos = true;
+done:
+	pw_thread_loop_unlock(c->context.loop);
+
+	return res;
+}
+
+SPA_EXPORT
+int  jack_transport_locate (jack_client_t *client,
+			    jack_nframes_t frame)
+{
+	jack_position_t pos;
+	pos.frame = frame;
+	pos.valid = (jack_position_bits_t)0;
+	return jack_transport_reposition(client, &pos);
+}
+
+SPA_EXPORT
+jack_transport_state_t jack_transport_query (const jack_client_t *client,
+					     jack_position_t *pos)
+{
+	struct client *c = (struct client *) client;
+	struct pw_node_activation *a;
+	jack_transport_state_t jack_state = JackTransportStopped;
+
+	spa_return_val_if_fail(c != NULL, JackTransportStopped);
+
+	if (SPA_LIKELY((a = c->rt.driver_activation) != NULL)) {
+		jack_state = position_to_jack(a, pos);
+	} else if ((a = c->driver_activation) != NULL) {
+		jack_state = position_to_jack(a, pos);
+	} else if (pos != NULL) {
+		memset(pos, 0, sizeof(jack_position_t));
+		pos->frame_rate = jack_get_sample_rate((jack_client_t*)client);
+	}
+	return jack_state;
+}
+
+SPA_EXPORT
+jack_nframes_t jack_get_current_transport_frame (const jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	struct pw_node_activation *a;
+	struct spa_io_position *pos;
+	struct spa_io_segment *seg;
+	uint64_t running;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (SPA_UNLIKELY((a = c->rt.driver_activation) == NULL))
+		return -EIO;
+
+	pos = &a->position;
+	running = pos->clock.position - pos->offset;
+
+	if (pos->state == SPA_IO_POSITION_STATE_RUNNING) {
+		struct timespec ts;
+		clock_gettime(CLOCK_MONOTONIC, &ts);
+		uint64_t nsecs = SPA_TIMESPEC_TO_NSEC(&ts) - pos->clock.nsec;
+		running += (uint64_t)floor((((double) c->sample_rate) / SPA_NSEC_PER_SEC) * nsecs);
+	}
+	seg = &pos->segments[0];
+
+	return (running - seg->start) * seg->rate + seg->position;
+}
+
+SPA_EXPORT
+int  jack_transport_reposition (jack_client_t *client,
+				const jack_position_t *pos)
+{
+	struct client *c = (struct client *) client;
+	struct pw_node_activation *a, *na;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	a = c->rt.driver_activation;
+	na = c->activation;
+	if (!a || !na)
+		return -EIO;
+
+	if (pos->valid & ~(JackPositionBBT|JackPositionTimecode))
+		return -EINVAL;
+
+	pw_log_debug("frame:%u", pos->frame);
+	spa_zero(na->reposition);
+	na->reposition.flags = 0;
+	na->reposition.start = 0;
+	na->reposition.duration = 0;
+	na->reposition.position = pos->frame;
+	na->reposition.rate = 1.0;
+	ATOMIC_STORE(a->reposition_owner, c->node_id);
+
+	return 0;
+}
+
+static void update_command(struct client *c, uint32_t command)
+{
+	struct pw_node_activation *a = c->rt.driver_activation;
+	if (!a)
+		return;
+	ATOMIC_STORE(a->command, command);
+}
+
+SPA_EXPORT
+void jack_transport_start (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	spa_return_if_fail(c != NULL);
+	update_command(c, PW_NODE_ACTIVATION_COMMAND_START);
+}
+
+SPA_EXPORT
+void jack_transport_stop (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	spa_return_if_fail(c != NULL);
+	update_command(c, PW_NODE_ACTIVATION_COMMAND_STOP);
+}
+
+SPA_EXPORT
+void jack_get_transport_info (jack_client_t *client,
+			      jack_transport_info_t *tinfo)
+{
+	pw_log_error("%p: deprecated", client);
+	if (tinfo)
+		memset(tinfo, 0, sizeof(jack_transport_info_t));
+}
+
+SPA_EXPORT
+void jack_set_transport_info (jack_client_t *client,
+			      jack_transport_info_t *tinfo)
+{
+	pw_log_error("%p: deprecated", client);
+	if (tinfo)
+		memset(tinfo, 0, sizeof(jack_transport_info_t));
+}
+
+SPA_EXPORT
+int jack_set_session_callback (jack_client_t       *client,
+                               JackSessionCallback  session_callback,
+                               void                *arg)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, -EINVAL);
+
+	if (c->active) {
+		pw_log_error("%p: can't set callback on active client", c);
+		return -EIO;
+	}
+	pw_log_warn("%p: not implemented", client);
+	return -ENOTSUP;
+}
+
+SPA_EXPORT
+int jack_session_reply (jack_client_t        *client,
+                        jack_session_event_t *event)
+{
+	pw_log_warn("%p: not implemented", client);
+	return -ENOTSUP;
+}
+
+
+SPA_EXPORT
+void jack_session_event_free (jack_session_event_t *event)
+{
+	if (event) {
+		free((void *)event->session_dir);
+		free((void *)event->client_uuid);
+		free(event->command_line);
+		free(event);
+	}
+}
+
+SPA_EXPORT
+char *jack_client_get_uuid (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_val_if_fail(c != NULL, NULL);
+
+	return spa_aprintf("%"PRIu64, client_make_uuid(c->serial, false));
+}
+
+SPA_EXPORT
+jack_session_command_t *jack_session_notify (
+        jack_client_t*             client,
+        const char                *target,
+        jack_session_event_type_t  type,
+        const char                *path)
+{
+	struct client *c = (struct client *) client;
+	jack_session_command_t *cmds;
+	spa_return_val_if_fail(c != NULL, NULL);
+	pw_log_warn("not implemented");
+	cmds = calloc(1, sizeof(jack_session_command_t));
+	return cmds;
+}
+
+SPA_EXPORT
+void jack_session_commands_free (jack_session_command_t *cmds)
+{
+	int i;
+	if (cmds == NULL)
+		return;
+
+	for (i = 0; cmds[i].uuid != NULL; i++) {
+		free((char*)cmds[i].client_name);
+		free((char*)cmds[i].command);
+		free((char*)cmds[i].uuid);
+	}
+	free(cmds);
+}
+
+SPA_EXPORT
+int jack_reserve_client_name (jack_client_t *client,
+                          const char    *name,
+                          const char    *uuid)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, -1);
+	pw_log_warn("not implemented");
+	return 0;
+}
+
+SPA_EXPORT
+int jack_client_has_session_callback (jack_client_t *client, const char *client_name)
+{
+	struct client *c = (struct client *) client;
+	spa_return_val_if_fail(c != NULL, -1);
+	return 0;
+}
+
+
+SPA_EXPORT
+int jack_client_real_time_priority (jack_client_t * client)
+{
+	return jack_client_max_real_time_priority(client) - 5;
+}
+
+SPA_EXPORT
+int jack_client_max_real_time_priority (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	int min, max;
+
+	spa_return_val_if_fail(c != NULL, -1);
+
+	spa_thread_utils_get_rt_range(&c->context.thread_utils, NULL, &min, &max);
+	return SPA_MIN(max, c->rt_max) - 1;
+}
+
+SPA_EXPORT
+int jack_acquire_real_time_scheduling (jack_native_thread_t thread, int priority)
+{
+	struct spa_thread *t = (struct spa_thread*)thread;
+	pw_log_info("acquire %p", t);
+	spa_return_val_if_fail(globals.thread_utils != NULL, -1);
+	spa_return_val_if_fail(t != NULL, -1);
+	return spa_thread_utils_acquire_rt(globals.thread_utils, t, priority);
+}
+
+SPA_EXPORT
+int jack_drop_real_time_scheduling (jack_native_thread_t thread)
+{
+	struct spa_thread *t = (struct spa_thread*)thread;
+	pw_log_info("drop %p", t);
+	spa_return_val_if_fail(globals.thread_utils != NULL, -1);
+	spa_return_val_if_fail(t != NULL, -1);
+	return spa_thread_utils_drop_rt(globals.thread_utils, t);
+}
+
+/**
+ * Create a thread for JACK or one of its clients.  The thread is
+ * created executing @a start_routine with @a arg as its sole
+ * argument.
+ *
+ * @param client the JACK client for whom the thread is being created. May be
+ * NULL if the client is being created within the JACK server.
+ * @param thread place to return POSIX thread ID.
+ * @param priority thread priority, if realtime.
+ * @param realtime true for the thread to use realtime scheduling.  On
+ * some systems that may require special privileges.
+ * @param start_routine function the thread calls when it starts.
+ * @param arg parameter passed to the @a start_routine.
+ *
+ * @returns 0, if successful; otherwise some error number.
+ */
+SPA_EXPORT
+int jack_client_create_thread (jack_client_t* client,
+                               jack_native_thread_t *thread,
+                               int priority,
+                               int realtime,	/* boolean */
+                               void *(*start_routine)(void*),
+                               void *arg)
+{
+	struct client *c = (struct client *) client;
+	int res = 0;
+	struct spa_thread *thr;
+
+	spa_return_val_if_fail(client != NULL, -EINVAL);
+	spa_return_val_if_fail(thread != NULL, -EINVAL);
+	spa_return_val_if_fail(start_routine != NULL, -EINVAL);
+
+	pw_log_info("client %p: create thread rt:%d prio:%d", client, realtime, priority);
+
+	thr = spa_thread_utils_create(&c->context.thread_utils, NULL, start_routine, arg);
+	if (thr == NULL)
+		res = -errno;
+	*thread = (pthread_t)thr;
+
+	if (res != 0) {
+		pw_log_warn("client %p: create RT thread failed: %s",
+				client, strerror(res));
+	} else if (realtime) {
+		/* Try to acquire RT scheduling, we don't fail here but the
+		 * function will emit a warning. Real JACK fails here. */
+		jack_acquire_real_time_scheduling(*thread, priority);
+	}
+	return res;
+}
+
+SPA_EXPORT
+int jack_client_stop_thread(jack_client_t* client, jack_native_thread_t thread)
+{
+	struct client *c = (struct client *) client;
+	void* status;
+
+	if (thread == (jack_native_thread_t)NULL)
+		return -EINVAL;
+
+	spa_return_val_if_fail(client != NULL, -EINVAL);
+
+	pw_log_debug("join thread %lu", thread);
+	spa_thread_utils_join(&c->context.thread_utils, (struct spa_thread*)thread, &status);
+	pw_log_debug("stopped thread %lu", thread);
+	return 0;
+}
+
+SPA_EXPORT
+int jack_client_kill_thread(jack_client_t* client, jack_native_thread_t thread)
+{
+	struct client *c = (struct client *) client;
+	void* status;
+
+	if (thread == (jack_native_thread_t)NULL)
+		return -EINVAL;
+
+	spa_return_val_if_fail(client != NULL, -EINVAL);
+
+	pw_log_debug("cancel thread %lu", thread);
+	pthread_cancel(thread);
+	pw_log_debug("join thread %lu", thread);
+	spa_thread_utils_join(&c->context.thread_utils, (struct spa_thread*)thread, &status);
+	pw_log_debug("stopped thread %lu", thread);
+	return 0;
+}
+
+SPA_EXPORT
+void jack_set_thread_creator (jack_thread_creator_t creator)
+{
+	globals.creator = creator;
+}
+
+static inline uint8_t * midi_event_data (void* port_buffer,
+                      const struct midi_event* event)
+{
+        if (SPA_LIKELY(event->size <= MIDI_INLINE_MAX))
+                return (uint8_t *)event->inline_data;
+        else
+                return SPA_PTROFF(port_buffer, event->byte_offset, uint8_t);
+}
+
+SPA_EXPORT
+uint32_t jack_midi_get_event_count(void* port_buffer)
+{
+	struct midi_buffer *mb = port_buffer;
+	if (mb == NULL || mb->magic != MIDI_BUFFER_MAGIC)
+		return 0;
+	return mb->event_count;
+}
+
+SPA_EXPORT
+int jack_midi_event_get(jack_midi_event_t *event,
+			void        *port_buffer,
+			uint32_t    event_index)
+{
+	struct midi_buffer *mb = port_buffer;
+	struct midi_event *ev = SPA_PTROFF(mb, sizeof(*mb), struct midi_event);
+	spa_return_val_if_fail(mb != NULL, -EINVAL);
+	spa_return_val_if_fail(ev != NULL, -EINVAL);
+	if (event_index >= mb->event_count)
+		return -ENOBUFS;
+	ev += event_index;
+	event->time = ev->time;
+	event->size = ev->size;
+	event->buffer = midi_event_data (port_buffer, ev);
+	return 0;
+}
+
+SPA_EXPORT
+void jack_midi_clear_buffer(void *port_buffer)
+{
+	struct midi_buffer *mb = port_buffer;
+	spa_return_if_fail(mb != NULL);
+	mb->event_count = 0;
+	mb->write_pos = 0;
+	mb->lost_events = 0;
+}
+
+SPA_EXPORT
+void jack_midi_reset_buffer(void *port_buffer)
+{
+	jack_midi_clear_buffer(port_buffer);
+}
+
+SPA_EXPORT
+size_t jack_midi_max_event_size(void* port_buffer)
+{
+	struct midi_buffer *mb = port_buffer;
+	size_t buffer_size;
+
+	spa_return_val_if_fail(mb != NULL, 0);
+
+	buffer_size = mb->buffer_size;
+
+        /* (event_count + 1) below accounts for jack_midi_port_internal_event_t
+         * which would be needed to store the next event */
+        size_t used_size = sizeof(struct midi_buffer)
+                           + mb->write_pos
+                           + ((mb->event_count + 1)
+                              * sizeof(struct midi_event));
+
+        if (SPA_UNLIKELY(used_size > buffer_size)) {
+                return 0;
+        } else if (SPA_LIKELY((buffer_size - used_size) < MIDI_INLINE_MAX)) {
+                return MIDI_INLINE_MAX;
+        } else {
+                return buffer_size - used_size;
+        }
+}
+
+SPA_EXPORT
+jack_midi_data_t* jack_midi_event_reserve(void *port_buffer,
+                        jack_nframes_t  time,
+                        size_t data_size)
+{
+	struct midi_buffer *mb = port_buffer;
+	struct midi_event *events = SPA_PTROFF(mb, sizeof(*mb), struct midi_event);
+	size_t buffer_size;
+
+	spa_return_val_if_fail(mb != NULL, NULL);
+
+	buffer_size = mb->buffer_size;
+
+	if (SPA_UNLIKELY(time >= mb->nframes)) {
+		pw_log_warn("midi %p: time:%d frames:%d", port_buffer, time, mb->nframes);
+		goto failed;
+	}
+
+	if (SPA_UNLIKELY(mb->event_count > 0 && time < events[mb->event_count - 1].time)) {
+		pw_log_warn("midi %p: time:%d ev:%d", port_buffer, time, mb->event_count);
+		goto failed;
+	}
+
+	/* Check if data_size is >0 and there is enough space in the buffer for the event. */
+	if (SPA_UNLIKELY(data_size <= 0)) {
+		pw_log_warn("midi %p: data_size:%zd", port_buffer, data_size);
+		goto failed; // return NULL?
+	} else if (SPA_UNLIKELY(jack_midi_max_event_size (port_buffer) < data_size)) {
+		pw_log_warn("midi %p: event too large: data_size:%zd", port_buffer, data_size);
+		goto failed;
+	} else {
+		struct midi_event *ev = &events[mb->event_count];
+		uint8_t *res;
+
+		ev->time = time;
+		ev->size = data_size;
+		if (SPA_LIKELY(data_size <= MIDI_INLINE_MAX)) {
+			res = ev->inline_data;
+		} else {
+			mb->write_pos += data_size;
+			ev->byte_offset = buffer_size - 1 - mb->write_pos;
+			res = SPA_PTROFF(mb, ev->byte_offset, uint8_t);
+		}
+		mb->event_count += 1;
+		return res;
+	}
+failed:
+	mb->lost_events++;
+	return NULL;
+}
+
+SPA_EXPORT
+int jack_midi_event_write(void *port_buffer,
+                      jack_nframes_t time,
+                      const jack_midi_data_t *data,
+                      size_t data_size)
+{
+	jack_midi_data_t *retbuf = jack_midi_event_reserve (port_buffer, time, data_size);
+        if (SPA_UNLIKELY(retbuf == NULL))
+                return -ENOBUFS;
+	memcpy (retbuf, data, data_size);
+	return 0;
+}
+
+SPA_EXPORT
+uint32_t jack_midi_get_lost_event_count(void *port_buffer)
+{
+	struct midi_buffer *mb = port_buffer;
+	spa_return_val_if_fail(mb != NULL, 0);
+	return mb->lost_events;
+}
+
+/** extensions */
+
+SPA_EXPORT
+int jack_get_video_image_size(jack_client_t *client, jack_image_size_t *size)
+{
+	struct client *c = (struct client *) client;
+	struct pw_node_activation *a;
+
+	spa_return_val_if_fail(c != NULL, 0);
+
+	a = c->rt.driver_activation;
+	if (SPA_UNLIKELY(a == NULL))
+		a = c->activation;
+	if (SPA_UNLIKELY(a == NULL))
+		return -EIO;
+
+	if (SPA_UNLIKELY(!(a->position.video.flags & SPA_IO_VIDEO_SIZE_VALID)))
+		return -EIO;
+
+	size->width = a->position.video.size.width;
+	size->height = a->position.video.size.height;
+	size->stride = a->position.video.stride;
+	size->flags = 0;
+	return size->stride * size->height;
+}
+
+
+static void reg(void) __attribute__ ((constructor));
+static void reg(void)
+{
+	pw_init(NULL, NULL);
+	PW_LOG_TOPIC_INIT(jack_log_topic);
+	pthread_mutex_init(&globals.lock, NULL);
+	pw_array_init(&globals.descriptions, 16);
+	spa_list_init(&globals.free_objects);
+}
diff --git a/pipewire-jack/src/pw-jack.in b/pipewire-jack/src/pw-jack.in
new file mode 100755
index 0000000..f3dba1d
--- /dev/null
+++ b/pipewire-jack/src/pw-jack.in
@@ -0,0 +1,78 @@
+#!/bin/sh
+
+# This file is part of PipeWire.
+#
+# Copyright © 2020 Wim Taymans
+#
+# Permission is hereby granted, free of charge, to any person obtaining a
+# copy of this software and associated documentation files (the "Software"),
+# to deal in the Software without restriction, including without limitation
+# the rights to use, copy, modify, merge, publish, distribute, sublicense,
+# and/or sell copies of the Software, and to permit persons to whom the
+# Software is furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice (including the next
+# paragraph) shall be included in all copies or substantial portions of the
+# Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+# THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+# FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+# DEALINGS IN THE SOFTWARE.
+#
+
+DEFAULT_SAMPLERATE=48000
+
+while getopts 'hr:vs:p:' param ; do
+	case $param in
+		r)
+			PIPEWIRE_REMOTE="$OPTARG"
+			export PIPEWIRE_REMOTE
+			;;
+		v)
+			if [ -z "$PIPEWIRE_DEBUG" ]; then
+				PIPEWIRE_DEBUG=3
+			else
+				PIPEWIRE_DEBUG=$(( PIPEWIRE_DEBUG + 1 ))
+			fi
+			export PIPEWIRE_DEBUG
+			;;
+		s)
+			SAMPLERATE="$OPTARG"
+			;;
+		p)
+			PERIOD="$OPTARG"
+			;;
+		*)
+			echo "$0 - run JACK applications on PipeWire"
+			echo " "
+			echo "$0 [options] application [arguments]"
+			echo " "
+			echo "options:"
+			echo "	-h                  show brief help"
+			echo "	-r <remote>         remote daemon name"
+			echo "	-v                  verbose debug info"
+			echo "	-s                  samplerate (default \"$DEFAULT_SAMPLERATE\")"
+			echo "	-p                  period in samples"
+			exit 0
+			;;
+	esac
+done
+
+shift $(( OPTIND - 1 ))
+
+if [ -n "$PERIOD" ]; then
+	if [ -n "$SAMPLERATE" ]; then
+		PIPEWIRE_QUANTUM="$PERIOD/$SAMPLERATE"
+	else
+		PIPEWIRE_QUANTUM="$PERIOD/$DEFAULT_SAMPLERATE"
+	fi
+	export PIPEWIRE_QUANTUM
+fi
+LD_LIBRARY_PATH='@LIBJACK_PATH@'"${LD_LIBRARY_PATH+":$LD_LIBRARY_PATH"}"
+export LD_LIBRARY_PATH
+
+exec "$@"
diff --git a/pipewire-jack/src/ringbuffer.c b/pipewire-jack/src/ringbuffer.c
new file mode 100644
index 0000000..887c7dc
--- /dev/null
+++ b/pipewire-jack/src/ringbuffer.c
@@ -0,0 +1,302 @@
+/* PipeWire
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+
+#include <spa/utils/defs.h>
+
+#include <jack/ringbuffer.h>
+
+SPA_EXPORT
+jack_ringbuffer_t *jack_ringbuffer_create(size_t sz)
+{
+	size_t power_of_two;
+	jack_ringbuffer_t *rb;
+
+	rb = calloc(1, sizeof(jack_ringbuffer_t));
+	if (rb == NULL)
+		return NULL;
+
+	for (power_of_two = 1; 1u << power_of_two < sz; power_of_two++);
+
+	rb->size = 1 << power_of_two;
+	rb->size_mask = rb->size - 1;
+	if ((rb->buf = calloc(1, rb->size)) == NULL) {
+		free (rb);
+		return NULL;
+	}
+	rb->mlocked = 0;
+
+	return rb;
+}
+
+SPA_EXPORT
+void jack_ringbuffer_free(jack_ringbuffer_t *rb)
+{
+#ifdef USE_MLOCK
+	if (rb->mlocked)
+		munlock (rb->buf, rb->size);
+#endif /* USE_MLOCK */
+	free (rb->buf);
+	free (rb);
+}
+
+SPA_EXPORT
+void jack_ringbuffer_get_read_vector(const jack_ringbuffer_t *rb,
+                                     jack_ringbuffer_data_t *vec)
+{
+	size_t free_cnt;
+	size_t cnt2;
+	size_t w, r;
+
+	w = rb->write_ptr;
+	r = rb->read_ptr;
+
+	if (w > r)
+		free_cnt = w - r;
+	else
+		free_cnt = (w - r + rb->size) & rb->size_mask;
+
+	cnt2 = r + free_cnt;
+
+	if (cnt2 > rb->size) {
+		vec[0].buf = &(rb->buf[r]);
+		vec[0].len = rb->size - r;
+		vec[1].buf = rb->buf;
+		vec[1].len = cnt2 & rb->size_mask;
+	} else {
+		vec[0].buf = &(rb->buf[r]);
+		vec[0].len = free_cnt;
+		vec[1].len = 0;
+	}
+}
+
+SPA_EXPORT
+void jack_ringbuffer_get_write_vector(const jack_ringbuffer_t *rb,
+                                      jack_ringbuffer_data_t *vec)
+{
+	size_t free_cnt;
+	size_t cnt2;
+	size_t w, r;
+
+	w = rb->write_ptr;
+	r = rb->read_ptr;
+
+	if (w > r)
+		free_cnt = ((r - w + rb->size) & rb->size_mask) - 1;
+	else if (w < r)
+		free_cnt = (r - w) - 1;
+	else
+		free_cnt = rb->size - 1;
+
+	cnt2 = w + free_cnt;
+
+	if (cnt2 > rb->size) {
+		vec[0].buf = &(rb->buf[w]);
+		vec[0].len = rb->size - w;
+		vec[1].buf = rb->buf;
+		vec[1].len = cnt2 & rb->size_mask;
+	} else {
+		vec[0].buf = &(rb->buf[w]);
+		vec[0].len = free_cnt;
+		vec[1].len = 0;
+	}
+}
+
+SPA_EXPORT
+size_t jack_ringbuffer_read(jack_ringbuffer_t *rb, char *dest, size_t cnt)
+{
+	size_t free_cnt;
+	size_t cnt2;
+	size_t to_read;
+	size_t n1, n2;
+
+	if ((free_cnt = jack_ringbuffer_read_space (rb)) == 0)
+		return 0;
+
+	to_read = cnt > free_cnt ? free_cnt : cnt;
+
+	cnt2 = rb->read_ptr + to_read;
+
+	if (cnt2 > rb->size) {
+		n1 = rb->size - rb->read_ptr;
+		n2 = cnt2 & rb->size_mask;
+	} else {
+		n1 = to_read;
+		n2 = 0;
+	}
+
+	memcpy (dest, &(rb->buf[rb->read_ptr]), n1);
+	rb->read_ptr = (rb->read_ptr + n1) & rb->size_mask;
+	if (n2) {
+		memcpy (dest + n1, &(rb->buf[rb->read_ptr]), n2);
+		rb->read_ptr = (rb->read_ptr + n2) & rb->size_mask;
+	}
+	return to_read;
+}
+
+SPA_EXPORT
+size_t jack_ringbuffer_peek(jack_ringbuffer_t *rb, char *dest, size_t cnt)
+{
+	size_t free_cnt;
+	size_t cnt2;
+	size_t to_read;
+	size_t n1, n2;
+	size_t tmp_read_ptr;
+
+	tmp_read_ptr = rb->read_ptr;
+
+	if ((free_cnt = jack_ringbuffer_read_space (rb)) == 0)
+		return 0;
+
+	to_read = cnt > free_cnt ? free_cnt : cnt;
+
+	cnt2 = tmp_read_ptr + to_read;
+
+	if (cnt2 > rb->size) {
+		n1 = rb->size - tmp_read_ptr;
+		n2 = cnt2 & rb->size_mask;
+	} else {
+		n1 = to_read;
+		n2 = 0;
+	}
+
+	memcpy (dest, &(rb->buf[tmp_read_ptr]), n1);
+	tmp_read_ptr = (tmp_read_ptr + n1) & rb->size_mask;
+
+	if (n2)
+		memcpy (dest + n1, &(rb->buf[tmp_read_ptr]), n2);
+
+	return to_read;
+}
+
+SPA_EXPORT
+void jack_ringbuffer_read_advance(jack_ringbuffer_t *rb, size_t cnt)
+{
+	size_t tmp = (rb->read_ptr + cnt) & rb->size_mask;
+	rb->read_ptr = tmp;
+}
+
+SPA_EXPORT
+size_t jack_ringbuffer_read_space(const jack_ringbuffer_t *rb)
+{
+	size_t w, r;
+
+	w = rb->write_ptr;
+	r = rb->read_ptr;
+
+	if (w > r)
+		return w - r;
+	else
+		return (w - r + rb->size) & rb->size_mask;
+}
+
+SPA_EXPORT
+int jack_ringbuffer_mlock(jack_ringbuffer_t *rb)
+{
+#ifdef USE_MLOCK
+	if (mlock (rb->buf, rb->size))
+                return -1;
+#endif /* USE_MLOCK */
+	rb->mlocked = 1;
+	return 0;
+}
+
+SPA_EXPORT
+void jack_ringbuffer_reset(jack_ringbuffer_t *rb)
+{
+	rb->read_ptr = 0;
+	rb->write_ptr = 0;
+	memset(rb->buf, 0, rb->size);
+}
+
+SPA_EXPORT
+void jack_ringbuffer_reset_size (jack_ringbuffer_t * rb, size_t sz)
+{
+	rb->size = sz;
+	rb->size_mask = rb->size - 1;
+	rb->read_ptr = 0;
+	rb->write_ptr = 0;
+}
+
+SPA_EXPORT
+size_t jack_ringbuffer_write(jack_ringbuffer_t *rb, const char *src,
+                             size_t cnt)
+{
+	size_t free_cnt;
+	size_t cnt2;
+	size_t to_write;
+	size_t n1, n2;
+
+	if ((free_cnt = jack_ringbuffer_write_space (rb)) == 0)
+		return 0;
+
+	to_write = cnt > free_cnt ? free_cnt : cnt;
+
+	cnt2 = rb->write_ptr + to_write;
+
+	if (cnt2 > rb->size) {
+		n1 = rb->size - rb->write_ptr;
+		n2 = cnt2 & rb->size_mask;
+	} else {
+		n1 = to_write;
+		n2 = 0;
+	}
+
+	memcpy (&(rb->buf[rb->write_ptr]), src, n1);
+	rb->write_ptr = (rb->write_ptr + n1) & rb->size_mask;
+	if (n2) {
+		memcpy (&(rb->buf[rb->write_ptr]), src + n1, n2);
+		rb->write_ptr = (rb->write_ptr + n2) & rb->size_mask;
+	}
+	return to_write;
+}
+
+SPA_EXPORT
+void jack_ringbuffer_write_advance(jack_ringbuffer_t *rb, size_t cnt)
+{
+	size_t tmp = (rb->write_ptr + cnt) & rb->size_mask;
+	rb->write_ptr = tmp;
+}
+
+SPA_EXPORT
+size_t jack_ringbuffer_write_space(const jack_ringbuffer_t *rb)
+{
+	size_t w, r;
+
+	w = rb->write_ptr;
+	r = rb->read_ptr;
+
+	if (w > r)
+		return ((r - w + rb->size) & rb->size_mask) - 1;
+	else if (w < r)
+		return (r - w) - 1;
+	else
+		return rb->size - 1;
+}
diff --git a/pipewire-jack/src/statistics.c b/pipewire-jack/src/statistics.c
new file mode 100644
index 0000000..25ffb3e
--- /dev/null
+++ b/pipewire-jack/src/statistics.c
@@ -0,0 +1,66 @@
+/* PipeWire
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include <jack/statistics.h>
+
+SPA_EXPORT
+float jack_get_max_delayed_usecs (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	float res = 0.0f;
+
+	spa_return_val_if_fail(c != NULL, 0.0);
+
+	if (c->driver_activation)
+		res = (float)c->driver_activation->max_delay / SPA_USEC_PER_SEC;
+
+	pw_log_trace("%p: max delay %f", client, res);
+	return res;
+}
+
+SPA_EXPORT
+float jack_get_xrun_delayed_usecs (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+	float res = 0.0f;
+
+	spa_return_val_if_fail(c != NULL, 0.0);
+
+	if (c->driver_activation)
+		res = (float)c->driver_activation->xrun_delay / SPA_USEC_PER_SEC;
+
+	pw_log_trace("%p: xrun delay %f", client, res);
+	return res;
+}
+
+SPA_EXPORT
+void jack_reset_max_delayed_usecs (jack_client_t *client)
+{
+	struct client *c = (struct client *) client;
+
+	spa_return_if_fail(c != NULL);
+
+	if (c->driver_activation)
+		c->driver_activation->max_delay = 0;
+}
diff --git a/pipewire-jack/src/uuid.c b/pipewire-jack/src/uuid.c
new file mode 100644
index 0000000..8584e11
--- /dev/null
+++ b/pipewire-jack/src/uuid.c
@@ -0,0 +1,111 @@
+/* PipeWire
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include "config.h"
+
+#include <stdio.h>
+#include <unistd.h>
+#include <sys/mman.h>
+
+#include <jack/uuid.h>
+
+#include <pipewire/pipewire.h>
+
+SPA_EXPORT
+jack_uuid_t jack_client_uuid_generate (void)
+{
+	static uint32_t uuid_cnt = 0;
+	jack_uuid_t uuid = 0x2; /* JackUUIDClient */;
+	uuid = (uuid << 32) | ++uuid_cnt;
+	pw_log_debug("uuid %"PRIu64, uuid);
+	return uuid;
+}
+
+SPA_EXPORT
+jack_uuid_t jack_port_uuid_generate (uint32_t port_id)
+{
+	jack_uuid_t uuid = 0x1; /* JackUUIDPort */
+	uuid = (uuid << 32) | (port_id + 1);
+	pw_log_debug("uuid %d -> %"PRIu64, port_id, uuid);
+	return uuid;
+}
+
+SPA_EXPORT
+uint32_t jack_uuid_to_index (jack_uuid_t id)
+{
+	return (id & 0xffffff) - 1;
+}
+
+SPA_EXPORT
+int  jack_uuid_compare (jack_uuid_t id1, jack_uuid_t id2)
+{
+	if (id1 == id2)
+		return 0;
+	if (id1 < id2)
+		return -1;
+	return 1;
+}
+
+SPA_EXPORT
+void jack_uuid_copy (jack_uuid_t* dst, jack_uuid_t src)
+{
+	spa_return_if_fail(dst != NULL);
+	*dst = src;
+}
+
+SPA_EXPORT
+void jack_uuid_clear (jack_uuid_t *id)
+{
+	spa_return_if_fail(id != NULL);
+	*id = 0;
+}
+
+SPA_EXPORT
+int  jack_uuid_parse (const char *buf, jack_uuid_t *id)
+{
+	spa_return_val_if_fail(buf != NULL, -EINVAL);
+	spa_return_val_if_fail(id != NULL, -EINVAL);
+
+	if (sscanf (buf, "%" PRIu64, id) == 1) {
+		if (*id < (0x1LL << 32)) {
+			/* has not type bits set - not legal */
+			return -1;
+		}
+		return 0;
+	}
+	return -1;
+}
+
+SPA_EXPORT
+void jack_uuid_unparse (jack_uuid_t id, char buf[JACK_UUID_STRING_SIZE])
+{
+	spa_return_if_fail(buf != NULL);
+	snprintf (buf, JACK_UUID_STRING_SIZE, "%" PRIu64, id);
+}
+
+SPA_EXPORT
+int  jack_uuid_empty (jack_uuid_t id)
+{
+	return id == 0;
+}