org.apache.hadoop.hdfs.qjournal.protocolPB

Class QJournalProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.qjournal.protocolPB.QJournalProtocolServerSideTranslatorPB

All Implemented Interfaces:

QJournalProtocolProtos.QJournalProtocolService.BlockingInterface, QJournalProtocolPB

@InterfaceAudience.Private
public class QJournalProtocolServerSideTranslatorPB
extends Object
implements QJournalProtocolPB

Implementation for protobuf service that forwards requests received on JournalProtocolPB to the JournalProtocol server implementation.

Constructor Summary

Constructors

Constructor and Description
QJournalProtocolServerSideTranslatorPB(QJournalProtocol impl)

Method Summary

Methods

Modifier and Type	Method and Description
QJournalProtocolProtos.AcceptRecoveryResponseProto	acceptRecovery(com.google.protobuf.RpcController controller, QJournalProtocolProtos.AcceptRecoveryRequestProto request)
QJournalProtocolProtos.FinalizeLogSegmentResponseProto	finalizeLogSegment(com.google.protobuf.RpcController controller, QJournalProtocolProtos.FinalizeLogSegmentRequestProto req)
QJournalProtocolProtos.FormatResponseProto	format(com.google.protobuf.RpcController controller, QJournalProtocolProtos.FormatRequestProto request)
QJournalProtocolProtos.GetEditLogManifestResponseProto	getEditLogManifest(com.google.protobuf.RpcController controller, QJournalProtocolProtos.GetEditLogManifestRequestProto request)
QJournalProtocolProtos.GetJournalStateResponseProto	getJournalState(com.google.protobuf.RpcController controller, QJournalProtocolProtos.GetJournalStateRequestProto request)
QJournalProtocolProtos.HeartbeatResponseProto	heartbeat(com.google.protobuf.RpcController controller, QJournalProtocolProtos.HeartbeatRequestProto req)
QJournalProtocolProtos.IsFormattedResponseProto	isFormatted(com.google.protobuf.RpcController controller, QJournalProtocolProtos.IsFormattedRequestProto request)
QJournalProtocolProtos.JournalResponseProto	journal(com.google.protobuf.RpcController unused, QJournalProtocolProtos.JournalRequestProto req)
QJournalProtocolProtos.NewEpochResponseProto	newEpoch(com.google.protobuf.RpcController controller, QJournalProtocolProtos.NewEpochRequestProto request)
QJournalProtocolProtos.PrepareRecoveryResponseProto	prepareRecovery(com.google.protobuf.RpcController controller, QJournalProtocolProtos.PrepareRecoveryRequestProto request)
QJournalProtocolProtos.PurgeLogsResponseProto	purgeLogs(com.google.protobuf.RpcController controller, QJournalProtocolProtos.PurgeLogsRequestProto req)
QJournalProtocolProtos.StartLogSegmentResponseProto	startLogSegment(com.google.protobuf.RpcController controller, QJournalProtocolProtos.StartLogSegmentRequestProto req)

Methods inherited from class java.lang.Object

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

Constructor Detail

QJournalProtocolServerSideTranslatorPB

public QJournalProtocolServerSideTranslatorPB(QJournalProtocol impl)

Method Detail

isFormatted

public QJournalProtocolProtos.IsFormattedResponseProto isFormatted(com.google.protobuf.RpcController controller,
                                                          QJournalProtocolProtos.IsFormattedRequestProto request)
                                                            throws com.google.protobuf.ServiceException

Specified by:

isFormatted in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getJournalState

public QJournalProtocolProtos.GetJournalStateResponseProto getJournalState(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.GetJournalStateRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

getJournalState in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

newEpoch

public QJournalProtocolProtos.NewEpochResponseProto newEpoch(com.google.protobuf.RpcController controller,
                                                    QJournalProtocolProtos.NewEpochRequestProto request)
                                                      throws com.google.protobuf.ServiceException

Specified by:

newEpoch in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

format

public QJournalProtocolProtos.FormatResponseProto format(com.google.protobuf.RpcController controller,
                                                QJournalProtocolProtos.FormatRequestProto request)
                                                  throws com.google.protobuf.ServiceException

Specified by:

format in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

journal

public QJournalProtocolProtos.JournalResponseProto journal(com.google.protobuf.RpcController unused,
                                                  QJournalProtocolProtos.JournalRequestProto req)
                                                    throws com.google.protobuf.ServiceException

Specified by:

journal in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

See Also:

JournalProtocol#journal

heartbeat

public QJournalProtocolProtos.HeartbeatResponseProto heartbeat(com.google.protobuf.RpcController controller,
                                                      QJournalProtocolProtos.HeartbeatRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

heartbeat in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

See Also:

JournalProtocol#heartbeat

startLogSegment

public QJournalProtocolProtos.StartLogSegmentResponseProto startLogSegment(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.StartLogSegmentRequestProto req)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

startLogSegment in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

See Also:

JournalProtocol#startLogSegment

finalizeLogSegment

public QJournalProtocolProtos.FinalizeLogSegmentResponseProto finalizeLogSegment(com.google.protobuf.RpcController controller,
                                                                        QJournalProtocolProtos.FinalizeLogSegmentRequestProto req)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

finalizeLogSegment in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

purgeLogs

public QJournalProtocolProtos.PurgeLogsResponseProto purgeLogs(com.google.protobuf.RpcController controller,
                                                      QJournalProtocolProtos.PurgeLogsRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

purgeLogs in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getEditLogManifest

public QJournalProtocolProtos.GetEditLogManifestResponseProto getEditLogManifest(com.google.protobuf.RpcController controller,
                                                                        QJournalProtocolProtos.GetEditLogManifestRequestProto request)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

getEditLogManifest in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

prepareRecovery

public QJournalProtocolProtos.PrepareRecoveryResponseProto prepareRecovery(com.google.protobuf.RpcController controller,
                                                                  QJournalProtocolProtos.PrepareRecoveryRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

prepareRecovery in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

acceptRecovery

public QJournalProtocolProtos.AcceptRecoveryResponseProto acceptRecovery(com.google.protobuf.RpcController controller,
                                                                QJournalProtocolProtos.AcceptRecoveryRequestProto request)
                                                                  throws com.google.protobuf.ServiceException

Specified by:

acceptRecovery in interface QJournalProtocolProtos.QJournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException