summaryrefslogtreecommitdiffstats
path: root/src/modules/module-combine.c
diff options
context:
space:
mode:
authorLennart Poettering <lennart@poettering.net>2008-06-26 00:39:31 +0200
committerLennart Poettering <lennart@poettering.net>2008-06-26 00:39:31 +0200
commit1514d138353f04578d885d9cb18c528d9b562a83 (patch)
treeb67e6debab81ad4515f41fdcb2b7691509c1fdae /src/modules/module-combine.c
parent5fccac94e737a760c12fb82e5cd4a82362c17a24 (diff)
split pa_memblockq_flush() into two flush commands, one which fixes up the read ptr, and one which fixes up the write ptr
Diffstat (limited to 'src/modules/module-combine.c')
-rw-r--r--src/modules/module-combine.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/modules/module-combine.c b/src/modules/module-combine.c
index cef7a99a..8c155da0 100644
--- a/src/modules/module-combine.c
+++ b/src/modules/module-combine.c
@@ -525,7 +525,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(o->memblockq);
+ pa_memblockq_flush_write(o->memblockq);
return 0;
}
@@ -555,7 +555,7 @@ static void enable_output(struct output *o) {
if (output_create_sink_input(o) >= 0) {
- pa_memblockq_flush(o->memblockq);
+ pa_memblockq_flush_write(o->memblockq);
pa_sink_input_put(o->sink_input);