OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2010 Google Inc. All rights reserved. | 2 * Copyright (C) 2010 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 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
63 const WebAudioLatencyHint& latencyHint, | 63 const WebAudioLatencyHint& latencyHint, |
64 PassRefPtr<SecurityOrigin> securityOrigin) | 64 PassRefPtr<SecurityOrigin> securityOrigin) |
65 : m_numberOfOutputChannels(numberOfOutputChannels), | 65 : m_numberOfOutputChannels(numberOfOutputChannels), |
66 m_isPlaying(false), | 66 m_isPlaying(false), |
67 m_callback(callback), | 67 m_callback(callback), |
68 m_outputBus(AudioBus::create(numberOfOutputChannels, | 68 m_outputBus(AudioBus::create(numberOfOutputChannels, |
69 AudioUtilities::kRenderQuantumFrames, | 69 AudioUtilities::kRenderQuantumFrames, |
70 false)), | 70 false)), |
71 m_renderBus(AudioBus::create(numberOfOutputChannels, | 71 m_renderBus(AudioBus::create(numberOfOutputChannels, |
72 AudioUtilities::kRenderQuantumFrames)), | 72 AudioUtilities::kRenderQuantumFrames)), |
| 73 m_fifo( |
| 74 WTF::wrapUnique(new PushPullFIFO(numberOfOutputChannels, kFIFOSize))), |
73 m_framesElapsed(0) { | 75 m_framesElapsed(0) { |
| 76 m_callbackBufferSize = hardwareBufferSize(); |
| 77 if (!checkBufferSize()) { |
| 78 NOTREACHED(); |
| 79 } |
| 80 |
74 // Create WebAudioDevice. blink::WebAudioDevice is designed to support the | 81 // Create WebAudioDevice. blink::WebAudioDevice is designed to support the |
75 // local input (e.g. loopback from OS audio system), but Chromium's media | 82 // local input (e.g. loopback from OS audio system), but Chromium's media |
76 // renderer does not support it currently. Thus, we use zero for the number | 83 // renderer does not support it currently. Thus, we use zero for the number |
77 // of input channels. | 84 // of input channels. |
78 m_webAudioDevice = WTF::wrapUnique(Platform::current()->createAudioDevice( | 85 m_webAudioDevice = WTF::wrapUnique(Platform::current()->createAudioDevice( |
79 0, numberOfOutputChannels, latencyHint, this, String(), | 86 0, numberOfOutputChannels, latencyHint, this, String(), |
80 std::move(securityOrigin))); | 87 std::move(securityOrigin))); |
81 DCHECK(m_webAudioDevice); | 88 DCHECK(m_webAudioDevice); |
82 | |
83 m_callbackBufferSize = m_webAudioDevice->framesPerBuffer(); | |
84 | |
85 if (!checkBufferSize()) { | |
86 NOTREACHED(); | |
87 } | |
88 | |
89 // Create a FIFO. | |
90 m_fifo = WTF::wrapUnique(new PushPullFIFO(numberOfOutputChannels, kFIFOSize)); | |
91 } | 89 } |
92 | 90 |
93 AudioDestination::~AudioDestination() { | 91 AudioDestination::~AudioDestination() { |
94 stop(); | 92 stop(); |
95 } | 93 } |
96 | 94 |
97 void AudioDestination::render(const WebVector<float*>& destinationData, | 95 void AudioDestination::render(const WebVector<float*>& destinationData, |
98 size_t numberOfFrames, | 96 size_t numberOfFrames, |
99 double delay, | 97 double delay, |
100 double delayTimestamp, | 98 double delayTimestamp, |
101 size_t priorFramesSkipped) { | 99 size_t priorFramesSkipped) { |
102 CHECK_EQ(destinationData.size(), m_numberOfOutputChannels); | 100 CHECK_EQ(destinationData.size(), m_numberOfOutputChannels); |
103 CHECK_EQ(numberOfFrames, m_callbackBufferSize); | 101 CHECK_EQ(numberOfFrames, m_callbackBufferSize); |
104 | 102 |
| 103 // Note that this method is called by AudioDeviceThread. If FIFO is not ready, |
| 104 // or the requested render size is greater than FIFO size return here. |
| 105 // (crbug.com/692423) |
| 106 if (!m_fifo || m_fifo->length() < numberOfFrames) |
| 107 return; |
| 108 |
105 m_framesElapsed -= std::min(m_framesElapsed, priorFramesSkipped); | 109 m_framesElapsed -= std::min(m_framesElapsed, priorFramesSkipped); |
106 double outputPosition = | 110 double outputPosition = |
107 m_framesElapsed / static_cast<double>(m_webAudioDevice->sampleRate()) - | 111 m_framesElapsed / static_cast<double>(m_webAudioDevice->sampleRate()) - |
108 delay; | 112 delay; |
109 m_outputPosition.position = outputPosition; | 113 m_outputPosition.position = outputPosition; |
110 m_outputPosition.timestamp = delayTimestamp; | 114 m_outputPosition.timestamp = delayTimestamp; |
111 m_outputPositionReceivedTimestamp = base::TimeTicks::Now(); | 115 m_outputPositionReceivedTimestamp = base::TimeTicks::Now(); |
112 | 116 |
113 // Associate the destination data array with the output bus then fill the | 117 // Associate the destination data array with the output bus then fill the |
114 // FIFO. | 118 // FIFO. |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
194 callbackBufferSizeHistogram.sample(m_callbackBufferSize); | 198 callbackBufferSizeHistogram.sample(m_callbackBufferSize); |
195 | 199 |
196 // Check if the requested buffer size is too large. | 200 // Check if the requested buffer size is too large. |
197 bool isBufferSizeValid = | 201 bool isBufferSizeValid = |
198 m_callbackBufferSize + AudioUtilities::kRenderQuantumFrames <= kFIFOSize; | 202 m_callbackBufferSize + AudioUtilities::kRenderQuantumFrames <= kFIFOSize; |
199 DCHECK(isBufferSizeValid); | 203 DCHECK(isBufferSizeValid); |
200 return isBufferSizeValid; | 204 return isBufferSizeValid; |
201 } | 205 } |
202 | 206 |
203 } // namespace blink | 207 } // namespace blink |
OLD | NEW |