RpcServer.Connection (Apache HBase 1.2.12 API)

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
`private InetAddress`	`addr`
`org.apache.hadoop.security.UserGroupInformation`	`attemptingUser`
`private boolean`	`authenticatedWithFallback`
`private RpcServer.Call`	`authFailedCall`
`private ByteArrayOutputStream`	`authFailedResponse`
`private AuthMethod`	`authMethod`
`private static int`	`AUTHORIZATION_FAILED_CALLID`
`protected SocketChannel`	`channel`
`private Codec`	`codec` Codec the client asked use.
`private org.apache.hadoop.io.compress.CompressionCodec`	`compressionCodec` Compression codec the client asked us use.
`(package private) org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ConnectionHeader`	`connectionHeader`
`private boolean`	`connectionHeaderRead`
`private boolean`	`connectionPreambleRead`
`private ByteBuffer`	`data`
`private ByteBuffer`	`dataLengthBuffer`
`protected String`	`hostAddress`
`private long`	`lastContact`
`private ByteBuffer`	`preambleBuffer`
`protected int`	`remotePort`
`protected ConcurrentLinkedDeque<RpcServer.Call>`	`responseQueue`
`private Lock`	`responseWriteLock`
`private boolean`	`retryImmediatelySupported`
`private Counter`	`rpcCount`
`private static int`	`SASL_CALLID`
`private RpcServer.Call`	`saslCall`
`private boolean`	`saslContextEstablished`
`(package private) SaslServer`	`saslServer`
`(package private) com.google.protobuf.BlockingService`	`service`
`private boolean`	`skipInitialSaslHandshake`
`protected Socket`	`socket`
`protected org.apache.hadoop.security.UserGroupInformation`	`ugi`
`private ByteBuffer`	`unwrappedData`
`private ByteBuffer`	`unwrappedDataLengthBuffer`
`protected User`	`user`
`(package private) boolean`	`useSasl`
`private boolean`	`useWrap`

Constructor Summary

Constructors
Constructor and Description

RpcServer.Connection(SocketChannel channel, long lastContact)

Constructors
Constructor and Description
`RpcServer.Connection(SocketChannel channel, long lastContact)`

Method Summary

Methods
Modifier and Type	Method and Description
`private boolean`	`authorizeConnection()`
`protected void`	`close()`
`private org.apache.hadoop.security.UserGroupInformation`	`createUser(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ConnectionHeader head)`
`protected void`	`decRpcCount()`
`private void`	`disposeSasl()`
`private int`	`doBadPreambleHandling(String msg)`
`private int`	`doBadPreambleHandling(String msg, Exception e)`
`private void`	`doRawSaslReply(SaslStatus status, org.apache.hadoop.io.Writable rv, String errorClass, String error)` No protobuf encoding of raw sasl messages
`private org.apache.hadoop.security.UserGroupInformation`	`getAuthorizedUgi(String authorizedId)`
`private String`	`getFatalConnectionString(int version, byte authByte)`
`String`	`getHostAddress()`
`InetAddress`	`getHostInetAddress()`
`int`	`getRemotePort()`
`org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo`	`getVersionInfo()`
`protected void`	`incRpcCount()`
`private boolean`	`isIdle()`
`private void`	`process()` Process the data buffer and clean the connection state for the next call.
`private void`	`processConnectionHeader(byte[] buf)`
`private void`	`processOneRpc(byte[] buf)`
`protected void`	`processRequest(byte[] buf)`
`private void`	`processUnwrappedData(byte[] inBuf)`
`private int`	`read4Bytes()`
`int`	`readAndProcess()` Read off the wire.
`private int`	`readPreamble()`
`private void`	`saslReadAndProcess(byte[] saslToken)`
`void`	`setLastContact(long lastContact)`
`private void`	`setupCellBlockCodecs(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ConnectionHeader header)` Set up cell block codecs
`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

connectionPreambleRead
```
private boolean connectionPreambleRead
```

connectionHeaderRead
```
private boolean connectionHeaderRead
```

channel
```
protected SocketChannel channel
```

data
```
private ByteBuffer data
```

dataLengthBuffer
```
private ByteBuffer dataLengthBuffer
```

preambleBuffer
```
private ByteBuffer preambleBuffer
```

responseQueue

protected final ConcurrentLinkedDeque<RpcServer.Call> responseQueue

responseWriteLock
```
private final Lock responseWriteLock
```

rpcCount
```
private Counter rpcCount
```

lastContact
```
private long lastContact
```

addr
```
private InetAddress addr
```

socket
```
protected Socket socket
```

hostAddress
```
protected String hostAddress
```

remotePort
```
protected int remotePort
```

connectionHeader

org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader

codec
```
private Codec codec
```
Codec the client asked use.

compressionCodec

private org.apache.hadoop.io.compress.CompressionCodec compressionCodec

Compression codec the client asked us use.

service

com.google.protobuf.BlockingService service

authMethod
```
private AuthMethod authMethod
```

saslContextEstablished
```
private boolean saslContextEstablished
```

skipInitialSaslHandshake

private boolean skipInitialSaslHandshake

unwrappedData
```
private ByteBuffer unwrappedData
```

unwrappedDataLengthBuffer

private ByteBuffer unwrappedDataLengthBuffer

useSasl
```
boolean useSasl
```

saslServer
```
SaslServer saslServer
```

useWrap
```
private boolean useWrap
```

AUTHORIZATION_FAILED_CALLID
```
private static final int AUTHORIZATION_FAILED_CALLID
```
See Also:
Constant Field Values

authFailedCall

private final RpcServer.Call authFailedCall

authFailedResponse

private ByteArrayOutputStream authFailedResponse

SASL_CALLID
```
private static final int SASL_CALLID
```
See Also:
Constant Field Values

saslCall
```
private final RpcServer.Call saslCall
```

authenticatedWithFallback

private boolean authenticatedWithFallback

retryImmediatelySupported

private boolean retryImmediatelySupported

attemptingUser

public org.apache.hadoop.security.UserGroupInformation attemptingUser

user
```
protected User user
```

ugi

protected org.apache.hadoop.security.UserGroupInformation ugi

Constructor Detail

RpcServer.Connection

public RpcServer.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 org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo getVersionInfo()

isIdle
```
private boolean isIdle()
```

decRpcCount
```
protected void decRpcCount()
```

incRpcCount
```
protected void incRpcCount()
```

timedOut

protected boolean timedOut(long currentTime)

getAuthorizedUgi

private org.apache.hadoop.security.UserGroupInformation getAuthorizedUgi(String authorizedId)
                                                                  throws IOException

Throws:: IOException

saslReadAndProcess

private void saslReadAndProcess(byte[] saslToken)
                         throws IOException,
                                InterruptedException

Throws:: IOException; InterruptedException

doRawSaslReply

private void doRawSaslReply(SaslStatus status,
                  org.apache.hadoop.io.Writable rv,
                  String errorClass,
                  String error)
                     throws IOException

No protobuf encoding of raw sasl messages

Throws:: IOException

disposeSasl
```
private void disposeSasl()
```

readPreamble

private int readPreamble()
                  throws IOException

Throws:: IOException

read4Bytes

private int read4Bytes()
                throws IOException

Throws:: IOException

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

process

private void process()
              throws IOException,
                     InterruptedException

Process the data buffer and clean the connection state for the next call.

Throws:: IOException; InterruptedException

getFatalConnectionString

private String getFatalConnectionString(int version,
                              byte authByte)

doBadPreambleHandling

private int doBadPreambleHandling(String msg)
                           throws IOException

Throws:: IOException

doBadPreambleHandling

private int doBadPreambleHandling(String msg,
                        Exception e)
                           throws IOException

Throws:: IOException

processConnectionHeader

private void processConnectionHeader(byte[] buf)
                              throws IOException

Throws:: IOException

setupCellBlockCodecs

private void setupCellBlockCodecs(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ConnectionHeader header)
                           throws FatalConnectionException

Set up cell block codecs

Throws:: FatalConnectionException

processUnwrappedData

private void processUnwrappedData(byte[] inBuf)
                           throws IOException,
                                  InterruptedException

Throws:: IOException; InterruptedException

processOneRpc

private void processOneRpc(byte[] buf)
                    throws IOException,
                           InterruptedException

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

authorizeConnection

private boolean authorizeConnection()
                             throws IOException

Throws:: IOException

close
```
protected void close()
```

createUser

private org.apache.hadoop.security.UserGroupInformation createUser(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ConnectionHeader head)

Class RpcServer.Connection

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

connectionPreambleRead

connectionHeaderRead

channel

data

dataLengthBuffer

preambleBuffer

responseQueue

responseWriteLock

rpcCount

lastContact

addr

socket

hostAddress

remotePort

connectionHeader

codec

compressionCodec

service

authMethod

saslContextEstablished

skipInitialSaslHandshake

unwrappedData

unwrappedDataLengthBuffer

useSasl

saslServer

useWrap

AUTHORIZATION_FAILED_CALLID

authFailedCall

authFailedResponse

SASL_CALLID

saslCall

authenticatedWithFallback

retryImmediatelySupported

attemptingUser

user

ugi

Constructor Detail

RpcServer.Connection

Method Detail

toString

getHostAddress

getHostInetAddress

getRemotePort

setLastContact

getVersionInfo

isIdle

decRpcCount

incRpcCount

timedOut

getAuthorizedUgi

saslReadAndProcess

doRawSaslReply

disposeSasl

readPreamble

read4Bytes

readAndProcess

process

getFatalConnectionString

doBadPreambleHandling

doBadPreambleHandling

processConnectionHeader

setupCellBlockCodecs

processUnwrappedData

processOneRpc

processRequest

authorizeConnection

close

createUser