/[svn]/jlscp/trunk/src/org/linuxsampler/lscp/Client.java

Diff of /jlscp/trunk/src/org/linuxsampler/lscp/Client.java

Parent Directory | Revision Log | View Patch Patch

-revision 1202 by iliev,
Thu May 24 20:17:25 2007 UTC
+revision 1781 by iliev,
Mon Sep 29 18:21:21 2008 UTC
 Line 1
  /*
   *   jlscp - a java LinuxSampler control protocol API
   *
-  *   Copyright (C) 2005-2007 Grigor Iliev <grigor@grigoriliev.com>
+  *   Copyright (C) 2005-2008 Grigor Iliev <grigor@grigoriliev.com>
   *
   *   This file is part of jlscp.
   *
 Line 34 
 import java.util.Vector;
  import java.util.logging.Level;
  import java.util.logging.Logger;
- import static org.linuxsampler.lscp.Parser.*;
  import org.linuxsampler.lscp.event.*;
+ import static org.linuxsampler.lscp.Parser.*;
  /**
   * This class is the abstraction representing a client endpoint for communication with LinuxSampler
-  * instance. Since it implements all commands specified in the LSCP protocol v1.1, for more
+  * instance. Since it implements all commands specified in the LSCP protocol v1.3, for more
   * information look at the
-  * <a href=http://www.linuxsampler.org/api/lscp-1.1.html>LSCP</a> specification.
+  * <a href=http://www.linuxsampler.org/api/lscp-1.3.html>LSCP</a> specification.
   *
   * <p> The following code establishes connection to LinuxSampler instance and gets the
   * LinuxSampler version:
-Line 163 
 public class Client {
+Line 164 
 public class Client {
                  if(printOnlyMode) setPrintOnlyMode(true);
          }
+         private boolean extendedCharacterEscaping = true;
+         /**
+          * Sets whether strings sent to LinuxSampler should be more aggressively escaped.
+          */
+         public synchronized void
+         setExtendedCharacterEscaping(boolean b) { extendedCharacterEscaping = b; }
+         /**
+          * Determines whether strings sent to LinuxSampler should be more aggressively escaped.
+          */
+         public synchronized boolean
+         getExtendedCharacterEscaping() { return extendedCharacterEscaping; }
+         /**
+          * @see java.net.Socket#setSoTimeout
+          */
+         public synchronized void
+         setSoTimeout(int timeout) {
+                 soTimeout = timeout;
+                 try { if(sock != null) sock.setSoTimeout(timeout); }
+                 catch(Exception x) { this.getLogger().log(Level.INFO, "Unable to set timeout", x); }
+         }
+         private String
+         toEscapedText(String s) {
+                 s = toEscapedString(s);
+                 return conv(s);
+         }
+         private String
+         toEscapedFsEntry(String s) {
+                 s = toEscapedFileName(s);
+                 return conv(s);
+         }
+         /**
+          * Applies an extended character escaping to the specified string if needed.
+          */
+         private String
+         conv(String s) {
+                 return getExtendedCharacterEscaping() ? toExtendedEscapeSequence(s) : s;
+         }
          /**
           * Determines whether the client is in print-only mode.
           * Print-only mode means that the client will just print all
-Line 343 
 public class Client {
+Line 389 
 public class Client {
                  if(!llFSI.isEmpty()) subscribe("FX_SEND_INFO");
                  if(!llSC.isEmpty()) subscribe("STREAM_COUNT");
                  if(!llVC.isEmpty()) subscribe("VOICE_COUNT");
+                 if(!llTSC.isEmpty()) subscribe("TOTAL_STREAM_COUNT");
                  if(!llTVC.isEmpty()) subscribe("TOTAL_VOICE_COUNT");
                  if(!llMIMC.isEmpty()) subscribe("MIDI_INSTRUMENT_MAP_COUNT");
                  if(!llMIMI.isEmpty()) subscribe("MIDI_INSTRUMENT_MAP_INFO");
                  if(!llMIC.isEmpty()) subscribe("MIDI_INSTRUMENT_COUNT");
                  if(!llMII.isEmpty()) subscribe("MIDI_INSTRUMENT_INFO");
+                 if(!llDMD.isEmpty()) subscribe("DEVICE_MIDI");
+                 if(!llCMD.isEmpty()) subscribe("CHANNEL_MIDI");
                  if(!llID.isEmpty()) {
                          subscribe("DB_INSTRUMENT_DIRECTORY_COUNT");
                          subscribe("DB_INSTRUMENT_DIRECTORY_INFO");
                          subscribe("DB_INSTRUMENT_COUNT");
                          subscribe("DB_INSTRUMENT_INFO");
+                         subscribe("DB_INSTRUMENTS_JOB_INFO");
                  }
                  if(!llGI.isEmpty()) subscribe("GLOBAL_INFO");
          }
-Line 484 
 public class Client {
+Line 534 
 public class Client {
          private final Vector<ItemInfoListener> llMIDI = new Vector<ItemInfoListener>();
          private final Vector<StreamCountListener> llSC = new Vector<StreamCountListener>();
          private final Vector<VoiceCountListener> llVC = new Vector<VoiceCountListener>();
+         private final Vector<TotalStreamCountListener> llTSC = new Vector<TotalStreamCountListener>();
          private final Vector<TotalVoiceCountListener> llTVC = new Vector<TotalVoiceCountListener>();
          /** MIDI instrument map count listeners */
-Line 496 
 public class Client {
+Line 547 
 public class Client {
          /** MIDI instrument info listeners */
          private final Vector<MidiInstrumentInfoListener> llMII =
                  new Vector<MidiInstrumentInfoListener>();
+         private final Vector<DeviceMidiDataListener> llDMD = new Vector<DeviceMidiDataListener>();
+         private final Vector<ChannelMidiDataListener> llCMD = new Vector<ChannelMidiDataListener>();
          private final Vector<InstrumentsDbListener> llID = new Vector<InstrumentsDbListener>();
          private final Vector<GlobalInfoListener> llGI = new Vector<GlobalInfoListener>();
-Line 521 
 public class Client {
+Line 574 
 public class Client {
                          !llMIDI.isEmpty() ||
                          !llSC.isEmpty()   ||
                          !llVC.isEmpty()   ||
+                         !llTSC.isEmpty()  ||
                          !llTVC.isEmpty()  ||
                          !llMIMC.isEmpty() ||
                          !llMIMI.isEmpty() ||
                          !llMIC.isEmpty()  ||
                          !llMII.isEmpty()  ||
+                         !llDMD.isEmpty()  ||
+                         !llCMD.isEmpty()  ||
                          !llID.isEmpty()   ||
                          !llGI.isEmpty();
          }
          private synchronized void
+         fireDeviceMidiDataEvent(String s) {
+                 try {
+                         String[] list = parseList(s, ' ');
+                         if(list.length != 5) {
+                                 getLogger().warning("Unknown DEVICE_MIDI format");
+                                 return;
+                         }
+                         int dev = parseInt(list[0]);
+                         int port = parseInt(list[1]);
+                         MidiDataEvent.Type type = parseMidiDataType(list[2]);
+                         if(type == null) return;
+                         int note = parseInt(list[3]);
+                         int velocity = parseInt(list[4]);
+                         DeviceMidiDataEvent e = new DeviceMidiDataEvent(this, type, note, velocity);
+                         e.setDeviceId(dev);
+                         e.setPortId(port);
+                         for(DeviceMidiDataListener l : llDMD) l.midiDataArrived(e);
+                 } catch(LscpException x) {
+                         getLogger().log (
+                                 Level.WARNING, LscpI18n.getLogMsg("CommandFailed!"), x
+                         );
+                 }
+         }
+         private synchronized void
+         fireChannelMidiDataEvent(String s) {
+                 try {
+                         String[] list = parseList(s, ' ');
+                         if(list.length != 4) {
+                                 getLogger().warning("Unknown CHANNEL_MIDI format");
+                                 return;
+                         }
+                         int channel = parseInt(list[0]);
+                         MidiDataEvent.Type type = parseMidiDataType(list[1]);
+                         if(type == null) return;
+                         int note = parseInt(list[2]);
+                         int velocity = parseInt(list[3]);
+                         ChannelMidiDataEvent e = new ChannelMidiDataEvent(this, type, note, velocity);
+                         e.setChannelId(channel);
+                         for(ChannelMidiDataListener l : llCMD) l.midiDataArrived(e);
+                 } catch(LscpException x) {
+                         getLogger().log (
+                                 Level.WARNING, LscpI18n.getLogMsg("CommandFailed!"), x
+                         );
+                 }
+         }
+         private MidiDataEvent.Type
+         parseMidiDataType(String s) {
+                 if("NOTE_ON".equals(s)) return MidiDataEvent.Type.NOTE_ON;
+                 if("NOTE_OFF".equals(s)) return MidiDataEvent.Type.NOTE_OFF;
+                 getLogger().warning("Unknown MIDI data type: " + s);
+                 return null;
+         }
+         private synchronized void
          fireEvent(String s) {
-                  if(s.startsWith("DB_INSTRUMENT_DIRECTORY_COUNT:")) {
+                 // Sort by priority
+                  if(s.startsWith("CHANNEL_MIDI:")) {
+                         s = s.substring("CHANNEL_MIDI:".length());
+                         fireChannelMidiDataEvent(s);
+                 } else if(s.startsWith("DEVICE_MIDI:")) {
+                         s = s.substring("DEVICE_MIDI:".length());
+                         fireDeviceMidiDataEvent(s);
+                 } else if(s.startsWith("DB_INSTRUMENT_DIRECTORY_COUNT:")) {
                          s = s.substring("DB_INSTRUMENT_DIRECTORY_COUNT:".length());
                          InstrumentsDbEvent e = new InstrumentsDbEvent(this, s);
                          for(InstrumentsDbListener l : llID) l.directoryCountChanged(e);
-Line 542 
 public class Client {
+Line 671 
 public class Client {
                          if(s.startsWith("NAME ")) {
                                  String[] list;
                                  try {
-                                         list = parseStringList(s.substring("NAME ".length()), ' ');
+                                         s = s.substring("NAME ".length());
+                                         list = parseEscapedStringList(s, ' ');
                                          if(list.length != 2) throw new LscpException();
+                                         list[1] = toNonEscapedString(list[1]);
                                          e = new InstrumentsDbEvent(this, list[0], list[1]);
                                          for(InstrumentsDbListener l : llID) {
                                                  l.directoryNameChanged(e);
-Line 569 
 public class Client {
+Line 700 
 public class Client {
                          if(s.startsWith("NAME ")) {
                                  String[] list;
                                  try {
-                                         list = parseStringList(s.substring("NAME ".length()), ' ');
+                                         s = s.substring("NAME ".length());
+                                         list = parseEscapedStringList(s, ' ');
                                          if(list.length != 2) throw new LscpException();
+                                         list[1] = toNonEscapedString(list[1]);
                                          e = new InstrumentsDbEvent(this, list[0], list[1]);
                                          for(InstrumentsDbListener l : llID) {
                                                  l.instrumentNameChanged(e);
-Line 657 
 public class Client {
+Line 790 
 public class Client {
                          } catch(NumberFormatException x) {
                                  getLogger().log(Level.WARNING, "Unknown CHANNEL_INFO format", x);
                          }
+                 } else if(s.startsWith("TOTAL_STREAM_COUNT:")) {
+                         try {
+                                 s = s.substring("TOTAL_STREAM_COUNT:".length());
+                                 int i = Integer.parseInt(s);
+                                 TotalStreamCountEvent e = new TotalStreamCountEvent(this, i);
+                                 for(TotalStreamCountListener l : llTSC) l.totalStreamCountChanged(e);
+                         } catch(NumberFormatException x) {
+                                 getLogger().log (
+                                         Level.WARNING, "Unknown TOTAL_STREAM_COUNT format", x
+                                 );
+                         }
                  } else if(s.startsWith("TOTAL_VOICE_COUNT:")) {
                          try {
                                  s = s.substring("TOTAL_VOICE_COUNT:".length());
-Line 1129 
 public class Client {
+Line 1273 
 public class Client {
          /**
           * Registers the specified listener for receiving event messages.
           * Listeners can be registered regardless of the connection state.
+          * @param l The <code>TotalStreamCountListener</code> to register.
+          */
+         public synchronized void
+         addTotalStreamCountListener(TotalStreamCountListener l) {
+                 if(llTSC.isEmpty()) subscribe("TOTAL_STREAM_COUNT");
+                 llTSC.add(l);
+         }
+         /**
+          * Removes the specified listener.
+          * Listeners can be removed regardless of the connection state.
+          * @param l The <code>TotalStreamCountListener</code> to remove.
+          */
+         public synchronized void
+         removeTotalStreamCountListener(TotalStreamCountListener l) {
+                 boolean b = llTSC.remove(l);
+                 if(b && llTSC.isEmpty()) unsubscribe("TOTAL_STREAM_COUNT");
+         }
+         /**
+          * Registers the specified listener for receiving event messages.
+          * Listeners can be registered regardless of the connection state.
           * @param l The <code>TotalVoiceCountListener</code> to register.
           */
          public synchronized void
-Line 1239 
 public class Client {
+Line 1405 
 public class Client {
          /**
           * Registers the specified listener for receiving event messages.
           * Listeners can be registered regardless of the connection state.
+          * @param l The <code>DeviceMidiDataListener</code> to register.
+          */
+         public synchronized void
+         addDeviceMidiDataListener(DeviceMidiDataListener l) {
+                 if(llDMD.isEmpty()) subscribe("DEVICE_MIDI");
+                 llDMD.add(l);
+         }
+         /**
+          * Removes the specified listener.
+          * Listeners can be removed regardless of the connection state.
+          * @param l The <code>DeviceMidiDataListener</code> to remove.
+          */
+         public synchronized void
+         removeDeviceMidiDataListener(DeviceMidiDataListener l) {
+                 boolean b = llDMD.remove(l);
+                 if(b && llDMD.isEmpty()) unsubscribe("DEVICE_MIDI");
+         }
+         /**
+          * Registers the specified listener for receiving event messages.
+          * Listeners can be registered regardless of the connection state.
+          * @param l The <code>ChannelMidiDataListener</code> to register.
+          */
+         public synchronized void
+         addChannelMidiDataListener(ChannelMidiDataListener l) {
+                 if(llCMD.isEmpty()) subscribe("CHANNEL_MIDI");
+                 llCMD.add(l);
+         }
+         /**
+          * Removes the specified listener.
+          * Listeners can be removed regardless of the connection state.
+          * @param l The <code>ChannelMidiDataListener</code> to remove.
+          */
+         public synchronized void
+         removeChannelMidiDataListener(ChannelMidiDataListener l) {
+                 boolean b = llCMD.remove(l);
+                 if(b && llCMD.isEmpty()) unsubscribe("CHANNEL_MIDI");
+         }
+         /**
+          * Registers the specified listener for receiving event messages.
+          * Listeners can be registered regardless of the connection state.
           * @param l The <code>InstrumentsDbListener</code> to register.
           */
          public synchronized void
-Line 1355 
 public class Client {
+Line 1565 
 public class Client {
          /**
           * Gets detailed information about a specific audio output driver.
           * @param driverName The name of the audio output driver.
-          *
+          * @param depList An optional list of dependences parameters.
           * @return An <code>AudioOutputDriver</code> object containing
           * information about the specified audio output driver.
           *
-Line 1365 
 public class Client {
+Line 1575 
 public class Client {
           *
           * @see #getAudioOutputDriverNames
           */
-         private synchronized AudioOutputDriver
+         public synchronized AudioOutputDriver
-         getAudioOutputDriverInfo(String driverName) throws IOException, LscpException, LSException {
+         getAudioOutputDriverInfo(String driverName, Parameter... depList)
+                                         throws IOException, LscpException, LSException {
                  verifyConnection();
                  out.writeLine("GET AUDIO_OUTPUT_DRIVER INFO " + driverName);
                  if(getPrintOnlyMode()) return null;
-Line 1376 
 public class Client {
+Line 1588 
 public class Client {
                  aod.setName(driverName);
                  for(String s : aod.getParameterNames())
-                         aod.addParameter(getAudioOutputDriverParameterInfo(driverName, s));
+                         aod.addParameter(getAudioOutputDriverParameterInfo(driverName, s, depList));
                  return aod;
          }
-Line 1410 
 public class Client {
+Line 1622 
 public class Client {
                  StringBuffer args = new StringBuffer(driver);
                  args.append(' ').append(param);
-                 for(Parameter p : deplist)
+                 for(Parameter p : deplist) {
+                         if(p == null || p.getName() == null || p.getValue() == null) continue;
                          args.append(' ').append(p.getName()).append('=').append(p.getStringValue());
+                 }
                  out.writeLine("GET AUDIO_OUTPUT_DRIVER_PARAMETER INFO " + args.toString());
                  if(getPrintOnlyMode()) return null;
-Line 1472 
 public class Client {
+Line 1686 
 public class Client {
                  verifyConnection();
                  StringBuffer args = new StringBuffer(aoDriver);
-                 for(Parameter p : paramList)
+                 for(Parameter p : paramList) {
+                         if(p == null || p.getName() == null || p.getValue() == null) continue;
                          args.append(' ').append(p.getName()).append('=').append(p.getStringValue());
+                 }
                  out.writeLine("CREATE AUDIO_OUTPUT_DEVICE " + args.toString());
                  if(getPrintOnlyMode()) return -1;
-Line 1934 
 public class Client {
+Line 2150 
 public class Client {
          /**
           * Gets detailed information about a specific MIDI input driver.
           * @param driverName The name of the MIDI input driver.
-          *
+          * @param depList An optional list of dependences parameters.
           * @return A <code>MidiInputDriver</code> object containing
           * information about the specified MIDI input driver.
           *
-Line 1944 
 public class Client {
+Line 2160 
 public class Client {
           *
           * @see #getMidiInputDriverNames
           */
-         private synchronized MidiInputDriver
+         public synchronized MidiInputDriver
-         getMidiInputDriverInfo(String driverName) throws IOException, LscpException, LSException {
+         getMidiInputDriverInfo(String driverName, Parameter... depList)
+                                         throws IOException, LscpException, LSException {
                  verifyConnection();
                  out.writeLine("GET MIDI_INPUT_DRIVER INFO " + driverName);
                  if(getPrintOnlyMode()) return null;
-Line 1956 
 public class Client {
+Line 2174 
 public class Client {
                  mid.setName(driverName);
                  for(String s : mid.getParameterNames())
-                         mid.addParameter(getMidiInputDriverParameterInfo(driverName, s));
+                         mid.addParameter(getMidiInputDriverParameterInfo(driverName, s, depList));
                  return mid;
          }
-Line 1990 
 public class Client {
+Line 2208 
 public class Client {
                  StringBuffer args = new StringBuffer(driver);
                  args.append(' ').append(param);
-                 for(Parameter p : deplist)
+                 for(Parameter p : deplist) {
+                         if(p == null || p.getName() == null || p.getValue() == null) continue;
                          args.append(' ').append(p.getName()).append('=').append(p.getStringValue());
+                 }
                  out.writeLine("GET MIDI_INPUT_DRIVER_PARAMETER INFO " + args.toString());
                  if(getPrintOnlyMode()) return null;
-Line 2053 
 public class Client {
+Line 2273 
 public class Client {
                  verifyConnection();
                  StringBuffer args = new StringBuffer(miDriver);
-                 for(Parameter p : paramList)
+                 for(Parameter p : paramList) {
+                         if(p == null || p.getName() == null || p.getValue() == null) continue;
                          args.append(' ').append(p.getName()).append('=').append(p.getStringValue());
+                 }
                  out.writeLine("CREATE MIDI_INPUT_DEVICE " + args.toString());
                  if(getPrintOnlyMode()) return -1;
-Line 2199 
 public class Client {
+Line 2421 
 public class Client {
                                  mid.setActive(Boolean.parseBoolean(s));
                          } else if(s.startsWith("PORTS: ")) {
                                  s = s.substring("PORTS: ".length());
-                                 int ports = Parser.parseInt(s);
-                                 MidiPort[] midiPorts = new MidiPort[ports > 0 ? ports : 0];
+                                 Parameter<Integer> ports = (Parameter<Integer>)
+                                         getMidiInputDriverParameterInfo(drv, "PORTS");
+                                 ports.parseValue(s);
+                                 mid.setPortsParameter(ports);
+                                 int j = ports.getValue();
+                                 MidiPort[] midiPorts = new MidiPort[j > 0 ? j : 0];
                                  for(int i = 0; i < midiPorts.length; i++)
                                          midiPorts[i] = getMidiInputPortInfo(deviceId, i);
-Line 2443 
 public class Client {
+Line 2672 
 public class Client {
          public synchronized int
          addMidiInstrumentMap(String name) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("ADD MIDI_INSTRUMENT_MAP '" + name + "'");
+                 out.writeLine("ADD MIDI_INSTRUMENT_MAP '" + toEscapedText(name) + "'");
                  if(getPrintOnlyMode()) return -1;
                  ResultSet rs = getEmptyResultSet();
-Line 2546 
 public class Client {
+Line 2775 
 public class Client {
                  for(String s : lnS) {
                          if(s.startsWith("NAME: ")) {
-                                 name = s.substring("NAME: ".length());
+                                 name = toNonEscapedString(s.substring("NAME: ".length()));
                          } else if(s.startsWith("DEFAULT: ")) {
                                  b = Boolean.parseBoolean(s.substring("DEFAULT: ".length()));
                          } else {
-Line 2594 
 public class Client {
+Line 2823 
 public class Client {
                                  throws IOException, LscpException, LSException {
                  verifyConnection();
+                 name = toEscapedText(name);
                  out.writeLine("SET MIDI_INSTRUMENT_MAP NAME " +  + mapId + " '" + name + "'");
                  if(getPrintOnlyMode()) return;
-Line 2643 
 public class Client {
+Line 2873 
 public class Client {
                  cmd.append(entry.getMidiBank()).append(' ');
                  cmd.append(entry.getMidiProgram()).append(' ');
                  cmd.append(info.getEngine()).append(" '");
-                 cmd.append(info.getFilePath()).append("' ");
+                 cmd.append(conv(info.getFilePath())).append("' ");
                  cmd.append(info.getInstrumentIndex()).append(' ');
                  cmd.append(info.getVolume());
                  if(!info.getLoadMode().name().equals("DEFAULT")) {
                          cmd.append(' ').append(info.getLoadMode().name());
                  }
-                 if(info.getName() != null) cmd.append(" '").append(info.getName()).append("'");
+                 if(info.getName() != null) {
+                         String s = toEscapedText(info.getName());
+                         cmd.append(" '").append(s).append("'");
+                 }
                  out.writeLine(cmd.toString());
                  if(getPrintOnlyMode()) return;
-Line 2738 
 public class Client {
+Line 2972 
 public class Client {
          }
          /**
-          * Gets all MIDI instrument contained int the specified MIDI instrument map.
+          * Gets all MIDI instrument entries contained int the specified MIDI instrument map.
+          * @param mapId The ID of the map, which instruments should be obtained.
+          * @return An int array providing all MIDI instrument entries
+          * in the specified MIDI instrument map.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If some other error occurs.
+          */
+         public synchronized int[][]
+         getMidiInstrumentEntries(int mapId) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("LIST MIDI_INSTRUMENTS " + String.valueOf(mapId));
+                 if(getPrintOnlyMode()) return null;
+                 String[] entries = parseArray(getSingleLineResultSet().getResult());
+                 int[][] e = new int[entries.length][3];
+                 for(int i = 0; i < entries.length; i++) {
+                         Integer[] vals = parseIntList(entries[i]);
+                         if(vals.length != 3) {
+                                 throw new LscpException(LscpI18n.getLogMsg("CommandFailed!"));
+                         }
+                         e[i][0] = vals[0];
+                         e[i][1] = vals[1];
+                         e[i][2] = vals[2];
+                 }
+                 return e;
+         }
+         /**
+          * Gets all MIDI instruments contained int the specified MIDI instrument map.
           * @param mapId The ID of the map, which instruments should be obtained.
           * @return A <code>MidiInstrumentInfo</code> array providing
-          * all MIDI instruments from all MIDI instrument maps.
+          * all MIDI instruments in the specified MIDI instrument map.
           * @throws IOException If some I/O error occurs.
           * @throws LscpException If LSCP protocol corruption occurs.
           * @throws LSException If some other error occurs.
-Line 2789 
 public class Client {
+Line 3055 
 public class Client {
                                          throws IOException, LscpException, LSException {
                  verifyConnection();
+                 requestMidiInstrumentInfo(mapId, bank, program);
+                 return getMidiInstrumentInfoResponse(mapId, bank, program);
+         }
+         private void
+         requestMidiInstrumentInfo(int mapId, int bank, int program) throws IOException {
                  StringBuffer cmd = new StringBuffer("GET MIDI_INSTRUMENT INFO ");
                  cmd.append(mapId).append(' ');
                  cmd.append(bank).append(' ');
                  cmd.append(program);
                  out.writeLine(cmd.toString());
-                 if(getPrintOnlyMode()) return null;
+         }
+         private MidiInstrumentInfo
+         getMidiInstrumentInfoResponse(int mapId, int bank, int program)
+                                         throws IOException, LscpException, LSException {
+                 if(getPrintOnlyMode()) return null;
                  ResultSet rs = getMultiLineResultSet();
                  MidiInstrumentEntry entry = new MidiInstrumentEntry(bank, program);
                  return new MidiInstrumentInfo(mapId, entry, rs.getMultiLineResult());
-Line 2846 
 public class Client {
+Line 3123 
 public class Client {
                                                  throws IOException, LscpException, LSException {
                  String cmd = nonModal ? "LOAD INSTRUMENT NON_MODAL " : "LOAD INSTRUMENT ";
-                 String args = '\'' + filename + "' " + instrIdx + ' ' + samplerChn;
+                 String args = '\'' + conv(filename) + "' " + instrIdx + ' ' + samplerChn;
                  out.writeLine(cmd + args);
                  if(getPrintOnlyMode()) return;
-Line 3498 
 public class Client {
+Line 3775 
 public class Client {
                  verifyConnection();
                  String s = String.valueOf(channel) + " " + String.valueOf(midiCtrl);
-                 if(name != null) s += " '" + name + "'";
+                 if(name != null) s += " '" + toEscapedText(name) + "'";
                  out.writeLine("CREATE FX_SEND " + s);
                  if(getPrintOnlyMode()) return -1;
-Line 3629 
 public class Client {
+Line 3906 
 public class Client {
                                  throws IOException, LscpException, LSException {
                  verifyConnection();
-                 String args = " " + channel + " " + fxSend + " '" + name + "'";
+                 String args = " " + channel + " " + fxSend + " '" + toEscapedText(name) + "'";
                  out.writeLine("SET FX_SEND NAME" + args);
                  if(getPrintOnlyMode()) return;
-Line 3717 
 public class Client {
+Line 3994 
 public class Client {
                  ResultSet rs = getEmptyResultSet();
          }
+         /**
+          * Starts an instrument editor for editing the loaded instrument
+          * on the specified sampler channel.
+          * @param samplerChn The sampler channel number.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If <code>samplerChn</code> is not a valid channel number or if
+          * there is no instrument loaded on the specified sampler channel.
+          * @see #getSamplerChannels
+          */
+         public synchronized void
+         editChannelInstrument(int samplerChn) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("EDIT CHANNEL INSTRUMENT " + samplerChn);
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Sends a MIDI event to this sampler channel.
+          * @param samplerChn The sampler channel number.
+          * @param type The type of MIDI message to send.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If <code>samplerChn</code> is not a valid channel number or if
+          * there is no instrument loaded on the specified sampler channel.
+          * @see #getSamplerChannels
+          */
+         public synchronized void
+         sendChannelMidiData(int samplerChn, MidiDataEvent.Type type, int arg1, int arg2)
+                                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 StringBuffer sb = new StringBuffer();
+                 sb.append("SEND CHANNEL MIDI_DATA ");
+                 sb.append(type).append(" ").append(samplerChn).append(" ");
+                 sb.append(arg1).append(" ").append(arg2);
+                 out.writeLine(sb.toString());
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Resets the specified sampler channel.
+          *
+          * @param samplerChn The sampler channel number.
+          *
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If <code>samplerChn</code> is not a valid channel number or if
+          * there is no engine assigned yet to the specified sampler channel.
+          * @see #getSamplerChannels
+          */
+         public synchronized void
+         resetChannel(int samplerChn) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("RESET CHANNEL " + samplerChn);
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
          /**
           * Adds the specified directory to the instruments database.
-          * @param dir The absolute path name of the directory to add.
+          * @param dir The absolute (escaped) path name of the directory to add.
           * @throws IOException If some I/O error occurs.
           * @throws LSException If the creation of the directory failed.
           * @throws LscpException If LSCP protocol corruption occurs.
-Line 3729 
 public class Client {
+Line 4071 
 public class Client {
          public synchronized void
          addDbDirectory(String dir) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("ADD DB_INSTRUMENT_DIRECTORY '" + dir + "'");
+                 out.writeLine("ADD DB_INSTRUMENT_DIRECTORY '" + conv(dir) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 3737 
 public class Client {
+Line 4079 
 public class Client {
          /**
           * Removes the specified directory from the instruments database.
-          * @param dir The absolute path name of the directory to remove.
+          * @param dir The absolute (escaped) path name of the directory to remove.
           * @throws IOException If some I/O error occurs.
           * @throws LscpException If LSCP protocol corruption occurs.
           * @throws LSException If the specified directory is not
-Line 3764 
 public class Client {
+Line 4106 
 public class Client {
                  verifyConnection();
                  String s = "REMOVE DB_INSTRUMENT_DIRECTORY ";
                  if(force) s += "FORCE ";
-                 out.writeLine(s + "'" + dir + "'");
+                 out.writeLine(s + "'" + conv(dir) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 3772 
 public class Client {
+Line 4114 
 public class Client {
          /**
           * Removes the specified directories from the instruments database.
-          * @param dirs The absolute path names of the directories to remove.
+          * @param dirs The absolute (escaped) path names of the directories to remove.
           * @param force If <code>true</code> forces the removal of non-empty
           * directories.
           * @throws IOException If some I/O error occurs.
-Line 3787 
 public class Client {
+Line 4129 
 public class Client {
                  String cmd = "REMOVE DB_INSTRUMENT_DIRECTORY ";
                  if(force) cmd += "FORCE ";
-                 for(String s : dirs) out.writeLine(cmd + "'" + s + "'");
+                 for(String s : dirs) out.writeLine(cmd + "'" + conv(s) + "'");
                  if(getPrintOnlyMode()) return;
-Line 3825 
 public class Client {
+Line 4167 
 public class Client {
                  String s;
                  if(recursive) s = "GET DB_INSTRUMENT_DIRECTORIES RECURSIVE '";
                  else s = "GET DB_INSTRUMENT_DIRECTORIES '";
-                 out.writeLine(s + dir + "'");
+                 out.writeLine(s + conv(dir) + "'");
                  if(getPrintOnlyMode()) return -1;
                  s = getSingleLineResultSet().getResult();
-Line 3844 
 public class Client {
+Line 4186 
 public class Client {
          public synchronized String[]
          getDbDirectoryNames(String dir) throws IOException, LscpException, LSException {
                  verifyConnection();
-                 out.writeLine("LIST DB_INSTRUMENT_DIRECTORIES '" + dir + "'");
+                 out.writeLine("LIST DB_INSTRUMENT_DIRECTORIES '" + conv(dir) + "'");
                  if(getPrintOnlyMode()) return null;
-                 return parseStringList(getSingleLineResultSet().getResult());
+                 String[] names = parseEscapedStringList(getSingleLineResultSet().getResult());
+                 for(int i = 0; i < names.length; i++) {
+                         names[i] = toNonEscapedString(names[i]);
+                 }
+                 return names;
          }
          /**
-Line 3862 
 public class Client {
+Line 4208 
 public class Client {
          public synchronized DbDirectoryInfo
          getDbDirectoryInfo(String dir) throws IOException, LscpException, LSException {
                  verifyConnection();
-                 out.writeLine("GET DB_INSTRUMENT_DIRECTORY INFO '" + dir + "'");
+                 out.writeLine("GET DB_INSTRUMENT_DIRECTORY INFO '" + conv(dir) + "'");
                  if(getPrintOnlyMode()) return null;
                  ResultSet rs = getMultiLineResultSet();
                  DbDirectoryInfo info = new DbDirectoryInfo(rs.getMultiLineResult());
                  if(dir.equals("/")) {
                          info.setName("/");
-                 } else if(dir.length() > 1 && dir.charAt(dir.length() - 1) == '/') {
+                 } else {
-                         dir = dir.substring(0, dir.length() - 1);
+                         dir = removeEndingFileSeparator(dir);
-                 }
-                 int i = dir.lastIndexOf('/');
-                 if(i != -1 && i < dir.length() - 1) {
-                         info.setName(dir.substring(i + 1));
-                         if(i == 0) info.setParentDirectoryPath("/");
-                         else info.setParentDirectoryPath(dir.substring(0, i));
                  }
+                 String s = getFileName(dir);
+                 if(s != null) info.setName(toNonEscapedFileName(s));
+                 s = getParentDirectory(dir);
+                 if(s != null) info.setParentDirectoryPath(s);
                  return info;
          }
-Line 3894 
 public class Client {
+Line 4238 
 public class Client {
          public synchronized DbDirectoryInfo[]
          getDbDirectories(String dir) throws IOException, LscpException, LSException {
                  String[] dirS = getDbDirectoryNames(dir);
-                 if(dir.charAt(dir.length() - 1) != '/') dir += "/";
+                 if(!hasEndingFileSeparator(dir)) dir += "/";
                  DbDirectoryInfo[] infoS = new DbDirectoryInfo[dirS.length];
-                 for(int i = 0; i < dirS.length; i++) infoS[i] = getDbDirectoryInfo(dir + dirS[i]);
+                 for(int i = 0; i < dirS.length; i++) {
+                         infoS[i] = getDbDirectoryInfo(conv(dir) + toEscapedFsEntry(dirS[i]));
+                 }
                  return infoS;
          }
-Line 3911 
 public class Client {
+Line 4257 
 public class Client {
           *
          public synchronized DbDirectoryInfo[]
          getDbDirectories(String dir) throws IOException, LscpException, LSException {
-                 String[] dirS = getDbDirectoryNames(dir);
+                 String[] dirS = getDbDirectoryNames(conv(dir));
                  if(dirS.length == 0) return new DbDirectoryInfo[0];
-                 if(dir.charAt(dir.length() - 1) != '/') dir += "/";
+                 if(dir.charAt(dir.length() - 1) != '/') dir += "/"; // FIXME:
                  for(int i = 0; i < dirS.length; i++) {
-                         out.writeLine("GET DB_INSTRUMENT_DIRECTORY INFO '" + dir + dirS[i] + "'");
+                         out.writeLine("GET DB_INSTRUMENT_DIRECTORY INFO '" + conv(dir + dirS[i]) + "'");
                  }
                  if(getPrintOnlyMode()) return null;
-Line 3961 
 public class Client {
+Line 4307 
 public class Client {
          public synchronized void
          renameDbDirectory(String dir, String name) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("SET DB_INSTRUMENT_DIRECTORY NAME '" + dir + "' '" + name + "'");
+                 name = toEscapedText(name);
+                 out.writeLine("SET DB_INSTRUMENT_DIRECTORY NAME '" + conv(dir) + "' '" + conv(name) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 3978 
 public class Client {
+Line 4325 
 public class Client {
          public synchronized void
          moveDbDirectory(String dir, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("MOVE DB_INSTRUMENT_DIRECTORY '" + dir + "' '" + dst + "'");
+                 out.writeLine("MOVE DB_INSTRUMENT_DIRECTORY '" + conv(dir) + "' '" + conv(dst) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 3996 
 public class Client {
+Line 4343 
 public class Client {
          moveDbDirectories(String dirs[], String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
                  for(String s : dirs) {
-                         out.writeLine("MOVE DB_INSTRUMENT_DIRECTORY '" + s + "' '" + dst + "'");
+                         out.writeLine("MOVE DB_INSTRUMENT_DIRECTORY '" + conv(s) + "' '" + conv(dst) + "'");
                  }
                  if(getPrintOnlyMode()) return;
-Line 4014 
 public class Client {
+Line 4361 
 public class Client {
          public synchronized void
          copyDbDirectory(String dir, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("COPY DB_INSTRUMENT_DIRECTORY '" + dir + "' '" + dst + "'");
+                 out.writeLine("COPY DB_INSTRUMENT_DIRECTORY '" + conv(dir) + "' '" + conv(dst) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4032 
 public class Client {
+Line 4379 
 public class Client {
          copyDbDirectories(String[] dirs, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
                  for(String s : dirs) {
-                         out.writeLine("COPY DB_INSTRUMENT_DIRECTORY '" + s + "' '" + dst + "'");
+                         out.writeLine("COPY DB_INSTRUMENT_DIRECTORY '" + conv(s) + "' '" + conv(dst) + "'");
                  }
                  if(getPrintOnlyMode()) return;
-Line 4053 
 public class Client {
+Line 4400 
 public class Client {
                  verifyConnection();
                  String s = "SET DB_INSTRUMENT_DIRECTORY DESCRIPTION '";
-                 out.writeLine(s + dir + "' '" + desc + "'");
+                 out.writeLine(s + conv(dir) + "' '" + toEscapedText(desc) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4102 
 public class Client {
+Line 4449 
 public class Client {
                  verifyConnection();
                  String s = "ADD DB_INSTRUMENTS";
                  if(background) s += " NON_MODAL";
-                 s += " '" + dbDir + "' '" + filePath + "' ";
+                 s += " '" + conv(dbDir) + "' '" + conv(filePath) + "' ";
                  out.writeLine(s + String.valueOf(instrIndex));
                  if(getPrintOnlyMode()) return -1;
-Line 4149 
 public class Client {
+Line 4496 
 public class Client {
                  verifyConnection();
                  String s = "ADD DB_INSTRUMENTS";
                  if(background) s += " NON_MODAL";
-                 out.writeLine(s + " '" + dbDir + "' '" + filePath + "'");
+                 out.writeLine(s + " '" + conv(dbDir) + "' '" + conv(filePath) + "'");
                  if(getPrintOnlyMode()) return -1;
                  ResultSet rs = getEmptyResultSet();
-Line 4216 
 public class Client {
+Line 4563 
 public class Client {
          addDbInstruments(ScanMode mode, String dbDir, String fsDir, boolean background)
                                          throws IOException, LSException, LscpException {
+                 return addDbInstruments(mode, dbDir, fsDir, background, false);
+         }
+         /**
+          * Adds the instruments in the specified file system directory
+          * to the specified instruments database directory.
+          * @param mode Determines the scanning mode. If RECURSIVE is
+          * specified, all supported instruments in the specified file system
+          * direcotry will be added to the specified instruments database
+          * directory, including the instruments in subdirectories
+          * of the supplied directory. If NON_RECURSIVE is specified,
+          * the instruments in the subdirectories will not be processed.
+          * If FLAT is specified, all supported instruments in the specified
+          * file system direcotry will be added, including the instruments in
+          * subdirectories of the supplied directory, but the respective
+          * subdirectory structure will not be recreated in the instruments
+          * database and all instruments will be added directly in the
+          * specified database directory.
+          * @param dbDir The absolute path name of the database directory
+          * in which the supported instruments will be added.
+          * @param fsDir The absolute path name of the file system directory.
+          * @param background If <code>true</code>, the scan will be done
+          * in background and this method may return before the job is finished.
+          * @param insDir If <code>true</code> a drieectory is created for each
+          * instrument file.
+          * @return If <code>background</code> is <code>true</code>, the ID
+          * of the scan job.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @see #addInstrumentsDbListener
+          */
+         public synchronized int
+         addDbInstruments(ScanMode mode, String dbDir, String fsDir, boolean background, boolean insDir)
+                                         throws IOException, LSException, LscpException {
                  verifyConnection();
                  StringBuffer sb = new StringBuffer("ADD DB_INSTRUMENTS");
                  if(background) sb.append(" NON_MODAL");
-Line 4231 
 public class Client {
+Line 4614 
 public class Client {
                                  sb.append(" FLAT");
                                  break;
                  }
+                 if(insDir)
+                         sb.append(" FILE_AS_DIR");
-                 sb.append(" '").append(dbDir).append("' '").append(fsDir).append("'");
+                 sb.append(" '").append(conv(dbDir)).append("' '");
+                 sb.append(conv(fsDir)).append("'");
                  out.writeLine(sb.toString());
                  if(getPrintOnlyMode()) return -1;
                  ResultSet rs = getEmptyResultSet();
                  return rs.getIndex();
          }
          /**
           * Removes the specified instrument from the instruments database.
           * @param instr The absolute path name of the instrument to remove.
-Line 4251 
 public class Client {
+Line 4637 
 public class Client {
          removeDbInstrument(String instr) throws IOException, LscpException, LSException {
                  verifyConnection();
-                 out.writeLine("REMOVE DB_INSTRUMENT '" + instr + "'");
+                 out.writeLine("REMOVE DB_INSTRUMENT '" + conv(instr) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4268 
 public class Client {
+Line 4654 
 public class Client {
          removeDbInstruments(String[] instrs) throws IOException, LscpException, LSException {
                  verifyConnection();
                  for(String s : instrs) {
-                         out.writeLine("REMOVE DB_INSTRUMENT '" + s + "'");
+                         out.writeLine("REMOVE DB_INSTRUMENT '" + conv(s) + "'");
                  }
                  if(getPrintOnlyMode()) return;
-Line 4306 
 public class Client {
+Line 4692 
 public class Client {
                  String s;
                  if(recursive) s = "GET DB_INSTRUMENTS RECURSIVE '";
                  else s = "GET DB_INSTRUMENTS '";
-                 out.writeLine(s + dir + "'");
+                 out.writeLine(s + conv(dir) + "'");
                  if(getPrintOnlyMode()) return -1;
                  s = getSingleLineResultSet().getResult();
-Line 4325 
 public class Client {
+Line 4711 
 public class Client {
          public synchronized String[]
          getDbInstrumentNames(String dir) throws IOException, LscpException, LSException {
                  verifyConnection();
-                 out.writeLine("LIST DB_INSTRUMENTS '" + dir + "'");
+                 out.writeLine("LIST DB_INSTRUMENTS '" + conv(dir) + "'");
                  if(getPrintOnlyMode()) return null;
-                 return parseStringList(getSingleLineResultSet().getResult());
+                 String[] names = parseEscapedStringList(getSingleLineResultSet().getResult());
+                 for(int i = 0; i < names.length; i++) {
+                         names[i] = toNonEscapedString(names[i]);
+                 }
+                 return names;
          }
          /**
-Line 4343 
 public class Client {
+Line 4733 
 public class Client {
          public synchronized DbInstrumentInfo
          getDbInstrumentInfo(String instr) throws IOException, LscpException, LSException {
                  verifyConnection();
-                 out.writeLine("GET DB_INSTRUMENT INFO '" + instr + "'");
+                 out.writeLine("GET DB_INSTRUMENT INFO '" + conv(instr) + "'");
                  if(getPrintOnlyMode()) return null;
                  ResultSet rs = getMultiLineResultSet();
                  DbInstrumentInfo info = new DbInstrumentInfo(rs.getMultiLineResult());
-                 int i = instr.lastIndexOf('/');
+                 String s = getParentDirectory(instr);
-                 if(i != -1 && i < instr.length() - 1) {
+                 if(s != null) info.setDirectoryPath(s);
-                         info.setName(instr.substring(i + 1));
+                 s = getFileName(instr);
-                         if(i == 0) info.setDirectoryPath("/");
+                 if(s != null) info.setName(toNonEscapedFileName(s));
-                         else info.setDirectoryPath(instr.substring(0, i));
-                 }
                  return info;
          }
-Line 4370 
 public class Client {
+Line 4758 
 public class Client {
          public synchronized DbInstrumentInfo[]
          getDbInstruments(String dir) throws IOException, LscpException, LSException {
                  String[] instrS = getDbInstrumentNames(dir);
-                 if(dir.charAt(dir.length() - 1) != '/') dir += "/";
+                 if(!hasEndingFileSeparator(dir)) dir += "/";
                  DbInstrumentInfo[] infoS = new DbInstrumentInfo[instrS.length];
                  for(int i = 0; i < instrS.length; i++) {
-                         infoS[i] = getDbInstrumentInfo(dir + instrS[i]);
+                         infoS[i] = getDbInstrumentInfo(conv(dir) + toEscapedFsEntry(instrS[i]));
                  }
                  return infoS;
          }
-Line 4393 
 public class Client {
+Line 4781 
 public class Client {
                  String[] instrS = getDbInstrumentNames(dir);
                  if(instrS.length == 0) return new DbInstrumentInfo[0];
-                 if(dir.charAt(dir.length() - 1) != '/') dir += "/";
+                 if(dir.charAt(dir.length() - 1) != '/') dir += "/"; FIXME:
                  for(int i = 0; i < instrS.length; i++) {
-                         out.writeLine("GET DB_INSTRUMENT INFO '" + dir + instrS[i] + "'");
+                         out.writeLine("GET DB_INSTRUMENT INFO '" + conv(dir) + instrS[i] + "'");
                  }
                  if(getPrintOnlyMode()) return null;
-Line 4442 
 public class Client {
+Line 4830 
 public class Client {
                                  throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("SET DB_INSTRUMENT NAME '" + instr + "' '" + name + "'");
+                 name = toEscapedText(name);
+                 out.writeLine("SET DB_INSTRUMENT NAME '" + conv(instr) + "' '" + conv(name) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4459 
 public class Client {
+Line 4848 
 public class Client {
          public synchronized void
          moveDbInstrument(String instr, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("MOVE DB_INSTRUMENT '" + instr + "' '" + dst + "'");
+                 out.writeLine("MOVE DB_INSTRUMENT '" + conv(instr) + "' '" + conv(dst) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4477 
 public class Client {
+Line 4866 
 public class Client {
          moveDbInstruments(String[] instrs, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
                  for(String s : instrs) {
-                         out.writeLine("MOVE DB_INSTRUMENT '" + s + "' '" + dst + "'");
+                         out.writeLine("MOVE DB_INSTRUMENT '" + conv(s) + "' '" + conv(dst) + "'");
                  }
                  if(getPrintOnlyMode()) return;
-Line 4495 
 public class Client {
+Line 4884 
 public class Client {
          public synchronized void
          copyDbInstrument(String instr, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("COPY DB_INSTRUMENT '" + instr + "' '" + dst + "'");
+                 out.writeLine("COPY DB_INSTRUMENT '" + conv(instr) + "' '" + conv(dst) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4513 
 public class Client {
+Line 4902 
 public class Client {
          copyDbInstruments(String[] instrs, String dst) throws IOException, LSException, LscpException {
                  verifyConnection();
                  for(String s : instrs) {
-                         out.writeLine("COPY DB_INSTRUMENT '" + s + "' '" + dst + "'");
+                         out.writeLine("COPY DB_INSTRUMENT '" + conv(s) + "' '" + conv(dst) + "'");
                  }
                  if(getPrintOnlyMode()) return;
-Line 4533 
 public class Client {
+Line 4922 
 public class Client {
                                  throws IOException, LSException, LscpException {
                  verifyConnection();
-                 out.writeLine("SET DB_INSTRUMENT DESCRIPTION '" + instr + "' '" + desc + "'");
+                 desc = toEscapedText(desc);
+                 out.writeLine("SET DB_INSTRUMENT DESCRIPTION '" + conv(instr) + "' '" + desc + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Substitutes all occurrences of the instrument file
+          * <code>oldPath</code> in the database, with <code>newPath</code>.
+          * @param oldPath The absolute path name of the instrument file to substitute.
+          * @param newPath The new absolute path name.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         setDbInstrumentFilePath(String oldPath, String newPath)
+                                 throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 out.writeLine("SET DB_INSTRUMENT FILE_PATH '" + conv(oldPath) + "' '" + conv(newPath) + "'");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4577 
 public class Client {
+Line 4987 
 public class Client {
                  StringBuffer sb = new StringBuffer();
                  sb.append("FIND DB_INSTRUMENT_DIRECTORIES");
                  if(nonRecursive) sb.append(" NON_RECURSIVE");
-                 sb.append(" '").append(dir).append("'");
+                 sb.append(" '").append(conv(dir)).append("'");
                  if(query.name != null && query.name.length() > 0) {
-                         sb.append(" NAME='").append(query.name).append("'");
+                         sb.append(" NAME='").append(toEscapedText(query.name)).append("'");
                  }
                  String s = query.getCreatedAfter();
-Line 4604 
 public class Client {
+Line 5014 
 public class Client {
                  }
                  if(query.description != null && query.description.length() > 0) {
-                         sb.append(" DESCRIPTION='").append(query.description).append("'");
+                         sb.append(" DESCRIPTION='");
+                         sb.append(toEscapedText(query.description)).append("'");
                  }
                  out.writeLine(sb.toString());
                  if(getPrintOnlyMode()) return null;
-                 String[] dirS = parseStringList(getSingleLineResultSet().getResult());
+                 String[] dirS = parseEscapedStringList(getSingleLineResultSet().getResult());
                  DbDirectoryInfo[] infoS = new DbDirectoryInfo[dirS.length];
                  for(int i = 0; i < dirS.length; i++) {
-Line 4657 
 public class Client {
+Line 5068 
 public class Client {
                  StringBuffer sb = new StringBuffer();
                  sb.append("FIND DB_INSTRUMENTS");
                  if(nonRecursive) sb.append(" NON_RECURSIVE");
-                 sb.append(" '").append(dir).append("'");
+                 sb.append(" '").append(conv(dir)).append("'");
                  if(query.name != null && query.name.length() > 0) {
-                         sb.append(" NAME='").append(query.name).append("'");
+                         sb.append(" NAME='").append(toEscapedText(query.name)).append("'");
                  }
                  if(query.formatFamilies.size() > 0) {
-Line 4700 
 public class Client {
+Line 5111 
 public class Client {
                  }
                  if(query.description != null && query.description.length() > 0) {
-                         sb.append(" DESCRIPTION='").append(query.description).append("'");
+                         sb.append(" DESCRIPTION='");
+                         sb.append(toEscapedText(query.description)).append("'");
                  }
                  if(query.instrumentType != DbSearchQuery.InstrumentType.BOTH) {
-Line 4713 
 public class Client {
+Line 5125 
 public class Client {
                  }
                  if(query.product != null && query.product.length() > 0) {
-                         sb.append(" PRODUCT='").append(query.product).append("'");
+                         sb.append(" PRODUCT='").append(toEscapedText(query.product)).append("'");
                  }
                  if(query.artists != null && query.artists.length() > 0) {
-                         sb.append(" ARTISTS='").append(query.artists).append("'");
+                         sb.append(" ARTISTS='").append(toEscapedText(query.artists)).append("'");
                  }
                  if(query.keywords != null && query.keywords.length() > 0) {
-                         sb.append(" KEYWORDS='").append(query.keywords).append("'");
+                         sb.append(" KEYWORDS='");
+                         sb.append(toEscapedText(query.keywords)).append("'");
                  }
                  out.writeLine(sb.toString());
                  if(getPrintOnlyMode()) return null;
-                 String[] instrS = parseStringList(getSingleLineResultSet().getResult());
+                 String[] instrS = parseEscapedStringList(getSingleLineResultSet().getResult());
                  DbInstrumentInfo[] infoS = new DbInstrumentInfo[instrS.length];
                  for(int i = 0; i < instrS.length; i++) {
-Line 4737 
 public class Client {
+Line 5150 
 public class Client {
          }
          /**
+          * Returns a list of all instrument files in the database
+          * that that don't exist in the filesystem.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If other error occurs.
+          */
+         public synchronized String[]
+         findLostDbInstrumentFiles() throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("FIND LOST DB_INSTRUMENT_FILES");
+                 if(getPrintOnlyMode()) return null;
+                 return parseEscapedStringList(getSingleLineResultSet().getResult());
+         }
+         /**
           * Gets status information about the specified job.
           * @param jobId The ID of the job.
           * @return A <code>ScanJobInfo</code> instance providing information
-Line 4758 
 public class Client {
+Line 5188 
 public class Client {
          }
          /**
-          * Resets the specified sampler channel.
+          * Removes all instruments and directories and re-creates
-          *
+          * the instruments database structure.
-          * @param samplerChn The sampler channel number.
-          *
           * @throws IOException If some I/O error occurs.
           * @throws LscpException If LSCP protocol corruption occurs.
-          * @throws LSException If <code>samplerChn</code> is not a valid channel number or if
+          * @throws LSException If the formatting of the instruments database failed.
-          * there is no engine assigned yet to the specified sampler channel.
-          * @see #getSamplerChannels
           */
          public synchronized void
-         resetChannel(int samplerChn) throws IOException, LscpException, LSException {
+         formatInstrumentsDb() throws IOException, LscpException, LSException {
                  verifyConnection();
-                 out.writeLine("RESET CHANNEL " + samplerChn);
+                 out.writeLine("FORMAT INSTRUMENTS_DB");
                  if(getPrintOnlyMode()) return;
                  ResultSet rs = getEmptyResultSet();
-Line 4794 
 public class Client {
+Line 5220 
 public class Client {
          }
          /**
+          * Gets the current number of all active streams.
+          * @return The current number of all active streams.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If some other error occurs.
+          */
+         public synchronized int
+         getTotalStreamCount() throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("GET TOTAL_STREAM_COUNT");
+                 if(getPrintOnlyMode()) return -1;
+                 String s = getSingleLineResultSet().getResult();
+                 return parseInt(s);
+         }
+         /**
           * Gets the current number of all active voices.
           * @return The current number of all active voices.
           * @throws IOException If some I/O error occurs.
-Line 4882 
 public class Client {
+Line 5325 
 public class Client {
                  ResultSet rs = getEmptyResultSet();
          }
+         /**
+          * Gets the number of instruments in the specified instrument file.
+          * @param filename The absolute path name of the instrument file.
+          * @return The number of instruments in the specified instrument file.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the file is not found, or other error occur.
+          */
+         public synchronized int
+         getFileInstrumentCount(String filename) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("GET FILE INSTRUMENTS '" + conv(filename) +"'");
+                 if(getPrintOnlyMode()) return -1;
+                 String s = getSingleLineResultSet().getResult();
+                 return parseInt(s);
+         }
+         /**
+          * Gets information about the instrument with index
+          * <code>instrIdx</code> in the specified instrument file.
+          * @param filename The absolute path name of the instrument file.
+          * @param instrIdx The index of the instrument in the specified instrument file.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If failed to retrieve information.
+          */
+         public synchronized Instrument
+         getFileInstrumentInfo(String filename, int instrIdx)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("GET FILE INSTRUMENT INFO '" + conv(filename) + "' " + String.valueOf(instrIdx));
+                 if(getPrintOnlyMode()) return null;
+                 ResultSet rs = getMultiLineResultSet();
+                 Instrument instr = new FileInstrument(rs.getMultiLineResult()) { };
+                 return instr;
+         }
+         /**
+          * Gets the list of instruments in the specified instrument file.
+          * @param filename The absolute path name of the instrument file.
+          * @return An <code>Instrument</code> array providing
+          * information about all instruments in the specified instrument file.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified file name is invalid.
+          */
+         public synchronized Instrument[]
+         getFileInstruments(String filename) throws IOException, LscpException, LSException {
+                 int l = getFileInstrumentCount(filename);
+                 if(l < 0) return null;
+                 Instrument[] instrS = new FileInstrument[l];
+                 for(int i = 0; i < instrS.length; i++) {
+                         instrS[i] = getFileInstrumentInfo(filename, i);
+                 }
+                 return instrS;
+         }
+         private static class FileInstrument extends AbstractInstrument {
+                 FileInstrument(String[] resultSet) throws LscpException {
+                         super(resultSet);
+                 }
+                 public String
+                 getEngine() {
+                         // TODO: engine lookup?
+                         return getFormatFamily();
+                 }
+                 public boolean
+                 parse(String s) throws LscpException {
+                         if(s.startsWith("PRODUCT: ") || s.startsWith("ARTISTS: ")) return true;
+                         return super.parse(s);
+                 }
+         }
          private void
          getEmptyResultSets(int count, String err) throws LSException {
                  StringBuffer sb = new StringBuffer();

 Legend:



Removed from v.1202
 


changed lines


 
Added in v.1781
 Legend:



Removed from v.1202
 


changed lines


 
Added in v.1781
-Removed from v.1202
+Added in v.1781

	ViewVC Help
Powered by ViewVC