3 * Copyright 2005,2006,2010 Free Software Foundation, Inc.
5 * This file is part of GNU Radio
7 * GNU Radio is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation; either version 3, or (at your option)
12 * GNU Radio is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
17 * You should have received a copy of the GNU General Public License
18 * along with GNU Radio; see the file COPYING. If not, write to
19 * the Free Software Foundation, Inc., 51 Franklin Street,
20 * Boston, MA 02110-1301, USA.
27 #include <audio_jack_source.h>
28 #include <gr_io_signature.h>
39 typedef jack_default_audio_sample_t sample_t;
42 // Number of jack buffers in the ringbuffer
43 // TODO: make it to match at least the quantity of items passed to work()
44 static const unsigned int N_BUFFERS = 16;
47 default_device_name ()
49 return gr_prefs::singleton()->get_string("audio_jack", "default_input_device", "gr_source");
54 jack_source_process (jack_nframes_t nframes, void *arg)
56 audio_jack_source *self = (audio_jack_source *)arg;
57 unsigned int write_size = nframes*sizeof(sample_t);
59 if (jack_ringbuffer_write_space (self->d_ringbuffer) < write_size) {
61 // FIXME: move this fputs out, we shouldn't use blocking calls in process()
66 char *buffer = (char *) jack_port_get_buffer (self->d_jack_input_port, nframes);
68 jack_ringbuffer_write (self->d_ringbuffer, buffer, write_size);
71 // Tell the source thread there is data in the ringbuffer.
72 // If it is already running, the lock will not be available.
73 // We can't wait here in the process() thread, but we don't
74 // need to signal in that case, because the source thread will
75 // check for data availability.
77 if (pthread_mutex_trylock (&self->d_jack_process_lock) == 0) {
78 pthread_cond_signal (&self->d_ringbuffer_ready);
79 pthread_mutex_unlock (&self->d_jack_process_lock);
86 // ----------------------------------------------------------------
88 audio_jack_source_sptr
89 audio_jack_make_source (int sampling_rate, const std::string dev, bool ok_to_block)
91 return gnuradio::get_initial_sptr(new audio_jack_source (sampling_rate, dev, ok_to_block));
94 audio_jack_source::audio_jack_source (int sampling_rate,
95 const std::string device_name,
97 : gr_sync_block ("audio_jack_source",
98 gr_make_io_signature (0, 0, 0),
99 gr_make_io_signature (0, 0, 0)),
100 d_sampling_rate (sampling_rate),
101 d_device_name (device_name.empty() ? default_device_name() : device_name),
102 d_ok_to_block(ok_to_block),
108 pthread_cond_init(&d_ringbuffer_ready, NULL);;
109 pthread_mutex_init(&d_jack_process_lock, NULL);
112 // try to become a client of the JACK server
113 jack_options_t options = JackNullOption;
114 jack_status_t status;
115 const char *server_name = NULL;
116 if ((d_jack_client = jack_client_open (d_device_name.c_str (),
118 server_name)) == NULL) {
119 fprintf (stderr, "audio_jack_source[%s]: jack server not running?\n",
120 d_device_name.c_str());
121 throw std::runtime_error ("audio_jack_source");
124 // tell the JACK server to call `jack_source_process()' whenever
125 // there is work to be done.
126 jack_set_process_callback (d_jack_client, &jack_source_process, (void*)this);
128 // tell the JACK server to call `jack_shutdown()' if
129 // it ever shuts down, either entirely, or if it
130 // just decides to stop calling us.
132 //jack_on_shutdown (d_jack_client, &jack_shutdown, (void*)this);
134 d_jack_input_port = jack_port_register (d_jack_client, "in",
135 JACK_DEFAULT_AUDIO_TYPE,
139 d_jack_buffer_size = jack_get_buffer_size (d_jack_client);
141 set_output_multiple (d_jack_buffer_size);
143 d_ringbuffer = jack_ringbuffer_create (N_BUFFERS*d_jack_buffer_size*sizeof(sample_t));
144 if (d_ringbuffer == NULL)
145 bail ("jack_ringbuffer_create failed", 0);
147 assert(sizeof(float)==sizeof(sample_t));
148 set_output_signature (gr_make_io_signature (1, 1, sizeof (sample_t)));
151 jack_nframes_t sample_rate = jack_get_sample_rate (d_jack_client);
153 if ((jack_nframes_t)sampling_rate != sample_rate){
154 fprintf (stderr, "audio_jack_source[%s]: unable to support sampling rate %d\n",
155 d_device_name.c_str (), sampling_rate);
156 fprintf (stderr, " card requested %d instead.\n", sample_rate);
162 audio_jack_source::check_topology (int ninputs, int noutputs)
164 // tell the JACK server that we are ready to roll
165 if (jack_activate (d_jack_client))
166 throw std::runtime_error ("audio_jack_source");
171 audio_jack_source::~audio_jack_source ()
173 jack_client_close (d_jack_client);
174 jack_ringbuffer_free (d_ringbuffer);
178 audio_jack_source::work (int noutput_items,
179 gr_vector_const_void_star &input_items,
180 gr_vector_void_star &output_items)
182 // read_size and work_size are in bytes
183 unsigned int read_size;
186 noutput_items = std::min (noutput_items, (int)d_jack_buffer_size);
188 int work_size = noutput_items*sizeof(sample_t);
190 while (work_size > 0) {
191 unsigned int read_space; // bytes
194 while ((read_space=jack_ringbuffer_read_space (d_ringbuffer)) <
195 d_jack_buffer_size*sizeof(sample_t)) {
196 usleep(1000000*((d_jack_buffer_size-read_space/sizeof(sample_t))/d_sampling_rate));
199 // JACK actually requires POSIX
201 pthread_mutex_lock (&d_jack_process_lock);
202 while ((read_space=jack_ringbuffer_read_space (d_ringbuffer)) <
203 d_jack_buffer_size*sizeof(sample_t)) {
205 // wait until jack_source_process() signals more data
206 pthread_cond_wait (&d_ringbuffer_ready, &d_jack_process_lock);
208 pthread_mutex_unlock (&d_jack_process_lock);
211 read_space -= read_space%(d_jack_buffer_size*sizeof(sample_t));
212 read_size = std::min(read_space, (unsigned int)work_size);
214 if (jack_ringbuffer_read (d_ringbuffer, (char *) output_items[0],
215 read_size) < read_size) {
216 bail ("jack_ringbuffer_read failed", 0);
218 work_size -= read_size;
221 return noutput_items;
225 audio_jack_source::output_error_msg (const char *msg, int err)
227 fprintf (stderr, "audio_jack_source[%s]: %s: %d\n",
228 d_device_name.c_str (), msg, err);
232 audio_jack_source::bail (const char *msg, int err) throw (std::runtime_error)
234 output_error_msg (msg, err);
235 throw std::runtime_error ("audio_jack_source");