Non-unified build fixes, late September 2020 edition
[WebKit-https.git] / Source / WebCore / Modules / webaudio / AudioNodeOutput.cpp
1 /*
2  * Copyright (C) 2010, Google Inc. All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  * 1.  Redistributions of source code must retain the above copyright
8  *    notice, this list of conditions and the following disclaimer.
9  * 2.  Redistributions in binary form must reproduce the above copyright
10  *    notice, this list of conditions and the following disclaimer in the
11  *    documentation and/or other materials provided with the distribution.
12  *
13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' AND ANY
14  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
15  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
16  * DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY
17  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
18  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
19  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
20  * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
21  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
22  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
23  */
24
25 #include "config.h"
26
27 #if ENABLE(WEB_AUDIO)
28
29 #include "AudioNodeOutput.h"
30
31 #include "AudioBus.h"
32 #include "AudioContext.h"
33 #include "AudioNodeInput.h"
34 #include "AudioParam.h"
35 #include "AudioUtilities.h"
36 #include <wtf/Threading.h>
37
38 namespace WebCore {
39
40 AudioNodeOutput::AudioNodeOutput(AudioNode* node, unsigned numberOfChannels)
41     : m_node(node)
42     , m_numberOfChannels(numberOfChannels)
43     , m_desiredNumberOfChannels(numberOfChannels)
44 {
45     ASSERT(numberOfChannels <= AudioContext::maxNumberOfChannels());
46
47     m_internalBus = AudioBus::create(numberOfChannels, AudioUtilities::renderQuantumSize);
48 }
49
50 void AudioNodeOutput::setNumberOfChannels(unsigned numberOfChannels)
51 {
52     ASSERT(numberOfChannels <= AudioContext::maxNumberOfChannels());
53     ASSERT(context().isGraphOwner());
54
55     m_desiredNumberOfChannels = numberOfChannels;
56
57     if (context().isAudioThread()) {
58         // If we're in the audio thread then we can take care of it right away (we should be at the very start or end of a rendering quantum).
59         updateNumberOfChannels();
60     } else {
61         // Let the context take care of it in the audio thread in the pre and post render tasks.
62         context().markAudioNodeOutputDirty(this);
63     }
64 }
65
66 void AudioNodeOutput::updateInternalBus()
67 {
68     if (numberOfChannels() == m_internalBus->numberOfChannels())
69         return;
70
71     m_internalBus = AudioBus::create(numberOfChannels(), AudioUtilities::renderQuantumSize);
72 }
73
74 void AudioNodeOutput::updateRenderingState()
75 {
76     updateNumberOfChannels();
77     m_renderingFanOutCount = fanOutCount();
78     m_renderingParamFanOutCount = paramFanOutCount();
79 }
80
81 void AudioNodeOutput::updateNumberOfChannels()
82 {
83     ASSERT(context().isAudioThread() && context().isGraphOwner());
84
85     if (m_numberOfChannels != m_desiredNumberOfChannels) {
86         m_numberOfChannels = m_desiredNumberOfChannels;
87         updateInternalBus();
88         propagateChannelCount();
89     }
90 }
91
92 void AudioNodeOutput::propagateChannelCount()
93 {
94     ASSERT(context().isAudioThread() && context().isGraphOwner());
95     
96     if (isChannelCountKnown()) {
97         // Announce to any nodes we're connected to that we changed our channel count for its input.
98         for (auto& input : m_inputs) {
99             AudioNode* connectionNode = input->node();
100             connectionNode->checkNumberOfChannelsForInput(input);
101         }
102     }
103 }
104
105 AudioBus* AudioNodeOutput::pull(AudioBus* inPlaceBus, size_t framesToProcess)
106 {
107     ASSERT(context().isAudioThread());
108     ASSERT(m_renderingFanOutCount > 0 || m_renderingParamFanOutCount > 0);
109     
110     // Causes our AudioNode to process if it hasn't already for this render quantum.
111     // We try to do in-place processing (using inPlaceBus) if at all possible,
112     // but we can't process in-place if we're connected to more than one input (fan-out > 1).
113     // In this case pull() is called multiple times per rendering quantum, and the processIfNecessary() call below will
114     // cause our node to process() only the first time, caching the output in m_internalOutputBus for subsequent calls.    
115     
116     m_isInPlace = inPlaceBus && inPlaceBus->numberOfChannels() == numberOfChannels() && (m_renderingFanOutCount + m_renderingParamFanOutCount) == 1;
117
118     m_inPlaceBus = m_isInPlace ? inPlaceBus : 0;
119
120     node()->processIfNecessary(framesToProcess);
121     return bus();
122 }
123
124 AudioBus* AudioNodeOutput::bus() const
125 {
126     ASSERT(const_cast<AudioNodeOutput*>(this)->context().isAudioThread());
127     return m_isInPlace ? m_inPlaceBus.get() : m_internalBus.get();
128 }
129
130 unsigned AudioNodeOutput::fanOutCount()
131 {
132     ASSERT(context().isGraphOwner());
133     return m_inputs.size();
134 }
135
136 unsigned AudioNodeOutput::paramFanOutCount()
137 {
138     ASSERT(context().isGraphOwner());
139     return m_params.size();
140 }
141
142 unsigned AudioNodeOutput::renderingFanOutCount() const
143 {
144     return m_renderingFanOutCount;
145 }
146
147 unsigned AudioNodeOutput::renderingParamFanOutCount() const
148 {
149     return m_renderingParamFanOutCount;
150 }
151
152 void AudioNodeOutput::addInput(AudioNodeInput* input)
153 {
154     ASSERT(context().isGraphOwner());
155
156     ASSERT(input);
157     if (!input)
158         return;
159
160     m_inputs.add(input);
161 }
162
163 void AudioNodeOutput::removeInput(AudioNodeInput* input)
164 {
165     ASSERT(context().isGraphOwner());
166
167     ASSERT(input);
168     if (!input)
169         return;
170
171     m_inputs.remove(input);
172 }
173
174 void AudioNodeOutput::disconnectAllInputs()
175 {
176     ASSERT(context().isGraphOwner());
177     
178     // AudioNodeInput::disconnect() changes m_inputs by calling removeInput().
179     while (!m_inputs.isEmpty()) {
180         AudioNodeInput* input = *m_inputs.begin();
181         input->disconnect(this);
182     }
183 }
184
185 void AudioNodeOutput::addParam(AudioParam* param)
186 {
187     ASSERT(context().isGraphOwner());
188
189     ASSERT(param);
190     if (!param)
191         return;
192
193     m_params.add(param);
194 }
195
196 void AudioNodeOutput::removeParam(AudioParam* param)
197 {
198     ASSERT(context().isGraphOwner());
199
200     ASSERT(param);
201     if (!param)
202         return;
203
204     m_params.remove(param);
205 }
206
207 void AudioNodeOutput::disconnectAllParams()
208 {
209     ASSERT(context().isGraphOwner());
210
211     // AudioParam::disconnect() changes m_params by calling removeParam().
212     while (!m_params.isEmpty()) {
213         AudioParam* param = m_params.begin()->get();
214         param->disconnect(this);
215     }
216 }
217
218 void AudioNodeOutput::disconnectAll()
219 {
220     disconnectAllInputs();
221     disconnectAllParams();
222 }
223
224 void AudioNodeOutput::disable()
225 {
226     ASSERT(context().isGraphOwner());
227
228     if (m_isEnabled) {
229         for (auto& input : m_inputs)
230             input->disable(this);
231         m_isEnabled = false;
232     }
233 }
234
235 void AudioNodeOutput::enable()
236 {
237     ASSERT(context().isGraphOwner());
238
239     if (!m_isEnabled) {
240         for (auto& input : m_inputs)
241             input->enable(this);
242         m_isEnabled = true;
243     }
244 }
245
246 } // namespace WebCore
247
248 #endif // ENABLE(WEB_AUDIO)