mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-05 13:30:02 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

jack: implement tee

Browse source
This commit is contained in:
Wim Taymans 2018-07-17 17:40:07 +02:00
parent 63cc6e920f
commit ac11392fad
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/pipewire-jack.c
View file

@ -2095,6 +2095,7 @@ void * jack_port_get_buffer (jack_port_t *port, jack_nframes_t frames)
add_f32(ptr, b->datas[0].data, frames); add_f32(ptr, b->datas[0].data, frames);
} }
} else { } else {
b = NULL;
spa_list_for_each(mix, &p->mix, port_link) { spa_list_for_each(mix, &p->mix, port_link) {
pw_log_trace("port %p: mix %d.%d get buffer %d", pw_log_trace("port %p: mix %d.%d get buffer %d",
p, p->id, mix->id, frames); p, p->id, mix->id, frames);
@ -2103,22 +2104,28 @@ void * jack_port_get_buffer (jack_port_t *port, jack_nframes_t frames)
if (mix->n_buffers == 0 || io == NULL) if (mix->n_buffers == 0 || io == NULL)
continue; continue;
io->status = SPA_STATUS_HAVE_BUFFER;
if ((b = dequeue_buffer(mix)) == NULL) { if ((b = dequeue_buffer(mix)) == NULL) {
pw_log_warn("port %p: out of buffers", p); pw_log_warn("port %p: out of buffers", p);
io->buffer_id = SPA_ID_INVALID; io->buffer_id = SPA_ID_INVALID;
goto done; goto done;
} }
reuse_buffer(c, mix, b->id); reuse_buffer(c, mix, b->id);
io->buffer_id = b->id;
ptr = b->datas[0].data; ptr = b->datas[0].data;
b->datas[0].chunk->offset = 0; b->datas[0].chunk->offset = 0;
b->datas[0].chunk->size = frames * sizeof(float); b->datas[0].chunk->size = frames * sizeof(float);
b->datas[0].chunk->stride = sizeof(float); b->datas[0].chunk->stride = sizeof(float);
io->status = SPA_STATUS_HAVE_BUFFER;
io->buffer_id = b->id;
break; break;
} }
spa_list_for_each(mix, &p->mix, port_link) {
struct spa_io_buffers *mio = mix->io;
if (mio == NULL)
continue;
*mio = *io;
}
} }
done: done: