summaryrefslogtreecommitdiff
path: root/recordmydesktop/src/rmd_jack.c
diff options
context:
space:
mode:
authorVito Caputo <vcaputo@pengaru.com>2020-07-11 16:40:51 -0700
committerVito Caputo <vcaputo@pengaru.com>2020-07-11 16:40:51 -0700
commitcfcca8681b88a171fb2cdbb83daa5f22bbedb6b8 (patch)
tree927aec37363af1b0bd98ac9b4c8bf3f91c134a7c /recordmydesktop/src/rmd_jack.c
parent522d52b58f6a8c29efa915bb1b119f49212e89ee (diff)
*: get libjack synchronization on the same page
This isn't tested as I don't currently have a JACK setup, but it at least compiles and looks semi sane.
Diffstat (limited to 'recordmydesktop/src/rmd_jack.c')
-rw-r--r--recordmydesktop/src/rmd_jack.c28
1 files changed, 11 insertions, 17 deletions
diff --git a/recordmydesktop/src/rmd_jack.c b/recordmydesktop/src/rmd_jack.c
index ba37c8b..841017f 100644
--- a/recordmydesktop/src/rmd_jack.c
+++ b/recordmydesktop/src/rmd_jack.c
@@ -55,25 +55,19 @@ static int rmdJackCapture(jack_nframes_t nframes, void *jdata_t) {
for(int i = 0; i < jdata->nports; i++)
jdata->portbuf[i] = jack_port_get_buffer(jdata->ports[i], nframes);
+
+ pthread_mutex_lock(jdata->sound_buffer_mutex);
//vorbis analysis buffer wants uninterleaved data
//so we are simply placing the buffers for every channel
//sequentially on the ringbuffer
for(int i = 0; i < jdata->nports; i++)
- (*jack_ringbuffer_write)( jdata->sound_buffer,
- (void *)(jdata->portbuf[i]),
- nframes *
- sizeof(jack_default_audio_sample_t));
-/*FIXME */
-//This is not safe.
-//cond_var signaling must move away from signal handlers
-//alltogether (rmdJackCapture, SetExpired, SetPaused).
-//Better would be a set of pipes for each of these.
-//The callback should write on the pipe and the main thread
-//should perform a select over the fd's, signaling afterwards the
-//appropriate cond_var.
- pthread_mutex_lock(jdata->snd_buff_ready_mutex);
+ jack_ringbuffer_write( jdata->sound_buffer,
+ (void *)(jdata->portbuf[i]),
+ nframes *
+ sizeof(jack_default_audio_sample_t));
+
pthread_cond_signal(jdata->sound_data_read);
- pthread_mutex_unlock(jdata->snd_buff_ready_mutex);
+ pthread_mutex_unlock(jdata->sound_buffer_mutex);
return 0;
}
@@ -148,7 +142,7 @@ int rmdStartJackClient(JackData *jdata) {
snprintf( pidbuf, 8, "%d", pid );
strcat(rmd_client_name, pidbuf);
- if ((jdata->client = (*jack_client_new)(rmd_client_name)) == 0) {
+ if ((jdata->client = jack_client_new(rmd_client_name)) == 0) {
fprintf(stderr, "Could not create new client!\n"
"Make sure that Jack server is running!\n");
return 15;
@@ -172,7 +166,7 @@ int rmdStartJackClient(JackData *jdata) {
jdata->frequency*
sizeof(jack_default_audio_sample_t)*
jdata->nports);
- jdata->sound_buffer = (*jack_ringbuffer_create)((int)(ring_buffer_size+0.5));//round up
+ jdata->sound_buffer = jack_ringbuffer_create((int)(ring_buffer_size+0.5));//round up
jack_set_process_callback(jdata->client, rmdJackCapture, jdata);
jack_on_shutdown(jdata->client, rmdJackShutdown, jdata);
@@ -192,7 +186,7 @@ int rmdStartJackClient(JackData *jdata) {
int rmdStopJackClient(JackData *jdata) {
int ret = 0;
- (*jack_ringbuffer_free)(jdata->sound_buffer);
+ jack_ringbuffer_free(jdata->sound_buffer);
if (jack_client_close(jdata->client)) {
fprintf(stderr, "Cannot close Jack client!\n");
ret = 1;
© All Rights Reserved