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

HDFS-16080. RBF: Invoking method in all locations should break the loop after successful result (#3121). Contributed by Viraj Jasani.

Browse Source 
Signed-off-by: Ayush Saxena <ayushsaxena@apache.org>
This commit is contained in:
Viraj Jasani 2021-06-20 17:19:05 +05:30 committed by GitHub
parent c255feb5d7
commit d9eccb1eb3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcClient.java
View File

@ -1129,25 +1129,17 @@ private static boolean isExpectedValue(Object expectedValue, Object value) {
* Invoke method in all locations and return success if any succeeds. * Invoke method in all locations and return success if any succeeds.
* *
* @param <T> The type of the remote location. * @param <T> The type of the remote location.
* @param <R> The type of the remote method return.
* @param locations List of remote locations to call concurrently. * @param locations List of remote locations to call concurrently.
* @param method The remote method and parameters to invoke. * @param method The remote method and parameters to invoke.
* @return If the call succeeds in any location. * @return If the call succeeds in any location.
* @throws IOException If any of the calls return an exception. * @throws IOException If any of the calls return an exception.
*/ */
public <T extends RemoteLocationContext, R> boolean invokeAll( public <T extends RemoteLocationContext> boolean invokeAll(
final Collection<T> locations, final RemoteMethod method) final Collection<T> locations, final RemoteMethod method)
throws IOException { throws IOException {
boolean anyResult = false;
Map<T, Boolean> results = Map<T, Boolean> results =
invokeConcurrent(locations, method, false, false, Boolean.class); invokeConcurrent(locations, method, false, false, Boolean.class);
for (Boolean value : results.values()) { return results.containsValue(true);
boolean result = value.booleanValue();
if (result) {
anyResult = true;
}
}
return anyResult;
} }
/** /**