HDFS-2298. Fix TestDfsOverAvroRpc by changing ClientProtocol to not include multiple methods of the same name.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1177757 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Doug Cutting 2011-09-30 18:01:27 +00:00
parent 32431d25ae
commit f48280ac56
5 changed files with 10 additions and 28 deletions

View File

@ -88,6 +88,9 @@ Trunk (unreleased changes)
HDFS-2361. hftp is broken, fixed username checks in JspHelper. (jitendra) HDFS-2361. hftp is broken, fixed username checks in JspHelper. (jitendra)
HDFS-2298. Fix TestDfsOverAvroRpc by changing ClientProtocol to
not include multiple methods of the same name. (cutting)
Release 0.23.0 - Unreleased Release 0.23.0 - Unreleased
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

View File

@ -874,13 +874,13 @@ public class DFSClient implements java.io.Closeable {
} }
/** /**
* Rename file or directory. * Rename file or directory.
* @see ClientProtocol#rename(String, String, Options.Rename...) * @see ClientProtocol#rename2(String, String, Options.Rename...)
*/ */
public void rename(String src, String dst, Options.Rename... options) public void rename(String src, String dst, Options.Rename... options)
throws IOException { throws IOException {
checkOpen(); checkOpen();
try { try {
namenode.rename(src, dst, options); namenode.rename2(src, dst, options);
} catch(RemoteException re) { } catch(RemoteException re) {
throw re.unwrapRemoteException(AccessControlException.class, throw re.unwrapRemoteException(AccessControlException.class,
DSQuotaExceededException.class, DSQuotaExceededException.class,

View File

@ -67,9 +67,9 @@ public interface ClientProtocol extends VersionedProtocol {
* Compared to the previous version the following changes have been introduced: * Compared to the previous version the following changes have been introduced:
* (Only the latest change is reflected. * (Only the latest change is reflected.
* The log of historical changes can be retrieved from the svn). * The log of historical changes can be retrieved from the svn).
* 68: Add Balancer Bandwidth Command protocol * 69: Eliminate overloaded method names.
*/ */
public static final long versionID = 68L; public static final long versionID = 69L;
/////////////////////////////////////// ///////////////////////////////////////
// File contents // File contents
@ -419,27 +419,12 @@ public interface ClientProtocol extends VersionedProtocol {
* <code>dst</code> contains a symlink * <code>dst</code> contains a symlink
* @throws IOException If an I/O error occurred * @throws IOException If an I/O error occurred
*/ */
public void rename(String src, String dst, Options.Rename... options) public void rename2(String src, String dst, Options.Rename... options)
throws AccessControlException, DSQuotaExceededException, throws AccessControlException, DSQuotaExceededException,
FileAlreadyExistsException, FileNotFoundException, FileAlreadyExistsException, FileNotFoundException,
NSQuotaExceededException, ParentNotDirectoryException, SafeModeException, NSQuotaExceededException, ParentNotDirectoryException, SafeModeException,
UnresolvedLinkException, IOException; UnresolvedLinkException, IOException;
/**
* Delete the given file or directory from the file system.
* <p>
* Any blocks belonging to the deleted files will be garbage-collected.
*
* @param src existing name.
* @return true only if the existing file or directory was actually removed
* from the file system.
* @throws UnresolvedLinkException if <code>src</code> contains a symlink.
* @deprecated use {@link #delete(String, boolean)} istead.
*/
@Deprecated
public boolean delete(String src)
throws IOException, UnresolvedLinkException;
/** /**
* Delete the given file or directory from the file system. * Delete the given file or directory from the file system.
* <p> * <p>

View File

@ -523,7 +523,7 @@ class NameNodeRpcServer implements NamenodeProtocols {
} }
@Override // ClientProtocol @Override // ClientProtocol
public void rename(String src, String dst, Options.Rename... options) public void rename2(String src, String dst, Options.Rename... options)
throws IOException { throws IOException {
if(stateChangeLog.isDebugEnabled()) { if(stateChangeLog.isDebugEnabled()) {
stateChangeLog.debug("*DIR* NameNode.rename: " + src + " to " + dst); stateChangeLog.debug("*DIR* NameNode.rename: " + src + " to " + dst);
@ -536,12 +536,6 @@ class NameNodeRpcServer implements NamenodeProtocols {
metrics.incrFilesRenamed(); metrics.incrFilesRenamed();
} }
@Deprecated
@Override // ClientProtocol
public boolean delete(String src) throws IOException {
return delete(src, true);
}
@Override // ClientProtocol @Override // ClientProtocol
public boolean delete(String src, boolean recursive) throws IOException { public boolean delete(String src, boolean recursive) throws IOException {
if (stateChangeLog.isDebugEnabled()) { if (stateChangeLog.isDebugEnabled()) {

View File

@ -257,7 +257,7 @@ public class NamenodeWebHdfsMethods {
final String js = JsonUtil.toJsonString(PutOpParam.Op.RENAME, b); final String js = JsonUtil.toJsonString(PutOpParam.Op.RENAME, b);
return Response.ok(js).type(MediaType.APPLICATION_JSON).build(); return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
} else { } else {
np.rename(fullpath, dstPath.getValue(), np.rename2(fullpath, dstPath.getValue(),
s.toArray(new Options.Rename[s.size()])); s.toArray(new Options.Rename[s.size()]));
return Response.ok().type(MediaType.APPLICATION_JSON).build(); return Response.ok().type(MediaType.APPLICATION_JSON).build();
} }