X-Git-Url: https://git.gag.com/?p=fw%2Faltos;a=blobdiff_plain;f=aoview%2Faoview_flite.c;h=e1b758983d171211d5ee9ade5ec578e7dfa02575;hp=daa3ed36c69ba0bfacdc707fc4e03679d6a7b2aa;hb=cd5456f18e4b39ad76d5549df91a0e0cfb18a2e9;hpb=4ca2d910f3be689fd3c78a4f1be0555d6b1a30c1

diff --git a/aoview/aoview_flite.c b/aoview/aoview_flite.c
index daa3ed36..e1b75898 100644
--- a/aoview/aoview_flite.c
+++ b/aoview/aoview_flite.c
@@ -17,23 +17,119 @@
 
 #include <stdio.h>
 #include <flite/flite.h>
+#include "aoview.h"
+#include <alsa/asoundlib.h>
 
 cst_voice *register_cmu_us_kal();
+static cst_voice *voice;
 
-int
-main(int argc, char **argv)
+static FILE *pipe_write;
+static GThread *aoview_flite_thread;
+
+static snd_pcm_t	*alsa_handle;
+
+gpointer
+aoview_flite_task(gpointer data)
 {
+	FILE		*input = data;
 	char		line[1024];
-	cst_voice	*v;
+	cst_wave	*wave;
+	int		rate;
+	int		channels;
+	int		err;
+	char		*samples;
+	int		num_samples;
+
+	err = snd_pcm_open(&alsa_handle, "default",
+			   SND_PCM_STREAM_PLAYBACK, 0);
+	if (err >= 0)
+	{
+		if (err < 0) {
+			snd_pcm_close(alsa_handle);
+			alsa_handle = 0;
+		}
+	}
+	rate = 0;
+	channels = 0;
+	while (fgets(line, sizeof (line) - 1, input) != NULL) {
+		if (!alsa_handle)
+			continue;
+		wave = flite_text_to_wave(line, voice);
+		if (wave->sample_rate != rate ||
+		    wave->num_channels != channels)
+		{
+			rate = wave->sample_rate;
+			channels = wave->num_channels;
+			err = snd_pcm_set_params(alsa_handle,
+						 SND_PCM_FORMAT_S16,
+						 SND_PCM_ACCESS_RW_INTERLEAVED,
+						 channels,
+						 rate,
+						 1,
+						 100000);
+			if (err < 0)
+				fprintf(stderr, "alsa set_params error %s\n",
+					strerror(-err));
+		}
+		err = snd_pcm_prepare(alsa_handle);
+		if (err < 0)
+			fprintf(stderr, "alsa pcm_prepare error %s\n",
+				strerror(-err));
+		samples = (char *) wave->samples;
+		num_samples = wave->num_samples;
+		while (num_samples > 0) {
+			err = snd_pcm_writei(alsa_handle,
+					     samples, num_samples);
+			if (err <= 0) {
+				fprintf(stderr, "alsa write error %s\n",
+					strerror(-err));
+				break;
+			}
+			num_samples -= err;
+			samples += err * 2 * channels;
+		}
+		snd_pcm_drain(alsa_handle);
+		delete_wave(wave);
+	}
+	snd_pcm_close(alsa_handle);
+	alsa_handle = 0;
+	return NULL;
+}
 
-	flite_init();
-	v = register_cmu_us_kal();
-	if (!v) {
-		perror("register voice");
-		exit(1);
+void
+aoview_flite_stop(void)
+{
+	int status;
+	if (pipe_write) {
+		fclose(pipe_write);
+		pipe_write = NULL;
+	}
+	if (aoview_flite_thread) {
+		g_thread_join(aoview_flite_thread);
+		aoview_flite_thread = NULL;
 	}
-	while (fgets(line, sizeof (line) - 1, stdin) != NULL) {
-		flite_text_to_speech(line, v, "play");
+}
+
+FILE *
+aoview_flite_start(void)
+{
+	static once;
+	int	p[2];
+	GError	*error;
+	FILE	*pipe_read;
+
+	if (!once) {
+		flite_init();
+		voice = register_cmu_us_kal();
+		if (!voice) {
+			perror("register voice");
+			exit(1);
+		}
 	}
-	exit (0);
+	aoview_flite_stop();
+	pipe(p);
+	pipe_read = fdopen(p[0], "r");
+	pipe_write = fdopen(p[1], "w");
+	g_thread_create(aoview_flite_task, pipe_read, TRUE, &error);
+	return pipe_write;
 }