fix javadoc

Author: KeeProMise

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

@@ -1353,9 +1353,9 @@ Map<String, List<RemoteLocation>> getAllLocations(String path) throws IOExceptio
    * Get all the locations of the path for {@link RouterClientProtocol#getContentSummary(String)}.
    * For example, there are some mount points:
    * <p>
-   *   /a - &gt ns0 - &gt /a
-   *   /a/b - &gt ns0 - &gt /a/b
-   *   /a/b/c - &gt ns1 - &gt /a/b/c
+   *   /a - [ns0 - /a]
+   *   /a/b - [ns0 - /a/b]
+   *   /a/b/c - [ns1 - /a/b/c]
    * </p>
    * When the path is '/a', the result of locations should be
    * [RemoteLocation('/a', ns0, '/a'), RemoteLocation('/a/b/c', ns1, '/a/b/c')]

hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/async/TestRouterAsyncClientProtocol.java

@@ -1,3 +1,20 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.hadoop.hdfs.server.federation.router.async;
 
 import org.apache.hadoop.crypto.CryptoProtocolVersion;
@@ -9,6 +26,7 @@
 import org.apache.hadoop.hdfs.protocol.DirectoryListing;
 import org.apache.hadoop.hdfs.protocol.HdfsConstants;
 import org.apache.hadoop.hdfs.protocol.HdfsFileStatus;
+import org.apache.hadoop.hdfs.server.federation.resolver.RemoteLocation;
 import org.apache.hadoop.hdfs.server.federation.router.RouterClientProtocol;
 import org.apache.hadoop.io.EnumSetWritable;
 import org.apache.hadoop.util.Lists;
@@ -29,6 +47,7 @@
 import static org.apache.hadoop.hdfs.server.federation.router.async.utils.AsyncUtil.syncReturn;
 import static org.apache.hadoop.hdfs.server.namenode.AclTestHelpers.aclEntry;
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
 import static org.junit.Assert.assertTrue;
 
 /**
@@ -84,12 +103,19 @@ public void testClientProtocolRpc() throws Exception {
     asyncClientProtocol.create(testPath + "/testCreate.file",
         new FsPermission(ALL, ALL, ALL), "testAsyncClient",
         new EnumSetWritable<>(EnumSet.of(CreateFlag.CREATE)),
-        false, (short) 1, 128 * 1024 * 1024L, new CryptoProtocolVersion[]{ENCRYPTION_ZONES},
+        false, (short) 1, 128 * 1024 * 1024L,
+        new CryptoProtocolVersion[]{ENCRYPTION_ZONES},
         null, null);
     hdfsFileStatus = syncReturn(HdfsFileStatus.class);
     assertTrue(hdfsFileStatus.isFile());
     assertEquals(128 * 1024 * 1024, hdfsFileStatus.getBlockSize());
 
+    asyncClientProtocol.getFileRemoteLocation(testPath);
+    RemoteLocation remoteLocation = syncReturn(RemoteLocation.class);
+    assertNotNull(remoteLocation);
+    assertEquals(getNs0(), remoteLocation.getNameserviceId());
+    assertEquals(testPath, remoteLocation.getSrc());
+
     asyncClientProtocol.getListing(testPath, new byte[1], true);
     DirectoryListing directoryListing = syncReturn(DirectoryListing.class);
     assertEquals(1, directoryListing.getPartialListing().length);