commit c17eb3ea5d328e63fd913280dff13b2e5b185acf
author Márton Elek <elek@apache.org> Tue Sep 24 12:20:42 2019 +0200
committer Márton Elek <elek@apache.org> Wed Sep 25 11:00:05 2019 +0200
tree 5df75505328fe4e292ca4f1b6ab6f591376eca54
parent 89d5e223fcefa8321151a90915ab5ff0e14024d6

remove RpcController

hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/OzoneProtocolMessageDispatcher.java

diff --git a/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/OzoneProtocolMessageDispatcher.java b/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/OzoneProtocolMessageDispatcher.java
index 558cf8b..85b8d3b 100644
--- a/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/OzoneProtocolMessageDispatcher.java
+++ b/hadoop-hdds/framework/src/main/java/org/apache/hadoop/hdds/server/OzoneProtocolMessageDispatcher.java
@@ -51,7 +51,6 @@ public OzoneProtocolMessageDispatcher(String serviceName,
   }
 
   public RESPONSE processRequest(
-      RpcController controller,
       REQUEST request,
       FunctionWithServiceException<REQUEST, RESPONSE> methodCall,
       ProtocolMessageEnum type,

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/protocol/ScmBlockLocationProtocolServerSideTranslatorPB.java

diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/protocol/ScmBlockLocationProtocolServerSideTranslatorPB.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/protocol/ScmBlockLocationProtocolServerSideTranslatorPB.java
index ea829c3..b6ce067 100644
--- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/protocol/ScmBlockLocationProtocolServerSideTranslatorPB.java
+++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/protocol/ScmBlockLocationProtocolServerSideTranslatorPB.java
@@ -96,7 +96,6 @@ private SCMBlockLocationResponse.Builder createSCMBlockResponse(
   public SCMBlockLocationResponse send(RpcController controller,
       SCMBlockLocationRequest request) throws ServiceException {
     return dispatcher.processRequest(
-        controller,
         request,
         this::processMessage,
         request.getCmdType(),

hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerProtocolServerSideTranslatorPB.java

diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerProtocolServerSideTranslatorPB.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerProtocolServerSideTranslatorPB.java
index eb9955c..d4c029b 100644
--- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerProtocolServerSideTranslatorPB.java
+++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/protocolPB/OzoneManagerProtocolServerSideTranslatorPB.java
@@ -97,7 +97,7 @@ public OzoneManagerProtocolServerSideTranslatorPB(
   public OMResponse submitRequest(RpcController controller,
       OMRequest request) throws ServiceException {
 
-    return dispatcher.processRequest(controller, request, this::processRequest,
+    return dispatcher.processRequest(request, this::processRequest,
         request.getCmdType(), request.getTraceID());
   }