Interface TransportHelper

All Known Implementing Classes:
TCPTransportHelper, UDPTransportHelper

public interface TransportHelper
  • Method Details

    • getAddress

      InetSocketAddress getAddress()
    • getName

      String getName(boolean verbose)
    • minimiseOverheads

      boolean minimiseOverheads()
    • getConnectTimeout

      int getConnectTimeout()
    • getReadTimeout

      int getReadTimeout()
    • delayWrite

      boolean delayWrite(ByteBuffer buffer)
    • hasDelayedWrite

      boolean hasDelayedWrite()
    • write

      int write(ByteBuffer buffer, boolean partial_write) throws IOException
      Throws:
      IOException
    • write

      long write(ByteBuffer[] buffers, int array_offset, int length) throws IOException
      Throws:
      IOException
    • read

      int read(ByteBuffer buffer) throws IOException
      Throws:
      IOException
    • read

      long read(ByteBuffer[] buffers, int array_offset, int length) throws IOException
      Throws:
      IOException
    • pauseReadSelects

      void pauseReadSelects()
    • pauseWriteSelects

      void pauseWriteSelects()
    • resumeReadSelects

      void resumeReadSelects()
    • resumeWriteSelects

      void resumeWriteSelects()
    • registerForReadSelects

      void registerForReadSelects(TransportHelper.selectListener listener, Object attachment)
    • registerForWriteSelects

      void registerForWriteSelects(TransportHelper.selectListener listener, Object attachment)
    • cancelReadSelects

      void cancelReadSelects()
    • cancelWriteSelects

      void cancelWriteSelects()
    • isClosed

      boolean isClosed()
    • close

      void close(String reason)
    • failed

      void failed(Throwable reason)
    • setUserData

      void setUserData(Object key, Object data)
    • getUserData

      Object getUserData(Object key)
    • setTrace

      void setTrace(boolean on)
    • setScatteringMode

      void setScatteringMode(long forBytes)