org.apache.hadoop.hdfs.protocolPB

Class JournalProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.JournalProtocolServerSideTranslatorPB

All Implemented Interfaces:

JournalProtocolProtos.JournalProtocolService.BlockingInterface, JournalProtocolPB

@InterfaceAudience.Private
public class JournalProtocolServerSideTranslatorPB
extends Object
implements JournalProtocolPB

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

Constructor Summary

Constructors

Constructor and Description
JournalProtocolServerSideTranslatorPB(JournalProtocol impl)

Method Summary

Methods

Modifier and Type	Method and Description
JournalProtocolProtos.FenceResponseProto	fence(com.google.protobuf.RpcController controller, JournalProtocolProtos.FenceRequestProto req)
JournalProtocolProtos.JournalResponseProto	journal(com.google.protobuf.RpcController unused, JournalProtocolProtos.JournalRequestProto req)
JournalProtocolProtos.StartLogSegmentResponseProto	startLogSegment(com.google.protobuf.RpcController controller, JournalProtocolProtos.StartLogSegmentRequestProto req)

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalProtocolServerSideTranslatorPB

public JournalProtocolServerSideTranslatorPB(JournalProtocol impl)

Method Detail

journal

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

Specified by:

journal in interface JournalProtocolProtos.JournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

See Also:

JournalProtocol.journal(org.apache.hadoop.hdfs.server.protocol.JournalInfo, long, long, int, byte[])

startLogSegment

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

Specified by:

startLogSegment in interface JournalProtocolProtos.JournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

See Also:

JournalProtocol.startLogSegment(org.apache.hadoop.hdfs.server.protocol.JournalInfo, long, long)

fence

public JournalProtocolProtos.FenceResponseProto fence(com.google.protobuf.RpcController controller,
                                             JournalProtocolProtos.FenceRequestProto req)
                                               throws com.google.protobuf.ServiceException

Specified by:

fence in interface JournalProtocolProtos.JournalProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException