Mercurial Hosting > luan
diff src/org/eclipse/jetty/io/ByteArrayEndPoint.java @ 909:c60c1adfac3e
simplify connectors
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Sat, 08 Oct 2016 21:15:28 -0600 |
parents | 3428c60d7cfc |
children |
line wrap: on
line diff
--- a/src/org/eclipse/jetty/io/ByteArrayEndPoint.java Fri Oct 07 15:17:01 2016 -0600 +++ b/src/org/eclipse/jetty/io/ByteArrayEndPoint.java Sat Oct 08 21:15:28 2016 -0600 @@ -29,380 +29,380 @@ */ public class ByteArrayEndPoint implements ConnectedEndPoint { - protected byte[] _inBytes; - protected ByteArrayBuffer _in; - protected ByteArrayBuffer _out; - protected boolean _closed; - protected boolean _nonBlocking; - protected boolean _growOutput; - protected Connection _connection; - protected int _maxIdleTime; + protected byte[] _inBytes; + protected ByteArrayBuffer _in; + protected ByteArrayBuffer _out; + protected boolean _closed; + protected boolean _nonBlocking; + protected boolean _growOutput; + protected Connection _connection; + protected int _maxIdleTime; - /* ------------------------------------------------------------ */ - /** - * - */ - public ByteArrayEndPoint() - { - } + /* ------------------------------------------------------------ */ + /** + * + */ + public ByteArrayEndPoint() + { + } - /* ------------------------------------------------------------ */ - /** - * @see org.eclipse.jetty.io.ConnectedEndPoint#getConnection() - */ - public Connection getConnection() - { - return _connection; - } + /* ------------------------------------------------------------ */ + /** + * @see org.eclipse.jetty.io.ConnectedEndPoint#getConnection() + */ + public Connection getConnection() + { + return _connection; + } - /* ------------------------------------------------------------ */ - /** - * @see org.eclipse.jetty.io.ConnectedEndPoint#setConnection(org.eclipse.jetty.io.Connection) - */ - public void setConnection(Connection connection) - { - _connection=connection; - } + /* ------------------------------------------------------------ */ + /** + * @see org.eclipse.jetty.io.ConnectedEndPoint#setConnection(org.eclipse.jetty.io.Connection) + */ + public void setConnection(Connection connection) + { + _connection=connection; + } - /* ------------------------------------------------------------ */ - /** - * @return the nonBlocking - */ - public boolean isNonBlocking() - { - return _nonBlocking; - } + /* ------------------------------------------------------------ */ + /** + * @return the nonBlocking + */ + public boolean isNonBlocking() + { + return _nonBlocking; + } - /* ------------------------------------------------------------ */ - /** - * @param nonBlocking the nonBlocking to set - */ - public void setNonBlocking(boolean nonBlocking) - { - _nonBlocking=nonBlocking; - } + /* ------------------------------------------------------------ */ + /** + * @param nonBlocking the nonBlocking to set + */ + public void setNonBlocking(boolean nonBlocking) + { + _nonBlocking=nonBlocking; + } - /* ------------------------------------------------------------ */ - /** - * - */ - public ByteArrayEndPoint(byte[] input, int outputSize) - { - _inBytes=input; - _in=new ByteArrayBuffer(input); - _out=new ByteArrayBuffer(outputSize); - } + /* ------------------------------------------------------------ */ + /** + * + */ + public ByteArrayEndPoint(byte[] input, int outputSize) + { + _inBytes=input; + _in=new ByteArrayBuffer(input); + _out=new ByteArrayBuffer(outputSize); + } - /* ------------------------------------------------------------ */ - /** - * @return Returns the in. - */ - public ByteArrayBuffer getIn() - { - return _in; - } - /* ------------------------------------------------------------ */ - /** - * @param in The in to set. - */ - public void setIn(ByteArrayBuffer in) - { - _in = in; - } - /* ------------------------------------------------------------ */ - /** - * @return Returns the out. - */ - public ByteArrayBuffer getOut() - { - return _out; - } - /* ------------------------------------------------------------ */ - /** - * @param out The out to set. - */ - public void setOut(ByteArrayBuffer out) - { - _out = out; - } + /* ------------------------------------------------------------ */ + /** + * @return Returns the in. + */ + public ByteArrayBuffer getIn() + { + return _in; + } + /* ------------------------------------------------------------ */ + /** + * @param in The in to set. + */ + public void setIn(ByteArrayBuffer in) + { + _in = in; + } + /* ------------------------------------------------------------ */ + /** + * @return Returns the out. + */ + public ByteArrayBuffer getOut() + { + return _out; + } + /* ------------------------------------------------------------ */ + /** + * @param out The out to set. + */ + public void setOut(ByteArrayBuffer out) + { + _out = out; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#isOpen() - */ - public boolean isOpen() - { - return !_closed; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#isOpen() + */ + public boolean isOpen() + { + return !_closed; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.jetty.io.EndPoint#isInputShutdown() - */ - public boolean isInputShutdown() - { - return _closed; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.jetty.io.EndPoint#isInputShutdown() + */ + public boolean isInputShutdown() + { + return _closed; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.jetty.io.EndPoint#isOutputShutdown() - */ - public boolean isOutputShutdown() - { - return _closed; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.jetty.io.EndPoint#isOutputShutdown() + */ + public boolean isOutputShutdown() + { + return _closed; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#isBlocking() - */ - public boolean isBlocking() - { - return !_nonBlocking; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#isBlocking() + */ + public boolean isBlocking() + { + return !_nonBlocking; + } - /* ------------------------------------------------------------ */ - public boolean blockReadable(long millisecs) - { - return true; - } + /* ------------------------------------------------------------ */ + public boolean blockReadable(long millisecs) + { + return true; + } - /* ------------------------------------------------------------ */ - public boolean blockWritable(long millisecs) - { - return true; - } + /* ------------------------------------------------------------ */ + public boolean blockWritable(long millisecs) + { + return true; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#shutdownOutput() - */ - public void shutdownOutput() throws IOException - { - close(); - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#shutdownOutput() + */ + public void shutdownOutput() throws IOException + { + close(); + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#shutdownInput() - */ - public void shutdownInput() throws IOException - { - close(); - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#shutdownInput() + */ + public void shutdownInput() throws IOException + { + close(); + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#close() - */ - public void close() throws IOException - { - _closed=true; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#close() + */ + public void close() throws IOException + { + _closed=true; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#fill(org.eclipse.io.Buffer) - */ - public int fill(Buffer buffer) throws IOException - { - if (_closed) - throw new IOException("CLOSED"); + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#fill(org.eclipse.io.Buffer) + */ + public int fill(Buffer buffer) throws IOException + { + if (_closed) + throw new IOException("CLOSED"); - if (_in!=null && _in.length()>0) - { - int len = buffer.put(_in); - _in.skip(len); - return len; - } + if (_in!=null && _in.length()>0) + { + int len = buffer.put(_in); + _in.skip(len); + return len; + } - if (_in!=null && _in.length()==0 && _nonBlocking) - return 0; + if (_in!=null && _in.length()==0 && _nonBlocking) + return 0; - close(); - return -1; - } + close(); + return -1; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#flush(org.eclipse.io.Buffer) - */ - public int flush(Buffer buffer) throws IOException - { - if (_closed) - throw new IOException("CLOSED"); - if (_growOutput && buffer.length()>_out.space()) - { - _out.compact(); + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#flush(org.eclipse.io.Buffer) + */ + public int flush(Buffer buffer) throws IOException + { + if (_closed) + throw new IOException("CLOSED"); + if (_growOutput && buffer.length()>_out.space()) + { + _out.compact(); - if (buffer.length()>_out.space()) - { - ByteArrayBuffer n = new ByteArrayBuffer(_out.putIndex()+buffer.length()); + if (buffer.length()>_out.space()) + { + ByteArrayBuffer n = new ByteArrayBuffer(_out.putIndex()+buffer.length()); - n.put(_out.peek(0,_out.putIndex())); - if (_out.getIndex()>0) - { - n.mark(); - n.setGetIndex(_out.getIndex()); - } - _out=n; - } - } - int len = _out.put(buffer); - if (!buffer.isImmutable()) - buffer.skip(len); - return len; - } + n.put(_out.peek(0,_out.putIndex())); + if (_out.getIndex()>0) + { + n.mark(); + n.setGetIndex(_out.getIndex()); + } + _out=n; + } + } + int len = _out.put(buffer); + if (!buffer.isImmutable()) + buffer.skip(len); + return len; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#flush(org.eclipse.io.Buffer, org.eclipse.io.Buffer, org.eclipse.io.Buffer) - */ - public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException - { - if (_closed) - throw new IOException("CLOSED"); + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#flush(org.eclipse.io.Buffer, org.eclipse.io.Buffer, org.eclipse.io.Buffer) + */ + public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException + { + if (_closed) + throw new IOException("CLOSED"); - int flushed=0; + int flushed=0; - if (header!=null && header.length()>0) - flushed=flush(header); + if (header!=null && header.length()>0) + flushed=flush(header); - if (header==null || header.length()==0) - { - if (buffer!=null && buffer.length()>0) - flushed+=flush(buffer); + if (header==null || header.length()==0) + { + if (buffer!=null && buffer.length()>0) + flushed+=flush(buffer); - if (buffer==null || buffer.length()==0) - { - if (trailer!=null && trailer.length()>0) - { - flushed+=flush(trailer); - } - } - } + if (buffer==null || buffer.length()==0) + { + if (trailer!=null && trailer.length()>0) + { + flushed+=flush(trailer); + } + } + } - return flushed; - } + return flushed; + } - /* ------------------------------------------------------------ */ - /** - * - */ - public void reset() - { - _closed=false; - _in.clear(); - _out.clear(); - if (_inBytes!=null) - _in.setPutIndex(_inBytes.length); - } + /* ------------------------------------------------------------ */ + /** + * + */ + public void reset() + { + _closed=false; + _in.clear(); + _out.clear(); + if (_inBytes!=null) + _in.setPutIndex(_inBytes.length); + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getLocalAddr() - */ - public String getLocalAddr() - { - return null; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getLocalAddr() + */ + public String getLocalAddr() + { + return null; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getLocalHost() - */ - public String getLocalHost() - { - return null; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getLocalHost() + */ + public String getLocalHost() + { + return null; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getLocalPort() - */ - public int getLocalPort() - { - return 0; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getLocalPort() + */ + public int getLocalPort() + { + return 0; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getRemoteAddr() - */ - public String getRemoteAddr() - { - return null; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getRemoteAddr() + */ + public String getRemoteAddr() + { + return null; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getRemoteHost() - */ - public String getRemoteHost() - { - return null; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getRemoteHost() + */ + public String getRemoteHost() + { + return null; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getRemotePort() - */ - public int getRemotePort() - { - return 0; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getRemotePort() + */ + public int getRemotePort() + { + return 0; + } - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getConnection() - */ - public Object getTransport() - { - return _inBytes; - } + /* ------------------------------------------------------------ */ + /* + * @see org.eclipse.io.EndPoint#getConnection() + */ + public Object getTransport() + { + return _inBytes; + } - /* ------------------------------------------------------------ */ - public void flush() throws IOException - { - } - - /* ------------------------------------------------------------ */ - /** - * @return the growOutput - */ - public boolean isGrowOutput() - { - return _growOutput; - } + /* ------------------------------------------------------------ */ + public void flush() throws IOException + { + } + + /* ------------------------------------------------------------ */ + /** + * @return the growOutput + */ + public boolean isGrowOutput() + { + return _growOutput; + } - /* ------------------------------------------------------------ */ - /** - * @param growOutput the growOutput to set - */ - public void setGrowOutput(boolean growOutput) - { - _growOutput=growOutput; - } + /* ------------------------------------------------------------ */ + /** + * @param growOutput the growOutput to set + */ + public void setGrowOutput(boolean growOutput) + { + _growOutput=growOutput; + } - /* ------------------------------------------------------------ */ - /** - * @see org.eclipse.jetty.io.EndPoint#getMaxIdleTime() - */ - public int getMaxIdleTime() - { - return _maxIdleTime; - } + /* ------------------------------------------------------------ */ + /** + * @see org.eclipse.jetty.io.EndPoint#getMaxIdleTime() + */ + public int getMaxIdleTime() + { + return _maxIdleTime; + } - /* ------------------------------------------------------------ */ - /** - * @see org.eclipse.jetty.io.EndPoint#setMaxIdleTime(int) - */ - public void setMaxIdleTime(int timeMs) throws IOException - { - _maxIdleTime=timeMs; - } + /* ------------------------------------------------------------ */ + /** + * @see org.eclipse.jetty.io.EndPoint#setMaxIdleTime(int) + */ + public void setMaxIdleTime(int timeMs) throws IOException + { + _maxIdleTime=timeMs; + } }