org.apache.hadoop.hbase.ipc

Class AsyncRpcChannel

java.lang.Object

org.apache.hadoop.hbase.ipc.AsyncRpcChannel

@InterfaceAudience.Private
public class AsyncRpcChannel
extends Object

Netty RPC channel

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG
protected static Map<AuthenticationProtos.TokenIdentifier.Kind,org.apache.hadoop.security.token.TokenSelector<? extends org.apache.hadoop.security.token.TokenIdentifier>>	tokenHandlers

Constructor Summary

Constructors

Constructor and Description
AsyncRpcChannel(io.netty.bootstrap.Bootstrap bootstrap, AsyncRpcClient client, User ticket, String serviceName, InetSocketAddress address) Constructor for netty RPC channel

Method Summary

Methods

Modifier and Type	Method and Description
io.netty.util.concurrent.Promise<com.google.protobuf.Message>	callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, PayloadCarryingRpcController controller, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype) Calls method on channel
void	close(Throwable e) Close connection
boolean	equals(Object obj)
int	getConnectionHashCode()
int	hashCode()
boolean	isAlive() Check if the connection is alive
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

tokenHandlers

protected static final Map<AuthenticationProtos.TokenIdentifier.Kind,org.apache.hadoop.security.token.TokenSelector<? extends org.apache.hadoop.security.token.TokenIdentifier>> tokenHandlers

Constructor Detail

AsyncRpcChannel

public AsyncRpcChannel(io.netty.bootstrap.Bootstrap bootstrap,
               AsyncRpcClient client,
               User ticket,
               String serviceName,
               InetSocketAddress address)

Constructor for netty RPC channel

Parameters:

bootstrap - to construct channel on

client - to connect with

ticket - of user which uses connection

serviceName - name of service to connect to

address - to connect to

Method Detail

callMethod

public io.netty.util.concurrent.Promise<com.google.protobuf.Message> callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                                       PayloadCarryingRpcController controller,
                                                                       com.google.protobuf.Message request,
                                                                       com.google.protobuf.Message responsePrototype)

Calls method on channel

Parameters:

method - to call

controller - to run call with

request - to send

responsePrototype - to construct response with

close

public void close(Throwable e)

Close connection

Parameters:

e - exception on close

isAlive

public boolean isAlive()

Check if the connection is alive

Returns:

true if alive

getConnectionHashCode

public int getConnectionHashCode()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object