Package org.apache.hadoop.ha.protocolPB

Class ZKFCProtocolServerSideTranslatorPB

java.lang.Object
org.apache.hadoop.ha.protocolPB.ZKFCProtocolServerSideTranslatorPB
All Implemented Interfaces:
org.apache.hadoop.ha.proto.ZKFCProtocolProtos.ZKFCProtocolService.BlockingInterface, ZKFCProtocolPB, VersionedProtocol
@Private @Stable public class ZKFCProtocolServerSideTranslatorPB extends Object implements ZKFCProtocolPB

  • Constructor Summary

    Constructors
    Constructor
    Description
    ZKFCProtocolServerSideTranslatorPB(ZKFCProtocol server)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.ha.proto.ZKFCProtocolProtos.CedeActiveResponseProto
    cedeActive(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.ha.proto.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.
    org.apache.hadoop.ha.proto.ZKFCProtocolProtos.GracefulFailoverResponseProto
    gracefulFailover(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.ha.proto.ZKFCProtocolProtos.GracefulFailoverRequestProto request)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ZKFCProtocolServerSideTranslatorPB

      public ZKFCProtocolServerSideTranslatorPB(ZKFCProtocol server)

  • Method Details

    • cedeActive

      public org.apache.hadoop.ha.proto.ZKFCProtocolProtos.CedeActiveResponseProto cedeActive(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.ha.proto.ZKFCProtocolProtos.CedeActiveRequestProto request) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      cedeActive in interface org.apache.hadoop.ha.proto.ZKFCProtocolProtos.ZKFCProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.protobuf.ServiceException

    • gracefulFailover

      public org.apache.hadoop.ha.proto.ZKFCProtocolProtos.GracefulFailoverResponseProto gracefulFailover(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.ha.proto.ZKFCProtocolProtos.GracefulFailoverRequestProto request) throws org.apache.hadoop.thirdparty.protobuf.ServiceException
      Specified by:
      gracefulFailover in interface org.apache.hadoop.ha.proto.ZKFCProtocolProtos.ZKFCProtocolService.BlockingInterface
      Throws:
      org.apache.hadoop.thirdparty.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 - raised on errors performing I/O.
      See Also: