mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-29 05:40:27 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

alsa: reduce start latency

Browse source
This commit is contained in:
Wim Taymans 2018-11-19 12:01:36 +01:00
parent 27451e4350
commit 7e9b223216
3 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
spa/plugins/alsa/alsa-sink.c
View file

@ -668,7 +668,7 @@ static int impl_node_process(struct spa_node *node)
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_OUT);
input->buffer_id = SPA_ID_INVALID;
spa_alsa_write(this, 0);
spa_alsa_write(this, 0, true);
input->status = SPA_STATUS_OK;
}

10
spa/plugins/alsa/alsa-utils.c
View file

@ -534,7 +534,7 @@ again:
} else {
state->alsa_started = false;
}
spa_alsa_write(state, state->threshold * 2);
spa_alsa_write(state, state->threshold * 2, true);
goto again;
}
@ -614,7 +614,7 @@ static int update_time(struct state *state, uint64_t nsec, snd_pcm_sframes_t del
return 0;
}
int spa_alsa_write(struct state *state, snd_pcm_uframes_t silence)
int spa_alsa_write(struct state *state, snd_pcm_uframes_t silence, bool start)
{
snd_pcm_t *hndl = state->hndl;
const snd_pcm_channel_area_t *my_areas;
@ -725,7 +725,7 @@ again:
state->sample_count += total_written;
if (!state->alsa_started && written > 0) {
if (!state->alsa_started && written > 0 && start) {
spa_log_trace(state->log, "snd_pcm_start %lu", written);
if ((res = snd_pcm_start(hndl)) < 0) {
spa_log_error(state->log, "snd_pcm_start: %s", snd_strerror(res));
@ -836,7 +836,7 @@ static void alsa_on_playback_timeout_event(struct spa_source *source)
state->callbacks->process(state->callbacks_data, SPA_STATUS_NEED_BUFFER);
}
else {
spa_alsa_write(state, 0);
spa_alsa_write(state, 0, true);
}
next:
set_timeout(state, state->next_time);
@ -946,7 +946,7 @@ int spa_alsa_start(struct state *state)
if (state->stream == SND_PCM_STREAM_PLAYBACK) {
state->alsa_started = false;
spa_alsa_write(state, state->threshold * 2);
spa_alsa_write(state, state->threshold, false);
} else {
if ((err = snd_pcm_start(state->hndl)) < 0) {
spa_log_error(state->log, "snd_pcm_start: %s", snd_strerror(err));

2
spa/plugins/alsa/alsa-utils.h
View file

@ -154,7 +154,7 @@ int spa_alsa_start(struct state *state);
int spa_alsa_pause(struct state *state);
int spa_alsa_close(struct state *state);
int spa_alsa_write(struct state *state, snd_pcm_uframes_t silence);
int spa_alsa_write(struct state *state, snd_pcm_uframes_t silence, bool start);
static inline void dll_bandwidth(struct dll *dll, double bandwidth)