Mercurial Hosting > luan
changeset 966:2ac9e57ccae6
remove ByteArrayEndPoint
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Fri, 14 Oct 2016 02:26:05 -0600 |
parents | 866f2e801618 |
children | 8a8dc0b1742f |
files | src/org/eclipse/jetty/io/ByteArrayEndPoint.java |
diffstat | 1 files changed, 0 insertions(+), 408 deletions(-) [+] |
line wrap: on
line diff
--- a/src/org/eclipse/jetty/io/ByteArrayEndPoint.java Fri Oct 14 02:19:21 2016 -0600 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,408 +0,0 @@ -// -// ======================================================================== -// Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd. -// ------------------------------------------------------------------------ -// All rights reserved. This program and the accompanying materials -// are made available under the terms of the Eclipse Public License v1.0 -// and Apache License v2.0 which accompanies this distribution. -// -// The Eclipse Public License is available at -// http://www.eclipse.org/legal/epl-v10.html -// -// The Apache License v2.0 is available at -// http://www.opensource.org/licenses/apache2.0.php -// -// You may elect to redistribute this code under either of these licenses. -// ======================================================================== -// - -package org.eclipse.jetty.io; - -import java.io.IOException; - - - -/* ------------------------------------------------------------ */ -/** ByteArrayEndPoint. - * - * - */ -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; - - - /* ------------------------------------------------------------ */ - /** - * - */ - public ByteArrayEndPoint() - { - } - - /* ------------------------------------------------------------ */ - /** - * @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; - } - - /* ------------------------------------------------------------ */ - /** - * @return the nonBlocking - */ - public boolean isNonBlocking() - { - return _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); - } - - /* ------------------------------------------------------------ */ - /** - * @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.jetty.io.EndPoint#isInputShutdown() - */ - public boolean isInputShutdown() - { - 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; - } - - /* ------------------------------------------------------------ */ - public boolean blockReadable(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#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#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 && _nonBlocking) - return 0; - - 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(); - - 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; - } - - /* ------------------------------------------------------------ */ - /* - * @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; - - 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 (buffer==null || buffer.length()==0) - { - if (trailer!=null && trailer.length()>0) - { - flushed+=flush(trailer); - } - } - } - - return flushed; - } - - /* ------------------------------------------------------------ */ - /** - * - */ - 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#getLocalHost() - */ - public String getLocalHost() - { - return null; - } - - /* ------------------------------------------------------------ */ - /* - * @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#getRemoteHost() - */ - public String getRemoteHost() - { - return null; - } - - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getRemotePort() - */ - public int getRemotePort() - { - return 0; - } - - /* ------------------------------------------------------------ */ - /* - * @see org.eclipse.io.EndPoint#getConnection() - */ - public Object getTransport() - { - return _inBytes; - } - - /* ------------------------------------------------------------ */ - 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; - } - - /* ------------------------------------------------------------ */ - /** - * @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; - } - - -}