public class SocketChannelEndPoint extends ChannelEndPoint
Modifier and Type | Field and Description |
---|---|
private java.net.InetSocketAddress |
_local |
private java.net.InetSocketAddress |
_remote |
private java.net.Socket |
_socket |
private static Logger |
LOG |
_currentInterestOps, _desiredInterestOps, _key, _selector
Constructor and Description |
---|
SocketChannelEndPoint(java.nio.channels.SelectableChannel channel,
ManagedSelector selector,
java.nio.channels.SelectionKey key,
Scheduler scheduler) |
SocketChannelEndPoint(java.nio.channels.SocketChannel channel,
ManagedSelector selector,
java.nio.channels.SelectionKey key,
Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
protected void |
doShutdownOutput() |
java.net.InetSocketAddress |
getLocalAddress() |
java.net.InetSocketAddress |
getRemoteAddress() |
java.net.Socket |
getSocket() |
doClose, fill, flush, getChannel, getTransport, isOpen, isOptimizedForDirectBuffers, needsFillInterest, onClose, onIncompleteFlush, onSelected, toEndPointString, updateKey
checkFill, checkFlush, close, close, doShutdownInput, fillInterested, getConnection, getCreatedTimeStamp, getFillInterest, getWriteFlusher, isFillInterested, isInputShutdown, isOutputShutdown, onClose, onIdleExpired, onOpen, reset, setConnection, shutdownInput, shutdownOutput, toConnectionString, toString, tryFillInterested, upgrade, write
checkIdleTimeout, getIdleFor, getIdleTimeout, getIdleTimestamp, getScheduler, notIdle, setIdleTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getIdleTimeout, setIdleTimeout
private static final Logger LOG
private final java.net.Socket _socket
private final java.net.InetSocketAddress _local
private final java.net.InetSocketAddress _remote
public SocketChannelEndPoint(java.nio.channels.SelectableChannel channel, ManagedSelector selector, java.nio.channels.SelectionKey key, Scheduler scheduler)
public SocketChannelEndPoint(java.nio.channels.SocketChannel channel, ManagedSelector selector, java.nio.channels.SelectionKey key, Scheduler scheduler)
public java.net.Socket getSocket()
public java.net.InetSocketAddress getLocalAddress()
EndPoint
is bound, or null
if this EndPoint
does not represent a network connection.public java.net.InetSocketAddress getRemoteAddress()
EndPoint
is bound, or null
if this EndPoint
does not represent a network connection.protected void doShutdownOutput()
doShutdownOutput
in class AbstractEndPoint