/[svn]/linuxsampler/trunk/src/drivers/audio/AudioOutputDevice.cpp
ViewVC logotype

Contents of /linuxsampler/trunk/src/drivers/audio/AudioOutputDevice.cpp

Parent Directory Parent Directory | Revision Log Revision Log


Revision 2410 - (show annotations) (download)
Sat Feb 2 18:52:15 2013 UTC (11 years, 2 months ago) by schoenebeck
File size: 14721 byte(s)
* Several fixes in JACK audio driver:
- React on sample rate changes.
- React on buffer size changes.
- jack_port_get_buffer() was cached and called
  outside RT context.

1 /***************************************************************************
2 * *
3 * LinuxSampler - modular, streaming capable sampler *
4 * *
5 * Copyright (C) 2003, 2004 by Benno Senoner and Christian Schoenebeck *
6 * Copyright (C) 2005 - 2010 Christian Schoenebeck *
7 * *
8 * This program is free software; you can redistribute it and/or modify *
9 * it under the terms of the GNU General Public License as published by *
10 * the Free Software Foundation; either version 2 of the License, or *
11 * (at your option) any later version. *
12 * *
13 * This program is distributed in the hope that it will be useful, *
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
16 * GNU General Public License for more details. *
17 * *
18 * You should have received a copy of the GNU General Public License *
19 * along with this program; if not, write to the Free Software *
20 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, *
21 * MA 02111-1307 USA *
22 ***************************************************************************/
23
24 #include "AudioOutputDeviceFactory.h"
25 #include "AudioOutputDevice.h"
26 #include "../../common/global_private.h"
27 #include "../../common/IDGenerator.h"
28
29 namespace LinuxSampler {
30
31 // *************** ParameterActive ***************
32 // *
33
34 AudioOutputDevice::ParameterActive::ParameterActive() : DeviceCreationParameterBool() {
35 InitWithDefault();
36 }
37
38 AudioOutputDevice::ParameterActive::ParameterActive(String s) : DeviceCreationParameterBool(s) {
39 }
40
41 String AudioOutputDevice::ParameterActive::Description() {
42 return "Enable / disable device";
43 }
44
45 bool AudioOutputDevice::ParameterActive::Fix() {
46 return false;
47 }
48
49 bool AudioOutputDevice::ParameterActive::Mandatory() {
50 return false;
51 }
52
53 std::map<String,DeviceCreationParameter*> AudioOutputDevice::ParameterActive::DependsAsParameters() {
54 return std::map<String,DeviceCreationParameter*>();
55 }
56
57 optional<bool> AudioOutputDevice::ParameterActive::DefaultAsBool(std::map<String,String> Parameters) {
58 return true;
59 }
60
61 void AudioOutputDevice::ParameterActive::OnSetValue(bool b) throw (Exception) {
62 if (b) ((AudioOutputDevice*)pDevice)->Play();
63 else ((AudioOutputDevice*)pDevice)->Stop();
64 }
65
66 String AudioOutputDevice::ParameterActive::Name() {
67 return "ACTIVE";
68 }
69
70
71
72 // *************** ParameterSampleRate ***************
73 // *
74
75 AudioOutputDevice::ParameterSampleRate::ParameterSampleRate() : DeviceCreationParameterInt() {
76 InitWithDefault();
77 }
78
79 AudioOutputDevice::ParameterSampleRate::ParameterSampleRate(String s) : DeviceCreationParameterInt(s) {
80 }
81
82 String AudioOutputDevice::ParameterSampleRate::Description() {
83 return "Output sample rate";
84 }
85
86 bool AudioOutputDevice::ParameterSampleRate::Fix() {
87 return true;
88 }
89
90 bool AudioOutputDevice::ParameterSampleRate::Mandatory() {
91 return false;
92 }
93
94 std::map<String,DeviceCreationParameter*> AudioOutputDevice::ParameterSampleRate::DependsAsParameters() {
95 return std::map<String,DeviceCreationParameter*>();
96 }
97
98 optional<int> AudioOutputDevice::ParameterSampleRate::DefaultAsInt(std::map<String,String> Parameters) {
99 return 44100;
100 }
101
102 optional<int> AudioOutputDevice::ParameterSampleRate::RangeMinAsInt(std::map<String,String> Parameters) {
103 return optional<int>::nothing;
104 }
105
106 optional<int> AudioOutputDevice::ParameterSampleRate::RangeMaxAsInt(std::map<String,String> Parameters) {
107 return optional<int>::nothing;
108 }
109
110 std::vector<int> AudioOutputDevice::ParameterSampleRate::PossibilitiesAsInt(std::map<String,String> Parameters) {
111 return std::vector<int>();
112 }
113
114 int AudioOutputDevice::ParameterSampleRate::ValueAsInt() {
115 return (pDevice) ? (int) ((AudioOutputDevice*)pDevice)->SampleRate()
116 : DeviceCreationParameterInt::ValueAsInt();
117 }
118
119 void AudioOutputDevice::ParameterSampleRate::OnSetValue(int i) throw (Exception) {
120 /* cannot happen, as parameter is fix */
121 }
122
123 String AudioOutputDevice::ParameterSampleRate::Name() {
124 return "SAMPLERATE";
125 }
126
127
128
129 // *************** ParameterChannels ***************
130 // *
131
132 AudioOutputDevice::ParameterChannels::ParameterChannels() : DeviceCreationParameterInt() {
133 InitWithDefault();
134 }
135
136 AudioOutputDevice::ParameterChannels::ParameterChannels(String s) : DeviceCreationParameterInt(s) {
137 }
138
139 String AudioOutputDevice::ParameterChannels::Description() {
140 return "Number of output channels";
141 }
142
143 bool AudioOutputDevice::ParameterChannels::Fix() {
144 return false;
145 }
146
147 bool AudioOutputDevice::ParameterChannels::Mandatory() {
148 return false;
149 }
150
151 std::map<String,DeviceCreationParameter*> AudioOutputDevice::ParameterChannels::DependsAsParameters() {
152 return std::map<String,DeviceCreationParameter*>();
153 }
154
155 optional<int> AudioOutputDevice::ParameterChannels::DefaultAsInt(std::map<String,String> Parameters) {
156 return 2;
157 }
158
159 optional<int> AudioOutputDevice::ParameterChannels::RangeMinAsInt(std::map<String,String> Parameters) {
160 return 1;
161 }
162
163 optional<int> AudioOutputDevice::ParameterChannels::RangeMaxAsInt(std::map<String,String> Parameters) {
164 return optional<int>::nothing;
165 }
166
167 std::vector<int> AudioOutputDevice::ParameterChannels::PossibilitiesAsInt(std::map<String,String> Parameters) {
168 return std::vector<int>();
169 }
170
171 void AudioOutputDevice::ParameterChannels::OnSetValue(int i) throw (Exception) {
172 ((AudioOutputDevice*)pDevice)->AcquireChannels(i);
173 }
174
175 String AudioOutputDevice::ParameterChannels::Name() {
176 return "CHANNELS";
177 }
178
179
180
181 // *************** AudioOutputDevice ***************
182 // *
183
184 AudioOutputDevice::AudioOutputDevice(std::map<String,DeviceCreationParameter*> DriverParameters)
185 : EnginesReader(Engines) {
186 this->Parameters = DriverParameters;
187 EffectChainIDs = new IDGenerator();
188 }
189
190 AudioOutputDevice::~AudioOutputDevice() {
191 // delete all audio channels
192 {
193 std::vector<AudioChannel*>::iterator iter = Channels.begin();
194 while (iter != Channels.end()) {
195 delete *iter;
196 iter++;
197 }
198 Channels.clear();
199 }
200
201 // delete all device parameters
202 {
203 std::map<String,DeviceCreationParameter*>::iterator iter = Parameters.begin();
204 while (iter != Parameters.end()) {
205 delete iter->second;
206 iter++;
207 }
208 Parameters.clear();
209 }
210
211 // delete all master effect chains
212 {
213 std::vector<EffectChain*>::iterator iter = vEffectChains.begin();
214 while (iter != vEffectChains.end()) {
215 delete *iter;
216 iter++;
217 }
218 vEffectChains.clear();
219 }
220
221 delete EffectChainIDs;
222 }
223
224 void AudioOutputDevice::Connect(Engine* pEngine) {
225 std::set<Engine*>& engines = Engines.GetConfigForUpdate();
226 if (engines.find(pEngine) == engines.end()) {
227 engines.insert(pEngine);
228 Engines.SwitchConfig().insert(pEngine);
229 // make sure the engine knows about the connection
230 //pEngine->Connect(this);
231 }
232 }
233
234 void AudioOutputDevice::Disconnect(Engine* pEngine) {
235 std::set<Engine*>& engines = Engines.GetConfigForUpdate();
236 if (engines.find(pEngine) != engines.end()) { // if clause to prevent disconnect loop
237 engines.erase(pEngine);
238 Engines.SwitchConfig().erase(pEngine);
239 // make sure the engine knows about the disconnection
240 //pEngine->DisconnectAudioOutputDevice();
241 }
242 }
243
244 void AudioOutputDevice::ReconnectAll() {
245 // copy by value, not by reference here !
246 std::set<Engine*> engines = Engines.GetConfigForUpdate();
247 {
248 std::set<Engine*>::iterator iterEngine = engines.begin();
249 std::set<Engine*>::iterator end = engines.end();
250 for (; iterEngine != end; iterEngine++) {
251 (*iterEngine)->ReconnectAudioOutputDevice();
252 }
253 }
254 }
255
256 AudioChannel* AudioOutputDevice::Channel(uint ChannelIndex) {
257 return (ChannelIndex < Channels.size()) ? Channels[ChannelIndex] : NULL;
258 }
259
260 void AudioOutputDevice::AcquireChannels(uint Channels) {
261 if (Channels > this->Channels.size()) {
262 for (int c = this->Channels.size(); c < Channels; c++) {
263 this->Channels.push_back(CreateChannel(c));
264 }
265 }
266 }
267
268 uint AudioOutputDevice::ChannelCount() {
269 return Channels.size();
270 }
271
272 std::map<String,DeviceCreationParameter*> AudioOutputDevice::DeviceParameters() {
273 return Parameters;
274 }
275
276 EffectChain* AudioOutputDevice::AddSendEffectChain() {
277 EffectChain* pChain = new EffectChain(this, EffectChainIDs->create());
278 vEffectChains.push_back(pChain);
279 return pChain;
280 }
281
282 void AudioOutputDevice::RemoveSendEffectChain(uint iChain) throw (Exception) {
283 if (iChain >= vEffectChains.size())
284 throw Exception(
285 "Could not remove send effect chain " + ToString(iChain) +
286 ", index out of bounds"
287 );
288 std::vector<EffectChain*>::iterator iter = vEffectChains.begin();
289 for (int i = 0; i < iChain; ++i) ++iter;
290 EffectChainIDs->destroy((*iter)->ID());
291 vEffectChains.erase(iter);
292 }
293
294 EffectChain* AudioOutputDevice::SendEffectChain(uint iChain) const {
295 if (iChain >= vEffectChains.size()) return NULL;
296 return vEffectChains[iChain];
297 }
298
299 EffectChain* AudioOutputDevice::SendEffectChainByID(uint iChainID) const {
300 for (int i = 0; i < SendEffectChainCount(); i++) {
301 if (SendEffectChain(i)->ID() == iChainID) return SendEffectChain(i);
302 }
303
304 return NULL;
305 }
306
307 uint AudioOutputDevice::SendEffectChainCount() const {
308 return vEffectChains.size();
309 }
310
311 // TODO: to be removed
312 EffectChain* AudioOutputDevice::AddMasterEffectChain() {
313 return AddSendEffectChain();
314 }
315
316 // TODO: to be removed
317 void AudioOutputDevice::RemoveMasterEffectChain(uint iChain) throw (Exception) {
318 RemoveSendEffectChain(iChain);
319 }
320
321 // TODO: to be removed
322 EffectChain* AudioOutputDevice::MasterEffectChain(uint iChain) const {
323 return SendEffectChain(iChain);
324 }
325
326 // TODO: to be removed
327 uint AudioOutputDevice::MasterEffectChainCount() const {
328 return SendEffectChainCount();
329 }
330
331 float AudioOutputDevice::latency() {
332 return float(MaxSamplesPerCycle()) / float(SampleRate());
333 }
334
335 int AudioOutputDevice::RenderAudio(uint Samples) {
336 if (Channels.empty()) return 0;
337
338 // reset all channels with silence
339 {
340 std::vector<AudioChannel*>::iterator iterChannels = Channels.begin();
341 std::vector<AudioChannel*>::iterator end = Channels.end();
342 for (; iterChannels != end; iterChannels++)
343 (*iterChannels)->Clear(Samples); // zero out audio buffer
344 }
345 // do the same for master effects
346 {
347 std::vector<EffectChain*>::iterator iterChains = vEffectChains.begin();
348 std::vector<EffectChain*>::iterator end = vEffectChains.end();
349 for (; iterChains != end; ++iterChains)
350 (*iterChains)->ClearAllChannels(); // zero out audio buffers
351 }
352
353 int result = 0;
354
355 // let all connected engines render audio for the current audio fragment cycle
356 const std::set<Engine*>& engines = EnginesReader.Lock();
357 #if CONFIG_RT_EXCEPTIONS
358 try
359 #endif // CONFIG_RT_EXCEPTIONS
360 {
361 std::set<Engine*>::iterator iterEngine = engines.begin();
362 std::set<Engine*>::iterator end = engines.end();
363 for (; iterEngine != end; iterEngine++) {
364 int res = (*iterEngine)->RenderAudio(Samples);
365 if (res != 0) result = res;
366 }
367 }
368 #if CONFIG_RT_EXCEPTIONS
369 catch (std::runtime_error se) {
370 std::cerr << "std::runtime_error: " << se.what() << std::endl << std::flush;
371 exit(EXIT_FAILURE);
372 }
373 #endif // CONFIG_RT_EXCEPTIONS
374 EnginesReader.Unlock();
375
376 // now that the engines (might) have left fx send signals for master
377 // effects, render all master effects
378 {
379 std::vector<EffectChain*>::iterator iterChains = vEffectChains.begin();
380 std::vector<EffectChain*>::iterator end = vEffectChains.end();
381 for (; iterChains != end; ++iterChains) {
382 if (!(*iterChains)->EffectCount()) continue;
383 (*iterChains)->RenderAudio(Samples);
384 // mix the result of the last effect in the chain to the audio
385 // output device channel(s)
386 Effect* pLastEffect =
387 (*iterChains)->GetEffect((*iterChains)->EffectCount() - 1);
388 for (int iChan = 0; iChan < pLastEffect->OutputChannelCount() && iChan < ChannelCount(); ++iChan)
389 pLastEffect->OutputChannel(iChan)->MixTo(Channel(iChan), Samples);
390 }
391 }
392
393 return result;
394 }
395
396 int AudioOutputDevice::RenderSilence(uint Samples) {
397 if (Channels.empty()) return 0;
398
399 // reset all channels with silence
400 {
401 std::vector<AudioChannel*>::iterator iterChannels = Channels.begin();
402 std::vector<AudioChannel*>::iterator end = Channels.end();
403 for (; iterChannels != end; iterChannels++)
404 (*iterChannels)->Clear(Samples); // zero out audio buffer
405 }
406
407 return 0;
408 }
409
410 } // namespace LinuxSampler

  ViewVC Help
Powered by ViewVC