From 45141fb11ef698b11c6fb3becca82ca10e11505a Mon Sep 17 00:00:00 2001
From: Gaetan Boismal <gaetan.boismal@forgerock.com>
Date: Mon, 15 Sep 2014 12:50:50 +0000
Subject: [PATCH] OPENDJ-1285 CR-4409 Migrate SDK from Futures to Promises
---
opendj-ldap-toolkit/src/main/java/com/forgerock/opendj/ldap/tools/ModRate.java | 20 ++++++++++++--------
1 files changed, 12 insertions(+), 8 deletions(-)
diff --git a/opendj-ldap-toolkit/src/main/java/com/forgerock/opendj/ldap/tools/ModRate.java b/opendj-ldap-toolkit/src/main/java/com/forgerock/opendj/ldap/tools/ModRate.java
index 1058ad1..0eeaa1f 100644
--- a/opendj-ldap-toolkit/src/main/java/com/forgerock/opendj/ldap/tools/ModRate.java
+++ b/opendj-ldap-toolkit/src/main/java/com/forgerock/opendj/ldap/tools/ModRate.java
@@ -26,19 +26,17 @@
*/
package com.forgerock.opendj.ldap.tools;
-import static com.forgerock.opendj.cli.ArgumentConstants.*;
-import static com.forgerock.opendj.ldap.tools.ToolsMessages.*;
-import static com.forgerock.opendj.cli.Utils.filterExitCode;
-
import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.opendj.ldap.Connection;
import org.forgerock.opendj.ldap.ConnectionFactory;
-import org.forgerock.opendj.ldap.FutureResult;
+import org.forgerock.opendj.ldap.ErrorResultException;
import org.forgerock.opendj.ldap.ModificationType;
import org.forgerock.opendj.ldap.ResultCode;
+import org.forgerock.opendj.ldap.ResultHandler;
import org.forgerock.opendj.ldap.requests.ModifyRequest;
import org.forgerock.opendj.ldap.requests.Requests;
import org.forgerock.opendj.ldap.responses.Result;
+import org.forgerock.util.promise.Promise;
import com.forgerock.opendj.cli.ArgumentException;
import com.forgerock.opendj.cli.ArgumentParser;
@@ -48,6 +46,10 @@
import com.forgerock.opendj.cli.ConsoleApplication;
import com.forgerock.opendj.cli.StringArgument;
+import static com.forgerock.opendj.cli.ArgumentConstants.*;
+import static com.forgerock.opendj.cli.Utils.*;
+import static com.forgerock.opendj.ldap.tools.ToolsMessages.*;
+
/**
* A load generation tool that can be used to load a Directory Server with
* Modify requests using one or more LDAP connections.
@@ -64,14 +66,15 @@
}
@Override
- public FutureResult<?> performOperation(final Connection connection,
+ public Promise<?, ErrorResultException> performOperation(final Connection connection,
final DataSource[] dataSources, final long startTime) {
if (dataSources != null) {
data = DataSource.generateData(dataSources, data);
}
mr = newModifyRequest(data);
- return connection.modifyAsync(mr, null, new UpdateStatsResultHandler<Result>(
- startTime));
+ ResultHandler<Result> modRes = new UpdateStatsResultHandler<Result>(startTime);
+
+ return connection.modifyAsync(mr).onSuccess(modRes).onFailure(modRes);
}
private ModifyRequest newModifyRequest(final Object[] data) {
@@ -139,6 +142,7 @@
}
/** {@inheritDoc} */
+ @Override
public boolean isInteractive() {
return false;
}
--
Gitblit v1.10.0