diff options
author | Lennart Poettering <lennart@poettering.net> | 2008-06-26 00:39:31 +0200 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2008-06-26 00:39:31 +0200 |
commit | 1514d138353f04578d885d9cb18c528d9b562a83 (patch) | |
tree | b67e6debab81ad4515f41fdcb2b7691509c1fdae /src/pulsecore/protocol-native.c | |
parent | 5fccac94e737a760c12fb82e5cd4a82362c17a24 (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/pulsecore/protocol-native.c')
-rw-r--r-- | src/pulsecore/protocol-native.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/pulsecore/protocol-native.c b/src/pulsecore/protocol-native.c index 923a5665..862b062e 100644 --- a/src/pulsecore/protocol-native.c +++ b/src/pulsecore/protocol-native.c @@ -1196,7 +1196,7 @@ static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int switch (code) { case SINK_INPUT_MESSAGE_FLUSH: - func = pa_memblockq_flush; + func = pa_memblockq_flush_write; break; case SINK_INPUT_MESSAGE_PREBUF_FORCE: @@ -3072,7 +3072,7 @@ static void command_flush_record_stream(PA_GCC_UNUSED pa_pdispatch *pd, PA_GCC_U s = pa_idxset_get_by_index(c->record_streams, idx); CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); - pa_memblockq_flush(s->memblockq); + pa_memblockq_flush_read(s->memblockq); pa_pstream_send_simple_ack(c->pstream, tag); } |