diff options
Diffstat (limited to 'src/modules')
| -rw-r--r-- | src/modules/module-combine.c | 4 | ||||
| -rw-r--r-- | src/modules/module-loopback.c | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/modules/module-combine.c b/src/modules/module-combine.c index 62e62679..cffb901b 100644 --- a/src/modules/module-combine.c +++ b/src/modules/module-combine.c @@ -562,7 +562,7 @@ static int sink_input_process_msg(pa_msgobject *obj, int code, void *data, int64 if (PA_SINK_IS_OPENED(o->sink_input->sink->thread_info.state)) pa_memblockq_push_align(o->memblockq, chunk); else - pa_memblockq_flush_write(o->memblockq); + pa_memblockq_flush_write(o->memblockq, TRUE); return 0; } @@ -982,7 +982,7 @@ static void output_disable(struct output *o) { o->sink_input = NULL; /* Finally, drop all queued data */ - pa_memblockq_flush_write(o->memblockq); + pa_memblockq_flush_write(o->memblockq, TRUE); pa_asyncmsgq_flush(o->inq, FALSE); pa_asyncmsgq_flush(o->outq, FALSE); } diff --git a/src/modules/module-loopback.c b/src/modules/module-loopback.c index bb0182b0..15ef96ef 100644 --- a/src/modules/module-loopback.c +++ b/src/modules/module-loopback.c @@ -430,7 +430,7 @@ static int sink_input_process_msg_cb(pa_msgobject *obj, int code, void *data, in if (PA_SINK_IS_OPENED(u->sink_input->sink->thread_info.state)) pa_memblockq_push_align(u->memblockq, chunk); else - pa_memblockq_flush_write(u->memblockq); + pa_memblockq_flush_write(u->memblockq, TRUE); update_min_memblockq_length(u); @@ -457,7 +457,7 @@ static int sink_input_process_msg_cb(pa_msgobject *obj, int code, void *data, in if (PA_SINK_IS_OPENED(u->sink_input->sink->thread_info.state)) pa_memblockq_seek(u->memblockq, -offset, PA_SEEK_RELATIVE, TRUE); else - pa_memblockq_flush_write(u->memblockq); + pa_memblockq_flush_write(u->memblockq, TRUE); u->recv_counter -= offset; |