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;
-	}
-
-
-}