Package org.apache.hadoop.ozone.protocolPB

Class StorageContainerDatanodeProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.ozone.protocolPB.StorageContainerDatanodeProtocolServerSideTranslatorPB

All Implemented Interfaces:

org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.StorageContainerDatanodeProtocolService.BlockingInterface, StorageContainerDatanodeProtocolPB

public class StorageContainerDatanodeProtocolServerSideTranslatorPB
extends Object
implements StorageContainerDatanodeProtocolPB

This class is the server-side translator that forwards requests received on StorageContainerDatanodeProtocolPB to the StorageContainerDatanodeProtocol server implementation.

Constructor Summary

Constructors

Constructor	Description
StorageContainerDatanodeProtocolServerSideTranslatorPB(StorageContainerDatanodeProtocol impl, org.apache.hadoop.hdds.utils.ProtocolMessageMetrics<com.google.protobuf.ProtocolMessageEnum> protocolMessageMetrics)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeResponse	processMessage(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeRequest request)
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisteredResponseProto	register(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisterRequestProto request)
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeResponse	submitRequest(com.google.protobuf.RpcController controller, org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

StorageContainerDatanodeProtocolServerSideTranslatorPB

public StorageContainerDatanodeProtocolServerSideTranslatorPB(StorageContainerDatanodeProtocol impl,
 org.apache.hadoop.hdds.utils.ProtocolMessageMetrics<com.google.protobuf.ProtocolMessageEnum> protocolMessageMetrics)

Method Details

register

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisteredResponseProto register(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMRegisterRequestProto request)
                                                                                                                 throws IOException

Throws:

IOException

submitRequest

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeResponse submitRequest(com.google.protobuf.RpcController controller,
 org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeRequest request)
                                                                                                               throws com.google.protobuf.ServiceException

Specified by:

submitRequest in interface org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.StorageContainerDatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

processMessage

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeResponse processMessage(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMDatanodeRequest request)
                                                                                                                throws com.google.protobuf.ServiceException

Throws:

com.google.protobuf.ServiceException