From 263d085885df024dca9250cc03c807912b0a7662 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Tue, 24 Apr 2012 22:33:21 +0000
Subject: [PATCH] Reformat to comply with new Checkstyle rules.
---
opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/util/RecursiveFutureResult.java | 354 ++++++++++++++++++++++++----------------------------------
1 files changed, 145 insertions(+), 209 deletions(-)
diff --git a/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/util/RecursiveFutureResult.java b/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/util/RecursiveFutureResult.java
index a39a6d5..db39636 100644
--- a/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/util/RecursiveFutureResult.java
+++ b/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/util/RecursiveFutureResult.java
@@ -6,17 +6,16 @@
* (the "License"). You may not use this file except in compliance
* with the License.
*
- * You can obtain a copy of the license at
- * trunk/opendj3/legal-notices/CDDLv1_0.txt
+ * You can obtain a copy of the license at legal-notices/CDDLv1_0.txt
* or http://forgerock.org/license/CDDLv1.0.html.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
- * file and include the License file at
- * trunk/opendj3/legal-notices/CDDLv1_0.txt. If applicable,
- * add the following below this CDDL HEADER, with the fields enclosed
- * by brackets "[]" replaced with your own identifying information:
+ * file and include the License file at legal-notices/CDDLv1_0.txt.
+ * If applicable, add the following below this CDDL HEADER, with the
+ * fields enclosed by brackets "[]" replaced with your own identifying
+ * information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
@@ -27,8 +26,6 @@
package com.forgerock.opendj.util;
-
-
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
@@ -37,8 +34,6 @@
import org.forgerock.opendj.ldap.FutureResult;
import org.forgerock.opendj.ldap.ResultHandler;
-
-
/**
* An implementation of the {@code FutureResult} interface which can be used to
* combine a sequence of two asynchronous operations into a single future
@@ -47,228 +42,169 @@
* operation.
*
* @param <M>
- * The type of the inner result.
+ * The type of the inner result.
* @param <N>
- * The type of the outer result.
+ * The type of the outer result.
*/
-public abstract class RecursiveFutureResult<M, N> implements FutureResult<N>,
- ResultHandler<M>
-{
- private final class FutureResultImpl extends AsynchronousFutureResult<N>
- {
- private FutureResultImpl(final ResultHandler<? super N> handler)
- {
- super(handler);
+public abstract class RecursiveFutureResult<M, N> implements FutureResult<N>, ResultHandler<M> {
+ private final class FutureResultImpl extends AsynchronousFutureResult<N> {
+ private FutureResultImpl(final ResultHandler<? super N> handler) {
+ super(handler);
+ }
+
+ public int getRequestID() {
+ if (innerFuture instanceof FutureResult<?>) {
+ final FutureResult<?> tmp = (FutureResult<?>) innerFuture;
+ return tmp.getRequestID();
+ } else {
+ return -1;
+ }
+ }
+
+ /**
+ * {@inheritDoc}
+ */
+ @Override
+ protected ErrorResultException handleCancelRequest(final boolean mayInterruptIfRunning) {
+ innerFuture.cancel(mayInterruptIfRunning);
+ if (outerFuture != null) {
+ outerFuture.cancel(mayInterruptIfRunning);
+ }
+ return null;
+ }
+
}
+ private final FutureResultImpl impl;
+ private volatile Future<?> innerFuture = null;
- public int getRequestID()
- {
- if (innerFuture instanceof FutureResult<?>)
- {
- final FutureResult<?> tmp = (FutureResult<?>) innerFuture;
- return tmp.getRequestID();
- }
- else
- {
- return -1;
- }
+ // This does not need to be volatile since the inner future acts as a
+ // memory barrier.
+ private FutureResult<? extends N> outerFuture = null;
+
+ /**
+ * Creates a new asynchronous result chain which will chain an outer
+ * asynchronous request once the inner asynchronous request completes.
+ *
+ * @param handler
+ * The outer result handler.
+ */
+ protected RecursiveFutureResult(final ResultHandler<? super N> handler) {
+ this.impl = new FutureResultImpl(handler);
}
-
-
/**
* {@inheritDoc}
*/
- @Override
- protected ErrorResultException handleCancelRequest(
- final boolean mayInterruptIfRunning)
- {
- innerFuture.cancel(mayInterruptIfRunning);
- if (outerFuture != null)
- {
- outerFuture.cancel(mayInterruptIfRunning);
- }
- return null;
+ public final boolean cancel(final boolean mayInterruptIfRunning) {
+ return impl.cancel(mayInterruptIfRunning);
}
- }
-
-
-
- private final FutureResultImpl impl;
-
- private volatile Future<?> innerFuture = null;
-
- // This does not need to be volatile since the inner future acts as a
- // memory barrier.
- private FutureResult<? extends N> outerFuture = null;
-
-
-
- /**
- * Creates a new asynchronous result chain which will chain an outer
- * asynchronous request once the inner asynchronous request completes.
- *
- * @param handler
- * The outer result handler.
- */
- protected RecursiveFutureResult(final ResultHandler<? super N> handler)
- {
- this.impl = new FutureResultImpl(handler);
- }
-
-
-
- /**
- * {@inheritDoc}
- */
- public final boolean cancel(final boolean mayInterruptIfRunning)
- {
- return impl.cancel(mayInterruptIfRunning);
- }
-
-
-
- /**
- * {@inheritDoc}
- */
- public final N get() throws ErrorResultException, InterruptedException
- {
- return impl.get();
- }
-
-
-
- /**
- * {@inheritDoc}
- */
- public final N get(final long timeout, final TimeUnit unit)
- throws ErrorResultException, TimeoutException, InterruptedException
- {
- return impl.get(timeout, unit);
- }
-
-
-
- /**
- * {@inheritDoc}
- */
- public final int getRequestID()
- {
- return impl.getRequestID();
- }
-
-
-
- /**
- * {@inheritDoc}
- */
- public final void handleErrorResult(final ErrorResultException error)
- {
- try
- {
- outerFuture = chainErrorResult(error, impl);
+ /**
+ * {@inheritDoc}
+ */
+ public final N get() throws ErrorResultException, InterruptedException {
+ return impl.get();
}
- catch (final ErrorResultException e)
- {
- impl.handleErrorResult(e);
+
+ /**
+ * {@inheritDoc}
+ */
+ public final N get(final long timeout, final TimeUnit unit) throws ErrorResultException,
+ TimeoutException, InterruptedException {
+ return impl.get(timeout, unit);
}
- }
-
-
- /**
- * {@inheritDoc}
- */
- public final void handleResult(final M result)
- {
- try
- {
- outerFuture = chainResult(result, impl);
+ /**
+ * {@inheritDoc}
+ */
+ public final int getRequestID() {
+ return impl.getRequestID();
}
- catch (final ErrorResultException e)
- {
- impl.handleErrorResult(e);
+
+ /**
+ * {@inheritDoc}
+ */
+ public final void handleErrorResult(final ErrorResultException error) {
+ try {
+ outerFuture = chainErrorResult(error, impl);
+ } catch (final ErrorResultException e) {
+ impl.handleErrorResult(e);
+ }
}
- }
+ /**
+ * {@inheritDoc}
+ */
+ public final void handleResult(final M result) {
+ try {
+ outerFuture = chainResult(result, impl);
+ } catch (final ErrorResultException e) {
+ impl.handleErrorResult(e);
+ }
+ }
+ /**
+ * {@inheritDoc}
+ */
+ public final boolean isCancelled() {
+ return impl.isCancelled();
+ }
- /**
- * {@inheritDoc}
- */
- public final boolean isCancelled()
- {
- return impl.isCancelled();
- }
+ /**
+ * {@inheritDoc}
+ */
+ public final boolean isDone() {
+ return impl.isDone();
+ }
+ /**
+ * Sets the inner future for this result chain. This must be done before
+ * this future is published.
+ *
+ * @param future
+ * The inner future.
+ */
+ public final void setFutureResult(final Future<?> future) {
+ this.innerFuture = future;
+ }
+ /**
+ * Invokes the outer request based on the error result of the inner request
+ * and returns a future representing the result of the outer request.
+ * <p>
+ * The default implementation is to terminate further processing by
+ * re-throwing the inner error result.
+ *
+ * @param innerError
+ * The error result of the inner request.
+ * @param handler
+ * The result handler to be used for the outer request.
+ * @return A future representing the result of the outer request.
+ * @throws ErrorResultException
+ * If the outer request could not be invoked and processing
+ * should terminate.
+ */
+ protected FutureResult<? extends N> chainErrorResult(final ErrorResultException innerError,
+ final ResultHandler<? super N> handler) throws ErrorResultException {
+ throw innerError;
+ }
- /**
- * {@inheritDoc}
- */
- public final boolean isDone()
- {
- return impl.isDone();
- }
-
-
-
- /**
- * Sets the inner future for this result chain. This must be done before this
- * future is published.
- *
- * @param future
- * The inner future.
- */
- public final void setFutureResult(final Future<?> future)
- {
- this.innerFuture = future;
- }
-
-
-
- /**
- * Invokes the outer request based on the error result of the inner request
- * and returns a future representing the result of the outer request.
- * <p>
- * The default implementation is to terminate further processing by
- * re-throwing the inner error result.
- *
- * @param innerError
- * The error result of the inner request.
- * @param handler
- * The result handler to be used for the outer request.
- * @return A future representing the result of the outer request.
- * @throws ErrorResultException
- * If the outer request could not be invoked and processing should
- * terminate.
- */
- protected FutureResult<? extends N> chainErrorResult(
- final ErrorResultException innerError,
- final ResultHandler<? super N> handler) throws ErrorResultException
- {
- throw innerError;
- }
-
-
-
- /**
- * Invokes the outer request based on the result of the inner request and
- * returns a future representing the result of the outer request.
- *
- * @param innerResult
- * The result of the inner request.
- * @param handler
- * The result handler to be used for the outer request.
- * @return A future representing the result of the outer request.
- * @throws ErrorResultException
- * If the outer request could not be invoked and processing should
- * terminate.
- */
- protected abstract FutureResult<? extends N> chainResult(M innerResult,
- ResultHandler<? super N> handler) throws ErrorResultException;
+ /**
+ * Invokes the outer request based on the result of the inner request and
+ * returns a future representing the result of the outer request.
+ *
+ * @param innerResult
+ * The result of the inner request.
+ * @param handler
+ * The result handler to be used for the outer request.
+ * @return A future representing the result of the outer request.
+ * @throws ErrorResultException
+ * If the outer request could not be invoked and processing
+ * should terminate.
+ */
+ protected abstract FutureResult<? extends N> chainResult(M innerResult,
+ ResultHandler<? super N> handler) throws ErrorResultException;
}
--
Gitblit v1.10.0