org.apache.hadoop.hbase.ipc

Class RpcServer.Connection

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcServer.Connection

Enclosing class:

RpcServer

public class RpcServer.Connection
extends Object

Reads calls from a connection and queues them for handling.

Field Summary

Fields

Modifier and Type	Field and Description
UserGroupInformation	attemptingUser
protected SocketChannel	channel
protected String	hostAddress
protected int	remotePort
protected ConcurrentLinkedDeque<org.apache.hadoop.hbase.ipc.RpcServer.Call>	responseQueue
protected Socket	socket
protected UserGroupInformation	user

Constructor Summary

Constructors

Constructor and Description
Connection(SocketChannel channel, long lastContact)

Method Summary

Modifier and Type	Method and Description
protected void	close()
protected void	decRpcCount()
String	getHostAddress()
InetAddress	getHostInetAddress()
int	getRemotePort()
RPCProtos.VersionInfo	getVersionInfo()
protected void	incRpcCount()
protected void	processRequest(byte[] buf)
int	readAndProcess() Read off the wire.
void	setLastContact(long lastContact)
protected boolean	timedOut(long currentTime)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected SocketChannel channel

responseQueue

protected final ConcurrentLinkedDeque<org.apache.hadoop.hbase.ipc.RpcServer.Call> responseQueue

socket

protected Socket socket

hostAddress

protected String hostAddress

remotePort

protected int remotePort

user

protected UserGroupInformation user

attemptingUser

public UserGroupInformation attemptingUser

Constructor Detail

Connection

public Connection(SocketChannel channel,
                  long lastContact)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getHostAddress

public String getHostAddress()

getHostInetAddress

public InetAddress getHostInetAddress()

getRemotePort

public int getRemotePort()

setLastContact

public void setLastContact(long lastContact)

getVersionInfo

public RPCProtos.VersionInfo getVersionInfo()

decRpcCount

protected void decRpcCount()

incRpcCount

protected void incRpcCount()

timedOut

protected boolean timedOut(long currentTime)

readAndProcess

public int readAndProcess()
                   throws IOException,
                          InterruptedException

Read off the wire. If there is not enough data to read, update the connection state with what we have and returns.

Returns:

Returns -1 if failure (and caller will close connection), else zero or more.

Throws:

IOException

InterruptedException

processRequest

protected void processRequest(byte[] buf)
                       throws IOException,
                              InterruptedException

Parameters:

buf - Has the request header and the request param and optionally encoded data buffer all in this one array.

Throws:

IOException

InterruptedException

close

protected void close()