org.apache.hadoop.hbase.ipc

Class TestBlockingIPC.TestFailingRpcServer.FailingConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.TestBlockingIPC.TestFailingRpcServer.FailingConnection

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

TestBlockingIPC.TestFailingRpcServer

final class TestBlockingIPC.TestFailingRpcServer.FailingConnection
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected InetAddress	addr
protected boolean	authenticatedWithFallback
protected org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup	callCleanup
(package private) SocketChannel	channel
protected org.apache.hadoop.hbase.codec.Codec	codec
protected org.apache.hadoop.io.compress.CompressionCodec	compressionCodec
protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader	connectionHeader
protected boolean	connectionHeaderRead
protected org.apache.hadoop.hbase.io.crypto.aes.CryptoAES	cryptoAES
protected String	hostAddress
(package private) long	lastSentTime
protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProvider	provider
protected int	remotePort
(package private) org.apache.hadoop.hbase.ipc.SimpleRpcServerResponder	responder
(package private) ConcurrentLinkedDeque<org.apache.hadoop.hbase.ipc.RpcResponse>	responseQueue
(package private) Lock	responseWriteLock
protected boolean	retryImmediatelySupported
protected org.apache.hadoop.hbase.ipc.RpcServer	rpcServer
protected boolean	saslContextEstablished
protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProviders	saslProviders
protected org.apache.hadoop.hbase.security.HBaseSaslRpcServer	saslServer
protected org.apache.hbase.thirdparty.com.google.protobuf.BlockingService	service
protected boolean	skipInitialSaslHandshake
protected org.apache.hadoop.security.UserGroupInformation	ugi
protected boolean	useCryptoAesWrap
protected org.apache.hadoop.hbase.security.User	user
protected boolean	useSasl
protected boolean	useWrap

Constructor Summary

Constructors

Modifier	Constructor and Description
private	FailingConnection(TestBlockingIPC.TestFailingRpcServer rpcServer, SocketChannel channel, long lastContact)

Method Summary

Modifier and Type	Method and Description
protected int	channelDataRead(ReadableByteChannel arg0, org.apache.hadoop.hbase.nio.ByteBuff arg1)
void	close()
org.apache.hadoop.hbase.ipc.SimpleServerCall	createCall(int arg0, org.apache.hbase.thirdparty.com.google.protobuf.BlockingService arg1, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor arg2, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader arg3, org.apache.hbase.thirdparty.com.google.protobuf.Message arg4, org.apache.hadoop.hbase.CellScanner arg5, long arg6, InetAddress arg7, int arg8, org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup arg9)
protected void	decRpcCount()
protected void	disposeSasl()
protected void	doRawSaslReply(org.apache.hadoop.hbase.security.SaslStatus arg0, org.apache.hadoop.io.Writable arg1, String arg2, String arg3)
protected void	doRespond(org.apache.hadoop.hbase.ipc.RpcResponse arg0)
protected org.apache.hadoop.hbase.ipc.RpcResponse	getErrorResponse(String arg0, Exception arg1)
String	getHostAddress()
InetAddress	getHostInetAddress()
long	getLastContact()
int	getRemotePort()
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo	getVersionInfo()
protected void	incRpcCount()
boolean	isConnectionOpen()
(package private) boolean	isIdle()
(package private) boolean	isSimpleAuthentication()
void	processOneRpc(org.apache.hadoop.hbase.nio.ByteBuff arg0)
protected boolean	processPreamble(ByteBuffer arg0)
void	processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf)
int	readAndProcess()
void	saslReadAndProcess(org.apache.hadoop.hbase.nio.ByteBuff arg0)
void	setLastContact(long arg0)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

channel

final SocketChannel channel

responder

final org.apache.hadoop.hbase.ipc.SimpleRpcServerResponder responder

responseQueue

final ConcurrentLinkedDeque<org.apache.hadoop.hbase.ipc.RpcResponse> responseQueue

responseWriteLock

final Lock responseWriteLock

lastSentTime

long lastSentTime

rpcServer

protected final org.apache.hadoop.hbase.ipc.RpcServer rpcServer

connectionHeaderRead

protected boolean connectionHeaderRead

callCleanup

protected org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup callCleanup

hostAddress

protected String hostAddress

remotePort

protected int remotePort

addr

protected InetAddress addr

connectionHeader

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

codec

protected org.apache.hadoop.hbase.codec.Codec codec

compressionCodec

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

service

protected org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service

provider

protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProvider provider

saslContextEstablished

protected boolean saslContextEstablished

skipInitialSaslHandshake

protected boolean skipInitialSaslHandshake

useSasl

protected boolean useSasl

saslServer

protected org.apache.hadoop.hbase.security.HBaseSaslRpcServer saslServer

cryptoAES

protected org.apache.hadoop.hbase.io.crypto.aes.CryptoAES cryptoAES

useWrap

protected boolean useWrap

useCryptoAesWrap

protected boolean useCryptoAesWrap

authenticatedWithFallback

protected boolean authenticatedWithFallback

retryImmediatelySupported

protected boolean retryImmediatelySupported

user

protected org.apache.hadoop.hbase.security.User user

ugi

protected org.apache.hadoop.security.UserGroupInformation ugi

saslProviders

protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProviders saslProviders

Constructor Detail

FailingConnection

private FailingConnection(TestBlockingIPC.TestFailingRpcServer rpcServer,
                          SocketChannel channel,
                          long lastContact)

Method Detail

processRequest

public void processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf)
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException

setLastContact

public void setLastContact(long arg0)

getLastContact

public long getLastContact()

isIdle

boolean isIdle()

decRpcCount

protected void decRpcCount()

incRpcCount

protected void incRpcCount()

readAndProcess

public int readAndProcess()
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException

channelDataRead

protected int channelDataRead(ReadableByteChannel arg0,
                              org.apache.hadoop.hbase.nio.ByteBuff arg1)
                       throws IOException

Throws:

IOException

close

public void close()

isConnectionOpen

public boolean isConnectionOpen()

createCall

public org.apache.hadoop.hbase.ipc.SimpleServerCall createCall(int arg0,
                                                               org.apache.hbase.thirdparty.com.google.protobuf.BlockingService arg1,
                                                               org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor arg2,
                                                               org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader arg3,
                                                               org.apache.hbase.thirdparty.com.google.protobuf.Message arg4,
                                                               org.apache.hadoop.hbase.CellScanner arg5,
                                                               long arg6,
                                                               InetAddress arg7,
                                                               int arg8,
                                                               org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup arg9)

doRespond

protected void doRespond(org.apache.hadoop.hbase.ipc.RpcResponse arg0)
                  throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getHostAddress

public String getHostAddress()

getHostInetAddress

public InetAddress getHostInetAddress()

getRemotePort

public int getRemotePort()

getVersionInfo

public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo getVersionInfo()

disposeSasl

protected final void disposeSasl()

doRawSaslReply

protected final void doRawSaslReply(org.apache.hadoop.hbase.security.SaslStatus arg0,
                                    org.apache.hadoop.io.Writable arg1,
                                    String arg2,
                                    String arg3)
                             throws IOException

Throws:

IOException

saslReadAndProcess

public void saslReadAndProcess(org.apache.hadoop.hbase.nio.ByteBuff arg0)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException

processOneRpc

public void processOneRpc(org.apache.hadoop.hbase.nio.ByteBuff arg0)
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException

getErrorResponse

protected final org.apache.hadoop.hbase.ipc.RpcResponse getErrorResponse(String arg0,
                                                                         Exception arg1)
                                                                  throws IOException

Throws:

IOException

processPreamble

protected final boolean processPreamble(ByteBuffer arg0)
                                 throws IOException

Throws:

IOException

isSimpleAuthentication

boolean isSimpleAuthentication()