/[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 905 by schoenebeck, Sun Jul 23 16:23:13 2006 UTC revision 1135 by iliev, Thu Mar 29 09:40:45 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, 2006 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"
27  //#include "../common/global.h"  #include "../common/global.h"
28    
29  #include <fcntl.h>  #include <fcntl.h>
30    
# Line 66  LSCPServer::LSCPServer(Sampler* pSampler Line 66  LSCPServer::LSCPServer(Sampler* pSampler
66      SocketAddress.sin_addr.s_addr = addr;      SocketAddress.sin_addr.s_addr = addr;
67      SocketAddress.sin_port        = port;      SocketAddress.sin_port        = port;
68      this->pSampler = pSampler;      this->pSampler = pSampler;
69        LSCPEvent::RegisterEvent(LSCPEvent::event_audio_device_count, "AUDIO_OUTPUT_DEVICE_COUNT");
70        LSCPEvent::RegisterEvent(LSCPEvent::event_audio_device_info, "AUDIO_OUTPUT_DEVICE_INFO");
71        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_device_count, "MIDI_INPUT_DEVICE_COUNT");
72        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_device_info, "MIDI_INPUT_DEVICE_INFO");
73      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_count, "CHANNEL_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_count, "CHANNEL_COUNT");
74      LSCPEvent::RegisterEvent(LSCPEvent::event_voice_count, "VOICE_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_voice_count, "VOICE_COUNT");
75      LSCPEvent::RegisterEvent(LSCPEvent::event_stream_count, "STREAM_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_stream_count, "STREAM_COUNT");
76      LSCPEvent::RegisterEvent(LSCPEvent::event_buffer_fill, "BUFFER_FILL");      LSCPEvent::RegisterEvent(LSCPEvent::event_buffer_fill, "BUFFER_FILL");
77      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_info, "CHANNEL_INFO");      LSCPEvent::RegisterEvent(LSCPEvent::event_channel_info, "CHANNEL_INFO");
78        LSCPEvent::RegisterEvent(LSCPEvent::event_fx_send_count, "FX_SEND_COUNT");
79        LSCPEvent::RegisterEvent(LSCPEvent::event_fx_send_info, "FX_SEND_INFO");
80        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_map_count, "MIDI_INSTRUMENT_MAP_COUNT");
81        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_map_info, "MIDI_INSTRUMENT_MAP_INFO");
82        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_count, "MIDI_INSTRUMENT_COUNT");
83        LSCPEvent::RegisterEvent(LSCPEvent::event_midi_instr_info, "MIDI_INSTRUMENT_INFO");
84      LSCPEvent::RegisterEvent(LSCPEvent::event_misc, "MISCELLANEOUS");      LSCPEvent::RegisterEvent(LSCPEvent::event_misc, "MISCELLANEOUS");
85      LSCPEvent::RegisterEvent(LSCPEvent::event_total_voice_count, "TOTAL_VOICE_COUNT");      LSCPEvent::RegisterEvent(LSCPEvent::event_total_voice_count, "TOTAL_VOICE_COUNT");
86        LSCPEvent::RegisterEvent(LSCPEvent::event_global_info, "GLOBAL_INFO");
87      hSocket = -1;      hSocket = -1;
88  }  }
89    
# Line 80  LSCPServer::~LSCPServer() { Line 91  LSCPServer::~LSCPServer() {
91      if (hSocket >= 0) close(hSocket);      if (hSocket >= 0) close(hSocket);
92  }  }
93    
94    void LSCPServer::EventHandler::ChannelCountChanged(int NewCount) {
95        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_count, NewCount));
96    }
97    
98    void LSCPServer::EventHandler::AudioDeviceCountChanged(int NewCount) {
99        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_audio_device_count, NewCount));
100    }
101    
102    void LSCPServer::EventHandler::MidiDeviceCountChanged(int NewCount) {
103        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_device_count, NewCount));
104    }
105    
106    void LSCPServer::EventHandler::MidiInstrumentCountChanged(int MapId, int NewCount) {
107        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_count, MapId, NewCount));
108    }
109    
110    void LSCPServer::EventHandler::MidiInstrumentInfoChanged(int MapId, int Bank, int Program) {
111        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_info, MapId, Bank, Program));
112    }
113    
114    void LSCPServer::EventHandler::MidiInstrumentMapCountChanged(int NewCount) {
115        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_map_count, NewCount));
116    }
117    
118    void LSCPServer::EventHandler::MidiInstrumentMapInfoChanged(int MapId) {
119        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_instr_map_info, MapId));
120    }
121    
122    void LSCPServer::EventHandler::FxSendCountChanged(int ChannelId, int NewCount) {
123        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_count, ChannelId, NewCount));
124    }
125    
126    void LSCPServer::EventHandler::VoiceCountChanged(int ChannelId, int NewCount) {
127        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_voice_count, ChannelId, NewCount));
128    }
129    
130    void LSCPServer::EventHandler::StreamCountChanged(int ChannelId, int NewCount) {
131        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_stream_count, ChannelId, NewCount));
132    }
133    
134    void LSCPServer::EventHandler::BufferFillChanged(int ChannelId, String FillData) {
135        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_buffer_fill, ChannelId, FillData));
136    }
137    
138    void LSCPServer::EventHandler::TotalVoiceCountChanged(int NewCount) {
139        LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_total_voice_count, NewCount));
140    }
141    
142    
143  /**  /**
144   * Blocks the calling thread until the LSCP Server is initialized and   * Blocks the calling thread until the LSCP Server is initialized and
145   * accepting socket connections, if the server is already initialized then   * accepting socket connections, if the server is already initialized then
# Line 120  int LSCPServer::Main() { Line 180  int LSCPServer::Main() {
180    
181      listen(hSocket, 1);      listen(hSocket, 1);
182      Initialized.Set(true);      Initialized.Set(true);
183        
184        // Registering event listeners
185        pSampler->AddChannelCountListener(&eventHandler);
186        pSampler->AddAudioDeviceCountListener(&eventHandler);
187        pSampler->AddMidiDeviceCountListener(&eventHandler);
188        pSampler->AddVoiceCountListener(&eventHandler);
189        pSampler->AddStreamCountListener(&eventHandler);
190        pSampler->AddBufferFillListener(&eventHandler);
191        pSampler->AddTotalVoiceCountListener(&eventHandler);
192        pSampler->AddFxSendCountListener(&eventHandler);
193        MidiInstrumentMapper::AddMidiInstrumentCountListener(&eventHandler);
194        MidiInstrumentMapper::AddMidiInstrumentInfoListener(&eventHandler);
195        MidiInstrumentMapper::AddMidiInstrumentMapCountListener(&eventHandler);
196        MidiInstrumentMapper::AddMidiInstrumentMapInfoListener(&eventHandler);
197    
198      // now wait for client connections and handle their requests      // now wait for client connections and handle their requests
199      sockaddr_in client;      sockaddr_in client;
# Line 140  int LSCPServer::Main() { Line 214  int LSCPServer::Main() {
214                  if ((*itEngineChannel)->StatusChanged()) {                  if ((*itEngineChannel)->StatusChanged()) {
215                      SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_info, (*itEngineChannel)->iSamplerChannelIndex));                      SendLSCPNotify(LSCPEvent(LSCPEvent::event_channel_info, (*itEngineChannel)->iSamplerChannelIndex));
216                  }                  }
217    
218                    for (int i = 0; i < (*itEngineChannel)->GetFxSendCount(); i++) {
219                        FxSend* fxs = (*itEngineChannel)->GetFxSend(i);
220                        if(fxs != NULL && fxs->IsInfoChanged()) {
221                            int chn = (*itEngineChannel)->iSamplerChannelIndex;
222                            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, chn, fxs->Id()));
223                            fxs->SetInfoChanged(false);
224                        }
225                    }
226              }              }
227          }          }
228    
# Line 322  bool LSCPServer::GetLSCPCommand( std::ve Line 405  bool LSCPServer::GetLSCPCommand( std::ve
405                                  continue; //Ignore CR                                  continue; //Ignore CR
406                          if (c == '\n') {                          if (c == '\n') {
407                                  LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_misc, "Received \'" + bufferedCommands[socket] + "\' on socket", socket));                                  LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_misc, "Received \'" + bufferedCommands[socket] + "\' on socket", socket));
408                                  bufferedCommands[socket] += "\n";                                  bufferedCommands[socket] += "\r\n";
409                                  return true; //Complete command was read                                  return true; //Complete command was read
410                          }                          }
411                          bufferedCommands[socket] += c;                          bufferedCommands[socket] += c;
# Line 482  String LSCPServer::DestroyMidiInputDevic Line 565  String LSCPServer::DestroyMidiInputDevic
565      return result.Produce();      return result.Produce();
566  }  }
567    
568    EngineChannel* LSCPServer::GetEngineChannel(uint uiSamplerChannel) {
569        SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
570        if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
571    
572        EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
573        if (!pEngineChannel) throw Exception("There is no engine deployed on this sampler channel yet");
574    
575        return pEngineChannel;        
576    }
577    
578  /**  /**
579   * Will be called by the parser to load an instrument.   * Will be called by the parser to load an instrument.
580   */   */
# Line 496  String LSCPServer::LoadInstrument(String Line 589  String LSCPServer::LoadInstrument(String
589          if (!pSamplerChannel->GetAudioOutputDevice())          if (!pSamplerChannel->GetAudioOutputDevice())
590              throw Exception("No audio output device connected to sampler channel");              throw Exception("No audio output device connected to sampler channel");
591          if (bBackground) {          if (bBackground) {
592              InstrumentLoader.StartNewLoad(Filename, uiInstrument, pEngineChannel);              InstrumentManager::instrument_id_t id;
593                id.FileName = Filename;
594                id.Index    = uiInstrument;
595                InstrumentManager::LoadInstrumentInBackground(id, pEngineChannel);
596          }          }
597          else {          else {
598              // tell the engine channel which instrument to load              // tell the engine channel which instrument to load
# Line 659  String LSCPServer::GetChannelInfo(uint u Line 755  String LSCPServer::GetChannelInfo(uint u
755          String AudioRouting;          String AudioRouting;
756          int Mute = 0;          int Mute = 0;
757          bool Solo = false;          bool Solo = false;
758            String MidiInstrumentMap = "NONE";
759    
760          if (pEngineChannel) {          if (pEngineChannel) {
761              EngineName          = pEngineChannel->EngineName();              EngineName          = pEngineChannel->EngineName();
# Line 676  String LSCPServer::GetChannelInfo(uint u Line 773  String LSCPServer::GetChannelInfo(uint u
773              }              }
774              Mute = pEngineChannel->GetMute();              Mute = pEngineChannel->GetMute();
775              Solo = pEngineChannel->GetSolo();              Solo = pEngineChannel->GetSolo();
776                if (pEngineChannel->UsesNoMidiInstrumentMap())
777                    MidiInstrumentMap = "NONE";
778                else if (pEngineChannel->UsesDefaultMidiInstrumentMap())
779                    MidiInstrumentMap = "DEFAULT";
780                else
781                    MidiInstrumentMap = ToString(pEngineChannel->GetMidiInstrumentMap());
782          }          }
783    
784          result.Add("ENGINE_NAME", EngineName);          result.Add("ENGINE_NAME", EngineName);
# Line 697  String LSCPServer::GetChannelInfo(uint u Line 800  String LSCPServer::GetChannelInfo(uint u
800          result.Add("INSTRUMENT_STATUS", InstrumentStatus);          result.Add("INSTRUMENT_STATUS", InstrumentStatus);
801          result.Add("MUTE", Mute == -1 ? "MUTED_BY_SOLO" : (Mute ? "true" : "false"));          result.Add("MUTE", Mute == -1 ? "MUTED_BY_SOLO" : (Mute ? "true" : "false"));
802          result.Add("SOLO", Solo);          result.Add("SOLO", Solo);
803            result.Add("MIDI_INSTRUMENT_MAP", MidiInstrumentMap);
804      }      }
805      catch (Exception e) {      catch (Exception e) {
806           result.Error(e);           result.Error(e);
# Line 1174  String LSCPServer::SetAudioOutputChannel Line 1278  String LSCPServer::SetAudioOutputChannel
1278    
1279          // set new channel parameter value          // set new channel parameter value
1280          pParameter->SetValue(ParamVal);          pParameter->SetValue(ParamVal);
1281            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_audio_device_info, DeviceId));
1282      }      }
1283      catch (Exception e) {      catch (Exception e) {
1284          result.Error(e);          result.Error(e);
# Line 1191  String LSCPServer::SetAudioOutputDeviceP Line 1296  String LSCPServer::SetAudioOutputDeviceP
1296          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
1297          if (!parameters.count(ParamKey)) throw Exception("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 + "'");
1298          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1299            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_audio_device_info, DeviceIndex));
1300      }      }
1301      catch (Exception e) {      catch (Exception e) {
1302          result.Error(e);          result.Error(e);
# Line 1208  String LSCPServer::SetMidiInputDevicePar Line 1314  String LSCPServer::SetMidiInputDevicePar
1314          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();          std::map<String,DeviceCreationParameter*> parameters = pDevice->DeviceParameters();
1315          if (!parameters.count(ParamKey)) throw Exception("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 + "'");
1316          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1317            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_device_info, DeviceIndex));
1318      }      }
1319      catch (Exception e) {      catch (Exception e) {
1320          result.Error(e);          result.Error(e);
# Line 1232  String LSCPServer::SetMidiInputPortParam Line 1339  String LSCPServer::SetMidiInputPortParam
1339          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();          std::map<String,DeviceRuntimeParameter*> parameters = pMidiInputPort->PortParameters();
1340          if (!parameters.count(ParamKey)) throw Exception("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 + "'");
1341          parameters[ParamKey]->SetValue(ParamVal);          parameters[ParamKey]->SetValue(ParamVal);
1342            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_midi_device_info, DeviceIndex));
1343      }      }
1344      catch (Exception e) {      catch (Exception e) {
1345          result.Error(e);          result.Error(e);
# Line 1479  String LSCPServer::SetChannelSolo(bool b Line 1587  String LSCPServer::SetChannelSolo(bool b
1587    
1588          bool oldSolo = pEngineChannel->GetSolo();          bool oldSolo = pEngineChannel->GetSolo();
1589          bool hadSoloChannel = HasSoloChannel();          bool hadSoloChannel = HasSoloChannel();
1590            
1591          pEngineChannel->SetSolo(bSolo);          pEngineChannel->SetSolo(bSolo);
1592            
1593          if(!oldSolo && bSolo) {          if(!oldSolo && bSolo) {
1594              if(pEngineChannel->GetMute() == -1) pEngineChannel->SetMute(0);              if(pEngineChannel->GetMute() == -1) pEngineChannel->SetMute(0);
1595              if(!hadSoloChannel) MuteNonSoloChannels();              if(!hadSoloChannel) MuteNonSoloChannels();
1596          }          }
1597            
1598          if(oldSolo && !bSolo) {          if(oldSolo && !bSolo) {
1599              if(!HasSoloChannel()) UnmuteChannels();              if(!HasSoloChannel()) UnmuteChannels();
1600              else if(!pEngineChannel->GetMute()) pEngineChannel->SetMute(-1);              else if(!pEngineChannel->GetMute()) pEngineChannel->SetMute(-1);
# Line 1544  void  LSCPServer::UnmuteChannels() { Line 1652  void  LSCPServer::UnmuteChannels() {
1652      }      }
1653  }  }
1654    
1655    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) {
1656        dmsg(2,("LSCPServer: AddOrReplaceMIDIInstrumentMapping()\n"));
1657    
1658        midi_prog_index_t idx;
1659        idx.midi_bank_msb = (MidiBank >> 7) & 0x7f;
1660        idx.midi_bank_lsb = MidiBank & 0x7f;
1661        idx.midi_prog     = MidiProg;
1662    
1663        MidiInstrumentMapper::entry_t entry;
1664        entry.EngineName      = EngineType;
1665        entry.InstrumentFile  = InstrumentFile;
1666        entry.InstrumentIndex = InstrumentIndex;
1667        entry.LoadMode        = LoadMode;
1668        entry.Volume          = Volume;
1669        entry.Name            = Name;
1670    
1671        LSCPResultSet result;
1672        try {
1673            // PERSISTENT mapping commands might block for a long time, so in
1674            // that case we add/replace the mapping in another thread in case
1675            // the NON_MODAL argument was supplied, non persistent mappings
1676            // should return immediately, so we don't need to do that for them
1677            bool bInBackground = (entry.LoadMode == MidiInstrumentMapper::PERSISTENT && !bModal);
1678            MidiInstrumentMapper::AddOrReplaceEntry(MidiMapID, idx, entry, bInBackground);
1679        } catch (Exception e) {
1680            result.Error(e);
1681        }
1682        return result.Produce();
1683    }
1684    
1685    String LSCPServer::RemoveMIDIInstrumentMapping(uint MidiMapID, uint MidiBank, uint MidiProg) {
1686        dmsg(2,("LSCPServer: RemoveMIDIInstrumentMapping()\n"));
1687    
1688        midi_prog_index_t idx;
1689        idx.midi_bank_msb = (MidiBank >> 7) & 0x7f;
1690        idx.midi_bank_lsb = MidiBank & 0x7f;
1691        idx.midi_prog     = MidiProg;
1692    
1693        LSCPResultSet result;
1694        try {
1695            MidiInstrumentMapper::RemoveEntry(MidiMapID, idx);
1696        } catch (Exception e) {
1697            result.Error(e);
1698        }
1699        return result.Produce();
1700    }
1701    
1702    String LSCPServer::GetMidiInstrumentMappings(uint MidiMapID) {
1703        dmsg(2,("LSCPServer: GetMidiInstrumentMappings()\n"));
1704        LSCPResultSet result;
1705        try {
1706            result.Add(MidiInstrumentMapper::Entries(MidiMapID).size());
1707        } catch (Exception e) {
1708            result.Error(e);
1709        }
1710        return result.Produce();
1711    }
1712    
1713    
1714    String LSCPServer::GetAllMidiInstrumentMappings() {
1715        dmsg(2,("LSCPServer: GetAllMidiInstrumentMappings()\n"));
1716        LSCPResultSet result;
1717        std::vector<int> maps = MidiInstrumentMapper::Maps();
1718        int totalMappings = 0;
1719        for (int i = 0; i < maps.size(); i++) {
1720            try {
1721                totalMappings += MidiInstrumentMapper::Entries(maps[i]).size();
1722            } catch (Exception e) { /*NOOP*/ }
1723        }
1724        result.Add(totalMappings);
1725        return result.Produce();
1726    }
1727    
1728    String LSCPServer::GetMidiInstrumentMapping(uint MidiMapID, uint MidiBank, uint MidiProg) {
1729        dmsg(2,("LSCPServer: GetMidiIstrumentMapping()\n"));
1730        LSCPResultSet result;
1731        try {
1732            midi_prog_index_t idx;
1733            idx.midi_bank_msb = (MidiBank >> 7) & 0x7f;
1734            idx.midi_bank_lsb = MidiBank & 0x7f;
1735            idx.midi_prog     = MidiProg;
1736    
1737            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t> mappings = MidiInstrumentMapper::Entries(MidiMapID);
1738            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t>::iterator iter = mappings.find(idx);
1739            if (iter == mappings.end()) result.Error("there is no map entry with that index");
1740            else { // found
1741                result.Add("NAME", iter->second.Name);
1742                result.Add("ENGINE_NAME", iter->second.EngineName);
1743                result.Add("INSTRUMENT_FILE", iter->second.InstrumentFile);
1744                result.Add("INSTRUMENT_NR", (int) iter->second.InstrumentIndex);
1745                String instrumentName;
1746                Engine* pEngine = EngineFactory::Create(iter->second.EngineName);
1747                if (pEngine) {
1748                    if (pEngine->GetInstrumentManager()) {
1749                        InstrumentManager::instrument_id_t instrID;
1750                        instrID.FileName = iter->second.InstrumentFile;
1751                        instrID.Index    = iter->second.InstrumentIndex;
1752                        instrumentName = pEngine->GetInstrumentManager()->GetInstrumentName(instrID);
1753                    }
1754                    EngineFactory::Destroy(pEngine);
1755                }
1756                result.Add("INSTRUMENT_NAME", instrumentName);
1757                switch (iter->second.LoadMode) {
1758                    case MidiInstrumentMapper::ON_DEMAND:
1759                        result.Add("LOAD_MODE", "ON_DEMAND");
1760                        break;
1761                    case MidiInstrumentMapper::ON_DEMAND_HOLD:
1762                        result.Add("LOAD_MODE", "ON_DEMAND_HOLD");
1763                        break;
1764                    case MidiInstrumentMapper::PERSISTENT:
1765                        result.Add("LOAD_MODE", "PERSISTENT");
1766                        break;
1767                    default:
1768                        throw Exception("entry reflects invalid LOAD_MODE, consider this as a bug!");
1769                }
1770                result.Add("VOLUME", iter->second.Volume);
1771            }
1772        } catch (Exception e) {
1773            result.Error(e);
1774        }
1775        return result.Produce();
1776    }
1777    
1778    String LSCPServer::ListMidiInstrumentMappings(uint MidiMapID) {
1779        dmsg(2,("LSCPServer: ListMidiInstrumentMappings()\n"));
1780        LSCPResultSet result;
1781        try {
1782            String s;
1783            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t> mappings = MidiInstrumentMapper::Entries(MidiMapID);
1784            std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t>::iterator iter = mappings.begin();
1785            for (; iter != mappings.end(); iter++) {
1786                if (s.size()) s += ",";
1787                s += "{" + ToString(MidiMapID) + ","
1788                         + ToString((int(iter->first.midi_bank_msb) << 7) | int(iter->first.midi_bank_lsb)) + ","
1789                         + ToString(int(iter->first.midi_prog)) + "}";
1790            }
1791            result.Add(s);
1792        } catch (Exception e) {
1793            result.Error(e);
1794        }
1795        return result.Produce();
1796    }
1797    
1798    String LSCPServer::ListAllMidiInstrumentMappings() {
1799        dmsg(2,("LSCPServer: ListAllMidiInstrumentMappings()\n"));
1800        LSCPResultSet result;
1801        try {
1802            std::vector<int> maps = MidiInstrumentMapper::Maps();
1803            String s;
1804            for (int i = 0; i < maps.size(); i++) {
1805                std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t> mappings = MidiInstrumentMapper::Entries(maps[i]);
1806                std::map<midi_prog_index_t,MidiInstrumentMapper::entry_t>::iterator iter = mappings.begin();
1807                for (; iter != mappings.end(); iter++) {
1808                    if (s.size()) s += ",";
1809                    s += "{" + ToString(maps[i]) + ","
1810                             + ToString((int(iter->first.midi_bank_msb) << 7) | int(iter->first.midi_bank_lsb)) + ","
1811                             + ToString(int(iter->first.midi_prog)) + "}";
1812                }
1813            }
1814            result.Add(s);
1815        } catch (Exception e) {
1816            result.Error(e);
1817        }
1818        return result.Produce();
1819    }
1820    
1821    String LSCPServer::ClearMidiInstrumentMappings(uint MidiMapID) {
1822        dmsg(2,("LSCPServer: ClearMidiInstrumentMappings()\n"));
1823        LSCPResultSet result;
1824        try {
1825            MidiInstrumentMapper::RemoveAllEntries(MidiMapID);
1826        } catch (Exception e) {
1827            result.Error(e);
1828        }
1829        return result.Produce();
1830    }
1831    
1832    String LSCPServer::ClearAllMidiInstrumentMappings() {
1833        dmsg(2,("LSCPServer: ClearAllMidiInstrumentMappings()\n"));
1834        LSCPResultSet result;
1835        try {
1836            std::vector<int> maps = MidiInstrumentMapper::Maps();
1837            for (int i = 0; i < maps.size(); i++)
1838                MidiInstrumentMapper::RemoveAllEntries(maps[i]);
1839        } catch (Exception e) {
1840            result.Error(e);
1841        }
1842        return result.Produce();
1843    }
1844    
1845    String LSCPServer::AddMidiInstrumentMap(String MapName) {
1846        dmsg(2,("LSCPServer: AddMidiInstrumentMap()\n"));
1847        LSCPResultSet result;
1848        try {
1849            int MapID = MidiInstrumentMapper::AddMap(MapName);
1850            result = LSCPResultSet(MapID);
1851        } catch (Exception e) {
1852            result.Error(e);
1853        }
1854        return result.Produce();
1855    }
1856    
1857    String LSCPServer::RemoveMidiInstrumentMap(uint MidiMapID) {
1858        dmsg(2,("LSCPServer: RemoveMidiInstrumentMap()\n"));
1859        LSCPResultSet result;
1860        try {
1861            MidiInstrumentMapper::RemoveMap(MidiMapID);
1862        } catch (Exception e) {
1863            result.Error(e);
1864        }
1865        return result.Produce();
1866    }
1867    
1868    String LSCPServer::RemoveAllMidiInstrumentMaps() {
1869        dmsg(2,("LSCPServer: RemoveAllMidiInstrumentMaps()\n"));
1870        LSCPResultSet result;
1871        try {
1872            MidiInstrumentMapper::RemoveAllMaps();
1873        } catch (Exception e) {
1874            result.Error(e);
1875        }
1876        return result.Produce();
1877    }
1878    
1879    String LSCPServer::GetMidiInstrumentMaps() {
1880        dmsg(2,("LSCPServer: GetMidiInstrumentMaps()\n"));
1881        LSCPResultSet result;
1882        try {
1883            result.Add(MidiInstrumentMapper::Maps().size());
1884        } catch (Exception e) {
1885            result.Error(e);
1886        }
1887        return result.Produce();
1888    }
1889    
1890    String LSCPServer::ListMidiInstrumentMaps() {
1891        dmsg(2,("LSCPServer: ListMidiInstrumentMaps()\n"));
1892        LSCPResultSet result;
1893        try {
1894            std::vector<int> maps = MidiInstrumentMapper::Maps();
1895            String sList;
1896            for (int i = 0; i < maps.size(); i++) {
1897                if (sList != "") sList += ",";
1898                sList += ToString(maps[i]);
1899            }
1900            result.Add(sList);
1901        } catch (Exception e) {
1902            result.Error(e);
1903        }
1904        return result.Produce();
1905    }
1906    
1907    String LSCPServer::GetMidiInstrumentMap(uint MidiMapID) {
1908        dmsg(2,("LSCPServer: GetMidiInstrumentMap()\n"));
1909        LSCPResultSet result;
1910        try {
1911            result.Add("NAME", MidiInstrumentMapper::MapName(MidiMapID));
1912            result.Add("DEFAULT", MidiInstrumentMapper::GetDefaultMap() == MidiMapID);
1913        } catch (Exception e) {
1914            result.Error(e);
1915        }
1916        return result.Produce();
1917    }
1918    
1919    String LSCPServer::SetMidiInstrumentMapName(uint MidiMapID, String NewName) {
1920        dmsg(2,("LSCPServer: SetMidiInstrumentMapName()\n"));
1921        LSCPResultSet result;
1922        try {
1923            MidiInstrumentMapper::RenameMap(MidiMapID, NewName);
1924        } catch (Exception e) {
1925            result.Error(e);
1926        }
1927        return result.Produce();
1928    }
1929    
1930    /**
1931     * Set the MIDI instrument map the given sampler channel shall use for
1932     * handling MIDI program change messages. There are the following two
1933     * special (negative) values:
1934     *
1935     *    - (-1) :  set to NONE (ignore program changes)
1936     *    - (-2) :  set to DEFAULT map
1937     */
1938    String LSCPServer::SetChannelMap(uint uiSamplerChannel, int MidiMapID) {
1939        dmsg(2,("LSCPServer: SetChannelMap()\n"));
1940        LSCPResultSet result;
1941        try {
1942            SamplerChannel* pSamplerChannel = pSampler->GetSamplerChannel(uiSamplerChannel);
1943            if (!pSamplerChannel) throw Exception("Invalid sampler channel number " + ToString(uiSamplerChannel));
1944    
1945            EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
1946            if (!pEngineChannel) throw Exception("There is no engine deployed on this sampler channel yet");
1947    
1948            if      (MidiMapID == -1) pEngineChannel->SetMidiInstrumentMapToNone();
1949            else if (MidiMapID == -2) pEngineChannel->SetMidiInstrumentMapToDefault();
1950            else                      pEngineChannel->SetMidiInstrumentMap(MidiMapID);
1951        } catch (Exception e) {
1952            result.Error(e);
1953        }
1954        return result.Produce();
1955    }
1956    
1957    String LSCPServer::CreateFxSend(uint uiSamplerChannel, uint MidiCtrl, String Name) {
1958        dmsg(2,("LSCPServer: CreateFxSend()\n"));
1959        LSCPResultSet result;
1960        try {
1961            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
1962            
1963            FxSend* pFxSend = pEngineChannel->AddFxSend(MidiCtrl, Name);
1964            if (!pFxSend) throw Exception("Could not add FxSend, don't ask, I don't know why (probably a bug)");
1965    
1966            result = LSCPResultSet(pFxSend->Id()); // success
1967        } catch (Exception e) {
1968            result.Error(e);
1969        }
1970        return result.Produce();
1971    }
1972    
1973    String LSCPServer::DestroyFxSend(uint uiSamplerChannel, uint FxSendID) {
1974        dmsg(2,("LSCPServer: DestroyFxSend()\n"));
1975        LSCPResultSet result;
1976        try {
1977            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
1978    
1979            FxSend* pFxSend = NULL;
1980            for (int i = 0; i < pEngineChannel->GetFxSendCount(); i++) {
1981                if (pEngineChannel->GetFxSend(i)->Id() == FxSendID) {
1982                    pFxSend = pEngineChannel->GetFxSend(i);
1983                    break;
1984                }
1985            }
1986            if (!pFxSend) throw Exception("There is no FxSend with that ID on the given sampler channel");
1987            pEngineChannel->RemoveFxSend(pFxSend);
1988        } catch (Exception e) {
1989            result.Error(e);
1990        }
1991        return result.Produce();
1992    }
1993    
1994    String LSCPServer::GetFxSends(uint uiSamplerChannel) {
1995        dmsg(2,("LSCPServer: GetFxSends()\n"));
1996        LSCPResultSet result;
1997        try {
1998            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
1999    
2000            result.Add(pEngineChannel->GetFxSendCount());
2001        } catch (Exception e) {
2002            result.Error(e);
2003        }
2004        return result.Produce();
2005    }
2006    
2007    String LSCPServer::ListFxSends(uint uiSamplerChannel) {
2008        dmsg(2,("LSCPServer: ListFxSends()\n"));
2009        LSCPResultSet result;
2010        String list;
2011        try {
2012            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2013    
2014            for (int i = 0; i < pEngineChannel->GetFxSendCount(); i++) {
2015                FxSend* pFxSend = pEngineChannel->GetFxSend(i);
2016                if (list != "") list += ",";
2017                list += ToString(pFxSend->Id());
2018            }
2019            result.Add(list);
2020        } catch (Exception e) {
2021            result.Error(e);
2022        }
2023        return result.Produce();
2024    }
2025    
2026    FxSend* LSCPServer::GetFxSend(uint uiSamplerChannel, uint FxSendID) {
2027        EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2028    
2029        FxSend* pFxSend = NULL;
2030        for (int i = 0; i < pEngineChannel->GetFxSendCount(); i++) {
2031            if (pEngineChannel->GetFxSend(i)->Id() == FxSendID) {
2032                pFxSend = pEngineChannel->GetFxSend(i);
2033                break;
2034            }
2035        }
2036        if (!pFxSend) throw Exception("There is no FxSend with that ID on the given sampler channel");
2037        return pFxSend;
2038    }
2039    
2040    String LSCPServer::GetFxSendInfo(uint uiSamplerChannel, uint FxSendID) {
2041        dmsg(2,("LSCPServer: GetFxSendInfo()\n"));
2042        LSCPResultSet result;
2043        try {
2044            EngineChannel* pEngineChannel = GetEngineChannel(uiSamplerChannel);
2045            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2046            
2047            // gather audio routing informations
2048            String AudioRouting;
2049            for (int chan = 0; chan < pEngineChannel->Channels(); chan++) {
2050                if (AudioRouting != "") AudioRouting += ",";
2051                AudioRouting += ToString(pFxSend->DestinationChannel(chan));
2052            }
2053    
2054            // success
2055            result.Add("NAME", pFxSend->Name());
2056            result.Add("MIDI_CONTROLLER", pFxSend->MidiController());
2057            result.Add("LEVEL", ToString(pFxSend->Level()));
2058            result.Add("AUDIO_OUTPUT_ROUTING", AudioRouting);
2059        } catch (Exception e) {
2060            result.Error(e);
2061        }
2062        return result.Produce();
2063    }
2064    
2065    String LSCPServer::SetFxSendName(uint uiSamplerChannel, uint FxSendID, String Name) {
2066        dmsg(2,("LSCPServer: SetFxSendName()\n"));
2067        LSCPResultSet result;
2068        try {
2069            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2070    
2071            pFxSend->SetName(Name);
2072            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2073        } catch (Exception e) {
2074            result.Error(e);
2075        }
2076        return result.Produce();
2077    }
2078    
2079    String LSCPServer::SetFxSendAudioOutputChannel(uint uiSamplerChannel, uint FxSendID, uint FxSendChannel, uint DeviceChannel) {
2080        dmsg(2,("LSCPServer: SetFxSendAudioOutputChannel()\n"));
2081        LSCPResultSet result;
2082        try {
2083            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2084    
2085            pFxSend->SetDestinationChannel(FxSendChannel, DeviceChannel);
2086            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2087        } catch (Exception e) {
2088            result.Error(e);
2089        }
2090        return result.Produce();
2091    }
2092    
2093    String LSCPServer::SetFxSendMidiController(uint uiSamplerChannel, uint FxSendID, uint MidiController) {
2094        dmsg(2,("LSCPServer: SetFxSendMidiController()\n"));
2095        LSCPResultSet result;
2096        try {
2097            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2098    
2099            pFxSend->SetMidiController(MidiController);
2100            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2101        } catch (Exception e) {
2102            result.Error(e);
2103        }
2104        return result.Produce();
2105    }
2106    
2107    String LSCPServer::SetFxSendLevel(uint uiSamplerChannel, uint FxSendID, double dLevel) {
2108        dmsg(2,("LSCPServer: SetFxSendLevel()\n"));
2109        LSCPResultSet result;
2110        try {
2111            FxSend* pFxSend = GetFxSend(uiSamplerChannel, FxSendID);
2112    
2113            pFxSend->SetLevel((float)dLevel);
2114            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_fx_send_info, uiSamplerChannel, FxSendID));
2115        } catch (Exception e) {
2116            result.Error(e);
2117        }
2118        return result.Produce();
2119    }
2120    
2121  /**  /**
2122   * Will be called by the parser to reset a particular sampler channel.   * Will be called by the parser to reset a particular sampler channel.
2123   */   */
# Line 1582  String LSCPServer::GetServerInfo() { Line 2156  String LSCPServer::GetServerInfo() {
2156      LSCPResultSet result;      LSCPResultSet result;
2157      result.Add("DESCRIPTION", "LinuxSampler - modular, streaming capable sampler");      result.Add("DESCRIPTION", "LinuxSampler - modular, streaming capable sampler");
2158      result.Add("VERSION", VERSION);      result.Add("VERSION", VERSION);
2159      result.Add("PROTOCOL_VERSION", "1.0");      result.Add("PROTOCOL_VERSION", ToString(LSCP_RELEASE_MAJOR) + "." + ToString(LSCP_RELEASE_MINOR));
2160      return result.Produce();      return result.Produce();
2161  }  }
2162    
# Line 1606  String LSCPServer::GetTotalVoiceCountMax Line 2180  String LSCPServer::GetTotalVoiceCountMax
2180      return result.Produce();      return result.Produce();
2181  }  }
2182    
2183    String LSCPServer::GetGlobalVolume() {
2184        LSCPResultSet result;
2185        result.Add(ToString(GLOBAL_VOLUME)); // see common/global.cpp
2186        return result.Produce();
2187    }
2188    
2189    String LSCPServer::SetGlobalVolume(double dVolume) {
2190        LSCPResultSet result;
2191        try {
2192            if (dVolume < 0) throw Exception("Volume may not be negative");
2193            GLOBAL_VOLUME = dVolume; // see common/global.cpp
2194            LSCPServer::SendLSCPNotify(LSCPEvent(LSCPEvent::event_global_info, "VOLUME", GLOBAL_VOLUME));
2195        } catch (Exception e) {
2196            result.Error(e);
2197        }
2198        return result.Produce();
2199    }
2200    
2201  /**  /**
2202   * 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
2203   * server for receiving event messages.   * server for receiving event messages.
Legend:
Removed from v.905  
changed lines
  Added in v.1135
  ViewVC Help
Powered by ViewVC