org.apache.hadoop.hbase.ipc

Class TestNettyIPC.TestFailingRpcServer.FailingConnection

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

TestNettyIPC.TestFailingRpcServer

static final class TestNettyIPC.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) org.apache.hbase.thirdparty.io.netty.channel.Channel	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
protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProvider	provider
protected int	remotePort
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(TestNettyIPC.TestFailingRpcServer rpcServer, org.apache.hbase.thirdparty.io.netty.channel.Channel channel)

Method Summary

Modifier and Type	Method and Description
protected void	callCleanupIfNeeded()
void	close()
org.apache.hadoop.hbase.ipc.NettyServerCall	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	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()
int	getRemotePort()
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo	getVersionInfo()
boolean	isConnectionOpen()
(package private) boolean	isSimpleAuthentication()
(package private) void	process(org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf arg0)
(package private) void	process(org.apache.hadoop.hbase.nio.ByteBuff arg0)
(package private) void	process(ByteBuffer arg0)
void	processOneRpc(org.apache.hadoop.hbase.nio.ByteBuff arg0)
protected boolean	processPreamble(ByteBuffer arg0)
void	processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf)
void	saslReadAndProcess(org.apache.hadoop.hbase.nio.ByteBuff arg0)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

channel

final org.apache.hbase.thirdparty.io.netty.channel.Channel channel

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(TestNettyIPC.TestFailingRpcServer rpcServer,
                          org.apache.hbase.thirdparty.io.netty.channel.Channel channel)

Method Detail

processRequest

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

Throws:

IOException

InterruptedException

process

void process(org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf arg0)
      throws IOException,
             InterruptedException

Throws:

IOException

InterruptedException

process

void process(ByteBuffer arg0)
      throws IOException,
             InterruptedException

Throws:

IOException

InterruptedException

process

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

Throws:

IOException

InterruptedException

close

public void close()

isConnectionOpen

public boolean isConnectionOpen()

createCall

public org.apache.hadoop.hbase.ipc.NettyServerCall 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)

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

callCleanupIfNeeded

protected final void callCleanupIfNeeded()

processPreamble

protected final boolean processPreamble(ByteBuffer arg0)
                                 throws IOException

Throws:

IOException

isSimpleAuthentication

boolean isSimpleAuthentication()