Add ipc() wrapper

Danny Becker · Danny Becker · commit ed0d884f3b6d · 2024-02-26T14:00:46.000-08:00
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/NamenodeProtocolTranslatorPB.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/NamenodeProtocolTranslatorPB.java
@@ -138,9 +138,9 @@ public long getMostRecentCheckpointTxId() throws IOException {
 
   @Override
   public long getMostRecentNameNodeFileTxId(NNStorage.NameNodeFile nnf) throws IOException {
-    return rpcProxy.getMostRecentNameNodeFileTxId(NULL_CONTROLLER,
+    return ipc(() -> rpcProxy.getMostRecentNameNodeFileTxId(NULL_CONTROLLER,
         GetMostRecentNameNodeFileTxIdRequestProto.newBuilder()
-            .setNameNodeFile(nnf.toString()).build()).getTxId();
+            .setNameNodeFile(nnf.toString()).build()).getTxId());
 
   }
 

Original file line number	Diff line number	Diff line change
`@@ -138,9 +138,9 @@ public long getMostRecentCheckpointTxId() throws IOException {`
`138`	`138`
`139`	`139`	`@Override`
`140`	`140`	`public long getMostRecentNameNodeFileTxId(NNStorage.NameNodeFile nnf) throws IOException {`
`141`		`- return rpcProxy.getMostRecentNameNodeFileTxId(NULL_CONTROLLER,`
	`141`	`+ return ipc(() -> rpcProxy.getMostRecentNameNodeFileTxId(NULL_CONTROLLER,`
`142`	`142`	`GetMostRecentNameNodeFileTxIdRequestProto.newBuilder()`
`143`		`- .setNameNodeFile(nnf.toString()).build()).getTxId();`
	`143`	`+ .setNameNodeFile(nnf.toString()).build()).getTxId());`
`144`	`144`
`145`	`145`	`}`
`146`	`146`