http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/direct/newnodes/GridSingleSplitsNewNodesAbstractLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/newnodes/GridSingleSplitsNewNodesAbstractLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/newnodes/GridSingleSplitsNewNodesAbstractLoadTest.java index f32efb9..d2e33f0 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/newnodes/GridSingleSplitsNewNodesAbstractLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/newnodes/GridSingleSplitsNewNodesAbstractLoadTest.java @@ -147,7 +147,7 @@ public abstract class GridSingleSplitsNewNodesAbstractLoadTest extends GridCommo GridTestUtils.runMultiThreaded(new Runnable() { /** {@inheritDoc} */ @Override public void run() { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); while (end - System.currentTimeMillis() > 0 && !Thread.currentThread().isInterrupted()) {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiClient.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiClient.java b/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiClient.java index 803018f..968a36b 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiClient.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiClient.java @@ -102,7 +102,7 @@ public class GridDsiClient implements Callable { /** {@inheritDoc} */ @SuppressWarnings({"unchecked", "InfiniteLoopStatement"}) @Nullable @Override public Object call() throws Exception { - IgniteCompute comp = g.compute(g.cluster().forPredicate(serverNode())).enableAsync(); + IgniteCompute comp = g.compute(g.cluster().forPredicate(serverNode())).withAsync(); while (!finish.get()) { try { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionLoadTestClientSemaphore.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionLoadTestClientSemaphore.java b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionLoadTestClientSemaphore.java index 7313ebf..a8d25a7 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionLoadTestClientSemaphore.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionLoadTestClientSemaphore.java @@ -65,7 +65,7 @@ public class GridJobExecutionLoadTestClientSemaphore implements Callable<Object> ClusterGroup rmts = g.cluster().forRemotes(); - IgniteCompute comp = g.compute(rmts).enableAsync(); + IgniteCompute comp = g.compute(rmts).withAsync(); while (!finish) { tasksSem.acquire(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java index 672eb0a..90267c8 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java @@ -173,7 +173,7 @@ public class GridJobExecutionSingleNodeSemaphoreLoadTest { @Nullable @Override public Object call() throws Exception { sem.acquire(); - IgniteCompute comp = g.compute().enableAsync(); + IgniteCompute comp = g.compute().withAsync(); comp.execute(GridJobExecutionLoadTestTask.class, null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobLoadTestSubmitter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobLoadTestSubmitter.java b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobLoadTestSubmitter.java index aa2d9d4..5e93b08 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobLoadTestSubmitter.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobLoadTestSubmitter.java @@ -64,7 +64,7 @@ public class GridJobLoadTestSubmitter implements Runnable { /** {@inheritDoc} */ @SuppressWarnings("BusyWait") @Override public void run() { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); while (true) { checkCompletion(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTask.java b/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTask.java index 8e0a59c..45dd14f 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTask.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTask.java @@ -68,7 +68,7 @@ public class GridMergeSortLoadTask extends ComputeTaskSplitAdapter<int[], int[]> // Future is null before holdcc() is called and // not null after callcc() is called. if (fut == null) { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); // Launch the recursive child task asynchronously. comp.execute(new GridMergeSortLoadTask(), arr); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/messaging/GridMessagingSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/messaging/GridMessagingSelfTest.java b/modules/core/src/test/java/org/apache/ignite/messaging/GridMessagingSelfTest.java index 2ae8568..e21ee80 100644 --- a/modules/core/src/test/java/org/apache/ignite/messaging/GridMessagingSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/messaging/GridMessagingSelfTest.java @@ -1008,7 +1008,7 @@ public class GridMessagingSelfTest extends GridCommonAbstractTest { assertFalse(ignite2.message().isAsync()); - final IgniteMessaging msg = ignite2.message().enableAsync(); + final IgniteMessaging msg = ignite2.message().withAsync(); assertTrue(msg.isAsync()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java index fd1ad37..11addeb 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java @@ -110,7 +110,7 @@ public class GridSessionFutureWaitJobAttributeSelfTest extends GridCommonAbstrac private void checkTask(int num) throws InterruptedException, IgniteCheckedException { Ignite ignite = G.ignite(getTestGridName()); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(GridTaskSessionTestTask.class.getName(), num); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeOrderSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeOrderSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeOrderSelfTest.java index b032960..732dae0 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeOrderSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeOrderSelfTest.java @@ -50,7 +50,7 @@ public class GridSessionSetJobAttributeOrderSelfTest extends GridCommonAbstractT ignite1.compute().localDeployTask(SessionTestTask.class, SessionTestTask.class.getClassLoader()); - IgniteCompute comp = ignite1.compute().enableAsync(); + IgniteCompute comp = ignite1.compute().withAsync(); for (int i = 0; i < TESTS_COUNT; i++) { comp.withTimeout(100000).execute(SessionTestTask.class.getName(), ignite2.cluster().localNode().id()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeWaitListenerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeWaitListenerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeWaitListenerSelfTest.java index 7fd8463..2289cd5 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeWaitListenerSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetJobAttributeWaitListenerSelfTest.java @@ -82,7 +82,7 @@ public class GridSessionSetJobAttributeWaitListenerSelfTest extends GridCommonAb for (int i = 0; i < 5; i++) { refreshInitialData(); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(GridTaskSessionTestTask.class.getName(), null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java index 4831cdf..02e9b7c 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java @@ -95,7 +95,7 @@ public class GridSessionSetTaskAttributeSelfTest extends GridCommonAbstractTest private void checkTask(int num) throws IgniteCheckedException { Ignite ignite = G.ignite(getTestGridName()); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(GridTaskSessionTestTask.class.getName(), num); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java index d73d757..52423c8 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java @@ -95,7 +95,7 @@ public class GridSessionTaskWaitJobAttributeSelfTest extends GridCommonAbstractT private void checkTask(int num) throws IgniteCheckedException { Ignite ignite = G.ignite(getTestGridName()); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(GridTaskSessionTestTask.class.getName(), num); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/session/GridSessionWaitAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionWaitAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionWaitAttributeSelfTest.java index 1ed91ca..a819a4c 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionWaitAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionWaitAttributeSelfTest.java @@ -206,7 +206,7 @@ public class GridSessionWaitAttributeSelfTest extends GridCommonAbstractTest { ignite1.compute().localDeployTask(TestSessionTask.class, TestSessionTask.class.getClassLoader()); - IgniteCompute comp = ignite1.compute().enableAsync(); + IgniteCompute comp = ignite1.compute().withAsync(); comp.execute(TestSessionTask.class.getName(), type); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java index 59f9d8f..bb9e502 100644 --- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java @@ -541,7 +541,7 @@ public abstract class GridAbstractCacheStoreSelfTest<T extends CacheStore<Object } /** {@inheritDoc} */ - @Override public IgniteAsyncSupport enableAsync() { + @Override public IgniteAsyncSupport withAsync() { throw new UnsupportedOperationException(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java index b5e15be..c8f3d78 100644 --- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java @@ -552,7 +552,7 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest { */ protected <R> ComputeTaskFuture<R> executeAsync(IgniteCompute comp, ComputeTask task, @Nullable Object arg) throws IgniteCheckedException { - comp = comp.enableAsync(); + comp = comp.withAsync(); assertNull(comp.execute(task, arg)); @@ -572,7 +572,7 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest { */ protected <R> ComputeTaskFuture<R> executeAsync(IgniteCompute comp, String taskName, @Nullable Object arg) throws IgniteCheckedException { - comp = comp.enableAsync(); + comp = comp.withAsync(); assertNull(comp.execute(taskName, arg)); @@ -593,7 +593,7 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest { @SuppressWarnings("unchecked") protected <R> ComputeTaskFuture<R> executeAsync(IgniteCompute comp, Class taskCls, @Nullable Object arg) throws IgniteCheckedException { - comp = comp.enableAsync(); + comp = comp.withAsync(); assertNull(comp.execute(taskCls, arg)); @@ -613,7 +613,7 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest { */ protected <T extends IgniteEvent> IgniteFuture<T> waitForLocalEvent(IgniteEvents evts, @Nullable IgnitePredicate<T> filter, @Nullable int... types) throws IgniteCheckedException { - evts = evts.enableAsync(); + evts = evts.withAsync(); assertTrue(evts.isAsync()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopDefaultMapReducePlannerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopDefaultMapReducePlannerSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopDefaultMapReducePlannerSelfTest.java index d1932d8..390e630 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopDefaultMapReducePlannerSelfTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopDefaultMapReducePlannerSelfTest.java @@ -911,7 +911,7 @@ public class GridHadoopDefaultMapReducePlannerSelfTest extends GridHadoopAbstrac } /** {@inheritDoc} */ - @Override public IgniteFs enableAsync() { + @Override public IgniteFs withAsync() { return null; } @@ -1205,7 +1205,7 @@ public class GridHadoopDefaultMapReducePlannerSelfTest extends GridHadoopAbstrac } /** {@inheritDoc} */ - @Override public IgniteCluster enableAsync() { + @Override public IgniteCluster withAsync() { return null; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/ssh/src/test/java/org/apache/ignite/internal/GridProjectionStartStopRestartSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/ssh/src/test/java/org/apache/ignite/internal/GridProjectionStartStopRestartSelfTest.java b/modules/ssh/src/test/java/org/apache/ignite/internal/GridProjectionStartStopRestartSelfTest.java index e5ee12c..7f3012e 100644 --- a/modules/ssh/src/test/java/org/apache/ignite/internal/GridProjectionStartStopRestartSelfTest.java +++ b/modules/ssh/src/test/java/org/apache/ignite/internal/GridProjectionStartStopRestartSelfTest.java @@ -1023,7 +1023,7 @@ public class GridProjectionStartStopRestartSelfTest extends GridCommonAbstractTe boolean restart, int timeout, int maxConn) throws IgniteCheckedException { - cluster = cluster.enableAsync(); + cluster = cluster.withAsync(); assertNull(cluster.startNodes(hosts, dflts, restart, timeout, maxConn));
