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)