mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-03 09:01:50 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Revert "core: adjust playing_for and underrun_for at rewind"

Browse source 
This reverts commit 5bc6cadcb2.

I wasn't meaning to push this out - just merged for review / testing.
This commit is contained in:
Arun Raghavan 2012-11-03 10:29:20 +01:00
parent 5bc6cadcb2
commit eeab4efa98
1 changed files with 4 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/pulsecore/sink-input.c
View file

@ -970,15 +970,6 @@ void pa_sink_input_drop(pa_sink_input *i, size_t nbytes /* in sink sample spec *
pa_memblockq_drop(i->thread_info.render_memblockq, nbytes); pa_memblockq_drop(i->thread_info.render_memblockq, nbytes);
} }
static void subtract_helper(size_t *p, size_t amount)
{
if (*p == (size_t) -1)
return;
if (*p < amount)
*p = 0;
*p -= amount;
}
/* Called from thread context */ /* Called from thread context */
void pa_sink_input_process_rewind(pa_sink_input *i, size_t nbytes /* in sink sample spec */) { void pa_sink_input_process_rewind(pa_sink_input *i, size_t nbytes /* in sink sample spec */) {
size_t lbq; size_t lbq;
@ -1005,12 +996,8 @@ void pa_sink_input_process_rewind(pa_sink_input *i, size_t nbytes /* in sink sam
/* We were asked to drop all buffered data, and rerequest new /* We were asked to drop all buffered data, and rerequest new
* data from implementor the next time peek() is called */ * data from implementor the next time peek() is called */
size_t s = pa_memblockq_get_length(i->thread_info.render_memblockq);
if (i->thread_info.resampler)
s = pa_resampler_request(i->thread_info.resampler, s);
pa_memblockq_flush_write(i->thread_info.render_memblockq, TRUE); pa_memblockq_flush_write(i->thread_info.render_memblockq, TRUE);
subtract_helper(&i->thread_info.underrun_for, s);
subtract_helper(&i->thread_info.playing_for, s);
} else if (i->thread_info.rewrite_nbytes > 0) { } else if (i->thread_info.rewrite_nbytes > 0) {
size_t max_rewrite, amount; size_t max_rewrite, amount;
@ -1025,8 +1012,6 @@ void pa_sink_input_process_rewind(pa_sink_input *i, size_t nbytes /* in sink sam
amount = PA_MIN(i->thread_info.rewrite_nbytes, max_rewrite); amount = PA_MIN(i->thread_info.rewrite_nbytes, max_rewrite);
if (amount > 0) { if (amount > 0) {
size_t samount = amount;
pa_log_debug("Have to rewind %lu bytes on implementor.", (unsigned long) amount); pa_log_debug("Have to rewind %lu bytes on implementor.", (unsigned long) amount);
/* Tell the implementor */ /* Tell the implementor */
@ -1036,14 +1021,11 @@ void pa_sink_input_process_rewind(pa_sink_input *i, size_t nbytes /* in sink sam
/* Convert back to to sink domain */ /* Convert back to to sink domain */
if (i->thread_info.resampler) if (i->thread_info.resampler)
samount = pa_resampler_result(i->thread_info.resampler, amount); amount = pa_resampler_result(i->thread_info.resampler, amount);
if (samount > 0) { if (amount > 0)
/* Ok, now update the write pointer */ /* Ok, now update the write pointer */
pa_memblockq_seek(i->thread_info.render_memblockq, - ((int64_t) samount), PA_SEEK_RELATIVE, TRUE); pa_memblockq_seek(i->thread_info.render_memblockq, - ((int64_t) amount), PA_SEEK_RELATIVE, TRUE);
subtract_helper(&i->thread_info.underrun_for, amount);
subtract_helper(&i->thread_info.playing_for, amount);
}
if (i->thread_info.rewrite_flush) if (i->thread_info.rewrite_flush)
pa_memblockq_silence(i->thread_info.render_memblockq); pa_memblockq_silence(i->thread_info.render_memblockq);