org.apache.hadoop.ha.protocolPB

Class HAServiceProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.ha.protocolPB.HAServiceProtocolServerSideTranslatorPB

All Implemented Interfaces:

HAServiceProtocolProtos.HAServiceProtocolService.BlockingInterface, HAServiceProtocolPB, VersionedProtocol

@InterfaceAudience.Private
@InterfaceStability.Stable
public class HAServiceProtocolServerSideTranslatorPB
extends Object
implements HAServiceProtocolPB

This class is used on the server side. Calls come across the wire for the for protocol HAServiceProtocolPB. This class translates the PB data types to the native data types used inside the NN as specified in the generic ClientProtocol.

Constructor Summary

Constructors

Constructor and Description
HAServiceProtocolServerSideTranslatorPB(HAServiceProtocol server)

Method Summary

Methods

Modifier and Type	Method and Description
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.
HAServiceProtocolProtos.GetServiceStatusResponseProto	getServiceStatus(com.google.protobuf.RpcController controller, HAServiceProtocolProtos.GetServiceStatusRequestProto request)
HAServiceProtocolProtos.MonitorHealthResponseProto	monitorHealth(com.google.protobuf.RpcController controller, HAServiceProtocolProtos.MonitorHealthRequestProto request)
HAServiceProtocolProtos.TransitionToActiveResponseProto	transitionToActive(com.google.protobuf.RpcController controller, HAServiceProtocolProtos.TransitionToActiveRequestProto request)
HAServiceProtocolProtos.TransitionToStandbyResponseProto	transitionToStandby(com.google.protobuf.RpcController controller, HAServiceProtocolProtos.TransitionToStandbyRequestProto request)

Methods inherited from class java.lang.Object

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

Constructor Detail

HAServiceProtocolServerSideTranslatorPB

public HAServiceProtocolServerSideTranslatorPB(HAServiceProtocol server)

Method Detail

monitorHealth

public HAServiceProtocolProtos.MonitorHealthResponseProto monitorHealth(com.google.protobuf.RpcController controller,
                                                               HAServiceProtocolProtos.MonitorHealthRequestProto request)
                                                                 throws com.google.protobuf.ServiceException

Specified by:

monitorHealth in interface HAServiceProtocolProtos.HAServiceProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

transitionToActive

public HAServiceProtocolProtos.TransitionToActiveResponseProto transitionToActive(com.google.protobuf.RpcController controller,
                                                                         HAServiceProtocolProtos.TransitionToActiveRequestProto request)
                                                                           throws com.google.protobuf.ServiceException

Specified by:

transitionToActive in interface HAServiceProtocolProtos.HAServiceProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

transitionToStandby

public HAServiceProtocolProtos.TransitionToStandbyResponseProto transitionToStandby(com.google.protobuf.RpcController controller,
                                                                           HAServiceProtocolProtos.TransitionToStandbyRequestProto request)
                                                                             throws com.google.protobuf.ServiceException

Specified by:

transitionToStandby in interface HAServiceProtocolProtos.HAServiceProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getServiceStatus

public HAServiceProtocolProtos.GetServiceStatusResponseProto getServiceStatus(com.google.protobuf.RpcController controller,
                                                                     HAServiceProtocolProtos.GetServiceStatusRequestProto request)
                                                                       throws com.google.protobuf.ServiceException

Specified by:

getServiceStatus in interface HAServiceProtocolProtos.HAServiceProtocolService.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