public class RpcServer.Connection
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
UserGroupInformation |
attemptingUser |
protected java.nio.channels.SocketChannel |
channel |
protected java.lang.String |
hostAddress |
protected int |
remotePort |
protected java.util.concurrent.ConcurrentLinkedDeque<RpcServer.Call> |
responseQueue |
protected java.net.Socket |
socket |
protected UserGroupInformation |
user |
Constructor and Description |
---|
Connection(java.nio.channels.SocketChannel channel,
long lastContact) |
Modifier and Type | Method and Description |
---|---|
protected void |
close() |
protected void |
decRpcCount() |
java.lang.String |
getHostAddress() |
java.net.InetAddress |
getHostInetAddress() |
int |
getRemotePort() |
RPCProtos.VersionInfo |
getVersionInfo() |
protected void |
incRpcCount() |
protected void |
processRequest(java.nio.ByteBuffer buf) |
int |
readAndProcess()
Read off the wire.
|
void |
setLastContact(long lastContact) |
protected boolean |
timedOut(long currentTime) |
java.lang.String |
toString() |
protected java.nio.channels.SocketChannel channel
protected final java.util.concurrent.ConcurrentLinkedDeque<RpcServer.Call> responseQueue
protected java.net.Socket socket
protected java.lang.String hostAddress
protected int remotePort
protected UserGroupInformation user
public UserGroupInformation attemptingUser
public Connection(java.nio.channels.SocketChannel channel, long lastContact)
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String getHostAddress()
public java.net.InetAddress getHostInetAddress()
public int getRemotePort()
public void setLastContact(long lastContact)
public RPCProtos.VersionInfo getVersionInfo()
protected void decRpcCount()
protected void incRpcCount()
protected boolean timedOut(long currentTime)
public int readAndProcess() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
protected void processRequest(java.nio.ByteBuffer buf) throws java.io.IOException, java.lang.InterruptedException
buf
- Has the request header and the request param and optionally encoded data buffer
all in this one array.java.io.IOException
java.lang.InterruptedException
protected void close()