/[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 563 - (hide annotations) (download)
Sun May 22 20:43:32 2005 UTC (18 years, 10 months ago) by schoenebeck
File size: 55249 byte(s)
* (re)implemented voice stealing algorithm "oldestvoiceonkey" and made it
  the default voice stealing algorithm
* added new LSCP command "GET SERVER INFO" which currently returns
  description and version about this sampler
* added some API documentation comments
* minor cleanup

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

  ViewVC Help
Powered by ViewVC