/[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 1139 by iliev,
Mon Apr  2 20:43:58 2007 UTC
+revision 1766 by iliev,
Mon Sep  8 00:16:17 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.2, 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.2.html>LSCP</a> specification.
   *
   * <p> The following code establishes connection to LinuxSampler instance and gets the
   * LinuxSampler version:
-Line 69 
 public class Client {
+Line 70 
 public class Client {
          private String address;
          private int port;
          private Socket sock = null;
-         private int soTimeout = 10000;
+         private int soTimeout = 20000;
          private LscpInputStream in = null;
          private LscpOutputStream out = null;
-Line 79 
 public class Client {
+Line 80 
 public class Client {
          private boolean printOnlyMode = false;
          class EventThread extends Thread {
+                 private Vector<String> queue = new Vector<String>();
                  private boolean terminate = false;
                  EventThread() { super("LSCP-Event-Thread"); }
-Line 86 
 public class Client {
+Line 88 
 public class Client {
                  public void
                  run() {
                          while(!mustTerminate()) {
-                                 try { processNotifications(); }
+                                 try {
-                                 catch(Exception x) {
+                                         processQueue();
+                                         processNotifications();
+                                 } catch(Exception x) {
                                          getLogger().log(Level.FINE, x.getMessage(), x);
                                  }
                                  try { synchronized(this) { wait(100); } }
-Line 105 
 public class Client {
+Line 109 
 public class Client {
                          terminate = true;
                          this.notifyAll();
                  }
+                 public synchronized void
+                 scheduleNotification(String s) { queue.add(s); }
+                 private void
+                 processQueue() {
+                         String[] notifications = popAllNotifications();
+                         for(String n : notifications) fireEvent(n);
+                 }
+                 private synchronized String[]
+                 popAllNotifications() {
+                         String[] notifications = queue.toArray(new String[queue.size()]);
+                         queue.removeAllElements();
+                         return notifications;
+                 }
          }
          /**
-Line 144 
 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 324 
 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 376 
 public class Client {
+Line 451 
 public class Client {
                  String s;
                  for(;;) {
                          s = in.readLine();
-                         if(s.startsWith("NOTIFY:")) fireEvent(s.substring("NOTIFY:".length()));
+                         if(s.startsWith("NOTIFY:")) {
+                                 eventThread.scheduleNotification(s.substring("NOTIFY:".length()));
+                         }
                          else break;
                  }
                  return s;
-Line 457 
 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 469 
 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 493 
 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 void
+         private synchronized void
+         fireDeviceMidiDataEvent(String s) {
+                 try {
+                         String[] list = parseStringList(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 = parseStringList(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("CHANNEL_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);
+                 } else if(s.startsWith("DB_INSTRUMENT_DIRECTORY_INFO:")) {
+                         InstrumentsDbEvent e;
+                         s = s.substring("DB_INSTRUMENT_DIRECTORY_INFO:".length());
+                         if(s.startsWith("NAME ")) {
+                                 String[] list;
+                                 try {
+                                         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);
+                                         }
+                                 } catch(LscpException x) {
+                                         getLogger().log (
+                                                 Level.WARNING,
+                                                 LscpI18n.getLogMsg("CommandFailed!"),
+                                                 x
+                                         );
+                                 }
+                         } else {
+                                 e = new InstrumentsDbEvent(this, s);
+                                 for(InstrumentsDbListener l : llID) l.directoryInfoChanged(e);
+                         }
+                 } else if(s.startsWith("DB_INSTRUMENT_COUNT:")) {
+                         s = s.substring("DB_INSTRUMENT_COUNT:".length());
+                         InstrumentsDbEvent e = new InstrumentsDbEvent(this, s);
+                         for(InstrumentsDbListener l : llID) l.instrumentCountChanged(e);
+                 } else if(s.startsWith("DB_INSTRUMENT_INFO:")) {
+                         InstrumentsDbEvent e;
+                         s = s.substring("DB_INSTRUMENT_INFO:".length());
+                         if(s.startsWith("NAME ")) {
+                                 String[] list;
+                                 try {
+                                         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);
+                                         }
+                                 } catch(LscpException x) {
+                                         getLogger().log (
+                                                 Level.WARNING,
+                                                 LscpI18n.getLogMsg("CommandFailed!"),
+                                                 x
+                                         );
+                                 }
+                         } else {
+                                 e = new InstrumentsDbEvent(this, s);
+                                 for(InstrumentsDbListener l : llID) l.instrumentInfoChanged(e);
+                         }
+                 } else if(s.startsWith("DB_INSTRUMENTS_JOB_INFO:")) {
+                         s = s.substring("DB_INSTRUMENTS_JOB_INFO:".length());
+                         try {
+                                 int i = Integer.parseInt(s);
+                                 InstrumentsDbEvent e = new InstrumentsDbEvent(this, i);
+                                 for(InstrumentsDbListener l : llID) l.jobStatusChanged(e);
+                         } catch(NumberFormatException x) {
+                                 s = "Unknown DB_INSTRUMENTS_JOB_INFO format";
+                                 getLogger().log(Level.WARNING, s, x);
+                         }
+                 } else if(s.startsWith("CHANNEL_COUNT:")) {
                          try {
                                  int i = Integer.parseInt(s.substring("CHANNEL_COUNT:".length()));
                                  ChannelCountEvent e = new ChannelCountEvent(this, i);
-Line 563 
 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 1035 
 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 1145 
 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
+         addInstrumentsDbListener(InstrumentsDbListener l) {
+                 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");
+                 }
+                 llID.add(l);
+         }
+         /**
+          * Removes the specified listener.
+          * Listeners can be removed regardless of the connection state.
+          * @param l The <code>InstrumentsDbListener</code> to remove.
+          */
+         public synchronized void
+         removeInstrumentsDbListener(InstrumentsDbListener l) {
+                 boolean b = llID.remove(l);
+                 if(b && llID.isEmpty()) {
+                         unsubscribe("DB_INSTRUMENT_DIRECTORY_COUNT");
+                         unsubscribe("DB_INSTRUMENT_DIRECTORY_INFO");
+                         unsubscribe("DB_INSTRUMENT_COUNT");
+                         unsubscribe("DB_INSTRUMENT_INFO");
+                         unsubscribe("DB_INSTRUMENTS_JOB_INFO");
+                 }
+         }
+         /**
+          * Registers the specified listener for receiving event messages.
+          * Listeners can be registered regardless of the connection state.
           * @param l The <code>GlobalInfoListener</code> to register.
           */
          public synchronized void
-Line 1227 
 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 1237 
 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 1248 
 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 1282 
 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 1344 
 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 1806 
 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 1816 
 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 1828 
 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 1862 
 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 1925 
 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 2071 
 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 2315 
 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 2418 
 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 2466 
 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;
                  ResultSet rs = getEmptyResultSet();
          }
          /**
           * Creates or replaces a MIDI instrument map entry.
           * @param mapId The ID of the map, where this instrument should be mapped.
-Line 2486 
 public class Client {
+Line 2846 
 public class Client {
          public synchronized void
          mapMidiInstrument(int mapId, MidiInstrumentEntry entry, MidiInstrumentInfo info)
                                          throws IOException, LSException, LscpException {
+                 mapMidiInstrument(mapId, entry, info, false);
+         }
+         /**
+          * Creates or replaces a MIDI instrument map entry.
+          * @param mapId The ID of the map, where this instrument should be mapped.
+          * @param entry Specifies the position of the MIDI instrument in the MIDI instrument map.
+          * @param info Provides the needed information of the
+          * MIDI instrument, which will be mapped to the specified MIDI instrument map.
+          * @param nonModal If <code>true</code> the function returns immediately
+          * and the mapping is established in the background.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the mapping failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @see #unmapMidiInstrument
+          */
+         public synchronized void
+         mapMidiInstrument(int mapId, MidiInstrumentEntry entry, MidiInstrumentInfo info, boolean nonModal)
+                                         throws IOException, LSException, LscpException {
                  verifyConnection();
                  StringBuffer cmd = new StringBuffer("MAP MIDI_INSTRUMENT ");
+                 if(nonModal) cmd.append("NON_MODAL ");
                  cmd.append(mapId).append(' ');
                  cmd.append(entry.getMidiBank()).append(' ');
                  cmd.append(entry.getMidiProgram()).append(' ');
                  cmd.append(info.getEngine()).append(" '");
-                 cmd.append(info.getFileName()).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 2588 
 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 2639 
 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 2696 
 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 3348 
 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 3479 
 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 3568 
 public class Client {
+Line 3995 
 public class Client {
          }
          /**
+          * 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();
+         }
+         /**
+          * Adds the specified directory to the instruments database.
+          * @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.
+          */
+         public synchronized void
+         addDbDirectory(String dir) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 out.writeLine("ADD DB_INSTRUMENT_DIRECTORY '" + conv(dir) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Removes the specified directory from the instruments database.
+          * @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
+          * empty or if the removal of the directory failed.
+          */
+         public synchronized void
+         removeDbDirectory(String dir) throws IOException, LscpException, LSException {
+                 removeDbDirectory(dir, false);
+         }
+         /**
+          * Removes the specified directory from the instruments database.
+          * @param dir The absolute path name of the directory to remove.
+          * @param force If <code>true</code> forces the removal of non-empty
+          * directory and all its content.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the removing of the directory failed.
+          */
+         public synchronized void
+         removeDbDirectory(String dir, boolean force)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 String s = "REMOVE DB_INSTRUMENT_DIRECTORY ";
+                 if(force) s += "FORCE ";
+                 out.writeLine(s + "'" + conv(dir) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Removes the specified directories from the instruments database.
+          * @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.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the removing of the directores failed.
+          */
+         public synchronized void
+         removeDbDirectories(String[] dirs, boolean force)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 String cmd = "REMOVE DB_INSTRUMENT_DIRECTORY ";
+                 if(force) cmd += "FORCE ";
+                 for(String s : dirs) out.writeLine(cmd + "'" + conv(s) + "'");
+                 if(getPrintOnlyMode()) return;
+                 getEmptyResultSets(dirs.length, "Client.dirDeletionFailed!");
+         }
+         /**
+          * Gets the number of directories in the specified directory.
+          * @return The current number of directories in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @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
+         getDbDirectoryCount(String dir) throws IOException, LscpException, LSException {
+                 return getDbDirectoryCount(dir, false);
+         }
+         /**
+          * Gets the number of directories in the specified directory.
+          * @return The current number of directories in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @param recursive If <code>true</code>, the number of all directories
+          * in the specified subtree will be returned.
+          * @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
+         getDbDirectoryCount(String dir, boolean recursive)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 String s;
+                 if(recursive) s = "GET DB_INSTRUMENT_DIRECTORIES RECURSIVE '";
+                 else s = "GET DB_INSTRUMENT_DIRECTORIES '";
+                 out.writeLine(s + conv(dir) + "'");
+                 if(getPrintOnlyMode()) return -1;
+                 s = getSingleLineResultSet().getResult();
+                 return parseInt(s);
+         }
+         /**
+          * Gets the list of directories in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>String</code> array providing the names of
+          * all directories in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized String[]
+         getDbDirectoryNames(String dir) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("LIST DB_INSTRUMENT_DIRECTORIES '" + conv(dir) + "'");
+                 if(getPrintOnlyMode()) return null;
+                 String[] names = parseEscapedStringList(getSingleLineResultSet().getResult());
+                 for(int i = 0; i < names.length; i++) {
+                         names[i] = toNonEscapedString(names[i]);
+                 }
+                 return names;
+         }
+         /**
+          * Gets information about the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>DbDirectoryInfo</code> instance providing information
+          * about the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified directory is not found.
+          */
+         public synchronized DbDirectoryInfo
+         getDbDirectoryInfo(String dir) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 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 {
+                         dir = removeEndingFileSeparator(dir);
+                 }
+                 String s = getFileName(dir);
+                 if(s != null) info.setName(toNonEscapedFileName(s));
+                 s = getParentDirectory(dir);
+                 if(s != null) info.setParentDirectoryPath(s);
+                 return info;
+         }
+         /**
+          * Gets the list of directories in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>DbDirectoryInfo</code> array providing
+          * information about all directories in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized DbDirectoryInfo[]
+         getDbDirectories(String dir) throws IOException, LscpException, LSException {
+                 String[] dirS = getDbDirectoryNames(dir);
+                 if(!hasEndingFileSeparator(dir)) dir += "/";
+                 DbDirectoryInfo[] infoS = new DbDirectoryInfo[dirS.length];
+                 for(int i = 0; i < dirS.length; i++) {
+                         infoS[i] = getDbDirectoryInfo(conv(dir) + toEscapedFsEntry(dirS[i]));
+                 }
+                 return infoS;
+         }
+         /**
+          * Gets the list of directories in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>DbDirectoryInfo</code> array providing
+          * information about all directories in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          *
+         public synchronized DbDirectoryInfo[]
+         getDbDirectories(String dir) throws IOException, LscpException, LSException {
+                 String[] dirS = getDbDirectoryNames(conv(dir));
+                 if(dirS.length == 0) return new DbDirectoryInfo[0];
+                 if(dir.charAt(dir.length() - 1) != '/') dir += "/"; // FIXME:
+                 for(int i = 0; i < dirS.length; i++) {
+                         out.writeLine("GET DB_INSTRUMENT_DIRECTORY INFO '" + conv(dir + dirS[i]) + "'");
+                 }
+                 if(getPrintOnlyMode()) return null;
+                 if(dir.length() > 1) dir = dir.substring(0, dir.length() - 1);
+                 StringBuffer sb = new StringBuffer();
+                 DbDirectoryInfo[] infoS = new DbDirectoryInfo[dirS.length];
+                 for(int i = 0; i < dirS.length; i++) {
+                         try {
+                                 ResultSet rs = getMultiLineResultSet();
+                                 infoS[i] = new DbDirectoryInfo(rs.getMultiLineResult());
+                                 infoS[i].setName(dirS[i]);
+                                 infoS[i].setParentDirectoryPath(dir);
+                         } catch (SocketTimeoutException e) {
+                                 getLogger().log(Level.FINE, e.getMessage(), e);
+                                 sb.append(e.getMessage()).append("\n");
+                                 break;
+                         } catch (Exception e) {
+                                 getLogger().log(Level.FINE, e.getMessage(), e);
+                                 sb.append(e.getMessage()).append("\n");
+                         }
+                 }
+                 String details = sb.toString();
+                 if(details.length() > 0) {
+                         String err = LscpI18n.getLogMsg("Client.getInstrsInfoFailed!");
+                         throw new LSException(0, err, details);
+                 }
+                 return infoS;
+         }*/
+         /**
+          * Renames the specified directory.
+          * @param dir The absolute path name of the directory to rename.
+          * @param name The new name for the directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the renaming of the directory failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         renameDbDirectory(String dir, String name) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 name = toEscapedText(name);
+                 out.writeLine("SET DB_INSTRUMENT_DIRECTORY NAME '" + conv(dir) + "' '" + conv(name) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Moves the specified directory into the specified location.
+          * @param dir The absolute path name of the directory to move.
+          * @param dst The location where the directory will be moved to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         moveDbDirectory(String dir, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 out.writeLine("MOVE DB_INSTRUMENT_DIRECTORY '" + conv(dir) + "' '" + conv(dst) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Moves the specified directories into the specified location.
+          * @param dirs The absolute path names of the directories to move.
+          * @param dst The location where the directories will be moved to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         moveDbDirectories(String dirs[], String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 for(String s : dirs) {
+                         out.writeLine("MOVE DB_INSTRUMENT_DIRECTORY '" + conv(s) + "' '" + conv(dst) + "'");
+                 }
+                 if(getPrintOnlyMode()) return;
+                 getEmptyResultSets(dirs.length, "Client.dirMovingFailed!");
+         }
+         /**
+          * Copies the specified directory into the specified location.
+          * @param dir The absolute path name of the directory to copy.
+          * @param dst The location where the directory will be copied to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         copyDbDirectory(String dir, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 out.writeLine("COPY DB_INSTRUMENT_DIRECTORY '" + conv(dir) + "' '" + conv(dst) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Copies the specified directories into the specified location.
+          * @param dirs The absolute path names of the directories to copy.
+          * @param dst The location where the directories will be copied to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         copyDbDirectories(String[] dirs, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 for(String s : dirs) {
+                         out.writeLine("COPY DB_INSTRUMENT_DIRECTORY '" + conv(s) + "' '" + conv(dst) + "'");
+                 }
+                 if(getPrintOnlyMode()) return;
+                 getEmptyResultSets(dirs.length, "Client.dirCopyingFailed!");
+         }
+         /**
+          * Changes the description of the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @param desc The new description for the directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If failed to change the description.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         setDbDirectoryDescription(String dir, String desc)
+                                 throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 String s = "SET DB_INSTRUMENT_DIRECTORY DESCRIPTION '";
+                 out.writeLine(s + conv(dir) + "' '" + toEscapedText(desc) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         public static enum ScanMode {
+                 RECURSIVE, NON_RECURSIVE, FLAT
+         }
+         /**
+          * Adds the specified instrument to the specified instruments database directory.
+          * @param dbDir The absolute path name of the database directory in which the
+          * specified instrument will be added.
+          * @param filePath The absolute path name of the instrument file.
+          * @param instrIndex The index of the instrument (in the given instrument file) to add.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         addDbInstrument(String dbDir, String filePath, int instrIndex)
+                                         throws IOException, LSException, LscpException {
+                 addDbInstrument(dbDir, filePath, instrIndex, false);
+         }
+         /**
+          * Adds the specified instrument to the specified instruments database directory.
+          * @param dbDir The absolute path name of the database directory in which the
+          * specified instrument will be added.
+          * @param filePath The absolute path name of the instrument file.
+          * @param instrIndex The index of the instrument (in the given instrument file) to add.
+          * @param background If <code>true</code>, the scan will be done
+          * in background and this method may return before the job is finished.
+          * @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
+         addDbInstrument(String dbDir, String filePath, int instrIndex, boolean background)
+                                         throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 String s = "ADD DB_INSTRUMENTS";
+                 if(background) s += " NON_MODAL";
+                 s += " '" + conv(dbDir) + "' '" + conv(filePath) + "' ";
+                 out.writeLine(s + String.valueOf(instrIndex));
+                 if(getPrintOnlyMode()) return -1;
+                 ResultSet rs = getEmptyResultSet();
+                 return rs.getIndex();
+         }
+         /**
+          * Adds the instruments in the specified file to the specified
+          * instruments database directory.
+          * @param dbDir The absolute path name of the database directory
+          * in which the the supported instruments will be added.
+          * @param filePath The absolute path name of the file to scan for instruments.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         addDbInstruments(String dbDir, String filePath)
+                                         throws IOException, LSException, LscpException {
+                 addDbInstruments(dbDir, filePath, false);
+         }
+         /**
+          * Adds the instruments in the specified file to the specified
+          * instruments database directory.
+          * @param dbDir The absolute path name of the database directory
+          * in which the the supported instruments will be added.
+          * @param filePath The absolute path name of the file to scan for instruments.
+          * @param background If <code>true</code>, the scan will be done
+          * in background and this method may return before the job is finished.
+          * @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(String dbDir, String filePath, boolean background)
+                                         throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 String s = "ADD DB_INSTRUMENTS";
+                 if(background) s += " NON_MODAL";
+                 out.writeLine(s + " '" + conv(dbDir) + "' '" + conv(filePath) + "'");
+                 if(getPrintOnlyMode()) return -1;
+                 ResultSet rs = getEmptyResultSet();
+                 return rs.getIndex();
+         }
+         /**
+          * 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.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         addDbInstruments(ScanMode mode, String dbDir, String fsDir)
+                                         throws IOException, LSException, LscpException {
+                 addDbInstruments(mode, dbDir, fsDir, 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.
+          * @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)
+                                         throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 StringBuffer sb = new StringBuffer("ADD DB_INSTRUMENTS");
+                 if(background) sb.append(" NON_MODAL");
+                 switch(mode) {
+                         case RECURSIVE:
+                                 sb.append(" RECURSIVE");
+                                 break;
+                         case NON_RECURSIVE:
+                                 sb.append(" NON_RECURSIVE");
+                                 break;
+                         case FLAT:
+                                 sb.append(" FLAT");
+                                 break;
+                 }
+                 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.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the removing of the instrument failed.
+          */
+         public synchronized void
+         removeDbInstrument(String instr) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("REMOVE DB_INSTRUMENT '" + conv(instr) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Removes the specified instruments from the instruments database.
+          * @param instrs The absolute path names of the instruments to remove.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the removing of the instruments failed.
+          */
+         public synchronized void
+         removeDbInstruments(String[] instrs) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 for(String s : instrs) {
+                         out.writeLine("REMOVE DB_INSTRUMENT '" + conv(s) + "'");
+                 }
+                 if(getPrintOnlyMode()) return;
+                 getEmptyResultSets(instrs.length, "Client.instrDeletionFailed!");
+         }
+         /**
+          * Gets the number of instruments in the specified directory.
+          * @return The current number of instruments in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @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
+         getDbInstrumentCount(String dir) throws IOException, LscpException, LSException {
+                 return getDbInstrumentCount(dir, false);
+         }
+         /**
+          * Gets the number of instruments in the specified directory.
+          * @return The current number of instruments in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @param recursive If <code>true</code>, the number of all instruments
+          * in the specified subtree will be returned.
+          * @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
+         getDbInstrumentCount(String dir, boolean recursive)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 String s;
+                 if(recursive) s = "GET DB_INSTRUMENTS RECURSIVE '";
+                 else s = "GET DB_INSTRUMENTS '";
+                 out.writeLine(s + conv(dir) + "'");
+                 if(getPrintOnlyMode()) return -1;
+                 s = getSingleLineResultSet().getResult();
+                 return parseInt(s);
+         }
+         /**
+          * Gets the list of instruments in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>String</code> array providing the names of
+          * all instruments in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized String[]
+         getDbInstrumentNames(String dir) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("LIST DB_INSTRUMENTS '" + conv(dir) + "'");
+                 if(getPrintOnlyMode()) return null;
+                 String[] names = parseEscapedStringList(getSingleLineResultSet().getResult());
+                 for(int i = 0; i < names.length; i++) {
+                         names[i] = toNonEscapedString(names[i]);
+                 }
+                 return names;
+         }
+         /**
+          * Gets information about the specified instrument.
+          * @param instr The absolute path name of the instrument.
+          * @return A <code>DbInstrumentInfo</code> instance providing information
+          * about the specified instrument.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified instrument is not found.
+          */
+         public synchronized DbInstrumentInfo
+         getDbInstrumentInfo(String instr) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("GET DB_INSTRUMENT INFO '" + conv(instr) + "'");
+                 if(getPrintOnlyMode()) return null;
+                 ResultSet rs = getMultiLineResultSet();
+                 DbInstrumentInfo info = new DbInstrumentInfo(rs.getMultiLineResult());
+                 String s = getParentDirectory(instr);
+                 if(s != null) info.setDirectoryPath(s);
+                 s = getFileName(instr);
+                 if(s != null) info.setName(toNonEscapedFileName(s));
+                 return info;
+         }
+         /**
+          * Gets the list of instruments in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>DbInstrumentInfo</code> array providing
+          * information about all instruments in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized DbInstrumentInfo[]
+         getDbInstruments(String dir) throws IOException, LscpException, LSException {
+                 String[] instrS = getDbInstrumentNames(dir);
+                 if(!hasEndingFileSeparator(dir)) dir += "/";
+                 DbInstrumentInfo[] infoS = new DbInstrumentInfo[instrS.length];
+                 for(int i = 0; i < instrS.length; i++) {
+                         infoS[i] = getDbInstrumentInfo(conv(dir) + toEscapedFsEntry(instrS[i]));
+                 }
+                 return infoS;
+         }
+         /**
+          * Gets the list of instruments in the specified directory.
+          * @param dir The absolute path name of the directory.
+          * @return A <code>DbInstrumentInfo</code> array providing
+          * information about all instruments in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          *
+         public synchronized DbInstrumentInfo[]
+         getDbInstruments(String dir) throws IOException, LscpException, LSException {
+                 String[] instrS = getDbInstrumentNames(dir);
+                 if(instrS.length == 0) return new DbInstrumentInfo[0];
+                 if(dir.charAt(dir.length() - 1) != '/') dir += "/"; FIXME:
+                 for(int i = 0; i < instrS.length; i++) {
+                         out.writeLine("GET DB_INSTRUMENT INFO '" + conv(dir) + instrS[i] + "'");
+                 }
+                 if(getPrintOnlyMode()) return null;
+                 if(dir.length() > 1) dir = dir.substring(0, dir.length() - 1);
+                 StringBuffer sb = new StringBuffer();
+                 DbInstrumentInfo[] infoS = new DbInstrumentInfo[instrS.length];
+                 for(int i = 0; i < instrS.length; i++) {
+                         try {
+                                 ResultSet rs = getMultiLineResultSet();
+                                 infoS[i] = new DbInstrumentInfo(rs.getMultiLineResult());
+                                 infoS[i].setName(instrS[i]);
+                                 infoS[i].setDirectoryPath(dir);
+                         } catch (SocketTimeoutException e) {
+                                 getLogger().log(Level.FINE, e.getMessage(), e);
+                                 sb.append(e.getMessage()).append("\n");
+                                 break;
+                         } catch (Exception e) {
+                                 getLogger().log(Level.FINE, e.getMessage(), e);
+                                 sb.append(e.getMessage()).append("\n");
+                         }
+                 }
+                 String details = sb.toString();
+                 if(details.length() > 0) {
+                         String err = LscpI18n.getLogMsg("Client.getInstrsInfoFailed!");
+                         throw new LSException(0, err, details);
+                 }
+                 return infoS;
+         }*/
+         /**
+          * Renames the specified instrument.
+          * @param instr The absolute path name of the instrument to rename.
+          * @param name The new name for the instrument.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the renaming of the instrument failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         renameDbInstrument(String instr, String name)
+                                 throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 name = toEscapedText(name);
+                 out.writeLine("SET DB_INSTRUMENT NAME '" + conv(instr) + "' '" + conv(name) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Moves the specified instrument into the specified location.
+          * @param instr The absolute path name of the instrument to move.
+          * @param dst The directory where the specified instrument will be moved to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         moveDbInstrument(String instr, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 out.writeLine("MOVE DB_INSTRUMENT '" + conv(instr) + "' '" + conv(dst) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Moves the specified instruments into the specified location.
+          * @param instrs The absolute path names of the instruments to move.
+          * @param dst The directory where the specified instruments will be moved to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         moveDbInstruments(String[] instrs, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 for(String s : instrs) {
+                         out.writeLine("MOVE DB_INSTRUMENT '" + conv(s) + "' '" + conv(dst) + "'");
+                 }
+                 if(getPrintOnlyMode()) return;
+                 getEmptyResultSets(instrs.length, "Client.instrMovingFailed!");
+         }
+         /**
+          * Copies the specified instrument into the specified location.
+          * @param instr The absolute path name of the instrument to copy.
+          * @param dst The directory where the specified instrument will be copied to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         copyDbInstrument(String instr, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 out.writeLine("COPY DB_INSTRUMENT '" + conv(instr) + "' '" + conv(dst) + "'");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
+          * Copies the specified instruments into the specified location.
+          * @param instrs The absolute path name of the instruments to copy.
+          * @param dst The directory where the specified instruments will be copied to.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If the operation failed.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         copyDbInstruments(String[] instrs, String dst) throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 for(String s : instrs) {
+                         out.writeLine("COPY DB_INSTRUMENT '" + conv(s) + "' '" + conv(dst) + "'");
+                 }
+                 if(getPrintOnlyMode()) return;
+                 getEmptyResultSets(instrs.length, "Client.instrCopyingFailed!");
+         }
+         /**
+          * Changes the description of the specified instrument.
+          * @param instr The absolute path name of the instrument.
+          * @param desc The new description for the instrument.
+          * @throws IOException If some I/O error occurs.
+          * @throws LSException If failed to change the description.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          */
+         public synchronized void
+         setDbInstrumentDescription(String instr, String desc)
+                                 throws IOException, LSException, LscpException {
+                 verifyConnection();
+                 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();
+         }
+         /**
+          * Finds all directories in the specified directory
+          * that corresponds to the specified search criterias.
+          * @param dir The absolute path name of the directory to search.
+          * @param query Provides the search criterias.
+          * @return A <code>DbDirectoryInfo</code> array providing
+          * information about all directories that are found in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized DbDirectoryInfo[]
+         findDbDirectories(String dir, DbSearchQuery query)
+                                 throws IOException, LscpException, LSException {
+                 return findDbDirectories(dir, query, false);
+         }
+         /**
+          * Finds all directories in the specified directory
+          * that corresponds to the specified search criterias.
+          * @param dir The absolute path name of the directory to search.
+          * @param query Provides the search criterias.
+          * @param nonRecursive If <code>true</code>, the search will be non-recursive.
+          * @return A <code>DbDirectoryInfo</code> array providing
+          * information about all directories that are found in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized DbDirectoryInfo[]
+         findDbDirectories(String dir, DbSearchQuery query, boolean nonRecursive)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 StringBuffer sb = new StringBuffer();
+                 sb.append("FIND DB_INSTRUMENT_DIRECTORIES");
+                 if(nonRecursive) sb.append(" NON_RECURSIVE");
+                 sb.append(" '").append(conv(dir)).append("'");
+                 if(query.name != null && query.name.length() > 0) {
+                         sb.append(" NAME='").append(toEscapedText(query.name)).append("'");
+                 }
+                 String s = query.getCreatedAfter();
+                 String s2 = query.getCreatedBefore();
+                 if(s != null || s2 != null) {
+                         sb.append(" CREATED='");
+                         if(s != null) sb.append(s);
+                         sb.append("..");
+                         if(s2 != null) sb.append(s2);
+                         sb.append("'");
+                 }
+                 s = query.getModifiedAfter();
+                 s2 = query.getModifiedBefore();
+                 if(s != null || s2 != null) {
+                         sb.append(" MODIFIED='");
+                         if(s != null) sb.append(s);
+                         sb.append("..");
+                         if(s2 != null) sb.append(s2);
+                         sb.append("'");
+                 }
+                 if(query.description != null && query.description.length() > 0) {
+                         sb.append(" DESCRIPTION='");
+                         sb.append(toEscapedText(query.description)).append("'");
+                 }
+                 out.writeLine(sb.toString());
+                 if(getPrintOnlyMode()) return null;
+                 String[] dirS = parseEscapedStringList(getSingleLineResultSet().getResult());
+                 DbDirectoryInfo[] infoS = new DbDirectoryInfo[dirS.length];
+                 for(int i = 0; i < dirS.length; i++) {
+                         infoS[i] = getDbDirectoryInfo(dirS[i]);
+                 }
+                 return infoS;
+         }
+         /**
+          * Finds all instruments in the specified directory
+          * that corresponds to the specified search criterias.
+          * @param dir The absolute path name of the directory to search.
+          * @param query Provides the search criterias.
+          * @return A <code>DbInstrumentInfo</code> array providing
+          * information about all instruments that are found in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized DbInstrumentInfo[]
+         findDbInstruments(String dir, DbSearchQuery query)
+                                 throws IOException, LscpException, LSException {
+                 return findDbInstruments(dir, query, false);
+         }
+         /**
+          * Finds all instruments in the specified directory
+          * that corresponds to the specified search criterias.
+          * @param dir The absolute path name of the directory to search.
+          * @param query Provides the search criterias.
+          * @param nonRecursive If <code>true</code>, the search will be non-recursive.
+          * @return A <code>DbInstrumentInfo</code> array providing
+          * information about all instruments that are found in the specified directory.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified path name is invalid.
+          */
+         public synchronized DbInstrumentInfo[]
+         findDbInstruments(String dir, DbSearchQuery query, boolean nonRecursive)
+                                 throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 StringBuffer sb = new StringBuffer();
+                 sb.append("FIND DB_INSTRUMENTS");
+                 if(nonRecursive) sb.append(" NON_RECURSIVE");
+                 sb.append(" '").append(conv(dir)).append("'");
+                 if(query.name != null && query.name.length() > 0) {
+                         sb.append(" NAME='").append(toEscapedText(query.name)).append("'");
+                 }
+                 if(query.formatFamilies.size() > 0) {
+                         sb.append(" FORMAT_FAMILIES='").append(query.formatFamilies.get(0));
+                         for(int i = 1; i < query.formatFamilies.size(); i++) {
+                                 sb.append(',').append(query.formatFamilies.get(i));
+                         }
+                         sb.append("'");
+                 }
+                 if(query.minSize != -1 || query.maxSize != -1) {
+                         sb.append(" SIZE='");
+                         if(query.minSize != -1) sb.append(query.minSize);
+                         sb.append("..");
+                         if(query.maxSize != -1) sb.append(query.maxSize);
+                         sb.append("'");
+                 }
+                 String s = query.getCreatedAfter();
+                 String s2 = query.getCreatedBefore();
+                 if(s != null || s2 != null) {
+                         sb.append(" CREATED='");
+                         if(s != null) sb.append(s);
+                         sb.append("..");
+                         if(s2 != null) sb.append(s2);
+                         sb.append("'");
+                 }
+                 s = query.getModifiedAfter();
+                 s2 = query.getModifiedBefore();
+                 if(s != null || s2 != null) {
+                         sb.append(" MODIFIED='");
+                         if(s != null) sb.append(s);
+                         sb.append("..");
+                         if(s2 != null) sb.append(s2);
+                         sb.append("'");
+                 }
+                 if(query.description != null && query.description.length() > 0) {
+                         sb.append(" DESCRIPTION='");
+                         sb.append(toEscapedText(query.description)).append("'");
+                 }
+                 if(query.instrumentType != DbSearchQuery.InstrumentType.BOTH) {
+                         sb.append(" IS_DRUM=");
+                         if(query.instrumentType == DbSearchQuery.InstrumentType.DRUM) {
+                                 sb.append("'true'");
+                         } else {
+                                 sb.append("'false'");
+                         }
+                 }
+                 if(query.product != null && query.product.length() > 0) {
+                         sb.append(" PRODUCT='").append(toEscapedText(query.product)).append("'");
+                 }
+                 if(query.artists != null && query.artists.length() > 0) {
+                         sb.append(" ARTISTS='").append(toEscapedText(query.artists)).append("'");
+                 }
+                 if(query.keywords != null && query.keywords.length() > 0) {
+                         sb.append(" KEYWORDS='");
+                         sb.append(toEscapedText(query.keywords)).append("'");
+                 }
+                 out.writeLine(sb.toString());
+                 if(getPrintOnlyMode()) return null;
+                 String[] instrS = parseEscapedStringList(getSingleLineResultSet().getResult());
+                 DbInstrumentInfo[] infoS = new DbInstrumentInfo[instrS.length];
+                 for(int i = 0; i < instrS.length; i++) {
+                         infoS[i] = getDbInstrumentInfo(instrS[i]);
+                 }
+                 return infoS;
+         }
+         /**
+          * 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
+          * about the specified job.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the specified job is not found.
+          */
+         public synchronized ScanJobInfo
+         getDbInstrumentsJobInfo(int jobId) throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("GET DB_INSTRUMENTS_JOB INFO " + String.valueOf(jobId));
+                 if(getPrintOnlyMode()) return null;
+                 ResultSet rs = getMultiLineResultSet();
+                 ScanJobInfo info = new ScanJobInfo(rs.getMultiLineResult());
+                 return info;
+         }
+         /**
+          * Removes all instruments and directories and re-creates
+          * the instruments database structure.
+          * @throws IOException If some I/O error occurs.
+          * @throws LscpException If LSCP protocol corruption occurs.
+          * @throws LSException If the formatting of the instruments database failed.
+          */
+         public synchronized void
+         formatInstrumentsDb() throws IOException, LscpException, LSException {
+                 verifyConnection();
+                 out.writeLine("FORMAT INSTRUMENTS_DB");
+                 if(getPrintOnlyMode()) return;
+                 ResultSet rs = getEmptyResultSet();
+         }
+         /**
           * Resets the specified sampler channel.
           *
           * @param samplerChn The sampler channel number.
-Line 3604 
 public class Client {
+Line 5156 
 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 3693 
 public class Client {
+Line 5262 
 public class Client {
          }
          /**
+          * 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();
+                 for(int i = 0; i < count; i++) {
+                         try { getEmptyResultSet(); }
+                         catch (SocketTimeoutException e) {
+                                 getLogger().log(Level.FINE, e.getMessage(), e);
+                                 sb.append(e.getMessage()).append("\n");
+                                 break;
+                         } catch (Exception e) {
+                                 getLogger().log(Level.FINE, e.getMessage(), e);
+                                 sb.append(e.getMessage()).append("\n");
+                         }
+                 }
+                 String details = sb.toString();
+                 if(details.length() > 0) {
+                         String s = LscpI18n.getLogMsg(err);
+                         throw new LSException(0, s, details);
+                 }
+         }
+         /**
           * Returns the logger for this library.
           * @return The logger for this library.
           */

 Legend:



Removed from v.1139
 


changed lines


 
Added in v.1766
 Legend:



Removed from v.1139
 


changed lines


 
Added in v.1766
-Removed from v.1139
+Added in v.1766

	ViewVC Help
Powered by ViewVC