public class BadAuthNettyRpcConnection extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.hbase.ipc.CellBlockBuilder |
cellBlockBuilder |
protected org.apache.hadoop.hbase.codec.Codec |
codec |
protected org.apache.hadoop.io.compress.CompressionCodec |
compressor |
protected org.apache.hadoop.conf.Configuration |
conf |
protected static boolean |
CRYPTO_AES_ENABLED_DEFAULT |
protected static String |
CRYPTO_AES_ENABLED_KEY |
protected long |
lastTouched |
protected org.apache.hadoop.hbase.client.MetricsConnection |
metrics |
protected org.apache.hadoop.hbase.security.provider.SaslClientAuthenticationProvider |
provider |
protected int |
reloginMaxBackoff |
protected org.apache.hadoop.hbase.ipc.ConnectionId |
remoteId |
protected org.apache.hadoop.hbase.security.SecurityInfo |
securityInfo |
protected org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer |
timeoutTimer |
protected org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> |
token |
protected boolean |
useSasl |
Constructor and Description |
---|
BadAuthNettyRpcConnection(org.apache.hadoop.hbase.ipc.NettyRpcClient rpcClient,
org.apache.hadoop.hbase.ipc.ConnectionId remoteId) |
Modifier and Type | Method and Description |
---|---|
protected void |
callTimeout(org.apache.hadoop.hbase.ipc.Call arg0) |
protected String |
chooseServerPrincipal(Set<String> arg0,
org.apache.hadoop.hbase.ipc.Call arg1) |
void |
cleanupConnection() |
protected org.apache.hadoop.hbase.ipc.Call |
createSecurityPreambleCall(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.Call> arg0) |
protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader |
getConnectionHeader() |
protected byte[] |
getConnectionHeaderPreamble() |
long |
getLastTouched() |
protected InetSocketAddress |
getRemoteInetAddress(org.apache.hadoop.hbase.client.MetricsConnection arg0) |
protected Set<String> |
getServerPrincipals() |
boolean |
isActive() |
protected boolean |
isKerberosAuth() |
protected <T> T |
randomSelect(Collection<T> arg0) |
(package private) <T extends InputStream & DataInput> |
readResponse(T arg0,
Map<Integer,org.apache.hadoop.hbase.ipc.Call> arg1,
org.apache.hadoop.hbase.ipc.Call arg2,
Consumer<org.apache.hadoop.ipc.RemoteException> arg3) |
org.apache.hadoop.hbase.ipc.ConnectionId |
remoteId() |
protected void |
saslNegotiationDone(String arg0,
boolean arg1) |
protected void |
scheduleTimeoutTask(org.apache.hadoop.hbase.ipc.Call arg0) |
void |
sendRequest(org.apache.hadoop.hbase.ipc.Call arg0,
org.apache.hadoop.hbase.ipc.HBaseRpcController arg1) |
void |
setLastTouched(long arg0) |
void |
shutdown() |
protected final org.apache.hadoop.hbase.ipc.ConnectionId remoteId
protected final boolean useSasl
protected final org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token
protected final org.apache.hadoop.hbase.security.SecurityInfo securityInfo
protected final int reloginMaxBackoff
protected final org.apache.hadoop.hbase.codec.Codec codec
protected final org.apache.hadoop.io.compress.CompressionCodec compressor
protected final org.apache.hadoop.hbase.ipc.CellBlockBuilder cellBlockBuilder
protected final org.apache.hadoop.hbase.client.MetricsConnection metrics
protected final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer timeoutTimer
protected final org.apache.hadoop.conf.Configuration conf
protected static String CRYPTO_AES_ENABLED_KEY
protected static boolean CRYPTO_AES_ENABLED_DEFAULT
protected long lastTouched
protected org.apache.hadoop.hbase.security.provider.SaslClientAuthenticationProvider provider
public BadAuthNettyRpcConnection(org.apache.hadoop.hbase.ipc.NettyRpcClient rpcClient, org.apache.hadoop.hbase.ipc.ConnectionId remoteId) throws IOException
IOException
protected byte[] getConnectionHeaderPreamble()
protected void callTimeout(org.apache.hadoop.hbase.ipc.Call arg0)
public boolean isActive()
public void shutdown()
public void cleanupConnection()
public void sendRequest(org.apache.hadoop.hbase.ipc.Call arg0, org.apache.hadoop.hbase.ipc.HBaseRpcController arg1)
protected final void scheduleTimeoutTask(org.apache.hadoop.hbase.ipc.Call arg0)
protected final org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader getConnectionHeader()
protected final InetSocketAddress getRemoteInetAddress(org.apache.hadoop.hbase.client.MetricsConnection arg0) throws UnknownHostException
UnknownHostException
protected final boolean isKerberosAuth()
protected final Set<String> getServerPrincipals() throws IOException
IOException
protected final <T> T randomSelect(Collection<T> arg0)
protected final String chooseServerPrincipal(Set<String> arg0, org.apache.hadoop.hbase.ipc.Call arg1) throws SaslException
SaslException
protected final void saslNegotiationDone(String arg0, boolean arg1)
public org.apache.hadoop.hbase.ipc.ConnectionId remoteId()
public long getLastTouched()
public void setLastTouched(long arg0)
protected final org.apache.hadoop.hbase.ipc.Call createSecurityPreambleCall(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.Call> arg0)
<T extends InputStream & DataInput> void readResponse(T arg0, Map<Integer,org.apache.hadoop.hbase.ipc.Call> arg1, org.apache.hadoop.hbase.ipc.Call arg2, Consumer<org.apache.hadoop.ipc.RemoteException> arg3) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.