Class ReadAheadEndpoint

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.eclipse.jetty.io.EndPoint

    public class ReadAheadEndpoint
    extends java.lang.Object
    implements org.eclipse.jetty.io.EndPoint
    • Constructor Detail

      • ReadAheadEndpoint

        public ReadAheadEndpoint​(org.eclipse.jetty.io.EndPoint channel,
                                 int readAheadLength)
    • Method Detail

      • getLocalAddress

        public java.net.InetSocketAddress getLocalAddress()
        Specified by:
        getLocalAddress in interface org.eclipse.jetty.io.EndPoint
      • getRemoteAddress

        public java.net.InetSocketAddress getRemoteAddress()
        Specified by:
        getRemoteAddress in interface org.eclipse.jetty.io.EndPoint
      • isOpen

        public boolean isOpen()
        Specified by:
        isOpen in interface org.eclipse.jetty.io.EndPoint
      • getCreatedTimeStamp

        public long getCreatedTimeStamp()
        Specified by:
        getCreatedTimeStamp in interface org.eclipse.jetty.io.EndPoint
      • isOutputShutdown

        public boolean isOutputShutdown()
        Specified by:
        isOutputShutdown in interface org.eclipse.jetty.io.EndPoint
      • isInputShutdown

        public boolean isInputShutdown()
        Specified by:
        isInputShutdown in interface org.eclipse.jetty.io.EndPoint
      • shutdownOutput

        public void shutdownOutput()
        Specified by:
        shutdownOutput in interface org.eclipse.jetty.io.EndPoint
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface org.eclipse.jetty.io.EndPoint
      • getTransport

        public java.lang.Object getTransport()
        Specified by:
        getTransport in interface org.eclipse.jetty.io.EndPoint
      • getIdleTimeout

        public long getIdleTimeout()
        Specified by:
        getIdleTimeout in interface org.eclipse.jetty.io.EndPoint
      • getConnection

        public org.eclipse.jetty.io.Connection getConnection()
        Specified by:
        getConnection in interface org.eclipse.jetty.io.EndPoint
      • onOpen

        public void onOpen()
        Specified by:
        onOpen in interface org.eclipse.jetty.io.EndPoint
      • onClose

        public void onClose()
        Specified by:
        onClose in interface org.eclipse.jetty.io.EndPoint
      • isOptimizedForDirectBuffers

        public boolean isOptimizedForDirectBuffers()
        Specified by:
        isOptimizedForDirectBuffers in interface org.eclipse.jetty.io.EndPoint
      • isFillInterested

        public boolean isFillInterested()
        Specified by:
        isFillInterested in interface org.eclipse.jetty.io.EndPoint
      • tryFillInterested

        public boolean tryFillInterested​(org.eclipse.jetty.util.Callback v)
        Specified by:
        tryFillInterested in interface org.eclipse.jetty.io.EndPoint
      • flush

        public boolean flush​(java.nio.ByteBuffer... v)
                      throws java.io.IOException
        Specified by:
        flush in interface org.eclipse.jetty.io.EndPoint
        Throws:
        java.io.IOException
      • setIdleTimeout

        public void setIdleTimeout​(long v)
        Specified by:
        setIdleTimeout in interface org.eclipse.jetty.io.EndPoint
      • write

        public void write​(org.eclipse.jetty.util.Callback v,
                          java.nio.ByteBuffer... b)
                   throws java.nio.channels.WritePendingException
        Specified by:
        write in interface org.eclipse.jetty.io.EndPoint
        Throws:
        java.nio.channels.WritePendingException
      • setConnection

        public void setConnection​(org.eclipse.jetty.io.Connection v)
        Specified by:
        setConnection in interface org.eclipse.jetty.io.EndPoint
      • upgrade

        public void upgrade​(org.eclipse.jetty.io.Connection v)
        Specified by:
        upgrade in interface org.eclipse.jetty.io.EndPoint
      • fillInterested

        public void fillInterested​(org.eclipse.jetty.util.Callback v)
                            throws java.nio.channels.ReadPendingException
        Specified by:
        fillInterested in interface org.eclipse.jetty.io.EndPoint
        Throws:
        java.nio.channels.ReadPendingException
      • fill

        public int fill​(java.nio.ByteBuffer dst)
                 throws java.io.IOException
        Specified by:
        fill in interface org.eclipse.jetty.io.EndPoint
        Throws:
        java.io.IOException
      • getBytes

        public byte[] getBytes()