OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2012 Google Inc. All rights reserved. | 2 * Copyright (C) 2012 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * | 7 * |
8 * 1. Redistributions of source code must retain the above copyright | 8 * 1. Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * 2. Redistributions in binary form must reproduce the above copyright | 10 * 2. Redistributions in binary form must reproduce the above copyright |
(...skipping 12 matching lines...) Expand all Loading... |
23 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | 23 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
24 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | 24 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF | 25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
27 */ | 27 */ |
28 | 28 |
29 #include "platform/audio/AudioPullFIFO.h" | 29 #include "platform/audio/AudioPullFIFO.h" |
30 | 30 |
31 namespace blink { | 31 namespace blink { |
32 | 32 |
33 AudioPullFIFO::AudioPullFIFO(AudioSourceProvider& audioProvider, unsigned number
OfChannels, size_t fifoLength, size_t providerSize) | 33 AudioPullFIFO::AudioPullFIFO(unsigned numberOfChannels, size_t fifoBufferLength,
AudioSourceProvider& provider, size_t providerRenderBlockSize) |
34 : m_provider(audioProvider) | 34 : m_providerRenderBlockSize(providerRenderBlockSize) |
35 , m_fifo(numberOfChannels, fifoLength) | 35 , m_provider(provider) |
36 , m_providerSize(providerSize) | 36 , m_tempBus(AudioBus::create(numberOfChannels, providerRenderBlockSize)) |
37 , m_tempBus(AudioBus::create(numberOfChannels, providerSize)) | 37 , m_fifo(numberOfChannels, fifoBufferLength) |
38 { | 38 { |
39 } | 39 } |
40 | 40 |
41 void AudioPullFIFO::consume(AudioBus* destination, size_t framesToConsume) | 41 void AudioPullFIFO::consume(AudioBus* destination, size_t framesToConsume) |
42 { | 42 { |
43 if (!destination) | 43 if (!destination) |
44 return; | 44 return; |
45 | 45 |
46 if (framesToConsume > m_fifo.framesInFifo()) { | 46 // Not enough data in the FIFO to fulfill the request. Ask for more data. |
47 // We don't have enough data in the FIFO to fulfill the request. Ask for
more data. | 47 if (framesToConsume > m_fifo.framesInFifo()) |
48 fillBuffer(framesToConsume - m_fifo.framesInFifo()); | 48 requestDataFromProvider(framesToConsume - m_fifo.framesInFifo()); |
49 } | |
50 | 49 |
51 m_fifo.consume(destination, framesToConsume); | 50 m_fifo.consume(destination, framesToConsume); |
52 } | 51 } |
53 | 52 |
54 void AudioPullFIFO::fillBuffer(size_t numberOfFrames) | 53 void AudioPullFIFO::requestDataFromProvider(size_t numberOfFrames) |
55 { | 54 { |
56 // Keep asking the provider to give us data until we have received at least
|numberOfFrames| of | 55 // Keep pulling the provider for more data until we have received at least |
57 // data. Stuff the data into the FIFO. | 56 // |numberOfFrames| of data. Fill the data into the FIFO. |
58 size_t framesProvided = 0; | 57 size_t framesProvided = 0; |
59 | 58 |
60 while (framesProvided < numberOfFrames) { | 59 while (framesProvided < numberOfFrames) { |
61 m_provider.provideInput(m_tempBus.get(), m_providerSize); | 60 m_provider.provideInput(m_tempBus.get(), m_providerRenderBlockSize); |
62 | |
63 m_fifo.push(m_tempBus.get()); | 61 m_fifo.push(m_tempBus.get()); |
64 | 62 framesProvided += m_providerRenderBlockSize; |
65 framesProvided += m_providerSize; | |
66 } | 63 } |
67 } | 64 } |
68 | 65 |
69 } // namespace blink | 66 } // namespace blink |
70 | 67 |
OLD | NEW |