org.apache.hadoop.ha.protocolPB

Class ZKFCProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.ha.protocolPB.ZKFCProtocolServerSideTranslatorPB

All Implemented Interfaces:

ZKFCProtocolProtos.ZKFCProtocolService.BlockingInterface, ZKFCProtocolPB, VersionedProtocol

@InterfaceAudience.Private
@InterfaceStability.Stable
public class ZKFCProtocolServerSideTranslatorPB
extends Object
implements ZKFCProtocolPB

Constructor Summary

Constructors

Constructor and Description
ZKFCProtocolServerSideTranslatorPB(ZKFCProtocol server)

Method Summary

Methods

Modifier and Type	Method and Description
ZKFCProtocolProtos.CedeActiveResponseProto	cedeActive(com.google.protobuf.RpcController controller, ZKFCProtocolProtos.CedeActiveRequestProto request)
ProtocolSignature	getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash) Return protocol version corresponding to protocol interface.
long	getProtocolVersion(String protocol, long clientVersion) Return protocol version corresponding to protocol interface.
ZKFCProtocolProtos.GracefulFailoverResponseProto	gracefulFailover(com.google.protobuf.RpcController controller, ZKFCProtocolProtos.GracefulFailoverRequestProto request)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKFCProtocolServerSideTranslatorPB

public ZKFCProtocolServerSideTranslatorPB(ZKFCProtocol server)

Method Detail

cedeActive

public ZKFCProtocolProtos.CedeActiveResponseProto cedeActive(com.google.protobuf.RpcController controller,
                                                    ZKFCProtocolProtos.CedeActiveRequestProto request)
                                                      throws com.google.protobuf.ServiceException

Specified by:

cedeActive in interface ZKFCProtocolProtos.ZKFCProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

gracefulFailover

public ZKFCProtocolProtos.GracefulFailoverResponseProto gracefulFailover(com.google.protobuf.RpcController controller,
                                                                ZKFCProtocolProtos.GracefulFailoverRequestProto request)
                                                                  throws com.google.protobuf.ServiceException

Specified by:

gracefulFailover in interface ZKFCProtocolProtos.ZKFCProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getProtocolVersion

public long getProtocolVersion(String protocol,
                      long clientVersion)
                        throws IOException

Description copied from interface: VersionedProtocol

Return protocol version corresponding to protocol interface.

Specified by:

getProtocolVersion in interface VersionedProtocol

Parameters:

protocol - The classname of the protocol interface

clientVersion - The version of the protocol that the client speaks

Returns:

the version that the server will speak

Throws:

IOException - if any IO error occurs

getProtocolSignature

public ProtocolSignature getProtocolSignature(String protocol,
                                     long clientVersion,
                                     int clientMethodsHash)
                                       throws IOException

Description copied from interface: VersionedProtocol

Return protocol version corresponding to protocol interface.

Specified by:

getProtocolSignature in interface VersionedProtocol

Parameters:

protocol - The classname of the protocol interface

clientVersion - The version of the protocol that the client speaks

clientMethodsHash - the hashcode of client protocol methods

Returns:

the server protocol signature containing its version and a list of its supported methods

Throws:

IOException

See Also:

for a default implementation