org.apache.hadoop.hbase.ipc

Class FailingNettyRpcServer.FailingConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.FailingNettyRpcServer.FailingConnection

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

FailingNettyRpcServer

static final class FailingNettyRpcServer.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 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 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 org.apache.hadoop.hbase.security.User	user
protected boolean	useSasl

Constructor Summary

Constructors

Modifier	Constructor and Description
private	FailingConnection(FailingNettyRpcServer 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)
(package private) void	finishSaslNegotiation()
protected org.apache.hadoop.hbase.ipc.RpcResponse	getErrorResponse(String arg0, Exception arg1)
String	getHostAddress()
InetAddress	getHostInetAddress()
(package private) org.apache.hadoop.hbase.security.HBaseSaslRpcServer	getOrCreateSaslServer()
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)
void	processOneRpc(org.apache.hadoop.hbase.nio.ByteBuff arg0)
protected boolean	processPreamble(ByteBuffer arg0)
void	processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf)
(package private) void	setupHandler()
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

skipInitialSaslHandshake

protected boolean skipInitialSaslHandshake

useSasl

protected boolean useSasl

saslServer

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

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(FailingNettyRpcServer 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

setupHandler

void setupHandler()

process

void process(org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf 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

getOrCreateSaslServer

org.apache.hadoop.hbase.security.HBaseSaslRpcServer getOrCreateSaslServer()
                                                                   throws IOException

Throws:

IOException

finishSaslNegotiation

void finishSaslNegotiation()
                    throws IOException

Throws:

IOException

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()