Class SocketChannelEndPoint

    • Constructor Detail

      • SocketChannelEndPoint

        public SocketChannelEndPoint​(java.nio.channels.SocketChannel channel,
                                     ManagedSelector selector,
                                     java.nio.channels.SelectionKey key,
                                     Scheduler scheduler)
    • Method Detail

      • isOpen

        public boolean isOpen()
        Description copied from class: IdleTimeout
        This abstract method should be called to check if idle timeouts should still be checked.
        Specified by:
        isOpen in interface EndPoint
        isOpen in class AbstractEndPoint
        True if the entity monitored should still be checked for idle timeouts
      • onClose

        public void onClose​(java.lang.Throwable cause)
        Description copied from interface: EndPoint

        Callback method invoked when this EndPoint is closed.

        Specified by:
        onClose in interface EndPoint
        onClose in class AbstractEndPoint
        cause - The reason for the close, or null if a normal close.
        See Also:
      • fill

        public int fill​(java.nio.ByteBuffer buffer)
        Description copied from interface: EndPoint
        Fill the passed buffer with data from this endpoint. The bytes are appended to any data already in the buffer by writing from the buffers limit up to it's capacity. The limit is updated to include the filled bytes.
        Specified by:
        fill in interface EndPoint
        buffer - The buffer to fill. The position and limit are modified during the fill. After the operation, the position is unchanged and the limit is increased to reflect the new data filled.
        an int value indicating the number of bytes filled or -1 if EOF is read or the input is shutdown.
        Throws: - if the endpoint is closed.
      • flush

        public boolean flush​(java.nio.ByteBuffer... buffers)
        Description copied from interface: EndPoint
        Flush data from the passed header/buffer to this endpoint. As many bytes as can be consumed are taken from the header/buffer position up until the buffer limit. The header/buffers position is updated to indicate how many bytes have been consumed.
        Specified by:
        flush in interface EndPoint
        buffers - the buffers to flush
        True IFF all the buffers have been consumed and the endpoint has flushed the data to its destination (ie is not buffering any data).
        Throws: - If the endpoint is closed or output is shutdown.
      • getChannel

        public java.nio.channels.SocketChannel getChannel()
      • getTransport

        public java.lang.Object getTransport()
        Specified by:
        getTransport in interface EndPoint
        The underlying transport object (socket, channel, etc.)
      • replaceKey

        public void replaceKey​(java.nio.channels.SelectionKey newKey)
        Description copied from interface: ManagedSelector.Selectable
        Callback method invoked when the SelectionKey is replaced because the channel has been moved to a new selector.
        Specified by:
        replaceKey in interface ManagedSelector.Selectable
        newKey - the new SelectionKey