big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix two more issues from trunk merge just committed -- removal of VersionedProtocol

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/HDFS-1623@1295349 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2012-03-01 00:08:13 +00:00
parent 1ba357553a
commit 1d3a0c9557
2 changed files with 0 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/protocolPB/HAServiceProtocolClientSideTranslatorPB.java
View File

@ -71,19 +71,6 @@ public HAServiceProtocolClientSideTranslatorPB(InetSocketAddress addr,
RPC.getProtocolVersion(HAServiceProtocolPB.class), addr, conf); RPC.getProtocolVersion(HAServiceProtocolPB.class), addr, conf);
} }
@Override
public long getProtocolVersion(String protocol, long clientVersion)
throws IOException {
return rpcProxy.getProtocolVersion(protocol, clientVersion);
}
@Override
public ProtocolSignature getProtocolSignature(String protocol,
long clientVersion, int clientMethodsHash) throws IOException {
return rpcProxy.getProtocolSignature(protocol, clientVersion,
clientMethodsHash);
}
@Override @Override
public void monitorHealth() throws IOException { public void monitorHealth() throws IOException {
try { try {

12
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ha/TestFailoverController.java
View File

@ -50,18 +50,6 @@ private class DummyService implements HAServiceProtocol {
this.state = state; this.state = state;
} }
@Override
public long getProtocolVersion(String protocol, long clientVersion)
throws IOException {
return 0;
}
@Override
public ProtocolSignature getProtocolSignature(String protocol,
long clientVersion, int clientMethodsHash) throws IOException {
return null;
}
@Override @Override
public void monitorHealth() throws HealthCheckFailedException, IOException { public void monitorHealth() throws HealthCheckFailedException, IOException {
// Do nothing // Do nothing