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