shithub: drawterm

Download patch

ref: 1f5a91b06083d47de0a85f432e1c4213c0a12095
parent: 671477fdba0362f603b387bc121d6fdedf67a7af
author: Jacob Moody <moody@posixcafe.org>
date: Wed Oct 13 02:58:21 EDT 2021

add pipewire playback support

--- a/Make.linux
+++ b/Make.linux
@@ -5,15 +5,15 @@
 AS=as
 RANLIB=ranlib
 CC=gcc
-CFLAGS=-Wall -Wno-missing-braces -ggdb -I$(ROOT) -I$(ROOT)/include -I$(ROOT)/kern -c -D_THREAD_SAFE -DPTHREAD $(PTHREAD) -O2
+CFLAGS=-Wall -Wno-missing-braces -ggdb -I$(ROOT) -I$(ROOT)/include -I$(ROOT)/kern -c -D_THREAD_SAFE -DPTHREAD $(PTHREAD) -I/usr/include/pipewire-0.3 -I/usr/include/spa-0.2 -D_REENTRANT -O2
 O=o
 OS=posix
 GUI=wl
-LDADD=-lwayland-client -lxkbcommon -ggdb -lm -lrt
+LDADD=-lwayland-client -lxkbcommon -ggdb -lm -lrt -lpipewire-0.3
 LDFLAGS=$(PTHREAD)
 TARG=drawterm
 # AUDIO=none
-AUDIO=unix
+AUDIO=pipewire
 
 all: default
 
--- /dev/null
+++ b/kern/devaudio-pipewire.c
@@ -1,0 +1,181 @@
+#include	"u.h"
+#include	"lib.h"
+#include	"dat.h"
+#include	"fns.h"
+#include	"error.h"
+#include	"devaudio.h"
+
+#undef long
+#include <pipewire/pipewire.h>
+#include <spa/param/audio/format-utils.h>
+
+static struct {
+	Lock lk;
+	Rendez z;
+	int init;
+	struct pw_main_loop *loop;
+	struct pw_stream *output;
+
+	char buf[8192];
+	int written; /* 0 means empty buffer */
+} pwstate;
+
+static char *argv[] = { "drawterm" };
+static int argc = 1;
+
+static void
+on_process(void *data)
+{
+	struct pw_buffer *b;
+	struct spa_buffer *buf;
+	int16_t *dst;
+
+	lock(&pwstate.lk);
+	if(pwstate.written == 0){
+		unlock(&pwstate.lk);
+		return;
+	}
+	b = pw_stream_dequeue_buffer(pwstate.output);
+	if(b == NULL)
+		sysfatal("pipewire ran out of buffers");
+
+	buf = b->buffer;
+	dst = buf->datas[0].data;
+	if(dst == NULL)
+		sysfatal("can't write anywhere");
+	if(buf->datas[0].maxsize < pwstate.written)
+		sysfatal("we buffered too much, or pipewire has comically low output rate");
+
+	memcpy(dst, pwstate.buf, pwstate.written);
+	buf->datas[0].chunk->offset = 0;
+	buf->datas[0].chunk->stride = sizeof(int16_t) * 2;
+	buf->datas[0].chunk->size = pwstate.written;
+	
+	pw_stream_queue_buffer(pwstate.output, b);
+	pwstate.written = 0;
+	unlock(&pwstate.lk);
+	wakeup(&pwstate.z);
+}
+
+static const struct pw_stream_events stream_events = {
+	PW_VERSION_STREAM_EVENTS,
+	.process = on_process,
+};
+
+static void
+pwproc(void *arg)
+{
+	struct pw_main_loop *loop;
+
+	loop = arg;
+	fprintf(stderr, "running main pipewire loop\n");
+	pw_main_loop_run(loop);
+}
+
+void
+audiodevopen(void)
+{
+	struct spa_pod *params[1];
+	struct spa_pod_builder b = SPA_POD_BUILDER_INIT(pwstate.buf, sizeof(pwstate.buf));
+	int err;
+
+	fprintf(stderr, "opening...\n");
+	lock(&pwstate.lk);
+	if(pwstate.init > 0){
+		kproc("pipewire main loop", pwproc, pwstate.loop);
+		unlock(&pwstate.lk);
+		return;
+	}
+
+	pwstate.init++;
+	fprintf(stderr, "initint...\n");
+	pw_init(&argc, &argv);
+	pwstate.loop = pw_main_loop_new(NULL);
+	if(pwstate.loop == NULL)
+		sysfatal("could not create loop");
+	pwstate.output = pw_stream_new_simple(
+		pw_main_loop_get_loop(pwstate.loop),
+		"drawterm",
+		pw_properties_new(
+			PW_KEY_MEDIA_TYPE, "Audio",
+			PW_KEY_MEDIA_CATEGORY, "Playback",
+			PW_KEY_MEDIA_ROLE, "Music",
+			NULL),
+		&stream_events,
+		NULL);
+
+	if(pwstate.output == NULL)
+		sysfatal("could not create output");
+	params[0] = spa_format_audio_raw_build(&b, SPA_PARAM_EnumFormat,
+		&SPA_AUDIO_INFO_RAW_INIT(
+			.format = SPA_AUDIO_FORMAT_S16_LE,
+			.channels = 2,
+			.rate = 44100 ));
+
+	err = pw_stream_connect(pwstate.output,
+		PW_DIRECTION_OUTPUT,
+		PW_ID_ANY,
+		PW_STREAM_FLAG_AUTOCONNECT |
+		PW_STREAM_FLAG_MAP_BUFFERS |
+		PW_STREAM_FLAG_RT_PROCESS,
+		params, 1);
+
+	if(err < 0)
+		sysfatal("failed to connect");
+
+	unlock(&pwstate.lk);
+	kproc("pipewire main loop", pwproc, pwstate.loop);
+}
+
+void
+audiodevclose(void)
+{
+	lock(&pwstate.lk);
+	pw_main_loop_quit(pwstate.loop);
+	unlock(&pwstate.lk);
+}
+
+int
+audiodevread(void *a, int n)
+{
+	error("no record support");
+	return -1;
+}
+
+static int
+canwrite(void *arg)
+{
+	return pwstate.written == 0;
+}
+
+int
+audiodevwrite(void *a, int n)
+{
+	if(n > sizeof(pwstate.buf)){
+		sysfatal("write too large of size:", n);
+		n = sizeof(pwstate.buf);
+	}
+	lock(&pwstate.lk);
+	if(pwstate.written != 0){
+		unlock(&pwstate.lk);
+		sleep(&pwstate.z, canwrite, 0);
+		lock(&pwstate.lk);
+	}
+	memcpy(pwstate.buf, a, n);
+	pwstate.written = n;
+	unlock(&pwstate.lk);
+	return n;
+}
+
+void
+audiodevsetvol(int what, int left, int right)
+{
+	error("no audio support");
+}
+
+void
+audiodevgetvol(int what, int *left, int *right)
+{
+	error("no audio support");
+}
+