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

jack: call thread_init

Browse source
This commit is contained in:
Wim Taymans 2019-09-03 13:45:13 +02:00
parent 46b2d1701b
commit a9640a826d
1 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/pipewire-jack.c
View file

@ -291,6 +291,7 @@ struct client {
unsigned int started:1; unsigned int started:1;
unsigned int active:1; unsigned int active:1;
unsigned int destroyed:1; unsigned int destroyed:1;
unsigned int first:1;
jack_position_t jack_position; jack_position_t jack_position;
jack_transport_state_t jack_state; jack_transport_state_t jack_state;
@ -834,6 +835,12 @@ static inline uint32_t cycle_wait(struct client *c)
if (wait_sync(c) < 0) if (wait_sync(c) < 0)
return 0; return 0;
if (c->first) {
if (c->thread_init_callback)
c->thread_init_callback(c->thread_init_arg);
c->first = false;
}
buffer_size = pos->clock.duration; buffer_size = pos->clock.duration;
if (buffer_size != c->buffer_size) { if (buffer_size != c->buffer_size) {
pw_log_info(NAME" %p: buffersize %d", c, buffer_size); pw_log_info(NAME" %p: buffersize %d", c, buffer_size);
@ -944,6 +951,10 @@ on_rtsocket_condition(void *data, int fd, uint32_t mask)
unhandle_socket(c); unhandle_socket(c);
return; return;
} }
if (c->thread_callback) {
c->thread_callback(c->thread_arg);
return;
}
if (mask & SPA_IO_IN) { if (mask & SPA_IO_IN) {
uint32_t buffer_size; uint32_t buffer_size;
@ -1102,6 +1113,7 @@ static int client_node_command(void *object, const struct spa_command *command)
c->socket_source, c->socket_source,
SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP); SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP);
c->started = true; c->started = true;
c->first = true;
} }
break; break;
default: default: