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

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

Parent Directory Parent Directory | Revision Log Revision Log


Revision 649 - (show annotations) (download)
Wed Jun 15 00:01:28 2005 UTC (12 years, 4 months ago) by schoenebeck
File size: 59443 byte(s)
* revised voice stealing (fixes crash caused by voice stealing)

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

  ViewVC Help
Powered by ViewVC