org/jsampler/DefaultLSConsoleModel.java

/*
 *   JSampler - a java front-end for LinuxSampler
 *
 *   Copyright (C) 2005-2008 Grigor Iliev <grigor@grigoriliev.com>
 *
 *   This file is part of JSampler.
 *
 *   JSampler is free software; you can redistribute it and/or modify
 *   it under the terms of the GNU General Public License version 2
 *   as published by the Free Software Foundation.
 *
 *   JSampler is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *   GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with JSampler; if not, write to the Free Software
 *   Foundation, Inc., 59 Temple Place, Suite 330, Boston,
 *   MA  02111-1307  USA
 */

package org.jsampler;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import java.io.InputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;

import java.net.Socket;

import java.util.LinkedList;
import java.util.Vector;

import java.util.logging.Level;

import javax.swing.SwingUtilities;

import net.sf.juife.event.TaskEvent;
import net.sf.juife.event.TaskListener;

import org.jsampler.event.LSConsoleEvent;
import org.jsampler.event.LSConsoleListener;

import org.jsampler.task.LSConsoleConnect;

import static org.jsampler.JSI18n.i18n;


/**
 * This class provides default implementation of the <code>LSConsoleModel</code> interface.
 * @author Grigor Iliev
 */
public class DefaultLSConsoleModel implements LSConsoleModel {
        private Socket socket;
        private LscpOutputStream out;
        
        private final String[] cmdList = LscpUtils.getCommandList();
        
        private String cmdLine = "";
        
        /**
         * Contains the global command history, excluding blank lines and comments.
         */
        private final LinkedList<String> cmdHistory = new LinkedList<String>();
        
        private int cmdHistoryIdx = -1;
        
        private int commandHistorySize = 1000;
        
        private final LSConsoleThread lsConsoleThread = new LSConsoleThread();
        
        /**
         * Contains the command history of the current
         * session, including blank lines and comments.
         */
        private final Vector<String> sessionHistory = new Vector<String>();
        
        /** Used to hold the current command when browsing through command history, etc. */
        private String currentCmd = "";
        
        private final Vector<LSConsoleListener> listeners = new Vector<LSConsoleListener>();
        
        
        /** Creates a new instance of <code>DefaultLSConsoleModel</code>. */
        public
        DefaultLSConsoleModel() {
                CC.addReconnectListener(new ActionListener() {
                        public void
                        actionPerformed(ActionEvent e) { reconnect(); }
                });
                
                lsConsoleThread.start();
        }
        
        private Socket
        getSocket() { return socket; }
        
        private void
        setSocket(Socket socket) { this.socket = socket; }
        
        private void
        reconnect() {
                final LSConsoleConnect cnt = new LSConsoleConnect(getSocket());
                
                cnt.addTaskListener(new TaskListener() {
                        public void
                        taskPerformed(TaskEvent e) { changeSocket(cnt.getResult()); }
                });
                
                CC.getTaskQueue().add(cnt);
        }
        
        public void
        disconnect() {
                try { if(getSocket() != null) getSocket().close(); }
                catch(Exception x) { CC.getLogger().info(HF.getErrorMessage(x)); }
        }
        
        private void
        changeSocket(Socket sock) {
                setSocket(sock);
                
                try {
                        LscpInputStream in;
                        in = sock == null ? null : new LscpInputStream(sock.getInputStream());
                        out = sock == null ? null : new LscpOutputStream(sock.getOutputStream());
                        
                        lsConsoleThread.setInputStream(in);
                } catch(Exception x) { CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x); }
        }
        
        /**
         * Registers the specified listener for receiving event messages.
         * @param l The <code>LSConsoleListener</code> to register.
         */
        @Override
        public void
        addLSConsoleListener(LSConsoleListener l) { listeners.add(l); }
        
        /**
         * Removes the specified listener.
         * @param l The <code>LSConsoleListener</code> to remove.
         */
        @Override
        public void
        removeLSConsoleListener(LSConsoleListener l) { listeners.remove(l); }
        
        /** Executes the command specified in the command line. */
        @Override
        public void
        execCommand() {
                String cmd = getCommandLineText();
                sessionHistory.add(cmd);
                if(cmd.trim().length() > 0 && !cmd.startsWith("#")) addToCommandHistory(cmd);
                while(cmdHistory.size() > getCommandHistorySize()) cmdHistory.removeFirst();
                
                setCommandLineText("");
                currentCmd = "";
                cmdHistoryIdx = -1;
                
                if( getSocket() == null || getSocket().isClosed() || !getSocket().isConnected() 
                        || getSocket().isOutputShutdown() || out == null ) {
                        
                        fireResponseReceived(i18n.getMessage("DefaultLSConsoleModel.notConnected"));
                } else {
                        CC.getTaskQueue().add(new LSConsoleExecCommand(cmd));
                }
                
                fireCommandExecuted();
        }
        
        /**
         * Gets the last executed command.
         * @return The last command executed in the LS Console.
         */
        @Override
        public String
        getLastExecutedCommand() {
                int size = sessionHistory.size();
                return size == 0 ? "" : sessionHistory.get(size - 1);
        }
        
        /**
         * Sets the text in the command line.
         * @param cmdLine The new command line text.
         */
        @Override
        public void
        setCommandLineText(String cmdLine) {
                if(this.cmdLine.equals(cmdLine)) return;
                
                String oldCmdLine = this.cmdLine;
                this.cmdLine = cmdLine;
                fireCommandLineTextChanged(oldCmdLine);
        }
        
        /**
         * Gets the text in the command line.
         * @return The command line's text.
         */
        @Override
        public String
        getCommandLineText() { return cmdLine; }
        
        /**
         * Gets the command history of the current session, including blank lines and comments.
         * @return The command history of the current session, including blank lines and comments.
         */
        @Override
        public String[]
        getSessionHistory() {
                return sessionHistory.toArray(new String[sessionHistory.size()]);
        }
        
        /**
         * Clears the session history.
         * @see #getSessionHistory
         */
        @Override
        public void
        clearSessionHistory() { sessionHistory.removeAllElements(); }
        
        /**
         * Adds the specified <code>command</code> to command history.
         * @param command The command to be added to command history.
         */
        @Override
        public void
        addToCommandHistory(String command) { cmdHistory.add(command); }
        
        /**
         * Gets the complete command history, excluding blank lines and comments.
         * @return The complete command history, excluding blank lines and comments.
         */
        @Override
        public String[]
        getCommandHistory() {
                return cmdHistory.toArray(new String[cmdHistory.size()]);
        }
        
        /**
         * Clears the complete/multisession command history.
         * @see #getCommandHistory
         */
        @Override
        public void
        clearCommandHistory() {
                cmdHistory.clear();
                cmdHistoryIdx = -1;
        }
        
        /**
         * Determines the maximum number of lines to be kept in the command history.
         * @return The maximum number of lines to be kept in the command history.
         */
        @Override
        public int
        getCommandHistorySize() { return commandHistorySize; }
        
        /**
         * Sets the maximum number of lines to be kept in the command history.
         * @param size Determines the maximum number of lines to be kept in the command history.
         */
        @Override
        public void
        setCommandHistorySize(int size) { commandHistorySize = size; }
        
        /**
         * Gets a list of all LSCP commands.
         * @return A list of all LSCP commands.
         */
        @Override
        public String[]
        getCommandList() { return cmdList; }
        
        /** Browses the command history one line up. */
        @Override
        public void
        browseCommandHistoryUp() {
                if(cmdHistory.size() == 0) return;
                        
                if(cmdHistoryIdx == -1) {
                        currentCmd = getCommandLineText();
                        cmdHistoryIdx = cmdHistory.size() - 1;
                        setCommandLineText(cmdHistory.get(cmdHistoryIdx));
                        return;
                }
                
                if(cmdHistoryIdx == 0) return;
                
                setCommandLineText(cmdHistory.get(--cmdHistoryIdx));
        }
        
        /** Browses the command history one line down. */
        @Override
        public void
        browseCommandHistoryDown() {
                if(cmdHistory.size() == 0 || cmdHistoryIdx == -1) return;
                if(cmdHistoryIdx == cmdHistory.size() - 1) {
                        cmdHistoryIdx = -1;
                        setCommandLineText(currentCmd);
                        currentCmd = "";
                        return;
                }
                
                setCommandLineText(cmdHistory.get(++cmdHistoryIdx));
        }
        
        /** Browses to the first line of the command history. */
        @Override
        public void
        browseCommandHistoryFirst() {
                if(cmdHistory.size() == 0) return;
                cmdHistoryIdx = 0;
                setCommandLineText(cmdHistory.get(cmdHistoryIdx));
        }
        
        /** Browses to the last line of the command history. */
        @Override
        public void
        browseCommandHistoryLast() {
                if(cmdHistory.size() == 0) return;
                cmdHistoryIdx = cmdHistory.size() - 1;
                setCommandLineText(cmdHistory.get(cmdHistoryIdx));
        }
        
        private Vector<String> tmpVector = new Vector<String>();
        
        /**
         * Searches the command history for commands
         * containing the string returned by {@link #getCommandLineText}.
         * @return All commands that contains the string returned by {@link #getCommandLineText}.
         * @see #getCommandHistory
         */
        @Override
        public String[]
        searchCommandHistory() { return searchCommandHistory(getCommandLineText()); }
        
        /**
         * Searches the command history for commands containing <code>substring</code>.
         * @param substring The substring to be used to perform the search.
         * @return All commands that contains <code>substring</code>.
         * @see #getCommandList
         */
        @Override
        public String[]
        searchCommandHistory(String substring) {
                tmpVector.removeAllElements();
                for(String s : cmdHistory) if(s.indexOf(substring) != -1) tmpVector.add(s);
                
                return tmpVector.toArray(new String[tmpVector.size()]);
        }
        
        /**
         * Searches the LSCP command list for commands
         * containing the string returned by {@link #getCommandLineText}.
         * @return All commands that contains the string returned by {@link #getCommandLineText}.
         * @see #getCommandList
         */
        @Override
        public String[]
        searchCommandList() { return searchCommandList(getCommandLineText()); }
        
        /**
         * Searches the LSCP command list for commands containing <code>substring</code>.
         * @param substring The substring to be used to perform the search.
         * @return All commands that contains <code>substring</code>.
         * @see #getCommandList
         */
        @Override
        public String[]
        searchCommandList(String substring) {
                tmpVector.removeAllElements();
                for(String s : cmdList) if(s.indexOf(substring) != -1) tmpVector.add(s);
                
                return tmpVector.toArray(new String[tmpVector.size()]);
        }
        
        @Override
        public void
        quit() { disconnect(); }
        
        /** Notifies listeners that the text in the command line has changed. */
        private void
        fireCommandLineTextChanged(String oldCmdLine) {
                LSConsoleEvent e = new LSConsoleEvent(this, null, oldCmdLine);
                for(LSConsoleListener l : listeners) l.commandLineTextChanged(e);
        }
        
        /** Notifies listeners that the command in the command line has been executed. */
        private void
        fireCommandExecuted() {
                LSConsoleEvent e = new LSConsoleEvent(this);
                for(LSConsoleListener l : listeners) l.commandExecuted(e);
        }
        
        /**
         * Notifies listeners that response is received from LinuxSampler.
         * @param response The response received from LinuxSampler.
         */
        private void
        fireResponseReceived(final String response) {
                SwingUtilities.invokeLater(new Runnable() {
                        public void
                        run() {
                                LSConsoleEvent e = new LSConsoleEvent(this, response);
                                for(LSConsoleListener l : listeners) l.responseReceived(e);
                        }
                });
        }
        
        /** Executes LS Console command. */
        private class LSConsoleExecCommand extends org.jsampler.task.EnhancedTask {
                private String cmd;
                
                /** Creates a new instance of <code>LSConsoleExecCommand</code>. */
                public
                LSConsoleExecCommand(String cmd) {
                        setTitle("LSConsoleExecCommand_task");
                        setDescription(i18n.getMessage("LSConsoleExecCommand.description"));
                        this.cmd = cmd;
                }
        
                /** The entry point of the task. */
                public void
                exec() throws Exception { out.writeLine(cmd); }
        }

        class LSConsoleThread extends Thread {
                LscpInputStream in;
                private boolean terminate = false;
                
                LSConsoleThread() {super("LS-Console-Thread"); }
                
                @Override
                public void
                run() {
                        while(!mustTerminate()) {
                                try { processInput(); }
                                catch(Exception x) {
                                        CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x);
                                }
                                
                                try { synchronized(this) { wait(100); } }
                                catch(Exception x) {
                                        CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x);
                                }
                        }
                }
        
                private synchronized boolean
                mustTerminate() { return terminate; }
                
                public synchronized void
                terminate() {
                        terminate = true;
                        this.notifyAll();
                }
                
                /** Processes the input sent by LinuxSampler */
                private synchronized void
                processInput() throws IOException {
                        while(in != null && in.available() > 0) {
                                String response = in.readLine();
                                fireResponseReceived(response); 
                        }
                }
                
                public synchronized void
                setInputStream(LscpInputStream in) { this.in = in; }
        }
        
        class LscpInputStream {
                private InputStream in;
                private StringBuffer buf = new StringBuffer();
                
                /**
                 * Creates a new instance of LscpInputStream.
                 *
                 */
                public
                LscpInputStream(InputStream in) {
                        this.in = in;
                }
        
                /**
                 * Reads a line. 
                 * This method is thread safe.
                 * 
                 * @return A string containing the next line readed from the stream or
                 * <code>null</code> if the end of the stream has been reached.
                 * @throws IOException If an I/O error occurs.
                 */
                public synchronized String
                readLine() throws IOException {
                        int i;
                        buf.setLength(0);
                
                        while((i = in.read()) != -1) {
                                if(i == '\r') {
                                        checkLF();
                                        break;
                                }
                                buf.append((char)i);
                        }
                
                        if(i == -1) {
                                if(buf.length() > 0)
                                        throw new IOException("Unexpected end of line!");
                                return null;
                        }
                        return buf.toString();
                }
        
                /**
                 * Returns the number of bytes that can
                 * be read from this input stream without blocking.
                 *
                 * @return The number of bytes that can
                 * be read from this input stream without blocking.
                 * @throws IOException If an I/O error occurs.
                 */
                public synchronized int
                available() throws IOException { return in.available(); }
        
                private void
                checkLF() throws IOException {
                        int i = in.read();
                        if(i == -1) throw new IOException("Unexpected end of file!");
                        if(i != '\n') throw new IOException("Unexpected end of line!");
                }
        }
        
        class LscpOutputStream {
                private OutputStream out;
        
                /** Creates a new instance of LscpOutputStream */
                public
                LscpOutputStream(OutputStream out) { this.out = out; }
        
                /*
                 * Writes a line.
                 * @param line a string to be written.
                 */
                public void
                writeLine(String line) throws IOException {
                        try {
                                out.write(line.getBytes("US-ASCII"));
                                out.write('\r');
                                out.write('\n');
                                out.flush();
                        } catch(UnsupportedEncodingException x) { 
                                CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x);
                        }
                }
        }
}
1	/*
2	* JSampler - a java front-end for LinuxSampler
3	*
4	* Copyright (C) 2005-2008 Grigor Iliev <grigor@grigoriliev.com>
5	*
6	* This file is part of JSampler.
7	*
8	* JSampler is free software; you can redistribute it and/or modify
9	* it under the terms of the GNU General Public License version 2
10	* as published by the Free Software Foundation.
11	*
12	* JSampler is distributed in the hope that it will be useful,
13	* but WITHOUT ANY WARRANTY; without even the implied warranty of
14	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15	* GNU General Public License for more details.
16	*
17	* You should have received a copy of the GNU General Public License
18	* along with JSampler; if not, write to the Free Software
19	* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
20	* MA 02111-1307 USA
21	*/
22
23	package org.jsampler;
24
25	import java.awt.event.ActionEvent;
26	import java.awt.event.ActionListener;
27
28	import java.io.InputStream;
29	import java.io.IOException;
30	import java.io.OutputStream;
31	import java.io.UnsupportedEncodingException;
32
33	import java.net.Socket;
34
35	import java.util.LinkedList;
36	import java.util.Vector;
37
38	import java.util.logging.Level;
39
40	import javax.swing.SwingUtilities;
41
42	import net.sf.juife.event.TaskEvent;
43	import net.sf.juife.event.TaskListener;
44
45	import org.jsampler.event.LSConsoleEvent;
46	import org.jsampler.event.LSConsoleListener;
47
48	import org.jsampler.task.LSConsoleConnect;
49
50	import static org.jsampler.JSI18n.i18n;
51
52
53	/**
54	* This class provides default implementation of the <code>LSConsoleModel</code> interface.
55	* @author Grigor Iliev
56	*/
57	public class DefaultLSConsoleModel implements LSConsoleModel {
58	private Socket socket;
59	private LscpOutputStream out;
60
61	private final String[] cmdList = LscpUtils.getCommandList();
62
63	private String cmdLine = "";
64
65	/**
66	* Contains the global command history, excluding blank lines and comments.
67	*/
68	private final LinkedList<String> cmdHistory = new LinkedList<String>();
69
70	private int cmdHistoryIdx = -1;
71
72	private int commandHistorySize = 1000;
73
74	private final LSConsoleThread lsConsoleThread = new LSConsoleThread();
75
76	/**
77	* Contains the command history of the current
78	* session, including blank lines and comments.
79	*/
80	private final Vector<String> sessionHistory = new Vector<String>();
81
82	/** Used to hold the current command when browsing through command history, etc. */
83	private String currentCmd = "";
84
85	private final Vector<LSConsoleListener> listeners = new Vector<LSConsoleListener>();
86
87
88	/** Creates a new instance of <code>DefaultLSConsoleModel</code>. */
89	public
90	DefaultLSConsoleModel() {
91	CC.addReconnectListener(new ActionListener() {
92	public void
93	actionPerformed(ActionEvent e) { reconnect(); }
94	});
95
96	lsConsoleThread.start();
97	}
98
99	private Socket
100	getSocket() { return socket; }
101
102	private void
103	setSocket(Socket socket) { this.socket = socket; }
104
105	private void
106	reconnect() {
107	final LSConsoleConnect cnt = new LSConsoleConnect(getSocket());
108
109	cnt.addTaskListener(new TaskListener() {
110	public void
111	taskPerformed(TaskEvent e) { changeSocket(cnt.getResult()); }
112	});
113
114	CC.getTaskQueue().add(cnt);
115	}
116
117	public void
118	disconnect() {
119	try { if(getSocket() != null) getSocket().close(); }
120	catch(Exception x) { CC.getLogger().info(HF.getErrorMessage(x)); }
121	}
122
123	private void
124	changeSocket(Socket sock) {
125	setSocket(sock);
126
127	try {
128	LscpInputStream in;
129	in = sock == null ? null : new LscpInputStream(sock.getInputStream());
130	out = sock == null ? null : new LscpOutputStream(sock.getOutputStream());
131
132	lsConsoleThread.setInputStream(in);
133	} catch(Exception x) { CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x); }
134	}
135
136	/**
137	* Registers the specified listener for receiving event messages.
138	* @param l The <code>LSConsoleListener</code> to register.
139	*/
140	@Override
141	public void
142	addLSConsoleListener(LSConsoleListener l) { listeners.add(l); }
143
144	/**
145	* Removes the specified listener.
146	* @param l The <code>LSConsoleListener</code> to remove.
147	*/
148	@Override
149	public void
150	removeLSConsoleListener(LSConsoleListener l) { listeners.remove(l); }
151
152	/** Executes the command specified in the command line. */
153	@Override
154	public void
155	execCommand() {
156	String cmd = getCommandLineText();
157	sessionHistory.add(cmd);
158	if(cmd.trim().length() > 0 && !cmd.startsWith("#")) addToCommandHistory(cmd);
159	while(cmdHistory.size() > getCommandHistorySize()) cmdHistory.removeFirst();
160
161	setCommandLineText("");
162	currentCmd = "";
163	cmdHistoryIdx = -1;
164
165	if( getSocket() == null \|\| getSocket().isClosed() \|\| !getSocket().isConnected()
166	\|\| getSocket().isOutputShutdown() \|\| out == null ) {
167
168	fireResponseReceived(i18n.getMessage("DefaultLSConsoleModel.notConnected"));
169	} else {
170	CC.getTaskQueue().add(new LSConsoleExecCommand(cmd));
171	}
172
173	fireCommandExecuted();
174	}
175
176	/**
177	* Gets the last executed command.
178	* @return The last command executed in the LS Console.
179	*/
180	@Override
181	public String
182	getLastExecutedCommand() {
183	int size = sessionHistory.size();
184	return size == 0 ? "" : sessionHistory.get(size - 1);
185	}
186
187	/**
188	* Sets the text in the command line.
189	* @param cmdLine The new command line text.
190	*/
191	@Override
192	public void
193	setCommandLineText(String cmdLine) {
194	if(this.cmdLine.equals(cmdLine)) return;
195
196	String oldCmdLine = this.cmdLine;
197	this.cmdLine = cmdLine;
198	fireCommandLineTextChanged(oldCmdLine);
199	}
200
201	/**
202	* Gets the text in the command line.
203	* @return The command line's text.
204	*/
205	@Override
206	public String
207	getCommandLineText() { return cmdLine; }
208
209	/**
210	* Gets the command history of the current session, including blank lines and comments.
211	* @return The command history of the current session, including blank lines and comments.
212	*/
213	@Override
214	public String[]
215	getSessionHistory() {
216	return sessionHistory.toArray(new String[sessionHistory.size()]);
217	}
218
219	/**
220	* Clears the session history.
221	* @see #getSessionHistory
222	*/
223	@Override
224	public void
225	clearSessionHistory() { sessionHistory.removeAllElements(); }
226
227	/**
228	* Adds the specified <code>command</code> to command history.
229	* @param command The command to be added to command history.
230	*/
231	@Override
232	public void
233	addToCommandHistory(String command) { cmdHistory.add(command); }
234
235	/**
236	* Gets the complete command history, excluding blank lines and comments.
237	* @return The complete command history, excluding blank lines and comments.
238	*/
239	@Override
240	public String[]
241	getCommandHistory() {
242	return cmdHistory.toArray(new String[cmdHistory.size()]);
243	}
244
245	/**
246	* Clears the complete/multisession command history.
247	* @see #getCommandHistory
248	*/
249	@Override
250	public void
251	clearCommandHistory() {
252	cmdHistory.clear();
253	cmdHistoryIdx = -1;
254	}
255
256	/**
257	* Determines the maximum number of lines to be kept in the command history.
258	* @return The maximum number of lines to be kept in the command history.
259	*/
260	@Override
261	public int
262	getCommandHistorySize() { return commandHistorySize; }
263
264	/**
265	* Sets the maximum number of lines to be kept in the command history.
266	* @param size Determines the maximum number of lines to be kept in the command history.
267	*/
268	@Override
269	public void
270	setCommandHistorySize(int size) { commandHistorySize = size; }
271
272	/**
273	* Gets a list of all LSCP commands.
274	* @return A list of all LSCP commands.
275	*/
276	@Override
277	public String[]
278	getCommandList() { return cmdList; }
279
280	/** Browses the command history one line up. */
281	@Override
282	public void
283	browseCommandHistoryUp() {
284	if(cmdHistory.size() == 0) return;
285
286	if(cmdHistoryIdx == -1) {
287	currentCmd = getCommandLineText();
288	cmdHistoryIdx = cmdHistory.size() - 1;
289	setCommandLineText(cmdHistory.get(cmdHistoryIdx));
290	return;
291	}
292
293	if(cmdHistoryIdx == 0) return;
294
295	setCommandLineText(cmdHistory.get(--cmdHistoryIdx));
296	}
297
298	/** Browses the command history one line down. */
299	@Override
300	public void
301	browseCommandHistoryDown() {
302	if(cmdHistory.size() == 0 \|\| cmdHistoryIdx == -1) return;
303	if(cmdHistoryIdx == cmdHistory.size() - 1) {
304	cmdHistoryIdx = -1;
305	setCommandLineText(currentCmd);
306	currentCmd = "";
307	return;
308	}
309
310	setCommandLineText(cmdHistory.get(++cmdHistoryIdx));
311	}
312
313	/** Browses to the first line of the command history. */
314	@Override
315	public void
316	browseCommandHistoryFirst() {
317	if(cmdHistory.size() == 0) return;
318	cmdHistoryIdx = 0;
319	setCommandLineText(cmdHistory.get(cmdHistoryIdx));
320	}
321
322	/** Browses to the last line of the command history. */
323	@Override
324	public void
325	browseCommandHistoryLast() {
326	if(cmdHistory.size() == 0) return;
327	cmdHistoryIdx = cmdHistory.size() - 1;
328	setCommandLineText(cmdHistory.get(cmdHistoryIdx));
329	}
330
331	private Vector<String> tmpVector = new Vector<String>();
332
333	/**
334	* Searches the command history for commands
335	* containing the string returned by {@link #getCommandLineText}.
336	* @return All commands that contains the string returned by {@link #getCommandLineText}.
337	* @see #getCommandHistory
338	*/
339	@Override
340	public String[]
341	searchCommandHistory() { return searchCommandHistory(getCommandLineText()); }
342
343	/**
344	* Searches the command history for commands containing <code>substring</code>.
345	* @param substring The substring to be used to perform the search.
346	* @return All commands that contains <code>substring</code>.
347	* @see #getCommandList
348	*/
349	@Override
350	public String[]
351	searchCommandHistory(String substring) {
352	tmpVector.removeAllElements();
353	for(String s : cmdHistory) if(s.indexOf(substring) != -1) tmpVector.add(s);
354
355	return tmpVector.toArray(new String[tmpVector.size()]);
356	}
357
358	/**
359	* Searches the LSCP command list for commands
360	* containing the string returned by {@link #getCommandLineText}.
361	* @return All commands that contains the string returned by {@link #getCommandLineText}.
362	* @see #getCommandList
363	*/
364	@Override
365	public String[]
366	searchCommandList() { return searchCommandList(getCommandLineText()); }
367
368	/**
369	* Searches the LSCP command list for commands containing <code>substring</code>.
370	* @param substring The substring to be used to perform the search.
371	* @return All commands that contains <code>substring</code>.
372	* @see #getCommandList
373	*/
374	@Override
375	public String[]
376	searchCommandList(String substring) {
377	tmpVector.removeAllElements();
378	for(String s : cmdList) if(s.indexOf(substring) != -1) tmpVector.add(s);
379
380	return tmpVector.toArray(new String[tmpVector.size()]);
381	}
382
383	@Override
384	public void
385	quit() { disconnect(); }
386
387	/** Notifies listeners that the text in the command line has changed. */
388	private void
389	fireCommandLineTextChanged(String oldCmdLine) {
390	LSConsoleEvent e = new LSConsoleEvent(this, null, oldCmdLine);
391	for(LSConsoleListener l : listeners) l.commandLineTextChanged(e);
392	}
393
394	/** Notifies listeners that the command in the command line has been executed. */
395	private void
396	fireCommandExecuted() {
397	LSConsoleEvent e = new LSConsoleEvent(this);
398	for(LSConsoleListener l : listeners) l.commandExecuted(e);
399	}
400
401	/**
402	* Notifies listeners that response is received from LinuxSampler.
403	* @param response The response received from LinuxSampler.
404	*/
405	private void
406	fireResponseReceived(final String response) {
407	SwingUtilities.invokeLater(new Runnable() {
408	public void
409	run() {
410	LSConsoleEvent e = new LSConsoleEvent(this, response);
411	for(LSConsoleListener l : listeners) l.responseReceived(e);
412	}
413	});
414	}
415
416	/** Executes LS Console command. */
417	private class LSConsoleExecCommand extends org.jsampler.task.EnhancedTask {
418	private String cmd;
419
420	/** Creates a new instance of <code>LSConsoleExecCommand</code>. */
421	public
422	LSConsoleExecCommand(String cmd) {
423	setTitle("LSConsoleExecCommand_task");
424	setDescription(i18n.getMessage("LSConsoleExecCommand.description"));
425	this.cmd = cmd;
426	}
427
428	/** The entry point of the task. */
429	public void
430	exec() throws Exception { out.writeLine(cmd); }
431	}
432
433	class LSConsoleThread extends Thread {
434	LscpInputStream in;
435	private boolean terminate = false;
436
437	LSConsoleThread() {super("LS-Console-Thread"); }
438
439	@Override
440	public void
441	run() {
442	while(!mustTerminate()) {
443	try { processInput(); }
444	catch(Exception x) {
445	CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x);
446	}
447
448	try { synchronized(this) { wait(100); } }
449	catch(Exception x) {
450	CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x);
451	}
452	}
453	}
454
455	private synchronized boolean
456	mustTerminate() { return terminate; }
457
458	public synchronized void
459	terminate() {
460	terminate = true;
461	this.notifyAll();
462	}
463
464	/** Processes the input sent by LinuxSampler */
465	private synchronized void
466	processInput() throws IOException {
467	while(in != null && in.available() > 0) {
468	String response = in.readLine();
469	fireResponseReceived(response);
470	}
471	}
472
473	public synchronized void
474	setInputStream(LscpInputStream in) { this.in = in; }
475	}
476
477	class LscpInputStream {
478	private InputStream in;
479	private StringBuffer buf = new StringBuffer();
480
481	/**
482	* Creates a new instance of LscpInputStream.
483	*
484	*/
485	public
486	LscpInputStream(InputStream in) {
487	this.in = in;
488	}
489
490	/**
491	* Reads a line.
492	* This method is thread safe.
493	*
494	* @return A string containing the next line readed from the stream or
495	* <code>null</code> if the end of the stream has been reached.
496	* @throws IOException If an I/O error occurs.
497	*/
498	public synchronized String
499	readLine() throws IOException {
500	int i;
501	buf.setLength(0);
502
503	while((i = in.read()) != -1) {
504	if(i == '\r') {
505	checkLF();
506	break;
507	}
508	buf.append((char)i);
509	}
510
511	if(i == -1) {
512	if(buf.length() > 0)
513	throw new IOException("Unexpected end of line!");
514	return null;
515	}
516	return buf.toString();
517	}
518
519	/**
520	* Returns the number of bytes that can
521	* be read from this input stream without blocking.
522	*
523	* @return The number of bytes that can
524	* be read from this input stream without blocking.
525	* @throws IOException If an I/O error occurs.
526	*/
527	public synchronized int
528	available() throws IOException { return in.available(); }
529
530	private void
531	checkLF() throws IOException {
532	int i = in.read();
533	if(i == -1) throw new IOException("Unexpected end of file!");
534	if(i != '\n') throw new IOException("Unexpected end of line!");
535	}
536	}
537
538	class LscpOutputStream {
539	private OutputStream out;
540
541	/** Creates a new instance of LscpOutputStream */
542	public
543	LscpOutputStream(OutputStream out) { this.out = out; }
544
545	/*
546	* Writes a line.
547	* @param line a string to be written.
548	*/
549	public void
550	writeLine(String line) throws IOException {
551	try {
552	out.write(line.getBytes("US-ASCII"));
553	out.write('\r');
554	out.write('\n');
555	out.flush();
556	} catch(UnsupportedEncodingException x) {
557	CC.getLogger().log(Level.INFO, HF.getErrorMessage(x), x);
558	}
559	}
560	}
561	}