linuxsampler/lscp/LscpInputStream.java

/*
 *   jlscp - a java LinuxSampler control protocol API
 *
 *   Copyright (C) 2005-2006 Grigor Iliev <grigor@grigoriliev.com>
 *
 *   This file is part of jlscp.
 *
 *   jlscp 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.
 *
 *   jlscp 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 jlscp; if not, write to the Free Software
 *   Foundation, Inc., 59 Temple Place, Suite 330, Boston,
 *   MA  02111-1307  USA
 */

package org.linuxsampler.lscp;

import java.io.InputStream;
import java.io.IOException;


/**
 *
 * @author  Grigor Iliev
 */
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 LscpException If the end of line or file is reached unexpectedly.
         * @throws IOException If an I/O error occurs.
         */
        public synchronized String
        readLine() throws IOException, LscpException {
                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 LscpException(LscpI18n.getLogMsg("LscpInputStream.EOL!"));
                        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
        skipLine() throws IOException, LscpException {
                int i;
                while((i = in.read()) != -1) {
                        if(i == '\r') {
                                checkLF();
                                break;
                        }
                }
        }
        
        private void
        checkLF() throws IOException, LscpException {
                int i = in.read();
                if(i == -1) throw new LscpException(LscpI18n.getLogMsg("LscpInputStream.EOF!"));
                if(i != '\n') throw new LscpException(LscpI18n.getLogMsg("LscpInputStream.EOL!"));
        }
}
1	/*
2	* jlscp - a java LinuxSampler control protocol API
3	*
4	* Copyright (C) 2005-2006 Grigor Iliev <grigor@grigoriliev.com>
5	*
6	* This file is part of jlscp.
7	*
8	* jlscp 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	* jlscp 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 jlscp; 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.linuxsampler.lscp;
24
25	import java.io.InputStream;
26	import java.io.IOException;
27
28
29	/**
30	*
31	* @author Grigor Iliev
32	*/
33	class LscpInputStream {
34	private InputStream in;
35	private StringBuffer buf = new StringBuffer();
36
37	/**
38	* Creates a new instance of LscpInputStream.
39	*
40	*/
41	public
42	LscpInputStream(InputStream in) {
43	this.in = in;
44	}
45
46	/**
47	* Reads a line.
48	* This method is thread safe.
49	*
50	* @return A string containing the next line readed from the stream or <code>null</code>
51	* if the end of the stream has been reached.
52	*
53	* @throws LscpException If the end of line or file is reached unexpectedly.
54	* @throws IOException If an I/O error occurs.
55	*/
56	public synchronized String
57	readLine() throws IOException, LscpException {
58	int i;
59	buf.setLength(0);
60
61	while((i = in.read()) != -1) {
62	if(i == '\r') {
63	checkLF();
64	break;
65	}
66	buf.append((char)i);
67	}
68
69	if(i == -1) {
70	if(buf.length() > 0)
71	throw new LscpException(LscpI18n.getLogMsg("LscpInputStream.EOL!"));
72	return null;
73	}
74	return buf.toString();
75	}
76
77	/**
78	* Returns the number of bytes that can be read from this input stream without blocking.
79	*
80	* @return The number of bytes that can be read from this input stream without blocking.
81	* @throws IOException If an I/O error occurs.
82	*/
83	public synchronized int
84	available() throws IOException { return in.available(); }
85
86	private void
87	skipLine() throws IOException, LscpException {
88	int i;
89	while((i = in.read()) != -1) {
90	if(i == '\r') {
91	checkLF();
92	break;
93	}
94	}
95	}
96
97	private void
98	checkLF() throws IOException, LscpException {
99	int i = in.read();
100	if(i == -1) throw new LscpException(LscpI18n.getLogMsg("LscpInputStream.EOF!"));
101	if(i != '\n') throw new LscpException(LscpI18n.getLogMsg("LscpInputStream.EOL!"));
102	}
103	}