Package org.apache.hadoop.ozone.protocolPB

Class OzoneManagerProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.ozone.protocolPB.OzoneManagerProtocolServerSideTranslatorPB

All Implemented Interfaces:

org.apache.hadoop.ozone.om.protocolPB.OzoneManagerProtocolPB, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OzoneManagerService.BlockingInterface

public class OzoneManagerProtocolServerSideTranslatorPB
extends Object
implements org.apache.hadoop.ozone.om.protocolPB.OzoneManagerProtocolPB

This is the server-side translator that forwards requests received from OzoneManagerProtocolPB to OzoneManager.

Constructor Summary

Constructors

Constructor	Description
OzoneManagerProtocolServerSideTranslatorPB(OzoneManager impl, OzoneManagerRatisServer ratisServer, org.apache.hadoop.hdds.utils.ProtocolMessageMetrics<com.google.protobuf.ProtocolMessageEnum> metrics)	Constructs an instance of the server handler.

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest	getLastRequestToSubmit()
static org.slf4j.Logger	getLog()
org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse	processRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest request)
org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse	submitRequest(com.google.protobuf.RpcController controller, org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest request)	Submit mutating requests to Ratis server in OM, and process read requests.

Methods inherited from class java.lang.Object

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

Constructor Details

OzoneManagerProtocolServerSideTranslatorPB

public OzoneManagerProtocolServerSideTranslatorPB(OzoneManager impl,
 OzoneManagerRatisServer ratisServer,
 org.apache.hadoop.hdds.utils.ProtocolMessageMetrics<com.google.protobuf.ProtocolMessageEnum> metrics)

Constructs an instance of the server handler.

Parameters:

impl - OzoneManagerProtocolPB

Method Details

submitRequest

public org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse submitRequest(com.google.protobuf.RpcController controller,
 org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest request)
                                                                                           throws com.google.protobuf.ServiceException

Submit mutating requests to Ratis server in OM, and process read requests.

Specified by:

submitRequest in interface org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OzoneManagerService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

processRequest

public org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMResponse processRequest(org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest request)
                                                                                            throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException

getLastRequestToSubmit

public org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos.OMRequest getLastRequestToSubmit()

getLog

public static org.slf4j.Logger getLog()