Package com.jme3.network.kernel.tcp

Class NioEndpoint

java.lang.Object
com.jme3.network.kernel.tcp.NioEndpoint
All Implemented Interfaces:
Endpoint
public class NioEndpoint extends Object implements Endpoint
Endpoint implementation that encapsulates the channel IO based connection information and keeps track of the outbound data queue for the channel.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected static final ByteBuffer
    CLOSE_MARKER
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    NioEndpoint(SelectorKernel kernel, long id, SocketChannel socket)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Closes this endpoint without flushing any of its currently enqueued outbound data.
    void
    close(boolean flushData)
    Closes this endpoint, optionally flushing any queued data before closing.
    String
    getAddress()
    Returns the transport specific remote address of this endpoint as a string.
    long
    getId()
    Returns an ID that is unique for this endpoint within its Kernel instance.
    Kernel
    getKernel()
    Returns the kernel to which this endpoint belongs.
    protected boolean
    hasPending()
     
    boolean
    isConnected()
    Returns true if this endpoint is currently connected.
    protected ByteBuffer
    peekPending()
    Called by the SelectorKernel to get the current top buffer for writing.
    protected ByteBuffer
    removePending()
    Called by the SelectorKernel when the top buffer has been exhausted.
    void
    send(ByteBuffer data)
    Sends data to the other end of the connection represented by this endpoint.
    protected void
    send(ByteBuffer data, boolean copy, boolean wakeup)
    The wakeup option is used internally when the kernel is broadcasting out to a bunch of endpoints and doesn't want to necessarily wakeup right away.
    String
    toString()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Field Details

    • CLOSE_MARKER

      protected static final ByteBuffer CLOSE_MARKER

  • Constructor Details

  • Method Details

    • getKernel

      public Kernel getKernel()
      Description copied from interface: Endpoint
      Returns the kernel to which this endpoint belongs.
      Specified by:
      getKernel in interface Endpoint

    • close

      public void close()
      Description copied from interface: Endpoint
      Closes this endpoint without flushing any of its currently enqueued outbound data.
      Specified by:
      close in interface Endpoint

    • close

      public void close(boolean flushData)
      Description copied from interface: Endpoint
      Closes this endpoint, optionally flushing any queued data before closing. As soon as this method is called, new send() calls will fail with an exception... even while close() is still flushing the earlier queued messages.
      Specified by:
      close in interface Endpoint

    • getId

      public long getId()
      Description copied from interface: Endpoint
      Returns an ID that is unique for this endpoint within its Kernel instance.
      Specified by:
      getId in interface Endpoint

    • getAddress

      public String getAddress()
      Description copied from interface: Endpoint
      Returns the transport specific remote address of this endpoint as a string. This may or may not be unique per endpoint depending on the type of transport.
      Specified by:
      getAddress in interface Endpoint

    • isConnected

      public boolean isConnected()
      Description copied from interface: Endpoint
      Returns true if this endpoint is currently connected.
      Specified by:
      isConnected in interface Endpoint

    • send

      protected void send(ByteBuffer data, boolean copy, boolean wakeup)
      The wakeup option is used internally when the kernel is broadcasting out to a bunch of endpoints and doesn't want to necessarily wakeup right away.

    • peekPending

      protected ByteBuffer peekPending()
      Called by the SelectorKernel to get the current top buffer for writing.

    • removePending

      protected ByteBuffer removePending()
      Called by the SelectorKernel when the top buffer has been exhausted.

    • hasPending

      protected boolean hasPending()

    • send

      public void send(ByteBuffer data)
      Description copied from interface: Endpoint
      Sends data to the other end of the connection represented by this endpoint.
      Specified by:
      send in interface Endpoint

    • toString

      public String toString()
      Overrides:
      toString in class Object