oysteikt/mpd
0
0
Fork 0
Code Issues Pull Requests Releases Activity

Add new update from Jose for JACK

Browse Source 
git-svn-id: https://svn.musicpd.org/mpd/trunk@5729 09075e82-0dd4-0310-85a5-a0d7c8717e4f
This commit is contained in:
Avuton Olrich 2007-03-23 11:07:04 +00:00
parent d5367a9504
commit 8553a98c84
1 changed files with 71 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

102
src/audioOutputs/audioOutput_jack.c
View File

@ -45,6 +45,7 @@ typedef struct _JackData {
jack_ringbuffer_t *ringbuffer[2]; jack_ringbuffer_t *ringbuffer[2];
jack_default_audio_sample_t *samples1; jack_default_audio_sample_t *samples1;
jack_default_audio_sample_t *samples2; jack_default_audio_sample_t *samples2;
int can_process;
int bps; int bps;
int shutdown; int shutdown;
int our_xrun; int our_xrun;
@ -128,9 +129,35 @@ static int process(jack_nframes_t nframes, void *arg)
out[0] = jack_port_get_buffer(jd->ports[0], nframes); out[0] = jack_port_get_buffer(jd->ports[0], nframes);
out[1] = jack_port_get_buffer(jd->ports[1], nframes); out[1] = jack_port_get_buffer(jd->ports[1], nframes);
avail_data = jack_ringbuffer_read_space(jd->ringbuffer[1]); /*if ( jd->can_process ) {*/
while ( nframes ) {
avail_data = jack_ringbuffer_read_space(jd->ringbuffer[1]);
if ( avail_data > 0 ) {
avail_frames = avail_data / sizeof(jack_default_audio_sample_t);
if (avail_frames > nframes) {
avail_frames = nframes;
avail_data = nframes*sizeof(jack_default_audio_sample_t);
}
jack_ringbuffer_read(jd->ringbuffer[0], (char *)out[0],
avail_data);
jack_ringbuffer_read(jd->ringbuffer[1], (char *)out[1],
avail_data);
nframes -= avail_frames;
out[0] += avail_data;
out[1] += avail_data;
} else {
for (i = 0; i < nframes; i++)
out[0][i] = out[1][i] = 0.0;
nframes = 0;
}
}
/*
if ( avail_data > 0 ) { if ( avail_data > 0 ) {
avail_frames = avail_data / sizeof(jack_default_audio_sample_t); avail_frames = avail_data / sizeof(jack_default_audio_sample_t);
if (avail_frames > nframes) { if (avail_frames > nframes) {
avail_frames = nframes; avail_frames = nframes;
@ -148,11 +175,11 @@ static int process(jack_nframes_t nframes, void *arg)
out[0][i] = out[1][i] = 0.0; out[0][i] = out[1][i] = 0.0;
} }
} }
} else { } else {
//ERROR ("avail_data=%d, no play (pid=%d)!\n", avail_data, getpid ()); //ERROR ("avail_data=%d, no play (pid=%d)!\n", avail_data, getpid ());
for (i = 0; i < nframes; i++) for (i = 0; i < nframes; i++)
out[0][i] = out[1][i] = 0.0; out[0][i] = out[1][i] = 0.0;
} } */
/*ERROR("process (pid=%d)\n", getpid());*/ /*ERROR("process (pid=%d)\n", getpid());*/
return 0; return 0;
@ -358,7 +385,7 @@ static void jack_closeDevice(AudioOutput * audioOutput)
{ {
/*jack_finishDriver(audioOutput);*/ /*jack_finishDriver(audioOutput);*/
audioOutput->open = 0; audioOutput->open = 0;
ERROR("jack_closeDevice (pid=%d)!\n", getpid()); ERROR("jack_closeDevice (pid=%d)\n", getpid());
} }
static void jack_dropBufferedAudio (AudioOutput * audioOutput) static void jack_dropBufferedAudio (AudioOutput * audioOutput)
@ -375,6 +402,8 @@ static int jack_playAudio(AudioOutput * audioOutput, char *buff, int size)
int i; int i;
short *buffer = (short *) buff; short *buffer = (short *) buff;
ERROR("jack_playAudio: (pid=%d)!\n", getpid());
if ( jd->shutdown ) { if ( jd->shutdown ) {
ERROR("Refusing to play, because there is no client thread.\n"); ERROR("Refusing to play, because there is no client thread.\n");
freeJackData(audioOutput); freeJackData(audioOutput);
@ -382,49 +411,60 @@ static int jack_playAudio(AudioOutput * audioOutput, char *buff, int size)
return 0; return 0;
} }
if ( jd->our_xrun ) { /*jd->can_process=0;*/
ERROR("xrun\n"); /* if ( jd->our_xrun ) { */
jd->our_xrun = 0; /* ERROR("xrun\n"); */
} /* jd->our_xrun = 0; */
/* } */
/*ERROR("jack_playAudio: size=%d\n", size/4);*/ /*ERROR("jack_playAudio: size=%d\n", size/4);*/
/*ERROR("jack_playAudio - INICIO\n");*/ /*ERROR("jack_playAudio - INICIO\n");*/
if ( ! jd->samples1 ) { if ( ! jd->samples1 ) {
ERROR("jd->samples1=xmalloc\n"); ERROR("jd->samples1=xmalloc\n");
jd->samples1 = (jack_default_audio_sample_t *)xmalloc(size); jd->samples1 = (jack_default_audio_sample_t *)
xmalloc(size*sizeof(jack_default_audio_sample_t));
} }
if ( ! jd->samples2 ) { if ( ! jd->samples2 ) {
ERROR("jd->samples2=xmalloc\n"); ERROR("jd->samples2=xmalloc\n");
jd->samples2 = (jack_default_audio_sample_t *)xmalloc(size); jd->samples2 = (jack_default_audio_sample_t *)
xmalloc(size*sizeof(jack_default_audio_sample_t));
} }
/* primero convierto todo el buffer al formato que usa jack */ /* primero convierto todo el buffer al formato que usa jack */
for (i=0; i<size/4; i++) { for (i=0; i<size; i++) {
*(jd->samples1 + i) = *(jd->samples1 + i) =
(jack_default_audio_sample_t) *(buffer++) / 32768; (jack_default_audio_sample_t) *(buffer++) / 32768;
*(jd->samples2 + i) = *(jd->samples2 + i) =
(jack_default_audio_sample_t) *(buffer++) / 32768; (jack_default_audio_sample_t) *(buffer++) / 32768;
/*
*(jd->samples1 + i) =
(jack_default_audio_sample_t) *(buff + i) / 32768;
*(jd->samples2 + i) =
(jack_default_audio_sample_t) *(buff + i) / 32768;
*/
} }
samples1=(char *)jd->samples1; samples1 = (char *)jd->samples1;
samples2=(char *)jd->samples2; samples2 = (char *)jd->samples2;
while ( size && !jd->shutdown ) { while ( size && !jd->shutdown ) {
if ( (space = jack_ringbuffer_write_space(jd->ringbuffer[0])) > if ( (space = jack_ringbuffer_write_space(jd->ringbuffer[0]))
sizeof(jack_default_audio_sample_t) ) { >= size ) {
/*ERROR("\t size=%d space=%d\n", size, space);*/ /*ERROR("\t size=%d space=%d\n", size, space);*/
space = MIN(space, size); space = MIN(space, size);
jack_ringbuffer_write(jd->ringbuffer[0],samples1,space); jack_ringbuffer_write(jd->ringbuffer[0],samples1,space);
jack_ringbuffer_write(jd->ringbuffer[1],samples2,space); jack_ringbuffer_write(jd->ringbuffer[1],samples2,space);
size -= space; size -= space;
samples1 += space; samples1 += space;
samples2 += space; samples2 += space;
} else { } else {
/*ERROR("\t space=%d\n", space);*/ /* ERROR("\t space=%d\n", space); */
usleep(3*(ringbuf_sz-space)/((float)(jd->bps)) /* ERROR("\t size=%d\n", size); */
* 1000000.0); usleep((unsigned long)
} ((size-space)/jd->bps) * 1000000.0);
} }
}
/* jd->can_process=1; */
/*ERROR("jack_playAudio - FIN\n");*/ /*ERROR("jack_playAudio - FIN\n");*/