/[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 778 by iliev, Fri Sep 23 06:58:26 2005 UTC revision 1536 by schoenebeck, Mon Dec 3 16:41:17 2007 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 Christian Schoenebeck                              *   *   Copyright (C) 2005 - 2007 Christian Schoenebeck                       *
7   *                                                                         *   *                                                                         *
8   *   This library 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  *
# Line 24  Line 24 
24  #include "lscpserver.h"  #include "lscpserver.h"
25  #include "lscpresultset.h"  #include "lscpresultset.h"
26  #include "lscpevent.h"  #include "lscpevent.h"
 //#include "../common/global.h"  
27    
28    #if defined(WIN32)
29    #else
30  #include <fcntl.h>  #include <fcntl.h>
31    #endif
32    
33  #if HAVE_SQLITE3  #if ! HAVE_SQLITE3
34  # include "sqlite3.h"  #define DOESNT_HAVE_SQLITE3 "No database support. SQLITE3 was not installed when linuxsampler was built."
35  #endif  #endif
36    
37  #include "../engines/EngineFactory.h"  #include "../engines/EngineFactory.h"
# Line 37  Line 39 
39  #include "../drivers/audio/AudioOutputDeviceFactory.h"  #include "../drivers/audio/AudioOutputDeviceFactory.h"
40  #include "../drivers/midi/MidiInputDeviceFactory.h"  #include "../drivers/midi/MidiInputDeviceFactory.h"
41    
42    
43    /**
44     * Returns a copy of the given string where all special characters are
45     * replaced by LSCP escape sequences ("\xHH"). This function shall be used
46     * to escape LSCP response fields in case the respective response field is
47     * actually defined as using escape sequences in the LSCP specs.
48     *
49     * @e Caution: DO NOT use this function for escaping path based responses,
50     * use the Path class (src/common/Path.h) for this instead!
51     */
52    static String _escapeLscpResponse(String txt) {
53        for (int i = 0; i < txt.length(); i++) {
54            const char c = txt.c_str()[i];
55            if (
56                !(c >= '0' && c <= '9') &&
57                !(c >= 'a' && c <= 'z') &&
58                !(c >= 'A' && c <= 'Z') &&
59                !(c == ' ') && !(c == '!') && !(c == '#') && !(c == '$') &&
60                !(c == '%') && !(c == '&') && !(c == '(') && !(c == ')') &&
61                !(c == '*') && !(c == '+') && !(c == ',') && !(c == '-') &&
62                !(c == '.') && !(c == '/') && !(c == ':') && !(c == ';') &&
63                !(c == '<') && !(c == '=') && !(c == '>') && !(c == '?') &&
64                !(c == '@') && !(c == '[') && !(c == ']') &&
65                !(c == '^') && !(c == '_') && !(c == '`') && !(c == '{') &&
66                !(c == '|') && !(c == '}') && !(c == '~')
67            ) {
68                // convert the "special" character into a "\xHH" LSCP escape sequence
69                char buf[5];
70                snprintf(buf, sizeof(buf), "\\x%02x", static_cast<unsigned char>(c));
71                txt.replace(i, 1, buf);
72                i += 3;
73            }
74        }
75        return txt;
76    }
77    
78  /**  /**
79   * Below are a few static members of the LSCPServer class.   * Below are a few static members of the LSCPServer class.
80   * The big assumption here is that LSCPServer is going to remain a singleton.   * The big assumption here is that LSCPServer is going to remain a singleton.
# Line 53  Line 91 
91  fd_set LSCPServer::fdSet;  fd_set LSCPServer::fdSet;
92  int LSCPServer::currentSocket = -1;  int LSCPServer::currentSocket = -1;
93  std::vector<yyparse_param_t> LSCPServer::Sessions = std::vector<yyparse_param_t>();  std::vector<yyparse_param_t> LSCPServer::Sessions = std::vector<yyparse_param_t>();
94    std::vector<yyparse_param_t>::iterator itCurrentSession = std::vector<yyparse_param_t>::iterator();
95  std::map<int,String> LSCPServer::bufferedNotifies = std::map<int,String>();  std::map<int,String> LSCPServer::bufferedNotifies = std::map<int,String>();
96  std::map<int,String> LSCPServer::bufferedCommands = std::map<int,String>();  std::map<int,String> LSCPServer::bufferedCommands = std::map<int,String>();
97  std::map< LSCPEvent::event_t, std::list<int> > LSCPServer::eventSubscriptions = std::map< LSCPEvent::event_t, std::list<int> >();  std::map< LSCPEvent::event_t, std::list<int> > LSCPServer::eventSubscriptions = std::map< LSCPEvent::event_t, std::list<int> >();
# Line 66  LSCPServer::LSCPServer(Sampler* pSampler Line 105  LSCPServer::LSCPServer(Sampler* pSampler
105      SocketAddress.sin_addr.s_addr = addr;      SocketAddress.sin_addr.s_addr = addr;
106      SocketAddress.sin_port        = port;      SocketAddress.sin_port        = port;
107      this->pSampler = pSampler;      this->pSampler = pSampler;
108        LSCPEvent::RegisterEvent(LSCPEvent::event_audio_device_count, "AUDIO_OUTPUT_DEVICE_COUNT");
109        LSCPEvent::RegisterEvent(LSCPEvent::event_audio_device_info, "AUDIO_OUTPUT_DEVICE_INFO");
110        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_device_count, "MIDI_INPUT_DEVICE_COUNT");
111        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_device_info, "MIDI_INPUT_DEVICE_INFO");
112      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_count, "CHANNEL_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_count, "CHANNEL_COUNT");
113      LSCPEvent::RegisterEvent(LSCPEvent::event_voice_count, "VOICE_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_voice_count, "VOICE_COUNT");
114      LSCPEvent::RegisterEvent(LSCPEvent::event_stream_count, "STREAM_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_stream_count, "STREAM_COUNT");
115      LSCPEvent::RegisterEvent(LSCPEvent::event_buffer_fill, "BUFFER_FILL");      LSCPEvent::RegisterEvent(LSCPEvent::event_buffer_fill, "BUFFER_FILL");
116      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_info, "CHANNEL_INFO");      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_info, "CHANNEL_INFO");
117        LSCPEvent::RegisterEvent(LSCPEvent::event_fx_send_count, "FX_SEND_COUNT");
118        LSCPEvent::RegisterEvent(LSCPEvent::event_fx_send_info, "FX_SEND_INFO");
119        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_map_count, "MIDI_INSTRUMENT_MAP_COUNT");
120        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_map_info, "MIDI_INSTRUMENT_MAP_INFO");
121        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_count, "MIDI_INSTRUMENT_COUNT");
122        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_info, "MIDI_INSTRUMENT_INFO");
123        LSCPEvent::RegisterEvent(LSCPEvent::event_db_instr_dir_count, "DB_INSTRUMENT_DIRECTORY_COUNT");
124        LSCPEvent::RegisterEvent(LSCPEvent::event_db_instr_dir_info, "DB_INSTRUMENT_DIRECTORY_INFO");
125        LSCPEvent::RegisterEvent(LSCPEvent::event_db_instr_count, "DB_INSTRUMENT_COUNT");
126        LSCPEvent::RegisterEvent(LSCPEvent::event_db_instr_info, "DB_INSTRUMENT_INFO");
127        LSCPEvent::RegisterEvent(LSCPEvent::event_db_instrs_job_info, "DB_INSTRUMENTS_JOB_INFO");
128      LSCPEvent::RegisterEvent(LSCPEvent::event_misc, "MISCELLANEOUS");      LSCPEvent::RegisterEvent(LSCPEvent::event_misc, "MISCELLANEOUS");
129      LSCPEvent::RegisterEvent(LSCPEvent::event_total_voice_count, "TOTAL_VOICE_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_total_voice_count, "TOTAL_VOICE_COUNT");
130        LSCPEvent::RegisterEvent(LSCPEvent::event_global_info, "GLOBAL_INFO");
131      hSocket = -1;      hSocket = -1;
132  }  }
133    
134  LSCPServer::~LSCPServer() {  LSCPServer::~LSCPServer() {
135    #if defined(WIN32)
136        if (hSocket >= 0) closesocket(hSocket);
137    #else
138      if (hSocket >= 0) close(hSocket);      if (hSocket >= 0) close(hSocket);
139    #endif
140    }
141    
142    void LSCPServer::EventHandler::ChannelCountChanged(int NewCount) {
143        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_count, NewCount));
144    }
145    
146    void LSCPServer::EventHandler::AudioDeviceCountChanged(int NewCount) {
147        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_audio_device_count, NewCount));
148    }
149    
150    void LSCPServer::EventHandler::MidiDeviceCountChanged(int NewCount) {
151        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_device_count, NewCount));
152    }
153    
154    void LSCPServer::EventHandler::MidiInstrumentCountChanged(int MapId, int NewCount) {
155        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_count, MapId, NewCount));
156    }
157    
158    void LSCPServer::EventHandler::MidiInstrumentInfoChanged(int MapId, int Bank, int Program) {
159        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_info, MapId, Bank, Program));
160    }
161    
162    void LSCPServer::EventHandler::MidiInstrumentMapCountChanged(int NewCount) {
163        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_map_count, NewCount));
164    }
165    
166    void LSCPServer::EventHandler::MidiInstrumentMapInfoChanged(int MapId) {
167        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_map_info, MapId));
168    }
169    
170    void LSCPServer::EventHandler::FxSendCountChanged(int ChannelId, int NewCount) {
171        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_count, ChannelId, NewCount));
172    }
173    
174    void LSCPServer::EventHandler::VoiceCountChanged(int ChannelId, int NewCount) {
175        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_voice_count, ChannelId, NewCount));
176    }
177    
178    void LSCPServer::EventHandler::StreamCountChanged(int ChannelId, int NewCount) {
179        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_stream_count, ChannelId, NewCount));
180    }
181    
182    void LSCPServer::EventHandler::BufferFillChanged(int ChannelId, String FillData) {
183        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_buffer_fill, ChannelId, FillData));
184    }
185    
186    void LSCPServer::EventHandler::TotalVoiceCountChanged(int NewCount) {
187        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_total_voice_count, NewCount));
188    }
189    
190    #if HAVE_SQLITE3
191    void LSCPServer::DbInstrumentsEventHandler::DirectoryCountChanged(String Dir) {
192        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instr_dir_count, InstrumentsDb::toEscapedPath(Dir)));
193    }
194    
195    void LSCPServer::DbInstrumentsEventHandler::DirectoryInfoChanged(String Dir) {
196        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instr_dir_info, InstrumentsDb::toEscapedPath(Dir)));
197    }
198    
199    void LSCPServer::DbInstrumentsEventHandler::DirectoryNameChanged(String Dir, String NewName) {
200        Dir = "'" + InstrumentsDb::toEscapedPath(Dir) + "'";
201        NewName = "'" + InstrumentsDb::toEscapedPath(NewName) + "'";
202        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instr_dir_info, "NAME", Dir, NewName));
203    }
204    
205    void LSCPServer::DbInstrumentsEventHandler::InstrumentCountChanged(String Dir) {
206        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instr_count, InstrumentsDb::toEscapedPath(Dir)));
207  }  }
208    
209    void LSCPServer::DbInstrumentsEventHandler::InstrumentInfoChanged(String Instr) {
210        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instr_info, InstrumentsDb::toEscapedPath(Instr)));
211    }
212    
213    void LSCPServer::DbInstrumentsEventHandler::InstrumentNameChanged(String Instr, String NewName) {
214        Instr = "'" + InstrumentsDb::toEscapedPath(Instr) + "'";
215        NewName = "'" + InstrumentsDb::toEscapedPath(NewName) + "'";
216        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instr_info, "NAME", Instr, NewName));
217    }
218    
219    void LSCPServer::DbInstrumentsEventHandler::JobStatusChanged(int JobId) {
220        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_db_instrs_job_info, JobId));
221    }
222    #endif // HAVE_SQLITE3
223    
224    
225  /**  /**
226   * Blocks the calling thread until the LSCP Server is initialized and   * Blocks the calling thread until the LSCP Server is initialized and
227   * accepting socket connections, if the server is already initialized then   * accepting socket connections, if the server is already initialized then
# Line 95  int LSCPServer::WaitUntilInitialized(lon Line 237  int LSCPServer::WaitUntilInitialized(lon
237  }  }
238    
239  int LSCPServer::Main() {  int LSCPServer::Main() {
240            #if defined(WIN32)
241            WSADATA wsaData;
242            int iResult;
243            iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
244            if (iResult != 0) {
245                    std::cerr << "LSCPServer: WSAStartup failed: " << iResult << "\n";
246                    exit(EXIT_FAILURE);
247            }
248            #endif
249      hSocket = socket(AF_INET, SOCK_STREAM, 0);      hSocket = socket(AF_INET, SOCK_STREAM, 0);
250      if (hSocket < 0) {      if (hSocket < 0) {
251          std::cerr << "LSCPServer: Could not create server socket." << std::endl;          std::cerr << "LSCPServer: Could not create server socket." << std::endl;
# Line 108  int LSCPServer::Main() { Line 259  int LSCPServer::Main() {
259              if (bind(hSocket, (sockaddr*) &SocketAddress, sizeof(sockaddr_in)) < 0) {              if (bind(hSocket, (sockaddr*) &SocketAddress, sizeof(sockaddr_in)) < 0) {
260                  if (trial > LSCP_SERVER_BIND_TIMEOUT) {                  if (trial > LSCP_SERVER_BIND_TIMEOUT) {
261                      std::cerr << "gave up!" << std::endl;                      std::cerr << "gave up!" << std::endl;
262                        #if defined(WIN32)
263                        closesocket(hSocket);
264                        #else
265                      close(hSocket);                      close(hSocket);
266                        #endif
267                      //return -1;                      //return -1;
268                      exit(EXIT_FAILURE);                      exit(EXIT_FAILURE);
269                  }                  }
# Line 121  int LSCPServer::Main() { Line 276  int LSCPServer::Main() {
276      listen(hSocket, 1);      listen(hSocket, 1);
277      Initialized.Set(true);      Initialized.Set(true);
278    
279        // Registering event listeners
280        pSampler->AddChannelCountListener(&eventHandler);
281        pSampler->AddAudioDeviceCountListener(&eventHandler);
282        pSampler->AddMidiDeviceCountListener(&eventHandler);
283        pSampler->AddVoiceCountListener(&eventHandler);
284        pSampler->AddStreamCountListener(&eventHandler);
285        pSampler->AddBufferFillListener(&eventHandler);
286        pSampler->AddTotalVoiceCountListener(&eventHandler);
287        pSampler->AddFxSendCountListener(&eventHandler);
288        MidiInstrumentMapper::AddMidiInstrumentCountListener(&eventHandler);
289        MidiInstrumentMapper::AddMidiInstrumentInfoListener(&eventHandler);
290        MidiInstrumentMapper::AddMidiInstrumentMapCountListener(&eventHandler);
291        MidiInstrumentMapper::AddMidiInstrumentMapInfoListener(&eventHandler);
292    #if HAVE_SQLITE3
293        InstrumentsDb::GetInstrumentsDb()->AddInstrumentsDbListener(&dbInstrumentsEventHandler);
294    #endif
295      // now wait for client connections and handle their requests      // now wait for client connections and handle their requests
296      sockaddr_in client;      sockaddr_in client;
297      int length = sizeof(client);      int length = sizeof(client);
# Line 128  int LSCPServer::Main() { Line 299  int LSCPServer::Main() {
299      FD_SET(hSocket, &fdSet);      FD_SET(hSocket, &fdSet);
300      int maxSessions = hSocket;      int maxSessions = hSocket;
301    
302        timeval timeout;
303    
304      while (true) {      while (true) {
305          fd_set selectSet = fdSet;          // check if some engine channel's parameter / status changed, if so notify the respective LSCP event subscribers
306          int retval = select(maxSessions+1, &selectSet, NULL, NULL, NULL);          {
307                std::set<EngineChannel*> engineChannels = EngineChannelFactory::EngineChannelInstances();
308                std::set<EngineChannel*>::iterator itEngineChannel = engineChannels.begin();
309                std::set<EngineChannel*>::iterator itEnd           = engineChannels.end();
310                for (; itEngineChannel != itEnd; ++itEngineChannel) {
311                    if ((*itEngineChannel)->StatusChanged()) {
312                        SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_info, (*itEngineChannel)->iSamplerChannelIndex));
313                    }
314    
315                    for (int i = 0; i < (*itEngineChannel)->GetFxSendCount(); i++) {
316                        FxSend* fxs = (*itEngineChannel)->GetFxSend(i);
317                        if(fxs != NULL && fxs->IsInfoChanged()) {
318                            int chn = (*itEngineChannel)->iSamplerChannelIndex;
319                            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, chn, fxs->Id()));
320                            fxs->SetInfoChanged(false);
321                        }
322                    }
323                }
324            }
325    
326            //Now let's deliver late notifies (if any)
327            NotifyBufferMutex.Lock();
328            for (std::map<int,String>::iterator iterNotify = bufferedNotifies.begin(); iterNotify != bufferedNotifies.end(); iterNotify++) {
329    #ifdef MSG_NOSIGNAL
330                    send(iterNotify->first, iterNotify->second.c_str(), iterNotify->second.size(), MSG_NOSIGNAL);
331    #else
332                    send(iterNotify->first, iterNotify->second.c_str(), iterNotify->second.size(), 0);
333    #endif
334            }
335            bufferedNotifies.clear();
336            NotifyBufferMutex.Unlock();
337    
338            fd_set selectSet = fdSet;
339            timeout.tv_sec  = 0;
340            timeout.tv_usec = 100000;
341    
342            int retval = select(maxSessions+1, &selectSet, NULL, NULL, &timeout);
343    
344          if (retval == 0)          if (retval == 0)
345                  continue; //Nothing try again                  continue; //Nothing try again
346          if (retval == -1) {          if (retval == -1) {
347                  std::cerr << "LSCPServer: Socket select error." << std::endl;                  std::cerr << "LSCPServer: Socket select error." << std::endl;
348                    #if defined(WIN32)
349                    closesocket(hSocket);
350                    #else
351                  close(hSocket);                  close(hSocket);
352                    #endif
353                  exit(EXIT_FAILURE);                  exit(EXIT_FAILURE);
354          }          }
355    
# Line 147  int LSCPServer::Main() { Line 361  int LSCPServer::Main() {
361                          exit(EXIT_FAILURE);                          exit(EXIT_FAILURE);
362                  }                  }
363    
364                    #if defined(WIN32)
365                    u_long nonblock_io = 1;
366                    if( ioctlsocket(socket, FIONBIO, &nonblock_io) ) {
367                      std::cerr << "LSCPServer: ioctlsocket: set FIONBIO failed. Error " << WSAGetLastError() << std::endl;
368                      exit(EXIT_FAILURE);
369                    }
370            #else
371                  if (fcntl(socket, F_SETFL, O_NONBLOCK)) {                  if (fcntl(socket, F_SETFL, O_NONBLOCK)) {
372                          std::cerr << "LSCPServer: F_SETFL O_NONBLOCK failed." << std::endl;                          std::cerr << "LSCPServer: F_SETFL O_NONBLOCK failed." << std::endl;
373                          exit(EXIT_FAILURE);                          exit(EXIT_FAILURE);
374                  }                  }
375                    #endif
376    
377                  // Parser initialization                  // Parser initialization
378                  yyparse_param_t yyparse_param;                  yyparse_param_t yyparse_param;
# Line 174  int LSCPServer::Main() { Line 396  int LSCPServer::Main() {
396                                  int dummy; // just a temporary hack to fulfill the restart() function prototype                                  int dummy; // just a temporary hack to fulfill the restart() function prototype
397                                  restart(NULL, dummy); // restart the 'scanner'                                  restart(NULL, dummy); // restart the 'scanner'
398                                  currentSocket = (*iter).hSession;  //a hack                                  currentSocket = (*iter).hSession;  //a hack
399                                    itCurrentSession = iter; // another hack
400                                  dmsg(2,("LSCPServer: [%s]\n",bufferedCommands[currentSocket].c_str()));                                  dmsg(2,("LSCPServer: [%s]\n",bufferedCommands[currentSocket].c_str()));
401                                  if ((*iter).bVerbose) { // if echo mode enabled                                  if ((*iter).bVerbose) { // if echo mode enabled
402                                      AnswerClient(bufferedCommands[currentSocket]);                                      AnswerClient(bufferedCommands[currentSocket]);
403                                  }                                  }
404                                  int result = yyparse(&(*iter));                                  int result = yyparse(&(*iter));
405                                  currentSocket = -1;     //continuation of a hack                                  currentSocket = -1;     //continuation of a hack
406                                    itCurrentSession = Sessions.end(); // hack as well
407                                  dmsg(3,("LSCPServer: Done parsing on socket %d.\n", currentSocket));                                  dmsg(3,("LSCPServer: Done parsing on socket %d.\n", currentSocket));
408                                  if (result == LSCP_QUIT) { //Was it a quit command by any chance?                                  if (result == LSCP_QUIT) { //Was it a quit command by any chance?
409                                          CloseConnection(iter);                                          CloseConnection(iter);
# Line 190  int LSCPServer::Main() { Line 414  int LSCPServer::Main() {
414                          break;                          break;
415                  }                  }
416          }          }
   
         // check if some engine channel's parameter / status changed, if so notify the respective LSCP event subscribers  
         {  
             std::set<EngineChannel*> engineChannels = EngineChannelFactory::EngineChannelInstances();  
             std::set<EngineChannel*>::iterator itEngineChannel = engineChannels.begin();  
             std::set<EngineChannel*>::iterator itEnd           = engineChannels.end();  
             for (; itEngineChannel != itEnd; ++itEngineChannel) {  
                 if ((*itEngineChannel)->StatusChanged()) {  
                     SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_info, (*itEngineChannel)->iSamplerChannelIndex));  
                 }  
             }  
         }  
   
         //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(), MSG_NOSIGNAL);  
                 bufferedNotifies.erase(iterNotify);  
         }  
         NotifyBufferMutex.Unlock();  
417      }      }
418  }  }
419    
# Line 227  void LSCPServer::CloseConnection( std::v Line 431  void LSCPServer::CloseConnection( std::v
431          NotifyMutex.Lock();          NotifyMutex.Lock();
432          bufferedCommands.erase(socket);          bufferedCommands.erase(socket);
433          bufferedNotifies.erase(socket);          bufferedNotifies.erase(socket);
434            #if defined(WIN32)
435            closesocket(socket);
436            #else
437          close(socket);          close(socket);
438            #endif
439          NotifyMutex.Unlock();          NotifyMutex.Unlock();
440  }  }
441    
# Line 256  void LSCPServer::SendLSCPNotify( LSCPEve Line 464  void LSCPServer::SendLSCPNotify( LSCPEve
464          while (true) {          while (true) {
465                  if (NotifyMutex.Trylock()) {                  if (NotifyMutex.Trylock()) {
466                          for(;iter != end; iter++)                          for(;iter != end; iter++)
467    #ifdef MSG_NOSIGNAL
468                                  send(*iter, notify.c_str(), notify.size(), MSG_NOSIGNAL);                                  send(*iter, notify.c_str(), notify.size(), MSG_NOSIGNAL);
469    #else
470                                    send(*iter, notify.c_str(), notify.size(), 0);
471    #endif
472                          NotifyMutex.Unlock();                          NotifyMutex.Unlock();
473                          break;                          break;
474                  } else {                  } else {
# Line 288  extern int GetLSCPCommand( void *buf, in Line 500  extern int GetLSCPCommand( void *buf, in
500          return command.size();          return command.size();
501  }  }
502    
503    extern yyparse_param_t* GetCurrentYaccSession() {
504        return &(*itCurrentSession);
505    }
506    
507  /**  /**
508   * Will be called to try to read the command from the socket   * Will be called to try to read the command from the socket
509   * If command is read, it will return true. Otherwise false is returned.   * If command is read, it will return true. Otherwise false is returned.
# Line 298  bool LSCPServer::GetLSCPCommand( std::ve Line 514  bool LSCPServer::GetLSCPCommand( std::ve
514          char c;          char c;
515          int i = 0;          int i = 0;
516          while (true) {          while (true) {
517                    #if defined(WIN32)
518                    int result = recv(socket, (char *)&c, 1, 0); //Read one character at a time for now
519                    #else
520                  int result = recv(socket, (void *)&c, 1, 0); //Read one character at a time for now                  int result = recv(socket, (void *)&c, 1, 0); //Read one character at a time for now
521                    #endif
522                  if (result == 0) { //socket was selected, so 0 here means client has closed the connection                  if (result == 0) { //socket was selected, so 0 here means client has closed the connection
523                          CloseConnection(iter);                          CloseConnection(iter);
524                          break;                          break;
# Line 308  bool LSCPServer::GetLSCPCommand( std::ve Line 528  bool LSCPServer::GetLSCPCommand( std::ve
528                                  continue; //Ignore CR                                  continue; //Ignore CR
529                          if (c == '\n') {                          if (c == '\n') {
530                                  LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_misc, "Received \'" + bufferedCommands[socket] + "\' on socket", socket));                                  LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_misc, "Received \'" + bufferedCommands[socket] + "\' on socket", socket));
531                                  bufferedCommands[socket] += "\n";                                  bufferedCommands[socket] += "\r\n";
532                                  return true; //Complete command was read                                  return true; //Complete command was read
533                          }                          }
534                          bufferedCommands[socket] += c;                          bufferedCommands[socket] += c;
535                  }                  }
536                    #if defined(WIN32)
537                    if (result == SOCKET_ERROR) {
538                        int wsa_lasterror = WSAGetLastError();
539                            if (wsa_lasterror == WSAEWOULDBLOCK) //Would block, try again later.
540                                    return false;
541                            dmsg(2,("LSCPScanner: Socket error after recv() Error %d.\n", wsa_lasterror));
542                            CloseConnection(iter);
543                            break;
544                    }
545                    #else
546                  if (result == -1) {                  if (result == -1) {
547                          if (errno == EAGAIN) //Would block, try again later.                          if (errno == EAGAIN) //Would block, try again later.
548                                  return false;                                  return false;
# Line 351  bool LSCPServer::GetLSCPCommand( std::ve Line 581  bool LSCPServer::GetLSCPCommand( std::ve
581                          CloseConnection(iter);                          CloseConnection(iter);
582                          break;                          break;
583                  }                  }
584                    #endif
585          }          }
586          return false;          return false;
587  }  }
# Line 365  void LSCPServer::AnswerClient(String Ret Line 596  void LSCPServer::AnswerClient(String Ret
596      dmsg(2,("LSCPServer::AnswerClient(ReturnMessage=%s)", ReturnMessage.c_str()));      dmsg(2,("LSCPServer::AnswerClient(ReturnMessage=%s)", ReturnMessage.c_str()));
597      if (currentSocket != -1) {      if (currentSocket != -1) {
598              NotifyMutex.Lock();              NotifyMutex.Lock();
599    #ifdef MSG_NOSIGNAL
600              send(currentSocket, ReturnMessage.c_str(), ReturnMessage.size(), MSG_NOSIGNAL);              send(currentSocket, ReturnMessage.c_str(), ReturnMessage.size(), MSG_NOSIGNAL);
601    #else
602                send(currentSocket, ReturnMessage.c_str(), ReturnMessage.size(), 0);
603    #endif
604              NotifyMutex.Unlock();              NotifyMutex.Unlock();
605      }      }
606  }  }
# Line 409  String LSCPServer::CreateAudioOutputDevi Line 644  String LSCPServer::CreateAudioOutputDevi
644          AudioOutputDevice* pDevice = pSampler->CreateAudioOutputDevice(Driver, Parameters);          AudioOutputDevice* pDevice = pSampler->CreateAudioOutputDevice(Driver, Parameters);
645          // search for the created device to get its index          // search for the created device to get its index
646          int index = GetAudioOutputDeviceIndex(pDevice);          int index = GetAudioOutputDeviceIndex(pDevice);
647          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.");
648          result = index; // success          result = index; // success
649      }      }
650      catch (LinuxSamplerException e) {      catch (Exception e) {
651          result.Error(e);          result.Error(e);
652      }      }
653      return result.Produce();      return result.Produce();
# Line 425  String LSCPServer::CreateMidiInputDevice Line 660  String LSCPServer::CreateMidiInputDevice
660          MidiInputDevice* pDevice = pSampler->CreateMidiInputDevice(Driver, Parameters);          MidiInputDevice* pDevice = pSampler->CreateMidiInputDevice(Driver, Parameters);
661          // search for the created device to get its index          // search for the created device to get its index
662          int index = GetMidiInputDeviceIndex(pDevice);          int index = GetMidiInputDeviceIndex(pDevice);
663          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.");
664          result = index; // success          result = index; // success
665      }      }
666      catch (LinuxSamplerException e) {      catch (Exception e) {
667          result.Error(e);          result.Error(e);
668      }      }
669      return result.Produce();      return result.Produce();
# Line 439  String LSCPServer::DestroyAudioOutputDev Line 674  String LSCPServer::DestroyAudioOutputDev
674      LSCPResultSet result;      LSCPResultSet result;
675      try {      try {
676          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
677          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) + ".");
678          AudioOutputDevice* pDevice = devices[DeviceIndex];          AudioOutputDevice* pDevice = devices[DeviceIndex];
679          pSampler->DestroyAudioOutputDevice(pDevice);          pSampler->DestroyAudioOutputDevice(pDevice);
680      }      }
681      catch (LinuxSamplerException e) {      catch (Exception e) {
682          result.Error(e);          result.Error(e);
683      }      }
684      return result.Produce();      return result.Produce();
# Line 454  String LSCPServer::DestroyMidiInputDevic Line 689  String LSCPServer::DestroyMidiInputDevic
689      LSCPResultSet result;      LSCPResultSet result;
690      try {      try {
691          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
692          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) + ".");
693          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
694          pSampler->DestroyMidiInputDevice(pDevice);          pSampler->DestroyMidiInputDevice(pDevice);
695      }      }
696      catch (LinuxSamplerException e) {      catch (Exception e) {
697          result.Error(e);          result.Error(e);
698      }      }
699      return result.Produce();      return result.Produce();
700  }  }
701    
702    EngineChannel* LSCPServer::GetEngineChannel(uint uiSamplerChannel) {
703        SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
704        if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
705    
706        EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
707        if (!pEngineChannel) throw Exception("There is no engine deployed on this sampler channel yet");
708    
709        return pEngineChannel;
710    }
711    
712  /**  /**
713   * Will be called by the parser to load an instrument.   * Will be called by the parser to load an instrument.
714   */   */
# Line 472  String LSCPServer::LoadInstrument(String Line 717  String LSCPServer::LoadInstrument(String
717      LSCPResultSet result;      LSCPResultSet result;
718      try {      try {
719          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
720          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
721          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
722          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel yet");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel yet");
723          if (!pSamplerChannel->GetAudioOutputDevice())          if (!pSamplerChannel->GetAudioOutputDevice())
724              throw LinuxSamplerException("No audio output device connected to sampler channel");              throw Exception("No audio output device connected to sampler channel");
725          if (bBackground) {          if (bBackground) {
726              InstrumentLoader.StartNewLoad(Filename, uiInstrument, pEngineChannel);              InstrumentManager::instrument_id_t id;
727                id.FileName = Filename;
728                id.Index    = uiInstrument;
729                InstrumentManager::LoadInstrumentInBackground(id, pEngineChannel);
730          }          }
731          else {          else {
732              // tell the engine channel which instrument to load              // tell the engine channel which instrument to load
# Line 487  String LSCPServer::LoadInstrument(String Line 735  String LSCPServer::LoadInstrument(String
735              pEngineChannel->LoadInstrument();              pEngineChannel->LoadInstrument();
736          }          }
737      }      }
738      catch (LinuxSamplerException e) {      catch (Exception e) {
739           result.Error(e);           result.Error(e);
740      }      }
741      return result.Produce();      return result.Produce();
# Line 502  String LSCPServer::SetEngineType(String Line 750  String LSCPServer::SetEngineType(String
750      LSCPResultSet result;      LSCPResultSet result;
751      try {      try {
752          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
753          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
754          LockRTNotify();          LockRTNotify();
755          pSamplerChannel->SetEngineType(EngineName);          pSamplerChannel->SetEngineType(EngineName);
756          if(HasSoloChannel()) pSamplerChannel->GetEngineChannel()->SetMute(-1);          if(HasSoloChannel()) pSamplerChannel->GetEngineChannel()->SetMute(-1);
757          UnlockRTNotify();          UnlockRTNotify();
758      }      }
759      catch (LinuxSamplerException e) {      catch (Exception e) {
760           result.Error(e);           result.Error(e);
761      }      }
762      return result.Produce();      return result.Produce();
# Line 546  String LSCPServer::ListChannels() { Line 794  String LSCPServer::ListChannels() {
794   */   */
795  String LSCPServer::AddChannel() {  String LSCPServer::AddChannel() {
796      dmsg(2,("LSCPServer: AddChannel()\n"));      dmsg(2,("LSCPServer: AddChannel()\n"));
797        LockRTNotify();
798      SamplerChannel* pSamplerChannel = pSampler->AddSamplerChannel();      SamplerChannel* pSamplerChannel = pSampler->AddSamplerChannel();
799        UnlockRTNotify();
800      LSCPResultSet result(pSamplerChannel->Index());      LSCPResultSet result(pSamplerChannel->Index());
801      return result.Produce();      return result.Produce();
802  }  }
# Line 568  String LSCPServer::RemoveChannel(uint ui Line 818  String LSCPServer::RemoveChannel(uint ui
818   */   */
819  String LSCPServer::GetAvailableEngines() {  String LSCPServer::GetAvailableEngines() {
820      dmsg(2,("LSCPServer: GetAvailableEngines()\n"));      dmsg(2,("LSCPServer: GetAvailableEngines()\n"));
821      LSCPResultSet result("1");      LSCPResultSet result;
822        try {
823            int n = EngineFactory::AvailableEngineTypes().size();
824            result.Add(n);
825        }
826        catch (Exception e) {
827            result.Error(e);
828        }
829      return result.Produce();      return result.Produce();
830  }  }
831    
# Line 577  String LSCPServer::GetAvailableEngines() Line 834  String LSCPServer::GetAvailableEngines()
834   */   */
835  String LSCPServer::ListAvailableEngines() {  String LSCPServer::ListAvailableEngines() {
836      dmsg(2,("LSCPServer: ListAvailableEngines()\n"));      dmsg(2,("LSCPServer: ListAvailableEngines()\n"));
837      LSCPResultSet result("\'GIG\'");      LSCPResultSet result;
838        try {
839            String s = EngineFactory::AvailableEngineTypesAsString();
840            result.Add(s);
841        }
842        catch (Exception e) {
843            result.Error(e);
844        }
845      return result.Produce();      return result.Produce();
846  }  }
847    
# Line 588  String LSCPServer::ListAvailableEngines( Line 852  String LSCPServer::ListAvailableEngines(
852  String LSCPServer::GetEngineInfo(String EngineName) {  String LSCPServer::GetEngineInfo(String EngineName) {
853      dmsg(2,("LSCPServer: GetEngineInfo(EngineName=%s)\n", EngineName.c_str()));      dmsg(2,("LSCPServer: GetEngineInfo(EngineName=%s)\n", EngineName.c_str()));
854      LSCPResultSet result;      LSCPResultSet result;
855        LockRTNotify();
856      try {      try {
857          Engine* pEngine = EngineFactory::Create(EngineName);          Engine* pEngine = EngineFactory::Create(EngineName);
858          result.Add("DESCRIPTION", pEngine->Description());          result.Add("DESCRIPTION", _escapeLscpResponse(pEngine->Description()));
859          result.Add("VERSION",     pEngine->Version());          result.Add("VERSION",     pEngine->Version());
860          EngineFactory::Destroy(pEngine);          EngineFactory::Destroy(pEngine);
861      }      }
862      catch (LinuxSamplerException e) {      catch (Exception e) {
863           result.Error(e);           result.Error(e);
864      }      }
865        UnlockRTNotify();
866      return result.Produce();      return result.Produce();
867  }  }
868    
# Line 609  String LSCPServer::GetChannelInfo(uint u Line 875  String LSCPServer::GetChannelInfo(uint u
875      LSCPResultSet result;      LSCPResultSet result;
876      try {      try {
877          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
878          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
879          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
880    
881          //Defaults values          //Defaults values
# Line 623  String LSCPServer::GetChannelInfo(uint u Line 889  String LSCPServer::GetChannelInfo(uint u
889          String AudioRouting;          String AudioRouting;
890          int Mute = 0;          int Mute = 0;
891          bool Solo = false;          bool Solo = false;
892            String MidiInstrumentMap = "NONE";
893    
894          if (pEngineChannel) {          if (pEngineChannel) {
895              EngineName          = pEngineChannel->EngineName();              EngineName          = pEngineChannel->EngineName();
# Line 640  String LSCPServer::GetChannelInfo(uint u Line 907  String LSCPServer::GetChannelInfo(uint u
907              }              }
908              Mute = pEngineChannel->GetMute();              Mute = pEngineChannel->GetMute();
909              Solo = pEngineChannel->GetSolo();              Solo = pEngineChannel->GetSolo();
910                if (pEngineChannel->UsesNoMidiInstrumentMap())
911                    MidiInstrumentMap = "NONE";
912                else if (pEngineChannel->UsesDefaultMidiInstrumentMap())
913                    MidiInstrumentMap = "DEFAULT";
914                else
915                    MidiInstrumentMap = ToString(pEngineChannel->GetMidiInstrumentMap());
916          }          }
917    
918          result.Add("ENGINE_NAME", EngineName);          result.Add("ENGINE_NAME", EngineName);
# Line 655  String LSCPServer::GetChannelInfo(uint u Line 928  String LSCPServer::GetChannelInfo(uint u
928          if (pSamplerChannel->GetMidiInputChannel() == midi_chan_all) result.Add("MIDI_INPUT_CHANNEL", "ALL");          if (pSamplerChannel->GetMidiInputChannel() == midi_chan_all) result.Add("MIDI_INPUT_CHANNEL", "ALL");
929          else result.Add("MIDI_INPUT_CHANNEL", pSamplerChannel->GetMidiInputChannel());          else result.Add("MIDI_INPUT_CHANNEL", pSamplerChannel->GetMidiInputChannel());
930    
931            // convert the filename into the correct encoding as defined for LSCP
932            // (especially in terms of special characters -> escape sequences)
933            if (InstrumentFileName != "NONE" && InstrumentFileName != "") {
934    #if WIN32
935                InstrumentFileName = Path::fromWindows(InstrumentFileName).toLscp();
936    #else
937                // assuming POSIX
938                InstrumentFileName = Path::fromPosix(InstrumentFileName).toLscp();
939    #endif
940            }
941    
942          result.Add("INSTRUMENT_FILE", InstrumentFileName);          result.Add("INSTRUMENT_FILE", InstrumentFileName);
943          result.Add("INSTRUMENT_NR", InstrumentIndex);          result.Add("INSTRUMENT_NR", InstrumentIndex);
944          result.Add("INSTRUMENT_NAME", InstrumentName);          result.Add("INSTRUMENT_NAME", _escapeLscpResponse(InstrumentName));
945          result.Add("INSTRUMENT_STATUS", InstrumentStatus);          result.Add("INSTRUMENT_STATUS", InstrumentStatus);
946          result.Add("MUTE", Mute == -1 ? "MUTED_BY_SOLO" : (Mute ? "true" : "false"));          result.Add("MUTE", Mute == -1 ? "MUTED_BY_SOLO" : (Mute ? "true" : "false"));
947          result.Add("SOLO", Solo);          result.Add("SOLO", Solo);
948            result.Add("MIDI_INSTRUMENT_MAP", MidiInstrumentMap);
949      }      }
950      catch (LinuxSamplerException e) {      catch (Exception e) {
951           result.Error(e);           result.Error(e);
952      }      }
953      return result.Produce();      return result.Produce();
# Line 677  String LSCPServer::GetVoiceCount(uint ui Line 962  String LSCPServer::GetVoiceCount(uint ui
962      LSCPResultSet result;      LSCPResultSet result;
963      try {      try {
964          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
965          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
966          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
967          if (!pEngineChannel) throw LinuxSamplerException("No engine loaded on sampler channel");          if (!pEngineChannel) throw Exception("No engine loaded on sampler channel");
968          if (!pEngineChannel->GetEngine()) throw LinuxSamplerException("No audio output device connected to sampler channel");          if (!pEngineChannel->GetEngine()) throw Exception("No audio output device connected to sampler channel");
969          result.Add(pEngineChannel->GetEngine()->VoiceCount());          result.Add(pEngineChannel->GetEngine()->VoiceCount());
970      }      }
971      catch (LinuxSamplerException e) {      catch (Exception e) {
972           result.Error(e);           result.Error(e);
973      }      }
974      return result.Produce();      return result.Produce();
# Line 698  String LSCPServer::GetStreamCount(uint u Line 983  String LSCPServer::GetStreamCount(uint u
983      LSCPResultSet result;      LSCPResultSet result;
984      try {      try {
985          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
986          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
987          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
988          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
989          if (!pEngineChannel->GetEngine()) throw LinuxSamplerException("No audio output device connected to sampler channel");          if (!pEngineChannel->GetEngine()) throw Exception("No audio output device connected to sampler channel");
990          result.Add(pEngineChannel->GetEngine()->DiskStreamCount());          result.Add(pEngineChannel->GetEngine()->DiskStreamCount());
991      }      }
992      catch (LinuxSamplerException e) {      catch (Exception e) {
993           result.Error(e);           result.Error(e);
994      }      }
995      return result.Produce();      return result.Produce();
# Line 719  String LSCPServer::GetBufferFill(fill_re Line 1004  String LSCPServer::GetBufferFill(fill_re
1004      LSCPResultSet result;      LSCPResultSet result;
1005      try {      try {
1006          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1007          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1008          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1009          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1010          if (!pEngineChannel->GetEngine()) throw LinuxSamplerException("No audio output device connected to sampler channel");          if (!pEngineChannel->GetEngine()) throw Exception("No audio output device connected to sampler channel");
1011          if (!pEngineChannel->GetEngine()->DiskStreamSupported()) result.Add("NA");          if (!pEngineChannel->GetEngine()->DiskStreamSupported()) result.Add("NA");
1012          else {          else {
1013              switch (ResponseType) {              switch (ResponseType) {
# Line 733  String LSCPServer::GetBufferFill(fill_re Line 1018  String LSCPServer::GetBufferFill(fill_re
1018                      result.Add(pEngineChannel->GetEngine()->DiskStreamBufferFillPercentage());                      result.Add(pEngineChannel->GetEngine()->DiskStreamBufferFillPercentage());
1019                      break;                      break;
1020                  default:                  default:
1021                      throw LinuxSamplerException("Unknown fill response type");                      throw Exception("Unknown fill response type");
1022              }              }
1023          }          }
1024      }      }
1025      catch (LinuxSamplerException e) {      catch (Exception e) {
1026           result.Error(e);           result.Error(e);
1027      }      }
1028      return result.Produce();      return result.Produce();
# Line 750  String LSCPServer::GetAvailableAudioOutp Line 1035  String LSCPServer::GetAvailableAudioOutp
1035          int n = AudioOutputDeviceFactory::AvailableDrivers().size();          int n = AudioOutputDeviceFactory::AvailableDrivers().size();
1036          result.Add(n);          result.Add(n);
1037      }      }
1038      catch (LinuxSamplerException e) {      catch (Exception e) {
1039          result.Error(e);          result.Error(e);
1040      }      }
1041      return result.Produce();      return result.Produce();
# Line 763  String LSCPServer::ListAvailableAudioOut Line 1048  String LSCPServer::ListAvailableAudioOut
1048          String s = AudioOutputDeviceFactory::AvailableDriversAsString();          String s = AudioOutputDeviceFactory::AvailableDriversAsString();
1049          result.Add(s);          result.Add(s);
1050      }      }
1051      catch (LinuxSamplerException e) {      catch (Exception e) {
1052          result.Error(e);          result.Error(e);
1053      }      }
1054      return result.Produce();      return result.Produce();
# Line 776  String LSCPServer::GetAvailableMidiInput Line 1061  String LSCPServer::GetAvailableMidiInput
1061          int n = MidiInputDeviceFactory::AvailableDrivers().size();          int n = MidiInputDeviceFactory::AvailableDrivers().size();
1062          result.Add(n);          result.Add(n);
1063      }      }
1064      catch (LinuxSamplerException e) {      catch (Exception e) {
1065          result.Error(e);          result.Error(e);
1066      }      }
1067      return result.Produce();      return result.Produce();
# Line 789  String LSCPServer::ListAvailableMidiInpu Line 1074  String LSCPServer::ListAvailableMidiInpu
1074          String s = MidiInputDeviceFactory::AvailableDriversAsString();          String s = MidiInputDeviceFactory::AvailableDriversAsString();
1075          result.Add(s);          result.Add(s);
1076      }      }
1077      catch (LinuxSamplerException e) {      catch (Exception e) {
1078          result.Error(e);          result.Error(e);
1079      }      }
1080      return result.Produce();      return result.Produce();
# Line 813  String LSCPServer::GetMidiInputDriverInf Line 1098  String LSCPServer::GetMidiInputDriverInf
1098              result.Add("PARAMETERS", s);              result.Add("PARAMETERS", s);
1099          }          }
1100      }      }
1101      catch (LinuxSamplerException e) {      catch (Exception e) {
1102          result.Error(e);          result.Error(e);
1103      }      }
1104      return result.Produce();      return result.Produce();
# Line 837  String LSCPServer::GetAudioOutputDriverI Line 1122  String LSCPServer::GetAudioOutputDriverI
1122              result.Add("PARAMETERS", s);              result.Add("PARAMETERS", s);
1123          }          }
1124      }      }
1125      catch (LinuxSamplerException e) {      catch (Exception e) {
1126          result.Error(e);          result.Error(e);
1127      }      }
1128      return result.Produce();      return result.Produce();
# Line 864  String LSCPServer::GetMidiInputDriverPar Line 1149  String LSCPServer::GetMidiInputDriverPar
1149          if (oRangeMax)      result.Add("RANGE_MAX",     *oRangeMax);          if (oRangeMax)      result.Add("RANGE_MAX",     *oRangeMax);
1150          if (oPossibilities) result.Add("POSSIBILITIES", *oPossibilities);          if (oPossibilities) result.Add("POSSIBILITIES", *oPossibilities);
1151      }      }
1152      catch (LinuxSamplerException e) {      catch (Exception e) {
1153          result.Error(e);          result.Error(e);
1154      }      }
1155      return result.Produce();      return result.Produce();
# Line 891  String LSCPServer::GetAudioOutputDriverP Line 1176  String LSCPServer::GetAudioOutputDriverP
1176          if (oRangeMax)      result.Add("RANGE_MAX",     *oRangeMax);          if (oRangeMax)      result.Add("RANGE_MAX",     *oRangeMax);
1177          if (oPossibilities) result.Add("POSSIBILITIES", *oPossibilities);          if (oPossibilities) result.Add("POSSIBILITIES", *oPossibilities);
1178      }      }
1179      catch (LinuxSamplerException e) {      catch (Exception e) {
1180          result.Error(e);          result.Error(e);
1181      }      }
1182      return result.Produce();      return result.Produce();
# Line 904  String LSCPServer::GetAudioOutputDeviceC Line 1189  String LSCPServer::GetAudioOutputDeviceC
1189          uint count = pSampler->AudioOutputDevices();          uint count = pSampler->AudioOutputDevices();
1190          result.Add(count); // success          result.Add(count); // success
1191      }      }
1192      catch (LinuxSamplerException e) {      catch (Exception e) {
1193          result.Error(e);          result.Error(e);
1194      }      }
1195      return result.Produce();      return result.Produce();
# Line 917  String LSCPServer::GetMidiInputDeviceCou Line 1202  String LSCPServer::GetMidiInputDeviceCou
1202          uint count = pSampler->MidiInputDevices();          uint count = pSampler->MidiInputDevices();
1203          result.Add(count); // success          result.Add(count); // success
1204      }      }
1205      catch (LinuxSamplerException e) {      catch (Exception e) {
1206          result.Error(e);          result.Error(e);
1207      }      }
1208      return result.Produce();      return result.Produce();
# Line 936  String LSCPServer::GetAudioOutputDevices Line 1221  String LSCPServer::GetAudioOutputDevices
1221          }          }
1222          result.Add(s);          result.Add(s);
1223      }      }
1224      catch (LinuxSamplerException e) {      catch (Exception e) {
1225          result.Error(e);          result.Error(e);
1226      }      }
1227      return result.Produce();      return result.Produce();
# Line 955  String LSCPServer::GetMidiInputDevices() Line 1240  String LSCPServer::GetMidiInputDevices()
1240          }          }
1241          result.Add(s);          result.Add(s);
1242      }      }
1243      catch (LinuxSamplerException e) {      catch (Exception e) {
1244          result.Error(e);          result.Error(e);
1245      }      }
1246      return result.Produce();      return result.Produce();
# Line 966  String LSCPServer::GetAudioOutputDeviceI Line 1251  String LSCPServer::GetAudioOutputDeviceI
1251      LSCPResultSet result;      LSCPResultSet result;
1252      try {      try {
1253          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1254          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) + ".");
1255          AudioOutputDevice* pDevice = devices[DeviceIndex];          AudioOutputDevice* pDevice = devices[DeviceIndex];
1256          result.Add("DRIVER", pDevice->Driver());          result.Add("DRIVER", pDevice->Driver());
1257          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
# Line 975  String LSCPServer::GetAudioOutputDeviceI Line 1260  String LSCPServer::GetAudioOutputDeviceI
1260              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1261          }          }
1262      }      }
1263      catch (LinuxSamplerException e) {      catch (Exception e) {
1264          result.Error(e);          result.Error(e);
1265      }      }
1266      return result.Produce();      return result.Produce();
# Line 986  String LSCPServer::GetMidiInputDeviceInf Line 1271  String LSCPServer::GetMidiInputDeviceInf
1271      LSCPResultSet result;      LSCPResultSet result;
1272      try {      try {
1273          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1274          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) + ".");
1275          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1276          result.Add("DRIVER", pDevice->Driver());          result.Add("DRIVER", pDevice->Driver());
1277          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
# Line 995  String LSCPServer::GetMidiInputDeviceInf Line 1280  String LSCPServer::GetMidiInputDeviceInf
1280              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1281          }          }
1282      }      }
1283      catch (LinuxSamplerException e) {      catch (Exception e) {
1284          result.Error(e);          result.Error(e);
1285      }      }
1286      return result.Produce();      return result.Produce();
# Line 1006  String LSCPServer::GetMidiInputPortInfo( Line 1291  String LSCPServer::GetMidiInputPortInfo(
1291      try {      try {
1292          // get MIDI input device          // get MIDI input device
1293          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1294          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) + ".");
1295          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1296    
1297          // get MIDI port          // get MIDI port
1298          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);
1299          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) + ".");
1300    
1301          // return the values of all MIDI port parameters          // return the values of all MIDI port parameters
1302          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();
# Line 1020  String LSCPServer::GetMidiInputPortInfo( Line 1305  String LSCPServer::GetMidiInputPortInfo(
1305              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1306          }          }
1307      }      }
1308      catch (LinuxSamplerException e) {      catch (Exception e) {
1309          result.Error(e);          result.Error(e);
1310      }      }
1311      return result.Produce();      return result.Produce();
# Line 1032  String LSCPServer::GetAudioOutputChannel Line 1317  String LSCPServer::GetAudioOutputChannel
1317      try {      try {
1318          // get audio output device          // get audio output device
1319          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1320          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) + ".");
1321          AudioOutputDevice* pDevice = devices[DeviceId];          AudioOutputDevice* pDevice = devices[DeviceId];
1322    
1323          // get audio channel          // get audio channel
1324          AudioChannel* pChannel = pDevice->Channel(ChannelId);          AudioChannel* pChannel = pDevice->Channel(ChannelId);
1325          if (!pChannel) throw LinuxSamplerException("Audio output device does not have audio channel " + ToString(ChannelId) + ".");          if (!pChannel) throw Exception("Audio output device does not have audio channel " + ToString(ChannelId) + ".");
1326    
1327          // return the values of all audio channel parameters          // return the values of all audio channel parameters
1328          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();
# Line 1046  String LSCPServer::GetAudioOutputChannel Line 1331  String LSCPServer::GetAudioOutputChannel
1331              result.Add(iter->first, iter->second->Value());              result.Add(iter->first, iter->second->Value());
1332          }          }
1333      }      }
1334      catch (LinuxSamplerException e) {      catch (Exception e) {
1335          result.Error(e);          result.Error(e);
1336      }      }
1337      return result.Produce();      return result.Produce();
# Line 1058  String LSCPServer::GetMidiInputPortParam Line 1343  String LSCPServer::GetMidiInputPortParam
1343      try {      try {
1344          // get MIDI input device          // get MIDI input device
1345          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1346          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) + ".");
1347          MidiInputDevice* pDevice = devices[DeviceId];          MidiInputDevice* pDevice = devices[DeviceId];
1348    
1349          // get midi port          // get midi port
1350          MidiInputPort* pPort = pDevice->GetPort(PortId);          MidiInputPort* pPort = pDevice->GetPort(PortId);
1351          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) + ".");
1352    
1353          // get desired port parameter          // get desired port parameter
1354          std::map<String,DeviceRuntimeParameter*> parameters = pPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pPort->PortParameters();
1355          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 + "'.");
1356          DeviceRuntimeParameter* pParameter = parameters[ParameterName];          DeviceRuntimeParameter* pParameter = parameters[ParameterName];
1357    
1358          // return all fields of this audio channel parameter          // return all fields of this audio channel parameter
# Line 1079  String LSCPServer::GetMidiInputPortParam Line 1364  String LSCPServer::GetMidiInputPortParam
1364          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());
1365          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());
1366      }      }
1367      catch (LinuxSamplerException e) {      catch (Exception e) {
1368          result.Error(e);          result.Error(e);
1369      }      }
1370      return result.Produce();      return result.Produce();
# Line 1091  String LSCPServer::GetAudioOutputChannel Line 1376  String LSCPServer::GetAudioOutputChannel
1376      try {      try {
1377          // get audio output device          // get audio output device
1378          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1379          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) + ".");
1380          AudioOutputDevice* pDevice = devices[DeviceId];          AudioOutputDevice* pDevice = devices[DeviceId];
1381    
1382          // get audio channel          // get audio channel
1383          AudioChannel* pChannel = pDevice->Channel(ChannelId);          AudioChannel* pChannel = pDevice->Channel(ChannelId);
1384          if (!pChannel) throw LinuxSamplerException("Audio output device does not have audio channel " + ToString(ChannelId) + ".");          if (!pChannel) throw Exception("Audio output device does not have audio channel " + ToString(ChannelId) + ".");
1385    
1386          // get desired audio channel parameter          // get desired audio channel parameter
1387          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();
1388          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 + "'.");
1389          DeviceRuntimeParameter* pParameter = parameters[ParameterName];          DeviceRuntimeParameter* pParameter = parameters[ParameterName];
1390    
1391          // return all fields of this audio channel parameter          // return all fields of this audio channel parameter
# Line 1112  String LSCPServer::GetAudioOutputChannel Line 1397  String LSCPServer::GetAudioOutputChannel
1397          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());          if (pParameter->RangeMax())      result.Add("RANGE_MAX",     *pParameter->RangeMax());
1398          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());          if (pParameter->Possibilities()) result.Add("POSSIBILITIES", *pParameter->Possibilities());
1399      }      }
1400      catch (LinuxSamplerException e) {      catch (Exception e) {
1401          result.Error(e);          result.Error(e);
1402      }      }
1403      return result.Produce();      return result.Produce();
# Line 1124  String LSCPServer::SetAudioOutputChannel Line 1409  String LSCPServer::SetAudioOutputChannel
1409      try {      try {
1410          // get audio output device          // get audio output device
1411          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1412          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) + ".");
1413          AudioOutputDevice* pDevice = devices[DeviceId];          AudioOutputDevice* pDevice = devices[DeviceId];
1414    
1415          // get audio channel          // get audio channel
1416          AudioChannel* pChannel = pDevice->Channel(ChannelId);          AudioChannel* pChannel = pDevice->Channel(ChannelId);
1417          if (!pChannel) throw LinuxSamplerException("Audio output device does not have audio channel " + ToString(ChannelId) + ".");          if (!pChannel) throw Exception("Audio output device does not have audio channel " + ToString(ChannelId) + ".");
1418    
1419          // get desired audio channel parameter          // get desired audio channel parameter
1420          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pChannel->ChannelParameters();
1421          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 + "'.");
1422          DeviceRuntimeParameter* pParameter = parameters[ParamKey];          DeviceRuntimeParameter* pParameter = parameters[ParamKey];
1423    
1424          // set new channel parameter value          // set new channel parameter value
1425          pParameter->SetValue(ParamVal);          pParameter->SetValue(ParamVal);
1426            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_audio_device_info, DeviceId));
1427      }      }
1428      catch (LinuxSamplerException e) {      catch (Exception e) {
1429          result.Error(e);          result.Error(e);
1430      }      }
1431      return result.Produce();      return result.Produce();
# Line 1150  String LSCPServer::SetAudioOutputDeviceP Line 1436  String LSCPServer::SetAudioOutputDeviceP
1436      LSCPResultSet result;      LSCPResultSet result;
1437      try {      try {
1438          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint,AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1439          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) + ".");
1440          AudioOutputDevice* pDevice = devices[DeviceIndex];          AudioOutputDevice* pDevice = devices[DeviceIndex];
1441          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
1442          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 + "'");
1443          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1444            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_audio_device_info, DeviceIndex));
1445      }      }
1446      catch (LinuxSamplerException e) {      catch (Exception e) {
1447          result.Error(e);          result.Error(e);
1448      }      }
1449      return result.Produce();      return result.Produce();
# Line 1167  String LSCPServer::SetMidiInputDevicePar Line 1454  String LSCPServer::SetMidiInputDevicePar
1454      LSCPResultSet result;      LSCPResultSet result;
1455      try {      try {
1456          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1457          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) + ".");
1458          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1459          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
1460          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 + "'");
1461          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1462            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_device_info, DeviceIndex));
1463      }      }
1464      catch (LinuxSamplerException e) {      catch (Exception e) {
1465          result.Error(e);          result.Error(e);
1466      }      }
1467      return result.Produce();      return result.Produce();
# Line 1185  String LSCPServer::SetMidiInputPortParam Line 1473  String LSCPServer::SetMidiInputPortParam
1473      try {      try {
1474          // get MIDI input device          // get MIDI input device
1475          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint,MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1476          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) + ".");
1477          MidiInputDevice* pDevice = devices[DeviceIndex];          MidiInputDevice* pDevice = devices[DeviceIndex];
1478    
1479          // get MIDI port          // get MIDI port
1480          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);          MidiInputPort* pMidiInputPort = pDevice->GetPort(PortIndex);
1481          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) + ".");
1482    
1483          // set port parameter value          // set port parameter value
1484          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();
1485          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 + "'");
1486          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1487            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_device_info, DeviceIndex));
1488      }      }
1489      catch (LinuxSamplerException e) {      catch (Exception e) {
1490          result.Error(e);          result.Error(e);
1491      }      }
1492      return result.Produce();      return result.Produce();
# Line 1212  String LSCPServer::SetAudioOutputChannel Line 1501  String LSCPServer::SetAudioOutputChannel
1501      LSCPResultSet result;      LSCPResultSet result;
1502      try {      try {
1503          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1504          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1505          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1506          if (!pEngineChannel) throw LinuxSamplerException("No engine type yet assigned to sampler channel " + ToString(uiSamplerChannel));          if (!pEngineChannel) throw Exception("No engine type yet assigned to sampler channel " + ToString(uiSamplerChannel));
1507          if (!pSamplerChannel->GetAudioOutputDevice()) throw LinuxSamplerException("No audio output device connected to sampler channel " + ToString(uiSamplerChannel));          if (!pSamplerChannel->GetAudioOutputDevice()) throw Exception("No audio output device connected to sampler channel " + ToString(uiSamplerChannel));
1508          pEngineChannel->SetOutputChannel(ChannelAudioOutputChannel, AudioOutputDeviceInputChannel);          pEngineChannel->SetOutputChannel(ChannelAudioOutputChannel, AudioOutputDeviceInputChannel);
1509      }      }
1510      catch (LinuxSamplerException e) {      catch (Exception e) {
1511           result.Error(e);           result.Error(e);
1512      }      }
1513      return result.Produce();      return result.Produce();
# Line 1227  String LSCPServer::SetAudioOutputChannel Line 1516  String LSCPServer::SetAudioOutputChannel
1516  String LSCPServer::SetAudioOutputDevice(uint AudioDeviceId, uint uiSamplerChannel) {  String LSCPServer::SetAudioOutputDevice(uint AudioDeviceId, uint uiSamplerChannel) {
1517      dmsg(2,("LSCPServer: SetAudiotOutputDevice(AudioDeviceId=%d, SamplerChannel=%d)\n",AudioDeviceId,uiSamplerChannel));      dmsg(2,("LSCPServer: SetAudiotOutputDevice(AudioDeviceId=%d, SamplerChannel=%d)\n",AudioDeviceId,uiSamplerChannel));
1518      LSCPResultSet result;      LSCPResultSet result;
1519        LockRTNotify();
1520      try {      try {
1521          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1522          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1523          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();          std::map<uint, AudioOutputDevice*> devices = pSampler->GetAudioOutputDevices();
1524          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));
1525          AudioOutputDevice* pDevice = devices[AudioDeviceId];          AudioOutputDevice* pDevice = devices[AudioDeviceId];
1526          pSamplerChannel->SetAudioOutputDevice(pDevice);          pSamplerChannel->SetAudioOutputDevice(pDevice);
1527      }      }
1528      catch (LinuxSamplerException e) {      catch (Exception e) {
1529           result.Error(e);           result.Error(e);
1530      }      }
1531        UnlockRTNotify();
1532      return result.Produce();      return result.Produce();
1533  }  }
1534    
1535  String LSCPServer::SetAudioOutputType(String AudioOutputDriver, uint uiSamplerChannel) {  String LSCPServer::SetAudioOutputType(String AudioOutputDriver, uint uiSamplerChannel) {
1536      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));
1537      LSCPResultSet result;      LSCPResultSet result;
1538        LockRTNotify();
1539      try {      try {
1540          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1541          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1542          // Driver type name aliasing...          // Driver type name aliasing...
1543          if (AudioOutputDriver == "Alsa") AudioOutputDriver = "ALSA";          if (AudioOutputDriver == "Alsa") AudioOutputDriver = "ALSA";
1544          if (AudioOutputDriver == "Jack") AudioOutputDriver = "JACK";          if (AudioOutputDriver == "Jack") AudioOutputDriver = "JACK";
# Line 1268  String LSCPServer::SetAudioOutputType(St Line 1560  String LSCPServer::SetAudioOutputType(St
1560          }          }
1561          // Must have a device...          // Must have a device...
1562          if (pDevice == NULL)          if (pDevice == NULL)
1563              throw LinuxSamplerException("Internal error: could not create audio output device.");              throw Exception("Internal error: could not create audio output device.");
1564          // Set it as the current channel device...          // Set it as the current channel device...
1565          pSamplerChannel->SetAudioOutputDevice(pDevice);          pSamplerChannel->SetAudioOutputDevice(pDevice);
1566      }      }
1567      catch (LinuxSamplerException e) {      catch (Exception e) {
1568           result.Error(e);           result.Error(e);
1569      }      }
1570        UnlockRTNotify();
1571      return result.Produce();      return result.Produce();
1572  }  }
1573    
# Line 1283  String LSCPServer::SetMIDIInputPort(uint Line 1576  String LSCPServer::SetMIDIInputPort(uint
1576      LSCPResultSet result;      LSCPResultSet result;
1577      try {      try {
1578          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1579          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1580          pSamplerChannel->SetMidiInputPort(MIDIPort);          pSamplerChannel->SetMidiInputPort(MIDIPort);
1581      }      }
1582      catch (LinuxSamplerException e) {      catch (Exception e) {
1583           result.Error(e);           result.Error(e);
1584      }      }
1585      return result.Produce();      return result.Produce();
# Line 1297  String LSCPServer::SetMIDIInputChannel(u Line 1590  String LSCPServer::SetMIDIInputChannel(u
1590      LSCPResultSet result;      LSCPResultSet result;
1591      try {      try {
1592          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1593          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1594          pSamplerChannel->SetMidiInputChannel((midi_chan_t) MIDIChannel);          pSamplerChannel->SetMidiInputChannel((midi_chan_t) MIDIChannel);
1595      }      }
1596      catch (LinuxSamplerException e) {      catch (Exception e) {
1597           result.Error(e);           result.Error(e);
1598      }      }
1599      return result.Produce();      return result.Produce();
# Line 1311  String LSCPServer::SetMIDIInputDevice(ui Line 1604  String LSCPServer::SetMIDIInputDevice(ui
1604      LSCPResultSet result;      LSCPResultSet result;
1605      try {      try {
1606          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1607          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1608          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();          std::map<uint, MidiInputDevice*> devices = pSampler->GetMidiInputDevices();
1609          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));
1610          MidiInputDevice* pDevice = devices[MIDIDeviceId];          MidiInputDevice* pDevice = devices[MIDIDeviceId];
1611          pSamplerChannel->SetMidiInputDevice(pDevice);          pSamplerChannel->SetMidiInputDevice(pDevice);
1612      }      }
1613      catch (LinuxSamplerException e) {      catch (Exception e) {
1614           result.Error(e);           result.Error(e);
1615      }      }
1616      return result.Produce();      return result.Produce();
# Line 1328  String LSCPServer::SetMIDIInputType(Stri Line 1621  String LSCPServer::SetMIDIInputType(Stri
1621      LSCPResultSet result;      LSCPResultSet result;
1622      try {      try {
1623          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1624          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1625          // Driver type name aliasing...          // Driver type name aliasing...
1626          if (MidiInputDriver == "Alsa") MidiInputDriver = "ALSA";          if (MidiInputDriver == "Alsa") MidiInputDriver = "ALSA";
1627          // Check if there's one MIDI input device already created          // Check if there's one MIDI input device already created
# Line 1352  String LSCPServer::SetMIDIInputType(Stri Line 1645  String LSCPServer::SetMIDIInputType(Stri
1645          }          }
1646          // Must have a device...          // Must have a device...
1647          if (pDevice == NULL)          if (pDevice == NULL)
1648              throw LinuxSamplerException("Internal error: could not create MIDI input device.");              throw Exception("Internal error: could not create MIDI input device.");
1649          // Set it as the current channel device...          // Set it as the current channel device...
1650          pSamplerChannel->SetMidiInputDevice(pDevice);          pSamplerChannel->SetMidiInputDevice(pDevice);
1651      }      }
1652      catch (LinuxSamplerException e) {      catch (Exception e) {
1653           result.Error(e);           result.Error(e);
1654      }      }
1655      return result.Produce();      return result.Produce();
# Line 1371  String LSCPServer::SetMIDIInput(uint MID Line 1664  String LSCPServer::SetMIDIInput(uint MID
1664      LSCPResultSet result;      LSCPResultSet result;
1665      try {      try {
1666          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1667          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1668          std::map<uint, MidiInputDevice*> devices =  pSampler->GetMidiInputDevices();          std::map<uint, MidiInputDevice*> devices =  pSampler->GetMidiInputDevices();
1669          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));
1670          MidiInputDevice* pDevice = devices[MIDIDeviceId];          MidiInputDevice* pDevice = devices[MIDIDeviceId];
1671          pSamplerChannel->SetMidiInput(pDevice, MIDIPort, (midi_chan_t) MIDIChannel);          pSamplerChannel->SetMidiInput(pDevice, MIDIPort, (midi_chan_t) MIDIChannel);
1672      }      }
1673      catch (LinuxSamplerException e) {      catch (Exception e) {
1674           result.Error(e);           result.Error(e);
1675      }      }
1676      return result.Produce();      return result.Produce();
# Line 1392  String LSCPServer::SetVolume(double dVol Line 1685  String LSCPServer::SetVolume(double dVol
1685      LSCPResultSet result;      LSCPResultSet result;
1686      try {      try {
1687          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1688          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1689          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1690          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1691          pEngineChannel->Volume(dVolume);          pEngineChannel->Volume(dVolume);
1692      }      }
1693      catch (LinuxSamplerException e) {      catch (Exception e) {
1694           result.Error(e);           result.Error(e);
1695      }      }
1696      return result.Produce();      return result.Produce();
# Line 1411  String LSCPServer::SetChannelMute(bool b Line 1704  String LSCPServer::SetChannelMute(bool b
1704      LSCPResultSet result;      LSCPResultSet result;
1705      try {      try {
1706          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1707          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1708    
1709          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1710          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1711    
1712          if(!bMute) pEngineChannel->SetMute((HasSoloChannel() && !pEngineChannel->GetSolo()) ? -1 : 0);          if(!bMute) pEngineChannel->SetMute((HasSoloChannel() && !pEngineChannel->GetSolo()) ? -1 : 0);
1713          else pEngineChannel->SetMute(1);          else pEngineChannel->SetMute(1);
1714      } catch (LinuxSamplerException e) {      } catch (Exception e) {
1715          result.Error(e);          result.Error(e);
1716      }      }
1717      return result.Produce();      return result.Produce();
# Line 1432  String LSCPServer::SetChannelSolo(bool b Line 1725  String LSCPServer::SetChannelSolo(bool b
1725      LSCPResultSet result;      LSCPResultSet result;
1726      try {      try {
1727          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1728          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1729    
1730          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1731          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
1732    
1733          bool oldSolo = pEngineChannel->GetSolo();          bool oldSolo = pEngineChannel->GetSolo();
1734          bool hadSoloChannel = HasSoloChannel();          bool hadSoloChannel = HasSoloChannel();
1735            
1736          pEngineChannel->SetSolo(bSolo);          pEngineChannel->SetSolo(bSolo);
1737            
1738          if(!oldSolo && bSolo) {          if(!oldSolo && bSolo) {
1739              if(pEngineChannel->GetMute() == -1) pEngineChannel->SetMute(0);              if(pEngineChannel->GetMute() == -1) pEngineChannel->SetMute(0);
1740              if(!hadSoloChannel) MuteNonSoloChannels();              if(!hadSoloChannel) MuteNonSoloChannels();
1741          }          }
1742            
1743          if(oldSolo && !bSolo) {          if(oldSolo && !bSolo) {
1744              if(!HasSoloChannel()) UnmuteChannels();              if(!HasSoloChannel()) UnmuteChannels();
1745              else if(!pEngineChannel->GetMute()) pEngineChannel->SetMute(-1);              else if(!pEngineChannel->GetMute()) pEngineChannel->SetMute(-1);
1746          }          }
1747      } catch (LinuxSamplerException e) {      } catch (Exception e) {
1748          result.Error(e);          result.Error(e);
1749      }      }
1750      return result.Produce();      return result.Produce();
# Line 1504  void  LSCPServer::UnmuteChannels() { Line 1797  void  LSCPServer::UnmuteChannels() {
1797      }      }
1798  }  }
1799    
1800    String LSCPServer::AddOrReplaceMIDIInstrumentMapping(uint MidiMapID, uint MidiBank, uint MidiProg, String EngineType, String InstrumentFile, uint InstrumentIndex, float Volume, MidiInstrumentMapper::mode_t LoadMode, String Name, bool bModal) {
1801        dmsg(2,("LSCPServer: AddOrReplaceMIDIInstrumentMapping()\n"));
1802    
1803        midi_prog_index_t idx;
1804        idx.midi_bank_msb = (MidiBank >> 7) & 0x7f;
1805        idx.midi_bank_lsb = MidiBank & 0x7f;
1806        idx.midi_prog     = MidiProg;
1807    
1808        MidiInstrumentMapper::entry_t entry;
1809        entry.EngineName      = EngineType;
1810        entry.InstrumentFile  = InstrumentFile;
1811        entry.InstrumentIndex = InstrumentIndex;
1812        entry.LoadMode        = LoadMode;
1813        entry.Volume          = Volume;
1814        entry.Name            = Name;
1815    
1816        LSCPResultSet result;
1817        try {
1818            // PERSISTENT mapping commands might block for a long time, so in
1819            // that case we add/replace the mapping in another thread in case
1820            // the NON_MODAL argument was supplied, non persistent mappings
1821            // should return immediately, so we don't need to do that for them
1822            bool bInBackground = (entry.LoadMode == MidiInstrumentMapper::PERSISTENT && !bModal);
1823            MidiInstrumentMapper::AddOrReplaceEntry(MidiMapID, idx, entry, bInBackground);
1824        } catch (Exception e) {
1825            result.Error(e);
1826        }
1827        return result.Produce();
1828    }
1829    
1830    String LSCPServer::RemoveMIDIInstrumentMapping(uint MidiMapID, uint MidiBank, uint MidiProg) {
1831        dmsg(2,("LSCPServer: RemoveMIDIInstrumentMapping()\n"));
1832    
1833        midi_prog_index_t idx;
1834        idx.midi_bank_msb = (MidiBank >> 7) & 0x7f;
1835        idx.midi_bank_lsb = MidiBank & 0x7f;
1836        idx.midi_prog     = MidiProg;
1837    
1838        LSCPResultSet result;
1839        try {
1840            MidiInstrumentMapper::RemoveEntry(MidiMapID, idx);
1841        } catch (Exception e) {
1842            result.Error(e);
1843        }
1844        return result.Produce();
1845    }
1846    
1847    String LSCPServer::GetMidiInstrumentMappings(uint MidiMapID) {
1848        dmsg(2,("LSCPServer: GetMidiInstrumentMappings()\n"));
1849        LSCPResultSet result;
1850        try {
1851            result.Add(MidiInstrumentMapper::Entries(MidiMapID).size());
1852        } catch (Exception e) {
1853            result.Error(e);
1854        }
1855        return result.Produce();
1856    }
1857    
1858    
1859    String LSCPServer::GetAllMidiInstrumentMappings() {
1860        dmsg(2,("LSCPServer: GetAllMidiInstrumentMappings()\n"));
1861        LSCPResultSet result;
1862        std::vector<int> maps = MidiInstrumentMapper::Maps();
1863        int totalMappings = 0;
1864        for (int i = 0; i < maps.size(); i++) {
1865            try {
1866                totalMappings += MidiInstrumentMapper::Entries(maps[i]).size();
1867            } catch (Exception e) { /*NOOP*/ }
1868        }
1869        result.Add(totalMappings);
1870        return result.Produce();
1871    }
1872    
1873    String LSCPServer::GetMidiInstrumentMapping(uint MidiMapID, uint MidiBank, uint MidiProg) {
1874        dmsg(2,("LSCPServer: GetMidiIstrumentMapping()\n"));
1875        LSCPResultSet result;
1876        try {
1877            midi_prog_index_t idx;
1878            idx.midi_bank_msb = (MidiBank >> 7) & 0x7f;
1879            idx.midi_bank_lsb = MidiBank & 0x7f;
1880            idx.midi_prog     = MidiProg;
1881    
1882            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t> mappings = MidiInstrumentMapper::Entries(MidiMapID);
1883            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t>::iterator iter = mappings.find(idx);
1884            if (iter == mappings.end()) result.Error("there is no map entry with that index");
1885            else { // found
1886    
1887                // convert the filename into the correct encoding as defined for LSCP
1888                // (especially in terms of special characters -> escape sequences)
1889    #if WIN32
1890                const String instrumentFileName = Path::fromWindows(iter->second.InstrumentFile).toLscp();
1891    #else
1892                // assuming POSIX
1893                const String instrumentFileName = Path::fromPosix(iter->second.InstrumentFile).toLscp();
1894    #endif
1895    
1896                result.Add("NAME", _escapeLscpResponse(iter->second.Name));
1897                result.Add("ENGINE_NAME", iter->second.EngineName);
1898                result.Add("INSTRUMENT_FILE", instrumentFileName);
1899                result.Add("INSTRUMENT_NR", (int) iter->second.InstrumentIndex);
1900                String instrumentName;
1901                Engine* pEngine = EngineFactory::Create(iter->second.EngineName);
1902                if (pEngine) {
1903                    if (pEngine->GetInstrumentManager()) {
1904                        InstrumentManager::instrument_id_t instrID;
1905                        instrID.FileName = iter->second.InstrumentFile;
1906                        instrID.Index    = iter->second.InstrumentIndex;
1907                        instrumentName = pEngine->GetInstrumentManager()->GetInstrumentName(instrID);
1908                    }
1909                    EngineFactory::Destroy(pEngine);
1910                }
1911                result.Add("INSTRUMENT_NAME", _escapeLscpResponse(instrumentName));
1912                switch (iter->second.LoadMode) {
1913                    case MidiInstrumentMapper::ON_DEMAND:
1914                        result.Add("LOAD_MODE", "ON_DEMAND");
1915                        break;
1916                    case MidiInstrumentMapper::ON_DEMAND_HOLD:
1917                        result.Add("LOAD_MODE", "ON_DEMAND_HOLD");
1918                        break;
1919                    case MidiInstrumentMapper::PERSISTENT:
1920                        result.Add("LOAD_MODE", "PERSISTENT");
1921                        break;
1922                    default:
1923                        throw Exception("entry reflects invalid LOAD_MODE, consider this as a bug!");
1924                }
1925                result.Add("VOLUME", iter->second.Volume);
1926            }
1927        } catch (Exception e) {
1928            result.Error(e);
1929        }
1930        return result.Produce();
1931    }
1932    
1933    String LSCPServer::ListMidiInstrumentMappings(uint MidiMapID) {
1934        dmsg(2,("LSCPServer: ListMidiInstrumentMappings()\n"));
1935        LSCPResultSet result;
1936        try {
1937            String s;
1938            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t> mappings = MidiInstrumentMapper::Entries(MidiMapID);
1939            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t>::iterator iter = mappings.begin();
1940            for (; iter != mappings.end(); iter++) {
1941                if (s.size()) s += ",";
1942                s += "{" + ToString(MidiMapID) + ","
1943                         + ToString((int(iter->first.midi_bank_msb) << 7) | int(iter->first.midi_bank_lsb)) + ","
1944                         + ToString(int(iter->first.midi_prog)) + "}";
1945            }
1946            result.Add(s);
1947        } catch (Exception e) {
1948            result.Error(e);
1949        }
1950        return result.Produce();
1951    }
1952    
1953    String LSCPServer::ListAllMidiInstrumentMappings() {
1954        dmsg(2,("LSCPServer: ListAllMidiInstrumentMappings()\n"));
1955        LSCPResultSet result;
1956        try {
1957            std::vector<int> maps = MidiInstrumentMapper::Maps();
1958            String s;
1959            for (int i = 0; i < maps.size(); i++) {
1960                std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t> mappings = MidiInstrumentMapper::Entries(maps[i]);
1961                std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t>::iterator iter = mappings.begin();
1962                for (; iter != mappings.end(); iter++) {
1963                    if (s.size()) s += ",";
1964                    s += "{" + ToString(maps[i]) + ","
1965                             + ToString((int(iter->first.midi_bank_msb) << 7) | int(iter->first.midi_bank_lsb)) + ","
1966                             + ToString(int(iter->first.midi_prog)) + "}";
1967                }
1968            }
1969            result.Add(s);
1970        } catch (Exception e) {
1971            result.Error(e);
1972        }
1973        return result.Produce();
1974    }
1975    
1976    String LSCPServer::ClearMidiInstrumentMappings(uint MidiMapID) {
1977        dmsg(2,("LSCPServer: ClearMidiInstrumentMappings()\n"));
1978        LSCPResultSet result;
1979        try {
1980            MidiInstrumentMapper::RemoveAllEntries(MidiMapID);
1981        } catch (Exception e) {
1982            result.Error(e);
1983        }
1984        return result.Produce();
1985    }
1986    
1987    String LSCPServer::ClearAllMidiInstrumentMappings() {
1988        dmsg(2,("LSCPServer: ClearAllMidiInstrumentMappings()\n"));
1989        LSCPResultSet result;
1990        try {
1991            std::vector<int> maps = MidiInstrumentMapper::Maps();
1992            for (int i = 0; i < maps.size(); i++)
1993                MidiInstrumentMapper::RemoveAllEntries(maps[i]);
1994        } catch (Exception e) {
1995            result.Error(e);
1996        }
1997        return result.Produce();
1998    }
1999    
2000    String LSCPServer::AddMidiInstrumentMap(String MapName) {
2001        dmsg(2,("LSCPServer: AddMidiInstrumentMap()\n"));
2002        LSCPResultSet result;
2003        try {
2004            int MapID = MidiInstrumentMapper::AddMap(MapName);
2005            result = LSCPResultSet(MapID);
2006        } catch (Exception e) {
2007            result.Error(e);
2008        }
2009        return result.Produce();
2010    }
2011    
2012    String LSCPServer::RemoveMidiInstrumentMap(uint MidiMapID) {
2013        dmsg(2,("LSCPServer: RemoveMidiInstrumentMap()\n"));
2014        LSCPResultSet result;
2015        try {
2016            MidiInstrumentMapper::RemoveMap(MidiMapID);
2017        } catch (Exception e) {
2018            result.Error(e);
2019        }
2020        return result.Produce();
2021    }
2022    
2023    String LSCPServer::RemoveAllMidiInstrumentMaps() {
2024        dmsg(2,("LSCPServer: RemoveAllMidiInstrumentMaps()\n"));
2025        LSCPResultSet result;
2026        try {
2027            MidiInstrumentMapper::RemoveAllMaps();
2028        } catch (Exception e) {
2029            result.Error(e);
2030        }
2031        return result.Produce();
2032    }
2033    
2034    String LSCPServer::GetMidiInstrumentMaps() {
2035        dmsg(2,("LSCPServer: GetMidiInstrumentMaps()\n"));
2036        LSCPResultSet result;
2037        try {
2038            result.Add(MidiInstrumentMapper::Maps().size());
2039        } catch (Exception e) {
2040            result.Error(e);
2041        }
2042        return result.Produce();
2043    }
2044    
2045    String LSCPServer::ListMidiInstrumentMaps() {
2046        dmsg(2,("LSCPServer: ListMidiInstrumentMaps()\n"));
2047        LSCPResultSet result;
2048        try {
2049            std::vector<int> maps = MidiInstrumentMapper::Maps();
2050            String sList;
2051            for (int i = 0; i < maps.size(); i++) {
2052                if (sList != "") sList += ",";
2053                sList += ToString(maps[i]);
2054            }
2055            result.Add(sList);
2056        } catch (Exception e) {
2057            result.Error(e);
2058        }
2059        return result.Produce();
2060    }
2061    
2062    String LSCPServer::GetMidiInstrumentMap(uint MidiMapID) {
2063        dmsg(2,("LSCPServer: GetMidiInstrumentMap()\n"));
2064        LSCPResultSet result;
2065        try {
2066            result.Add("NAME", _escapeLscpResponse(MidiInstrumentMapper::MapName(MidiMapID)));
2067            result.Add("DEFAULT", MidiInstrumentMapper::GetDefaultMap() == MidiMapID);
2068        } catch (Exception e) {
2069            result.Error(e);
2070        }
2071        return result.Produce();
2072    }
2073    
2074    String LSCPServer::SetMidiInstrumentMapName(uint MidiMapID, String NewName) {
2075        dmsg(2,("LSCPServer: SetMidiInstrumentMapName()\n"));
2076        LSCPResultSet result;
2077        try {
2078            MidiInstrumentMapper::RenameMap(MidiMapID, NewName);
2079        } catch (Exception e) {
2080            result.Error(e);
2081        }
2082        return result.Produce();
2083    }
2084    
2085    /**
2086     * Set the MIDI instrument map the given sampler channel shall use for
2087     * handling MIDI program change messages. There are the following two
2088     * special (negative) values:
2089     *
2090     *    - (-1) :  set to NONE (ignore program changes)
2091     *    - (-2) :  set to DEFAULT map
2092     */
2093    String LSCPServer::SetChannelMap(uint uiSamplerChannel, int MidiMapID) {
2094        dmsg(2,("LSCPServer: SetChannelMap()\n"));
2095        LSCPResultSet result;
2096        try {
2097            SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
2098            if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
2099    
2100            EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
2101            if (!pEngineChannel) throw Exception("There is no engine deployed on this sampler channel yet");
2102    
2103            if      (MidiMapID == -1) pEngineChannel->SetMidiInstrumentMapToNone();
2104            else if (MidiMapID == -2) pEngineChannel->SetMidiInstrumentMapToDefault();
2105            else                      pEngineChannel->SetMidiInstrumentMap(MidiMapID);
2106        } catch (Exception e) {
2107            result.Error(e);
2108        }
2109        return result.Produce();
2110    }
2111    
2112    String LSCPServer::CreateFxSend(uint uiSamplerChannel, uint MidiCtrl, String Name) {
2113        dmsg(2,("LSCPServer: CreateFxSend()\n"));
2114        LSCPResultSet result;
2115        try {
2116            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2117    
2118            FxSend* pFxSend = pEngineChannel->AddFxSend(MidiCtrl, Name);
2119            if (!pFxSend) throw Exception("Could not add FxSend, don't ask, I don't know why (probably a bug)");
2120    
2121            result = LSCPResultSet(pFxSend->Id()); // success
2122        } catch (Exception e) {
2123            result.Error(e);
2124        }
2125        return result.Produce();
2126    }
2127    
2128    String LSCPServer::DestroyFxSend(uint uiSamplerChannel, uint FxSendID) {
2129        dmsg(2,("LSCPServer: DestroyFxSend()\n"));
2130        LSCPResultSet result;
2131        try {
2132            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2133    
2134            FxSend* pFxSend = NULL;
2135            for (int i = 0; i < pEngineChannel->GetFxSendCount(); i++) {
2136                if (pEngineChannel->GetFxSend(i)->Id() == FxSendID) {
2137                    pFxSend = pEngineChannel->GetFxSend(i);
2138                    break;
2139                }
2140            }
2141            if (!pFxSend) throw Exception("There is no FxSend with that ID on the given sampler channel");
2142            pEngineChannel->RemoveFxSend(pFxSend);
2143        } catch (Exception e) {
2144            result.Error(e);
2145        }
2146        return result.Produce();
2147    }
2148    
2149    String LSCPServer::GetFxSends(uint uiSamplerChannel) {
2150        dmsg(2,("LSCPServer: GetFxSends()\n"));
2151        LSCPResultSet result;
2152        try {
2153            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2154    
2155            result.Add(pEngineChannel->GetFxSendCount());
2156        } catch (Exception e) {
2157            result.Error(e);
2158        }
2159        return result.Produce();
2160    }
2161    
2162    String LSCPServer::ListFxSends(uint uiSamplerChannel) {
2163        dmsg(2,("LSCPServer: ListFxSends()\n"));
2164        LSCPResultSet result;
2165        String list;
2166        try {
2167            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2168    
2169            for (int i = 0; i < pEngineChannel->GetFxSendCount(); i++) {
2170                FxSend* pFxSend = pEngineChannel->GetFxSend(i);
2171                if (list != "") list += ",";
2172                list += ToString(pFxSend->Id());
2173            }
2174            result.Add(list);
2175        } catch (Exception e) {
2176            result.Error(e);
2177        }
2178        return result.Produce();
2179    }
2180    
2181    FxSend* LSCPServer::GetFxSend(uint uiSamplerChannel, uint FxSendID) {
2182        EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2183    
2184        FxSend* pFxSend = NULL;
2185        for (int i = 0; i < pEngineChannel->GetFxSendCount(); i++) {
2186            if (pEngineChannel->GetFxSend(i)->Id() == FxSendID) {
2187                pFxSend = pEngineChannel->GetFxSend(i);
2188                break;
2189            }
2190        }
2191        if (!pFxSend) throw Exception("There is no FxSend with that ID on the given sampler channel");
2192        return pFxSend;
2193    }
2194    
2195    String LSCPServer::GetFxSendInfo(uint uiSamplerChannel, uint FxSendID) {
2196        dmsg(2,("LSCPServer: GetFxSendInfo()\n"));
2197        LSCPResultSet result;
2198        try {
2199            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2200            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2201    
2202            // gather audio routing informations
2203            String AudioRouting;
2204            for (int chan = 0; chan < pEngineChannel->Channels(); chan++) {
2205                if (AudioRouting != "") AudioRouting += ",";
2206                AudioRouting += ToString(pFxSend->DestinationChannel(chan));
2207            }
2208    
2209            // success
2210            result.Add("NAME", _escapeLscpResponse(pFxSend->Name()));
2211            result.Add("MIDI_CONTROLLER", pFxSend->MidiController());
2212            result.Add("LEVEL", ToString(pFxSend->Level()));
2213            result.Add("AUDIO_OUTPUT_ROUTING", AudioRouting);
2214        } catch (Exception e) {
2215            result.Error(e);
2216        }
2217        return result.Produce();
2218    }
2219    
2220    String LSCPServer::SetFxSendName(uint uiSamplerChannel, uint FxSendID, String Name) {
2221        dmsg(2,("LSCPServer: SetFxSendName()\n"));
2222        LSCPResultSet result;
2223        try {
2224            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2225    
2226            pFxSend->SetName(Name);
2227            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2228        } catch (Exception e) {
2229            result.Error(e);
2230        }
2231        return result.Produce();
2232    }
2233    
2234    String LSCPServer::SetFxSendAudioOutputChannel(uint uiSamplerChannel, uint FxSendID, uint FxSendChannel, uint DeviceChannel) {
2235        dmsg(2,("LSCPServer: SetFxSendAudioOutputChannel()\n"));
2236        LSCPResultSet result;
2237        try {
2238            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2239    
2240            pFxSend->SetDestinationChannel(FxSendChannel, DeviceChannel);
2241            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2242        } catch (Exception e) {
2243            result.Error(e);
2244        }
2245        return result.Produce();
2246    }
2247    
2248    String LSCPServer::SetFxSendMidiController(uint uiSamplerChannel, uint FxSendID, uint MidiController) {
2249        dmsg(2,("LSCPServer: SetFxSendMidiController()\n"));
2250        LSCPResultSet result;
2251        try {
2252            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2253    
2254            pFxSend->SetMidiController(MidiController);
2255            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2256        } catch (Exception e) {
2257            result.Error(e);
2258        }
2259        return result.Produce();
2260    }
2261    
2262    String LSCPServer::SetFxSendLevel(uint uiSamplerChannel, uint FxSendID, double dLevel) {
2263        dmsg(2,("LSCPServer: SetFxSendLevel()\n"));
2264        LSCPResultSet result;
2265        try {
2266            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2267    
2268            pFxSend->SetLevel((float)dLevel);
2269            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2270        } catch (Exception e) {
2271            result.Error(e);
2272        }
2273        return result.Produce();
2274    }
2275    
2276    String LSCPServer::EditSamplerChannelInstrument(uint uiSamplerChannel) {
2277        dmsg(2,("LSCPServer: EditSamplerChannelInstrument(SamplerChannel=%d)\n", uiSamplerChannel));
2278        LSCPResultSet result;
2279        try {
2280            SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
2281            if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
2282            EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
2283            if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
2284            if (pEngineChannel->InstrumentStatus() < 0) throw Exception("No instrument loaded to sampler channel");
2285            Engine* pEngine = pEngineChannel->GetEngine();
2286            InstrumentManager* pInstrumentManager = pEngine->GetInstrumentManager();
2287            if (!pInstrumentManager) throw Exception("Engine does not provide an instrument manager");
2288            InstrumentManager::instrument_id_t instrumentID;
2289            instrumentID.FileName = pEngineChannel->InstrumentFileName();
2290            instrumentID.Index    = pEngineChannel->InstrumentIndex();
2291            pInstrumentManager->LaunchInstrumentEditor(instrumentID);
2292        } catch (Exception e) {
2293            result.Error(e);
2294        }
2295        return result.Produce();
2296    }
2297    
2298  /**  /**
2299   * Will be called by the parser to reset a particular sampler channel.   * Will be called by the parser to reset a particular sampler channel.
2300   */   */
# Line 1512  String LSCPServer::ResetChannel(uint uiS Line 2303  String LSCPServer::ResetChannel(uint uiS
2303      LSCPResultSet result;      LSCPResultSet result;
2304      try {      try {
2305          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);          SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
2306          if (!pSamplerChannel) throw LinuxSamplerException("Invalid sampler channel number " + ToString(uiSamplerChannel));          if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
2307          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();          EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
2308          if (!pEngineChannel) throw LinuxSamplerException("No engine type assigned to sampler channel");          if (!pEngineChannel) throw Exception("No engine type assigned to sampler channel");
2309          pEngineChannel->Reset();          pEngineChannel->Reset();
2310      }      }
2311      catch (LinuxSamplerException e) {      catch (Exception e) {
2312           result.Error(e);           result.Error(e);
2313      }      }
2314      return result.Produce();      return result.Produce();
# Line 1539  String LSCPServer::ResetSampler() { Line 2330  String LSCPServer::ResetSampler() {
2330   */   */
2331  String LSCPServer::GetServerInfo() {  String LSCPServer::GetServerInfo() {
2332      dmsg(2,("LSCPServer: GetServerInfo()\n"));      dmsg(2,("LSCPServer: GetServerInfo()\n"));
2333        const std::string description =
2334            _escapeLscpResponse("LinuxSampler - modular, streaming capable sampler");
2335      LSCPResultSet result;      LSCPResultSet result;
2336      result.Add("DESCRIPTION", "LinuxSampler - modular, streaming capable sampler");      result.Add("DESCRIPTION", description);
2337      result.Add("VERSION", VERSION);      result.Add("VERSION", VERSION);
2338      result.Add("PROTOCOL_VERSION", "1.0");      result.Add("PROTOCOL_VERSION", ToString(LSCP_RELEASE_MAJOR) + "." + ToString(LSCP_RELEASE_MINOR));
2339    #if HAVE_SQLITE3
2340        result.Add("INSTRUMENTS_DB_SUPPORT", "yes");
2341    #else
2342        result.Add("INSTRUMENTS_DB_SUPPORT", "no");
2343    #endif
2344    
2345      return result.Produce();      return result.Produce();
2346  }  }
2347    
# Line 1566  String LSCPServer::GetTotalVoiceCountMax Line 2365  String LSCPServer::GetTotalVoiceCountMax
2365      return result.Produce();      return result.Produce();
2366  }  }
2367    
2368    String LSCPServer::GetGlobalVolume() {
2369        LSCPResultSet result;
2370        result.Add(ToString(GLOBAL_VOLUME)); // see common/global.cpp
2371        return result.Produce();
2372    }
2373    
2374    String LSCPServer::SetGlobalVolume(double dVolume) {
2375        LSCPResultSet result;
2376        try {
2377            if (dVolume < 0) throw Exception("Volume may not be negative");
2378            GLOBAL_VOLUME = dVolume; // see common/global.cpp
2379            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_global_info, "VOLUME", GLOBAL_VOLUME));
2380        } catch (Exception e) {
2381            result.Error(e);
2382        }
2383        return result.Produce();
2384    }
2385    
2386    String LSCPServer::GetFileInstruments(String Filename) {
2387        dmsg(2,("LSCPServer: GetFileInstruments(String Filename=%s)\n",Filename.c_str()));
2388        LSCPResultSet result;
2389        try {
2390            VerifyFile(Filename);
2391        } catch (Exception e) {
2392            result.Error(e);
2393            return result.Produce();
2394        }
2395        // try to find a sampler engine that can handle the file
2396        bool bFound = false;
2397        std::vector<String> engineTypes = EngineFactory::AvailableEngineTypes();
2398        for (int i = 0; !bFound && i < engineTypes.size(); i++) {
2399            Engine* pEngine = NULL;
2400            try {
2401                pEngine = EngineFactory::Create(engineTypes[i]);
2402                if (!pEngine) throw Exception("Internal error: could not create '" + engineTypes[i] + "' engine");
2403                InstrumentManager* pManager = pEngine->GetInstrumentManager();
2404                if (pManager) {
2405                    std::vector<InstrumentManager::instrument_id_t> IDs =
2406                        pManager->GetInstrumentFileContent(Filename);
2407                    // return the amount of instruments in the file
2408                    result.Add(IDs.size());
2409                    // no more need to ask other engine types
2410                    bFound = true;
2411                } else dmsg(1,("Warning: engine '%s' does not provide an instrument manager\n", engineTypes[i].c_str()));
2412            } catch (Exception e) {
2413                // NOOP, as exception is thrown if engine doesn't support file
2414            }
2415            if (pEngine) EngineFactory::Destroy(pEngine);
2416        }
2417    
2418        if (!bFound) result.Error("Unknown file format");
2419        return result.Produce();
2420    }
2421    
2422    String LSCPServer::ListFileInstruments(String Filename) {
2423        dmsg(2,("LSCPServer: ListFileInstruments(String Filename=%s)\n",Filename.c_str()));
2424        LSCPResultSet result;
2425        try {
2426            VerifyFile(Filename);
2427        } catch (Exception e) {
2428            result.Error(e);
2429            return result.Produce();
2430        }
2431        // try to find a sampler engine that can handle the file
2432        bool bFound = false;
2433        std::vector<String> engineTypes = EngineFactory::AvailableEngineTypes();
2434        for (int i = 0; !bFound && i < engineTypes.size(); i++) {
2435            Engine* pEngine = NULL;
2436            try {
2437                pEngine = EngineFactory::Create(engineTypes[i]);
2438                if (!pEngine) throw Exception("Internal error: could not create '" + engineTypes[i] + "' engine");
2439                InstrumentManager* pManager = pEngine->GetInstrumentManager();
2440                if (pManager) {
2441                    std::vector<InstrumentManager::instrument_id_t> IDs =
2442                        pManager->GetInstrumentFileContent(Filename);
2443                    // return a list of IDs of the instruments in the file
2444                    String s;
2445                    for (int j = 0; j < IDs.size(); j++) {
2446                        if (s.size()) s += ",";
2447                        s += ToString(IDs[j].Index);
2448                    }
2449                    result.Add(s);
2450                    // no more need to ask other engine types
2451                    bFound = true;
2452                } else dmsg(1,("Warning: engine '%s' does not provide an instrument manager\n", engineTypes[i].c_str()));
2453            } catch (Exception e) {
2454                // NOOP, as exception is thrown if engine doesn't support file
2455            }
2456            if (pEngine) EngineFactory::Destroy(pEngine);
2457        }
2458    
2459        if (!bFound) result.Error("Unknown file format");
2460        return result.Produce();
2461    }
2462    
2463    String LSCPServer::GetFileInstrumentInfo(String Filename, uint InstrumentID) {
2464        dmsg(2,("LSCPServer: GetFileInstrumentInfo(String Filename=%s, InstrumentID=%d)\n",Filename.c_str(),InstrumentID));
2465        LSCPResultSet result;
2466        try {
2467            VerifyFile(Filename);
2468        } catch (Exception e) {
2469            result.Error(e);
2470            return result.Produce();
2471        }
2472        InstrumentManager::instrument_id_t id;
2473        id.FileName = Filename;
2474        id.Index    = InstrumentID;
2475        // try to find a sampler engine that can handle the file
2476        bool bFound = false;
2477        bool bFatalErr = false;
2478        std::vector<String> engineTypes = EngineFactory::AvailableEngineTypes();
2479        for (int i = 0; !bFound && !bFatalErr && i < engineTypes.size(); i++) {
2480            Engine* pEngine = NULL;
2481            try {
2482                pEngine = EngineFactory::Create(engineTypes[i]);
2483                if (!pEngine) throw Exception("Internal error: could not create '" + engineTypes[i] + "' engine");
2484                InstrumentManager* pManager = pEngine->GetInstrumentManager();
2485                if (pManager) {
2486                    // check if the instrument index is valid
2487                    // FIXME: this won't work if an engine only supports parts of the instrument file
2488                    std::vector<InstrumentManager::instrument_id_t> IDs =
2489                        pManager->GetInstrumentFileContent(Filename);
2490                    if (std::find(IDs.begin(), IDs.end(), id) == IDs.end()) {
2491                        std::stringstream ss;
2492                        ss << "Invalid instrument index " << InstrumentID << " for instrument file '" << Filename << "'";
2493                        bFatalErr = true;
2494                        throw Exception(ss.str());
2495                    }
2496                    // get the info of the requested instrument
2497                    InstrumentManager::instrument_info_t info =
2498                        pManager->GetInstrumentInfo(id);
2499                    // return detailed informations about the file
2500                    result.Add("NAME", info.InstrumentName);
2501                    result.Add("FORMAT_FAMILY", engineTypes[i]);
2502                    result.Add("FORMAT_VERSION", info.FormatVersion);
2503                    result.Add("PRODUCT", info.Product);
2504                    result.Add("ARTISTS", info.Artists);
2505                    // no more need to ask other engine types
2506                    bFound = true;
2507                } else dmsg(1,("Warning: engine '%s' does not provide an instrument manager\n", engineTypes[i].c_str()));
2508            } catch (Exception e) {
2509                // usually NOOP, as exception is thrown if engine doesn't support file
2510                if (bFatalErr) result.Error(e);
2511            }
2512            if (pEngine) EngineFactory::Destroy(pEngine);
2513        }
2514    
2515        if (!bFound && !bFatalErr) result.Error("Unknown file format");
2516        return result.Produce();
2517    }
2518    
2519    void LSCPServer::VerifyFile(String Filename) {
2520        struct stat statBuf;
2521        int res = stat(Filename.c_str(), &statBuf);
2522        if (res) {
2523            std::stringstream ss;
2524            ss << "Fail to stat `" << Filename << "`: " << strerror(errno);
2525            throw Exception(ss.str());
2526        }
2527    
2528        if (S_ISDIR(statBuf.st_mode)) {
2529            throw Exception("Directory is specified");
2530        }
2531    }
2532    
2533  /**  /**
2534   * 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
2535   * server for receiving event messages.   * server for receiving event messages.
# Line 1592  String LSCPServer::UnsubscribeNotificati Line 2556  String LSCPServer::UnsubscribeNotificati
2556      return result.Produce();      return result.Produce();
2557  }  }
2558    
2559  static int select_callback(void * lscpResultSet, int argc,  String LSCPServer::AddDbInstrumentDirectory(String Dir) {
2560                          char **argv, char **azColName)      dmsg(2,("LSCPServer: AddDbInstrumentDirectory(Dir=%s)\n", Dir.c_str()));
2561  {      LSCPResultSet result;
2562      LSCPResultSet* resultSet = (LSCPResultSet*) lscpResultSet;  #if HAVE_SQLITE3
2563      resultSet->Add(argc, argv);      try {
2564      return 0;          InstrumentsDb::GetInstrumentsDb()->AddDirectory(Dir);
2565        } catch (Exception e) {
2566             result.Error(e);
2567        }
2568    #else
2569        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2570    #endif
2571        return result.Produce();
2572    }
2573    
2574    String LSCPServer::RemoveDbInstrumentDirectory(String Dir, bool Force) {
2575        dmsg(2,("LSCPServer: RemoveDbInstrumentDirectory(Dir=%s,Force=%d)\n", Dir.c_str(), Force));
2576        LSCPResultSet result;
2577    #if HAVE_SQLITE3
2578        try {
2579            InstrumentsDb::GetInstrumentsDb()->RemoveDirectory(Dir, Force);
2580        } catch (Exception e) {
2581             result.Error(e);
2582        }
2583    #else
2584        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2585    #endif
2586        return result.Produce();
2587    }
2588    
2589    String LSCPServer::GetDbInstrumentDirectoryCount(String Dir, bool Recursive) {
2590        dmsg(2,("LSCPServer: GetDbInstrumentDirectoryCount(Dir=%s,Recursive=%d)\n", Dir.c_str(), Recursive));
2591        LSCPResultSet result;
2592    #if HAVE_SQLITE3
2593        try {
2594            result.Add(InstrumentsDb::GetInstrumentsDb()->GetDirectoryCount(Dir, Recursive));
2595        } catch (Exception e) {
2596             result.Error(e);
2597        }
2598    #else
2599        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2600    #endif
2601        return result.Produce();
2602    }
2603    
2604    String LSCPServer::GetDbInstrumentDirectories(String Dir, bool Recursive) {
2605        dmsg(2,("LSCPServer: GetDbInstrumentDirectories(Dir=%s,Recursive=%d)\n", Dir.c_str(), Recursive));
2606        LSCPResultSet result;
2607    #if HAVE_SQLITE3
2608        try {
2609            String list;
2610            StringListPtr dirs = InstrumentsDb::GetInstrumentsDb()->GetDirectories(Dir, Recursive);
2611    
2612            for (int i = 0; i < dirs->size(); i++) {
2613                if (list != "") list += ",";
2614                list += "'" + InstrumentsDb::toEscapedPath(dirs->at(i)) + "'";
2615            }
2616    
2617            result.Add(list);
2618        } catch (Exception e) {
2619             result.Error(e);
2620        }
2621    #else
2622        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2623    #endif
2624        return result.Produce();
2625    }
2626    
2627    String LSCPServer::GetDbInstrumentDirectoryInfo(String Dir) {
2628        dmsg(2,("LSCPServer: GetDbInstrumentDirectoryInfo(Dir=%s)\n", Dir.c_str()));
2629        LSCPResultSet result;
2630    #if HAVE_SQLITE3
2631        try {
2632            DbDirectory info = InstrumentsDb::GetInstrumentsDb()->GetDirectoryInfo(Dir);
2633    
2634            result.Add("DESCRIPTION", _escapeLscpResponse(info.Description));
2635            result.Add("CREATED", info.Created);
2636            result.Add("MODIFIED", info.Modified);
2637        } catch (Exception e) {
2638             result.Error(e);
2639        }
2640    #else
2641        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2642    #endif
2643        return result.Produce();
2644    }
2645    
2646    String LSCPServer::SetDbInstrumentDirectoryName(String Dir, String Name) {
2647        dmsg(2,("LSCPServer: SetDbInstrumentDirectoryName(Dir=%s,Name=%s)\n", Dir.c_str(), Name.c_str()));
2648        LSCPResultSet result;
2649    #if HAVE_SQLITE3
2650        try {
2651            InstrumentsDb::GetInstrumentsDb()->RenameDirectory(Dir, Name);
2652        } catch (Exception e) {
2653             result.Error(e);
2654        }
2655    #else
2656        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2657    #endif
2658        return result.Produce();
2659    }
2660    
2661    String LSCPServer::MoveDbInstrumentDirectory(String Dir, String Dst) {
2662        dmsg(2,("LSCPServer: MoveDbInstrumentDirectory(Dir=%s,Dst=%s)\n", Dir.c_str(), Dst.c_str()));
2663        LSCPResultSet result;
2664    #if HAVE_SQLITE3
2665        try {
2666            InstrumentsDb::GetInstrumentsDb()->MoveDirectory(Dir, Dst);
2667        } catch (Exception e) {
2668             result.Error(e);
2669        }
2670    #else
2671        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2672    #endif
2673        return result.Produce();
2674    }
2675    
2676    String LSCPServer::CopyDbInstrumentDirectory(String Dir, String Dst) {
2677        dmsg(2,("LSCPServer: CopyDbInstrumentDirectory(Dir=%s,Dst=%s)\n", Dir.c_str(), Dst.c_str()));
2678        LSCPResultSet result;
2679    #if HAVE_SQLITE3
2680        try {
2681            InstrumentsDb::GetInstrumentsDb()->CopyDirectory(Dir, Dst);
2682        } catch (Exception e) {
2683             result.Error(e);
2684        }
2685    #else
2686        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2687    #endif
2688        return result.Produce();
2689    }
2690    
2691    String LSCPServer::SetDbInstrumentDirectoryDescription(String Dir, String Desc) {
2692        dmsg(2,("LSCPServer: SetDbInstrumentDirectoryDescription(Dir=%s,Desc=%s)\n", Dir.c_str(), Desc.c_str()));
2693        LSCPResultSet result;
2694    #if HAVE_SQLITE3
2695        try {
2696            InstrumentsDb::GetInstrumentsDb()->SetDirectoryDescription(Dir, Desc);
2697        } catch (Exception e) {
2698             result.Error(e);
2699        }
2700    #else
2701        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2702    #endif
2703        return result.Produce();
2704    }
2705    
2706    String LSCPServer::AddDbInstruments(String DbDir, String FilePath, int Index, bool bBackground) {
2707        dmsg(2,("LSCPServer: AddDbInstruments(DbDir=%s,FilePath=%s,Index=%d,bBackground=%d)\n", DbDir.c_str(), FilePath.c_str(), Index, bBackground));
2708        LSCPResultSet result;
2709    #if HAVE_SQLITE3
2710        try {
2711            int id;
2712            InstrumentsDb* db = InstrumentsDb::GetInstrumentsDb();
2713            id = db->AddInstruments(DbDir, FilePath, Index, bBackground);
2714            if (bBackground) result = id;
2715        } catch (Exception e) {
2716             result.Error(e);
2717        }
2718    #else
2719        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2720    #endif
2721        return result.Produce();
2722    }
2723    
2724    String LSCPServer::AddDbInstruments(String ScanMode, String DbDir, String FsDir, bool bBackground) {
2725        dmsg(2,("LSCPServer: AddDbInstruments(ScanMode=%s,DbDir=%s,FsDir=%s,bBackground=%d)\n", ScanMode.c_str(), DbDir.c_str(), FsDir.c_str(), bBackground));
2726        LSCPResultSet result;
2727    #if HAVE_SQLITE3
2728        try {
2729            int id;
2730            InstrumentsDb* db = InstrumentsDb::GetInstrumentsDb();
2731            if (ScanMode.compare("RECURSIVE") == 0) {
2732               id = db->AddInstruments(RECURSIVE, DbDir, FsDir, bBackground);
2733            } else if (ScanMode.compare("NON_RECURSIVE") == 0) {
2734               id = db->AddInstruments(NON_RECURSIVE, DbDir, FsDir, bBackground);
2735            } else if (ScanMode.compare("FLAT") == 0) {
2736               id = db->AddInstruments(FLAT, DbDir, FsDir, bBackground);
2737            } else {
2738                throw Exception("Unknown scan mode: " + ScanMode);
2739            }
2740    
2741            if (bBackground) result = id;
2742        } catch (Exception e) {
2743             result.Error(e);
2744        }
2745    #else
2746        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2747    #endif
2748        return result.Produce();
2749    }
2750    
2751    String LSCPServer::RemoveDbInstrument(String Instr) {
2752        dmsg(2,("LSCPServer: RemoveDbInstrument(Instr=%s)\n", Instr.c_str()));
2753        LSCPResultSet result;
2754    #if HAVE_SQLITE3
2755        try {
2756            InstrumentsDb::GetInstrumentsDb()->RemoveInstrument(Instr);
2757        } catch (Exception e) {
2758             result.Error(e);
2759        }
2760    #else
2761        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2762    #endif
2763        return result.Produce();
2764    }
2765    
2766    String LSCPServer::GetDbInstrumentCount(String Dir, bool Recursive) {
2767        dmsg(2,("LSCPServer: GetDbInstrumentCount(Dir=%s,Recursive=%d)\n", Dir.c_str(), Recursive));
2768        LSCPResultSet result;
2769    #if HAVE_SQLITE3
2770        try {
2771            result.Add(InstrumentsDb::GetInstrumentsDb()->GetInstrumentCount(Dir, Recursive));
2772        } catch (Exception e) {
2773             result.Error(e);
2774        }
2775    #else
2776        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2777    #endif
2778        return result.Produce();
2779    }
2780    
2781    String LSCPServer::GetDbInstruments(String Dir, bool Recursive) {
2782        dmsg(2,("LSCPServer: GetDbInstruments(Dir=%s,Recursive=%d)\n", Dir.c_str(), Recursive));
2783        LSCPResultSet result;
2784    #if HAVE_SQLITE3
2785        try {
2786            String list;
2787            StringListPtr instrs = InstrumentsDb::GetInstrumentsDb()->GetInstruments(Dir, Recursive);
2788    
2789            for (int i = 0; i < instrs->size(); i++) {
2790                if (list != "") list += ",";
2791                list += "'" + InstrumentsDb::toEscapedPath(instrs->at(i)) + "'";
2792            }
2793    
2794            result.Add(list);
2795        } catch (Exception e) {
2796             result.Error(e);
2797        }
2798    #else
2799        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2800    #endif
2801        return result.Produce();
2802    }
2803    
2804    String LSCPServer::GetDbInstrumentInfo(String Instr) {
2805        dmsg(2,("LSCPServer: GetDbInstrumentInfo(Instr=%s)\n", Instr.c_str()));
2806        LSCPResultSet result;
2807    #if HAVE_SQLITE3
2808        try {
2809            DbInstrument info = InstrumentsDb::GetInstrumentsDb()->GetInstrumentInfo(Instr);
2810    
2811            result.Add("INSTRUMENT_FILE", info.InstrFile);
2812            result.Add("INSTRUMENT_NR", info.InstrNr);
2813            result.Add("FORMAT_FAMILY", info.FormatFamily);
2814            result.Add("FORMAT_VERSION", info.FormatVersion);
2815            result.Add("SIZE", (int)info.Size);
2816            result.Add("CREATED", info.Created);
2817            result.Add("MODIFIED", info.Modified);
2818            result.Add("DESCRIPTION", _escapeLscpResponse(info.Description));
2819            result.Add("IS_DRUM", info.IsDrum);
2820            result.Add("PRODUCT", _escapeLscpResponse(info.Product));
2821            result.Add("ARTISTS", _escapeLscpResponse(info.Artists));
2822            result.Add("KEYWORDS", _escapeLscpResponse(info.Keywords));
2823        } catch (Exception e) {
2824             result.Error(e);
2825        }
2826    #else
2827        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2828    #endif
2829        return result.Produce();
2830  }  }
2831    
2832  String LSCPServer::QueryDatabase(String query) {  String LSCPServer::GetDbInstrumentsJobInfo(int JobId) {
2833        dmsg(2,("LSCPServer: GetDbInstrumentsJobInfo(JobId=%d)\n", JobId));
2834      LSCPResultSet result;      LSCPResultSet result;
2835  #if HAVE_SQLITE3  #if HAVE_SQLITE3
2836      char* zErrMsg = NULL;      try {
2837      sqlite3 *db;          ScanJob job = InstrumentsDb::GetInstrumentsDb()->Jobs.GetJobById(JobId);
     String selectStr = "SELECT " + query;  
2838    
2839      int rc = sqlite3_open("linuxsampler.db", &db);          result.Add("FILES_TOTAL", job.FilesTotal);
2840      if (rc == SQLITE_OK)          result.Add("FILES_SCANNED", job.FilesScanned);
2841      {          result.Add("SCANNING", job.Scanning);
2842              rc = sqlite3_exec(db, selectStr.c_str(), select_callback, &result, &zErrMsg);          result.Add("STATUS", job.Status);
2843        } catch (Exception e) {
2844             result.Error(e);
2845        }
2846    #else
2847        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2848    #endif
2849        return result.Produce();
2850    }
2851    
2852    String LSCPServer::SetDbInstrumentName(String Instr, String Name) {
2853        dmsg(2,("LSCPServer: SetDbInstrumentName(Instr=%s,Name=%s)\n", Instr.c_str(), Name.c_str()));
2854        LSCPResultSet result;
2855    #if HAVE_SQLITE3
2856        try {
2857            InstrumentsDb::GetInstrumentsDb()->RenameInstrument(Instr, Name);
2858        } catch (Exception e) {
2859             result.Error(e);
2860      }      }
2861      if ( rc != SQLITE_OK )  #else
2862      {      result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2863              result.Error(String(zErrMsg), rc);  #endif
2864        return result.Produce();
2865    }
2866    
2867    String LSCPServer::MoveDbInstrument(String Instr, String Dst) {
2868        dmsg(2,("LSCPServer: MoveDbInstrument(Instr=%s,Dst=%s)\n", Instr.c_str(), Dst.c_str()));
2869        LSCPResultSet result;
2870    #if HAVE_SQLITE3
2871        try {
2872            InstrumentsDb::GetInstrumentsDb()->MoveInstrument(Instr, Dst);
2873        } catch (Exception e) {
2874             result.Error(e);
2875        }
2876    #else
2877        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2878    #endif
2879        return result.Produce();
2880    }
2881    
2882    String LSCPServer::CopyDbInstrument(String Instr, String Dst) {
2883        dmsg(2,("LSCPServer: CopyDbInstrument(Instr=%s,Dst=%s)\n", Instr.c_str(), Dst.c_str()));
2884        LSCPResultSet result;
2885    #if HAVE_SQLITE3
2886        try {
2887            InstrumentsDb::GetInstrumentsDb()->CopyInstrument(Instr, Dst);
2888        } catch (Exception e) {
2889             result.Error(e);
2890        }
2891    #else
2892        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2893    #endif
2894        return result.Produce();
2895    }
2896    
2897    String LSCPServer::SetDbInstrumentDescription(String Instr, String Desc) {
2898        dmsg(2,("LSCPServer: SetDbInstrumentDescription(Instr=%s,Desc=%s)\n", Instr.c_str(), Desc.c_str()));
2899        LSCPResultSet result;
2900    #if HAVE_SQLITE3
2901        try {
2902            InstrumentsDb::GetInstrumentsDb()->SetInstrumentDescription(Instr, Desc);
2903        } catch (Exception e) {
2904             result.Error(e);
2905      }      }
     sqlite3_close(db);  
2906  #else  #else
2907      result.Error(String("SQLITE3 was not installed when linuxsampler was built. SELECT statement is not available."), 0);      result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2908  #endif  #endif
2909      return result.Produce();      return result.Produce();
2910  }  }
2911    
2912    String LSCPServer::FindDbInstrumentDirectories(String Dir, std::map<String,String> Parameters, bool Recursive) {
2913        dmsg(2,("LSCPServer: FindDbInstrumentDirectories(Dir=%s)\n", Dir.c_str()));
2914        LSCPResultSet result;
2915    #if HAVE_SQLITE3
2916        try {
2917            SearchQuery Query;
2918            std::map<String,String>::iterator iter;
2919            for (iter = Parameters.begin(); iter != Parameters.end(); iter++) {
2920                if (iter->first.compare("NAME") == 0) {
2921                    Query.Name = iter->second;
2922                } else if (iter->first.compare("CREATED") == 0) {
2923                    Query.SetCreated(iter->second);
2924                } else if (iter->first.compare("MODIFIED") == 0) {
2925                    Query.SetModified(iter->second);
2926                } else if (iter->first.compare("DESCRIPTION") == 0) {
2927                    Query.Description = iter->second;
2928                } else {
2929                    throw Exception("Unknown search criteria: " + iter->first);
2930                }
2931            }
2932    
2933            String list;
2934            StringListPtr pDirectories =
2935                InstrumentsDb::GetInstrumentsDb()->FindDirectories(Dir, &Query, Recursive);
2936    
2937            for (int i = 0; i < pDirectories->size(); i++) {
2938                if (list != "") list += ",";
2939                list += "'" + InstrumentsDb::toEscapedPath(pDirectories->at(i)) + "'";
2940            }
2941    
2942            result.Add(list);
2943        } catch (Exception e) {
2944             result.Error(e);
2945        }
2946    #else
2947        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
2948    #endif
2949        return result.Produce();
2950    }
2951    
2952    String LSCPServer::FindDbInstruments(String Dir, std::map<String,String> Parameters, bool Recursive) {
2953        dmsg(2,("LSCPServer: FindDbInstruments(Dir=%s)\n", Dir.c_str()));
2954        LSCPResultSet result;
2955    #if HAVE_SQLITE3
2956        try {
2957            SearchQuery Query;
2958            std::map<String,String>::iterator iter;
2959            for (iter = Parameters.begin(); iter != Parameters.end(); iter++) {
2960                if (iter->first.compare("NAME") == 0) {
2961                    Query.Name = iter->second;
2962                } else if (iter->first.compare("FORMAT_FAMILIES") == 0) {
2963                    Query.SetFormatFamilies(iter->second);
2964                } else if (iter->first.compare("SIZE") == 0) {
2965                    Query.SetSize(iter->second);
2966                } else if (iter->first.compare("CREATED") == 0) {
2967                    Query.SetCreated(iter->second);
2968                } else if (iter->first.compare("MODIFIED") == 0) {
2969                    Query.SetModified(iter->second);
2970                } else if (iter->first.compare("DESCRIPTION") == 0) {
2971                    Query.Description = iter->second;
2972                } else if (iter->first.compare("IS_DRUM") == 0) {
2973                    if (!strcasecmp(iter->second.c_str(), "true")) {
2974                        Query.InstrType = SearchQuery::DRUM;
2975                    } else {
2976                        Query.InstrType = SearchQuery::CHROMATIC;
2977                    }
2978                } else if (iter->first.compare("PRODUCT") == 0) {
2979                     Query.Product = iter->second;
2980                } else if (iter->first.compare("ARTISTS") == 0) {
2981                     Query.Artists = iter->second;
2982                } else if (iter->first.compare("KEYWORDS") == 0) {
2983                     Query.Keywords = iter->second;
2984                } else {
2985                    throw Exception("Unknown search criteria: " + iter->first);
2986                }
2987            }
2988    
2989            String list;
2990            StringListPtr pInstruments =
2991                InstrumentsDb::GetInstrumentsDb()->FindInstruments(Dir, &Query, Recursive);
2992    
2993            for (int i = 0; i < pInstruments->size(); i++) {
2994                if (list != "") list += ",";
2995                list += "'" + InstrumentsDb::toEscapedPath(pInstruments->at(i)) + "'";
2996            }
2997    
2998            result.Add(list);
2999        } catch (Exception e) {
3000             result.Error(e);
3001        }
3002    #else
3003        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
3004    #endif
3005        return result.Produce();
3006    }
3007    
3008    String LSCPServer::FormatInstrumentsDb() {
3009        dmsg(2,("LSCPServer: FormatInstrumentsDb()\n"));
3010        LSCPResultSet result;
3011    #if HAVE_SQLITE3
3012        try {
3013            InstrumentsDb::GetInstrumentsDb()->Format();
3014        } catch (Exception e) {
3015             result.Error(e);
3016        }
3017    #else
3018        result.Error(String(DOESNT_HAVE_SQLITE3), 0);
3019    #endif
3020        return result.Produce();
3021    }
3022    
3023    
3024  /**  /**
3025   * 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
3026   * mode is enabled, all commands from the client will (immediately) be   * mode is enabled, all commands from the client will (immediately) be
# Line 1634  String LSCPServer::SetEcho(yyparse_param Line 3032  String LSCPServer::SetEcho(yyparse_param
3032      try {      try {
3033          if      (boolean_value == 0) pSession->bVerbose = false;          if      (boolean_value == 0) pSession->bVerbose = false;
3034          else if (boolean_value == 1) pSession->bVerbose = true;          else if (boolean_value == 1) pSession->bVerbose = true;
3035          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");
3036      }      }
3037      catch (LinuxSamplerException e) {      catch (Exception e) {
3038           result.Error(e);           result.Error(e);
3039      }      }
3040      return result.Produce();      return result.Produce();

Legend:
Removed from v.778  
changed lines
  Added in v.1536

  ViewVC Help
Powered by ViewVC