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

echo-cancel: flush streams in PAUSED

Browse source 
so that we don't end up with old data when we resume.

Fixes #1660
This commit is contained in:
Wim Taymans 2021-10-14 12:18:37 +02:00
parent 12567ea5d8
commit 257bbb1fd5
1 changed files with 32 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

32
src/modules/module-echo-cancel.c
View file

@ -391,6 +391,20 @@ static void capture_process(void *data)
pw_stream_queue_buffer(impl->capture, buf); pw_stream_queue_buffer(impl->capture, buf);
} }
static void input_state_changed(void *data, enum pw_stream_state old,
enum pw_stream_state state, const char *error)
{
struct impl *impl = data;
switch (state) {
case PW_STREAM_STATE_PAUSED:
pw_stream_flush(impl->source, false);
pw_stream_flush(impl->capture, false);
break;
default:
break;
}
}
static void input_param_latency_changed(struct impl *impl, const struct spa_pod *param) static void input_param_latency_changed(struct impl *impl, const struct spa_pod *param)
{ {
struct spa_latency_info latency; struct spa_latency_info latency;
@ -423,6 +437,7 @@ static void input_param_changed(void *data, uint32_t id, const struct spa_pod *p
static const struct pw_stream_events capture_events = { static const struct pw_stream_events capture_events = {
PW_VERSION_STREAM_EVENTS, PW_VERSION_STREAM_EVENTS,
.destroy = capture_destroy, .destroy = capture_destroy,
.state_changed = input_state_changed,
.io_changed = capture_io_changed, .io_changed = capture_io_changed,
.process = capture_process, .process = capture_process,
.param_changed = input_param_changed .param_changed = input_param_changed
@ -438,9 +453,24 @@ static void source_destroy(void *d)
static const struct pw_stream_events source_events = { static const struct pw_stream_events source_events = {
PW_VERSION_STREAM_EVENTS, PW_VERSION_STREAM_EVENTS,
.destroy = source_destroy, .destroy = source_destroy,
.state_changed = input_state_changed,
.param_changed = input_param_changed .param_changed = input_param_changed
}; };
static void output_state_changed(void *data, enum pw_stream_state old,
enum pw_stream_state state, const char *error)
{
struct impl *impl = data;
switch (state) {
case PW_STREAM_STATE_PAUSED:
pw_stream_flush(impl->sink, false);
pw_stream_flush(impl->playback, false);
break;
default:
break;
}
}
static void output_param_latency_changed(struct impl *impl, const struct spa_pod *param) static void output_param_latency_changed(struct impl *impl, const struct spa_pod *param)
{ {
struct spa_latency_info latency; struct spa_latency_info latency;
@ -553,6 +583,7 @@ static void playback_destroy(void *d)
static const struct pw_stream_events playback_events = { static const struct pw_stream_events playback_events = {
PW_VERSION_STREAM_EVENTS, PW_VERSION_STREAM_EVENTS,
.destroy = playback_destroy, .destroy = playback_destroy,
.state_changed = output_state_changed,
.param_changed = output_param_changed .param_changed = output_param_changed
}; };
static const struct pw_stream_events sink_events = { static const struct pw_stream_events sink_events = {
@ -560,6 +591,7 @@ static const struct pw_stream_events sink_events = {
.destroy = sink_destroy, .destroy = sink_destroy,
.io_changed = sink_io_changed, .io_changed = sink_io_changed,
.process = sink_process, .process = sink_process,
.state_changed = output_state_changed,
.param_changed = output_param_changed .param_changed = output_param_changed
}; };