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

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

Parent Directory | Revision Log | View Patch Patch

-revision 376 by senkov,
Sat Feb 12 23:48:50 2005 UTC
+revision 1933 by persson,
Thu Jul  9 17:37:41 2009 UTC
 Line 2
   *                                                                         *
   *   LinuxSampler - modular, streaming capable sampler                     *
   *                                                                         *
-  *   Copyright (C) 2003, 2004 by Benno Senoner and Christian Schoenebeck   *
+  *   Copyright (C) 2003,2004 by Benno Senoner and Christian Schoenebeck    *
+  *   Copyright (C) 2005-2009 Christian Schoenebeck                         *
   *                                                                         *
   *   This program is free software; you can redistribute it and/or modify  *
   *   it under the terms of the GNU General Public License as published by  *
-Line 24
+Line 25
  #include "DiskThread.h"
  #include "Voice.h"
  #include "EGADSR.h"
+ #include "../EngineFactory.h"
  #include "Engine.h"
- #if defined(__APPLE__)
+ #include "../../common/global_private.h"
- # include <stdlib.h>
- #else
- # include <malloc.h>
- #endif
  namespace LinuxSampler { namespace gig {
-     InstrumentResourceManager Engine::Instruments;
+     InstrumentResourceManager Engine::instruments;
-     Engine::Engine() {
+     std::map<AudioOutputDevice*,Engine*> Engine::engines;
-         pRIFF              = NULL;
-         pGig               = NULL;
+     /**
-         pInstrument        = NULL;
+      * Get a gig::Engine object for the given gig::EngineChannel and the
+      * given AudioOutputDevice. All engine channels which are connected to
+      * the same audio output device will use the same engine instance. This
+      * method will be called by a gig::EngineChannel whenever it's
+      * connecting to a audio output device.
+      *
+      * @param pChannel - engine channel which acquires an engine object
+      * @param pDevice  - the audio output device \a pChannel is connected to
+      */
+     Engine* Engine::AcquireEngine(LinuxSampler::gig::EngineChannel* pChannel, AudioOutputDevice* pDevice) {
+         Engine* pEngine = NULL;
+         // check if there's already an engine for the given audio output device
+         if (engines.count(pDevice)) {
+             dmsg(4,("Using existing gig::Engine.\n"));
+             pEngine = engines[pDevice];
+             // Disable the engine while the new engine channel is
+             // added and initialized. The engine will be enabled again
+             // in EngineChannel::Connect.
+             pEngine->DisableAndLock();
+         } else { // create a new engine (and disk thread) instance for the given audio output device
+             dmsg(4,("Creating new gig::Engine.\n"));
+             pEngine = (Engine*) EngineFactory::Create("gig");
+             pEngine->Connect(pDevice);
+             engines[pDevice] = pEngine;
+         }
+         // register engine channel to the engine instance
+         pEngine->engineChannels.add(pChannel);
+         // remember index in the ArrayList
+         pChannel->iEngineIndexSelf = pEngine->engineChannels.size() - 1;
+         dmsg(4,("This gig::Engine has now %d EngineChannels.\n",pEngine->engineChannels.size()));
+         return pEngine;
+     }
+     /**
+      * Once an engine channel is disconnected from an audio output device,
+      * it will immediately call this method to unregister itself from the
+      * engine instance and if that engine instance is not used by any other
+      * engine channel anymore, then that engine instance will be destroyed.
+      *
+      * @param pChannel - engine channel which wants to disconnect from it's
+      *                   engine instance
+      * @param pDevice  - audio output device \a pChannel was connected to
+      */
+     void Engine::FreeEngine(LinuxSampler::gig::EngineChannel* pChannel, AudioOutputDevice* pDevice) {
+         dmsg(4,("Disconnecting EngineChannel from gig::Engine.\n"));
+         Engine* pEngine = engines[pDevice];
+         // unregister EngineChannel from the Engine instance
+         pEngine->engineChannels.remove(pChannel);
+         // if the used Engine instance is not used anymore, then destroy it
+         if (pEngine->engineChannels.empty()) {
+             pDevice->Disconnect(pEngine);
+             engines.erase(pDevice);
+             delete pEngine;
+             dmsg(4,("Destroying gig::Engine.\n"));
+         }
+         else dmsg(4,("This gig::Engine has now %d EngineChannels.\n",pEngine->engineChannels.size()));
+     }
+     /**
+      * Constructor
+      */
+     Engine::Engine() : SuspendedRegions(128) {
          pAudioOutputDevice = NULL;
          pDiskThread        = NULL;
          pEventGenerator    = NULL;
-         pSysexBuffer       = new RingBuffer<uint8_t>(SYSEX_BUFFER_SIZE, 0);
+         pSysexBuffer       = new RingBuffer<uint8_t,false>(CONFIG_SYSEX_BUFFER_SIZE, 0);
-         pEventQueue        = new RingBuffer<Event>(MAX_EVENTS_PER_FRAGMENT, 0);
+         pEventQueue        = new RingBuffer<Event,false>(CONFIG_MAX_EVENTS_PER_FRAGMENT, 0);
-         pEventPool         = new Pool<Event>(MAX_EVENTS_PER_FRAGMENT);
+         pEventPool         = new Pool<Event>(CONFIG_MAX_EVENTS_PER_FRAGMENT);
-         pVoicePool         = new Pool<Voice>(MAX_AUDIO_VOICES);
+         pVoicePool         = new Pool<Voice>(GLOBAL_MAX_VOICES);
-         pActiveKeys        = new Pool<uint>(128);
+         pDimRegionPool[0]  = new Pool< ::gig::DimensionRegion*>(GLOBAL_MAX_VOICES);
+         pDimRegionPool[1]  = new Pool< ::gig::DimensionRegion*>(GLOBAL_MAX_VOICES);
          pVoiceStealingQueue = new RTList<Event>(pEventPool);
-         pEvents            = new RTList<Event>(pEventPool);
+         pGlobalEvents      = new RTList<Event>(pEventPool);
-         pCCEvents          = new RTList<Event>(pEventPool);
+         iMaxDiskStreams    = GLOBAL_MAX_STREAMS;
-         for (uint i = 0; i < Event::destination_count; i++) {
+         FrameTime          = 0;
-             pSynthesisEvents[i] = new RTList<Event>(pEventPool);
-         }
-         for (uint i = 0; i < 128; i++) {
-             pMIDIKeyInfo[i].pActiveVoices  = new RTList<Voice>(pVoicePool);
-             pMIDIKeyInfo[i].KeyPressed     = false;
-             pMIDIKeyInfo[i].Active         = false;
-             pMIDIKeyInfo[i].ReleaseTrigger = false;
-             pMIDIKeyInfo[i].pEvents        = new RTList<Event>(pEventPool);
-         }
          for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
              iterVoice->SetEngine(this);
          }
          pVoicePool->clear();
-         pSynthesisParameters[0] = NULL; // we allocate when an audio device is connected
-         pBasicFilterParameters  = NULL;
-         pMainFilterParameters   = NULL;
-         InstrumentIdx = -1;
-         InstrumentStat = -1;
-         AudioDeviceChannelLeft  = -1;
-         AudioDeviceChannelRight = -1;
          ResetInternal();
+         ResetScaleTuning();
+         ResetSuspendedRegions();
      }
+     /**
+      * Destructor
+      */
      Engine::~Engine() {
+         MidiInputPort::RemoveSysexListener(this);
          if (pDiskThread) {
              dmsg(1,("Stopping disk thread..."));
              pDiskThread->StopThread();
              delete pDiskThread;
              dmsg(1,("OK\n"));
          }
-         if (pInstrument) Instruments.HandBack(pInstrument, this);
-         if (pGig)  delete pGig;
-         if (pRIFF) delete pRIFF;
-         for (uint i = 0; i < 128; i++) {
-             if (pMIDIKeyInfo[i].pActiveVoices) delete pMIDIKeyInfo[i].pActiveVoices;
-             if (pMIDIKeyInfo[i].pEvents)       delete pMIDIKeyInfo[i].pEvents;
-         }
-         for (uint i = 0; i < Event::destination_count; i++) {
-             if (pSynthesisEvents[i]) delete pSynthesisEvents[i];
-         }
-         if (pEvents)     delete pEvents;
-         if (pCCEvents)   delete pCCEvents;
          if (pEventQueue) delete pEventQueue;
          if (pEventPool)  delete pEventPool;
          if (pVoicePool) {
-                 pVoicePool->clear();
+             pVoicePool->clear();
-                 delete pVoicePool;
+             delete pVoicePool;
          }
-         if (pActiveKeys) delete pActiveKeys;
-         if (pSysexBuffer) delete pSysexBuffer;
          if (pEventGenerator) delete pEventGenerator;
-         if (pMainFilterParameters) delete[] pMainFilterParameters;
-         if (pBasicFilterParameters) delete[] pBasicFilterParameters;
-         if (pSynthesisParameters[0]) free(pSynthesisParameters[0]);
          if (pVoiceStealingQueue) delete pVoiceStealingQueue;
+         if (pSysexBuffer) delete pSysexBuffer;
+         if (pGlobalEvents) delete pGlobalEvents;
+         if (pDimRegionPool[0]) delete pDimRegionPool[0];
+         if (pDimRegionPool[1]) delete pDimRegionPool[1];
+         ResetSuspendedRegions();
+         Unregister();
      }
      void Engine::Enable() {
          dmsg(3,("gig::Engine: enabling\n"));
-         EngineDisabled.PushAndUnlock(false, 2); // set condition object 'EngineDisabled' to false (wait max. 2s)
+         EngineDisabled.PushAndUnlock(false, 2, 0, true); // set condition object 'EngineDisabled' to false (wait max. 2s)
          dmsg(3,("gig::Engine: enabled (val=%d)\n", EngineDisabled.GetUnsafe()));
      }
+     /**
+      * Temporarily stop the engine to not do anything. The engine will just be
+      * frozen during that time, that means after enabling it again it will
+      * continue where it was, with all its voices and playback state it had at
+      * the point of disabling. Notice that the engine's (audio) thread will
+      * continue to run, it just remains in an inactive loop during that time.
+      *
+      * If you need to be sure that all voices and disk streams are killed as
+      * well, use @c SuspendAll() instead.
+      *
+      * @see Enable(), SuspendAll()
+      */
      void Engine::Disable() {
          dmsg(3,("gig::Engine: disabling\n"));
          bool* pWasDisabled = EngineDisabled.PushAndUnlock(true, 2); // wait max. 2s
-Line 135 
 namespace LinuxSampler { namespace gig {
+Line 183 
 namespace LinuxSampler { namespace gig {
      }
      /**
-      *  Reset all voices and disk thread and clear input event queue and all
+      * Similar to @c Disable() but this method additionally kills all voices
-      *  control and status variables.
+      * and disk streams and blocks until all voices and disk streams are actually
+      * killed / deleted.
+      *
+      * @e Note: only the original calling thread is able to re-enable the
+      * engine afterwards by calling @c ResumeAll() later on!
       */
-     void Engine::Reset() {
+     void Engine::SuspendAll() {
+         dmsg(2,("gig::Engine: Suspending all ...\n"));
+         // stop the engine, so we can safely modify the engine's
+         // data structures from this foreign thread
          DisableAndLock();
+         // we could also use the respective class member variable here,
+         // but this is probably safer and cleaner
+         int iPendingStreamDeletions = 0;
+         // kill all voices on all engine channels the *die hard* way
+         for (int iChannel = 0; iChannel < engineChannels.size(); iChannel++) {
+             EngineChannel* pEngineChannel = engineChannels[iChannel];
+             RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
+             RTList<uint>::Iterator end    = pEngineChannel->pActiveKeys->end();
+             for (; iuiKey != end; ++iuiKey) { // iterate through all active keys
+                 midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
+                 RTList<Voice>::Iterator itVoice = pKey->pActiveVoices->first();
+                 RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
+                 for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
+                     // request a notification from disk thread side for stream deletion
+                     const Stream::Handle hStream = itVoice->KillImmediately(true);
+                     if (hStream != Stream::INVALID_HANDLE) { // voice actually used a stream
+                         iPendingStreamDeletions++;
+                     }
+                     // free the voice to the voice pool and update key info
+                     FreeVoice(pEngineChannel, itVoice);
+                 }
+             }
+         }
+         // wait until all streams were actually deleted by the disk thread
+         while (iPendingStreamDeletions) {
+             while (
+                 iPendingStreamDeletions &&
+                 pDiskThread->AskForDeletedStream() != Stream::INVALID_HANDLE
+             ) iPendingStreamDeletions--;
+             if (!iPendingStreamDeletions) break;
+             usleep(10000); // sleep for 10ms
+         }
+         dmsg(2,("gig::Engine: Everything suspended.\n"));
+     }
-         //if (pAudioOutputDevice->IsPlaying()) { // if already running
+     /**
-             /*
+      * At the moment same as calling @c Enable() directly, but this might
-             // signal audio thread not to enter render part anymore
+      * change in future, so better call this method as counterpart to
-             SuspensionRequested = true;
+      * @c SuspendAll() instead of @c Enable() !
-             // sleep until wakened by audio thread
+      */
-             pthread_mutex_lock(&__render_state_mutex);
+     void Engine::ResumeAll() {
-             pthread_cond_wait(&__render_exit_condition, &__render_state_mutex);
+         Enable();
-             pthread_mutex_unlock(&__render_state_mutex);
+     }
-             */
-         //}
-         //if (wasplaying) pAudioOutputDevice->Stop();
+     /**
+      * Order the engine to stop rendering audio for the given region.
+      * Additionally this method will block until all voices and their disk
+      * streams associated with that region are actually killed / deleted, so
+      * one can i.e. safely modify the region with an instrument editor after
+      * returning from this method.
+      *
+      * @param pRegion - region the engine shall stop using
+      */
+     void Engine::Suspend(::gig::Region* pRegion) {
+         dmsg(2,("gig::Engine: Suspending Region %x ...\n",pRegion));
+         SuspendedRegionsMutex.Lock();
+         SuspensionChangeOngoing.Set(true);
+         pPendingRegionSuspension = pRegion;
+         SuspensionChangeOngoing.WaitAndUnlockIf(true);
+         SuspendedRegionsMutex.Unlock();
+         dmsg(2,("gig::Engine: Region %x suspended.",pRegion));
+     }
-         ResetInternal();
+     /**
+      * Orders the engine to resume playing back the given region, previously
+      * suspended with @c Suspend() .
+      *
+      * @param pRegion - region the engine shall be allowed to use again
+      */
+     void Engine::Resume(::gig::Region* pRegion) {
+         dmsg(2,("gig::Engine: Resuming Region %x ...\n",pRegion));
+         SuspendedRegionsMutex.Lock();
+         SuspensionChangeOngoing.Set(true);
+         pPendingRegionResumption = pRegion;
+         SuspensionChangeOngoing.WaitAndUnlockIf(true);
+         SuspendedRegionsMutex.Unlock();
+         dmsg(2,("gig::Engine: Region %x resumed.\n",pRegion));
+     }
-         // signal audio thread to continue with rendering
+     /**
-         //SuspensionRequested = false;
+      *  Reset all voices and disk thread and clear input event queue and all
+      *  control and status variables.
+      */
+     void Engine::Reset() {
+         DisableAndLock();
+         ResetInternal();
+         ResetScaleTuning();
          Enable();
      }
      /**
       *  Reset all voices and disk thread and clear input event queue and all
-      *  control and status variables. This method is not thread safe!
+      *  control and status variables. This method is protected by a mutex.
       */
      void Engine::ResetInternal() {
-         Pitch               = 0;
+         ResetInternalMutex.Lock();
-         SustainPedal        = false;
-         ActiveVoiceCount    = 0;
+         // make sure that the engine does not get any sysex messages
+         // while it's reseting
+         bool sysexDisabled = MidiInputPort::RemoveSysexListener(this);
+         SetVoiceCount(0);
          ActiveVoiceCountMax = 0;
-         GlobalVolume        = 1.0;
-         CurrentKeyDimension = 0;
          // reset voice stealing parameters
-         itLastStolenVoice = RTList<Voice>::Iterator();
-         iuiLastStolenKey  = RTList<uint>::Iterator();
          pVoiceStealingQueue->clear();
+         itLastStolenVoice          = RTList<Voice>::Iterator();
-         // reset to normal chromatic scale (means equal temper)
+         itLastStolenVoiceGlobally  = RTList<Voice>::Iterator();
-         memset(&ScaleTuning[0], 0x00, 12);
+         iuiLastStolenKey           = RTList<uint>::Iterator();
+         iuiLastStolenKeyGlobally   = RTList<uint>::Iterator();
-         // set all MIDI controller values to zero
+         pLastStolenChannel         = NULL;
-         memset(ControllerTable, 0x00, 128);
-         // reset key info
-         for (uint i = 0; i < 128; i++) {
-             pMIDIKeyInfo[i].pActiveVoices->clear();
-             pMIDIKeyInfo[i].pEvents->clear();
-             pMIDIKeyInfo[i].KeyPressed     = false;
-             pMIDIKeyInfo[i].Active         = false;
-             pMIDIKeyInfo[i].ReleaseTrigger = false;
-             pMIDIKeyInfo[i].itSelf         = Pool<uint>::Iterator();
-         }
-         // reset all key groups
-         map<uint,uint*>::iterator iter = ActiveKeyGroups.begin();
-         for (; iter != ActiveKeyGroups.end(); iter++) iter->second = NULL;
          // reset all voices
          for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
-Line 204 
 namespace LinuxSampler { namespace gig {
+Line 312 
 namespace LinuxSampler { namespace gig {
          }
          pVoicePool->clear();
-         // free all active keys
-         pActiveKeys->clear();
          // reset disk thread
          if (pDiskThread) pDiskThread->Reset();
          // delete all input events
          pEventQueue->init();
+         pSysexBuffer->init();
+         if (sysexDisabled) MidiInputPort::AddSysexListener(this);
+         ResetInternalMutex.Unlock();
      }
      /**
-      *  Load an instrument from a .gig file.
+      * Reset to normal, chromatic scale (means equal tempered).
-      *
-      *  @param FileName   - file name of the Gigasampler instrument file
-      *  @param Instrument - index of the instrument in the .gig file
-      *  @throws LinuxSamplerException  on error
-      *  @returns          detailed description of the method call result
       */
-     void Engine::LoadInstrument(const char* FileName, uint Instrument) {
+     void Engine::ResetScaleTuning() {
+         memset(&ScaleTuning[0], 0x00, 12);
-         DisableAndLock();
-         ResetInternal(); // reset engine
-         // free old instrument
-         if (pInstrument) {
-             // give old instrument back to instrument manager
-             Instruments.HandBack(pInstrument, this);
-         }
-         InstrumentFile = FileName;
-         InstrumentIdx = Instrument;
-         InstrumentStat = 0;
-         // delete all key groups
-         ActiveKeyGroups.clear();
-         // request gig instrument from instrument manager
-         try {
-             instrument_id_t instrid;
-             instrid.FileName    = FileName;
-             instrid.iInstrument = Instrument;
-             pInstrument = Instruments.Borrow(instrid, this);
-             if (!pInstrument) {
-                 InstrumentStat = -1;
-                 dmsg(1,("no instrument loaded!!!\n"));
-                 exit(EXIT_FAILURE);
-             }
-         }
-         catch (RIFF::Exception e) {
-             InstrumentStat = -2;
-             String msg = "gig::Engine error: Failed to load instrument, cause: " + e.Message;
-             throw LinuxSamplerException(msg);
-         }
-         catch (InstrumentResourceManagerException e) {
-             InstrumentStat = -3;
-             String msg = "gig::Engine error: Failed to load instrument, cause: " + e.Message();
-             throw LinuxSamplerException(msg);
-         }
-         catch (...) {
-             InstrumentStat = -4;
-             throw LinuxSamplerException("gig::Engine error: Failed to load instrument, cause: Unknown exception while trying to parse gig file.");
-         }
-         // rebuild ActiveKeyGroups map with key groups of current instrument
-         for (::gig::Region* pRegion = pInstrument->GetFirstRegion(); pRegion; pRegion = pInstrument->GetNextRegion())
-             if (pRegion->KeyGroup) ActiveKeyGroups[pRegion->KeyGroup] = NULL;
-         InstrumentIdxName = pInstrument->pInfo->Name;
-         InstrumentStat = 100;
-         // inform audio driver for the need of two channels
-         try {
-             if (pAudioOutputDevice) pAudioOutputDevice->AcquireChannels(2); // gig Engine only stereo
-         }
-         catch (AudioOutputException e) {
-             String msg = "Audio output device unable to provide 2 audio channels, cause: " + e.Message();
-             throw LinuxSamplerException(msg);
-         }
-         Enable();
      }
-     /**
+     void Engine::ResetSuspendedRegions() {
-      * Will be called by the InstrumentResourceManager when the instrument
+         SuspendedRegions.clear();
-      * we are currently using in this engine is going to be updated, so we
+         iPendingStreamDeletions = 0;
-      * can stop playback before that happens.
+         pPendingRegionSuspension = pPendingRegionResumption = NULL;
-      */
+         SuspensionChangeOngoing.Set(false);
-     void Engine::ResourceToBeUpdated(::gig::Instrument* pResource, void*& pUpdateArg) {
-         dmsg(3,("gig::Engine: Received instrument update message.\n"));
-         DisableAndLock();
-         ResetInternal();
-         this->pInstrument = NULL;
      }
      /**
-      * Will be called by the InstrumentResourceManager when the instrument
+      * Connect this engine instance with the given audio output device.
-      * update process was completed, so we can continue with playback.
+      * This method will be called when an Engine instance is created.
+      * All of the engine's data structures which are dependant to the used
+      * audio output device / driver will be (re)allocated and / or
+      * adjusted appropriately.
+      *
+      * @param pAudioOut - audio output device to connect to
       */
-     void Engine::ResourceUpdated(::gig::Instrument* pOldResource, ::gig::Instrument* pNewResource, void* pUpdateArg) {
-         this->pInstrument = pNewResource; //TODO: there are couple of engine parameters we should update here as well if the instrument was updated (see LoadInstrument())
-         Enable();
-     }
      void Engine::Connect(AudioOutputDevice* pAudioOut) {
+         // caution: don't ignore if connecting to the same device here,
+         // because otherwise SetMaxDiskStreams() implementation won't work anymore!
          pAudioOutputDevice = pAudioOut;
          ResetInternal();
-Line 319 
 namespace LinuxSampler { namespace gig {
+Line 359 
 namespace LinuxSampler { namespace gig {
          }
          catch (AudioOutputException e) {
              String msg = "Audio output device unable to provide 2 audio channels, cause: " + e.Message();
-             throw LinuxSamplerException(msg);
+             throw Exception(msg);
          }
-         this->AudioDeviceChannelLeft  = 0;
+         this->MaxSamplesPerCycle = pAudioOutputDevice->MaxSamplesPerCycle();
-         this->AudioDeviceChannelRight = 1;
+         this->SampleRate         = pAudioOutputDevice->SampleRate();
-         this->pOutputLeft             = pAudioOutputDevice->Channel(0)->Buffer();
-         this->pOutputRight            = pAudioOutputDevice->Channel(1)->Buffer();
+         MinFadeOutSamples = int(double(SampleRate) * CONFIG_EG_MIN_RELEASE_TIME) - 1;
-         this->MaxSamplesPerCycle      = pAudioOutputDevice->MaxSamplesPerCycle();
+         if (MaxSamplesPerCycle < MinFadeOutSamples) {
-         this->SampleRate              = pAudioOutputDevice->SampleRate();
+             std::cerr << "gig::Engine: WARNING, CONFIG_EG_MIN_RELEASE_TIME "
+                       << "too big for current audio fragment size & sampling rate! "
-         // FIXME: audio drivers with varying fragment sizes might be a problem here
+                       << "May lead to click sounds if voice stealing chimes in!\n" << std::flush;
-         MaxFadeOutPos = MaxSamplesPerCycle - int(double(SampleRate) * EG_MIN_RELEASE_TIME) - 1;
+             // force volume ramp downs at the beginning of each fragment
-         if (MaxFadeOutPos < 0)
+             MinFadeOutSamples = MaxSamplesPerCycle;
-             throw LinuxSamplerException("EG_MIN_RELEASE_TIME in EGADSR.h to big for current audio fragment size / sampling rate!");
+             // lower minimum release time
+             const float minReleaseTime = (float) MaxSamplesPerCycle / (float) SampleRate;
+             for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
+                 iterVoice->EG1.CalculateFadeOutCoeff(minReleaseTime, SampleRate);
+             }
+             pVoicePool->clear();
+         }
          // (re)create disk thread
          if (this->pDiskThread) {
-Line 341 
 namespace LinuxSampler { namespace gig {
+Line 387 
 namespace LinuxSampler { namespace gig {
              delete this->pDiskThread;
              dmsg(1,("OK\n"));
          }
-         this->pDiskThread = new DiskThread(((pAudioOut->MaxSamplesPerCycle() << MAX_PITCH) << 1) + 6); //FIXME: assuming stereo
+         this->pDiskThread =
+             new DiskThread(
+                 iMaxDiskStreams,
+                 ((pAudioOut->MaxSamplesPerCycle() << CONFIG_MAX_PITCH) << 1) + 6, //FIXME: assuming stereo
+                 &instruments
+             );
          if (!pDiskThread) {
              dmsg(0,("gig::Engine  new diskthread = NULL\n"));
              exit(EXIT_FAILURE);
-Line 357 
 namespace LinuxSampler { namespace gig {
+Line 409 
 namespace LinuxSampler { namespace gig {
          if (pEventGenerator) delete pEventGenerator;
          pEventGenerator = new EventGenerator(pAudioOut->SampleRate());
-         // (re)allocate synthesis parameter matrix
-         if (pSynthesisParameters[0]) free(pSynthesisParameters[0]);
-         #if defined(__APPLE__)
-         pSynthesisParameters[0] = (float *) malloc(Event::destination_count * sizeof(float) * pAudioOut->MaxSamplesPerCycle());
-         #else
-         pSynthesisParameters[0] = (float *) memalign(16,(Event::destination_count * sizeof(float) * pAudioOut->MaxSamplesPerCycle()));
-         #endif
-         for (int dst = 1; dst < Event::destination_count; dst++)
-             pSynthesisParameters[dst] = pSynthesisParameters[dst - 1] + pAudioOut->MaxSamplesPerCycle();
-         // (re)allocate biquad filter parameter sequence
-         if (pBasicFilterParameters) delete[] pBasicFilterParameters;
-         if (pMainFilterParameters)  delete[] pMainFilterParameters;
-         pBasicFilterParameters = new biquad_param_t[pAudioOut->MaxSamplesPerCycle()];
-         pMainFilterParameters  = new biquad_param_t[pAudioOut->MaxSamplesPerCycle()];
          dmsg(1,("Starting disk thread..."));
          pDiskThread->StartThread();
          dmsg(1,("OK\n"));
-Line 384 
 namespace LinuxSampler { namespace gig {
+Line 419 
 namespace LinuxSampler { namespace gig {
                  exit(EXIT_FAILURE);
              }
          }
+         pVoicePool->clear();
      }
-     void Engine::DisconnectAudioOutputDevice() {
+     /**
-         if (pAudioOutputDevice) { // if clause to prevent disconnect loops
+      * Called by the engine's (audio) thread once per cycle to process requests
-             AudioOutputDevice* olddevice = pAudioOutputDevice;
+      * from the outer world to suspend or resume a given @c gig::Region .
-             pAudioOutputDevice = NULL;
+      */
-             olddevice->Disconnect(this);
+     void Engine::ProcessSuspensionsChanges() {
-             AudioDeviceChannelLeft  = -1;
+         // process request for suspending one region
-             AudioDeviceChannelRight = -1;
+         if (pPendingRegionSuspension) {
+             // kill all voices on all engine channels that use this region
+             for (int iChannel = 0; iChannel < engineChannels.size(); iChannel++) {
+                 EngineChannel* pEngineChannel = engineChannels[iChannel];
+                 RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
+                 RTList<uint>::Iterator end    = pEngineChannel->pActiveKeys->end();
+                 for (; iuiKey != end; ++iuiKey) { // iterate through all active keys
+                     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
+                     RTList<Voice>::Iterator itVoice = pKey->pActiveVoices->first();
+                     // if current key is not associated with this region, skip this key
+                     if (itVoice->pDimRgn->GetParent() != pPendingRegionSuspension) continue;
+                     RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
+                     for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
+                         // request a notification from disk thread side for stream deletion
+                         const Stream::Handle hStream = itVoice->KillImmediately(true);
+                         if (hStream != Stream::INVALID_HANDLE) { // voice actually used a stream
+                             iPendingStreamDeletions++;
+                         }
+                         //NOTE: maybe we should call FreeVoice() here, shouldn't cause a harm though I think, since the voices should be freed by RenderActiveVoices() in the render loop, they are probably just freed a bit later than they could/should be
+                     }
+                 }
+             }
+             // make sure the region is not yet on the list
+             bool bAlreadySuspended = false;
+             RTList< ::gig::Region*>::Iterator iter = SuspendedRegions.first();
+             RTList< ::gig::Region*>::Iterator end  = SuspendedRegions.end();
+             for (; iter != end; ++iter) { // iterate through all suspended regions
+                 if (*iter == pPendingRegionSuspension) { // found
+                     bAlreadySuspended = true;
+                     dmsg(1,("gig::Engine: attempt to suspend an already suspended region !!!\n"));
+                     break;
+                 }
+             }
+             if (!bAlreadySuspended) {
+                 // put the region on the list of suspended regions
+                 RTList< ::gig::Region*>::Iterator iter = SuspendedRegions.allocAppend();
+                 if (iter) {
+                     *iter = pPendingRegionSuspension;
+                 } else std::cerr << "gig::Engine: Could not suspend Region, list is full. This is a bug!!!\n" << std::flush;
+             }
+             // free request slot for next caller (and to make sure that
+             // we're not going to process the same request in the next cycle)
+             pPendingRegionSuspension = NULL;
+             // if no disk stream deletions are pending, awaken other side, as
+             // we're done in this case
+             if (!iPendingStreamDeletions) SuspensionChangeOngoing.Set(false);
+         }
+         // process request for resuming one region
+         if (pPendingRegionResumption) {
+             // remove region from the list of suspended regions
+             RTList< ::gig::Region*>::Iterator iter = SuspendedRegions.first();
+             RTList< ::gig::Region*>::Iterator end  = SuspendedRegions.end();
+             for (; iter != end; ++iter) { // iterate through all suspended regions
+                 if (*iter == pPendingRegionResumption) { // found
+                     SuspendedRegions.free(iter);
+                     break; // done
+                 }
+             }
+             // free request slot for next caller
+             pPendingRegionResumption = NULL;
+             // awake other side as we're done
+             SuspensionChangeOngoing.Set(false);
          }
      }
      /**
-      *  Let this engine proceed to render the given amount of sample points. The
+      * Called by the engine's (audio) thread once per cycle to check if
-      *  calculated audio data of all voices of this engine will be placed into
+      * streams of voices that were killed due to suspension request have
-      *  the engine's audio sum buffer which has to be copied and eventually be
+      * finally really been deleted by the disk thread.
-      *  converted to the appropriate value range by the audio output class (e.g.
+      */
-      *  AlsaIO or JackIO) right after.
+     void Engine::ProcessPendingStreamDeletions() {
+         if (!iPendingStreamDeletions) return;
+         //TODO: or shall we better store a list with stream handles instead of a scalar amount of streams to be deleted? might be safer
+         while (
+             iPendingStreamDeletions &&
+             pDiskThread->AskForDeletedStream() != Stream::INVALID_HANDLE
+         ) iPendingStreamDeletions--;
+         // just for safety ...
+         while (pDiskThread->AskForDeletedStream() != Stream::INVALID_HANDLE);
+         // now that all disk streams are deleted, awake other side as
+         // we're finally done with suspending the requested region
+         if (!iPendingStreamDeletions) SuspensionChangeOngoing.Set(false);
+     }
+     /**
+      * Returns @c true if the given region is currently set to be suspended
+      * from being used, @c false otherwise.
+      */
+     bool Engine::RegionSuspended(::gig::Region* pRegion) {
+         if (SuspendedRegions.isEmpty()) return false;
+         //TODO: or shall we use a sorted container instead of the RTList? might be faster ... or trivial ;-)
+         RTList< ::gig::Region*>::Iterator iter = SuspendedRegions.first();
+         RTList< ::gig::Region*>::Iterator end  = SuspendedRegions.end();
+         for (; iter != end; ++iter)  // iterate through all suspended regions
+             if (*iter == pRegion) return true;
+         return false;
+     }
+     /**
+      * Clear all engine global event lists.
+      */
+     void Engine::ClearEventLists() {
+         pGlobalEvents->clear();
+     }
+     /**
+      * Copy all events from the engine's global input queue buffer to the
+      * engine's internal event list. This will be done at the beginning of
+      * each audio cycle (that is each RenderAudio() call) to distinguish
+      * all global events which have to be processed in the current audio
+      * cycle. These events are usually just SysEx messages. Every
+      * EngineChannel has it's own input event queue buffer and event list
+      * to handle common events like NoteOn, NoteOff and ControlChange
+      * events.
+      *
+      * @param Samples - number of sample points to be processed in the
+      *                  current audio cycle
+      */
+     void Engine::ImportEvents(uint Samples) {
+         RingBuffer<Event,false>::NonVolatileReader eventQueueReader = pEventQueue->get_non_volatile_reader();
+         Event* pEvent;
+         while (true) {
+             // get next event from input event queue
+             if (!(pEvent = eventQueueReader.pop())) break;
+             // if younger event reached, ignore that and all subsequent ones for now
+             if (pEvent->FragmentPos() >= Samples) {
+                 eventQueueReader--;
+                 dmsg(2,("Younger Event, pos=%d ,Samples=%d!\n",pEvent->FragmentPos(),Samples));
+                 pEvent->ResetFragmentPos();
+                 break;
+             }
+             // copy event to internal event list
+             if (pGlobalEvents->poolIsEmpty()) {
+                 dmsg(1,("Event pool emtpy!\n"));
+                 break;
+             }
+             *pGlobalEvents->allocAppend() = *pEvent;
+         }
+         eventQueueReader.free(); // free all copied events from input queue
+     }
+     /**
+      * Let this engine proceed to render the given amount of sample points.
+      * The engine will iterate through all engine channels and render audio
+      * for each engine channel independently. The calculated audio data of
+      * all voices of each engine channel will be placed into the audio sum
+      * buffers of the respective audio output device, connected to the
+      * respective engine channel.
       *
       *  @param Samples - number of sample points to be rendered
       *  @returns       0 on success
       */
      int Engine::RenderAudio(uint Samples) {
-         dmsg(5,("RenderAudio(Samples=%d)\n", Samples));
+         dmsg(8,("RenderAudio(Samples=%d)\n", Samples));
-         // return if no instrument loaded or engine disabled
+         // return if engine disabled
          if (EngineDisabled.Pop()) {
              dmsg(5,("gig::Engine: engine disabled (val=%d)\n",EngineDisabled.GetUnsafe()));
-             return 0;
+             EngineDisabled.RttDone();
-         }
-         if (!pInstrument) {
-             dmsg(5,("gig::Engine: no instrument loaded\n"));
              return 0;
          }
+         // process requests for suspending / resuming regions (i.e. to avoid
+         // crashes while these regions are modified by an instrument editor)
+         ProcessSuspensionsChanges();
          // update time of start and end of this audio fragment (as events' time stamps relate to this)
          pEventGenerator->UpdateFragmentTime(Samples);
+         // We only allow the given maximum number of voices to be spawned
+         // in each audio fragment. All subsequent request for spawning new
+         // voices in the same audio fragment will be ignored.
+         VoiceSpawnsLeft = MaxVoices();
+         // get all events from the engine's global input event queue which belong to the current fragment
+         // (these are usually just SysEx messages)
+         ImportEvents(Samples);
-         // empty the event lists for the new fragment
+         // process engine global events (these are currently only MIDI System Exclusive messages)
-         pEvents->clear();
-         pCCEvents->clear();
-         for (uint i = 0; i < Event::destination_count; i++) {
-             pSynthesisEvents[i]->clear();
-         }
          {
-             RTList<uint>::Iterator iuiKey = pActiveKeys->first();
+             RTList<Event>::Iterator itEvent = pGlobalEvents->first();
-             RTList<uint>::Iterator end    = pActiveKeys->end();
+             RTList<Event>::Iterator end     = pGlobalEvents->end();
-             for(; iuiKey != end; ++iuiKey) {
+             for (; itEvent != end; ++itEvent) {
-                 pMIDIKeyInfo[*iuiKey].pEvents->clear(); // free all events on the key
+                 switch (itEvent->Type) {
+                     case Event::type_sysex:
+                         dmsg(5,("Engine: Sysex received\n"));
+                         ProcessSysex(itEvent);
+                         break;
+                 }
              }
          }
+         // reset internal voice counter (just for statistic of active voices)
+         ActiveVoiceCountTemp = 0;
-         // get all events from the input event queue which belong to the current fragment
+         // handle instrument change commands
-         {
+         bool instrumentChanged = false;
-             RingBuffer<Event>::NonVolatileReader eventQueueReader = pEventQueue->get_non_volatile_reader();
+         for (int i = 0; i < engineChannels.size(); i++) {
-             Event* pEvent;
+             EngineChannel* pEngineChannel = engineChannels[i];
-             while (true) {
-                 // get next event from input event queue
+             // as we're going to (carefully) write some status to the
-                 if (!(pEvent = eventQueueReader.pop())) break;
+             // synchronized struct, we cast away the const
-                 // if younger event reached, ignore that and all subsequent ones for now
+             EngineChannel::instrument_change_command_t& cmd =
-                 if (pEvent->FragmentPos() >= Samples) {
+                 const_cast<EngineChannel::instrument_change_command_t&>(pEngineChannel->InstrumentChangeCommandReader.Lock());
-                     eventQueueReader--;
-                     dmsg(2,("Younger Event, pos=%d ,Samples=%d!\n",pEvent->FragmentPos(),Samples));
+             pEngineChannel->pDimRegionsInUse = cmd.pDimRegionsInUse;
-                     pEvent->ResetFragmentPos();
+             pEngineChannel->pDimRegionsInUse->clear();
-                     break;
-                 }
+             if (cmd.bChangeInstrument) {
-                 // copy event to internal event list
+                 // change instrument
-                 if (pEvents->poolIsEmpty()) {
+                 dmsg(5,("Engine: instrument change command received\n"));
-                     dmsg(1,("Event pool emtpy!\n"));
+                 cmd.bChangeInstrument = false;
-                     break;
+                 pEngineChannel->pInstrument = cmd.pInstrument;
+                 instrumentChanged = true;
+                 // Iterate through all active voices and mark them as
+                 // "orphans", which means that the dimension regions
+                 // and samples they use should be released to the
+                 // instrument resource manager when the voices die.
+                 int i = 0;
+                 RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
+                 RTList<uint>::Iterator end    = pEngineChannel->pActiveKeys->end();
+                 while (iuiKey != end) { // iterate through all active keys
+                     midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
+                     ++iuiKey;
+                     RTList<Voice>::Iterator itVoice     = pKey->pActiveVoices->first();
+                     RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
+                     for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
+                         itVoice->Orphan = true;
+                     }
                  }
-                 *pEvents->allocAppend() = *pEvent;
              }
-             eventQueueReader.free(); // free all copied events from input queue
          }
+         if (instrumentChanged) {
+             //TODO: this is a lazy solution ATM and not safe in case somebody is currently editing the instrument we're currently switching to (we should store all suspended regions on instrument manager side and when switching to another instrument copy that list to the engine's local list of suspensions
+             ResetSuspendedRegions();
+         }
+         // handle events on all engine channels
+         for (int i = 0; i < engineChannels.size(); i++) {
+             ProcessEvents(engineChannels[i], Samples);
+         }
+         // render all 'normal', active voices on all engine channels
+         for (int i = 0; i < engineChannels.size(); i++) {
+             RenderActiveVoices(engineChannels[i], Samples);
+         }
+         // now that all ordinary voices on ALL engine channels are rendered, render new stolen voices
+         RenderStolenVoices(Samples);
+         // handle audio routing for engine channels with FX sends
+         for (int i = 0; i < engineChannels.size(); i++) {
+             if (engineChannels[i]->fxSends.empty()) continue; // ignore if no FX sends
+             RouteAudio(engineChannels[i], Samples);
+         }
+         // handle cleanup on all engine channels for the next audio fragment
+         for (int i = 0; i < engineChannels.size(); i++) {
+             PostProcess(engineChannels[i]);
+         }
+         // empty the engine's event list for the next audio fragment
+         ClearEventLists();
+         // reset voice stealing for the next audio fragment
+         pVoiceStealingQueue->clear();
+         // just some statistics about this engine instance
+         SetVoiceCount(ActiveVoiceCountTemp);
+         if (VoiceCount() > ActiveVoiceCountMax) ActiveVoiceCountMax = VoiceCount();
+         // in case regions were previously suspended and we killed voices
+         // with disk streams due to that, check if those streams have finally
+         // been deleted by the disk thread
+         if (iPendingStreamDeletions) ProcessPendingStreamDeletions();
+         for (int i = 0; i < engineChannels.size(); i++) {
+             engineChannels[i]->InstrumentChangeCommandReader.Unlock();
+         }
+         FrameTime += Samples;
+         EngineDisabled.RttDone();
+         return 0;
+     }
+     /**
+      * Dispatch and handle all events in this audio fragment for the given
+      * engine channel.
+      *
+      * @param pEngineChannel - engine channel on which events should be
+      *                         processed
+      * @param Samples        - amount of sample points to be processed in
+      *                         this audio fragment cycle
+      */
+     void Engine::ProcessEvents(EngineChannel* pEngineChannel, uint Samples) {
+         // get all events from the engine channels's input event queue which belong to the current fragment
+         // (these are the common events like NoteOn, NoteOff, ControlChange, etc.)
+         pEngineChannel->ImportEvents(Samples);
          // process events
          {
-             RTList<Event>::Iterator itEvent = pEvents->first();
+             RTList<Event>::Iterator itEvent = pEngineChannel->pEvents->first();
-             RTList<Event>::Iterator end     = pEvents->end();
+             RTList<Event>::Iterator end     = pEngineChannel->pEvents->end();
              for (; itEvent != end; ++itEvent) {
                  switch (itEvent->Type) {
                      case Event::type_note_on:
                          dmsg(5,("Engine: Note on received\n"));
-                         ProcessNoteOn(itEvent);
+                         ProcessNoteOn((EngineChannel*)itEvent->pEngineChannel, itEvent);
                          break;
                      case Event::type_note_off:
                          dmsg(5,("Engine: Note off received\n"));
-                         ProcessNoteOff(itEvent);
+                         ProcessNoteOff((EngineChannel*)itEvent->pEngineChannel, itEvent);
                          break;
                      case Event::type_control_change:
                          dmsg(5,("Engine: MIDI CC received\n"));
-                         ProcessControlChange(itEvent);
+                         ProcessControlChange((EngineChannel*)itEvent->pEngineChannel, itEvent);
                          break;
                      case Event::type_pitchbend:
                          dmsg(5,("Engine: Pitchbend received\n"));
-                         ProcessPitchbend(itEvent);
+                         ProcessPitchbend((EngineChannel*)itEvent->pEngineChannel, itEvent);
-                         break;
-                     case Event::type_sysex:
-                         dmsg(5,("Engine: Sysex received\n"));
-                         ProcessSysex(itEvent);
                          break;
                  }
              }
          }
+         // reset voice stealing for the next engine channel (or next audio fragment)
+         itLastStolenVoice         = RTList<Voice>::Iterator();
+         itLastStolenVoiceGlobally = RTList<Voice>::Iterator();
+         iuiLastStolenKey          = RTList<uint>::Iterator();
+         iuiLastStolenKeyGlobally  = RTList<uint>::Iterator();
+         pLastStolenChannel        = NULL;
+     }
-         int active_voices = 0;
+     /**
+      * Render all 'normal' voices (that is voices which were not stolen in
+      * this fragment) on the given engine channel.
+      *
+      * @param pEngineChannel - engine channel on which audio should be
+      *                         rendered
+      * @param Samples        - amount of sample points to be rendered in
+      *                         this audio fragment cycle
+      */
+     void Engine::RenderActiveVoices(EngineChannel* pEngineChannel, uint Samples) {
+         #if !CONFIG_PROCESS_MUTED_CHANNELS
+         if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+         #endif
-         // render audio from all active voices
+         uint voiceCount = 0;
-         {
+         uint streamCount = 0;
-             RTList<uint>::Iterator iuiKey = pActiveKeys->first();
+         RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
-             RTList<uint>::Iterator end    = pActiveKeys->end();
+         RTList<uint>::Iterator end    = pEngineChannel->pActiveKeys->end();
-             while (iuiKey != end) { // iterate through all active keys
+         while (iuiKey != end) { // iterate through all active keys
-                 midi_key_info_t* pKey = &pMIDIKeyInfo[*iuiKey];
+             midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
-                 ++iuiKey;
+             ++iuiKey;
+             RTList<Voice>::Iterator itVoice     = pKey->pActiveVoices->first();
+             RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
+             for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
+                 // now render current voice
+                 itVoice->Render(Samples);
+                 if (itVoice->IsActive()) { // still active
+                     if (!itVoice->Orphan) {
+                         *(pEngineChannel->pDimRegionsInUse->allocAppend()) = itVoice->pDimRgn;
+                     }
+                     ActiveVoiceCountTemp++;
+                     voiceCount++;
-                 RTList<Voice>::Iterator itVoice     = pKey->pActiveVoices->first();
+                     if (itVoice->PlaybackState == Voice::playback_state_disk) {
-                 RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
+                         if ((itVoice->DiskStreamRef).State != Stream::state_unused) streamCount++;
-                 for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
-                     // now render current voice
-                     itVoice->Render(Samples);
-                     if (itVoice->IsActive()) active_voices++; // still active
-                     else { // voice reached end, is now inactive
-                         FreeVoice(itVoice); // remove voice from the list of active voices
                      }
+                 }  else { // voice reached end, is now inactive
+                     FreeVoice(pEngineChannel, itVoice); // remove voice from the list of active voices
                  }
              }
          }
+         pEngineChannel->SetVoiceCount(voiceCount);
+         pEngineChannel->SetDiskStreamCount(streamCount);
+     }
-         // now render all postponed voices from voice stealing
+     /**
-         {
+      * Render all stolen voices (only voices which were stolen in this
-             RTList<Event>::Iterator itVoiceStealEvent = pVoiceStealingQueue->first();
+      * fragment) on the given engine channel. Stolen voices are rendered
-             RTList<Event>::Iterator end               = pVoiceStealingQueue->end();
+      * after all normal voices have been rendered; this is needed to render
-             for (; itVoiceStealEvent != end; ++itVoiceStealEvent) {
+      * audio of those voices which were selected for voice stealing until
-                 Pool<Voice>::Iterator itNewVoice = LaunchVoice(itVoiceStealEvent, itVoiceStealEvent->Param.Note.Layer, itVoiceStealEvent->Param.Note.ReleaseTrigger, false);
+      * the point were the stealing (that is the take over of the voice)
-                 if (itNewVoice) {
+      * actually happened.
-                     for (; itNewVoice; itNewVoice = itNewVoice->itChildVoice) {
+      *
-                         itNewVoice->Render(Samples);
+      * @param pEngineChannel - engine channel on which audio should be
-                         if (itNewVoice->IsActive()) active_voices++; // still active
+      *                         rendered
-                         else { // voice reached end, is now inactive
+      * @param Samples        - amount of sample points to be rendered in
-                             FreeVoice(itNewVoice); // remove voice from the list of active voices
+      *                         this audio fragment cycle
+      */
+     void Engine::RenderStolenVoices(uint Samples) {
+         RTList<Event>::Iterator itVoiceStealEvent = pVoiceStealingQueue->first();
+         RTList<Event>::Iterator end               = pVoiceStealingQueue->end();
+         for (; itVoiceStealEvent != end; ++itVoiceStealEvent) {
+             EngineChannel* pEngineChannel = (EngineChannel*) itVoiceStealEvent->pEngineChannel;
+             if (!pEngineChannel->pInstrument) continue; // ignore if no instrument loaded
+             Pool<Voice>::Iterator itNewVoice =
+                 LaunchVoice(pEngineChannel, itVoiceStealEvent, itVoiceStealEvent->Param.Note.Layer, itVoiceStealEvent->Param.Note.ReleaseTrigger, false, false);
+             if (itNewVoice) {
+                 itNewVoice->Render(Samples);
+                 if (itNewVoice->IsActive()) { // still active
+                     *(pEngineChannel->pDimRegionsInUse->allocAppend()) = itNewVoice->pDimRgn;
+                     ActiveVoiceCountTemp++;
+                     pEngineChannel->SetVoiceCount(pEngineChannel->GetVoiceCount() + 1);
+                     if (itNewVoice->PlaybackState == Voice::playback_state_disk) {
+                         if (itNewVoice->DiskStreamRef.State != Stream::state_unused) {
+                             pEngineChannel->SetDiskStreamCount(pEngineChannel->GetDiskStreamCount() + 1);
                          }
                      }
+                 } else { // voice reached end, is now inactive
+                     FreeVoice(pEngineChannel, itNewVoice); // remove voice from the list of active voices
                  }
-                 else dmsg(1,("gig::Engine: ERROR, voice stealing didn't work out!\n"));
              }
+             else dmsg(1,("gig::Engine: ERROR, voice stealing didn't work out!\n"));
+             // we need to clear the key's event list explicitly here in case key was never active
+             midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[itVoiceStealEvent->Param.Note.Key];
+             pKey->VoiceTheftsQueued--;
+             if (!pKey->Active && !pKey->VoiceTheftsQueued) pKey->pEvents->clear();
          }
-         // reset voice stealing for the new fragment
+     }
-         pVoiceStealingQueue->clear();
-         itLastStolenVoice = RTList<Voice>::Iterator();
-         iuiLastStolenKey  = RTList<uint>::Iterator();
+     /**
+      * Will be called in case the respective engine channel sports FX send
+      * channels. In this particular case, engine channel local buffers are
+      * used to render and mix all voices to. This method is responsible for
+      * copying the audio data from those local buffers to the master audio
+      * output channels as well as to the FX send audio output channels with
+      * their respective FX send levels.
+      *
+      * @param pEngineChannel - engine channel from which audio should be
+      *                         routed
+      * @param Samples        - amount of sample points to be routed in
+      *                         this audio fragment cycle
+      */
+     void Engine::RouteAudio(EngineChannel* pEngineChannel, uint Samples) {
+         // route dry signal
+         {
+             AudioChannel* pDstL = pAudioOutputDevice->Channel(pEngineChannel->AudioDeviceChannelLeft);
+             AudioChannel* pDstR = pAudioOutputDevice->Channel(pEngineChannel->AudioDeviceChannelRight);
+             pEngineChannel->pChannelLeft->MixTo(pDstL, Samples);
+             pEngineChannel->pChannelRight->MixTo(pDstR, Samples);
+         }
+         // route FX send signal
+         {
+             for (int iFxSend = 0; iFxSend < pEngineChannel->GetFxSendCount(); iFxSend++) {
+                 FxSend* pFxSend = pEngineChannel->GetFxSend(iFxSend);
+                 for (int iChan = 0; iChan < 2; ++iChan) {
+                     AudioChannel* pSource =
+                         (iChan)
+                             ? pEngineChannel->pChannelRight
+                             : pEngineChannel->pChannelLeft;
+                     const int iDstChan = pFxSend->DestinationChannel(iChan);
+                     if (iDstChan < 0) {
+                         dmsg(1,("Engine::RouteAudio() Error: invalid FX send (%s) destination channel (%d->%d)", ((iChan) ? "R" : "L"), iChan, iDstChan));
+                         goto channel_cleanup;
+                     }
+                     AudioChannel* pDstChan = NULL;
+                     if (pFxSend->DestinationMasterEffectChain() >= 0) { // fx send routed to an internal master effect
+                         EffectChain* pEffectChain =
+                             pAudioOutputDevice->MasterEffectChain(
+                                 pFxSend->DestinationMasterEffectChain()
+                             );
+                         if (!pEffectChain) {
+                             dmsg(1,("Engine::RouteAudio() Error: invalid FX send (%s) destination effect chain %d", ((iChan) ? "R" : "L"), pFxSend->DestinationMasterEffectChain()));
+                             goto channel_cleanup;
+                         }
+                         Effect* pEffect =
+                             pEffectChain->GetEffect(
+                                 pFxSend->DestinationMasterEffect()
+                             );
+                         if (!pEffect) {
+                             dmsg(1,("Engine::RouteAudio() Error: invalid FX send (%s) destination effect %d of effect chain %d", ((iChan) ? "R" : "L"), pFxSend->DestinationMasterEffect(), pFxSend->DestinationMasterEffectChain()));
+                             goto channel_cleanup;
+                         }
+                         pDstChan = pEffect->InputChannel(iDstChan);
+                     } else { // FX send routed directly to an audio output channel
+                         pDstChan = pAudioOutputDevice->Channel(iDstChan);
+                     }
+                     if (!pDstChan) {
+                         dmsg(1,("Engine::RouteAudio() Error: invalid FX send (%s) destination channel (%d->%d)", ((iChan) ? "R" : "L"), iChan, iDstChan));
+                         goto channel_cleanup;
+                     }
+                     pSource->MixTo(pDstChan, Samples, pFxSend->Level());
+                 }
+             }
+         }
+         channel_cleanup:
+         // reset buffers with silence (zero out) for the next audio cycle
+         pEngineChannel->pChannelLeft->Clear();
+         pEngineChannel->pChannelRight->Clear();
+     }
+     /**
+      * Free all keys which have turned inactive in this audio fragment, from
+      * the list of active keys and clear all event lists on that engine
+      * channel.
+      *
+      * @param pEngineChannel - engine channel to cleanup
+      */
+     void Engine::PostProcess(EngineChannel* pEngineChannel) {
          // free all keys which have no active voices left
          {
-             RTList<uint>::Iterator iuiKey = pActiveKeys->first();
+             RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
-             RTList<uint>::Iterator end    = pActiveKeys->end();
+             RTList<uint>::Iterator end    = pEngineChannel->pActiveKeys->end();
              while (iuiKey != end) { // iterate through all active keys
-                 midi_key_info_t* pKey = &pMIDIKeyInfo[*iuiKey];
+                 midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
                  ++iuiKey;
-                 if (pKey->pActiveVoices->isEmpty()) FreeKey(pKey);
+                 if (pKey->pActiveVoices->isEmpty()) FreeKey(pEngineChannel, pKey);
-                 #if DEVMODE
+                 #if CONFIG_DEVMODE
-                 else { // FIXME: should be removed before the final release (purpose: just a sanity check for debugging)
+                 else { // just a sanity check for debugging
                      RTList<Voice>::Iterator itVoice     = pKey->pActiveVoices->first();
                      RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
                      for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
-Line 561 
 namespace LinuxSampler { namespace gig {
+Line 955 
 namespace LinuxSampler { namespace gig {
                          }
                      }
                  }
-                 #endif // DEVMODE
+                 #endif // CONFIG_DEVMODE
              }
          }
+         // empty the engine channel's own event lists
-         // write that to the disk thread class so that it can print it
+         pEngineChannel->ClearEventLists();
-         // on the console for debugging purposes
-         ActiveVoiceCount = active_voices;
-         if (ActiveVoiceCount > ActiveVoiceCountMax) ActiveVoiceCountMax = ActiveVoiceCount;
-         return 0;
-     }
-     /**
-      *  Will be called by the MIDIIn Thread to let the audio thread trigger a new
-      *  voice for the given key.
-      *
-      *  @param Key      - MIDI key number of the triggered key
-      *  @param Velocity - MIDI velocity value of the triggered key
-      */
-     void Engine::SendNoteOn(uint8_t Key, uint8_t Velocity) {
-         Event event               = pEventGenerator->CreateEvent();
-         event.Type                = Event::type_note_on;
-         event.Param.Note.Key      = Key;
-         event.Param.Note.Velocity = Velocity;
-         if (this->pEventQueue->write_space() > 0) this->pEventQueue->push(&event);
-         else dmsg(1,("Engine: Input event queue full!"));
-     }
-     /**
-      *  Will be called by the MIDIIn Thread to signal the audio thread to release
-      *  voice(s) on the given key.
-      *
-      *  @param Key      - MIDI key number of the released key
-      *  @param Velocity - MIDI release velocity value of the released key
-      */
-     void Engine::SendNoteOff(uint8_t Key, uint8_t Velocity) {
-         Event event               = pEventGenerator->CreateEvent();
-         event.Type                = Event::type_note_off;
-         event.Param.Note.Key      = Key;
-         event.Param.Note.Velocity = Velocity;
-         if (this->pEventQueue->write_space() > 0) this->pEventQueue->push(&event);
-         else dmsg(1,("Engine: Input event queue full!"));
-     }
-     /**
-      *  Will be called by the MIDIIn Thread to signal the audio thread to change
-      *  the pitch value for all voices.
-      *
-      *  @param Pitch - MIDI pitch value (-8192 ... +8191)
-      */
-     void Engine::SendPitchbend(int Pitch) {
-         Event event             = pEventGenerator->CreateEvent();
-         event.Type              = Event::type_pitchbend;
-         event.Param.Pitch.Pitch = Pitch;
-         if (this->pEventQueue->write_space() > 0) this->pEventQueue->push(&event);
-         else dmsg(1,("Engine: Input event queue full!"));
-     }
-     /**
-      *  Will be called by the MIDIIn Thread to signal the audio thread that a
-      *  continuous controller value has changed.
-      *
-      *  @param Controller - MIDI controller number of the occured control change
-      *  @param Value      - value of the control change
-      */
-     void Engine::SendControlChange(uint8_t Controller, uint8_t Value) {
-         Event event               = pEventGenerator->CreateEvent();
-         event.Type                = Event::type_control_change;
-         event.Param.CC.Controller = Controller;
-         event.Param.CC.Value      = Value;
-         if (this->pEventQueue->write_space() > 0) this->pEventQueue->push(&event);
-         else dmsg(1,("Engine: Input event queue full!"));
      }
      /**
-Line 643 
 namespace LinuxSampler { namespace gig {
+Line 969 
 namespace LinuxSampler { namespace gig {
       *
       *  @param pData - pointer to sysex data
       *  @param Size  - lenght of sysex data (in bytes)
+      *  @param pSender - the MIDI input port on which the SysEx message was
+      *                   received
       */
-     void Engine::SendSysex(void* pData, uint Size) {
+     void Engine::SendSysex(void* pData, uint Size, MidiInputPort* pSender) {
          Event event             = pEventGenerator->CreateEvent();
          event.Type              = Event::type_sysex;
          event.Param.Sysex.Size  = Size;
+         event.pEngineChannel    = NULL; // as Engine global event
+         event.pMidiInputPort    = pSender;
          if (pEventQueue->write_space() > 0) {
              if (pSysexBuffer->write_space() >= Size) {
                  // copy sysex data to input buffer
-Line 663 
 namespace LinuxSampler { namespace gig {
+Line 993 
 namespace LinuxSampler { namespace gig {
                  // finally place sysex event into input event queue
                  pEventQueue->push(&event);
              }
-             else dmsg(1,("Engine: Sysex message too large (%d byte) for input buffer (%d byte)!",Size,SYSEX_BUFFER_SIZE));
+             else dmsg(1,("Engine: Sysex message too large (%d byte) for input buffer (%d byte)!",Size,CONFIG_SYSEX_BUFFER_SIZE));
          }
          else dmsg(1,("Engine: Input event queue full!"));
      }
-Line 671 
 namespace LinuxSampler { namespace gig {
+Line 1001 
 namespace LinuxSampler { namespace gig {
      /**
       *  Assigns and triggers a new voice for the respective MIDI key.
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param itNoteOnEvent - key, velocity and time stamp of the event
       */
-     void Engine::ProcessNoteOn(Pool<Event>::Iterator& itNoteOnEvent) {
+     void Engine::ProcessNoteOn(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOnEvent) {
+         #if !CONFIG_PROCESS_MUTED_CHANNELS
+         if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+         #endif
+         if (!pEngineChannel->pInstrument) return; // ignore if no instrument loaded
+         //HACK: we should better add the transpose value only to the most mandatory places (like for retrieving the region and calculating the tuning), because otherwise voices will unintendedly survive when changing transpose while playing
+         itNoteOnEvent->Param.Note.Key += pEngineChannel->GlobalTranspose;
          const int key = itNoteOnEvent->Param.Note.Key;
+         midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[key];
-         // Change key dimension value if key is in keyswitching area
+         // move note on event to the key's own event list
-         if (key >= pInstrument->DimensionKeyRange.low && key <= pInstrument->DimensionKeyRange.high)
+         RTList<Event>::Iterator itNoteOnEventOnKeyList = itNoteOnEvent.moveToEndOf(pKey->pEvents);
-             CurrentKeyDimension = ((key - pInstrument->DimensionKeyRange.low) * 128) /
-                 (pInstrument->DimensionKeyRange.high - pInstrument->DimensionKeyRange.low + 1);
-         midi_key_info_t* pKey = &pMIDIKeyInfo[key];
+         // if Solo Mode then kill all already active voices
+         if (pEngineChannel->SoloMode) {
+             Pool<uint>::Iterator itYoungestKey = pEngineChannel->pActiveKeys->last();
+             if (itYoungestKey) {
+                 const int iYoungestKey = *itYoungestKey;
+                 const midi_key_info_t* pOtherKey = &pEngineChannel->pMIDIKeyInfo[iYoungestKey];
+                 if (pOtherKey->Active) {
+                     // get final portamento position of currently active voice
+                     if (pEngineChannel->PortamentoMode) {
+                         RTList<Voice>::Iterator itVoice = pOtherKey->pActiveVoices->last();
+                         if (itVoice) itVoice->UpdatePortamentoPos(itNoteOnEventOnKeyList);
+                     }
+                     // kill all voices on the (other) key
+                     RTList<Voice>::Iterator itVoiceToBeKilled = pOtherKey->pActiveVoices->first();
+                     RTList<Voice>::Iterator end               = pOtherKey->pActiveVoices->end();
+                     for (; itVoiceToBeKilled != end; ++itVoiceToBeKilled) {
+                         if (itVoiceToBeKilled->Type != Voice::type_release_trigger)
+                             itVoiceToBeKilled->Kill(itNoteOnEventOnKeyList);
+                     }
+                 }
+             }
+             // set this key as 'currently active solo key'
+             pEngineChannel->SoloKey = key;
+         }
+         // Change key dimension value if key is in keyswitching area
+         {
+             const ::gig::Instrument* pInstrument = pEngineChannel->pInstrument;
+             if (key >= pInstrument->DimensionKeyRange.low && key <= pInstrument->DimensionKeyRange.high)
+                 pEngineChannel->CurrentKeyDimension = float(key - pInstrument->DimensionKeyRange.low) /
+                     (pInstrument->DimensionKeyRange.high - pInstrument->DimensionKeyRange.low + 1);
+         }
          pKey->KeyPressed = true; // the MIDI key was now pressed down
+         pKey->Velocity   = itNoteOnEventOnKeyList->Param.Note.Velocity;
+         pKey->NoteOnTime = FrameTime + itNoteOnEventOnKeyList->FragmentPos(); // will be used to calculate note length
          // cancel release process of voices on this key if needed
-         if (pKey->Active && !SustainPedal) {
+         if (pKey->Active && !pEngineChannel->SustainPedal) {
              RTList<Event>::Iterator itCancelReleaseEvent = pKey->pEvents->allocAppend();
              if (itCancelReleaseEvent) {
-                 *itCancelReleaseEvent = *itNoteOnEvent;                  // copy event
+                 *itCancelReleaseEvent = *itNoteOnEventOnKeyList;         // copy event
                  itCancelReleaseEvent->Type = Event::type_cancel_release; // transform event type
              }
              else dmsg(1,("Event pool emtpy!\n"));
          }
-         // move note on event to the key's own event list
+         // allocate and trigger new voice(s) for the key
-         RTList<Event>::Iterator itNoteOnEventOnKeyList = itNoteOnEvent.moveToEndOf(pKey->pEvents);
+         {
+             // first, get total amount of required voices (dependant on amount of layers)
+             ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(itNoteOnEventOnKeyList->Param.Note.Key);
+             if (pRegion && !RegionSuspended(pRegion)) {
+                 int voicesRequired = pRegion->Layers;
+                 // now launch the required amount of voices
+                 for (int i = 0; i < voicesRequired; i++)
+                     LaunchVoice(pEngineChannel, itNoteOnEventOnKeyList, i, false, true, true);
+             }
+         }
+         // if neither a voice was spawned or postponed then remove note on event from key again
+         if (!pKey->Active && !pKey->VoiceTheftsQueued)
+             pKey->pEvents->free(itNoteOnEventOnKeyList);
-         // allocate and trigger a new voice for the key
+         if (!pEngineChannel->SoloMode || pEngineChannel->PortamentoPos < 0.0f) pEngineChannel->PortamentoPos = (float) key;
-         LaunchVoice(itNoteOnEventOnKeyList, 0, false, true);
+         pKey->RoundRobinIndex++;
      }
      /**
-Line 709 
 namespace LinuxSampler { namespace gig {
+Line 1093 
 namespace LinuxSampler { namespace gig {
       *  sustain pedal will be released or voice turned inactive by itself (e.g.
       *  due to completion of sample playback).
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param itNoteOffEvent - key, velocity and time stamp of the event
       */
-     void Engine::ProcessNoteOff(Pool<Event>::Iterator& itNoteOffEvent) {
+     void Engine::ProcessNoteOff(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOffEvent) {
-         midi_key_info_t* pKey = &pMIDIKeyInfo[itNoteOffEvent->Param.Note.Key];
+         #if !CONFIG_PROCESS_MUTED_CHANNELS
+         if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+         #endif
-         pKey->KeyPressed = false; // the MIDI key was now released
+         //HACK: we should better add the transpose value only to the most mandatory places (like for retrieving the region and calculating the tuning), because otherwise voices will unintendedly survive when changing transpose while playing
+         itNoteOffEvent->Param.Note.Key += pEngineChannel->GlobalTranspose;
-         // release voices on this key if needed
+         const int iKey = itNoteOffEvent->Param.Note.Key;
-         if (pKey->Active && !SustainPedal) {
+         midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[iKey];
-             itNoteOffEvent->Type = Event::type_release; // transform event type
+         pKey->KeyPressed = false; // the MIDI key was now released
-         }
          // move event to the key's own event list
          RTList<Event>::Iterator itNoteOffEventOnKeyList = itNoteOffEvent.moveToEndOf(pKey->pEvents);
-         // spawn release triggered voice(s) if needed
+         bool bShouldRelease = pKey->Active && ShouldReleaseVoice(pEngineChannel, itNoteOffEventOnKeyList->Param.Note.Key);
-         if (pKey->ReleaseTrigger) {
-             LaunchVoice(itNoteOffEventOnKeyList, 0, true, false); //FIXME: for the moment we don't perform voice stealing for release triggered samples
+         // in case Solo Mode is enabled, kill all voices on this key and respawn a voice on the highest pressed key (if any)
-             pKey->ReleaseTrigger = false;
+         if (pEngineChannel->SoloMode && pEngineChannel->pInstrument) { //TODO: this feels like too much code just for handling solo mode :P
+             bool bOtherKeysPressed = false;
+             if (iKey == pEngineChannel->SoloKey) {
+                 pEngineChannel->SoloKey = -1;
+                 // if there's still a key pressed down, respawn a voice (group) on the highest key
+                 for (int i = 127; i > 0; i--) {
+                     midi_key_info_t* pOtherKey = &pEngineChannel->pMIDIKeyInfo[i];
+                     if (pOtherKey->KeyPressed) {
+                         bOtherKeysPressed = true;
+                         // make the other key the new 'currently active solo key'
+                         pEngineChannel->SoloKey = i;
+                         // get final portamento position of currently active voice
+                         if (pEngineChannel->PortamentoMode) {
+                             RTList<Voice>::Iterator itVoice = pKey->pActiveVoices->first();
+                             if (itVoice) itVoice->UpdatePortamentoPos(itNoteOffEventOnKeyList);
+                         }
+                         // create a pseudo note on event
+                         RTList<Event>::Iterator itPseudoNoteOnEvent = pOtherKey->pEvents->allocAppend();
+                         if (itPseudoNoteOnEvent) {
+                             // copy event
+                             *itPseudoNoteOnEvent = *itNoteOffEventOnKeyList;
+                             // transform event to a note on event
+                             itPseudoNoteOnEvent->Type                = Event::type_note_on;
+                             itPseudoNoteOnEvent->Param.Note.Key      = i;
+                             itPseudoNoteOnEvent->Param.Note.Velocity = pOtherKey->Velocity;
+                             // allocate and trigger new voice(s) for the other key
+                             {
+                                 // first, get total amount of required voices (dependant on amount of layers)
+                                 ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(i);
+                                 if (pRegion) {
+                                     int voicesRequired = pRegion->Layers;
+                                     // now launch the required amount of voices
+                                     for (int iLayer = 0; iLayer < voicesRequired; iLayer++)
+                                         LaunchVoice(pEngineChannel, itPseudoNoteOnEvent, iLayer, false, true, false);
+                                 }
+                             }
+                             // if neither a voice was spawned or postponed then remove note on event from key again
+                             if (!pOtherKey->Active && !pOtherKey->VoiceTheftsQueued)
+                                 pOtherKey->pEvents->free(itPseudoNoteOnEvent);
+                         } else dmsg(1,("Could not respawn voice, no free event left\n"));
+                         break; // done
+                     }
+                 }
+             }
+             if (bOtherKeysPressed) {
+                 if (pKey->Active) { // kill all voices on this key
+                     bShouldRelease = false; // no need to release, as we kill it here
+                     RTList<Voice>::Iterator itVoiceToBeKilled = pKey->pActiveVoices->first();
+                     RTList<Voice>::Iterator end               = pKey->pActiveVoices->end();
+                     for (; itVoiceToBeKilled != end; ++itVoiceToBeKilled) {
+                         if (itVoiceToBeKilled->Type != Voice::type_release_trigger)
+                             itVoiceToBeKilled->Kill(itNoteOffEventOnKeyList);
+                     }
+                 }
+             } else pEngineChannel->PortamentoPos = -1.0f;
          }
+         // if no solo mode (the usual case) or if solo mode and no other key pressed, then release voices on this key if needed
+         if (bShouldRelease) {
+             itNoteOffEventOnKeyList->Type = Event::type_release; // transform event type
+             // spawn release triggered voice(s) if needed
+             if (pKey->ReleaseTrigger && pEngineChannel->pInstrument) {
+                 // first, get total amount of required voices (dependant on amount of layers)
+                 ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(itNoteOffEventOnKeyList->Param.Note.Key);
+                 if (pRegion) {
+                     int voicesRequired = pRegion->Layers;
+                     // MIDI note-on velocity is used instead of note-off velocity
+                     itNoteOffEventOnKeyList->Param.Note.Velocity = pKey->Velocity;
+                     // now launch the required amount of voices
+                     for (int i = 0; i < voicesRequired; i++)
+                         LaunchVoice(pEngineChannel, itNoteOffEventOnKeyList, i, true, false, false); //FIXME: for the moment we don't perform voice stealing for release triggered samples
+                 }
+                 pKey->ReleaseTrigger = false;
+             }
+         }
+         // if neither a voice was spawned or postponed on this key then remove note off event from key again
+         if (!pKey->Active && !pKey->VoiceTheftsQueued)
+             pKey->pEvents->free(itNoteOffEventOnKeyList);
      }
      /**
-      *  Moves pitchbend event from the general (input) event list to the pitch
+      *  Moves pitchbend event from the general (input) event list to the engine
-      *  event list.
+      *  channel's event list. It will actually processed later by the
+      *  respective voice.
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param itPitchbendEvent - absolute pitch value and time stamp of the event
       */
-     void Engine::ProcessPitchbend(Pool<Event>::Iterator& itPitchbendEvent) {
+     void Engine::ProcessPitchbend(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itPitchbendEvent) {
-         this->Pitch = itPitchbendEvent->Param.Pitch.Pitch; // store current pitch value
+         pEngineChannel->Pitch = itPitchbendEvent->Param.Pitch.Pitch; // store current pitch value
-         itPitchbendEvent.moveToEndOf(pSynthesisEvents[Event::destination_vco]);
      }
      /**
-Line 747 
 namespace LinuxSampler { namespace gig {
+Line 1216 
 namespace LinuxSampler { namespace gig {
       *  called by the ProcessNoteOn() method and by the voices itself
       *  (e.g. to spawn further voices on the same key for layered sounds).
       *
+      *  @param pEngineChannel      - engine channel on which this event occured on
       *  @param itNoteOnEvent       - key, velocity and time stamp of the event
       *  @param iLayer              - layer index for the new voice (optional - only
       *                               in case of layered sounds of course)
-Line 755 
 namespace LinuxSampler { namespace gig {
+Line 1225 
 namespace LinuxSampler { namespace gig {
       *  @param VoiceStealing       - if voice stealing should be performed
       *                               when there is no free voice
       *                               (optional, default = true)
+      *  @param HandleKeyGroupConflicts - if voices should be killed due to a
+      *                                   key group conflict
       *  @returns pointer to new voice or NULL if there was no free voice or
       *           if the voice wasn't triggered (for example when no region is
       *           defined for the given key).
       */
-     Pool<Voice>::Iterator Engine::LaunchVoice(Pool<Event>::Iterator& itNoteOnEvent, int iLayer, bool ReleaseTriggerVoice, bool VoiceStealing) {
+     Pool<Voice>::Iterator Engine::LaunchVoice(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOnEvent, int iLayer, bool ReleaseTriggerVoice, bool VoiceStealing, bool HandleKeyGroupConflicts) {
-         midi_key_info_t* pKey = &pMIDIKeyInfo[itNoteOnEvent->Param.Note.Key];
+         int MIDIKey            = itNoteOnEvent->Param.Note.Key;
+         midi_key_info_t* pKey  = &pEngineChannel->pMIDIKeyInfo[MIDIKey];
+         ::gig::Region* pRegion = pEngineChannel->pInstrument->GetRegion(MIDIKey);
+         // if nothing defined for this key
+         if (!pRegion) return Pool<Voice>::Iterator(); // nothing to do
+         // only mark the first voice of a layered voice (group) to be in a
+         // key group, so the layered voices won't kill each other
+         int iKeyGroup = (iLayer == 0 && !ReleaseTriggerVoice) ? pRegion->KeyGroup : 0;
+         // handle key group (a.k.a. exclusive group) conflicts
+         if (HandleKeyGroupConflicts) {
+             if (iKeyGroup) { // if this voice / key belongs to a key group
+                 uint** ppKeyGroup = &pEngineChannel->ActiveKeyGroups[iKeyGroup];
+                 if (*ppKeyGroup) { // if there's already an active key in that key group
+                     midi_key_info_t* pOtherKey = &pEngineChannel->pMIDIKeyInfo[**ppKeyGroup];
+                     // kill all voices on the (other) key
+                     RTList<Voice>::Iterator itVoiceToBeKilled = pOtherKey->pActiveVoices->first();
+                     RTList<Voice>::Iterator end               = pOtherKey->pActiveVoices->end();
+                     for (; itVoiceToBeKilled != end; ++itVoiceToBeKilled) {
+                         if (itVoiceToBeKilled->Type != Voice::type_release_trigger) {
+                             itVoiceToBeKilled->Kill(itNoteOnEvent);
+                             --VoiceSpawnsLeft; //FIXME: just a hack, we should better check in StealVoice() if the voice was killed due to key conflict
+                         }
+                     }
+                 }
+             }
+         }
+         Voice::type_t VoiceType = Voice::type_normal;
+         // get current dimension values to select the right dimension region
+         //TODO: for stolen voices this dimension region selection block is processed twice, this should be changed
+         //FIXME: controller values for selecting the dimension region here are currently not sample accurate
+         uint DimValues[8] = { 0 };
+         for (int i = pRegion->Dimensions - 1; i >= 0; i--) {
+             switch (pRegion->pDimensionDefinitions[i].dimension) {
+                 case ::gig::dimension_samplechannel:
+                     DimValues[i] = 0; //TODO: we currently ignore this dimension
+                     break;
+                 case ::gig::dimension_layer:
+                     DimValues[i] = iLayer;
+                     break;
+                 case ::gig::dimension_velocity:
+                     DimValues[i] = itNoteOnEvent->Param.Note.Velocity;
+                     break;
+                 case ::gig::dimension_channelaftertouch:
+                     DimValues[i] = pEngineChannel->ControllerTable[128];
+                     break;
+                 case ::gig::dimension_releasetrigger:
+                     VoiceType = (ReleaseTriggerVoice) ? Voice::type_release_trigger : (!iLayer) ? Voice::type_release_trigger_required : Voice::type_normal;
+                     DimValues[i] = (uint) ReleaseTriggerVoice;
+                     break;
+                 case ::gig::dimension_keyboard:
+                     DimValues[i] = (uint) (pEngineChannel->CurrentKeyDimension * pRegion->pDimensionDefinitions[i].zones);
+                     break;
+                 case ::gig::dimension_roundrobin:
+                     DimValues[i] = (uint) pEngineChannel->pMIDIKeyInfo[MIDIKey].RoundRobinIndex; // incremented for each note on
+                     break;
+                 case ::gig::dimension_random:
+                     RandomSeed   = RandomSeed * 1103515245 + 12345; // classic pseudo random number generator
+                     DimValues[i] = (uint) RandomSeed >> (32 - pRegion->pDimensionDefinitions[i].bits); // highest bits are most random
+                     break;
+                 case ::gig::dimension_modwheel:
+                     DimValues[i] = pEngineChannel->ControllerTable[1];
+                     break;
+                 case ::gig::dimension_breath:
+                     DimValues[i] = pEngineChannel->ControllerTable[2];
+                     break;
+                 case ::gig::dimension_foot:
+                     DimValues[i] = pEngineChannel->ControllerTable[4];
+                     break;
+                 case ::gig::dimension_portamentotime:
+                     DimValues[i] = pEngineChannel->ControllerTable[5];
+                     break;
+                 case ::gig::dimension_effect1:
+                     DimValues[i] = pEngineChannel->ControllerTable[12];
+                     break;
+                 case ::gig::dimension_effect2:
+                     DimValues[i] = pEngineChannel->ControllerTable[13];
+                     break;
+                 case ::gig::dimension_genpurpose1:
+                     DimValues[i] = pEngineChannel->ControllerTable[16];
+                     break;
+                 case ::gig::dimension_genpurpose2:
+                     DimValues[i] = pEngineChannel->ControllerTable[17];
+                     break;
+                 case ::gig::dimension_genpurpose3:
+                     DimValues[i] = pEngineChannel->ControllerTable[18];
+                     break;
+                 case ::gig::dimension_genpurpose4:
+                     DimValues[i] = pEngineChannel->ControllerTable[19];
+                     break;
+                 case ::gig::dimension_sustainpedal:
+                     DimValues[i] = pEngineChannel->ControllerTable[64];
+                     break;
+                 case ::gig::dimension_portamento:
+                     DimValues[i] = pEngineChannel->ControllerTable[65];
+                     break;
+                 case ::gig::dimension_sostenutopedal:
+                     DimValues[i] = pEngineChannel->ControllerTable[66];
+                     break;
+                 case ::gig::dimension_softpedal:
+                     DimValues[i] = pEngineChannel->ControllerTable[67];
+                     break;
+                 case ::gig::dimension_genpurpose5:
+                     DimValues[i] = pEngineChannel->ControllerTable[80];
+                     break;
+                 case ::gig::dimension_genpurpose6:
+                     DimValues[i] = pEngineChannel->ControllerTable[81];
+                     break;
+                 case ::gig::dimension_genpurpose7:
+                     DimValues[i] = pEngineChannel->ControllerTable[82];
+                     break;
+                 case ::gig::dimension_genpurpose8:
+                     DimValues[i] = pEngineChannel->ControllerTable[83];
+                     break;
+                 case ::gig::dimension_effect1depth:
+                     DimValues[i] = pEngineChannel->ControllerTable[91];
+                     break;
+                 case ::gig::dimension_effect2depth:
+                     DimValues[i] = pEngineChannel->ControllerTable[92];
+                     break;
+                 case ::gig::dimension_effect3depth:
+                     DimValues[i] = pEngineChannel->ControllerTable[93];
+                     break;
+                 case ::gig::dimension_effect4depth:
+                     DimValues[i] = pEngineChannel->ControllerTable[94];
+                     break;
+                 case ::gig::dimension_effect5depth:
+                     DimValues[i] = pEngineChannel->ControllerTable[95];
+                     break;
+                 case ::gig::dimension_none:
+                     std::cerr << "gig::Engine::LaunchVoice() Error: dimension=none\n" << std::flush;
+                     break;
+                 default:
+                     std::cerr << "gig::Engine::LaunchVoice() Error: Unknown dimension\n" << std::flush;
+             }
+         }
+         // return if this is a release triggered voice and there is no
+         // releasetrigger dimension (could happen if an instrument
+         // change has occured between note on and off)
+         if (ReleaseTriggerVoice && VoiceType != Voice::type_release_trigger) return Pool<Voice>::Iterator();
+         ::gig::DimensionRegion* pDimRgn = pRegion->GetDimensionRegionByValue(DimValues);
+         // no need to continue if sample is silent
+         if (!pDimRgn->pSample || !pDimRgn->pSample->SamplesTotal) return Pool<Voice>::Iterator();
          // allocate a new voice for the key
          Pool<Voice>::Iterator itNewVoice = pKey->pActiveVoices->allocAppend();
          if (itNewVoice) {
              // launch the new voice
-             if (itNewVoice->Trigger(itNoteOnEvent, this->Pitch, this->pInstrument, iLayer, ReleaseTriggerVoice, VoiceStealing) < 0) {
+             if (itNewVoice->Trigger(pEngineChannel, itNoteOnEvent, pEngineChannel->Pitch, pDimRgn, VoiceType, iKeyGroup) < 0) {
                  dmsg(4,("Voice not triggered\n"));
                  pKey->pActiveVoices->free(itNewVoice);
              }
              else { // on success
-                 uint** ppKeyGroup = NULL;
+                 --VoiceSpawnsLeft;
-                 if (itNewVoice->KeyGroup) { // if this voice / key belongs to a key group
-                     ppKeyGroup = &ActiveKeyGroups[itNewVoice->KeyGroup];
-                     if (*ppKeyGroup) { // if there's already an active key in that key group
-                         midi_key_info_t* pOtherKey = &pMIDIKeyInfo[**ppKeyGroup];
-                         // kill all voices on the (other) key
-                         RTList<Voice>::Iterator itVoiceToBeKilled = pOtherKey->pActiveVoices->first();
-                         RTList<Voice>::Iterator end               = pOtherKey->pActiveVoices->end();
-                         for (; itVoiceToBeKilled != end; ++itVoiceToBeKilled) {
-                             if (itVoiceToBeKilled->Type != Voice::type_release_trigger) itVoiceToBeKilled->Kill(itNoteOnEvent);
-                         }
-                     }
-                 }
                  if (!pKey->Active) { // mark as active key
                      pKey->Active = true;
-                     pKey->itSelf = pActiveKeys->allocAppend();
+                     pKey->itSelf = pEngineChannel->pActiveKeys->allocAppend();
                      *pKey->itSelf = itNoteOnEvent->Param.Note.Key;
                  }
                  if (itNewVoice->KeyGroup) {
+                     uint** ppKeyGroup = &pEngineChannel->ActiveKeyGroups[itNewVoice->KeyGroup];
                      *ppKeyGroup = &*pKey->itSelf; // put key as the (new) active key to its key group
                  }
                  if (itNewVoice->Type == Voice::type_release_trigger_required) pKey->ReleaseTrigger = true; // mark key for the need of release triggered voice(s)
-Line 797 
 namespace LinuxSampler { namespace gig {
+Line 1407 
 namespace LinuxSampler { namespace gig {
              }
          }
          else if (VoiceStealing) {
-             // first, get total amount of required voices (dependant on amount of layers)
+             // try to steal one voice
-             ::gig::Region* pRegion = pInstrument->GetRegion(itNoteOnEvent->Param.Note.Key);
+             int result = StealVoice(pEngineChannel, itNoteOnEvent);
-             if (!pRegion) return Pool<Voice>::Iterator(); // nothing defined for this MIDI key, so no voice needed
+             if (!result) { // voice stolen successfully
-             int voicesRequired = pRegion->Layers;
+                 // put note-on event into voice-stealing queue, so it will be reprocessed after killed voice died
+                 RTList<Event>::Iterator itStealEvent = pVoiceStealingQueue->allocAppend();
-             // now steal the (remaining) amount of voices
+                 if (itStealEvent) {
-             for (int i = iLayer; i < voicesRequired; i++)
+                     *itStealEvent = *itNoteOnEvent; // copy event
-                 StealVoice(itNoteOnEvent);
+                     itStealEvent->Param.Note.Layer = iLayer;
+                     itStealEvent->Param.Note.ReleaseTrigger = ReleaseTriggerVoice;
-             // put note-on event into voice-stealing queue, so it will be reprocessed after killed voice died
+                     pKey->VoiceTheftsQueued++;
-             RTList<Event>::Iterator itStealEvent = pVoiceStealingQueue->allocAppend();
+                 }
-             if (itStealEvent) {
+                 else dmsg(1,("Voice stealing queue full!\n"));
-                 *itStealEvent = *itNoteOnEvent; // copy event
-                 itStealEvent->Param.Note.Layer = iLayer;
-                 itStealEvent->Param.Note.ReleaseTrigger = ReleaseTriggerVoice;
              }
-             else dmsg(1,("Voice stealing queue full!\n"));
          }
          return Pool<Voice>::Iterator(); // no free voice or error
-Line 825 
 namespace LinuxSampler { namespace gig {
+Line 1431 
 namespace LinuxSampler { namespace gig {
       *  voice stealing and postpone the note-on event until the selected
       *  voice actually died.
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param itNoteOnEvent - key, velocity and time stamp of the event
+      *  @returns 0 on success, a value < 0 if no active voice could be picked for voice stealing
       */
-     void Engine::StealVoice(Pool<Event>::Iterator& itNoteOnEvent) {
+     int Engine::StealVoice(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itNoteOnEvent) {
+         if (VoiceSpawnsLeft <= 0) {
+             dmsg(1,("Max. voice thefts per audio fragment reached (you may raise CONFIG_MAX_VOICES).\n"));
+             return -1;
+         }
          if (!pEventPool->poolIsEmpty()) {
-             RTList<uint>::Iterator  iuiOldestKey;
+             RTList<Voice>::Iterator itSelectedVoice;
-             RTList<Voice>::Iterator itOldestVoice;
              // Select one voice for voice stealing
-             switch (VOICE_STEAL_ALGORITHM) {
+             switch (CONFIG_VOICE_STEAL_ALGO) {
                  // try to pick the oldest voice on the key where the new
                  // voice should be spawned, if there is no voice on that
-                 // key, or no voice left to kill there, then procceed with
+                 // key, or no voice left to kill, then procceed with
                  // 'oldestkey' algorithm
-                 case voice_steal_algo_keymask: {
+                 case voice_steal_algo_oldestvoiceonkey: {
-                     midi_key_info_t* pOldestKey = &pMIDIKeyInfo[itNoteOnEvent->Param.Note.Key];
+                     midi_key_info_t* pSelectedKey = &pEngineChannel->pMIDIKeyInfo[itNoteOnEvent->Param.Note.Key];
-                     if (itLastStolenVoice) {
+                     itSelectedVoice = pSelectedKey->pActiveVoices->first();
-                         itOldestVoice = itLastStolenVoice;
+                     // proceed iterating if voice was created in this fragment cycle
-                         ++itOldestVoice;
+                     while (itSelectedVoice && !itSelectedVoice->IsStealable()) ++itSelectedVoice;
-                     }
+                     // if we haven't found a voice then proceed with algorithm 'oldestkey'
-                     else { // no voice stolen in this audio fragment cycle yet
+                     if (itSelectedVoice && itSelectedVoice->IsStealable()) break;
-                         itOldestVoice = pOldestKey->pActiveVoices->first();
-                     }
-                     if (itOldestVoice) {
-                         iuiOldestKey = pOldestKey->itSelf;
-                         break; // selection succeeded
-                     }
                  } // no break - intentional !
                  // try to pick the oldest voice on the oldest active key
-                 // (caution: must stay after 'keymask' algorithm !)
+                 // from the same engine channel
+                 // (caution: must stay after 'oldestvoiceonkey' algorithm !)
                  case voice_steal_algo_oldestkey: {
-                     if (itLastStolenVoice) {
+                     // if we already stole in this fragment, try to proceed on same key
-                         midi_key_info_t* pOldestKey = &pMIDIKeyInfo[*iuiLastStolenKey];
+                     if (this->itLastStolenVoice) {
-                         itOldestVoice = itLastStolenVoice;
+                         itSelectedVoice = this->itLastStolenVoice;
-                         ++itOldestVoice;
+                         do {
-                         if (!itOldestVoice) {
+                             ++itSelectedVoice;
-                             iuiOldestKey = iuiLastStolenKey;
+                         } while (itSelectedVoice && !itSelectedVoice->IsStealable()); // proceed iterating if voice was created in this fragment cycle
-                             ++iuiOldestKey;
+                         // found a "stealable" voice ?
-                             if (iuiOldestKey) {
+                         if (itSelectedVoice && itSelectedVoice->IsStealable()) {
-                                 midi_key_info_t* pOldestKey = &pMIDIKeyInfo[*iuiOldestKey];
+                             // remember which voice we stole, so we can simply proceed on next voice stealing
-                                 itOldestVoice = pOldestKey->pActiveVoices->first();
+                             this->itLastStolenVoice = itSelectedVoice;
-                             }
+                             break; // selection succeeded
-                             else {
-                                 dmsg(1,("gig::Engine: Warning, too less voices, even for voice stealing! - Better recompile with higher MAX_AUDIO_VOICES.\n"));
-                                 return;
-                             }
                          }
-                         else iuiOldestKey = iuiLastStolenKey;
                      }
-                     else { // no voice stolen in this audio fragment cycle yet
+                     // get (next) oldest key
-                         iuiOldestKey = pActiveKeys->first();
+                     RTList<uint>::Iterator iuiSelectedKey = (this->iuiLastStolenKey) ? ++this->iuiLastStolenKey : pEngineChannel->pActiveKeys->first();
-                         midi_key_info_t* pOldestKey = &pMIDIKeyInfo[*iuiOldestKey];
+                     while (iuiSelectedKey) {
-                         itOldestVoice = pOldestKey->pActiveVoices->first();
+                         midi_key_info_t* pSelectedKey = &pEngineChannel->pMIDIKeyInfo[*iuiSelectedKey];
+                         itSelectedVoice = pSelectedKey->pActiveVoices->first();
+                         // proceed iterating if voice was created in this fragment cycle
+                         while (itSelectedVoice && !itSelectedVoice->IsStealable()) ++itSelectedVoice;
+                         // found a "stealable" voice ?
+                         if (itSelectedVoice && itSelectedVoice->IsStealable()) {
+                             // remember which voice on which key we stole, so we can simply proceed on next voice stealing
+                             this->iuiLastStolenKey  = iuiSelectedKey;
+                             this->itLastStolenVoice = itSelectedVoice;
+                             break; // selection succeeded
+                         }
+                         ++iuiSelectedKey; // get next oldest key
                      }
                      break;
                  }
-Line 888 
 namespace LinuxSampler { namespace gig {
+Line 1500 
 namespace LinuxSampler { namespace gig {
                  case voice_steal_algo_none:
                  default: {
                      dmsg(1,("No free voice (voice stealing disabled)!\n"));
-                     return;
+                     return -1;
+                 }
+             }
+             // if we couldn't steal a voice from the same engine channel then
+             // steal oldest voice on the oldest key from any other engine channel
+             // (the smaller engine channel number, the higher priority)
+             if (!itSelectedVoice || !itSelectedVoice->IsStealable()) {
+                 EngineChannel* pSelectedChannel;
+                 int            iChannelIndex;
+                 // select engine channel
+                 if (pLastStolenChannel) {
+                     pSelectedChannel = pLastStolenChannel;
+                     iChannelIndex    = pSelectedChannel->iEngineIndexSelf;
+                 } else { // pick the engine channel followed by this engine channel
+                     iChannelIndex    = (pEngineChannel->iEngineIndexSelf + 1) % engineChannels.size();
+                     pSelectedChannel = engineChannels[iChannelIndex];
+                 }
+                 // if we already stole in this fragment, try to proceed on same key
+                 if (this->itLastStolenVoiceGlobally) {
+                     itSelectedVoice = this->itLastStolenVoiceGlobally;
+                     do {
+                         ++itSelectedVoice;
+                     } while (itSelectedVoice && !itSelectedVoice->IsStealable()); // proceed iterating if voice was created in this fragment cycle
+                 }
+                 #if CONFIG_DEVMODE
+                 EngineChannel* pBegin = pSelectedChannel; // to detect endless loop
+                 #endif // CONFIG_DEVMODE
+                 // did we find a 'stealable' voice?
+                 if (itSelectedVoice && itSelectedVoice->IsStealable()) {
+                     // remember which voice we stole, so we can simply proceed on next voice stealing
+                     this->itLastStolenVoiceGlobally = itSelectedVoice;
+                 } else while (true) { // iterate through engine channels
+                     // get (next) oldest key
+                     RTList<uint>::Iterator iuiSelectedKey = (this->iuiLastStolenKeyGlobally) ? ++this->iuiLastStolenKeyGlobally : pSelectedChannel->pActiveKeys->first();
+                     this->iuiLastStolenKeyGlobally = RTList<uint>::Iterator(); // to prevent endless loop (see line above)
+                     while (iuiSelectedKey) {
+                         midi_key_info_t* pSelectedKey = &pSelectedChannel->pMIDIKeyInfo[*iuiSelectedKey];
+                         itSelectedVoice = pSelectedKey->pActiveVoices->first();
+                         // proceed iterating if voice was created in this fragment cycle
+                         while (itSelectedVoice && !itSelectedVoice->IsStealable()) ++itSelectedVoice;
+                         // found a "stealable" voice ?
+                         if (itSelectedVoice && itSelectedVoice->IsStealable()) {
+                             // remember which voice on which key on which engine channel we stole, so we can simply proceed on next voice stealing
+                             this->iuiLastStolenKeyGlobally  = iuiSelectedKey;
+                             this->itLastStolenVoiceGlobally = itSelectedVoice;
+                             this->pLastStolenChannel        = pSelectedChannel;
+                             goto stealable_voice_found; // selection succeeded
+                         }
+                         ++iuiSelectedKey; // get next key on current engine channel
+                     }
+                     // get next engine channel
+                     iChannelIndex    = (iChannelIndex + 1) % engineChannels.size();
+                     pSelectedChannel = engineChannels[iChannelIndex];
+                     #if CONFIG_DEVMODE
+                     if (pSelectedChannel == pBegin) {
+                         dmsg(1,("FATAL ERROR: voice stealing endless loop!\n"));
+                         dmsg(1,("VoiceSpawnsLeft=%d.\n", VoiceSpawnsLeft));
+                         dmsg(1,("Exiting.\n"));
+                         exit(-1);
+                     }
+                     #endif // CONFIG_DEVMODE
                  }
              }
-             //FIXME: can be removed, just a sanity check for debugging
+             // jump point if a 'stealable' voice was found
-             if (!itOldestVoice->IsActive()) dmsg(1,("gig::Engine: ERROR, tried to steal a voice which was not active !!!\n"));
+             stealable_voice_found:
+             #if CONFIG_DEVMODE
+             if (!itSelectedVoice->IsActive()) {
+                 dmsg(1,("gig::Engine: ERROR, tried to steal a voice which was not active !!!\n"));
+                 return -1;
+             }
+             #endif // CONFIG_DEVMODE
              // now kill the selected voice
-             itOldestVoice->Kill(itNoteOnEvent);
+             itSelectedVoice->Kill(itNoteOnEvent);
-             // remember which voice on which key we stole, so we can simply proceed for the next voice stealing
-             this->itLastStolenVoice = itOldestVoice;
+             --VoiceSpawnsLeft;
-             this->iuiLastStolenKey = iuiOldestKey;
+             return 0; // success
+         }
+         else {
+             dmsg(1,("Event pool emtpy!\n"));
+             return -1;
          }
-         else dmsg(1,("Event pool emtpy!\n"));
      }
      /**
-Line 910 
 namespace LinuxSampler { namespace gig {
+Line 1598 
 namespace LinuxSampler { namespace gig {
       *  it finished to playback its sample, finished its release stage or
       *  just was killed.
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param itVoice - points to the voice to be freed
       */
-     void Engine::FreeVoice(Pool<Voice>::Iterator& itVoice) {
+     void Engine::FreeVoice(EngineChannel* pEngineChannel, Pool<Voice>::Iterator& itVoice) {
          if (itVoice) {
-             midi_key_info_t* pKey = &pMIDIKeyInfo[itVoice->MIDIKey];
+             midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[itVoice->MIDIKey];
              uint keygroup = itVoice->KeyGroup;
+             // if the sample and dimension region belong to an
+             // instrument that is unloaded, tell the disk thread to
+             // release them
+             if (itVoice->Orphan) {
+                 pDiskThread->OrderDeletionOfDimreg(itVoice->pDimRgn);
+             }
              // free the voice object
              pVoicePool->free(itVoice);
              // if no other voices left and member of a key group, remove from key group
              if (pKey->pActiveVoices->isEmpty() && keygroup) {
-                 uint** ppKeyGroup = &ActiveKeyGroups[keygroup];
+                 uint** ppKeyGroup = &pEngineChannel->ActiveKeyGroups[keygroup];
                  if (*ppKeyGroup == &*pKey->itSelf) *ppKeyGroup = NULL; // remove key from key group
              }
          }
-Line 934 
 namespace LinuxSampler { namespace gig {
+Line 1630 
 namespace LinuxSampler { namespace gig {
       *  Called when there's no more voice left on a key, this call will
       *  update the key info respectively.
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param pKey - key which is now inactive
       */
-     void Engine::FreeKey(midi_key_info_t* pKey) {
+     void Engine::FreeKey(EngineChannel* pEngineChannel, midi_key_info_t* pKey) {
          if (pKey->pActiveVoices->isEmpty()) {
              pKey->Active = false;
-             pActiveKeys->free(pKey->itSelf); // remove key from list of active keys
+             pEngineChannel->pActiveKeys->free(pKey->itSelf); // remove key from list of active keys
              pKey->itSelf = RTList<uint>::Iterator();
              pKey->ReleaseTrigger = false;
              pKey->pEvents->clear();
-Line 952 
 namespace LinuxSampler { namespace gig {
+Line 1649 
 namespace LinuxSampler { namespace gig {
       *  Reacts on supported control change commands (e.g. pitch bend wheel,
       *  modulation wheel, aftertouch).
       *
+      *  @param pEngineChannel - engine channel on which this event occured on
       *  @param itControlChangeEvent - controller, value and time stamp of the event
       */
-     void Engine::ProcessControlChange(Pool<Event>::Iterator& itControlChangeEvent) {
+     void Engine::ProcessControlChange(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itControlChangeEvent) {
          dmsg(4,("Engine::ContinuousController cc=%d v=%d\n", itControlChangeEvent->Param.CC.Controller, itControlChangeEvent->Param.CC.Value));
+         // handle the "control triggered" MIDI rule: a control change
+         // event can trigger a new note on or note off event
+         if (pEngineChannel->pInstrument) {
+             ::gig::MidiRule* rule;
+             for (int i = 0 ; (rule = pEngineChannel->pInstrument->GetMidiRule(i)) ; i++) {
+                 if (::gig::MidiRuleCtrlTrigger* ctrlTrigger =
+                     dynamic_cast< ::gig::MidiRuleCtrlTrigger*>(rule)) {
+                     if (itControlChangeEvent->Param.CC.Controller ==
+                         ctrlTrigger->ControllerNumber) {
+                         uint8_t oldCCValue = pEngineChannel->ControllerTable[
+                             itControlChangeEvent->Param.CC.Controller];
+                         uint8_t newCCValue = itControlChangeEvent->Param.CC.Value;
+                         for (int i = 0 ; i < ctrlTrigger->Triggers ; i++) {
+                             ::gig::MidiRuleCtrlTrigger::trigger_t* pTrigger =
+                                   &ctrlTrigger->pTriggers[i];
+                             // check if the controller has passed the
+                             // trigger point in the right direction
+                             if ((pTrigger->Descending &&
+                                  oldCCValue > pTrigger->TriggerPoint &&
+                                  newCCValue <= pTrigger->TriggerPoint) ||
+                                 (!pTrigger->Descending &&
+                                  oldCCValue < pTrigger->TriggerPoint &&
+                                  newCCValue >= pTrigger->TriggerPoint)) {
+                                 RTList<Event>::Iterator itNewEvent = pGlobalEvents->allocAppend();
+                                 if (itNewEvent) {
+                                     *itNewEvent = *itControlChangeEvent;
+                                     itNewEvent->Param.Note.Key = pTrigger->Key;
+                                     if (pTrigger->NoteOff || pTrigger->Velocity == 0) {
+                                         itNewEvent->Type = Event::type_note_off;
+                                         itNewEvent->Param.Note.Velocity = 100;
+                                         ProcessNoteOff(pEngineChannel, itNewEvent);
+                                     } else {
+                                         itNewEvent->Type = Event::type_note_on;
+                                         //TODO: if Velocity is 255, the triggered velocity should
+                                         // depend on how fast the controller is moving
+                                         itNewEvent->Param.Note.Velocity =
+                                             pTrigger->Velocity == 255 ? 100 :
+                                             pTrigger->Velocity;
+                                         ProcessNoteOn(pEngineChannel, itNewEvent);
+                                     }
+                                 }
+                                 else dmsg(1,("Event pool emtpy!\n"));
+                             }
+                         }
+                     }
+                 }
+             }
+         }
+         // update controller value in the engine channel's controller table
+         pEngineChannel->ControllerTable[itControlChangeEvent->Param.CC.Controller] = itControlChangeEvent->Param.CC.Value;
+         // handle hard coded MIDI controllers
          switch (itControlChangeEvent->Param.CC.Controller) {
-             case 64: {
+             case 5: { // portamento time
-                 if (itControlChangeEvent->Param.CC.Value >= 64 && !SustainPedal) {
+                 pEngineChannel->PortamentoTime = (float) itControlChangeEvent->Param.CC.Value / 127.0f * (float) CONFIG_PORTAMENTO_TIME_MAX + (float) CONFIG_PORTAMENTO_TIME_MIN;
-                     dmsg(4,("PEDAL DOWN\n"));
+                 break;
-                     SustainPedal = true;
+             }
+             case 6: { // data entry (currently only used for RPN controllers)
+                 if (pEngineChannel->GetMidiRpnController() == 2) { // coarse tuning in half tones
+                     int transpose = (int) itControlChangeEvent->Param.CC.Value - 64;
+                     // limit to +- two octaves for now
+                     transpose = RTMath::Min(transpose,  24);
+                     transpose = RTMath::Max(transpose, -24);
+                     pEngineChannel->GlobalTranspose = transpose;
+                     // workaround, so we won't have hanging notes
+                     ReleaseAllVoices(pEngineChannel, itControlChangeEvent);
+                 }
+                 // to avoid other MIDI CC #6 messages to be misenterpreted as RPN controller data
+                 pEngineChannel->ResetMidiRpnController();
+                 break;
+             }
+             case 7: { // volume
+                 //TODO: not sample accurate yet
+                 pEngineChannel->MidiVolume = VolumeCurve[itControlChangeEvent->Param.CC.Value];
+                 pEngineChannel->bStatusChanged = true; // engine channel status has changed, so set notify flag
+                 break;
+             }
+             case 10: { // panpot
+                 //TODO: not sample accurate yet
+                 pEngineChannel->GlobalPanLeft  = PanCurve[128 - itControlChangeEvent->Param.CC.Value];
+                 pEngineChannel->GlobalPanRight = PanCurve[itControlChangeEvent->Param.CC.Value];
+                 pEngineChannel->iLastPanRequest = itControlChangeEvent->Param.CC.Value;
+                 break;
+             }
+             case 64: { // sustain
+                 if (itControlChangeEvent->Param.CC.Value >= 64 && !pEngineChannel->SustainPedal) {
+                     dmsg(4,("DAMPER (RIGHT) PEDAL DOWN\n"));
+                     pEngineChannel->SustainPedal = true;
+                     #if !CONFIG_PROCESS_MUTED_CHANNELS
+                     if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+                     #endif
                      // cancel release process of voices if necessary
-                     RTList<uint>::Iterator iuiKey = pActiveKeys->first();
+                     RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
-                     if (iuiKey) {
+                     for (; iuiKey; ++iuiKey) {
-                         itControlChangeEvent->Type = Event::type_cancel_release; // transform event type
+                         midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
-                         while (iuiKey) {
+                         if (!pKey->KeyPressed) {
-                             midi_key_info_t* pKey = &pMIDIKeyInfo[*iuiKey];
+                             RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
-                             ++iuiKey;
+                             if (itNewEvent) {
-                             if (!pKey->KeyPressed) {
+                                 *itNewEvent = *itControlChangeEvent; // copy event to the key's own event list
-                                 RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
+                                 itNewEvent->Type = Event::type_cancel_release; // transform event type
-                                 if (itNewEvent) *itNewEvent = *itControlChangeEvent; // copy event to the key's own event list
-                                 else dmsg(1,("Event pool emtpy!\n"));
                              }
+                             else dmsg(1,("Event pool emtpy!\n"));
                          }
                      }
                  }
-                 if (itControlChangeEvent->Param.CC.Value < 64 && SustainPedal) {
+                 if (itControlChangeEvent->Param.CC.Value < 64 && pEngineChannel->SustainPedal) {
-                     dmsg(4,("PEDAL UP\n"));
+                     dmsg(4,("DAMPER (RIGHT) PEDAL UP\n"));
-                     SustainPedal = false;
+                     pEngineChannel->SustainPedal = false;
+                     #if !CONFIG_PROCESS_MUTED_CHANNELS
+                     if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+                     #endif
                      // release voices if their respective key is not pressed
-                     RTList<uint>::Iterator iuiKey = pActiveKeys->first();
+                     RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
-                     if (iuiKey) {
+                     for (; iuiKey; ++iuiKey) {
-                         itControlChangeEvent->Type = Event::type_release; // transform event type
+                         midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
-                         while (iuiKey) {
+                         if (!pKey->KeyPressed && ShouldReleaseVoice(pEngineChannel, *iuiKey)) {
-                             midi_key_info_t* pKey = &pMIDIKeyInfo[*iuiKey];
+                             RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
-                             ++iuiKey;
+                             if (itNewEvent) {
-                             if (!pKey->KeyPressed) {
+                                 *itNewEvent = *itControlChangeEvent; // copy event to the key's own event list
-                                 RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
+                                 itNewEvent->Type = Event::type_release; // transform event type
-                                 if (itNewEvent) *itNewEvent = *itControlChangeEvent; // copy event to the key's own event list
-                                 else dmsg(1,("Event pool emtpy!\n"));
                              }
+                             else dmsg(1,("Event pool emtpy!\n"));
                          }
                      }
                  }
                  break;
              }
-         }
+             case 65: { // portamento on / off
+                 const bool bPortamento = itControlChangeEvent->Param.CC.Value >= 64;
+                 if (bPortamento != pEngineChannel->PortamentoMode)
+                     KillAllVoices(pEngineChannel, itControlChangeEvent);
+                 pEngineChannel->PortamentoMode = bPortamento;
+                 break;
+             }
+             case 66: { // sostenuto
+                 if (itControlChangeEvent->Param.CC.Value >= 64 && !pEngineChannel->SostenutoPedal) {
+                     dmsg(4,("SOSTENUTO (CENTER) PEDAL DOWN\n"));
+                     pEngineChannel->SostenutoPedal = true;
+                     #if !CONFIG_PROCESS_MUTED_CHANNELS
+                     if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+                     #endif
+                     SostenutoKeyCount = 0;
+                     // Remeber the pressed keys
+                     RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
+                     for (; iuiKey; ++iuiKey) {
+                         midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
+                         if (pKey->KeyPressed && SostenutoKeyCount < 128) SostenutoKeys[SostenutoKeyCount++] = *iuiKey;
+                     }
+                 }
+                 if (itControlChangeEvent->Param.CC.Value < 64 && pEngineChannel->SostenutoPedal) {
+                     dmsg(4,("SOSTENUTO (CENTER) PEDAL UP\n"));
+                     pEngineChannel->SostenutoPedal = false;
+                     #if !CONFIG_PROCESS_MUTED_CHANNELS
+                     if (pEngineChannel->GetMute()) return; // skip if sampler channel is muted
+                     #endif
+                     // release voices if the damper pedal is up and their respective key is not pressed
+                     for (int i = 0; i < SostenutoKeyCount; i++) {
+                         midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[SostenutoKeys[i]];
+                         if (!pKey->KeyPressed && !pEngineChannel->SustainPedal) {
+                             RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
+                             if (itNewEvent) {
+                                 *itNewEvent = *itControlChangeEvent; // copy event to the key's own event list
+                                 itNewEvent->Type = Event::type_release; // transform event type
+                             }
+                             else dmsg(1,("Event pool emtpy!\n"));
+                         }
+                     }
+                 }
+                 break;
+             }
+             case 100: { // RPN controller LSB
+                 pEngineChannel->SetMidiRpnControllerLsb(itControlChangeEvent->Param.CC.Value);
+                 break;
+             }
+             case 101: { // RPN controller MSB
+                 pEngineChannel->SetMidiRpnControllerMsb(itControlChangeEvent->Param.CC.Value);
+                 break;
+             }
-         // update controller value in the engine's controller table
-         ControllerTable[itControlChangeEvent->Param.CC.Controller] = itControlChangeEvent->Param.CC.Value;
-         // move event from the unsorted event list to the control change event list
+             // Channel Mode Messages
-         itControlChangeEvent.moveToEndOf(pCCEvents);
+             case 120: { // all sound off
+                 KillAllVoices(pEngineChannel, itControlChangeEvent);
+                 break;
+             }
+             case 121: { // reset all controllers
+                 pEngineChannel->ResetControllers();
+                 break;
+             }
+             case 123: { // all notes off
+                 #if CONFIG_PROCESS_ALL_NOTES_OFF
+                 ReleaseAllVoices(pEngineChannel, itControlChangeEvent);
+                 #endif // CONFIG_PROCESS_ALL_NOTES_OFF
+                 break;
+             }
+             case 126: { // mono mode on
+                 if (!pEngineChannel->SoloMode)
+                     KillAllVoices(pEngineChannel, itControlChangeEvent);
+                 pEngineChannel->SoloMode = true;
+                 break;
+             }
+             case 127: { // poly mode on
+                 if (pEngineChannel->SoloMode)
+                     KillAllVoices(pEngineChannel, itControlChangeEvent);
+                 pEngineChannel->SoloMode = false;
+                 break;
+             }
+         }
+         // handle FX send controllers
+         if (!pEngineChannel->fxSends.empty()) {
+             for (int iFxSend = 0; iFxSend < pEngineChannel->GetFxSendCount(); iFxSend++) {
+                 FxSend* pFxSend = pEngineChannel->GetFxSend(iFxSend);
+                 if (pFxSend->MidiController() == itControlChangeEvent->Param.CC.Controller) {
+                     pFxSend->SetLevel(itControlChangeEvent->Param.CC.Value);
+                     pFxSend->SetInfoChanged(true);
+                 }
+             }
+         }
      }
      /**
-Line 1014 
 namespace LinuxSampler { namespace gig {
+Line 1901 
 namespace LinuxSampler { namespace gig {
       *  @param itSysexEvent - sysex data size and time stamp of the sysex event
       */
      void Engine::ProcessSysex(Pool<Event>::Iterator& itSysexEvent) {
-         RingBuffer<uint8_t>::NonVolatileReader reader = pSysexBuffer->get_non_volatile_reader();
+         RingBuffer<uint8_t,false>::NonVolatileReader reader = pSysexBuffer->get_non_volatile_reader();
          uint8_t exclusive_status, id;
          if (!reader.pop(&exclusive_status)) goto free_sysex_data;
-Line 1022 
 namespace LinuxSampler { namespace gig {
+Line 1909 
 namespace LinuxSampler { namespace gig {
          if (exclusive_status != 0xF0)       goto free_sysex_data;
          switch (id) {
+             case 0x7f: { // (Realtime) Universal Sysex (GM Standard)
+                 uint8_t sysex_channel, sub_id1, sub_id2, val_msb, val_lsb;;
+                 if (!reader.pop(&sysex_channel)) goto free_sysex_data;
+                 if (!reader.pop(&sub_id1)) goto free_sysex_data;
+                 if (!reader.pop(&sub_id2)) goto free_sysex_data;
+                 if (!reader.pop(&val_lsb)) goto free_sysex_data;
+                 if (!reader.pop(&val_msb)) goto free_sysex_data;
+                 //TODO: for now we simply ignore the sysex channel, seldom used anyway
+                 switch (sub_id1) {
+                     case 0x04: // Device Control
+                         switch (sub_id2) {
+                             case 0x01: { // Master Volume
+                                 const double volume =
+                                     double((uint(val_msb)<<7) | uint(val_lsb)) / 16383.0;
+                                 #if CONFIG_MASTER_VOLUME_SYSEX_BY_PORT
+                                 // apply volume to all sampler channels that
+                                 // are connected to the same MIDI input port
+                                 // this sysex message arrived on
+                                 for (int i = 0; i < engineChannels.size(); ++i) {
+                                     EngineChannel* pEngineChannel = engineChannels[i];
+                                     if (pEngineChannel->GetMidiInputPort() ==
+                                         itSysexEvent->pMidiInputPort)
+                                     {
+                                         pEngineChannel->Volume(volume);
+                                     }
+                                 }
+                                 #else
+                                 // apply volume globally to the whole sampler
+                                 GLOBAL_VOLUME = volume;
+                                 #endif // CONFIG_MASTER_VOLUME_SYSEX_BY_PORT
+                                 break;
+                             }
+                         }
+                         break;
+                 }
+                 break;
+             }
              case 0x41: { // Roland
+                 dmsg(3,("Roland Sysex\n"));
                  uint8_t device_id, model_id, cmd_id;
                  if (!reader.pop(&device_id)) goto free_sysex_data;
                  if (!reader.pop(&model_id))  goto free_sysex_data;
-Line 1032 
 namespace LinuxSampler { namespace gig {
+Line 1957 
 namespace LinuxSampler { namespace gig {
                  // command address
                  uint8_t addr[3]; // 2 byte addr MSB, followed by 1 byte addr LSB)
-                 const RingBuffer<uint8_t>::NonVolatileReader checksum_reader = reader; // so we can calculate the check sum later
+                 const RingBuffer<uint8_t,false>::NonVolatileReader checksum_reader = reader; // so we can calculate the check sum later
                  if (reader.read(&addr[0], 3) != 3) goto free_sysex_data;
                  if (addr[0] == 0x40 && addr[1] == 0x00) { // System Parameters
+                     dmsg(3,("\tSystem Parameter\n"));
+                     if (addr[2] == 0x7f) { // GS reset
+                         for (int i = 0; i < engineChannels.size(); ++i) {
+                             EngineChannel* pEngineChannel = engineChannels[i];
+                             if (pEngineChannel->GetMidiInputPort() == itSysexEvent->pMidiInputPort) {
+                                 KillAllVoices(pEngineChannel, itSysexEvent);
+                                 pEngineChannel->ResetControllers();
+                             }
+                         }
+                     }
                  }
                  else if (addr[0] == 0x40 && addr[1] == 0x01) { // Common Parameters
+                     dmsg(3,("\tCommon Parameter\n"));
                  }
                  else if (addr[0] == 0x40 && (addr[1] & 0xf0) == 0x10) { // Part Parameters (1)
-                     switch (addr[3]) {
+                     dmsg(3,("\tPart Parameter\n"));
+                     switch (addr[2]) {
                          case 0x40: { // scale tuning
+                             dmsg(3,("\t\tScale Tuning\n"));
                              uint8_t scale_tunes[12]; // detuning of all 12 semitones of an octave
                              if (reader.read(&scale_tunes[0], 12) != 12) goto free_sysex_data;
                              uint8_t checksum;
-                             if (!reader.pop(&checksum))                      goto free_sysex_data;
+                             if (!reader.pop(&checksum)) goto free_sysex_data;
-                             if (GSCheckSum(checksum_reader, 12) != checksum) goto free_sysex_data;
+                             #if CONFIG_ASSERT_GS_SYSEX_CHECKSUM
+                             if (GSCheckSum(checksum_reader, 12)) goto free_sysex_data;
+                             #endif // CONFIG_ASSERT_GS_SYSEX_CHECKSUM
                              for (int i = 0; i < 12; i++) scale_tunes[i] -= 64;
                              AdjustScale((int8_t*) scale_tunes);
+                             dmsg(3,("\t\t\tNew scale applied.\n"));
+                             break;
+                         }
+                         case 0x15: { // chromatic / drumkit mode
+                             dmsg(3,("\t\tMIDI Instrument Map Switch\n"));
+                             uint8_t part = addr[1] & 0x0f;
+                             uint8_t map;
+                             if (!reader.pop(&map)) goto free_sysex_data;
+                             for (int i = 0; i < engineChannels.size(); ++i) {
+                                 EngineChannel* pEngineChannel = engineChannels[i];
+                                 if (
+                                     (pEngineChannel->midiChannel == part ||
+                                      pEngineChannel->midiChannel == midi_chan_all) &&
+                                      pEngineChannel->GetMidiInputPort() == itSysexEvent->pMidiInputPort
+                                 ) {
+                                     try {
+                                         pEngineChannel->SetMidiInstrumentMap(map);
+                                     } catch (Exception e) {
+                                         dmsg(2,("\t\t\tCould not apply MIDI instrument map %d to part %d: %s\n", map, part, e.Message().c_str()));
+                                         goto free_sysex_data;
+                                     } catch (...) {
+                                         dmsg(2,("\t\t\tCould not apply MIDI instrument map %d to part %d (unknown exception)\n", map, part));
+                                         goto free_sysex_data;
+                                     }
+                                 }
+                             }
+                             dmsg(3,("\t\t\tApplied MIDI instrument map %d to part %d.\n", map, part));
                              break;
                          }
                      }
-Line 1072 
 namespace LinuxSampler { namespace gig {
+Line 2039 
 namespace LinuxSampler { namespace gig {
       *                     question
       * @param DataSize   - size of the GS message data (in bytes)
       */
-     uint8_t Engine::GSCheckSum(const RingBuffer<uint8_t>::NonVolatileReader AddrReader, uint DataSize) {
+     uint8_t Engine::GSCheckSum(const RingBuffer<uint8_t,false>::NonVolatileReader AddrReader, uint DataSize) {
-         RingBuffer<uint8_t>::NonVolatileReader reader = AddrReader;
+         RingBuffer<uint8_t,false>::NonVolatileReader reader = AddrReader;
          uint bytes = 3 /*addr*/ + DataSize;
          uint8_t addr_and_data[bytes];
          reader.read(&addr_and_data[0], bytes);
-Line 1092 
 namespace LinuxSampler { namespace gig {
+Line 2059 
 namespace LinuxSampler { namespace gig {
      }
      /**
-      * Initialize the parameter sequence for the modulation destination given by
+      * Releases all voices on an engine channel. All voices will go into
-      * by 'dst' with the constant value given by val.
+      * the release stage and thus it might take some time (e.g. dependant to
+      * their envelope release time) until they actually die.
+      *
+      * @param pEngineChannel - engine channel on which all voices should be released
+      * @param itReleaseEvent - event which caused this releasing of all voices
       */
-     void Engine::ResetSynthesisParameters(Event::destination_t dst, float val) {
+     void Engine::ReleaseAllVoices(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itReleaseEvent) {
-         int maxsamples = pAudioOutputDevice->MaxSamplesPerCycle();
+         RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
-         float* m = &pSynthesisParameters[dst][0];
+         while (iuiKey) {
-         for (int i = 0; i < maxsamples; i += 4) {
+             midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
-            m[i]   = val;
+             ++iuiKey;
-            m[i+1] = val;
+             // append a 'release' event to the key's own event list
-            m[i+2] = val;
+             RTList<Event>::Iterator itNewEvent = pKey->pEvents->allocAppend();
-            m[i+3] = val;
+             if (itNewEvent) {
+                 *itNewEvent = *itReleaseEvent; // copy original event (to the key's event list)
+                 itNewEvent->Type = Event::type_release; // transform event type
+             }
+             else dmsg(1,("Event pool emtpy!\n"));
          }
      }
-     float Engine::Volume() {
+     /**
-         return GlobalVolume;
+      * Kills all voices on an engine channel as soon as possible. Voices
+      * won't get into release state, their volume level will be ramped down
+      * as fast as possible.
+      *
+      * @param pEngineChannel - engine channel on which all voices should be killed
+      * @param itKillEvent    - event which caused this killing of all voices
+      */
+     void Engine::KillAllVoices(EngineChannel* pEngineChannel, Pool<Event>::Iterator& itKillEvent) {
+         RTList<uint>::Iterator iuiKey = pEngineChannel->pActiveKeys->first();
+         RTList<uint>::Iterator end    = pEngineChannel->pActiveKeys->end();
+         while (iuiKey != end) { // iterate through all active keys
+             midi_key_info_t* pKey = &pEngineChannel->pMIDIKeyInfo[*iuiKey];
+             ++iuiKey;
+             RTList<Voice>::Iterator itVoice     = pKey->pActiveVoices->first();
+             RTList<Voice>::Iterator itVoicesEnd = pKey->pActiveVoices->end();
+             for (; itVoice != itVoicesEnd; ++itVoice) { // iterate through all voices on this key
+                 itVoice->Kill(itKillEvent);
+                 --VoiceSpawnsLeft; //FIXME: just a temporary workaround, we should check the cause in StealVoice() instead
+             }
+         }
      }
-     void Engine::Volume(float f) {
+     /**
-         GlobalVolume = f;
+      * Determines whether the specified voice should be released.
+      *
+      * @param pEngineChannel - The engine channel on which the voice should be checked
+      * @param Key - The key number
+      * @returns true if the specified should be released, false otherwise.
+      */
+     bool Engine::ShouldReleaseVoice(EngineChannel* pEngineChannel, int Key) {
+         if (pEngineChannel->SustainPedal) return false;
+         if (pEngineChannel->SostenutoPedal) {
+             for (int i = 0; i < SostenutoKeyCount; i++)
+                 if (Key == SostenutoKeys[i]) return false;
+         }
+         return true;
      }
-     uint Engine::Channels() {
+     uint Engine::VoiceCount() {
-         return 2;
+         return atomic_read(&ActiveVoiceCount);
      }
-     void Engine::SetOutputChannel(uint EngineAudioChannel, uint AudioDeviceChannel) {
+     void Engine::SetVoiceCount(uint Count) {
-         AudioChannel* pChannel = pAudioOutputDevice->Channel(AudioDeviceChannel);
+         atomic_set(&ActiveVoiceCount, Count);
-         if (!pChannel) throw AudioOutputException("Invalid audio output device channel " + ToString(AudioDeviceChannel));
-         switch (EngineAudioChannel) {
-             case 0: // left output channel
-                 pOutputLeft = pChannel->Buffer();
-                 AudioDeviceChannelLeft = AudioDeviceChannel;
-                 break;
-             case 1: // right output channel
-                 pOutputRight = pChannel->Buffer();
-                 AudioDeviceChannelRight = AudioDeviceChannel;
-                 break;
-             default:
-                 throw AudioOutputException("Invalid engine audio channel " + ToString(EngineAudioChannel));
-         }
      }
-     int Engine::OutputChannel(uint EngineAudioChannel) {
+     uint Engine::VoiceCountMax() {
-         switch (EngineAudioChannel) {
+         return ActiveVoiceCountMax;
-             case 0: // left channel
-                 return AudioDeviceChannelLeft;
-             case 1: // right channel
-                 return AudioDeviceChannelRight;
-             default:
-                 throw AudioOutputException("Invalid engine audio channel " + ToString(EngineAudioChannel));
-         }
      }
-     uint Engine::VoiceCount() {
+     int Engine::MaxVoices() {
-         return ActiveVoiceCount;
+         return pVoicePool->poolSize();
      }
-     uint Engine::VoiceCountMax() {
+     void Engine::SetMaxVoices(int iVoices) throw (Exception) {
-         return ActiveVoiceCountMax;
+         if (iVoices < 1)
+             throw Exception("Maximum voices for an engine cannot be set lower than 1");
+         SuspendAll();
+         // NOTE: we need to clear pDimRegionsInUse before deleting pDimRegionPool,
+         // otherwise memory corruption will occur if there are active voices (see bug #118)
+         for (int iChannel = 0; iChannel < engineChannels.size(); iChannel++) {
+             engineChannels[iChannel]->ClearDimRegionsInUse();
+         }
+         if (pDimRegionPool[0]) delete pDimRegionPool[0];
+         if (pDimRegionPool[1]) delete pDimRegionPool[1];
+         pDimRegionPool[0] = new Pool< ::gig::DimensionRegion*>(iVoices);
+         pDimRegionPool[1] = new Pool< ::gig::DimensionRegion*>(iVoices);
+         for (int iChannel = 0; iChannel < engineChannels.size(); iChannel++) {
+             engineChannels[iChannel]->ResetDimRegionsInUse();
+         }
+         try {
+             pVoicePool->resizePool(iVoices);
+         } catch (...) {
+             throw Exception("FATAL: Could not resize voice pool!");
+         }
+         for (RTList<Voice>::Iterator iterVoice = pVoicePool->allocAppend(); iterVoice == pVoicePool->last(); iterVoice = pVoicePool->allocAppend()) {
+             iterVoice->SetEngine(this);
+             iterVoice->pDiskThread = this->pDiskThread;
+         }
+         pVoicePool->clear();
+         ResumeAll();
      }
      bool Engine::DiskStreamSupported() {
-Line 1159 
 namespace LinuxSampler { namespace gig {
+Line 2180 
 namespace LinuxSampler { namespace gig {
      }
      uint Engine::DiskStreamCount() {
-         return (pDiskThread) ? pDiskThread->ActiveStreamCount : 0;
+         return (pDiskThread) ? pDiskThread->GetActiveStreamCount() : 0;
      }
      uint Engine::DiskStreamCountMax() {
          return (pDiskThread) ? pDiskThread->ActiveStreamCountMax : 0;
      }
-     String Engine::DiskStreamBufferFillBytes() {
+     int Engine::MaxDiskStreams() {
-         return pDiskThread->GetBufferFillBytes();
+         return iMaxDiskStreams;
      }
-     String Engine::DiskStreamBufferFillPercentage() {
+     void Engine::SetMaxDiskStreams(int iStreams) throw (Exception) {
-         return pDiskThread->GetBufferFillPercentage();
+         if (iStreams < 0)
-     }
+             throw Exception("Maximum disk streams for an engine cannot be set lower than 0");
-     String Engine::EngineName() {
+         SuspendAll();
-         return "GigEngine";
-     }
+         iMaxDiskStreams = iStreams;
-     String Engine::InstrumentFileName() {
+         // reconnect to audio output device, because that will automatically
-         return InstrumentFile;
+         // recreate the disk thread with the required amount of streams
+         if (pAudioOutputDevice) Connect(pAudioOutputDevice);
+         ResumeAll();
      }
-     String Engine::InstrumentName() {
+     String Engine::DiskStreamBufferFillBytes() {
-         return InstrumentIdxName;
+         return pDiskThread->GetBufferFillBytes();
      }
-     int Engine::InstrumentIndex() {
+     String Engine::DiskStreamBufferFillPercentage() {
-         return InstrumentIdx;
+         return pDiskThread->GetBufferFillPercentage();
      }
-     int Engine::InstrumentStatus() {
+     String Engine::EngineName() {
-         return InstrumentStat;
+         return LS_GIG_ENGINE_NAME;
      }
      String Engine::Description() {
-         return "Gigasampler Engine";
+         return "Gigasampler Format Engine";
      }
      String Engine::Version() {
-         String s = "$Revision: 1.24 $";
+         String s = "$Revision: 1.104 $";
          return s.substr(11, s.size() - 13); // cut dollar signs, spaces and CVS macro keyword
      }
+     InstrumentManager* Engine::GetInstrumentManager() {
+         return &instruments;
+     }
+     // static constant initializers
+     const Engine::FloatTable Engine::VolumeCurve(InitVolumeCurve());
+     const Engine::FloatTable Engine::PanCurve(InitPanCurve());
+     const Engine::FloatTable Engine::CrossfadeCurve(InitCrossfadeCurve());
+     float* Engine::InitVolumeCurve() {
+         // line-segment approximation
+         const float segments[] = {
+, 0, 2, 0.0046, 16, 0.016, 31, 0.051, 45, 0.115, 54.5, 0.2,
+.5, 0.39, 74, 0.74, 92, 1.03, 114, 1.94, 119.2, 2.2, 127, 2.2
+         };
+         return InitCurve(segments);
+     }
+     float* Engine::InitPanCurve() {
+         // line-segment approximation
+         const float segments[] = {
+, 0, 1, 0,
+, 0.05, 31.5, 0.7, 51, 0.851, 74.5, 1.12,
+, 1.41, 128, 1.41
+         };
+         return InitCurve(segments, 129);
+     }
+     float* Engine::InitCrossfadeCurve() {
+         // line-segment approximation
+         const float segments[] = {
+, 0, 1, 0.03, 10, 0.1, 51, 0.58, 127, 1
+         };
+         return InitCurve(segments);
+     }
+     float* Engine::InitCurve(const float* segments, int size) {
+         float* y = new float[size];
+         for (int x = 0 ; x < size ; x++) {
+             if (x > segments[2]) segments += 2;
+             y[x] = segments[1] + (x - segments[0]) *
+                 (segments[3] - segments[1]) / (segments[2] - segments[0]);
+         }
+         return y;
+     }
  }} // namespace LinuxSampler::gig

 Legend:



Removed from v.376
 


changed lines


 
Added in v.1933
 Legend:



Removed from v.376
 


changed lines


 
Added in v.1933
-Removed from v.376
+Added in v.1933

	ViewVC Help
Powered by ViewVC