mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-08 13:29:59 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

simplify handling of rewrite requests

Browse source
This commit is contained in:
Lennart Poettering 2008-06-27 21:58:39 +02:00
parent 89620d3f00
commit 0fb402c8d4
1 changed files with 3 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

15
src/modules/module-pipe-sink.c
View file

@ -116,13 +116,6 @@ static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offse
return pa_sink_process_msg(o, code, data, offset, chunk); return pa_sink_process_msg(o, code, data, offset, chunk);
} }
static void process_rewind(struct userdata *u) {
pa_assert(u);
pa_log_debug("Rewind requested but not supported by pipe sink. Ignoring.");
u->sink->thread_info.rewind_nbytes = 0;
}
static int process_render(struct userdata *u) { static int process_render(struct userdata *u) {
pa_assert(u); pa_assert(u);
@ -182,14 +175,10 @@ static void thread_func(void *userdata) {
pollfd = pa_rtpoll_item_get_pollfd(u->rtpoll_item, NULL); pollfd = pa_rtpoll_item_get_pollfd(u->rtpoll_item, NULL);
/* Render some data and write it to the fifo */ /* Render some data and write it to the fifo */
if (u->sink->thread_info.state == PA_SINK_RUNNING) { if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) {
if (u->sink->thread_info.rewind_requested) { if (u->sink->thread_info.rewind_requested)
if (u->sink->thread_info.rewind_nbytes > 0)
process_rewind(u);
else
pa_sink_process_rewind(u->sink, 0); pa_sink_process_rewind(u->sink, 0);
}
if (pollfd->revents) { if (pollfd->revents) {
if (process_render(u) < 0) if (process_render(u) < 0)