summaryrefslogtreecommitdiff
path: root/gr-audio/lib/jack
diff options
context:
space:
mode:
authorTom Rondeau2011-04-08 15:37:29 -0400
committerTom Rondeau2011-04-08 15:37:29 -0400
commit21b64f070a3eb38ab044529a6ddd9cd6b6d0a2cb (patch)
tree4e72909a051b0a4ac428252d15f34b53bcc986b6 /gr-audio/lib/jack
parentd7093fd06d0ec37f6ba2841d202fe90f4fa3661e (diff)
parent5c358afd00347f5da7a59dd73ea79cd3df26659d (diff)
downloadgnuradio-21b64f070a3eb38ab044529a6ddd9cd6b6d0a2cb.tar.gz
gnuradio-21b64f070a3eb38ab044529a6ddd9cd6b6d0a2cb.tar.bz2
gnuradio-21b64f070a3eb38ab044529a6ddd9cd6b6d0a2cb.zip
Merge branch 'master' into constell_obj
Conflicts: gnuradio-core/src/lib/filter/gr_pfb_clock_sync_ccf.h gr-audio-oss/src/Makefile.swig.gen gr-audio/swig/Makefile.swig.gen
Diffstat (limited to 'gr-audio/lib/jack')
-rw-r--r--gr-audio/lib/jack/audio_jack_sink.cc236
-rw-r--r--gr-audio/lib/jack/audio_jack_sink.h79
-rw-r--r--gr-audio/lib/jack/audio_jack_source.cc237
-rw-r--r--gr-audio/lib/jack/audio_jack_source.h79
-rw-r--r--gr-audio/lib/jack/gr-audio-jack.conf8
-rw-r--r--gr-audio/lib/jack/gri_jack.cc30
-rw-r--r--gr-audio/lib/jack/gri_jack.h28
7 files changed, 697 insertions, 0 deletions
diff --git a/gr-audio/lib/jack/audio_jack_sink.cc b/gr-audio/lib/jack/audio_jack_sink.cc
new file mode 100644
index 000000000..f06e77bd5
--- /dev/null
+++ b/gr-audio/lib/jack/audio_jack_sink.cc
@@ -0,0 +1,236 @@
+/* -*- c++ -*- */
+/*
+ * Copyright 2005-2011 Free Software Foundation, Inc.
+ *
+ * This file is part of GNU Radio
+ *
+ * GNU Radio is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3, or (at your option)
+ * any later version.
+ *
+ * GNU Radio is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNU Radio; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street,
+ * Boston, MA 02110-1301, USA.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "gr_audio_registry.h"
+#include <audio_jack_sink.h>
+#include <gr_io_signature.h>
+#include <gr_prefs.h>
+#include <stdio.h>
+#include <iostream>
+#include <stdexcept>
+#include <gri_jack.h>
+
+#ifndef NO_PTHREAD
+#include <pthread.h>
+#endif
+
+AUDIO_REGISTER_SINK(REG_PRIO_MED, jack)(
+ int sampling_rate, const std::string &device_name, bool ok_to_block
+){
+ return audio_sink::sptr(new audio_jack_sink(sampling_rate, device_name, ok_to_block));
+}
+
+typedef jack_default_audio_sample_t sample_t;
+
+
+// Number of jack buffers in the ringbuffer
+// TODO: make it to match at least the quantity of items passed by work()
+static const unsigned int N_BUFFERS = 16;
+
+static std::string
+default_device_name ()
+{
+ return gr_prefs::singleton()->get_string("audio_jack", "default_output_device", "gr_sink");
+}
+
+int
+jack_sink_process (jack_nframes_t nframes, void *arg)
+{
+ audio_jack_sink *self = (audio_jack_sink *)arg;
+ unsigned int read_size = nframes*sizeof(sample_t);
+
+ if (jack_ringbuffer_read_space (self->d_ringbuffer) < read_size) {
+ self->d_nunderuns++;
+ // FIXME: move this fputs out, we shouldn't use blocking calls in process()
+ fputs ("jU", stderr);
+ return 0;
+ }
+
+ char *buffer = (char *) jack_port_get_buffer (self->d_jack_output_port, nframes);
+
+ jack_ringbuffer_read (self->d_ringbuffer, buffer, read_size);
+
+#ifndef NO_PTHREAD
+ // Tell the sink thread there is room in the ringbuffer.
+ // If it is already running, the lock will not be available.
+ // We can't wait here in the process() thread, but we don't
+ // need to signal in that case, because the sink thread will
+ // check for room availability.
+
+ if (pthread_mutex_trylock (&self->d_jack_process_lock) == 0) {
+ pthread_cond_signal (&self->d_ringbuffer_ready);
+ pthread_mutex_unlock (&self->d_jack_process_lock);
+ }
+#endif
+
+ return 0;
+}
+
+// ----------------------------------------------------------------
+
+audio_jack_sink::audio_jack_sink (int sampling_rate,
+ const std::string device_name,
+ bool ok_to_block)
+ : gr_sync_block ("audio_jack_sink",
+ gr_make_io_signature (0, 0, 0),
+ gr_make_io_signature (0, 0, 0)),
+ d_sampling_rate (sampling_rate),
+ d_device_name (device_name.empty() ? default_device_name() : device_name),
+ d_ok_to_block (ok_to_block),
+ d_jack_client (0),
+ d_ringbuffer (0),
+ d_nunderuns (0)
+{
+#ifndef NO_PTHREAD
+ pthread_cond_init(&d_ringbuffer_ready, NULL);;
+ pthread_mutex_init(&d_jack_process_lock, NULL);
+#endif
+
+ // try to become a client of the JACK server
+ jack_options_t options = JackNullOption;
+ jack_status_t status;
+ const char *server_name = NULL;
+ if ((d_jack_client = jack_client_open (d_device_name.c_str (),
+ options, &status,
+ server_name)) == NULL) {
+ fprintf (stderr, "audio_jack_sink[%s]: jack server not running?\n",
+ d_device_name.c_str());
+ throw std::runtime_error ("audio_jack_sink");
+ }
+
+ // tell the JACK server to call `jack_sink_process()' whenever
+ // there is work to be done.
+ jack_set_process_callback (d_jack_client, &jack_sink_process, (void*)this);
+
+ // tell the JACK server to call `jack_shutdown()' if
+ // it ever shuts down, either entirely, or if it
+ // just decides to stop calling us.
+
+ //jack_on_shutdown (d_jack_client, &jack_shutdown, (void*)this);
+
+ d_jack_output_port =
+ jack_port_register (d_jack_client, "out",
+ JACK_DEFAULT_AUDIO_TYPE, JackPortIsOutput, 0);
+
+
+ d_jack_buffer_size = jack_get_buffer_size (d_jack_client);
+
+ set_output_multiple (d_jack_buffer_size);
+
+ d_ringbuffer =
+ jack_ringbuffer_create (N_BUFFERS*d_jack_buffer_size*sizeof(sample_t));
+ if (d_ringbuffer == NULL)
+ bail ("jack_ringbuffer_create failed", 0);
+
+ assert(sizeof(float)==sizeof(sample_t));
+ set_input_signature (gr_make_io_signature (1, 1, sizeof (sample_t)));
+
+
+ jack_nframes_t sample_rate = jack_get_sample_rate (d_jack_client);
+
+ if ((jack_nframes_t)sampling_rate != sample_rate){
+ fprintf (stderr, "audio_jack_sink[%s]: unable to support sampling rate %d\n",
+ d_device_name.c_str (), sampling_rate);
+ fprintf (stderr, " card requested %d instead.\n", sample_rate);
+ }
+}
+
+
+bool
+audio_jack_sink::check_topology (int ninputs, int noutputs)
+{
+ if (ninputs != 1)
+ return false;
+
+ // tell the JACK server that we are ready to roll
+ if (jack_activate (d_jack_client))
+ throw std::runtime_error ("audio_jack_sink");
+
+ return true;
+}
+
+audio_jack_sink::~audio_jack_sink ()
+{
+ jack_client_close (d_jack_client);
+ jack_ringbuffer_free (d_ringbuffer);
+}
+
+int
+audio_jack_sink::work (int noutput_items,
+ gr_vector_const_void_star &input_items,
+ gr_vector_void_star &output_items)
+{
+ // write_size and work_size are in bytes
+ int work_size = noutput_items*sizeof(sample_t);
+ unsigned int write_size;
+
+ while (work_size > 0) {
+ unsigned int write_space; // bytes
+
+#ifdef NO_PTHREAD
+ while ((write_space=jack_ringbuffer_write_space (d_ringbuffer)) <
+ d_jack_buffer_size*sizeof(sample_t)) {
+ usleep(1000000*((d_jack_buffer_size-write_space/sizeof(sample_t))/d_sampling_rate));
+ }
+#else
+ // JACK actually requires POSIX
+
+ pthread_mutex_lock (&d_jack_process_lock);
+ while ((write_space=jack_ringbuffer_write_space (d_ringbuffer)) <
+ d_jack_buffer_size*sizeof(sample_t)) {
+
+ // wait until jack_sink_process() signals more room
+ pthread_cond_wait (&d_ringbuffer_ready, &d_jack_process_lock);
+ }
+ pthread_mutex_unlock (&d_jack_process_lock);
+#endif
+
+ write_space -= write_space%(d_jack_buffer_size*sizeof(sample_t));
+ write_size = std::min(write_space, (unsigned int)work_size);
+
+ if (jack_ringbuffer_write (d_ringbuffer, (char *) input_items[0],
+ write_size) < write_size) {
+ bail ("jack_ringbuffer_write failed", 0);
+ }
+ work_size -= write_size;
+ }
+
+ return noutput_items;
+}
+
+void
+audio_jack_sink::output_error_msg (const char *msg, int err)
+{
+ fprintf (stderr, "audio_jack_sink[%s]: %s: %d\n",
+ d_device_name.c_str (), msg, err);
+}
+
+void
+audio_jack_sink::bail (const char *msg, int err) throw (std::runtime_error)
+{
+ output_error_msg (msg, err);
+ throw std::runtime_error ("audio_jack_sink");
+}
diff --git a/gr-audio/lib/jack/audio_jack_sink.h b/gr-audio/lib/jack/audio_jack_sink.h
new file mode 100644
index 000000000..a11863ee0
--- /dev/null
+++ b/gr-audio/lib/jack/audio_jack_sink.h
@@ -0,0 +1,79 @@
+/* -*- c++ -*- */
+/*
+ * Copyright 2005-2011 Free Software Foundation, Inc.
+ *
+ * This file is part of GNU Radio
+ *
+ * GNU Radio is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3, or (at your option)
+ * any later version.
+ *
+ * GNU Radio is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNU Radio; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street,
+ * Boston, MA 02110-1301, USA.
+ */
+#ifndef INCLUDED_AUDIO_JACK_SINK_H
+#define INCLUDED_AUDIO_JACK_SINK_H
+
+#include <gr_audio_sink.h>
+#include <string>
+#include <jack/jack.h>
+#include <jack/ringbuffer.h>
+#include <stdexcept>
+
+int jack_sink_process (jack_nframes_t nframes, void *arg);
+
+/*!
+ * \brief audio sink using JACK
+ *
+ * The sink has one input stream of floats.
+ *
+ * Input samples must be in the range [-1,1].
+ */
+class audio_jack_sink : public audio_sink {
+
+ friend int jack_sink_process (jack_nframes_t nframes, void *arg);
+
+ // typedef for pointer to class work method
+ typedef int (audio_jack_sink::*work_t)(int noutput_items,
+ gr_vector_const_void_star &input_items,
+ gr_vector_void_star &output_items);
+
+ unsigned int d_sampling_rate;
+ std::string d_device_name;
+ bool d_ok_to_block;
+
+ jack_client_t *d_jack_client;
+ jack_port_t *d_jack_output_port;
+ jack_ringbuffer_t *d_ringbuffer;
+ jack_nframes_t d_jack_buffer_size;
+ pthread_cond_t d_ringbuffer_ready;
+ pthread_mutex_t d_jack_process_lock;
+
+ // random stats
+ int d_nunderuns; // count of underruns
+
+ void output_error_msg (const char *msg, int err);
+ void bail (const char *msg, int err) throw (std::runtime_error);
+
+
+public:
+ audio_jack_sink (int sampling_rate, const std::string device_name, bool ok_to_block);
+
+ ~audio_jack_sink ();
+
+ bool check_topology (int ninputs, int noutputs);
+
+ int work (int noutput_items,
+ gr_vector_const_void_star &input_items,
+ gr_vector_void_star &output_items);
+};
+
+#endif /* INCLUDED_AUDIO_JACK_SINK_H */
diff --git a/gr-audio/lib/jack/audio_jack_source.cc b/gr-audio/lib/jack/audio_jack_source.cc
new file mode 100644
index 000000000..dcd41c3ac
--- /dev/null
+++ b/gr-audio/lib/jack/audio_jack_source.cc
@@ -0,0 +1,237 @@
+/* -*- c++ -*- */
+/*
+ * Copyright 2005,2006,2010 Free Software Foundation, Inc.
+ *
+ * This file is part of GNU Radio
+ *
+ * GNU Radio is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3, or (at your option)
+ * any later version.
+ *
+ * GNU Radio is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNU Radio; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street,
+ * Boston, MA 02110-1301, USA.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "gr_audio_registry.h"
+#include <audio_jack_source.h>
+#include <gr_io_signature.h>
+#include <gr_prefs.h>
+#include <stdio.h>
+#include <iostream>
+#include <stdexcept>
+#include <gri_jack.h>
+
+#ifndef NO_PTHREAD
+#include <pthread.h>
+#endif
+
+AUDIO_REGISTER_SOURCE(REG_PRIO_MED, jack)(
+ int sampling_rate, const std::string &device_name, bool ok_to_block
+){
+ return audio_source::sptr(new audio_jack_source(sampling_rate, device_name, ok_to_block));
+}
+
+typedef jack_default_audio_sample_t sample_t;
+
+
+// Number of jack buffers in the ringbuffer
+// TODO: make it to match at least the quantity of items passed to work()
+static const unsigned int N_BUFFERS = 16;
+
+static std::string
+default_device_name ()
+{
+ return gr_prefs::singleton()->get_string("audio_jack", "default_input_device", "gr_source");
+}
+
+
+int
+jack_source_process (jack_nframes_t nframes, void *arg)
+{
+ audio_jack_source *self = (audio_jack_source *)arg;
+ unsigned int write_size = nframes*sizeof(sample_t);
+
+ if (jack_ringbuffer_write_space (self->d_ringbuffer) < write_size) {
+ self->d_noverruns++;
+ // FIXME: move this fputs out, we shouldn't use blocking calls in process()
+ fputs ("jO", stderr);
+ return 0;
+ }
+
+ char *buffer = (char *) jack_port_get_buffer (self->d_jack_input_port, nframes);
+
+ jack_ringbuffer_write (self->d_ringbuffer, buffer, write_size);
+
+#ifndef NO_PTHREAD
+ // Tell the source thread there is data in the ringbuffer.
+ // If it is already running, the lock will not be available.
+ // We can't wait here in the process() thread, but we don't
+ // need to signal in that case, because the source thread will
+ // check for data availability.
+
+ if (pthread_mutex_trylock (&self->d_jack_process_lock) == 0) {
+ pthread_cond_signal (&self->d_ringbuffer_ready);
+ pthread_mutex_unlock (&self->d_jack_process_lock);
+ }
+#endif
+
+ return 0;
+}
+
+// ----------------------------------------------------------------
+
+audio_jack_source::audio_jack_source (int sampling_rate,
+ const std::string device_name,
+ bool ok_to_block)
+ : gr_sync_block ("audio_jack_source",
+ gr_make_io_signature (0, 0, 0),
+ gr_make_io_signature (0, 0, 0)),
+ d_sampling_rate (sampling_rate),
+ d_device_name (device_name.empty() ? default_device_name() : device_name),
+ d_ok_to_block(ok_to_block),
+ d_jack_client (0),
+ d_ringbuffer (0),
+ d_noverruns (0)
+{
+#ifndef NO_PTHREAD
+ pthread_cond_init(&d_ringbuffer_ready, NULL);;
+ pthread_mutex_init(&d_jack_process_lock, NULL);
+#endif
+
+ // try to become a client of the JACK server
+ jack_options_t options = JackNullOption;
+ jack_status_t status;
+ const char *server_name = NULL;
+ if ((d_jack_client = jack_client_open (d_device_name.c_str (),
+ options, &status,
+ server_name)) == NULL) {
+ fprintf (stderr, "audio_jack_source[%s]: jack server not running?\n",
+ d_device_name.c_str());
+ throw std::runtime_error ("audio_jack_source");
+ }
+
+ // tell the JACK server to call `jack_source_process()' whenever
+ // there is work to be done.
+ jack_set_process_callback (d_jack_client, &jack_source_process, (void*)this);
+
+ // tell the JACK server to call `jack_shutdown()' if
+ // it ever shuts down, either entirely, or if it
+ // just decides to stop calling us.
+
+ //jack_on_shutdown (d_jack_client, &jack_shutdown, (void*)this);
+
+ d_jack_input_port = jack_port_register (d_jack_client, "in",
+ JACK_DEFAULT_AUDIO_TYPE,
+ JackPortIsInput, 0);
+
+
+ d_jack_buffer_size = jack_get_buffer_size (d_jack_client);
+
+ set_output_multiple (d_jack_buffer_size);
+
+ d_ringbuffer = jack_ringbuffer_create (N_BUFFERS*d_jack_buffer_size*sizeof(sample_t));
+ if (d_ringbuffer == NULL)
+ bail ("jack_ringbuffer_create failed", 0);
+
+ assert(sizeof(float)==sizeof(sample_t));
+ set_output_signature (gr_make_io_signature (1, 1, sizeof (sample_t)));
+
+
+ jack_nframes_t sample_rate = jack_get_sample_rate (d_jack_client);
+
+ if ((jack_nframes_t)sampling_rate != sample_rate){
+ fprintf (stderr, "audio_jack_source[%s]: unable to support sampling rate %d\n",
+ d_device_name.c_str (), sampling_rate);
+ fprintf (stderr, " card requested %d instead.\n", sample_rate);
+ }
+}
+
+
+bool
+audio_jack_source::check_topology (int ninputs, int noutputs)
+{
+ // tell the JACK server that we are ready to roll
+ if (jack_activate (d_jack_client))
+ throw std::runtime_error ("audio_jack_source");
+
+ return true;
+}
+
+audio_jack_source::~audio_jack_source ()
+{
+ jack_client_close (d_jack_client);
+ jack_ringbuffer_free (d_ringbuffer);
+}
+
+int
+audio_jack_source::work (int noutput_items,
+ gr_vector_const_void_star &input_items,
+ gr_vector_void_star &output_items)
+{
+ // read_size and work_size are in bytes
+ unsigned int read_size;
+
+ // Minimize latency
+ noutput_items = std::min (noutput_items, (int)d_jack_buffer_size);
+
+ int work_size = noutput_items*sizeof(sample_t);
+
+ while (work_size > 0) {
+ unsigned int read_space; // bytes
+
+#ifdef NO_PTHREAD
+ while ((read_space=jack_ringbuffer_read_space (d_ringbuffer)) <
+ d_jack_buffer_size*sizeof(sample_t)) {
+ usleep(1000000*((d_jack_buffer_size-read_space/sizeof(sample_t))/d_sampling_rate));
+ }
+#else
+ // JACK actually requires POSIX
+
+ pthread_mutex_lock (&d_jack_process_lock);
+ while ((read_space=jack_ringbuffer_read_space (d_ringbuffer)) <
+ d_jack_buffer_size*sizeof(sample_t)) {
+
+ // wait until jack_source_process() signals more data
+ pthread_cond_wait (&d_ringbuffer_ready, &d_jack_process_lock);
+ }
+ pthread_mutex_unlock (&d_jack_process_lock);
+#endif
+
+ read_space -= read_space%(d_jack_buffer_size*sizeof(sample_t));
+ read_size = std::min(read_space, (unsigned int)work_size);
+
+ if (jack_ringbuffer_read (d_ringbuffer, (char *) output_items[0],
+ read_size) < read_size) {
+ bail ("jack_ringbuffer_read failed", 0);
+ }
+ work_size -= read_size;
+ }
+
+ return noutput_items;
+}
+
+void
+audio_jack_source::output_error_msg (const char *msg, int err)
+{
+ fprintf (stderr, "audio_jack_source[%s]: %s: %d\n",
+ d_device_name.c_str (), msg, err);
+}
+
+void
+audio_jack_source::bail (const char *msg, int err) throw (std::runtime_error)
+{
+ output_error_msg (msg, err);
+ throw std::runtime_error ("audio_jack_source");
+}
diff --git a/gr-audio/lib/jack/audio_jack_source.h b/gr-audio/lib/jack/audio_jack_source.h
new file mode 100644
index 000000000..858f34528
--- /dev/null
+++ b/gr-audio/lib/jack/audio_jack_source.h
@@ -0,0 +1,79 @@
+/* -*- c++ -*- */
+/*
+ * Copyright 2005-2011 Free Software Foundation, Inc.
+ *
+ * This file is part of GNU Radio
+ *
+ * GNU Radio is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3, or (at your option)
+ * any later version.
+ *
+ * GNU Radio is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNU Radio; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street,
+ * Boston, MA 02110-1301, USA.
+ */
+#ifndef INCLUDED_AUDIO_JACK_SOURCE_H
+#define INCLUDED_AUDIO_JACK_SOURCE_H
+
+#include <gr_audio_source.h>
+#include <string>
+#include <jack/jack.h>
+#include <jack/ringbuffer.h>
+#include <stdexcept>
+
+int jack_source_process (jack_nframes_t nframes, void *arg);
+
+/*!
+ * \brief audio source using JACK
+ *
+ * The source has one input stream of floats.
+ *
+ * Output samples will be in the range [-1,1].
+ */
+class audio_jack_source : public audio_source {
+
+ friend int jack_source_process (jack_nframes_t nframes, void *arg);
+
+ // typedef for pointer to class work method
+ typedef int (audio_jack_source::*work_t)(int noutput_items,
+ gr_vector_const_void_star &input_items,
+ gr_vector_void_star &output_items);
+
+ unsigned int d_sampling_rate;
+ std::string d_device_name;
+ bool d_ok_to_block;
+
+ jack_client_t *d_jack_client;
+ jack_port_t *d_jack_input_port;
+ jack_ringbuffer_t *d_ringbuffer;
+ jack_nframes_t d_jack_buffer_size;
+ pthread_cond_t d_ringbuffer_ready;
+ pthread_mutex_t d_jack_process_lock;
+
+ // random stats
+ int d_noverruns; // count of overruns
+
+ void output_error_msg (const char *msg, int err);
+ void bail (const char *msg, int err) throw (std::runtime_error);
+
+
+public:
+ audio_jack_source (int sampling_rate, const std::string device_name, bool ok_to_block);
+
+ ~audio_jack_source ();
+
+ bool check_topology (int ninputs, int noutputs);
+
+ int work (int noutput_items,
+ gr_vector_const_void_star &input_items,
+ gr_vector_void_star &output_items);
+};
+
+#endif /* INCLUDED_AUDIO_JACK_SOURCE_H */
diff --git a/gr-audio/lib/jack/gr-audio-jack.conf b/gr-audio/lib/jack/gr-audio-jack.conf
new file mode 100644
index 000000000..bdbc1fd1d
--- /dev/null
+++ b/gr-audio/lib/jack/gr-audio-jack.conf
@@ -0,0 +1,8 @@
+# This file contains system wide configuration data for GNU Radio.
+# You may override any setting on a per-user basis by editing
+# ~/.gnuradio/config.conf
+
+[audio_jack]
+
+default_input_device = gr_source
+default_output_device = gr_sink
diff --git a/gr-audio/lib/jack/gri_jack.cc b/gr-audio/lib/jack/gri_jack.cc
new file mode 100644
index 000000000..fef1c58a6
--- /dev/null
+++ b/gr-audio/lib/jack/gri_jack.cc
@@ -0,0 +1,30 @@
+/* -*- c++ -*- */
+/*
+ * Copyright 2005 Free Software Foundation, Inc.
+ *
+ * This file is part of GNU Radio
+ *
+ * GNU Radio is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3, or (at your option)
+ * any later version.
+ *
+ * GNU Radio is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNU Radio; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street,
+ * Boston, MA 02110-1301, USA.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <gri_jack.h>
+#include <algorithm>
+
+
diff --git a/gr-audio/lib/jack/gri_jack.h b/gr-audio/lib/jack/gri_jack.h
new file mode 100644
index 000000000..ddc0b744d
--- /dev/null
+++ b/gr-audio/lib/jack/gri_jack.h
@@ -0,0 +1,28 @@
+/* -*- c++ -*- */
+/*
+ * Copyright 2005 Free Software Foundation, Inc.
+ *
+ * This file is part of GNU Radio
+ *
+ * GNU Radio is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3, or (at your option)
+ * any later version.
+ *
+ * GNU Radio is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNU Radio; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street,
+ * Boston, MA 02110-1301, USA.
+ */
+
+#ifndef INCLUDED_GRI_JACK_H
+#define INCLUDED_GRI_JACK_H
+
+#include <stdio.h>
+
+#endif /* INCLUDED_GRI_JACK_H */