/[svn]/linuxsampler/trunk/src/engines/gig/Engine.cpp
ViewVC logotype

Annotation of /linuxsampler/trunk/src/engines/gig/Engine.cpp

Parent Directory Parent Directory | Revision Log Revision Log


Revision 668 - (hide annotations) (download)
Mon Jun 20 15:30:47 2005 UTC (14 years, 3 months ago) by schoenebeck
File size: 61427 byte(s)
* fixed a key group bug which caused undefined behavior in conjunction with
  stolen voices (this case was usually followed by a "killed voice
  survived" or "voice stealing didn't work out" error message)

1 schoenebeck 53 /***************************************************************************
2     * *
3     * LinuxSampler - modular, streaming capable sampler *
4     * *
5 schoenebeck 56 * Copyright (C) 2003, 2004 by Benno Senoner and Christian Schoenebeck *
6 schoenebeck 411 * Copyright (C) 2005 Christian Schoenebeck *
7 schoenebeck 53 * *
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 <sstream>
25     #include "DiskThread.h"
26     #include "Voice.h"
27 schoenebeck 285 #include "EGADSR.h"
28 schoenebeck 420 #include "../EngineFactory.h"
29 schoenebeck 53
30     #include "Engine.h"
31    
32 schoenebeck 361 #if defined(__APPLE__)
33     # include <stdlib.h>
34     #else
35     # include <malloc.h>
36     #endif
37    
38 schoenebeck 53 namespace LinuxSampler { namespace gig {
39    
40 schoenebeck 411 InstrumentResourceManager Engine::instruments;
41 schoenebeck 53
42 schoenebeck 411 std::map<AudioOutputDevice*,Engine*> Engine::engines;
43    
44 schoenebeck 412 /**
45     * Get a gig::Engine object for the given gig::EngineChannel and the
46     * given AudioOutputDevice. All engine channels which are connected to
47     * the same audio output device will use the same engine instance. This
48     * method will be called by a gig::EngineChannel whenever it's
49     * connecting to a audio output device.
50     *
51     * @param pChannel - engine channel which acquires an engine object
52     * @param pDevice - the audio output device \a pChannel is connected to
53     */
54 schoenebeck 411 Engine* Engine::AcquireEngine(LinuxSampler::gig::EngineChannel* pChannel, AudioOutputDevice* pDevice) {
55 schoenebeck 412 Engine* pEngine = NULL;
56     // check if there's already an engine for the given audio output device
57 schoenebeck 411 if (engines.count(pDevice)) {
58 schoenebeck 412 dmsg(4,("Using existing gig::Engine.\n"));
59 persson 438 pEngine = engines[pDevice];
60 schoenebeck 412 } else { // create a new engine (and disk thread) instance for the given audio output device
61     dmsg(4,("Creating new gig::Engine.\n"));
62 schoenebeck 420 pEngine = (Engine*) EngineFactory::Create("gig");
63 schoenebeck 411 pEngine->Connect(pDevice);
64 persson 438 engines[pDevice] = pEngine;
65 schoenebeck 411 }
66 schoenebeck 412 // register engine channel to the engine instance
67 schoenebeck 460 pEngine->engineChannels.add(pChannel);
68     // remember index in the ArrayList
69     pChannel->iEngineIndexSelf = pEngine->engineChannels.size() - 1;
70 schoenebeck 412 dmsg(4,("This gig::Engine has now %d EngineChannels.\n",pEngine->engineChannels.size()));
71 schoenebeck 411 return pEngine;
72     }
73    
74 schoenebeck 412 /**
75     * Once an engine channel is disconnected from an audio output device,
76     * it wil immediately call this method to unregister itself from the
77     * engine instance and if that engine instance is not used by any other
78     * engine channel anymore, then that engine instance will be destroyed.
79     *
80     * @param pChannel - engine channel which wants to disconnect from it's
81     * engine instance
82     * @param pDevice - audio output device \a pChannel was connected to
83     */
84 schoenebeck 411 void Engine::FreeEngine(LinuxSampler::gig::EngineChannel* pChannel, AudioOutputDevice* pDevice) {
85 schoenebeck 412 dmsg(4,("Disconnecting EngineChannel from gig::Engine.\n"));
86 schoenebeck 411 Engine* pEngine = engines[pDevice];
87 schoenebeck 412 // unregister EngineChannel from the Engine instance
88     pEngine->engineChannels.remove(pChannel);
89     // if the used Engine instance is not used anymore, then destroy it
90     if (pEngine->engineChannels.empty()) {
91     pDevice->Disconnect(pEngine);
92     engines.erase(pDevice);
93     delete pEngine;
94     dmsg(4,("Destroying gig::Engine.\n"));
95     }
96     else dmsg(4,("This gig::Engine has now %d EngineChannels.\n",pEngine->engineChannels.size()));
97 schoenebeck 411 }
98    
99 schoenebeck 473 /**
100     * Constructor
101     */
102 schoenebeck 53 Engine::Engine() {
103     pAudioOutputDevice = NULL;
104     pDiskThread = NULL;
105     pEventGenerator = NULL;
106 schoenebeck 554 pSysexBuffer = new RingBuffer<uint8_t>(CONFIG_SYSEX_BUFFER_SIZE, 0);
107     pEventQueue = new RingBuffer<Event>(CONFIG_MAX_EVENTS_PER_FRAGMENT, 0);
108     pEventPool = new Pool<Event>(CONFIG_MAX_EVENTS_PER_FRAGMENT);
109     pVoicePool = new Pool<Voice>(CONFIG_MAX_VOICES);
110 schoenebeck 271 pVoiceStealingQueue = new RTList<Event>(pEventPool);
111 schoenebeck 460 pGlobalEvents = new RTList<Event>(pEventPool);
112 schoenebeck 271 for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
113     iterVoice->SetEngine(this);
114 schoenebeck 53 }
115     pVoicePool->clear();
116    
117     pSynthesisParameters[0] = NULL; // we allocate when an audio device is connected
118 schoenebeck 80 pBasicFilterParameters = NULL;
119     pMainFilterParameters = NULL;
120 schoenebeck 123
121 schoenebeck 53 ResetInternal();
122 schoenebeck 659 ResetScaleTuning();
123 schoenebeck 53 }
124    
125 schoenebeck 473 /**
126     * Destructor
127     */
128 schoenebeck 53 Engine::~Engine() {
129     if (pDiskThread) {
130 senkov 329 dmsg(1,("Stopping disk thread..."));
131 schoenebeck 53 pDiskThread->StopThread();
132     delete pDiskThread;
133 senkov 329 dmsg(1,("OK\n"));
134 schoenebeck 53 }
135     if (pEventQueue) delete pEventQueue;
136     if (pEventPool) delete pEventPool;
137 schoenebeck 411 if (pVoicePool) {
138     pVoicePool->clear();
139     delete pVoicePool;
140     }
141 schoenebeck 53 if (pEventGenerator) delete pEventGenerator;
142 schoenebeck 80 if (pMainFilterParameters) delete[] pMainFilterParameters;
143     if (pBasicFilterParameters) delete[] pBasicFilterParameters;
144 schoenebeck 319 if (pSynthesisParameters[0]) free(pSynthesisParameters[0]);
145 schoenebeck 250 if (pVoiceStealingQueue) delete pVoiceStealingQueue;
146 schoenebeck 411 if (pSysexBuffer) delete pSysexBuffer;
147 schoenebeck 420 EngineFactory::Destroy(this);
148 schoenebeck 53 }
149    
150     void Engine::Enable() {
151     dmsg(3,("gig::Engine: enabling\n"));
152     EngineDisabled.PushAndUnlock(false, 2); // set condition object 'EngineDisabled' to false (wait max. 2s)
153 schoenebeck 64 dmsg(3,("gig::Engine: enabled (val=%d)\n", EngineDisabled.GetUnsafe()));
154 schoenebeck 53 }
155    
156     void Engine::Disable() {
157     dmsg(3,("gig::Engine: disabling\n"));
158     bool* pWasDisabled = EngineDisabled.PushAndUnlock(true, 2); // wait max. 2s
159     if (!pWasDisabled) dmsg(3,("gig::Engine warning: Timeout waiting to disable engine.\n"));
160     }
161    
162     void Engine::DisableAndLock() {
163     dmsg(3,("gig::Engine: disabling\n"));
164     bool* pWasDisabled = EngineDisabled.Push(true, 2); // wait max. 2s
165     if (!pWasDisabled) dmsg(3,("gig::Engine warning: Timeout waiting to disable engine.\n"));
166     }
167    
168     /**
169     * Reset all voices and disk thread and clear input event queue and all
170     * control and status variables.
171     */
172     void Engine::Reset() {
173     DisableAndLock();
174     ResetInternal();
175 schoenebeck 659 ResetScaleTuning();
176 schoenebeck 53 Enable();
177     }
178    
179     /**
180     * Reset all voices and disk thread and clear input event queue and all
181     * control and status variables. This method is not thread safe!
182     */
183     void Engine::ResetInternal() {
184     ActiveVoiceCount = 0;
185     ActiveVoiceCountMax = 0;
186    
187 schoenebeck 250 // reset voice stealing parameters
188     pVoiceStealingQueue->clear();
189 schoenebeck 649 itLastStolenVoice = RTList<Voice>::Iterator();
190     itLastStolenVoiceGlobally = RTList<Voice>::Iterator();
191     iuiLastStolenKey = RTList<uint>::Iterator();
192     iuiLastStolenKeyGlobally = RTList<uint>::Iterator();
193     pLastStolenChannel = NULL;
194 schoenebeck 250
195 schoenebeck 53 // reset all voices
196 schoenebeck 271 for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
197     iterVoice->Reset();
198 schoenebeck 53 }
199     pVoicePool->clear();
200    
201     // reset disk thread
202     if (pDiskThread) pDiskThread->Reset();
203    
204     // delete all input events
205     pEventQueue->init();
206 persson 438 }
207 schoenebeck 53
208 schoenebeck 473 /**
209 schoenebeck 659 * Reset to normal, chromatic scale (means equal tempered).
210     */
211     void Engine::ResetScaleTuning() {
212     memset(&ScaleTuning[0], 0x00, 12);
213     }
214    
215     /**
216 schoenebeck 473 * Connect this engine instance with the given audio output device.
217     * This method will be called when an Engine instance is created.
218     * All of the engine's data structures which are dependant to the used
219     * audio output device / driver will be (re)allocated and / or
220     * adjusted appropriately.
221     *
222     * @param pAudioOut - audio output device to connect to
223     */
224 schoenebeck 53 void Engine::Connect(AudioOutputDevice* pAudioOut) {
225     pAudioOutputDevice = pAudioOut;
226    
227     ResetInternal();
228    
229     // inform audio driver for the need of two channels
230     try {
231     pAudioOutputDevice->AcquireChannels(2); // gig engine only stereo
232     }
233     catch (AudioOutputException e) {
234     String msg = "Audio output device unable to provide 2 audio channels, cause: " + e.Message();
235     throw LinuxSamplerException(msg);
236     }
237 persson 438
238 schoenebeck 460 this->MaxSamplesPerCycle = pAudioOutputDevice->MaxSamplesPerCycle();
239     this->SampleRate = pAudioOutputDevice->SampleRate();
240 schoenebeck 225
241 schoenebeck 285 // FIXME: audio drivers with varying fragment sizes might be a problem here
242 schoenebeck 554 MaxFadeOutPos = MaxSamplesPerCycle - int(double(SampleRate) * CONFIG_EG_MIN_RELEASE_TIME) - 1;
243 schoenebeck 285 if (MaxFadeOutPos < 0)
244 schoenebeck 554 throw LinuxSamplerException("CONFIG_EG_MIN_RELEASE_TIME too big for current audio fragment size / sampling rate!");
245 schoenebeck 285
246 schoenebeck 53 // (re)create disk thread
247     if (this->pDiskThread) {
248 senkov 329 dmsg(1,("Stopping disk thread..."));
249 schoenebeck 53 this->pDiskThread->StopThread();
250     delete this->pDiskThread;
251 senkov 329 dmsg(1,("OK\n"));
252 schoenebeck 53 }
253 schoenebeck 554 this->pDiskThread = new DiskThread(((pAudioOut->MaxSamplesPerCycle() << CONFIG_MAX_PITCH) << 1) + 6); //FIXME: assuming stereo
254 schoenebeck 53 if (!pDiskThread) {
255     dmsg(0,("gig::Engine new diskthread = NULL\n"));
256     exit(EXIT_FAILURE);
257     }
258    
259 schoenebeck 271 for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
260     iterVoice->pDiskThread = this->pDiskThread;
261 schoenebeck 53 dmsg(3,("d"));
262     }
263     pVoicePool->clear();
264    
265     // (re)create event generator
266     if (pEventGenerator) delete pEventGenerator;
267     pEventGenerator = new EventGenerator(pAudioOut->SampleRate());
268    
269     // (re)allocate synthesis parameter matrix
270 schoenebeck 319 if (pSynthesisParameters[0]) free(pSynthesisParameters[0]);
271 schoenebeck 361
272     #if defined(__APPLE__)
273     pSynthesisParameters[0] = (float *) malloc(Event::destination_count * sizeof(float) * pAudioOut->MaxSamplesPerCycle());
274     #else
275 schoenebeck 319 pSynthesisParameters[0] = (float *) memalign(16,(Event::destination_count * sizeof(float) * pAudioOut->MaxSamplesPerCycle()));
276 schoenebeck 361 #endif
277 schoenebeck 53 for (int dst = 1; dst < Event::destination_count; dst++)
278     pSynthesisParameters[dst] = pSynthesisParameters[dst - 1] + pAudioOut->MaxSamplesPerCycle();
279    
280 schoenebeck 80 // (re)allocate biquad filter parameter sequence
281     if (pBasicFilterParameters) delete[] pBasicFilterParameters;
282     if (pMainFilterParameters) delete[] pMainFilterParameters;
283     pBasicFilterParameters = new biquad_param_t[pAudioOut->MaxSamplesPerCycle()];
284     pMainFilterParameters = new biquad_param_t[pAudioOut->MaxSamplesPerCycle()];
285    
286 schoenebeck 53 dmsg(1,("Starting disk thread..."));
287     pDiskThread->StartThread();
288     dmsg(1,("OK\n"));
289    
290 schoenebeck 271 for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
291     if (!iterVoice->pDiskThread) {
292 schoenebeck 53 dmsg(0,("Engine -> voice::trigger: !pDiskThread\n"));
293     exit(EXIT_FAILURE);
294     }
295     }
296     }
297    
298 schoenebeck 473 /**
299     * Clear all engine global event lists.
300     */
301 schoenebeck 412 void Engine::ClearEventLists() {
302 schoenebeck 460 pGlobalEvents->clear();
303 schoenebeck 412 }
304    
305 schoenebeck 53 /**
306 schoenebeck 460 * Copy all events from the engine's global input queue buffer to the
307     * engine's internal event list. This will be done at the beginning of
308     * each audio cycle (that is each RenderAudio() call) to distinguish
309     * all global events which have to be processed in the current audio
310     * cycle. These events are usually just SysEx messages. Every
311     * EngineChannel has it's own input event queue buffer and event list
312     * to handle common events like NoteOn, NoteOff and ControlChange
313     * events.
314 schoenebeck 412 *
315 schoenebeck 460 * @param Samples - number of sample points to be processed in the
316     * current audio cycle
317 schoenebeck 412 */
318 schoenebeck 460 void Engine::ImportEvents(uint Samples) {
319 schoenebeck 412 RingBuffer<Event>::NonVolatileReader eventQueueReader = pEventQueue->get_non_volatile_reader();
320     Event* pEvent;
321     while (true) {
322     // get next event from input event queue
323     if (!(pEvent = eventQueueReader.pop())) break;
324     // if younger event reached, ignore that and all subsequent ones for now
325     if (pEvent->FragmentPos() >= Samples) {
326     eventQueueReader--;
327     dmsg(2,("Younger Event, pos=%d ,Samples=%d!\n",pEvent->FragmentPos(),Samples));
328     pEvent->ResetFragmentPos();
329     break;
330     }
331     // copy event to internal event list
332 schoenebeck 460 if (pGlobalEvents->poolIsEmpty()) {
333 schoenebeck 412 dmsg(1,("Event pool emtpy!\n"));
334     break;
335     }
336 schoenebeck 460 *pGlobalEvents->allocAppend() = *pEvent;
337 schoenebeck 412 }
338     eventQueueReader.free(); // free all copied events from input queue
339 persson 438 }
340 schoenebeck 412
341     /**
342 schoenebeck 53 * Let this engine proceed to render the given amount of sample points. The
343     * calculated audio data of all voices of this engine will be placed into
344     * the engine's audio sum buffer which has to be copied and eventually be
345     * converted to the appropriate value range by the audio output class (e.g.
346     * AlsaIO or JackIO) right after.
347     *
348     * @param Samples - number of sample points to be rendered
349     * @returns 0 on success
350     */
351 schoenebeck 412 int Engine::RenderAudio(uint Samples) {
352 schoenebeck 53 dmsg(5,("RenderAudio(Samples=%d)\n", Samples));
353    
354 schoenebeck 412 // return if engine disabled
355 schoenebeck 53 if (EngineDisabled.Pop()) {
356     dmsg(5,("gig::Engine: engine disabled (val=%d)\n",EngineDisabled.GetUnsafe()));
357     return 0;
358     }
359    
360 schoenebeck 293 // update time of start and end of this audio fragment (as events' time stamps relate to this)
361     pEventGenerator->UpdateFragmentTime(Samples);
362    
363 schoenebeck 663 // We only allow a maximum of CONFIG_MAX_VOICES voices to be spawned
364     // in each audio fragment. All subsequent request for spawning new
365     // voices in the same audio fragment will be ignored.
366     VoiceSpawnsLeft = CONFIG_MAX_VOICES;
367    
368 schoenebeck 412 // get all events from the engine's global input event queue which belong to the current fragment
369     // (these are usually just SysEx messages)
370 schoenebeck 460 ImportEvents(Samples);
371 schoenebeck 412
372     // process engine global events (these are currently only MIDI System Exclusive messages)
373     {
374 schoenebeck 460 RTList<Event>::Iterator itEvent = pGlobalEvents->first();
375     RTList<Event>::Iterator end = pGlobalEvents->end();
376 schoenebeck 412 for (; itEvent != end; ++itEvent) {
377     switch (itEvent->Type) {
378     case Event::type_sysex:
379     dmsg(5,("Engine: Sysex received\n"));
380     ProcessSysex(itEvent);
381     break;
382     }
383     }
384 schoenebeck 53 }
385 schoenebeck 412
386     // reset internal voice counter (just for statistic of active voices)
387     ActiveVoiceCountTemp = 0;
388    
389 schoenebeck 466 // handle events on all engine channels
390 schoenebeck 460 for (int i = 0; i < engineChannels.size(); i++) {
391     if (!engineChannels[i]->pInstrument) continue; // ignore if no instrument loaded
392     ProcessEvents(engineChannels[i], Samples);
393 schoenebeck 466 }
394    
395     // render all 'normal', active voices on all engine channels
396     for (int i = 0; i < engineChannels.size(); i++) {
397     if (!engineChannels[i]->pInstrument) continue; // ignore if no instrument loaded
398 schoenebeck 460 RenderActiveVoices(engineChannels[i], Samples);
399 schoenebeck 412 }
400    
401 schoenebeck 460 // now that all ordinary voices on ALL engine channels are rendered, render new stolen voices
402     RenderStolenVoices(Samples);
403    
404     // handle cleanup on all engine channels for the next audio fragment
405     for (int i = 0; i < engineChannels.size(); i++) {
406     if (!engineChannels[i]->pInstrument) continue; // ignore if no instrument loaded
407     PostProcess(engineChannels[i]);
408     }
409    
410    
411     // empty the engine's event list for the next audio fragment
412     ClearEventLists();
413    
414     // reset voice stealing for the next audio fragment
415     pVoiceStealingQueue->clear();
416    
417 schoenebeck 412 // just some statistics about this engine instance
418     ActiveVoiceCount = ActiveVoiceCountTemp;
419     if (ActiveVoiceCount > ActiveVoiceCountMax) ActiveVoiceCountMax = ActiveVoiceCount;
420    
421 persson 630 FrameTime += Samples;
422    
423 schoenebeck 412 return 0;
424     }
425    
426 schoenebeck 473 /**
427     * Dispatch and handle all events in this audio fragment for the given
428     * engine channel.
429     *
430     * @param pEngineChannel - engine channel on which events should be
431     * processed
432     * @param Samples - amount of sample points to be processed in
433     * this audio fragment cycle
434     */
435 schoenebeck 460 void Engine::ProcessEvents(EngineChannel* pEngineChannel, uint Samples) {
436 schoenebeck 412 // get all events from the engine channels's input event queue which belong to the current fragment
437     // (these are the common events like NoteOn, NoteOff, ControlChange, etc.)
438 schoenebeck 460 pEngineChannel->ImportEvents(Samples);
439 schoenebeck 53
440     // process events
441 schoenebeck 271 {
442 schoenebeck 460 RTList<Event>::Iterator itEvent = pEngineChannel->pEvents->first();
443     RTList<Event>::Iterator end = pEngineChannel->pEvents->end();
444 schoenebeck 271 for (; itEvent != end; ++itEvent) {
445     switch (itEvent->Type) {
446     case Event::type_note_on:
447     dmsg(5,("Engine: Note on received\n"));
448 schoenebeck 412 ProcessNoteOn((EngineChannel*)itEvent->pEngineChannel, itEvent);
449 schoenebeck 271 break;
450     case Event::type_note_off:
451     dmsg(5,("Engine: Note off received\n"));
452 schoenebeck 412 ProcessNoteOff((EngineChannel*)itEvent->pEngineChannel, itEvent);
453 schoenebeck 271 break;
454     case Event::type_control_change:
455     dmsg(5,("Engine: MIDI CC received\n"));
456 schoenebeck 412 ProcessControlChange((EngineChannel*)itEvent->pEngineChannel, itEvent);
457 schoenebeck 271 break;
458     case Event::type_pitchbend:
459     dmsg(5,("Engine: Pitchbend received\n"));
460 schoenebeck 412 ProcessPitchbend((EngineChannel*)itEvent->pEngineChannel, itEvent);
461 schoenebeck 271 break;
462     }
463 schoenebeck 53 }
464     }
465 schoenebeck 649
466     // reset voice stealing for the next engine channel (or next audio fragment)
467     itLastStolenVoice = RTList<Voice>::Iterator();
468     itLastStolenVoiceGlobally = RTList<Voice>::Iterator();
469     iuiLastStolenKey = RTList<uint>::Iterator();
470     iuiLastStolenKeyGlobally = RTList<uint>::Iterator();
471     pLastStolenChannel = NULL;
472 schoenebeck 460 }
473 schoenebeck 53
474 schoenebeck 473 /**
475     * Render all 'normal' voices (that is voices which were not stolen in
476     * this fragment) on the given engine channel.
477     *
478     * @param pEngineChannel - engine channel on which audio should be
479     * rendered
480     * @param Samples - amount of sample points to be rendered in
481     * this audio fragment cycle
482     */
483 schoenebeck 460 void Engine::RenderActiveVoices(EngineChannel* pEngineChannel, uint Samples) {
484     RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
485     RTList<uint>::Iterator end = pEngineChannel->pActiveKeys->end();
486     while (iuiKey != end) { // iterate through all active keys
487     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
488     ++iuiKey;
489 schoenebeck 53
490 schoenebeck 460 RTList<Voice>::Iterator itVoice = pKey->pActiveVoices->first();
491     RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
492     for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
493     // now render current voice
494     itVoice->Render(Samples);
495     if (itVoice->IsActive()) ActiveVoiceCountTemp++; // still active
496     else { // voice reached end, is now inactive
497     FreeVoice(pEngineChannel, itVoice); // remove voice from the list of active voices
498 schoenebeck 53 }
499     }
500     }
501 schoenebeck 460 }
502 schoenebeck 53
503 schoenebeck 473 /**
504     * Render all stolen voices (only voices which were stolen in this
505     * fragment) on the given engine channel. Stolen voices are rendered
506     * after all normal voices have been rendered; this is needed to render
507     * audio of those voices which were selected for voice stealing until
508     * the point were the stealing (that is the take over of the voice)
509     * actually happened.
510     *
511     * @param pEngineChannel - engine channel on which audio should be
512     * rendered
513     * @param Samples - amount of sample points to be rendered in
514     * this audio fragment cycle
515     */
516 schoenebeck 460 void Engine::RenderStolenVoices(uint Samples) {
517     RTList<Event>::Iterator itVoiceStealEvent = pVoiceStealingQueue->first();
518     RTList<Event>::Iterator end = pVoiceStealingQueue->end();
519     for (; itVoiceStealEvent != end; ++itVoiceStealEvent) {
520     EngineChannel* pEngineChannel = (EngineChannel*) itVoiceStealEvent->pEngineChannel;
521     Pool<Voice>::Iterator itNewVoice =
522 schoenebeck 668 LaunchVoice(pEngineChannel, itVoiceStealEvent, itVoiceStealEvent->Param.Note.Layer, itVoiceStealEvent->Param.Note.ReleaseTrigger, false, false);
523 schoenebeck 460 if (itNewVoice) {
524     itNewVoice->Render(Samples);
525     if (itNewVoice->IsActive()) ActiveVoiceCountTemp++; // still active
526     else { // voice reached end, is now inactive
527     FreeVoice(pEngineChannel, itNewVoice); // remove voice from the list of active voices
528 schoenebeck 250 }
529     }
530 schoenebeck 460 else dmsg(1,("gig::Engine: ERROR, voice stealing didn't work out!\n"));
531 schoenebeck 473
532     // we need to clear the key's event list explicitly here in case key was never active
533     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[itVoiceStealEvent->Param.Note.Key];
534     pKey->VoiceTheftsQueued--;
535     if (!pKey->Active && !pKey->VoiceTheftsQueued) pKey->pEvents->clear();
536 schoenebeck 250 }
537 schoenebeck 460 }
538 schoenebeck 250
539 schoenebeck 473 /**
540     * Free all keys which have turned inactive in this audio fragment, from
541     * the list of active keys and clear all event lists on that engine
542     * channel.
543     *
544     * @param pEngineChannel - engine channel to cleanup
545     */
546 schoenebeck 460 void Engine::PostProcess(EngineChannel* pEngineChannel) {
547 schoenebeck 287 // free all keys which have no active voices left
548     {
549 schoenebeck 411 RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
550     RTList<uint>::Iterator end = pEngineChannel->pActiveKeys->end();
551 schoenebeck 287 while (iuiKey != end) { // iterate through all active keys
552 schoenebeck 411 midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
553 schoenebeck 287 ++iuiKey;
554 schoenebeck 411 if (pKey->pActiveVoices->isEmpty()) FreeKey(pEngineChannel, pKey);
555 schoenebeck 554 #if CONFIG_DEVMODE
556 schoenebeck 563 else { // just a sanity check for debugging
557 schoenebeck 287 RTList<Voice>::Iterator itVoice = pKey->pActiveVoices->first();
558     RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
559     for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
560     if (itVoice->itKillEvent) {
561     dmsg(1,("gig::Engine: ERROR, killed voice survived !!!\n"));
562     }
563     }
564     }
565 schoenebeck 554 #endif // CONFIG_DEVMODE
566 schoenebeck 287 }
567     }
568 schoenebeck 460
569     // empty the engine channel's own event lists
570     pEngineChannel->ClearEventLists();
571 schoenebeck 412 }
572 schoenebeck 287
573 schoenebeck 53 /**
574 schoenebeck 244 * Will be called by the MIDI input device whenever a MIDI system
575     * exclusive message has arrived.
576     *
577     * @param pData - pointer to sysex data
578     * @param Size - lenght of sysex data (in bytes)
579     */
580     void Engine::SendSysex(void* pData, uint Size) {
581 schoenebeck 246 Event event = pEventGenerator->CreateEvent();
582     event.Type = Event::type_sysex;
583     event.Param.Sysex.Size = Size;
584 schoenebeck 412 event.pEngineChannel = NULL; // as Engine global event
585 schoenebeck 244 if (pEventQueue->write_space() > 0) {
586     if (pSysexBuffer->write_space() >= Size) {
587     // copy sysex data to input buffer
588     uint toWrite = Size;
589     uint8_t* pPos = (uint8_t*) pData;
590     while (toWrite) {
591     const uint writeNow = RTMath::Min(toWrite, pSysexBuffer->write_space_to_end());
592     pSysexBuffer->write(pPos, writeNow);
593     toWrite -= writeNow;
594     pPos += writeNow;
595    
596     }
597     // finally place sysex event into input event queue
598     pEventQueue->push(&event);
599     }
600 schoenebeck 554 else dmsg(1,("Engine: Sysex message too large (%d byte) for input buffer (%d byte)!",Size,CONFIG_SYSEX_BUFFER_SIZE));
601 schoenebeck 244 }
602     else dmsg(1,("Engine: Input event queue full!"));
603     }
604    
605     /**
606 schoenebeck 53 * Assigns and triggers a new voice for the respective MIDI key.
607     *
608 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
609 schoenebeck 271 * @param itNoteOnEvent - key, velocity and time stamp of the event
610 schoenebeck 53 */
611 schoenebeck 411 void Engine::ProcessNoteOn(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOnEvent) {
612 persson 438
613 schoenebeck 354 const int key = itNoteOnEvent->Param.Note.Key;
614    
615     // Change key dimension value if key is in keyswitching area
616 schoenebeck 411 {
617     const ::gig::Instrument* pInstrument = pEngineChannel->pInstrument;
618     if (key >= pInstrument->DimensionKeyRange.low && key <= pInstrument->DimensionKeyRange.high)
619     pEngineChannel->CurrentKeyDimension = ((key - pInstrument->DimensionKeyRange.low) * 128) /
620     (pInstrument->DimensionKeyRange.high - pInstrument->DimensionKeyRange.low + 1);
621     }
622 schoenebeck 354
623 schoenebeck 411 midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[key];
624 schoenebeck 354
625 schoenebeck 53 pKey->KeyPressed = true; // the MIDI key was now pressed down
626 persson 630 pKey->Velocity = itNoteOnEvent->Param.Note.Velocity;
627     pKey->NoteOnTime = FrameTime + itNoteOnEvent->FragmentPos(); // will be used to calculate note length
628 schoenebeck 53
629     // cancel release process of voices on this key if needed
630 schoenebeck 411 if (pKey->Active && !pEngineChannel->SustainPedal) {
631 schoenebeck 271 RTList<Event>::Iterator itCancelReleaseEvent = pKey->pEvents->allocAppend();
632     if (itCancelReleaseEvent) {
633     *itCancelReleaseEvent = *itNoteOnEvent; // copy event
634     itCancelReleaseEvent->Type = Event::type_cancel_release; // transform event type
635 schoenebeck 239 }
636     else dmsg(1,("Event pool emtpy!\n"));
637 schoenebeck 53 }
638    
639 schoenebeck 271 // move note on event to the key's own event list
640     RTList<Event>::Iterator itNoteOnEventOnKeyList = itNoteOnEvent.moveToEndOf(pKey->pEvents);
641    
642 schoenebeck 460 // allocate and trigger new voice(s) for the key
643     {
644     // first, get total amount of required voices (dependant on amount of layers)
645     ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(itNoteOnEventOnKeyList->Param.Note.Key);
646     if (pRegion) {
647     int voicesRequired = pRegion->Layers;
648     // now launch the required amount of voices
649     for (int i = 0; i < voicesRequired; i++)
650 schoenebeck 668 LaunchVoice(pEngineChannel, itNoteOnEventOnKeyList, i, false, true, true);
651 schoenebeck 460 }
652     }
653 persson 438
654 schoenebeck 473 // if neither a voice was spawned or postponed then remove note on event from key again
655     if (!pKey->Active && !pKey->VoiceTheftsQueued)
656     pKey->pEvents->free(itNoteOnEventOnKeyList);
657    
658 persson 438 pKey->RoundRobinIndex++;
659 schoenebeck 53 }
660    
661     /**
662     * Releases the voices on the given key if sustain pedal is not pressed.
663     * If sustain is pressed, the release of the note will be postponed until
664     * sustain pedal will be released or voice turned inactive by itself (e.g.
665     * due to completion of sample playback).
666     *
667 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
668 schoenebeck 271 * @param itNoteOffEvent - key, velocity and time stamp of the event
669 schoenebeck 53 */
670 schoenebeck 411 void Engine::ProcessNoteOff(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOffEvent) {
671     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[itNoteOffEvent->Param.Note.Key];
672 schoenebeck 53
673     pKey->KeyPressed = false; // the MIDI key was now released
674    
675     // release voices on this key if needed
676 schoenebeck 411 if (pKey->Active && !pEngineChannel->SustainPedal) {
677 schoenebeck 271 itNoteOffEvent->Type = Event::type_release; // transform event type
678 schoenebeck 242
679 persson 497 // move event to the key's own event list
680     RTList<Event>::Iterator itNoteOffEventOnKeyList = itNoteOffEvent.moveToEndOf(pKey->pEvents);
681 schoenebeck 271
682 persson 497 // spawn release triggered voice(s) if needed
683 persson 630 if (pKey->ReleaseTrigger) {
684 persson 497 // first, get total amount of required voices (dependant on amount of layers)
685     ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(itNoteOffEventOnKeyList->Param.Note.Key);
686     if (pRegion) {
687     int voicesRequired = pRegion->Layers;
688 persson 630
689     // MIDI note-on velocity is used instead of note-off velocity
690     itNoteOffEventOnKeyList->Param.Note.Velocity = pKey->Velocity;
691    
692 persson 497 // now launch the required amount of voices
693     for (int i = 0; i < voicesRequired; i++)
694 schoenebeck 668 LaunchVoice(pEngineChannel, itNoteOffEventOnKeyList, i, true, false, false); //FIXME: for the moment we don't perform voice stealing for release triggered samples
695 persson 497 }
696     pKey->ReleaseTrigger = false;
697 schoenebeck 460 }
698 persson 497
699     // if neither a voice was spawned or postponed then remove note off event from key again
700     if (!pKey->Active && !pKey->VoiceTheftsQueued)
701     pKey->pEvents->free(itNoteOffEventOnKeyList);
702 schoenebeck 242 }
703 schoenebeck 53 }
704    
705     /**
706     * Moves pitchbend event from the general (input) event list to the pitch
707     * event list.
708     *
709 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
710 schoenebeck 271 * @param itPitchbendEvent - absolute pitch value and time stamp of the event
711 schoenebeck 53 */
712 schoenebeck 411 void Engine::ProcessPitchbend(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itPitchbendEvent) {
713     pEngineChannel->Pitch = itPitchbendEvent->Param.Pitch.Pitch; // store current pitch value
714 schoenebeck 460 itPitchbendEvent.moveToEndOf(pEngineChannel->pSynthesisEvents[Event::destination_vco]);
715 schoenebeck 53 }
716    
717     /**
718 schoenebeck 233 * Allocates and triggers a new voice. This method will usually be
719     * called by the ProcessNoteOn() method and by the voices itself
720     * (e.g. to spawn further voices on the same key for layered sounds).
721     *
722 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
723 schoenebeck 271 * @param itNoteOnEvent - key, velocity and time stamp of the event
724 schoenebeck 242 * @param iLayer - layer index for the new voice (optional - only
725     * in case of layered sounds of course)
726     * @param ReleaseTriggerVoice - if new voice is a release triggered voice
727     * (optional, default = false)
728 schoenebeck 250 * @param VoiceStealing - if voice stealing should be performed
729     * when there is no free voice
730     * (optional, default = true)
731 schoenebeck 668 * @param HandleKeyGroupConflicts - if voices should be killed due to a
732     * key group conflict
733 schoenebeck 250 * @returns pointer to new voice or NULL if there was no free voice or
734 schoenebeck 354 * if the voice wasn't triggered (for example when no region is
735     * defined for the given key).
736 schoenebeck 233 */
737 schoenebeck 668 Pool<Voice>::Iterator Engine::LaunchVoice(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOnEvent, int iLayer, bool ReleaseTriggerVoice, bool VoiceStealing, bool HandleKeyGroupConflicts) {
738     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[itNoteOnEvent->Param.Note.Key];
739     ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(itNoteOnEvent->Param.Note.Key);
740 schoenebeck 233
741 schoenebeck 668 // if nothing defined for this key
742     if (!pRegion) return Pool<Voice>::Iterator(); // nothing to do
743    
744     // handle key group (a.k.a. exclusive group) conflicts
745     if (HandleKeyGroupConflicts) {
746     // only mark the first voice of a layered voice (group) to be in a
747     // key group, so the layered voices won't kill each other
748     int iKeyGroup = (iLayer == 0 && !ReleaseTriggerVoice) ? pRegion->KeyGroup : 0;
749     if (iKeyGroup) { // if this voice / key belongs to a key group
750     uint** ppKeyGroup = &pEngineChannel->ActiveKeyGroups[iKeyGroup];
751     if (*ppKeyGroup) { // if there's already an active key in that key group
752     midi_key_info_t* pOtherKey = &pEngineChannel->pMIDIKeyInfo[**ppKeyGroup];
753     // kill all voices on the (other) key
754     RTList<Voice>::Iterator itVoiceToBeKilled = pOtherKey->pActiveVoices->first();
755     RTList<Voice>::Iterator end = pOtherKey->pActiveVoices->end();
756     for (; itVoiceToBeKilled != end; ++itVoiceToBeKilled) {
757     if (itVoiceToBeKilled->Type != Voice::type_release_trigger) {
758     itVoiceToBeKilled->Kill(itNoteOnEvent);
759     --VoiceSpawnsLeft; //FIXME: just a hack, we should better check in StealVoice() if the voice was killed due to key conflict
760     }
761     }
762     }
763     }
764     }
765    
766 schoenebeck 233 // allocate a new voice for the key
767 schoenebeck 271 Pool<Voice>::Iterator itNewVoice = pKey->pActiveVoices->allocAppend();
768     if (itNewVoice) {
769 schoenebeck 233 // launch the new voice
770 schoenebeck 411 if (itNewVoice->Trigger(pEngineChannel, itNoteOnEvent, pEngineChannel->Pitch, pEngineChannel->pInstrument, iLayer, ReleaseTriggerVoice, VoiceStealing) < 0) {
771 schoenebeck 354 dmsg(4,("Voice not triggered\n"));
772 schoenebeck 271 pKey->pActiveVoices->free(itNewVoice);
773 schoenebeck 233 }
774 schoenebeck 239 else { // on success
775 schoenebeck 663 --VoiceSpawnsLeft;
776 schoenebeck 239 if (!pKey->Active) { // mark as active key
777     pKey->Active = true;
778 schoenebeck 411 pKey->itSelf = pEngineChannel->pActiveKeys->allocAppend();
779 schoenebeck 271 *pKey->itSelf = itNoteOnEvent->Param.Note.Key;
780 schoenebeck 239 }
781 schoenebeck 271 if (itNewVoice->KeyGroup) {
782 schoenebeck 668 uint** ppKeyGroup = &pEngineChannel->ActiveKeyGroups[itNewVoice->KeyGroup];
783 schoenebeck 271 *ppKeyGroup = &*pKey->itSelf; // put key as the (new) active key to its key group
784 schoenebeck 239 }
785 schoenebeck 271 if (itNewVoice->Type == Voice::type_release_trigger_required) pKey->ReleaseTrigger = true; // mark key for the need of release triggered voice(s)
786     return itNewVoice; // success
787 schoenebeck 233 }
788     }
789 schoenebeck 285 else if (VoiceStealing) {
790 schoenebeck 460 // try to steal one voice
791 schoenebeck 473 int result = StealVoice(pEngineChannel, itNoteOnEvent);
792     if (!result) { // voice stolen successfully
793     // put note-on event into voice-stealing queue, so it will be reprocessed after killed voice died
794     RTList<Event>::Iterator itStealEvent = pVoiceStealingQueue->allocAppend();
795     if (itStealEvent) {
796     *itStealEvent = *itNoteOnEvent; // copy event
797     itStealEvent->Param.Note.Layer = iLayer;
798     itStealEvent->Param.Note.ReleaseTrigger = ReleaseTriggerVoice;
799     pKey->VoiceTheftsQueued++;
800     }
801     else dmsg(1,("Voice stealing queue full!\n"));
802 schoenebeck 285 }
803     }
804    
805 schoenebeck 271 return Pool<Voice>::Iterator(); // no free voice or error
806 schoenebeck 233 }
807    
808     /**
809 schoenebeck 250 * Will be called by LaunchVoice() method in case there are no free
810     * voices left. This method will select and kill one old voice for
811     * voice stealing and postpone the note-on event until the selected
812     * voice actually died.
813     *
814 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
815 schoenebeck 285 * @param itNoteOnEvent - key, velocity and time stamp of the event
816 schoenebeck 473 * @returns 0 on success, a value < 0 if no active voice could be picked for voice stealing
817 schoenebeck 250 */
818 schoenebeck 473 int Engine::StealVoice(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOnEvent) {
819 schoenebeck 663 if (VoiceSpawnsLeft <= 0) {
820 schoenebeck 554 dmsg(1,("Max. voice thefts per audio fragment reached (you may raise CONFIG_MAX_VOICES).\n"));
821 schoenebeck 473 return -1;
822 schoenebeck 460 }
823 schoenebeck 271 if (!pEventPool->poolIsEmpty()) {
824 schoenebeck 250
825 schoenebeck 460 RTList<Voice>::Iterator itSelectedVoice;
826 schoenebeck 250
827     // Select one voice for voice stealing
828 schoenebeck 554 switch (CONFIG_VOICE_STEAL_ALGO) {
829 schoenebeck 250
830     // try to pick the oldest voice on the key where the new
831     // voice should be spawned, if there is no voice on that
832 schoenebeck 563 // key, or no voice left to kill, then procceed with
833 schoenebeck 250 // 'oldestkey' algorithm
834 schoenebeck 460 case voice_steal_algo_oldestvoiceonkey: {
835     midi_key_info_t* pSelectedKey = &pEngineChannel->pMIDIKeyInfo[itNoteOnEvent->Param.Note.Key];
836 schoenebeck 563 itSelectedVoice = pSelectedKey->pActiveVoices->first();
837     // proceed iterating if voice was created in this fragment cycle
838 schoenebeck 663 while (itSelectedVoice && !itSelectedVoice->IsStealable()) ++itSelectedVoice;
839 schoenebeck 563 // if we haven't found a voice then proceed with algorithm 'oldestkey'
840 schoenebeck 663 if (itSelectedVoice && itSelectedVoice->IsStealable()) break;
841 schoenebeck 250 } // no break - intentional !
842    
843     // try to pick the oldest voice on the oldest active key
844 schoenebeck 563 // from the same engine channel
845 schoenebeck 460 // (caution: must stay after 'oldestvoiceonkey' algorithm !)
846 schoenebeck 250 case voice_steal_algo_oldestkey: {
847 schoenebeck 649 // if we already stole in this fragment, try to proceed on same key
848 schoenebeck 460 if (this->itLastStolenVoice) {
849     itSelectedVoice = this->itLastStolenVoice;
850 schoenebeck 649 do {
851     ++itSelectedVoice;
852 schoenebeck 663 } while (itSelectedVoice && !itSelectedVoice->IsStealable()); // proceed iterating if voice was created in this fragment cycle
853 schoenebeck 649 // found a "stealable" voice ?
854 schoenebeck 663 if (itSelectedVoice && itSelectedVoice->IsStealable()) {
855 schoenebeck 649 // remember which voice we stole, so we can simply proceed on next voice stealing
856     this->itLastStolenVoice = itSelectedVoice;
857 schoenebeck 460 break; // selection succeeded
858 schoenebeck 250 }
859     }
860 schoenebeck 649 // get (next) oldest key
861     RTList<uint>::Iterator iuiSelectedKey = (this->iuiLastStolenKey) ? ++this->iuiLastStolenKey : pEngineChannel->pActiveKeys->first();
862     while (iuiSelectedKey) {
863     midi_key_info_t* pSelectedKey = &pEngineChannel->pMIDIKeyInfo[*iuiSelectedKey];
864 schoenebeck 659 itSelectedVoice = pSelectedKey->pActiveVoices->first();
865 schoenebeck 649 // proceed iterating if voice was created in this fragment cycle
866 schoenebeck 663 while (itSelectedVoice && !itSelectedVoice->IsStealable()) ++itSelectedVoice;
867 schoenebeck 649 // found a "stealable" voice ?
868 schoenebeck 663 if (itSelectedVoice && itSelectedVoice->IsStealable()) {
869 schoenebeck 649 // remember which voice on which key we stole, so we can simply proceed on next voice stealing
870     this->iuiLastStolenKey = iuiSelectedKey;
871     this->itLastStolenVoice = itSelectedVoice;
872     break; // selection succeeded
873     }
874     ++iuiSelectedKey; // get next oldest key
875     }
876 schoenebeck 250 break;
877     }
878    
879     // don't steal anything
880     case voice_steal_algo_none:
881     default: {
882     dmsg(1,("No free voice (voice stealing disabled)!\n"));
883 schoenebeck 473 return -1;
884 schoenebeck 250 }
885     }
886    
887 schoenebeck 563 // if we couldn't steal a voice from the same engine channel then
888     // steal oldest voice on the oldest key from any other engine channel
889 schoenebeck 649 // (the smaller engine channel number, the higher priority)
890 schoenebeck 663 if (!itSelectedVoice || !itSelectedVoice->IsStealable()) {
891 schoenebeck 649 EngineChannel* pSelectedChannel;
892     int iChannelIndex;
893     // select engine channel
894     if (pLastStolenChannel) {
895     pSelectedChannel = pLastStolenChannel;
896     iChannelIndex = pSelectedChannel->iEngineIndexSelf;
897     } else { // pick the engine channel followed by this engine channel
898     iChannelIndex = (pEngineChannel->iEngineIndexSelf + 1) % engineChannels.size();
899     pSelectedChannel = engineChannels[iChannelIndex];
900     }
901 schoenebeck 663
902     // if we already stole in this fragment, try to proceed on same key
903     if (this->itLastStolenVoiceGlobally) {
904     itSelectedVoice = this->itLastStolenVoiceGlobally;
905     do {
906     ++itSelectedVoice;
907     } while (itSelectedVoice && !itSelectedVoice->IsStealable()); // proceed iterating if voice was created in this fragment cycle
908     }
909    
910     #if CONFIG_DEVMODE
911     EngineChannel* pBegin = pSelectedChannel; // to detect endless loop
912     #endif // CONFIG_DEVMODE
913    
914     // did we find a 'stealable' voice?
915     if (itSelectedVoice && itSelectedVoice->IsStealable()) {
916     // remember which voice we stole, so we can simply proceed on next voice stealing
917     this->itLastStolenVoiceGlobally = itSelectedVoice;
918     } else while (true) { // iterate through engine channels
919 schoenebeck 649 // get (next) oldest key
920 schoenebeck 663 RTList<uint>::Iterator iuiSelectedKey = (this->iuiLastStolenKeyGlobally) ? ++this->iuiLastStolenKeyGlobally : pSelectedChannel->pActiveKeys->first();
921     this->iuiLastStolenKeyGlobally = RTList<uint>::Iterator(); // to prevent endless loop (see line above)
922 schoenebeck 649 while (iuiSelectedKey) {
923 schoenebeck 663 midi_key_info_t* pSelectedKey = &pSelectedChannel->pMIDIKeyInfo[*iuiSelectedKey];
924 schoenebeck 649 itSelectedVoice = pSelectedKey->pActiveVoices->first();
925     // proceed iterating if voice was created in this fragment cycle
926 schoenebeck 663 while (itSelectedVoice && !itSelectedVoice->IsStealable()) ++itSelectedVoice;
927 schoenebeck 649 // found a "stealable" voice ?
928 schoenebeck 663 if (itSelectedVoice && itSelectedVoice->IsStealable()) {
929 schoenebeck 649 // remember which voice on which key on which engine channel we stole, so we can simply proceed on next voice stealing
930     this->iuiLastStolenKeyGlobally = iuiSelectedKey;
931     this->itLastStolenVoiceGlobally = itSelectedVoice;
932     this->pLastStolenChannel = pSelectedChannel;
933 schoenebeck 665 goto stealable_voice_found; // selection succeeded
934 schoenebeck 649 }
935     ++iuiSelectedKey; // get next key on current engine channel
936     }
937     // get next engine channel
938 schoenebeck 460 iChannelIndex = (iChannelIndex + 1) % engineChannels.size();
939 schoenebeck 649 pSelectedChannel = engineChannels[iChannelIndex];
940 schoenebeck 663
941     #if CONFIG_DEVMODE
942     if (pSelectedChannel == pBegin) {
943     dmsg(1,("FATAL ERROR: voice stealing endless loop!\n"));
944     dmsg(1,("VoiceSpawnsLeft=%d.\n", VoiceSpawnsLeft));
945     dmsg(1,("Exiting.\n"));
946     exit(-1);
947     }
948     #endif // CONFIG_DEVMODE
949 schoenebeck 460 }
950     }
951    
952 schoenebeck 665 // jump point if a 'stealable' voice was found
953     stealable_voice_found:
954    
955 schoenebeck 563 #if CONFIG_DEVMODE
956 schoenebeck 473 if (!itSelectedVoice->IsActive()) {
957     dmsg(1,("gig::Engine: ERROR, tried to steal a voice which was not active !!!\n"));
958     return -1;
959     }
960 schoenebeck 563 #endif // CONFIG_DEVMODE
961 schoenebeck 287
962 schoenebeck 250 // now kill the selected voice
963 schoenebeck 659 itSelectedVoice->Kill(itNoteOnEvent);
964 schoenebeck 460
965 schoenebeck 663 --VoiceSpawnsLeft;
966 schoenebeck 473
967     return 0; // success
968 schoenebeck 250 }
969 schoenebeck 473 else {
970     dmsg(1,("Event pool emtpy!\n"));
971     return -1;
972     }
973 schoenebeck 250 }
974    
975     /**
976 schoenebeck 285 * Removes the given voice from the MIDI key's list of active voices.
977     * This method will be called when a voice went inactive, e.g. because
978     * it finished to playback its sample, finished its release stage or
979     * just was killed.
980 schoenebeck 53 *
981 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
982 schoenebeck 285 * @param itVoice - points to the voice to be freed
983 schoenebeck 53 */
984 schoenebeck 411 void Engine::FreeVoice(EngineChannel* pEngineChannel, Pool<Voice>::Iterator& itVoice) {
985 schoenebeck 271 if (itVoice) {
986 schoenebeck 411 midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[itVoice->MIDIKey];
987 schoenebeck 53
988 schoenebeck 271 uint keygroup = itVoice->KeyGroup;
989    
990 schoenebeck 53 // free the voice object
991 schoenebeck 271 pVoicePool->free(itVoice);
992 schoenebeck 53
993 schoenebeck 287 // if no other voices left and member of a key group, remove from key group
994     if (pKey->pActiveVoices->isEmpty() && keygroup) {
995 schoenebeck 411 uint** ppKeyGroup = &pEngineChannel->ActiveKeyGroups[keygroup];
996 schoenebeck 287 if (*ppKeyGroup == &*pKey->itSelf) *ppKeyGroup = NULL; // remove key from key group
997 schoenebeck 53 }
998     }
999 schoenebeck 285 else std::cerr << "Couldn't release voice! (!itVoice)\n" << std::flush;
1000 schoenebeck 53 }
1001    
1002     /**
1003 schoenebeck 287 * Called when there's no more voice left on a key, this call will
1004     * update the key info respectively.
1005     *
1006 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
1007 schoenebeck 287 * @param pKey - key which is now inactive
1008     */
1009 schoenebeck 411 void Engine::FreeKey(EngineChannel* pEngineChannel, midi_key_info_t* pKey) {
1010 schoenebeck 287 if (pKey->pActiveVoices->isEmpty()) {
1011     pKey->Active = false;
1012 schoenebeck 411 pEngineChannel->pActiveKeys->free(pKey->itSelf); // remove key from list of active keys
1013 schoenebeck 287 pKey->itSelf = RTList<uint>::Iterator();
1014     pKey->ReleaseTrigger = false;
1015     pKey->pEvents->clear();
1016     dmsg(3,("Key has no more voices now\n"));
1017     }
1018     else dmsg(1,("gig::Engine: Oops, tried to free a key which contains voices.\n"));
1019     }
1020    
1021     /**
1022 schoenebeck 53 * Reacts on supported control change commands (e.g. pitch bend wheel,
1023     * modulation wheel, aftertouch).
1024     *
1025 schoenebeck 411 * @param pEngineChannel - engine channel on which this event occured on
1026 schoenebeck 271 * @param itControlChangeEvent - controller, value and time stamp of the event
1027 schoenebeck 53 */
1028 schoenebeck 411 void Engine::ProcessControlChange(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itControlChangeEvent) {
1029 schoenebeck 271 dmsg(4,("Engine::ContinuousController cc=%d v=%d\n", itControlChangeEvent->Param.CC.Controller, itControlChangeEvent->Param.CC.Value));
1030 schoenebeck 53
1031 schoenebeck 473 // update controller value in the engine channel's controller table
1032     pEngineChannel->ControllerTable[itControlChangeEvent->Param.CC.Controller] = itControlChangeEvent->Param.CC.Value;
1033    
1034     // move event from the unsorted event list to the control change event list
1035     Pool<Event>::Iterator itControlChangeEventOnCCList = itControlChangeEvent.moveToEndOf(pEngineChannel->pCCEvents);
1036    
1037     switch (itControlChangeEventOnCCList->Param.CC.Controller) {
1038 schoenebeck 424 case 7: { // volume
1039     //TODO: not sample accurate yet
1040 schoenebeck 473 pEngineChannel->GlobalVolume = (float) itControlChangeEventOnCCList->Param.CC.Value / 127.0f;
1041 schoenebeck 660 pEngineChannel->bStatusChanged = true; // engine channel status has changed, so set notify flag
1042 schoenebeck 424 break;
1043     }
1044     case 10: { // panpot
1045     //TODO: not sample accurate yet
1046 schoenebeck 473 const int pan = (int) itControlChangeEventOnCCList->Param.CC.Value - 64;
1047 schoenebeck 424 pEngineChannel->GlobalPanLeft = 1.0f - float(RTMath::Max(pan, 0)) / 63.0f;
1048     pEngineChannel->GlobalPanRight = 1.0f - float(RTMath::Min(pan, 0)) / -64.0f;
1049     break;
1050     }
1051     case 64: { // sustain
1052 schoenebeck 473 if (itControlChangeEventOnCCList->Param.CC.Value >= 64 && !pEngineChannel->SustainPedal) {
1053 schoenebeck 53 dmsg(4,("PEDAL DOWN\n"));
1054 schoenebeck 411 pEngineChannel->SustainPedal = true;
1055 schoenebeck 53
1056     // cancel release process of voices if necessary
1057 schoenebeck 411 RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
1058 schoenebeck 473 for (; iuiKey; ++iuiKey) {
1059     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
1060     if (!pKey->KeyPressed) {
1061     RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
1062     if (itNewEvent) {
1063     *itNewEvent = *itControlChangeEventOnCCList; // copy event to the key's own event list
1064     itNewEvent->Type = Event::type_cancel_release; // transform event type
1065 schoenebeck 53 }
1066 schoenebeck 473 else dmsg(1,("Event pool emtpy!\n"));
1067 schoenebeck 53 }
1068     }
1069     }
1070 schoenebeck 473 if (itControlChangeEventOnCCList->Param.CC.Value < 64 && pEngineChannel->SustainPedal) {
1071 schoenebeck 53 dmsg(4,("PEDAL UP\n"));
1072 schoenebeck 411 pEngineChannel->SustainPedal = false;
1073 schoenebeck 53
1074     // release voices if their respective key is not pressed
1075 schoenebeck 411 RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
1076 schoenebeck 473 for (; iuiKey; ++iuiKey) {
1077     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
1078     if (!pKey->KeyPressed) {
1079     RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
1080     if (itNewEvent) {
1081     *itNewEvent = *itControlChangeEventOnCCList; // copy event to the key's own event list
1082     itNewEvent->Type = Event::type_release; // transform event type
1083 schoenebeck 53 }
1084 schoenebeck 473 else dmsg(1,("Event pool emtpy!\n"));
1085 schoenebeck 53 }
1086     }
1087     }
1088     break;
1089     }
1090    
1091    
1092 schoenebeck 473 // Channel Mode Messages
1093    
1094     case 120: { // all sound off
1095     KillAllVoices(pEngineChannel, itControlChangeEventOnCCList);
1096     break;
1097     }
1098     case 121: { // reset all controllers
1099     pEngineChannel->ResetControllers();
1100     break;
1101     }
1102     case 123: { // all notes off
1103     ReleaseAllVoices(pEngineChannel, itControlChangeEventOnCCList);
1104     break;
1105     }
1106     }
1107 schoenebeck 53 }
1108    
1109     /**
1110 schoenebeck 244 * Reacts on MIDI system exclusive messages.
1111     *
1112 schoenebeck 271 * @param itSysexEvent - sysex data size and time stamp of the sysex event
1113 schoenebeck 244 */
1114 schoenebeck 271 void Engine::ProcessSysex(Pool<Event>::Iterator& itSysexEvent) {
1115 schoenebeck 244 RingBuffer<uint8_t>::NonVolatileReader reader = pSysexBuffer->get_non_volatile_reader();
1116    
1117     uint8_t exclusive_status, id;
1118     if (!reader.pop(&exclusive_status)) goto free_sysex_data;
1119     if (!reader.pop(&id)) goto free_sysex_data;
1120     if (exclusive_status != 0xF0) goto free_sysex_data;
1121    
1122     switch (id) {
1123     case 0x41: { // Roland
1124 schoenebeck 493 dmsg(3,("Roland Sysex\n"));
1125 schoenebeck 244 uint8_t device_id, model_id, cmd_id;
1126     if (!reader.pop(&device_id)) goto free_sysex_data;
1127     if (!reader.pop(&model_id)) goto free_sysex_data;
1128     if (!reader.pop(&cmd_id)) goto free_sysex_data;
1129     if (model_id != 0x42 /*GS*/) goto free_sysex_data;
1130     if (cmd_id != 0x12 /*DT1*/) goto free_sysex_data;
1131    
1132     // command address
1133     uint8_t addr[3]; // 2 byte addr MSB, followed by 1 byte addr LSB)
1134     const RingBuffer<uint8_t>::NonVolatileReader checksum_reader = reader; // so we can calculate the check sum later
1135     if (reader.read(&addr[0], 3) != 3) goto free_sysex_data;
1136     if (addr[0] == 0x40 && addr[1] == 0x00) { // System Parameters
1137 schoenebeck 493 dmsg(3,("\tSystem Parameter\n"));
1138 schoenebeck 244 }
1139     else if (addr[0] == 0x40 && addr[1] == 0x01) { // Common Parameters
1140 schoenebeck 493 dmsg(3,("\tCommon Parameter\n"));
1141 schoenebeck 244 }
1142     else if (addr[0] == 0x40 && (addr[1] & 0xf0) == 0x10) { // Part Parameters (1)
1143 schoenebeck 493 dmsg(3,("\tPart Parameter\n"));
1144     switch (addr[2]) {
1145 schoenebeck 244 case 0x40: { // scale tuning
1146 schoenebeck 493 dmsg(3,("\t\tScale Tuning\n"));
1147 schoenebeck 244 uint8_t scale_tunes[12]; // detuning of all 12 semitones of an octave
1148     if (reader.read(&scale_tunes[0], 12) != 12) goto free_sysex_data;
1149     uint8_t checksum;
1150 schoenebeck 493 if (!reader.pop(&checksum)) goto free_sysex_data;
1151 schoenebeck 563 #if CONFIG_ASSERT_GS_SYSEX_CHECKSUM
1152     if (GSCheckSum(checksum_reader, 12)) goto free_sysex_data;
1153     #endif // CONFIG_ASSERT_GS_SYSEX_CHECKSUM
1154 schoenebeck 244 for (int i = 0; i < 12; i++) scale_tunes[i] -= 64;
1155     AdjustScale((int8_t*) scale_tunes);
1156 schoenebeck 493 dmsg(3,("\t\t\tNew scale applied.\n"));
1157 schoenebeck 244 break;
1158     }
1159     }
1160     }
1161     else if (addr[0] == 0x40 && (addr[1] & 0xf0) == 0x20) { // Part Parameters (2)
1162     }
1163     else if (addr[0] == 0x41) { // Drum Setup Parameters
1164     }
1165     break;
1166     }
1167     }
1168    
1169     free_sysex_data: // finally free sysex data
1170 schoenebeck 271 pSysexBuffer->increment_read_ptr(itSysexEvent->Param.Sysex.Size);
1171 schoenebeck 244 }
1172    
1173     /**
1174     * Calculates the Roland GS sysex check sum.
1175     *
1176     * @param AddrReader - reader which currently points to the first GS
1177     * command address byte of the GS sysex message in
1178     * question
1179     * @param DataSize - size of the GS message data (in bytes)
1180     */
1181     uint8_t Engine::GSCheckSum(const RingBuffer<uint8_t>::NonVolatileReader AddrReader, uint DataSize) {
1182     RingBuffer<uint8_t>::NonVolatileReader reader = AddrReader;
1183     uint bytes = 3 /*addr*/ + DataSize;
1184     uint8_t addr_and_data[bytes];
1185     reader.read(&addr_and_data[0], bytes);
1186     uint8_t sum = 0;
1187     for (uint i = 0; i < bytes; i++) sum += addr_and_data[i];
1188     return 128 - sum % 128;
1189     }
1190    
1191     /**
1192     * Allows to tune each of the twelve semitones of an octave.
1193     *
1194     * @param ScaleTunes - detuning of all twelve semitones (in cents)
1195     */
1196     void Engine::AdjustScale(int8_t ScaleTunes[12]) {
1197     memcpy(&this->ScaleTuning[0], &ScaleTunes[0], 12); //TODO: currently not sample accurate
1198     }
1199    
1200     /**
1201 schoenebeck 473 * Releases all voices on an engine channel. All voices will go into
1202     * the release stage and thus it might take some time (e.g. dependant to
1203     * their envelope release time) until they actually die.
1204     *
1205     * @param pEngineChannel - engine channel on which all voices should be released
1206     * @param itReleaseEvent - event which caused this releasing of all voices
1207     */
1208     void Engine::ReleaseAllVoices(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itReleaseEvent) {
1209     RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
1210     while (iuiKey) {
1211     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
1212     ++iuiKey;
1213     // append a 'release' event to the key's own event list
1214     RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
1215     if (itNewEvent) {
1216     *itNewEvent = *itReleaseEvent; // copy original event (to the key's event list)
1217     itNewEvent->Type = Event::type_release; // transform event type
1218     }
1219     else dmsg(1,("Event pool emtpy!\n"));
1220     }
1221     }
1222    
1223     /**
1224     * Kills all voices on an engine channel as soon as possible. Voices
1225     * won't get into release state, their volume level will be ramped down
1226     * as fast as possible.
1227     *
1228     * @param pEngineChannel - engine channel on which all voices should be killed
1229     * @param itKillEvent - event which caused this killing of all voices
1230     */
1231     void Engine::KillAllVoices(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itKillEvent) {
1232     RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
1233     RTList<uint>::Iterator end = pEngineChannel->pActiveKeys->end();
1234     while (iuiKey != end) { // iterate through all active keys
1235     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
1236     ++iuiKey;
1237     RTList<Voice>::Iterator itVoice = pKey->pActiveVoices->first();
1238     RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
1239     for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
1240     itVoice->Kill(itKillEvent);
1241 schoenebeck 663 --VoiceSpawnsLeft; //FIXME: just a temporary workaround, we should check the cause in StealVoice() instead
1242 schoenebeck 473 }
1243     }
1244     }
1245    
1246     /**
1247 schoenebeck 53 * Initialize the parameter sequence for the modulation destination given by
1248     * by 'dst' with the constant value given by val.
1249     */
1250     void Engine::ResetSynthesisParameters(Event::destination_t dst, float val) {
1251     int maxsamples = pAudioOutputDevice->MaxSamplesPerCycle();
1252 schoenebeck 80 float* m = &pSynthesisParameters[dst][0];
1253     for (int i = 0; i < maxsamples; i += 4) {
1254     m[i] = val;
1255     m[i+1] = val;
1256     m[i+2] = val;
1257     m[i+3] = val;
1258     }
1259 persson 438 }
1260 schoenebeck 53
1261     uint Engine::VoiceCount() {
1262     return ActiveVoiceCount;
1263     }
1264    
1265     uint Engine::VoiceCountMax() {
1266     return ActiveVoiceCountMax;
1267     }
1268    
1269     bool Engine::DiskStreamSupported() {
1270     return true;
1271     }
1272    
1273     uint Engine::DiskStreamCount() {
1274     return (pDiskThread) ? pDiskThread->ActiveStreamCount : 0;
1275     }
1276    
1277     uint Engine::DiskStreamCountMax() {
1278     return (pDiskThread) ? pDiskThread->ActiveStreamCountMax : 0;
1279     }
1280    
1281     String Engine::DiskStreamBufferFillBytes() {
1282     return pDiskThread->GetBufferFillBytes();
1283     }
1284    
1285     String Engine::DiskStreamBufferFillPercentage() {
1286     return pDiskThread->GetBufferFillPercentage();
1287     }
1288    
1289 senkov 112 String Engine::EngineName() {
1290 schoenebeck 475 return LS_GIG_ENGINE_NAME;
1291 senkov 112 }
1292    
1293 schoenebeck 53 String Engine::Description() {
1294     return "Gigasampler Engine";
1295     }
1296    
1297     String Engine::Version() {
1298 schoenebeck 668 String s = "$Revision: 1.46 $";
1299 schoenebeck 123 return s.substr(11, s.size() - 13); // cut dollar signs, spaces and CVS macro keyword
1300 schoenebeck 53 }
1301    
1302     }} // namespace LinuxSampler::gig

  ViewVC Help
Powered by ViewVC