From f84862993fca45ffb3190d8e3ca0ae73ad4f2942 Mon Sep 17 00:00:00 2001 From: Ludovic Pouzenc Date: Thu, 31 May 2012 20:35:47 +0000 Subject: Debuts avec pulse audio + gmainloop mais ya du chantier vu la doc... git-svn-id: file:///var/svn/2012-violon-leds/trunk@8 6be1fa4d-33ac-4c33-becc-79fcb3794bb6 --- tests/test5/compil.sh | 3 + tests/test5/test5.c | 176 ++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 179 insertions(+) create mode 100755 tests/test5/compil.sh create mode 100644 tests/test5/test5.c (limited to 'tests') diff --git a/tests/test5/compil.sh b/tests/test5/compil.sh new file mode 100755 index 0000000..6ca9982 --- /dev/null +++ b/tests/test5/compil.sh @@ -0,0 +1,3 @@ +#!/bin/bash -ex +gcc -Wall -g -c test5.c $(pkg-config --cflags gtk+-2.0 libpulse libpulse-mainloop-glib) +gcc -Wall -o test5 test5.o $(pkg-config --libs gtk+-2.0 libpulse libpulse-mainloop-glib) diff --git a/tests/test5/test5.c b/tests/test5/test5.c new file mode 100644 index 0000000..373efb0 --- /dev/null +++ b/tests/test5/test5.c @@ -0,0 +1,176 @@ +#ifdef HAVE_CONFIG_H +#include +#endif + +#include +#include +#include +#include + +#include + +#include +#include + +#define APP_TITLE "Test 5 lpo" +#define BUFSIZE 1024 + +pa_context *context; + +void create_stream(); + +static void stream_state_callback(pa_stream *s, void *unused) { + switch (pa_stream_get_state(s)) { + case PA_STREAM_UNCONNECTED: + case PA_STREAM_CREATING: + break; + + case PA_STREAM_READY: + printf("PA_STREAM_READY\n"); +/* + g_assert(!mainWindow); + mainWindow = new MainWindow(*pa_stream_get_channel_map(s), device_name, device_description); + + g_timeout_add(100, latency_func, NULL); + pa_operation_unref(pa_stream_update_timing_info(stream, stream_update_timing_info_callback, NULL)); +*/ + break; + + case PA_STREAM_FAILED: + printf("PA_STREAM_FAILED\n"); + break; + + case PA_STREAM_TERMINATED: + printf("PA_STREAM_TERMINATED\n"); + //Gtk::Main::quit(); + } +} + +static void context_get_source_info_callback(pa_context *c, const pa_source_info *si, int is_last, void *unused) { + printf("context_get_source_info_callback\n"); + + if (is_last < 0) { + printf("Failed to get source information"); + return; + } + + if (!si) + return; + + create_stream(si->name, si->description, si->sample_spec, si->channel_map); +} + +static void context_get_sink_info_callback(pa_context *c, const pa_sink_info *si, int is_last, void *unused) { + printf("context_get_sink_info_callback\n"); + if (is_last < 0) { + printf("Failed to get sink information"); + return; + } + + if (!si) + return; + + create_stream(si->monitor_source_name, si->description, si->sample_spec, si->channel_map); +} + + +static void stream_read_callback(pa_stream *s, size_t l, void *unused) { + const void *p; + + if (pa_stream_peek(s, &p, &l) < 0) { + printf("pa_stream_peek() failed: %s", pa_strerror(pa_context_errno(context))); + return; + } + + printf("%f, %i\n", *((const float*)p), l/sizeof(float)); + + pa_stream_drop(s); +} + +static void context_state_callback(pa_context *c, void *unused) { + switch (pa_context_get_state(c)) { + case PA_CONTEXT_UNCONNECTED: + printf("PA_CONTEXT_UNCONNECTED\n"); + break; + case PA_CONTEXT_CONNECTING: + printf("PA_CONTEXT_CONNECTING\n"); + break; + case PA_CONTEXT_AUTHORIZING: + printf("PA_CONTEXT_AUTHORIZING\n"); + break; + case PA_CONTEXT_SETTING_NAME: + printf("PA_CONTEXT_SETTING_NAME\n"); + break; + + case PA_CONTEXT_READY: + printf("PA_CONTEXT_READY\n"); + //g_assert(!stream); + + //if (device_name && mode == RECORD) + //pa_operation_unref(pa_context_get_source_info_by_name(c, device_name, context_get_source_info_callback, NULL)); + /*else if (device_name && mode == PLAYBACK) + pa_operation_unref(pa_context_get_sink_info_by_name(c, device_name, context_get_sink_info_callback, NULL)); + else + pa_operation_unref(pa_context_get_server_info(c, context_get_server_info_callback, NULL)); + */ + break; + + case PA_CONTEXT_FAILED: + printf("PA_CONTEXT_FAILED\n"); + break; + + case PA_CONTEXT_TERMINATED: + printf("PA_CONTEXT_TERMINATED\n"); + break; + } +} + +void create_stream(const char *name, const char *description, const pa_sample_spec *ss, const pa_channel_map *cmap) { + /* The sample type to use */ + static const pa_sample_spec nss = { + .format = PA_SAMPLE_S16LE, + .rate = 44100, + .channels = 1 + }; + + pa_stream *stream=NULL; + char t[256]; +/* + g_free(device_name); + device_name = g_strdup(name); + g_free(device_description); + device_description = g_strdup(description); +*/ + + printf("Using sample format: %s", pa_sample_spec_snprint(t, sizeof(t), &nss)); + printf("Using channel map: %s", pa_channel_map_snprint(t, sizeof(t), cmap)); + + stream = pa_stream_new(context, APP_TITLE, &nss, cmap); + pa_stream_set_state_callback(stream, stream_state_callback, NULL); + pa_stream_set_read_callback(stream, stream_read_callback, NULL); + pa_stream_connect_record(stream, name, NULL, (enum pa_stream_flags) 0); +} + + +int main(int argc, char*argv[]) { +/* + int ret = 1; + int error; + int i,j; + float sum; +*/ + pa_glib_mainloop *m; + + m = pa_glib_mainloop_new(g_main_context_default()); +// g_assert(m); + + context = pa_context_new(pa_glib_mainloop_get_api(m), APP_TITLE); +// g_assert(context); + + pa_context_set_state_callback(context, context_state_callback, NULL); + pa_context_connect(context, NULL, PA_CONTEXT_NOAUTOSPAWN, NULL); + + sleep(60); + + return 0; +} -- cgit v1.2.3