From 649144435718c7f446e9a056fc2988dc75fae14c Mon Sep 17 00:00:00 2001 From: Todd Lipcon Date: Mon, 5 Dec 2011 21:13:07 +0000 Subject: [PATCH] Fix to previous trunk merge - RPC's addProtocol method now needs an RpcKind git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/HDFS-1623@1210638 13f79535-47bb-0310-9956-ffa450edef68 --- .../hadoop/hdfs/server/namenode/NameNodeRpcServer.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java index f005f8b9d4f..f0ac86ae8c0 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java @@ -163,7 +163,8 @@ class NameNodeRpcServer implements NamenodeProtocols { RefreshUserMappingsProtocol.class, this); this.serviceRpcServer.addProtocol(RpcKind.RPC_WRITABLE, GetUserMappingsProtocol.class, this); - this.serviceRpcServer.addProtocol(HAServiceProtocol.class, this); + this.serviceRpcServer.addProtocol(RpcKind.RPC_WRITABLE, + HAServiceProtocol.class, this); this.serviceRPCAddress = this.serviceRpcServer.getListenerAddress(); nn.setRpcServiceServerAddress(conf, serviceRPCAddress); @@ -188,7 +189,8 @@ class NameNodeRpcServer implements NamenodeProtocols { RefreshUserMappingsProtocol.class, this); this.clientRpcServer.addProtocol(RpcKind.RPC_WRITABLE, GetUserMappingsProtocol.class, this); - this.clientRpcServer.addProtocol(HAServiceProtocol.class, this); + this.clientRpcServer.addProtocol(RpcKind.RPC_WRITABLE, + HAServiceProtocol.class, this); // set service-level authorization security policy