/[svn]/linuxsampler/trunk/src/network/lscpserver.cpp
ViewVC logotype

Diff of /linuxsampler/trunk/src/network/lscpserver.cpp

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 225 by schoenebeck, Sun Aug 22 14:46:47 2004 UTC revision 880 by schoenebeck, Tue Jun 27 22:57:37 2006 UTC
# Line 3  Line 3 
3   *   LinuxSampler - modular, streaming capable sampler                     *   *   LinuxSampler - modular, streaming capable sampler                     *
4   *                                                                         *   *                                                                         *
5   *   Copyright (C) 2003, 2004 by Benno Senoner and Christian Schoenebeck   *   *   Copyright (C) 2003, 2004 by Benno Senoner and Christian Schoenebeck   *
6     *   Copyright (C) 2005, 2006 Christian Schoenebeck                        *
7   *                                                                         *   *                                                                         *
8   *   This program is free software; you can redistribute it and/or modify  *   *   This library is free software; you can redistribute it and/or modify  *
9   *   it under the terms of the GNU General Public License as published by  *   *   it under the terms of the GNU General Public License as published by  *
10   *   the Free Software Foundation; either version 2 of the License, or     *   *   the Free Software Foundation; either version 2 of the License, or     *
11   *   (at your option) any later version.                                   *   *   (at your option) any later version.                                   *
12   *                                                                         *   *                                                                         *
13   *   This program is distributed in the hope that it will be useful,       *   *   This library is distributed in the hope that it will be useful,       *
14   *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *   *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
15   *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *   *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
16   *   GNU General Public License for more details.                          *   *   GNU General Public License for more details.                          *
17   *                                                                         *   *                                                                         *
18   *   You should have received a copy of the GNU General Public License     *   *   You should have received a copy of the GNU General Public License     *
19   *   along with this program; if not, write to the Free Software           *   *   along with this library; if not, write to the Free Software           *
20   *   Foundation, Inc., 59 Temple Place, Suite 330, Boston,                 *   *   Foundation, Inc., 59 Temple Place, Suite 330, Boston,                 *
21   *   MA  02111-1307  USA                                                   *   *   MA  02111-1307  USA                                                   *
22   ***************************************************************************/   ***************************************************************************/
# Line 23  Line 24 
24  #include "lscpserver.h"  #include "lscpserver.h"
25  #include "lscpresultset.h"  #include "lscpresultset.h"
26  #include "lscpevent.h"  #include "lscpevent.h"
27    //#include "../common/global.h"
28    
29  #include "../engines/gig/Engine.h"  #include <fcntl.h>
30    
31    #if HAVE_SQLITE3
32    # include "sqlite3.h"
33    #endif
34    
35    #include "../engines/EngineFactory.h"
36    #include "../engines/EngineChannelFactory.h"
37  #include "../drivers/audio/AudioOutputDeviceFactory.h"  #include "../drivers/audio/AudioOutputDeviceFactory.h"
38  #include "../drivers/midi/MidiInputDeviceFactory.h"  #include "../drivers/midi/MidiInputDeviceFactory.h"
39    
# Line 50  std::map< LSCPEvent::event_t, std::list< Line 59  std::map< LSCPEvent::event_t, std::list<
59  Mutex LSCPServer::NotifyMutex = Mutex();  Mutex LSCPServer::NotifyMutex = Mutex();
60  Mutex LSCPServer::NotifyBufferMutex = Mutex();  Mutex LSCPServer::NotifyBufferMutex = Mutex();
61  Mutex LSCPServer::SubscriptionMutex = Mutex();  Mutex LSCPServer::SubscriptionMutex = Mutex();
62    Mutex LSCPServer::RTNotifyMutex = Mutex();
63    
64  LSCPServer::LSCPServer(Sampler* pSampler) : Thread(false, 0, -4) {  LSCPServer::LSCPServer(Sampler* pSampler, long int addr, short int port) : Thread(true, false, 0, -4) {
65        SocketAddress.sin_family      = AF_INET;
66        SocketAddress.sin_addr.s_addr = addr;
67        SocketAddress.sin_port        = port;
68      this->pSampler = pSampler;      this->pSampler = pSampler;
69      LSCPEvent::RegisterEvent(LSCPEvent::event_channels, "CHANNELS");      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_count, "CHANNEL_COUNT");
70      LSCPEvent::RegisterEvent(LSCPEvent::event_voice_count, "VOICE_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_voice_count, "VOICE_COUNT");
71      LSCPEvent::RegisterEvent(LSCPEvent::event_stream_count, "STREAM_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_stream_count, "STREAM_COUNT");
72      LSCPEvent::RegisterEvent(LSCPEvent::event_buffer_fill, "BUFFER_FILL");      LSCPEvent::RegisterEvent(LSCPEvent::event_buffer_fill, "BUFFER_FILL");
73      LSCPEvent::RegisterEvent(LSCPEvent::event_info, "INFO");      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_info, "CHANNEL_INFO");
74      LSCPEvent::RegisterEvent(LSCPEvent::event_misc, "MISCELLANEOUS");      LSCPEvent::RegisterEvent(LSCPEvent::event_misc, "MISCELLANEOUS");
75        LSCPEvent::RegisterEvent(LSCPEvent::event_total_voice_count, "TOTAL_VOICE_COUNT");
76        hSocket = -1;
77    }
78    
79    LSCPServer::~LSCPServer() {
80        if (hSocket >= 0) close(hSocket);
81  }  }
82    
83  /**  /**
# Line 76  int LSCPServer::WaitUntilInitialized(lon Line 95  int LSCPServer::WaitUntilInitialized(lon
95  }  }
96    
97  int LSCPServer::Main() {  int LSCPServer::Main() {
98      int hSocket = socket(AF_INET, SOCK_STREAM, 0);      hSocket = socket(AF_INET, SOCK_STREAM, 0);
99      if (hSocket < 0) {      if (hSocket < 0) {
100          std::cerr << "LSCPServer: Could not create server socket." << std::endl;          std::cerr << "LSCPServer: Could not create server socket." << std::endl;
101          //return -1;          //return -1;
102          exit(EXIT_FAILURE);          exit(EXIT_FAILURE);
103      }      }
104    
     SocketAddress.sin_family      = AF_INET;  
     SocketAddress.sin_port        = htons(LSCP_PORT);  
     SocketAddress.sin_addr.s_addr = htonl(INADDR_ANY);  
   
105      if (bind(hSocket, (sockaddr*) &SocketAddress, sizeof(sockaddr_in)) < 0) {      if (bind(hSocket, (sockaddr*) &SocketAddress, sizeof(sockaddr_in)) < 0) {
106          std::cerr << "LSCPServer: Could not bind server socket." << std::endl;          std::cerr << "LSCPServer: Could not bind server socket, retrying for " << ToString(LSCP_SERVER_BIND_TIMEOUT) << " seconds...";
107          close(hSocket);          for (int trial = 0; true; trial++) { // retry for LSCP_SERVER_BIND_TIMEOUT seconds
108          //return -1;              if (bind(hSocket, (sockaddr*) &SocketAddress, sizeof(sockaddr_in)) < 0) {
109          exit(EXIT_FAILURE);                  if (trial > LSCP_SERVER_BIND_TIMEOUT) {
110                        std::cerr << "gave up!" << std::endl;
111                        close(hSocket);
112                        //return -1;
113                        exit(EXIT_FAILURE);
114                    }
115                    else sleep(1); // sleep 1s
116                }
117                else break; // success
118            }
119      }      }
120    
121      listen(hSocket, 1);      listen(hSocket, 1);
# Line 104  int LSCPServer::Main() { Line 128  int LSCPServer::Main() {
128      FD_SET(hSocket, &fdSet);      FD_SET(hSocket, &fdSet);
129      int maxSessions = hSocket;      int maxSessions = hSocket;
130    
131        timeval timeout;
132    
133      while (true) {      while (true) {
134          fd_set selectSet = fdSet;          // check if some engine channel's parameter / status changed, if so notify the respective LSCP event subscribers
135          int retval = select(maxSessions+1, &selectSet, NULL, NULL, NULL);          {
136                std::set<EngineChannel*> engineChannels = EngineChannelFactory::EngineChannelInstances();
137                std::set<EngineChannel*>::iterator itEngineChannel = engineChannels.begin();
138                std::set<EngineChannel*>::iterator itEnd           = engineChannels.end();
139                for (; itEngineChannel != itEnd; ++itEngineChannel) {
140                    if ((*itEngineChannel)->StatusChanged()) {
141                        SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_info, (*itEngineChannel)->iSamplerChannelIndex));
142                    }
143                }
144            }
145    
146            //Now let's deliver late notifies (if any)
147            NotifyBufferMutex.Lock();
148            for (std::map<int,String>::iterator iterNotify = bufferedNotifies.begin(); iterNotify != bufferedNotifies.end(); iterNotify++) {
149    #ifdef MSG_NOSIGNAL
150                    send(iterNotify->first, iterNotify->second.c_str(), iterNotify->second.size(), MSG_NOSIGNAL);
151    #else
152                    send(iterNotify->first, iterNotify->second.c_str(), iterNotify->second.size(), 0);
153    #endif
154            }
155            bufferedNotifies.clear();
156            NotifyBufferMutex.Unlock();
157    
158            fd_set selectSet = fdSet;
159            timeout.tv_sec  = 0;
160            timeout.tv_usec = 100000;
161    
162            int retval = select(maxSessions+1, &selectSet, NULL, NULL, &timeout);
163    
164          if (retval == 0)          if (retval == 0)
165                  continue; //Nothing try again                  continue; //Nothing try again
166          if (retval == -1) {          if (retval == -1) {
# Line 150  int LSCPServer::Main() { Line 204  int LSCPServer::Main() {
204                                  int dummy; // just a temporary hack to fulfill the restart() function prototype                                  int dummy; // just a temporary hack to fulfill the restart() function prototype
205                                  restart(NULL, dummy); // restart the 'scanner'                                  restart(NULL, dummy); // restart the 'scanner'
206                                  currentSocket = (*iter).hSession;  //a hack                                  currentSocket = (*iter).hSession;  //a hack
207                                    dmsg(2,("LSCPServer: [%s]\n",bufferedCommands[currentSocket].c_str()));
208                                  if ((*iter).bVerbose) { // if echo mode enabled                                  if ((*iter).bVerbose) { // if echo mode enabled
209                                      AnswerClient(bufferedCommands[currentSocket]);                                      AnswerClient(bufferedCommands[currentSocket]);
210                                  }                                  }
# Line 165  int LSCPServer::Main() { Line 220  int LSCPServer::Main() {
220                          break;                          break;
221                  }                  }
222          }          }
   
         //Now let's deliver late notifies (if any)  
         NotifyBufferMutex.Lock();  
         for (std::map<int,String>::iterator iterNotify = bufferedNotifies.begin(); iterNotify != bufferedNotifies.end(); iterNotify++) {  
                 send(iterNotify->first, iterNotify->second.c_str(), iterNotify->second.size(), 0);  
                 bufferedNotifies.erase(iterNotify);  
         }  
         NotifyBufferMutex.Unlock();  
223      }      }
224  }  }
225    
# Line 194  void LSCPServer::CloseConnection( std::v Line 241  void LSCPServer::CloseConnection( std::v
241          NotifyMutex.Unlock();          NotifyMutex.Unlock();
242  }  }
243    
244    int LSCPServer::EventSubscribers( std::list<LSCPEvent::event_t> events ) {
245            int subs = 0;
246            SubscriptionMutex.Lock();
247            for( std::list<LSCPEvent::event_t>::iterator iter = events.begin();
248                            iter != events.end(); iter++)
249            {
250                    subs += eventSubscriptions.count(*iter);
251            }
252            SubscriptionMutex.Unlock();
253            return subs;
254    }
255    
256  void LSCPServer::SendLSCPNotify( LSCPEvent event ) {  void LSCPServer::SendLSCPNotify( LSCPEvent event ) {
257          SubscriptionMutex.Lock();          SubscriptionMutex.Lock();
258          if (eventSubscriptions.count(event.GetType()) == 0) {          if (eventSubscriptions.count(event.GetType()) == 0) {
# Line 207  void LSCPServer::SendLSCPNotify( LSCPEve Line 266  void LSCPServer::SendLSCPNotify( LSCPEve
266          while (true) {          while (true) {
267                  if (NotifyMutex.Trylock()) {                  if (NotifyMutex.Trylock()) {
268                          for(;iter != end; iter++)                          for(;iter != end; iter++)
269    #ifdef MSG_NOSIGNAL
270                                    send(*iter, notify.c_str(), notify.size(), MSG_NOSIGNAL);
271    #else
272                                  send(*iter, notify.c_str(), notify.size(), 0);                                  send(*iter, notify.c_str(), notify.size(), 0);
273    #endif
274                          NotifyMutex.Unlock();                          NotifyMutex.Unlock();
275                          break;                          break;
276                  } else {                  } else {
# Line 316  void LSCPServer::AnswerClient(String Ret Line 379  void LSCPServer::AnswerClient(String Ret
379      dmsg(2,("LSCPServer::AnswerClient(ReturnMessage=%s)", ReturnMessage.c_str()));      dmsg(2,("LSCPServer::AnswerClient(ReturnMessage=%s)", ReturnMessage.c_str()));
380      if (currentSocket != -1) {      if (currentSocket != -1) {
381              NotifyMutex.Lock();              NotifyMutex.Lock();
382    #ifdef MSG_NOSIGNAL
383                send(currentSocket, ReturnMessage.c_str(), ReturnMessage.size(), MSG_NOSIGNAL);
384    #else
385              send(currentSocket, ReturnMessage.c_str(), ReturnMessage.size(), 0);              send(currentSocket, ReturnMessage.c_str(), ReturnMessage.size(), 0);
386    #endif
387              NotifyMutex.Unlock();              NotifyMutex.Unlock();
388      }      }
389  }  }
# Line 360  String LSCPServer::CreateAudioOutputDevi Line 427  String LSCPServer::CreateAudioOutputDevi
427          AudioOutputDevice* pDevice = pSampler->CreateAudioOutputDevice(Driver, Parameters);          AudioOutputDevice* pDevice = pSampler->CreateAudioOutputDevice(Driver, Parameters);
428          // search for the created device to get its index          // search for the created device to get its index
429          int index = GetAudioOutputDeviceIndex(pDevice);          int index = GetAudioOutputDeviceIndex(pDevice);
430          if (index == -1) throw LinuxSamplerException("Internal error: could not find created audio output device.");          if (index == -1) throw Exception("Internal error: could not find created audio output device.");
431          result = index; // success          result = index; // success
432      }      }
433      catch (LinuxSamplerException e) {      catch (Exception e) {
434          result.Error(e);          result.Error(e);
435      }      }
436      return result.Produce();      return result.Produce();
# Line 376  String LSCPServer::CreateMidiInputDevice Line 443  String LSCPServer::CreateMidiInputDevice
443          MidiInputDevice* pDevice = pSampler->CreateMidiInputDevice(Driver, Parameters);          MidiInputDevice* pDevice = pSampler->CreateMidiInputDevice(Driver, Parameters);
444          // search for the created device to get its index          // search for the created device to get its index
445          int index = GetMidiInputDeviceIndex(pDevice);          int index = GetMidiInputDeviceIndex(pDevice);
446          if (index == -1) throw LinuxSamplerException("Internal error: could not find created midi input device.");          if (index == -1) throw Exception("Internal error: could not find created midi input device.");
447          result = index; // success          result = index; // success
448      }      }
449      catch (LinuxSamplerException e) {      catch (Exception e) {
450          result.Error(e);          result.Error(e);
451      }      }
452      return result.Produce();      return result.Produce();
# Line 390  String LSCPServer::DestroyAudioOutputDev Line 457  String LSCPServer::DestroyAudioOutputDev
457      LSCPResultSet result;      LSCPResultSet result;
458      try {      try {
459          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
460          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no audio output device with index " + ToString(DeviceIndex) + ".");
461          AudioOutputDevice* pDevice = devices[DeviceIndex];          AudioOutputDevice* pDevice = devices[DeviceIndex];
462          pSampler->DestroyAudioOutputDevice(pDevice);          pSampler->DestroyAudioOutputDevice(pDevice);
463      }      }
464      catch (LinuxSamplerException e) {      catch (Exception e) {
465          result.Error(e);          result.Error(e);
466      }      }
467      return result.Produce();      return result.Produce();
# Line 405  String LSCPServer::DestroyMidiInputDevic Line 472  String LSCPServer::DestroyMidiInputDevic
472      LSCPResultSet result;      LSCPResultSet result;
473      try {      try {
474          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
475          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no audio output device with index " + ToString(DeviceIndex) + ".");
476          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
477          pSampler->DestroyMidiInputDevice(pDevice);          pSampler->DestroyMidiInputDevice(pDevice);
478      }      }
479      catch (LinuxSamplerException e) {      catch (Exception e) {
480          result.Error(e);          result.Error(e);
481      }      }
482      return result.Produce();      return result.Produce();
# Line 423  String LSCPServer::LoadInstrument(String Line 490  String LSCPServer::LoadInstrument(String
490      LSCPResultSet result;      LSCPResultSet result;
491      try {      try {
492          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
493          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
494          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
495          if (!pEngine) throw LinuxSamplerException("No engine loaded on channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel yet");
496          if (!pSamplerChannel->GetAudioOutputDevice())          if (!pSamplerChannel->GetAudioOutputDevice())
497              throw LinuxSamplerException("No audio output device on channel");              throw Exception("No audio output device connected to sampler channel");
498          if (bBackground) {          if (bBackground) {
499              LSCPLoadInstrument *pLoadInstrument = new LSCPLoadInstrument(pEngine, Filename.c_str(), uiInstrument);              InstrumentLoader.StartNewLoad(Filename, uiInstrument, pEngineChannel);
500              pLoadInstrument->StartThread();          }
501            else {
502                // tell the engine channel which instrument to load
503                pEngineChannel->PrepareLoadInstrument(Filename.c_str(), uiInstrument);
504                // actually start to load the instrument (blocks until completed)
505                pEngineChannel->LoadInstrument();
506          }          }
         else pEngine->LoadInstrument(Filename.c_str(), uiInstrument);  
507      }      }
508      catch (LinuxSamplerException e) {      catch (Exception e) {
509           result.Error(e);           result.Error(e);
510      }      }
511      return result.Produce();      return result.Produce();
512  }  }
513    
514  /**  /**
515   * Will be called by the parser to load and deploy an engine.   * Will be called by the parser to assign a sampler engine type to a
516     * sampler channel.
517   */   */
518  String LSCPServer::LoadEngine(String EngineName, uint uiSamplerChannel) {  String LSCPServer::SetEngineType(String EngineName, uint uiSamplerChannel) {
519      dmsg(2,("LSCPServer: LoadEngine(EngineName=%s,SamplerChannel=%d)\n", EngineName.c_str(), uiSamplerChannel));      dmsg(2,("LSCPServer: SetEngineType(EngineName=%s,uiSamplerChannel=%d)\n", EngineName.c_str(), uiSamplerChannel));
520      LSCPResultSet result;      LSCPResultSet result;
521      try {      try {
         Engine::type_t type;  
         if ((EngineName == "GigEngine") || (EngineName == "gig")) type = Engine::type_gig;  
         else throw LinuxSamplerException("Unknown engine type");  
522          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
523          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
524          pSamplerChannel->LoadEngine(type);          LockRTNotify();
525            pSamplerChannel->SetEngineType(EngineName);
526            if(HasSoloChannel()) pSamplerChannel->GetEngineChannel()->SetMute(-1);
527            UnlockRTNotify();
528      }      }
529      catch (LinuxSamplerException e) {      catch (Exception e) {
530           result.Error(e);           result.Error(e);
531      }      }
532      return result.Produce();      return result.Produce();
# Line 492  String LSCPServer::ListChannels() { Line 564  String LSCPServer::ListChannels() {
564   */   */
565  String LSCPServer::AddChannel() {  String LSCPServer::AddChannel() {
566      dmsg(2,("LSCPServer: AddChannel()\n"));      dmsg(2,("LSCPServer: AddChannel()\n"));
567        LockRTNotify();
568      SamplerChannel* pSamplerChannel = pSampler->AddSamplerChannel();      SamplerChannel* pSamplerChannel = pSampler->AddSamplerChannel();
569        UnlockRTNotify();
570      LSCPResultSet result(pSamplerChannel->Index());      LSCPResultSet result(pSamplerChannel->Index());
571      return result.Produce();      return result.Produce();
572  }  }
# Line 503  String LSCPServer::AddChannel() { Line 577  String LSCPServer::AddChannel() {
577  String LSCPServer::RemoveChannel(uint uiSamplerChannel) {  String LSCPServer::RemoveChannel(uint uiSamplerChannel) {
578      dmsg(2,("LSCPServer: RemoveChannel(SamplerChannel=%d)\n", uiSamplerChannel));      dmsg(2,("LSCPServer: RemoveChannel(SamplerChannel=%d)\n", uiSamplerChannel));
579      LSCPResultSet result;      LSCPResultSet result;
580        LockRTNotify();
581      pSampler->RemoveSamplerChannel(uiSamplerChannel);      pSampler->RemoveSamplerChannel(uiSamplerChannel);
582        UnlockRTNotify();
583      return result.Produce();      return result.Produce();
584  }  }
585    
586  /**  /**
587   * Will be called by the parser to get all available engines.   * Will be called by the parser to get the amount of all available engines.
588   */   */
589  String LSCPServer::GetAvailableEngines() {  String LSCPServer::GetAvailableEngines() {
590      dmsg(2,("LSCPServer: GetAvailableEngines()\n"));      dmsg(2,("LSCPServer: GetAvailableEngines()\n"));
591      LSCPResultSet result("GigEngine");      LSCPResultSet result("1");
592      return result.Produce();      return result.Produce();
593  }  }
594    
595  /**  /**
596   * Will be called by the parser to get descriptions for a particular engine.   * Will be called by the parser to get a list of all available engines.
597     */
598    String LSCPServer::ListAvailableEngines() {
599        dmsg(2,("LSCPServer: ListAvailableEngines()\n"));
600        LSCPResultSet result("\'GIG\'");
601        return result.Produce();
602    }
603    
604    /**
605     * Will be called by the parser to get descriptions for a particular
606     * sampler engine.
607   */   */
608  String LSCPServer::GetEngineInfo(String EngineName) {  String LSCPServer::GetEngineInfo(String EngineName) {
609      dmsg(2,("LSCPServer: GetEngineInfo(EngineName=%s)\n", EngineName.c_str()));      dmsg(2,("LSCPServer: GetEngineInfo(EngineName=%s)\n", EngineName.c_str()));
610      LSCPResultSet result;      LSCPResultSet result;
611        LockRTNotify();
612      try {      try {
613          if ((EngineName == "GigEngine") || (EngineName == "gig")) {          Engine* pEngine = EngineFactory::Create(EngineName);
614              Engine* pEngine = new LinuxSampler::gig::Engine;          result.Add("DESCRIPTION", pEngine->Description());
615              result.Add("DESCRIPTION", pEngine->Description());          result.Add("VERSION",     pEngine->Version());
616              result.Add("VERSION",     pEngine->Version());          EngineFactory::Destroy(pEngine);
             delete pEngine;  
         }  
         else throw LinuxSamplerException("Unknown engine type");  
617      }      }
618      catch (LinuxSamplerException e) {      catch (Exception e) {
619           result.Error(e);           result.Error(e);
620      }      }
621        UnlockRTNotify();
622      return result.Produce();      return result.Produce();
623  }  }
624    
# Line 546  String LSCPServer::GetChannelInfo(uint u Line 631  String LSCPServer::GetChannelInfo(uint u
631      LSCPResultSet result;      LSCPResultSet result;
632      try {      try {
633          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
634          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
635          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
636    
637          //Defaults values          //Defaults values
638          String EngineName = "NONE";          String EngineName = "NONE";
639          float Volume = 0.0f;          float Volume = 0.0f;
640          String InstrumentFileName = "NONE";          String InstrumentFileName = "NONE";
641            String InstrumentName = "NONE";
642          int InstrumentIndex = -1;          int InstrumentIndex = -1;
643          int InstrumentStatus = -1;          int InstrumentStatus = -1;
644          int AudioOutputChannels = 0;          int AudioOutputChannels = 0;
645          String AudioRouting;          String AudioRouting;
646            int Mute = 0;
647            bool Solo = false;
648    
649          if (pEngine) {          if (pEngineChannel) {
650              EngineName =  pEngine->EngineName();              EngineName          = pEngineChannel->EngineName();
651              AudioOutputChannels = pEngine->Channels();              AudioOutputChannels = pEngineChannel->Channels();
652              Volume = pEngine->Volume();              Volume              = pEngineChannel->Volume();
653              InstrumentStatus = pEngine->InstrumentStatus();              InstrumentStatus    = pEngineChannel->InstrumentStatus();
654              InstrumentIndex = pEngine->InstrumentIndex();              InstrumentIndex     = pEngineChannel->InstrumentIndex();
655              if (InstrumentIndex != -1)              if (InstrumentIndex != -1) {
656                  InstrumentFileName = pEngine->InstrumentFileName();                  InstrumentFileName = pEngineChannel->InstrumentFileName();
657              for (int chan = 0; chan < pEngine->Channels(); chan++) {                  InstrumentName     = pEngineChannel->InstrumentName();
658                }
659                for (int chan = 0; chan < pEngineChannel->Channels(); chan++) {
660                  if (AudioRouting != "") AudioRouting += ",";                  if (AudioRouting != "") AudioRouting += ",";
661                  AudioRouting += ToString(pEngine->OutputChannel(chan));                  AudioRouting += ToString(pEngineChannel->OutputChannel(chan));
662              }              }
663                Mute = pEngineChannel->GetMute();
664                Solo = pEngineChannel->GetSolo();
665          }          }
666    
667          result.Add("ENGINE_NAME", EngineName);          result.Add("ENGINE_NAME", EngineName);
# Line 582  String LSCPServer::GetChannelInfo(uint u Line 674  String LSCPServer::GetChannelInfo(uint u
674    
675          result.Add("MIDI_INPUT_DEVICE", GetMidiInputDeviceIndex(pSamplerChannel->GetMidiInputDevice()));          result.Add("MIDI_INPUT_DEVICE", GetMidiInputDeviceIndex(pSamplerChannel->GetMidiInputDevice()));
676          result.Add("MIDI_INPUT_PORT", pSamplerChannel->GetMidiInputPort());          result.Add("MIDI_INPUT_PORT", pSamplerChannel->GetMidiInputPort());
677          if (pSamplerChannel->GetMidiInputChannel()) result.Add("MIDI_INPUT_CHANNEL", pSamplerChannel->GetMidiInputChannel());          if (pSamplerChannel->GetMidiInputChannel() == midi_chan_all) result.Add("MIDI_INPUT_CHANNEL", "ALL");
678          else                                        result.Add("MIDI_INPUT_CHANNEL", "ALL");          else result.Add("MIDI_INPUT_CHANNEL", pSamplerChannel->GetMidiInputChannel());
679    
680          result.Add("INSTRUMENT_FILE", InstrumentFileName);          result.Add("INSTRUMENT_FILE", InstrumentFileName);
681          result.Add("INSTRUMENT_NR", InstrumentIndex);          result.Add("INSTRUMENT_NR", InstrumentIndex);
682            result.Add("INSTRUMENT_NAME", InstrumentName);
683          result.Add("INSTRUMENT_STATUS", InstrumentStatus);          result.Add("INSTRUMENT_STATUS", InstrumentStatus);
684            result.Add("MUTE", Mute == -1 ? "MUTED_BY_SOLO" : (Mute ? "true" : "false"));
685            result.Add("SOLO", Solo);
686      }      }
687      catch (LinuxSamplerException e) {      catch (Exception e) {
688           result.Error(e);           result.Error(e);
689      }      }
690      return result.Produce();      return result.Produce();
# Line 604  String LSCPServer::GetVoiceCount(uint ui Line 699  String LSCPServer::GetVoiceCount(uint ui
699      LSCPResultSet result;      LSCPResultSet result;
700      try {      try {
701          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
702          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
703          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
704          if (!pEngine) throw LinuxSamplerException("No engine loaded on channel");          if (!pEngineChannel) throw Exception("No engine loaded on sampler channel");
705          result.Add(pEngine->VoiceCount());          if (!pEngineChannel->GetEngine()) throw Exception("No audio output device connected to sampler channel");
706            result.Add(pEngineChannel->GetEngine()->VoiceCount());
707      }      }
708      catch (LinuxSamplerException e) {      catch (Exception e) {
709           result.Error(e);           result.Error(e);
710      }      }
711      return result.Produce();      return result.Produce();
# Line 624  String LSCPServer::GetStreamCount(uint u Line 720  String LSCPServer::GetStreamCount(uint u
720      LSCPResultSet result;      LSCPResultSet result;
721      try {      try {
722          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
723          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
724          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
725          if (!pEngine) throw LinuxSamplerException("No engine loaded on channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
726          result.Add(pEngine->DiskStreamCount());          if (!pEngineChannel->GetEngine()) throw Exception("No audio output device connected to sampler channel");
727            result.Add(pEngineChannel->GetEngine()->DiskStreamCount());
728      }      }
729      catch (LinuxSamplerException e) {      catch (Exception e) {
730           result.Error(e);           result.Error(e);
731      }      }
732      return result.Produce();      return result.Produce();
# Line 644  String LSCPServer::GetBufferFill(fill_re Line 741  String LSCPServer::GetBufferFill(fill_re
741      LSCPResultSet result;      LSCPResultSet result;
742      try {      try {
743          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
744          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
745          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
746          if (!pEngine) throw LinuxSamplerException("No engine loaded on channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
747          if (!pEngine->DiskStreamSupported())          if (!pEngineChannel->GetEngine()) throw Exception("No audio output device connected to sampler channel");
748              result.Add("NA");          if (!pEngineChannel->GetEngine()->DiskStreamSupported()) result.Add("NA");
749          else {          else {
750              switch (ResponseType) {              switch (ResponseType) {
751                  case fill_response_bytes:                  case fill_response_bytes:
752                      result.Add(pEngine->DiskStreamBufferFillBytes());                      result.Add(pEngineChannel->GetEngine()->DiskStreamBufferFillBytes());
753                      break;                      break;
754                  case fill_response_percentage:                  case fill_response_percentage:
755                      result.Add(pEngine->DiskStreamBufferFillPercentage());                      result.Add(pEngineChannel->GetEngine()->DiskStreamBufferFillPercentage());
756                      break;                      break;
757                  default:                  default:
758                      throw LinuxSamplerException("Unknown fill response type");                      throw Exception("Unknown fill response type");
759              }              }
760          }          }
761      }      }
762      catch (LinuxSamplerException e) {      catch (Exception e) {
763           result.Error(e);           result.Error(e);
764      }      }
765      return result.Produce();      return result.Produce();
# Line 672  String LSCPServer::GetAvailableAudioOutp Line 769  String LSCPServer::GetAvailableAudioOutp
769      dmsg(2,("LSCPServer: GetAvailableAudioOutputDrivers()\n"));      dmsg(2,("LSCPServer: GetAvailableAudioOutputDrivers()\n"));
770      LSCPResultSet result;      LSCPResultSet result;
771      try {      try {
772            int n = AudioOutputDeviceFactory::AvailableDrivers().size();
773            result.Add(n);
774        }
775        catch (Exception e) {
776            result.Error(e);
777        }
778        return result.Produce();
779    }
780    
781    String LSCPServer::ListAvailableAudioOutputDrivers() {
782        dmsg(2,("LSCPServer: ListAvailableAudioOutputDrivers()\n"));
783        LSCPResultSet result;
784        try {
785          String s = AudioOutputDeviceFactory::AvailableDriversAsString();          String s = AudioOutputDeviceFactory::AvailableDriversAsString();
786          result.Add(s);          result.Add(s);
787      }      }
788      catch (LinuxSamplerException e) {      catch (Exception e) {
789          result.Error(e);          result.Error(e);
790      }      }
791      return result.Produce();      return result.Produce();
# Line 685  String LSCPServer::GetAvailableMidiInput Line 795  String LSCPServer::GetAvailableMidiInput
795      dmsg(2,("LSCPServer: GetAvailableMidiInputDrivers()\n"));      dmsg(2,("LSCPServer: GetAvailableMidiInputDrivers()\n"));
796      LSCPResultSet result;      LSCPResultSet result;
797      try {      try {
798            int n = MidiInputDeviceFactory::AvailableDrivers().size();
799            result.Add(n);
800        }
801        catch (Exception e) {
802            result.Error(e);
803        }
804        return result.Produce();
805    }
806    
807    String LSCPServer::ListAvailableMidiInputDrivers() {
808        dmsg(2,("LSCPServer: ListAvailableMidiInputDrivers()\n"));
809        LSCPResultSet result;
810        try {
811          String s = MidiInputDeviceFactory::AvailableDriversAsString();          String s = MidiInputDeviceFactory::AvailableDriversAsString();
812          result.Add(s);          result.Add(s);
813      }      }
814      catch (LinuxSamplerException e) {      catch (Exception e) {
815          result.Error(e);          result.Error(e);
816      }      }
817      return result.Produce();      return result.Produce();
# Line 712  String LSCPServer::GetMidiInputDriverInf Line 835  String LSCPServer::GetMidiInputDriverInf
835              result.Add("PARAMETERS", s);              result.Add("PARAMETERS", s);
836          }          }
837      }      }
838      catch (LinuxSamplerException e) {      catch (Exception e) {
839          result.Error(e);          result.Error(e);
840      }      }
841      return result.Produce();      return result.Produce();
# Line 736  String LSCPServer::GetAudioOutputDriverI Line 859  String LSCPServer::GetAudioOutputDriverI
859              result.Add("PARAMETERS", s);              result.Add("PARAMETERS", s);
860          }          }
861      }      }
862      catch (LinuxSamplerException e) {      catch (Exception e) {
863          result.Error(e);          result.Error(e);
864      }      }
865      return result.Produce();      return result.Produce();
866  }  }
867    
868  String LSCPServer::GetMidiInputDriverParameterInfo(String Driver, String Parameter, std::map<String,String> DependencyList) {  String LSCPServer::GetMidiInputDriverParameterInfo(String Driver, String Parameter, std::map<String,String> DependencyList) {
869      dmsg(2,("LSCPServer: GetMidiInputDriverParameterInfo(Driver=%s,Parameter=%s)\n",Driver.c_str(),Parameter.c_str()));      dmsg(2,("LSCPServer: GetMidiInputDriverParameterInfo(Driver=%s,Parameter=%s,DependencyListSize=%d)\n",Driver.c_str(),Parameter.c_str(),DependencyList.size()));
870      LSCPResultSet result;      LSCPResultSet result;
871      try {      try {
872          DeviceCreationParameter* pParameter = MidiInputDeviceFactory::GetDriverParameter(Driver, Parameter);          DeviceCreationParameter* pParameter = MidiInputDeviceFactory::GetDriverParameter(Driver, Parameter);
# Line 752  String LSCPServer::GetMidiInputDriverPar Line 875  String LSCPServer::GetMidiInputDriverPar
875          result.Add("MANDATORY",    pParameter->Mandatory());          result.Add("MANDATORY",    pParameter->Mandatory());
876          result.Add("FIX",          pParameter->Fix());          result.Add("FIX",          pParameter->Fix());
877          result.Add("MULTIPLICITY", pParameter->Multiplicity());          result.Add("MULTIPLICITY", pParameter->Multiplicity());
878          if (pParameter->Depends())       result.Add("DEPENDS",       *pParameter->Depends());          optional<String> oDepends       = pParameter->Depends();
879          if (pParameter->Default())       result.Add("DEFAULT",       *pParameter->Default());          optional<String> oDefault       = pParameter->Default(DependencyList);
880          if (pParameter->RangeMin())      result.Add("RANGE_MIN",     *pParameter->RangeMin());          optional<String> oRangeMin      = pParameter->RangeMin(DependencyList);
881          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());          optional<String> oRangeMax      = pParameter->RangeMax(DependencyList);
882          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());          optional<String> oPossibilities = pParameter->Possibilities(DependencyList);
883            if (oDepends)       result.Add("DEPENDS",       *oDepends);
884            if (oDefault)       result.Add("DEFAULT",       *oDefault);
885            if (oRangeMin)      result.Add("RANGE_MIN",     *oRangeMin);
886            if (oRangeMax)      result.Add("RANGE_MAX",     *oRangeMax);
887            if (oPossibilities) result.Add("POSSIBILITIES", *oPossibilities);
888      }      }
889      catch (LinuxSamplerException e) {      catch (Exception e) {
890          result.Error(e);          result.Error(e);
891      }      }
892      return result.Produce();      return result.Produce();
893  }  }
894    
895  String LSCPServer::GetAudioOutputDriverParameterInfo(String Driver, String Parameter, std::map<String,String> DependencyList) {  String LSCPServer::GetAudioOutputDriverParameterInfo(String Driver, String Parameter, std::map<String,String> DependencyList) {
896      dmsg(2,("LSCPServer: GetAudioOutputDriverParameterInfo(Driver=%s,Parameter=%s)\n",Driver.c_str(),Parameter.c_str()));      dmsg(2,("LSCPServer: GetAudioOutputDriverParameterInfo(Driver=%s,Parameter=%s,DependencyListSize=%d)\n",Driver.c_str(),Parameter.c_str(),DependencyList.size()));
897      LSCPResultSet result;      LSCPResultSet result;
898      try {      try {
899          DeviceCreationParameter* pParameter = AudioOutputDeviceFactory::GetDriverParameter(Driver, Parameter);          DeviceCreationParameter* pParameter = AudioOutputDeviceFactory::GetDriverParameter(Driver, Parameter);
# Line 774  String LSCPServer::GetAudioOutputDriverP Line 902  String LSCPServer::GetAudioOutputDriverP
902          result.Add("MANDATORY",    pParameter->Mandatory());          result.Add("MANDATORY",    pParameter->Mandatory());
903          result.Add("FIX",          pParameter->Fix());          result.Add("FIX",          pParameter->Fix());
904          result.Add("MULTIPLICITY", pParameter->Multiplicity());          result.Add("MULTIPLICITY", pParameter->Multiplicity());
905          if (pParameter->Depends())       result.Add("DEPENDS",       *pParameter->Depends());          optional<String> oDepends       = pParameter->Depends();
906          if (pParameter->Default())       result.Add("DEFAULT",       *pParameter->Default());          optional<String> oDefault       = pParameter->Default(DependencyList);
907          if (pParameter->RangeMin())      result.Add("RANGE_MIN",     *pParameter->RangeMin());          optional<String> oRangeMin      = pParameter->RangeMin(DependencyList);
908          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());          optional<String> oRangeMax      = pParameter->RangeMax(DependencyList);
909          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());          optional<String> oPossibilities = pParameter->Possibilities(DependencyList);
910            if (oDepends)       result.Add("DEPENDS",       *oDepends);
911            if (oDefault)       result.Add("DEFAULT",       *oDefault);
912            if (oRangeMin)      result.Add("RANGE_MIN",     *oRangeMin);
913            if (oRangeMax)      result.Add("RANGE_MAX",     *oRangeMax);
914            if (oPossibilities) result.Add("POSSIBILITIES", *oPossibilities);
915      }      }
916      catch (LinuxSamplerException e) {      catch (Exception e) {
917          result.Error(e);          result.Error(e);
918      }      }
919      return result.Produce();      return result.Produce();
# Line 793  String LSCPServer::GetAudioOutputDeviceC Line 926  String LSCPServer::GetAudioOutputDeviceC
926          uint count = pSampler->AudioOutputDevices();          uint count = pSampler->AudioOutputDevices();
927          result.Add(count); // success          result.Add(count); // success
928      }      }
929      catch (LinuxSamplerException e) {      catch (Exception e) {
930          result.Error(e);          result.Error(e);
931      }      }
932      return result.Produce();      return result.Produce();
# Line 806  String LSCPServer::GetMidiInputDeviceCou Line 939  String LSCPServer::GetMidiInputDeviceCou
939          uint count = pSampler->MidiInputDevices();          uint count = pSampler->MidiInputDevices();
940          result.Add(count); // success          result.Add(count); // success
941      }      }
942      catch (LinuxSamplerException e) {      catch (Exception e) {
943          result.Error(e);          result.Error(e);
944      }      }
945      return result.Produce();      return result.Produce();
# Line 825  String LSCPServer::GetAudioOutputDevices Line 958  String LSCPServer::GetAudioOutputDevices
958          }          }
959          result.Add(s);          result.Add(s);
960      }      }
961      catch (LinuxSamplerException e) {      catch (Exception e) {
962          result.Error(e);          result.Error(e);
963      }      }
964      return result.Produce();      return result.Produce();
# Line 844  String LSCPServer::GetMidiInputDevices() Line 977  String LSCPServer::GetMidiInputDevices()
977          }          }
978          result.Add(s);          result.Add(s);
979      }      }
980      catch (LinuxSamplerException e) {      catch (Exception e) {
981          result.Error(e);          result.Error(e);
982      }      }
983      return result.Produce();      return result.Produce();
# Line 855  String LSCPServer::GetAudioOutputDeviceI Line 988  String LSCPServer::GetAudioOutputDeviceI
988      LSCPResultSet result;      LSCPResultSet result;
989      try {      try {
990          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
991          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no audio output device with index " + ToString(DeviceIndex) + ".");
992          AudioOutputDevice* pDevice = devices[DeviceIndex];          AudioOutputDevice* pDevice = devices[DeviceIndex];
993          result.Add("DRIVER", pDevice->Driver());          result.Add("DRIVER", pDevice->Driver());
994          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
# Line 864  String LSCPServer::GetAudioOutputDeviceI Line 997  String LSCPServer::GetAudioOutputDeviceI
997              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
998          }          }
999      }      }
1000      catch (LinuxSamplerException e) {      catch (Exception e) {
1001          result.Error(e);          result.Error(e);
1002      }      }
1003      return result.Produce();      return result.Produce();
# Line 875  String LSCPServer::GetMidiInputDeviceInf Line 1008  String LSCPServer::GetMidiInputDeviceInf
1008      LSCPResultSet result;      LSCPResultSet result;
1009      try {      try {
1010          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1011          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");
1012          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1013          result.Add("DRIVER", pDevice->Driver());          result.Add("DRIVER", pDevice->Driver());
1014          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
# Line 884  String LSCPServer::GetMidiInputDeviceInf Line 1017  String LSCPServer::GetMidiInputDeviceInf
1017              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1018          }          }
1019      }      }
1020      catch (LinuxSamplerException e) {      catch (Exception e) {
1021          result.Error(e);          result.Error(e);
1022      }      }
1023      return result.Produce();      return result.Produce();
# Line 895  String LSCPServer::GetMidiInputPortInfo( Line 1028  String LSCPServer::GetMidiInputPortInfo(
1028      try {      try {
1029          // get MIDI input device          // get MIDI input device
1030          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1031          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");
1032          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1033    
1034          // get MIDI port          // get MIDI port
1035          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);
1036          if (!pMidiInputPort) throw LinuxSamplerException("There is no MIDI input port with index " + ToString(PortIndex) + ".");          if (!pMidiInputPort) throw Exception("There is no MIDI input port with index " + ToString(PortIndex) + ".");
1037    
1038          // return the values of all MIDI port parameters          // return the values of all MIDI port parameters
1039          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();
# Line 909  String LSCPServer::GetMidiInputPortInfo( Line 1042  String LSCPServer::GetMidiInputPortInfo(
1042              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1043          }          }
1044      }      }
1045      catch (LinuxSamplerException e) {      catch (Exception e) {
1046          result.Error(e);          result.Error(e);
1047      }      }
1048      return result.Produce();      return result.Produce();
# Line 921  String LSCPServer::GetAudioOutputChannel Line 1054  String LSCPServer::GetAudioOutputChannel
1054      try {      try {
1055          // get audio output device          // get audio output device
1056          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1057          if (!devices.count(DeviceId)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceId) + ".");          if (!devices.count(DeviceId)) throw Exception("There is no audio output device with index " + ToString(DeviceId) + ".");
1058          AudioOutputDevice* pDevice = devices[DeviceId];          AudioOutputDevice* pDevice = devices[DeviceId];
1059    
1060          // get audio channel          // get audio channel
1061          AudioChannel* pChannel = pDevice->Channel(ChannelId);          AudioChannel* pChannel = pDevice->Channel(ChannelId);
1062          if (!pChannel) throw LinuxSamplerException("Audio ouotput device does not have channel " + ToString(ChannelId) + ".");          if (!pChannel) throw Exception("Audio output device does not have audio channel " + ToString(ChannelId) + ".");
1063    
1064          // return the values of all audio channel parameters          // return the values of all audio channel parameters
1065          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();
# Line 935  String LSCPServer::GetAudioOutputChannel Line 1068  String LSCPServer::GetAudioOutputChannel
1068              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1069          }          }
1070      }      }
1071      catch (LinuxSamplerException e) {      catch (Exception e) {
1072          result.Error(e);          result.Error(e);
1073      }      }
1074      return result.Produce();      return result.Produce();
# Line 947  String LSCPServer::GetMidiInputPortParam Line 1080  String LSCPServer::GetMidiInputPortParam
1080      try {      try {
1081          // get MIDI input device          // get MIDI input device
1082          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1083          if (!devices.count(DeviceId)) throw LinuxSamplerException("There is no midi input device with index " + ToString(DeviceId) + ".");          if (!devices.count(DeviceId)) throw Exception("There is no midi input device with index " + ToString(DeviceId) + ".");
1084          MidiInputDevice* pDevice = devices[DeviceId];          MidiInputDevice* pDevice = devices[DeviceId];
1085    
1086          // get midi port          // get midi port
1087          MidiInputPort* pPort = pDevice->GetPort(PortId);          MidiInputPort* pPort = pDevice->GetPort(PortId);
1088          if (!pPort) throw LinuxSamplerException("Midi input device does not have port " + ToString(PortId) + ".");          if (!pPort) throw Exception("Midi input device does not have port " + ToString(PortId) + ".");
1089    
1090          // get desired port parameter          // get desired port parameter
1091          std::map<String,DeviceRuntimeParameter*> parameters = pPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pPort->PortParameters();
1092          if (!parameters.count(ParameterName)) throw LinuxSamplerException("Midi port does not provide a parameter '" + ParameterName + "'.");          if (!parameters.count(ParameterName)) throw Exception("Midi port does not provide a parameter '" + ParameterName + "'.");
1093          DeviceRuntimeParameter* pParameter = parameters[ParameterName];          DeviceRuntimeParameter* pParameter = parameters[ParameterName];
1094    
1095          // return all fields of this audio channel parameter          // return all fields of this audio channel parameter
# Line 968  String LSCPServer::GetMidiInputPortParam Line 1101  String LSCPServer::GetMidiInputPortParam
1101          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());
1102          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());
1103      }      }
1104      catch (LinuxSamplerException e) {      catch (Exception e) {
1105          result.Error(e);          result.Error(e);
1106      }      }
1107      return result.Produce();      return result.Produce();
# Line 980  String LSCPServer::GetAudioOutputChannel Line 1113  String LSCPServer::GetAudioOutputChannel
1113      try {      try {
1114          // get audio output device          // get audio output device
1115          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1116          if (!devices.count(DeviceId)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceId) + ".");          if (!devices.count(DeviceId)) throw Exception("There is no audio output device with index " + ToString(DeviceId) + ".");
1117          AudioOutputDevice* pDevice = devices[DeviceId];          AudioOutputDevice* pDevice = devices[DeviceId];
1118    
1119          // get audio channel          // get audio channel
1120          AudioChannel* pChannel = pDevice->Channel(ChannelId);          AudioChannel* pChannel = pDevice->Channel(ChannelId);
1121          if (!pChannel) throw LinuxSamplerException("Audio output device does not have channel " + ToString(ChannelId) + ".");          if (!pChannel) throw Exception("Audio output device does not have audio channel " + ToString(ChannelId) + ".");
1122    
1123          // get desired audio channel parameter          // get desired audio channel parameter
1124          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();
1125          if (!parameters.count(ParameterName)) throw LinuxSamplerException("Audio channel does not provide a parameter '" + ParameterName + "'.");          if (!parameters.count(ParameterName)) throw Exception("Audio channel does not provide a parameter '" + ParameterName + "'.");
1126          DeviceRuntimeParameter* pParameter = parameters[ParameterName];          DeviceRuntimeParameter* pParameter = parameters[ParameterName];
1127    
1128          // return all fields of this audio channel parameter          // return all fields of this audio channel parameter
# Line 1001  String LSCPServer::GetAudioOutputChannel Line 1134  String LSCPServer::GetAudioOutputChannel
1134          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());
1135          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());
1136      }      }
1137      catch (LinuxSamplerException e) {      catch (Exception e) {
1138          result.Error(e);          result.Error(e);
1139      }      }
1140      return result.Produce();      return result.Produce();
# Line 1013  String LSCPServer::SetAudioOutputChannel Line 1146  String LSCPServer::SetAudioOutputChannel
1146      try {      try {
1147          // get audio output device          // get audio output device
1148          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1149          if (!devices.count(DeviceId)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceId) + ".");          if (!devices.count(DeviceId)) throw Exception("There is no audio output device with index " + ToString(DeviceId) + ".");
1150          AudioOutputDevice* pDevice = devices[DeviceId];          AudioOutputDevice* pDevice = devices[DeviceId];
1151    
1152          // get audio channel          // get audio channel
1153          AudioChannel* pChannel = pDevice->Channel(ChannelId);          AudioChannel* pChannel = pDevice->Channel(ChannelId);
1154          if (!pChannel) throw LinuxSamplerException("Audio output device does not have channel " + ToString(ChannelId) + ".");          if (!pChannel) throw Exception("Audio output device does not have audio channel " + ToString(ChannelId) + ".");
1155    
1156          // get desired audio channel parameter          // get desired audio channel parameter
1157          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();
1158          if (!parameters.count(ParamKey)) throw LinuxSamplerException("Audio channel does not provide a parameter '" + ParamKey + "'.");          if (!parameters.count(ParamKey)) throw Exception("Audio channel does not provide a parameter '" + ParamKey + "'.");
1159          DeviceRuntimeParameter* pParameter = parameters[ParamKey];          DeviceRuntimeParameter* pParameter = parameters[ParamKey];
1160    
1161          // set new channel parameter value          // set new channel parameter value
1162          pParameter->SetValue(ParamVal);          pParameter->SetValue(ParamVal);
1163      }      }
1164      catch (LinuxSamplerException e) {      catch (Exception e) {
1165          result.Error(e);          result.Error(e);
1166      }      }
1167      return result.Produce();      return result.Produce();
# Line 1039  String LSCPServer::SetAudioOutputDeviceP Line 1172  String LSCPServer::SetAudioOutputDeviceP
1172      LSCPResultSet result;      LSCPResultSet result;
1173      try {      try {
1174          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1175          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no audio output device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no audio output device with index " + ToString(DeviceIndex) + ".");
1176          AudioOutputDevice* pDevice = devices[DeviceIndex];          AudioOutputDevice* pDevice = devices[DeviceIndex];
1177          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
1178          if (!parameters.count(ParamKey)) throw LinuxSamplerException("Audio output device " + ToString(DeviceIndex) + " does not have a device parameter '" + ParamKey + "'");          if (!parameters.count(ParamKey)) throw Exception("Audio output device " + ToString(DeviceIndex) + " does not have a device parameter '" + ParamKey + "'");
1179          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1180      }      }
1181      catch (LinuxSamplerException e) {      catch (Exception e) {
1182          result.Error(e);          result.Error(e);
1183      }      }
1184      return result.Produce();      return result.Produce();
# Line 1056  String LSCPServer::SetMidiInputDevicePar Line 1189  String LSCPServer::SetMidiInputDevicePar
1189      LSCPResultSet result;      LSCPResultSet result;
1190      try {      try {
1191          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1192          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");
1193          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1194          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
1195          if (!parameters.count(ParamKey)) throw LinuxSamplerException("MIDI input device " + ToString(DeviceIndex) + " does not have a device parameter '" + ParamKey + "'");          if (!parameters.count(ParamKey)) throw Exception("MIDI input device " + ToString(DeviceIndex) + " does not have a device parameter '" + ParamKey + "'");
1196          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1197      }      }
1198      catch (LinuxSamplerException e) {      catch (Exception e) {
1199          result.Error(e);          result.Error(e);
1200      }      }
1201      return result.Produce();      return result.Produce();
# Line 1074  String LSCPServer::SetMidiInputPortParam Line 1207  String LSCPServer::SetMidiInputPortParam
1207      try {      try {
1208          // get MIDI input device          // get MIDI input device
1209          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1210          if (!devices.count(DeviceIndex)) throw LinuxSamplerException("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");          if (!devices.count(DeviceIndex)) throw Exception("There is no MIDI input device with index " + ToString(DeviceIndex) + ".");
1211          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1212    
1213          // get MIDI port          // get MIDI port
1214          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);
1215          if (!pMidiInputPort) throw LinuxSamplerException("There is no MIDI input port with index " + ToString(PortIndex) + ".");          if (!pMidiInputPort) throw Exception("There is no MIDI input port with index " + ToString(PortIndex) + ".");
1216    
1217          // set port parameter value          // set port parameter value
1218          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();
1219          if (!parameters.count(ParamKey)) throw LinuxSamplerException("MIDI input device " + ToString(PortIndex) + " does not have a parameter '" + ParamKey + "'");          if (!parameters.count(ParamKey)) throw Exception("MIDI input device " + ToString(PortIndex) + " does not have a parameter '" + ParamKey + "'");
1220          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1221      }      }
1222      catch (LinuxSamplerException e) {      catch (Exception e) {
1223          result.Error(e);          result.Error(e);
1224      }      }
1225      return result.Produce();      return result.Produce();
# Line 1101  String LSCPServer::SetAudioOutputChannel Line 1234  String LSCPServer::SetAudioOutputChannel
1234      LSCPResultSet result;      LSCPResultSet result;
1235      try {      try {
1236          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1237          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1238          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1239          if (!pEngine) throw LinuxSamplerException("No engine deployed on sampler channel " + ToString(uiSamplerChannel));          if (!pEngineChannel) throw Exception("No engine type yet assigned to sampler channel " + ToString(uiSamplerChannel));
1240          pEngine->SetOutputChannel(ChannelAudioOutputChannel, AudioOutputDeviceInputChannel);          if (!pSamplerChannel->GetAudioOutputDevice()) throw Exception("No audio output device connected to sampler channel " + ToString(uiSamplerChannel));
1241            pEngineChannel->SetOutputChannel(ChannelAudioOutputChannel, AudioOutputDeviceInputChannel);
1242      }      }
1243      catch (LinuxSamplerException e) {      catch (Exception e) {
1244           result.Error(e);           result.Error(e);
1245      }      }
1246      return result.Produce();      return result.Produce();
# Line 1115  String LSCPServer::SetAudioOutputChannel Line 1249  String LSCPServer::SetAudioOutputChannel
1249  String LSCPServer::SetAudioOutputDevice(uint AudioDeviceId, uint uiSamplerChannel) {  String LSCPServer::SetAudioOutputDevice(uint AudioDeviceId, uint uiSamplerChannel) {
1250      dmsg(2,("LSCPServer: SetAudiotOutputDevice(AudioDeviceId=%d, SamplerChannel=%d)\n",AudioDeviceId,uiSamplerChannel));      dmsg(2,("LSCPServer: SetAudiotOutputDevice(AudioDeviceId=%d, SamplerChannel=%d)\n",AudioDeviceId,uiSamplerChannel));
1251      LSCPResultSet result;      LSCPResultSet result;
1252        LockRTNotify();
1253      try {      try {
1254          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1255          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1256          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1257          if (!devices.count(AudioDeviceId)) throw LinuxSamplerException("There is no audio output device with index " + ToString(AudioDeviceId));          if (!devices.count(AudioDeviceId)) throw Exception("There is no audio output device with index " + ToString(AudioDeviceId));
1258          AudioOutputDevice* pDevice = devices[AudioDeviceId];          AudioOutputDevice* pDevice = devices[AudioDeviceId];
1259          pSamplerChannel->SetAudioOutputDevice(pDevice);          pSamplerChannel->SetAudioOutputDevice(pDevice);
1260      }      }
1261      catch (LinuxSamplerException e) {      catch (Exception e) {
1262           result.Error(e);           result.Error(e);
1263      }      }
1264        UnlockRTNotify();
1265      return result.Produce();      return result.Produce();
1266  }  }
1267    
1268  String LSCPServer::SetAudioOutputType(String AudioOutputDriver, uint uiSamplerChannel) {  String LSCPServer::SetAudioOutputType(String AudioOutputDriver, uint uiSamplerChannel) {
1269      dmsg(2,("LSCPServer: SetAudioOutputType(String AudioOutputDriver=%s, SamplerChannel=%d)\n",AudioOutputDriver.c_str(),uiSamplerChannel));      dmsg(2,("LSCPServer: SetAudioOutputType(String AudioOutputDriver=%s, SamplerChannel=%d)\n",AudioOutputDriver.c_str(),uiSamplerChannel));
1270      LSCPResultSet result;      LSCPResultSet result;
1271        LockRTNotify();
1272      try {      try {
1273          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1274          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1275          // Driver type name aliasing...          // Driver type name aliasing...
1276          if (AudioOutputDriver == "ALSA") AudioOutputDriver = "Alsa";          if (AudioOutputDriver == "Alsa") AudioOutputDriver = "ALSA";
1277          if (AudioOutputDriver == "JACK") AudioOutputDriver = "Jack";          if (AudioOutputDriver == "Jack") AudioOutputDriver = "JACK";
1278          // Check if there's one audio output device already created          // Check if there's one audio output device already created
1279          // for the intended audio driver type (AudioOutputDriver)...          // for the intended audio driver type (AudioOutputDriver)...
1280          AudioOutputDevice *pDevice = NULL;          AudioOutputDevice *pDevice = NULL;
# Line 1156  String LSCPServer::SetAudioOutputType(St Line 1293  String LSCPServer::SetAudioOutputType(St
1293          }          }
1294          // Must have a device...          // Must have a device...
1295          if (pDevice == NULL)          if (pDevice == NULL)
1296              throw LinuxSamplerException("Internal error: could not create audio output device.");              throw Exception("Internal error: could not create audio output device.");
1297          // Set it as the current channel device...          // Set it as the current channel device...
1298          pSamplerChannel->SetAudioOutputDevice(pDevice);          pSamplerChannel->SetAudioOutputDevice(pDevice);
1299      }      }
1300      catch (LinuxSamplerException e) {      catch (Exception e) {
1301           result.Error(e);           result.Error(e);
1302      }      }
1303        UnlockRTNotify();
1304      return result.Produce();      return result.Produce();
1305  }  }
1306    
# Line 1171  String LSCPServer::SetMIDIInputPort(uint Line 1309  String LSCPServer::SetMIDIInputPort(uint
1309      LSCPResultSet result;      LSCPResultSet result;
1310      try {      try {
1311          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1312          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1313          pSamplerChannel->SetMidiInputPort(MIDIPort);          pSamplerChannel->SetMidiInputPort(MIDIPort);
1314      }      }
1315      catch (LinuxSamplerException e) {      catch (Exception e) {
1316           result.Error(e);           result.Error(e);
1317      }      }
1318      return result.Produce();      return result.Produce();
# Line 1185  String LSCPServer::SetMIDIInputChannel(u Line 1323  String LSCPServer::SetMIDIInputChannel(u
1323      LSCPResultSet result;      LSCPResultSet result;
1324      try {      try {
1325          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1326          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1327          pSamplerChannel->SetMidiInputChannel((MidiInputPort::midi_chan_t) MIDIChannel);          pSamplerChannel->SetMidiInputChannel((midi_chan_t) MIDIChannel);
1328      }      }
1329      catch (LinuxSamplerException e) {      catch (Exception e) {
1330           result.Error(e);           result.Error(e);
1331      }      }
1332      return result.Produce();      return result.Produce();
# Line 1199  String LSCPServer::SetMIDIInputDevice(ui Line 1337  String LSCPServer::SetMIDIInputDevice(ui
1337      LSCPResultSet result;      LSCPResultSet result;
1338      try {      try {
1339          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1340          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1341          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1342          if (!devices.count(MIDIDeviceId)) throw LinuxSamplerException("There is no MIDI input device with index " + ToString(MIDIDeviceId));          if (!devices.count(MIDIDeviceId)) throw Exception("There is no MIDI input device with index " + ToString(MIDIDeviceId));
1343          MidiInputDevice* pDevice = devices[MIDIDeviceId];          MidiInputDevice* pDevice = devices[MIDIDeviceId];
1344          pSamplerChannel->SetMidiInputDevice(pDevice);          pSamplerChannel->SetMidiInputDevice(pDevice);
1345      }      }
1346      catch (LinuxSamplerException e) {      catch (Exception e) {
1347           result.Error(e);           result.Error(e);
1348      }      }
1349      return result.Produce();      return result.Produce();
# Line 1216  String LSCPServer::SetMIDIInputType(Stri Line 1354  String LSCPServer::SetMIDIInputType(Stri
1354      LSCPResultSet result;      LSCPResultSet result;
1355      try {      try {
1356          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1357          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1358          // Driver type name aliasing...          // Driver type name aliasing...
1359          if (MidiInputDriver == "ALSA") MidiInputDriver = "Alsa";          if (MidiInputDriver == "Alsa") MidiInputDriver = "ALSA";
1360          // Check if there's one MIDI input device already created          // Check if there's one MIDI input device already created
1361          // for the intended MIDI driver type (MidiInputDriver)...          // for the intended MIDI driver type (MidiInputDriver)...
1362          MidiInputDevice *pDevice = NULL;          MidiInputDevice *pDevice = NULL;
# Line 1240  String LSCPServer::SetMIDIInputType(Stri Line 1378  String LSCPServer::SetMIDIInputType(Stri
1378          }          }
1379          // Must have a device...          // Must have a device...
1380          if (pDevice == NULL)          if (pDevice == NULL)
1381              throw LinuxSamplerException("Internal error: could not create MIDI input device.");              throw Exception("Internal error: could not create MIDI input device.");
1382          // Set it as the current channel device...          // Set it as the current channel device...
1383          pSamplerChannel->SetMidiInputDevice(pDevice);          pSamplerChannel->SetMidiInputDevice(pDevice);
1384      }      }
1385      catch (LinuxSamplerException e) {      catch (Exception e) {
1386           result.Error(e);           result.Error(e);
1387      }      }
1388      return result.Produce();      return result.Produce();
# Line 1259  String LSCPServer::SetMIDIInput(uint MID Line 1397  String LSCPServer::SetMIDIInput(uint MID
1397      LSCPResultSet result;      LSCPResultSet result;
1398      try {      try {
1399          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1400          if (!pSamplerChannel) throw LinuxSamplerException("Invalid channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1401          std::map<uint, MidiInputDevice*> devices =  pSampler->GetMidiInputDevices();          std::map<uint, MidiInputDevice*> devices =  pSampler->GetMidiInputDevices();
1402          if (!devices.count(MIDIDeviceId)) throw LinuxSamplerException("There is no MIDI input device with index " + ToString(MIDIDeviceId));          if (!devices.count(MIDIDeviceId)) throw Exception("There is no MIDI input device with index " + ToString(MIDIDeviceId));
1403          MidiInputDevice* pDevice = devices[MIDIDeviceId];          MidiInputDevice* pDevice = devices[MIDIDeviceId];
1404          pSamplerChannel->SetMidiInput(pDevice, MIDIPort, (MidiInputPort::midi_chan_t) MIDIChannel);          pSamplerChannel->SetMidiInput(pDevice, MIDIPort, (midi_chan_t) MIDIChannel);
1405      }      }
1406      catch (LinuxSamplerException e) {      catch (Exception e) {
1407           result.Error(e);           result.Error(e);
1408      }      }
1409      return result.Produce();      return result.Produce();
# Line 1280  String LSCPServer::SetVolume(double dVol Line 1418  String LSCPServer::SetVolume(double dVol
1418      LSCPResultSet result;      LSCPResultSet result;
1419      try {      try {
1420          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1421          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1422          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1423          if (!pEngine) throw LinuxSamplerException("No engine loaded on channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1424          pEngine->Volume(dVolume);          pEngineChannel->Volume(dVolume);
1425      }      }
1426      catch (LinuxSamplerException e) {      catch (Exception e) {
1427           result.Error(e);           result.Error(e);
1428      }      }
1429      return result.Produce();      return result.Produce();
1430  }  }
1431    
1432  /**  /**
1433     * Will be called by the parser to mute/unmute particular sampler channel.
1434     */
1435    String LSCPServer::SetChannelMute(bool bMute, uint uiSamplerChannel) {
1436        dmsg(2,("LSCPServer: SetChannelMute(bMute=%d,uiSamplerChannel=%d)\n",bMute,uiSamplerChannel));
1437        LSCPResultSet result;
1438        try {
1439            SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1440            if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1441    
1442            EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1443            if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1444    
1445            if(!bMute) pEngineChannel->SetMute((HasSoloChannel() && !pEngineChannel->GetSolo()) ? -1 : 0);
1446            else pEngineChannel->SetMute(1);
1447        } catch (Exception e) {
1448            result.Error(e);
1449        }
1450        return result.Produce();
1451    }
1452    
1453    /**
1454     * Will be called by the parser to solo particular sampler channel.
1455     */
1456    String LSCPServer::SetChannelSolo(bool bSolo, uint uiSamplerChannel) {
1457        dmsg(2,("LSCPServer: SetChannelSolo(bSolo=%d,uiSamplerChannel=%d)\n",bSolo,uiSamplerChannel));
1458        LSCPResultSet result;
1459        try {
1460            SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1461            if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1462    
1463            EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1464            if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1465    
1466            bool oldSolo = pEngineChannel->GetSolo();
1467            bool hadSoloChannel = HasSoloChannel();
1468            
1469            pEngineChannel->SetSolo(bSolo);
1470            
1471            if(!oldSolo && bSolo) {
1472                if(pEngineChannel->GetMute() == -1) pEngineChannel->SetMute(0);
1473                if(!hadSoloChannel) MuteNonSoloChannels();
1474            }
1475            
1476            if(oldSolo && !bSolo) {
1477                if(!HasSoloChannel()) UnmuteChannels();
1478                else if(!pEngineChannel->GetMute()) pEngineChannel->SetMute(-1);
1479            }
1480        } catch (Exception e) {
1481            result.Error(e);
1482        }
1483        return result.Produce();
1484    }
1485    
1486    /**
1487     * Determines whether there is at least one solo channel in the channel list.
1488     *
1489     * @returns true if there is at least one solo channel in the channel list,
1490     * false otherwise.
1491     */
1492    bool LSCPServer::HasSoloChannel() {
1493        std::map<uint,SamplerChannel*> channels = pSampler->GetSamplerChannels();
1494        std::map<uint,SamplerChannel*>::iterator iter = channels.begin();
1495        for (; iter != channels.end(); iter++) {
1496            EngineChannel* c = iter->second->GetEngineChannel();
1497            if(c && c->GetSolo()) return true;
1498        }
1499    
1500        return false;
1501    }
1502    
1503    /**
1504     * Mutes all unmuted non-solo channels. Notice that the channels are muted
1505     * with -1 which indicates that they are muted because of the presence
1506     * of a solo channel(s). Channels muted with -1 will be automatically unmuted
1507     * when there are no solo channels left.
1508     */
1509    void LSCPServer::MuteNonSoloChannels() {
1510        dmsg(2,("LSCPServer: MuteNonSoloChannels()\n"));
1511        std::map<uint,SamplerChannel*> channels = pSampler->GetSamplerChannels();
1512        std::map<uint,SamplerChannel*>::iterator iter = channels.begin();
1513        for (; iter != channels.end(); iter++) {
1514            EngineChannel* c = iter->second->GetEngineChannel();
1515            if(c && !c->GetSolo() && !c->GetMute()) c->SetMute(-1);
1516        }
1517    }
1518    
1519    /**
1520     * Unmutes all channels that are muted because of the presence
1521     * of a solo channel(s).
1522     */
1523    void  LSCPServer::UnmuteChannels() {
1524        dmsg(2,("LSCPServer: UnmuteChannels()\n"));
1525        std::map<uint,SamplerChannel*> channels = pSampler->GetSamplerChannels();
1526        std::map<uint,SamplerChannel*>::iterator iter = channels.begin();
1527        for (; iter != channels.end(); iter++) {
1528            EngineChannel* c = iter->second->GetEngineChannel();
1529            if(c && c->GetMute() == -1) c->SetMute(0);
1530        }
1531    }
1532    
1533    /**
1534   * Will be called by the parser to reset a particular sampler channel.   * Will be called by the parser to reset a particular sampler channel.
1535   */   */
1536  String LSCPServer::ResetChannel(uint uiSamplerChannel) {  String LSCPServer::ResetChannel(uint uiSamplerChannel) {
# Line 1299  String LSCPServer::ResetChannel(uint uiS Line 1538  String LSCPServer::ResetChannel(uint uiS
1538      LSCPResultSet result;      LSCPResultSet result;
1539      try {      try {
1540          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1541          if (!pSamplerChannel) throw LinuxSamplerException("Index out of bounds");          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1542          Engine* pEngine = pSamplerChannel->GetEngine();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1543          if (!pEngine) throw LinuxSamplerException("No engine loaded on channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1544          pEngine->Reset();          pEngineChannel->Reset();
1545      }      }
1546      catch (LinuxSamplerException e) {      catch (Exception e) {
1547           result.Error(e);           result.Error(e);
1548      }      }
1549      return result.Produce();      return result.Produce();
# Line 1321  String LSCPServer::ResetSampler() { Line 1560  String LSCPServer::ResetSampler() {
1560  }  }
1561    
1562  /**  /**
1563     * Will be called by the parser to return general informations about this
1564     * sampler.
1565     */
1566    String LSCPServer::GetServerInfo() {
1567        dmsg(2,("LSCPServer: GetServerInfo()\n"));
1568        LSCPResultSet result;
1569        result.Add("DESCRIPTION", "LinuxSampler - modular, streaming capable sampler");
1570        result.Add("VERSION", VERSION);
1571        result.Add("PROTOCOL_VERSION", "1.0");
1572        return result.Produce();
1573    }
1574    
1575    /**
1576     * Will be called by the parser to return the current number of all active voices.
1577     */
1578    String LSCPServer::GetTotalVoiceCount() {
1579        dmsg(2,("LSCPServer: GetTotalVoiceCount()\n"));
1580        LSCPResultSet result;
1581        result.Add(pSampler->GetVoiceCount());
1582        return result.Produce();
1583    }
1584    
1585    /**
1586     * Will be called by the parser to return the maximum number of voices.
1587     */
1588    String LSCPServer::GetTotalVoiceCountMax() {
1589        dmsg(2,("LSCPServer: GetTotalVoiceCountMax()\n"));
1590        LSCPResultSet result;
1591        result.Add(EngineFactory::EngineInstances().size() * CONFIG_MAX_VOICES);
1592        return result.Produce();
1593    }
1594    
1595    /**
1596   * Will be called by the parser to subscribe a client (frontend) on the   * Will be called by the parser to subscribe a client (frontend) on the
1597   * server for receiving event messages.   * server for receiving event messages.
1598   */   */
# Line 1346  String LSCPServer::UnsubscribeNotificati Line 1618  String LSCPServer::UnsubscribeNotificati
1618      return result.Produce();      return result.Produce();
1619  }  }
1620    
1621    static int select_callback(void * lscpResultSet, int argc,
1622                            char **argv, char **azColName)
1623    {
1624        LSCPResultSet* resultSet = (LSCPResultSet*) lscpResultSet;
1625        resultSet->Add(argc, argv);
1626        return 0;
1627    }
1628    
1629    String LSCPServer::QueryDatabase(String query) {
1630        LSCPResultSet result;
1631    #if HAVE_SQLITE3
1632        char* zErrMsg = NULL;
1633        sqlite3 *db;
1634        String selectStr = "SELECT " + query;
1635    
1636        int rc = sqlite3_open("linuxsampler.db", &db);
1637        if (rc == SQLITE_OK)
1638        {
1639                rc = sqlite3_exec(db, selectStr.c_str(), select_callback, &result, &zErrMsg);
1640        }
1641        if ( rc != SQLITE_OK )
1642        {
1643                result.Error(String(zErrMsg), rc);
1644        }
1645        sqlite3_close(db);
1646    #else
1647        result.Error(String("SQLITE3 was not installed when linuxsampler was built. SELECT statement is not available."), 0);
1648    #endif
1649        return result.Produce();
1650    }
1651    
1652  /**  /**
1653   * Will be called by the parser to enable or disable echo mode; if echo   * Will be called by the parser to enable or disable echo mode; if echo
1654   * mode is enabled, all commands from the client will (immediately) be   * mode is enabled, all commands from the client will (immediately) be
# Line 1357  String LSCPServer::SetEcho(yyparse_param Line 1660  String LSCPServer::SetEcho(yyparse_param
1660      try {      try {
1661          if      (boolean_value == 0) pSession->bVerbose = false;          if      (boolean_value == 0) pSession->bVerbose = false;
1662          else if (boolean_value == 1) pSession->bVerbose = true;          else if (boolean_value == 1) pSession->bVerbose = true;
1663          else throw LinuxSamplerException("Not a boolean value, must either be 0 or 1");          else throw Exception("Not a boolean value, must either be 0 or 1");
1664      }      }
1665      catch (LinuxSamplerException e) {      catch (Exception e) {
1666           result.Error(e);           result.Error(e);
1667      }      }
1668      return result.Produce();      return result.Produce();
1669  }  }
   
 // Instrument loader constructor.  
 LSCPLoadInstrument::LSCPLoadInstrument(Engine* pEngine, String Filename, uint uiInstrument)  
     : Thread(false, 0, -4)  
 {  
     this->pEngine = pEngine;  
     this->Filename = Filename;  
     this->uiInstrument = uiInstrument;  
 }  
   
 // Instrument loader process.  
 int LSCPLoadInstrument::Main()  
 {  
     try {  
         pEngine->LoadInstrument(Filename.c_str(), uiInstrument);  
     }  
   
     catch (LinuxSamplerException e) {  
         e.PrintMessage();  
     }  
   
     // Always re-enable the engine.  
     pEngine->Enable();  
   
     // FIXME: Shoot ourselves on the foot?  
     delete this;  
 }  
Legend:
Removed from v.225  
changed lines
  Added in v.880
  ViewVC Help
Powered by ViewVC