Skip to content

Commit 113a9e4

Browse files
authored
HADOOP-18625. Fix method name of RPC.Builder#setnumReaders (apache#5301)
Changes method name of RPC.Builder#setnumReaders to setNumReaders() The original method is still there, just marked deprecated. It is the one which should be used when working with older branches. Contributed by Haiyang Hu
1 parent d5c0465 commit 113a9e4

File tree

3 files changed

+17
-3
lines changed
  • hadoop-common-project/hadoop-common/src
  • hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router

3 files changed

+17
-3
lines changed

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/RPC.java

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -896,15 +896,29 @@ public Builder setNumHandlers(int numHandlers) {
896896
this.numHandlers = numHandlers;
897897
return this;
898898
}
899-
899+
900900
/**
901901
* @return Default: -1.
902902
* @param numReaders input numReaders.
903+
* @deprecated call {@link #setNumReaders(int value)} instead.
903904
*/
905+
@Deprecated
904906
public Builder setnumReaders(int numReaders) {
905907
this.numReaders = numReaders;
906908
return this;
907909
}
910+
911+
/**
912+
* Set the number of reader threads.
913+
*
914+
* @return this builder.
915+
* @param value input numReaders.
916+
* @since HADOOP-18625.
917+
*/
918+
public Builder setNumReaders(int value) {
919+
this.numReaders = value;
920+
return this;
921+
}
908922

909923
/**
910924
* @return Default: -1.

hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ public void testConfRpc() throws IOException {
378378
assertEquals(confReaders, server.getNumReaders());
379379

380380
server = newServerBuilder(conf)
381-
.setNumHandlers(1).setnumReaders(3).setQueueSizePerHandler(200)
381+
.setNumHandlers(1).setNumReaders(3).setQueueSizePerHandler(200)
382382
.setVerbose(false).build();
383383

384384
assertEquals(3, server.getNumReaders());

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -333,7 +333,7 @@ public RouterRpcServer(Configuration conf, Router router,
333333
.setBindAddress(confRpcAddress.getHostName())
334334
.setPort(confRpcAddress.getPort())
335335
.setNumHandlers(handlerCount)
336-
.setnumReaders(readerCount)
336+
.setNumReaders(readerCount)
337337
.setQueueSizePerHandler(handlerQueueSize)
338338
.setVerbose(false)
339339
.setAlignmentContext(routerStateIdContext)

0 commit comments

Comments
 (0)