class DefaultTcpTransportMapping.SocketEntry
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private long |
lastUse |
private java.util.LinkedList<byte[]> |
message |
private TcpAddress |
peerAddress |
private java.nio.ByteBuffer |
readBuffer |
private int |
registrations |
private java.net.Socket |
socket |
Constructor and Description |
---|
SocketEntry(TcpAddress address,
java.net.Socket socket) |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(byte[] message) |
void |
addRegistration(java.nio.channels.Selector selector,
int opKey) |
long |
getLastUse() |
TcpAddress |
getPeerAddress() |
java.nio.ByteBuffer |
getReadBuffer() |
java.net.Socket |
getSocket() |
boolean |
hasMessage() |
boolean |
isRegistered(int opKey) |
byte[] |
nextMessage() |
void |
removeRegistration(java.nio.channels.Selector selector,
int opKey) |
void |
setReadBuffer(java.nio.ByteBuffer byteBuffer) |
java.lang.String |
toString() |
void |
used() |
private java.net.Socket socket
private TcpAddress peerAddress
private long lastUse
private java.util.LinkedList<byte[]> message
private java.nio.ByteBuffer readBuffer
private volatile int registrations
public SocketEntry(TcpAddress address, java.net.Socket socket)
public void addRegistration(java.nio.channels.Selector selector, int opKey) throws java.nio.channels.ClosedChannelException
java.nio.channels.ClosedChannelException
public void removeRegistration(java.nio.channels.Selector selector, int opKey) throws java.nio.channels.ClosedChannelException
java.nio.channels.ClosedChannelException
public boolean isRegistered(int opKey)
public long getLastUse()
public void used()
public java.net.Socket getSocket()
public TcpAddress getPeerAddress()
public void addMessage(byte[] message)
public byte[] nextMessage()
public boolean hasMessage()
public void setReadBuffer(java.nio.ByteBuffer byteBuffer)
public java.nio.ByteBuffer getReadBuffer()
public java.lang.String toString()
toString
in class java.lang.Object