IGNITE-142 Rename IgniteAsyncSupport.enableAsync() to IgniteAsyncSupport.withAsync()
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/bceabb1d Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bceabb1d Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bceabb1d Branch: refs/heads/ignite-132 Commit: bceabb1d167c825250994fb5995d2167bb1dd22d Parents: 0e110c0 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Wed Jan 28 13:29:56 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Wed Jan 28 13:29:56 2015 +0300 ---------------------------------------------------------------------- .../ComputeFibonacciContinuationExample.java | 2 +- .../compute/ComputeRunnableExample.java | 2 +- .../singlesplit/SingleSplitsLoadTest.java | 2 +- .../ignite/client/ClientStartNodeTask.java | 2 +- .../java/org/apache/ignite/IgniteCache.java | 2 +- .../java/org/apache/ignite/IgniteCluster.java | 2 +- .../java/org/apache/ignite/IgniteCompute.java | 2 +- .../java/org/apache/ignite/IgniteEvents.java | 2 +- .../main/java/org/apache/ignite/IgniteFs.java | 2 +- .../java/org/apache/ignite/IgniteManaged.java | 2 +- .../java/org/apache/ignite/IgniteMessaging.java | 2 +- .../org/apache/ignite/internal/GridKernal.java | 2 +- .../ignite/internal/IgniteManagedImpl.java | 2 +- .../internal/executor/GridExecutorService.java | 2 +- .../processors/cache/GridCacheAdapter.java | 5 +-- .../cache/transactions/IgniteTxAdapter.java | 6 ++-- .../cache/transactions/IgniteTxProxyImpl.java | 2 +- .../internal/processors/fs/GridGgfsImpl.java | 2 +- .../handlers/cache/GridCacheCommandHandler.java | 4 +-- .../cache/GridCacheQueryCommandHandler.java | 4 +-- .../handlers/task/GridTaskCommandHandler.java | 4 +-- .../apache/ignite/lang/IgniteAsyncSupport.java | 2 +- .../ignite/lang/IgniteAsyncSupportAdapter.java | 2 +- .../ignite/lang/IgniteAsyncSupported.java | 2 +- .../internal/GridCancelOnGridStopSelfTest.java | 2 +- .../GridCancelledJobsMetricsSelfTest.java | 2 +- .../internal/GridContinuousTaskSelfTest.java | 4 +-- .../GridEventStorageCheckAllEventsSelfTest.java | 2 +- .../GridFailoverCustomTopologySelfTest.java | 2 +- .../GridJobMasterLeaveAwareSelfTest.java | 34 ++++++++++---------- .../internal/GridMultipleJobsSelfTest.java | 2 +- .../internal/GridProjectionAbstractTest.java | 20 ++++++------ .../ignite/internal/GridReduceSelfTest.java | 2 +- .../GridTaskCancelSingleNodeSelfTest.java | 2 +- .../internal/GridTaskExecutionSelfTest.java | 2 +- .../GridTaskInstanceExecutionSelfTest.java | 2 +- .../internal/GridTaskJobRejectSelfTest.java | 2 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 8 ++--- .../GridCacheConcurrentTxMultiNodeTest.java | 2 +- .../GridCacheGroupLockFailoverSelfTest.java | 2 +- .../cache/GridCachePutAllFailoverSelfTest.java | 4 +-- .../cache/IgniteCacheInvokeAbstractTest.java | 4 +-- .../GridCacheCountDownLatchSelfTest.java | 2 +- ...ridCacheQueueJoinedNodeSelfAbstractTest.java | 4 +-- .../GridCacheAbstractJobExecutionTest.java | 2 +- ...cOriginatingNodeFailureAbstractSelfTest.java | 2 +- .../dht/GridCacheGlobalLoadTest.java | 2 +- .../GridCachePartitionedEntryLockSelfTest.java | 2 +- .../GridCachePartitionedLoadCacheSelfTest.java | 2 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 2 +- .../closure/GridClosureProcessorSelfTest.java | 16 ++++----- .../continuous/GridEventConsumeSelfTest.java | 8 ++--- .../processors/fs/GridGgfsTaskSelfTest.java | 2 +- .../GridServiceProcessorAbstractSelfTest.java | 18 +++++------ .../GridServiceProcessorMultiNodeSelfTest.java | 6 ++-- .../loadtest/GridSingleExecutionTest.java | 2 +- .../loadtests/colocation/GridTestMain.java | 2 +- .../multisplit/GridMultiSplitsLoadTest.java | 2 +- ...ridSingleSplitsNewNodesAbstractLoadTest.java | 2 +- .../ignite/loadtests/dsi/GridDsiClient.java | 2 +- ...GridJobExecutionLoadTestClientSemaphore.java | 2 +- ...JobExecutionSingleNodeSemaphoreLoadTest.java | 2 +- .../loadtests/job/GridJobLoadTestSubmitter.java | 2 +- .../mergesort/GridMergeSortLoadTask.java | 2 +- .../ignite/messaging/GridMessagingSelfTest.java | 2 +- ...idSessionFutureWaitJobAttributeSelfTest.java | 2 +- ...GridSessionSetJobAttributeOrderSelfTest.java | 2 +- ...sionSetJobAttributeWaitListenerSelfTest.java | 2 +- .../GridSessionSetTaskAttributeSelfTest.java | 2 +- ...GridSessionTaskWaitJobAttributeSelfTest.java | 2 +- .../GridSessionWaitAttributeSelfTest.java | 2 +- .../cache/GridAbstractCacheStoreSelfTest.java | 2 +- .../junits/common/GridCommonAbstractTest.java | 8 ++--- ...idHadoopDefaultMapReducePlannerSelfTest.java | 4 +-- .../GridProjectionStartStopRestartSelfTest.java | 2 +- 75 files changed, 138 insertions(+), 137 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java index 9d8bbca..7309f7e 100644 --- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java @@ -131,7 +131,7 @@ public final class ComputeFibonacciContinuationExample { ClusterGroup p = g.cluster().forPredicate(nodeFilter); - IgniteCompute compute = g.compute(p).enableAsync(); + IgniteCompute compute = g.compute(p).withAsync(); // If future is not cached in node-local-map, cache it. if (fut1 == null) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java index 147e98a..c70360f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java @@ -47,7 +47,7 @@ public class ComputeRunnableExample { Collection<IgniteFuture> futs = new ArrayList<>(); // Enable asynchronous mode. - IgniteCompute compute = g.compute().enableAsync(); + IgniteCompute compute = g.compute().withAsync(); // Iterate through all words in the sentence and create callable jobs. for (final String word : "Print words using runnable".split(" ")) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java index a4bc6d7..7239b25 100644 --- a/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java +++ b/modules/aop/src/test/java/org/apache/loadtests/direct/singlesplit/SingleSplitsLoadTest.java @@ -105,7 +105,7 @@ public class SingleSplitsLoadTest extends GridCommonAbstractTest { try { int levels = 20; - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(new SingleSplitTestTask(), levels); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java b/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java index bd1ea93..5560593 100644 --- a/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java +++ b/modules/clients/src/test/java/org/apache/ignite/client/ClientStartNodeTask.java @@ -151,7 +151,7 @@ public class ClientStartNodeTask extends TaskSingleJobSplitAdapter<String, Integ private static void changeTopology(Ignite parent, int add, int rmv, String type) throws IgniteCheckedException { Collection<ComputeTaskFuture<?>> tasks = new ArrayList<>(); - IgniteCompute comp = parent.compute().enableAsync(); + IgniteCompute comp = parent.compute().withAsync(); // Start nodes in parallel. while (add-- > 0) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java index c8539cb..8430ec4 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java @@ -66,7 +66,7 @@ import java.util.concurrent.locks.*; */ public interface IgniteCache<K, V> extends javax.cache.Cache<K, V>, IgniteAsyncSupport { /** {@inheritDoc} */ - public @Override IgniteCache<K, V> enableAsync(); + public @Override IgniteCache<K, V> withAsync(); /** {@inheritDoc} */ public @Override <C extends Configuration<K, V>> C getConfiguration(Class<C> clazz); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java index 5d17bca..b5bdbd9 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java @@ -335,5 +335,5 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { public void resetMetrics(); /** {@inheritDoc} */ - public IgniteCluster enableAsync(); + public IgniteCluster withAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java index 798c75d..da5ebb9 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java @@ -443,5 +443,5 @@ public interface IgniteCompute extends IgniteAsyncSupport { @Override public <R> ComputeTaskFuture<R> future(); /** {@inheritDoc} */ - @Override public IgniteCompute enableAsync(); + @Override public IgniteCompute withAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java index e6f411a..6a42639 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java @@ -257,5 +257,5 @@ public interface IgniteEvents extends IgniteAsyncSupport { public boolean isEnabled(int type); /** {@inheritDoc} */ - @Override IgniteEvents enableAsync(); + @Override IgniteEvents withAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteFs.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java index 47ff289..ff7a9b6 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java @@ -341,5 +341,5 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { long maxRangeLen, @Nullable T arg) throws IgniteCheckedException; /** {@inheritDoc} */ - @Override public IgniteFs enableAsync(); + @Override public IgniteFs withAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java index f711503..5c7aaa7 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java @@ -356,5 +356,5 @@ public interface IgniteManaged extends IgniteAsyncSupport { public <T> T serviceProxy(String name, Class<? super T> svcItf, boolean sticky) throws IgniteException; /** {@inheritDoc} */ - @Override public IgniteManaged enableAsync(); + @Override public IgniteManaged withAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java index 1a9f74f..68e4f48 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java @@ -147,5 +147,5 @@ public interface IgniteMessaging extends IgniteAsyncSupport { public void stopRemoteListen(UUID opId) throws IgniteCheckedException; /** {@inheritDoc} */ - @Override IgniteMessaging enableAsync(); + @Override IgniteMessaging withAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java index fb31087..e13f48a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java @@ -2637,7 +2637,7 @@ public class GridKernal extends ClusterGroupAdapter implements GridEx, IgniteMXB } /** {@inheritDoc} */ - @Override public IgniteCluster enableAsync() { + @Override public IgniteCluster withAsync() { return new IgniteClusterAsyncImpl(this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java index 9c5763b..7d68d96 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteManagedImpl.java @@ -235,7 +235,7 @@ public class IgniteManagedImpl extends IgniteAsyncSupportAdapter implements Igni } /** {@inheritDoc} */ - @Override public IgniteManaged enableAsync() { + @Override public IgniteManaged withAsync() { if (isAsync()) return this; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java b/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java index 86c041e..0f2b6eb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java @@ -115,7 +115,7 @@ public class GridExecutorService implements ExecutorService, Externalizable { this.prj = prj; this.log = log.getLogger(GridExecutorService.class); - comp = prj.compute().enableAsync(); + comp = prj.compute().withAsync(); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index f2680fe..5b674fb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -2473,7 +2473,8 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K, V>, (IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>>)fut; return fut0.chain(new CX1<IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>>, Map<K, EntryProcessorResult<T>>>() { - @Override public Map<K, EntryProcessorResult<T>> applyx(IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>> fut) + @Override public Map<K, EntryProcessorResult<T>> applyx( + IgniteFuture<GridCacheReturn<Map<K, EntryProcessorResult<T>>>> fut) throws IgniteCheckedException { GridCacheReturn<Map<K, EntryProcessorResult<T>>> ret = fut.get(); @@ -3830,7 +3831,7 @@ public abstract class GridCacheAdapter<K, V> implements GridCache<K, V>, IgniteCompute comp = ctx.kernalContext().grid().compute(nodes).withNoFailover(); - comp = comp.enableAsync(); + comp = comp.withAsync(); comp.broadcast(new LoadCacheClosure<>(ctx.name(), p, args)); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java index aebf9db..47cd12b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java @@ -547,8 +547,8 @@ public abstract class IgniteTxAdapter<K, V> extends GridMetadataAwareAdapter } /** {@inheritDoc} */ - @Override public IgniteAsyncSupport enableAsync() { - throw new UnsupportedOperationException("enableAsync() should not be called on IgniteTxAdapter directly."); + @Override public IgniteAsyncSupport withAsync() { + throw new UnsupportedOperationException("withAsync() should not be called on IgniteTxAdapter directly."); } /** {@inheritDoc} */ @@ -1514,7 +1514,7 @@ public abstract class IgniteTxAdapter<K, V> extends GridMetadataAwareAdapter } /** {@inheritDoc} */ - @Override public IgniteAsyncSupport enableAsync() { + @Override public IgniteAsyncSupport withAsync() { throw new IllegalStateException("Deserialized transaction can only be used as read-only."); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java index 3ac8227..3bfebc8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxProxyImpl.java @@ -185,7 +185,7 @@ public class IgniteTxProxyImpl<K, V> implements IgniteTxProxy, Externalizable { } /** {@inheritDoc} */ - @Override public IgniteAsyncSupport enableAsync() { + @Override public IgniteAsyncSupport withAsync() { return new IgniteTxProxyImpl<>(tx, cctx, true); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java index 4fb77bc..84942ce 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/fs/GridGgfsImpl.java @@ -1825,7 +1825,7 @@ public final class GridGgfsImpl implements GridGgfsEx { } /** {@inheritDoc} */ - @Override public IgniteFs enableAsync() { + @Override public IgniteFs withAsync() { return new GridGgfsAsyncImpl(this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java index b76735a..8d67de4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java @@ -361,7 +361,7 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter { else { ClusterGroup prj = ctx.grid().forPredicate(F.nodeForNodeId(destId)); - IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().enableAsync(); + IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().withAsync(); comp.call(new FlaggedCacheOperationCallable(clientId, cacheName, flags, op, key, keepPortable)); @@ -399,7 +399,7 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter { else { ClusterGroup prj = ctx.grid().forPredicate(F.nodeForNodeId(destId)); - IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().enableAsync(); + IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().withAsync(); comp.call(new CacheOperationCallable(clientId, cacheName, op, key)); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java index 71292e9..72236a0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheQueryCommandHandler.java @@ -125,7 +125,7 @@ public class GridCacheQueryCommandHandler extends GridRestCommandHandlerAdapter "the query): " + destId)); try { - IgniteCompute comp = ctx.grid().compute(ctx.grid().forNodeId(destId)).withNoFailover().enableAsync(); + IgniteCompute comp = ctx.grid().compute(ctx.grid().forNodeId(destId)).withNoFailover().withAsync(); comp.call(c); @@ -144,7 +144,7 @@ public class GridCacheQueryCommandHandler extends GridRestCommandHandlerAdapter * @return Execution future. */ private IgniteFuture<GridRestResponse> broadcast(String cacheName, Callable<Object> c) { - IgniteCompute comp = ctx.grid().compute(ctx.grid().forCache(cacheName)).withNoFailover().enableAsync(); + IgniteCompute comp = ctx.grid().compute(ctx.grid().forCache(cacheName)).withNoFailover().withAsync(); try { comp.broadcast(c); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java index c3efcaa..0012712 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskCommandHandler.java @@ -190,7 +190,7 @@ public class GridTaskCommandHandler extends GridRestCommandHandlerAdapter { if (locExec) { ClusterGroup prj = ctx.grid().forSubjectId(clientId); - IgniteCompute comp = ctx.grid().compute(prj).withTimeout(timeout).enableAsync(); + IgniteCompute comp = ctx.grid().compute(prj).withTimeout(timeout).withAsync(); Object arg = !F.isEmpty(params) ? params.size() == 1 ? params.get(0) : params.toArray() : null; @@ -203,7 +203,7 @@ public class GridTaskCommandHandler extends GridRestCommandHandlerAdapter { // in order to provide user well-structured EmptyProjectionException. ClusterGroup prj = ctx.grid().forPredicate(F.nodeForNodeId(req.destinationId())); - IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().enableAsync(); + IgniteCompute comp = ctx.grid().compute(prj).withNoFailover().withAsync(); comp.call(new ExeCallable(name, params, timeout, clientId)); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java index 6e536d1..4540e8c 100644 --- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java +++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupport.java @@ -26,7 +26,7 @@ public interface IgniteAsyncSupport { * * @return Component with asynchronous mode enabled. */ - public IgniteAsyncSupport enableAsync(); + public IgniteAsyncSupport withAsync(); /** * @return {@code True} if asynchronous mode is enabled. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java index 99b1a1e..63cf9f5 100644 --- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupportAdapter.java @@ -51,7 +51,7 @@ public class IgniteAsyncSupportAdapter<T extends IgniteAsyncSupport> implements } /** {@inheritDoc} */ - @Override public T enableAsync() { + @Override public T withAsync() { T res = asyncInstance; if (res == null) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java index 7f82c0c..e70c07a 100644 --- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java +++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java @@ -21,7 +21,7 @@ import java.lang.annotation.*; /** * Annotation to indicate that method can be executed asynchronously if async mode is enabled. - * To enable async mode, invoke {@link IgniteAsyncSupport#enableAsync()} method on the API. + * To enable async mode, invoke {@link IgniteAsyncSupport#withAsync()} method on the API. * The future for the async method can be retrieved via {@link IgniteAsyncSupport#future()} method * right after the execution of an asynchronous method. * http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java index 730225f..42a15d2 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelOnGridStopSelfTest.java @@ -54,7 +54,7 @@ public class GridCancelOnGridStopSelfTest extends GridCommonAbstractTest { try (Ignite g = startGrid(1)) { cnt = new CountDownLatch(1); - g.compute().enableAsync().execute(CancelledTask.class, null); + g.compute().withAsync().execute(CancelledTask.class, null); cnt.await(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java index d37c57d..e04b9e0 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridCancelledJobsMetricsSelfTest.java @@ -70,7 +70,7 @@ public class GridCancelledJobsMetricsSelfTest extends GridCommonAbstractTest { Collection<ComputeTaskFuture<?>> futs = new ArrayList<>(); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); for (int i = 1; i <= 10; i++) { comp.execute(CancelledTask.class, null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java index f4729c4..90a6553 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridContinuousTaskSelfTest.java @@ -45,7 +45,7 @@ public class GridContinuousTaskSelfTest extends GridCommonAbstractTest { try { Ignite ignite = startGrid(0); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(TestJobsChainTask.class, true); @@ -75,7 +75,7 @@ public class GridContinuousTaskSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override public void run() { try { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); comp.execute(TestJobsChainTask.class, true); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java index 384b953..ca71778 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageCheckAllEventsSelfTest.java @@ -289,7 +289,7 @@ public class GridEventStorageCheckAllEventsSelfTest extends GridCommonAbstractTe * @throws Exception If failed. */ private ComputeTaskFuture<?> generateEvents(@Nullable Long timeout, ComputeJob job) throws Exception { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); if (timeout == null) comp.execute(GridAllEventsTestTask.class.getName(), job); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java index 025acdb..55b36f8 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridFailoverCustomTopologySelfTest.java @@ -84,7 +84,7 @@ public class GridFailoverCustomTopologySelfTest extends GridCommonAbstractTest { ComputeTaskFuture<String> fut; synchronized(mux){ - IgniteCompute comp = ignite1.compute().enableAsync(); + IgniteCompute comp = ignite1.compute().withAsync(); comp.execute(JobTask.class, null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java index aff0eaf..f79a68a 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java @@ -134,7 +134,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { Ignite g = startGrid(0); - g.compute().enableAsync().execute(new TestTask(1), null); + g.compute().withAsync().execute(new TestTask(1), null); jobLatch.await(); @@ -171,7 +171,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { int lastGridIdx = GRID_CNT - 1; - compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).enableAsync(). + compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).withAsync(). execute(new TestTask(GRID_CNT - 1), null); jobLatch.await(); @@ -196,7 +196,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { int lastGridIdx = GRID_CNT - 1; - compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).enableAsync(). + compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).withAsync(). execute(new TestTask(GRID_CNT - 1), null); jobLatch.await(); @@ -225,7 +225,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { int lastGridIdx = GRID_CNT - 1; - compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).enableAsync(). + compute(grid(lastGridIdx).forPredicate(excludeLastPredicate())).withAsync(). execute(new TestTask(GRID_CNT - 1), null); jobLatch.await(); @@ -255,7 +255,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testApply1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException { - IgniteCompute comp = compute(grid).enableAsync(); + IgniteCompute comp = compute(grid).withAsync(); comp.apply(new TestClosure(), "arg"); @@ -270,7 +270,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testApply2() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException { - IgniteCompute comp = compute(grid).enableAsync(); + IgniteCompute comp = compute(grid).withAsync(); comp.apply(new TestClosure(), Arrays.asList("arg1", "arg2")); @@ -285,7 +285,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testApply3() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException { - IgniteCompute comp = compute(grid).enableAsync(); + IgniteCompute comp = compute(grid).withAsync(); comp.apply(new TestClosure(), Arrays.asList("arg1", "arg2"), @@ -310,7 +310,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testRun1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.run(new TestRunnable()); @@ -325,7 +325,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testRun2() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.run(Arrays.asList(new TestRunnable(), new TestRunnable())); @@ -340,7 +340,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testCall1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.call(new TestCallable()); @@ -355,7 +355,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testCall2() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.call(Arrays.asList(new TestCallable(), new TestCallable())); @@ -370,7 +370,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testCall3() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.call( Arrays.asList(new TestCallable(), new TestCallable()), @@ -395,7 +395,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testBroadcast1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestRunnable()); @@ -410,7 +410,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testBroadcast2() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestCallable()); @@ -425,7 +425,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testBroadcast3() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestClosure(), "arg"); @@ -440,7 +440,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testAffinityRun() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); CacheAffinity<Object> aff = prj.ignite().cache(null).affinity(); @@ -459,7 +459,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { public void testAffinityCall() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); CacheAffinity<Object> aff = prj.ignite().cache(null).affinity(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java index 49635de..d6ec8ad 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java @@ -148,7 +148,7 @@ public class GridMultipleJobsSelfTest extends GridCommonAbstractTest { throw new IgniteCheckedException("Could not instantiate a job.", e); } - IgniteCompute comp = ignite1.compute().enableAsync(); + IgniteCompute comp = ignite1.compute().withAsync(); comp.call(job); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java index 96c6efa..9da8a0b 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionAbstractTest.java @@ -323,7 +323,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest * @throws Exception If failed. */ private void run1(AtomicInteger cnt) throws Exception { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(runJob); @@ -345,7 +345,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest private void run2(AtomicInteger cnt) throws Exception { Collection<Runnable> jobs = F.asList(runJob); - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.run(jobs); @@ -365,7 +365,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest * @throws Exception If failed. */ private void call1(AtomicInteger cnt) throws Exception { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(calJob); @@ -385,7 +385,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest * @throws Exception If failed. */ private void call2(AtomicInteger cnt) throws Exception { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); Collection<Callable<String>> jobs = F.asList(calJob); @@ -407,7 +407,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest * @throws Exception If failed. */ private void call3(AtomicInteger cnt) throws Exception { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.apply(clrJob, (String) null); @@ -429,7 +429,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest private void call4(AtomicInteger cnt) throws Exception { Collection<String> args = F.asList("a", "b", "c"); - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.apply(clrJob, args); @@ -449,7 +449,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest * @throws Exception If failed. */ private void call5(AtomicInteger cnt) throws Exception { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestClosure(), "arg"); @@ -476,7 +476,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest private void forkjoin1(AtomicInteger cnt) throws Exception { Collection<String> args = F.asList("a", "b", "c"); - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.apply(clrJob, args, rdc); @@ -498,7 +498,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest private void forkjoin2(AtomicInteger cnt) throws Exception { Collection<Callable<String>> jobs = F.asList(calJob); - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.call(jobs, rdc); @@ -643,7 +643,7 @@ public abstract class GridProjectionAbstractTest extends GridCommonAbstractTest * @throws Exception If test failed. */ private void checkActiveFutures() throws Exception { - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); assertEquals(0, comp.activeTaskFutures().size()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java index f83b7e8..db2e960 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridReduceSelfTest.java @@ -87,7 +87,7 @@ public class GridReduceSelfTest extends GridCommonAbstractTest { List<ReducerTestClosure> closures = closures(ignite.cluster().nodes().size()); - IgniteCompute comp = compute(ignite.cluster().forLocal()).enableAsync(); + IgniteCompute comp = compute(ignite.cluster().forLocal()).withAsync(); comp.call(closures, new R1<Long, Long>() { private long sum; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java index c587e5d..c107914 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskCancelSingleNodeSelfTest.java @@ -100,7 +100,7 @@ public class GridTaskCancelSingleNodeSelfTest extends GridCommonAbstractTest { } }, EVT_JOB_FINISHED, EVT_JOB_CANCELLED, EVT_JOB_REJECTED); - IgniteCompute comp = grid().compute().enableAsync(); + IgniteCompute comp = grid().compute().withAsync(); comp.execute(TestTask.class, null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java index a843394..e12ae60 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionSelfTest.java @@ -55,7 +55,7 @@ public class GridTaskExecutionSelfTest extends GridCommonAbstractTest { * @throws Exception If failed. */ public void testSynchronousExecute() throws Exception { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); assertNull(comp.execute(GridTestTask.class, "testArg")); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java index 80fe81f..1aebc39 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskInstanceExecutionSelfTest.java @@ -52,7 +52,7 @@ public class GridTaskInstanceExecutionSelfTest extends GridCommonAbstractTest { assert task.getState() != null; assert task.getState() == testState; - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); assertNull(comp.execute(task, "testArg")); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java index 9b055a8..062c42b 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskJobRejectSelfTest.java @@ -116,7 +116,7 @@ public class GridTaskJobRejectSelfTest extends GridCommonAbstractTest { final ClusterNode node = grid(1).localNode(); - IgniteCompute comp = grid(1).compute().enableAsync(); + IgniteCompute comp = grid(1).compute().withAsync(); comp.execute(new ComputeTaskAdapter<Void, Void>() { @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java index 237ab68..e7b93bf 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java @@ -1245,7 +1245,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract cache.put("key2", 1); cache.put("key3", 3); - IgniteCache<String, Integer> asyncCache = cache.enableAsync(); + IgniteCache<String, Integer> asyncCache = cache.withAsync(); assertNull(asyncCache.invoke("key1", INCR_PROCESSOR)); @@ -1619,7 +1619,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract IgniteFuture<IgniteTx> f = null; if (tx != null) { - tx = (IgniteTx)tx.enableAsync(); + tx = (IgniteTx)tx.withAsync(); tx.commit(); @@ -3480,7 +3480,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract final CountDownLatch latch = new CountDownLatch(1); - IgniteCompute comp = forLocal(dfltIgnite).enableAsync(); + IgniteCompute comp = forLocal(dfltIgnite).withAsync(); comp.call(new Callable<Boolean>() { @Override public Boolean call() throws Exception { @@ -3550,7 +3550,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract final CountDownLatch syncLatch = new CountDownLatch(1); - IgniteCompute comp = forLocal(dfltIgnite).enableAsync(); + IgniteCompute comp = forLocal(dfltIgnite).withAsync(); comp.call(new Callable<Boolean>() { @Override public Boolean call() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java index 56ce912..3e537c5 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java @@ -309,7 +309,7 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest { long submitTime1 = t0; - IgniteCompute comp = g.compute(g.cluster().forPredicate(serverNode)).enableAsync(); + IgniteCompute comp = g.compute(g.cluster().forPredicate(serverNode)).withAsync(); comp.execute(RequestTask.class, new Message(terminalId, nodeId)); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java index 534daf0..96879cf 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheGroupLockFailoverSelfTest.java @@ -320,7 +320,7 @@ public class GridCacheGroupLockFailoverSelfTest extends GridCommonAbstractTest { throws IgniteCheckedException { ClusterGroup prj = master.cluster().forPredicate(workerNodesFilter); - IgniteCompute comp = master.compute(prj).enableAsync(); + IgniteCompute comp = master.compute(prj).withAsync(); comp.execute(new GridCacheGroupLockPutTask(preferredNodeId, CACHE_NAME, optimisticTx()), dataChunk); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java index bea2421..a21eb18 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java @@ -235,7 +235,7 @@ public class GridCachePutAllFailoverSelfTest extends GridCommonAbstractTest { final AtomicBoolean inputExhausted = new AtomicBoolean(); - IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).enableAsync(); + IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).withAsync(); for (Integer key : testKeys) { dataChunk.add(key); @@ -402,7 +402,7 @@ public class GridCachePutAllFailoverSelfTest extends GridCommonAbstractTest { final AtomicBoolean inputExhausted = new AtomicBoolean(); - IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).enableAsync(); + IgniteCompute comp = compute(master.cluster().forPredicate(workerNodesFilter)).withAsync(); for (Integer key : testKeys) { ClusterNode mappedNode = master.cluster().mapKeyToNode(CACHE_NAME, key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java index fa12084..63c42c9 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeAbstractTest.java @@ -147,7 +147,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT checkValue(key, 63); - IgniteCache<Integer, Integer> asyncCache = cache.enableAsync(); + IgniteCache<Integer, Integer> asyncCache = cache.withAsync(); assertTrue(asyncCache.isAsync()); @@ -398,7 +398,7 @@ public abstract class IgniteCacheInvokeAbstractTest extends IgniteCacheAbstractT for (Integer key : keys) checkValue(key, null); - IgniteCache<Integer, Integer> asyncCache = cache.enableAsync(); + IgniteCache<Integer, Integer> asyncCache = cache.withAsync(); assertTrue(asyncCache.isAsync()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java index ea1d2ed..3860d1a 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheCountDownLatchSelfTest.java @@ -208,7 +208,7 @@ public class GridCacheCountDownLatchSelfTest extends GridCommonAbstractTest impl assert latch1.count() == 2; - IgniteCompute comp = grid(0).compute().enableAsync(); + IgniteCompute comp = grid(0).compute().withAsync(); comp.call(new IgniteCallable<Object>() { @IgniteInstanceResource http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java index 36ecfe1..2268044 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheQueueJoinedNodeSelfAbstractTest.java @@ -85,7 +85,7 @@ public abstract class GridCacheQueueJoinedNodeSelfAbstractTest extends GridCommo PutJob putJob = new PutJob(queueName); - IgniteCompute comp = compute(grid(0).forLocal()).enableAsync(); + IgniteCompute comp = compute(grid(0).forLocal()).withAsync(); comp.run(putJob); @@ -104,7 +104,7 @@ public abstract class GridCacheQueueJoinedNodeSelfAbstractTest extends GridCommo jobs.add(job); - comp = compute(grid(i).forLocal()).enableAsync(); + comp = compute(grid(i).forLocal()).withAsync(); comp.call(job); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java index c5c0752..9878cb5 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java @@ -123,7 +123,7 @@ public abstract class GridCacheAbstractJobExecutionTest extends GridCommonAbstra Collection<IgniteFuture<?>> futs = new LinkedList<>(); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); for (int i = 0; i < jobCnt; i++) { comp.apply(new CX1<Integer, Void>() { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java index 4d8fee4..c6b3adc 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest.java @@ -186,7 +186,7 @@ public abstract class IgniteTxPessimisticOriginatingNodeFailureAbstractSelfTest info("Before commitAsync"); - tx = (IgniteTx)tx.enableAsync(); + tx = (IgniteTx)tx.withAsync(); tx.commit(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java index aabcc3a..999f527 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheGlobalLoadTest.java @@ -85,7 +85,7 @@ public class GridCacheGlobalLoadTest extends IgniteCacheAbstractTest { private void loadCache(boolean async) throws Exception { IgniteCache<Integer, Integer> cache = jcache(); - IgniteCache<Integer, Integer> asyncCache = cache.enableAsync(); + IgniteCache<Integer, Integer> asyncCache = cache.withAsync(); assertTrue(asyncCache.isAsync()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java index b8cab48..cf93827 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedEntryLockSelfTest.java @@ -57,7 +57,7 @@ public class GridCachePartitionedEntryLockSelfTest extends GridCacheAbstractSelf assert e.isLocked(); - IgniteCompute comp = compute(grid(i).forLocal()).enableAsync(); + IgniteCompute comp = compute(grid(i).forLocal()).withAsync(); comp.call(new Callable<Boolean>() { @Override public Boolean call() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java index 79ab0b8..1563356 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedLoadCacheSelfTest.java @@ -100,7 +100,7 @@ public class GridCachePartitionedLoadCacheSelfTest extends GridCommonAbstractTes IgniteCache<Integer, String> cache = jcache(0); if (async) { - IgniteCache<Integer, String> asyncCache = cache.enableAsync(); + IgniteCache<Integer, String> asyncCache = cache.withAsync(); asyncCache.localLoadCache(null, PUT_CNT); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java index 5d89685..86ba60b 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiNodeFullApiSelfTest.java @@ -446,7 +446,7 @@ public class GridCachePartitionedMultiNodeFullApiSelfTest extends GridCacheParti final CountDownLatch syncLatch = new CountDownLatch(1); - IgniteCompute comp = compute(dfltIgnite.cluster().forLocal()).enableAsync(); + IgniteCompute comp = compute(dfltIgnite.cluster().forLocal()).withAsync(); comp.call(new Callable<Boolean>() { @Override public Boolean call() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java index 58db968..964fdc9 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java @@ -198,7 +198,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute(); - comp = comp.enableAsync(); + comp = comp.withAsync(); comp.run(job); @@ -224,7 +224,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { if (p != null) prj = prj.forPredicate(p); - IgniteCompute comp = compute(prj).enableAsync(); + IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(job); @@ -247,7 +247,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute(); - comp = comp.enableAsync(); + comp = comp.withAsync(); comp.run(jobs); @@ -270,7 +270,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute(); - comp = comp.enableAsync(); + comp = comp.withAsync(); comp.call(job); @@ -293,7 +293,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute(); - comp = comp.enableAsync(); + comp = comp.withAsync(); comp.broadcast(job); @@ -316,7 +316,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { IgniteCompute comp = p != null ? compute(grid(idx).forPredicate(p)) : grid(idx).compute(); - comp = comp.enableAsync(); + comp = comp.withAsync(); comp.call(jobs); @@ -407,7 +407,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { * @throws Exception If failed. */ public void testCallAsyncErrorNoFailover() throws Exception { - IgniteCompute comp = compute(grid(0).forPredicate(F.notEqualTo(grid(0).localNode()))).enableAsync(); + IgniteCompute comp = compute(grid(0).forPredicate(F.notEqualTo(grid(0).localNode()))).withAsync(); comp.withNoFailover().call(new TestCallableError()); @@ -486,7 +486,7 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { public void testReduceAsync() throws Exception { Collection<TestCallable> jobs = F.asList(new TestCallable(), new TestCallable()); - IgniteCompute comp = grid(0).compute().enableAsync(); + IgniteCompute comp = grid(0).compute().withAsync(); comp.call(jobs, F.sumIntReducer()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java index 2db4e33..a67d1cd 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java @@ -964,7 +964,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { int idx = rnd.nextInt(GRID_CNT); try { - IgniteEvents evts = grid(idx).events().enableAsync(); + IgniteEvents evts = grid(idx).events().withAsync(); evts.remoteListen(new P2<UUID, IgniteEvent>() { @Override public boolean apply(UUID uuid, IgniteEvent evt) { @@ -1003,7 +1003,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { UUID consumeId = t.get2(); try { - IgniteEvents evts = grid(idx).events().enableAsync(); + IgniteEvents evts = grid(idx).events().withAsync(); evts.stopRemoteListen(consumeId); @@ -1037,7 +1037,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { int idx = rnd.nextInt(GRID_CNT); try { - IgniteCompute comp = grid(idx).compute().enableAsync(); + IgniteCompute comp = grid(idx).compute().withAsync(); comp.run(F.noop()); @@ -1063,7 +1063,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { int idx = t.get1(); UUID consumeId = t.get2(); - IgniteEvents evts = grid(idx).events().enableAsync(); + IgniteEvents evts = grid(idx).events().withAsync(); evts.stopRemoteListen(consumeId); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java index b11d7bb..1211797 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/fs/GridGgfsTaskSelfTest.java @@ -172,7 +172,7 @@ public class GridGgfsTaskSelfTest extends GridGgfsCommonAbstractTest { assertFalse(ggfs.isAsync()); - IgniteFs ggfsAsync = ggfs.enableAsync(); + IgniteFs ggfsAsync = ggfs.withAsync(); assertTrue(ggfsAsync.isAsync()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java index f5e6c86..a0469b3 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java @@ -141,8 +141,8 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs public void testSameConfiguration() throws Exception { String name = "dupService"; - IgniteManaged svcs1 = randomGrid().managed().enableAsync(); - IgniteManaged svcs2 = randomGrid().managed().enableAsync(); + IgniteManaged svcs1 = randomGrid().managed().withAsync(); + IgniteManaged svcs2 = randomGrid().managed().withAsync(); svcs1.deployClusterSingleton(name, new DummyService()); @@ -170,8 +170,8 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs public void testDifferentConfiguration() throws Exception { String name = "dupService"; - IgniteManaged svcs1 = randomGrid().managed().enableAsync(); - IgniteManaged svcs2 = randomGrid().managed().enableAsync(); + IgniteManaged svcs1 = randomGrid().managed().withAsync(); + IgniteManaged svcs2 = randomGrid().managed().withAsync(); svcs1.deployClusterSingleton(name, new DummyService()); @@ -255,7 +255,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs DummyService.exeLatch(name, latch); - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployNodeSingleton(name, new DummyService()); @@ -287,7 +287,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs DummyService.exeLatch(name, latch); - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployClusterSingleton(name, new DummyService()); @@ -320,7 +320,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs String name = "serviceAffinity"; - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployKeyAffinitySingleton(name, new AffinityService(affKey), CACHE_NAME, affKey); @@ -348,7 +348,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs DummyService.exeLatch(name, latch); - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployMultiple(name, new DummyService(), nodeCount() * 2, 3); @@ -382,7 +382,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs DummyService.exeLatch(name, latch); - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployMultiple(name, new DummyService(), cnt, 3); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java index 9896ea5..fccbf85 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorMultiNodeSelfTest.java @@ -44,7 +44,7 @@ public class GridServiceProcessorMultiNodeSelfTest extends GridServiceProcessorA DummyService.exeLatch(name, latch); - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployClusterSingleton(name, new DummyService()); @@ -91,7 +91,7 @@ public class GridServiceProcessorMultiNodeSelfTest extends GridServiceProcessorA String name = "serviceAffinityUpdateTopology"; - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployKeyAffinitySingleton(name, new AffinityService(affKey), CACHE_NAME, affKey); @@ -130,7 +130,7 @@ public class GridServiceProcessorMultiNodeSelfTest extends GridServiceProcessorA DummyService.exeLatch(name, latch); - IgniteManaged svcs = g.managed().enableAsync(); + IgniteManaged svcs = g.managed().withAsync(); svcs.deployNodeSingleton(name, new DummyService()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java index 8ca7e7e..c8c9371 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtest/GridSingleExecutionTest.java @@ -81,7 +81,7 @@ public final class GridSingleExecutionTest { try { Ignite ignite = G.ignite(); - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); // Execute Hello World task. comp.execute(!useSes ? TestTask.class : TestSessionTask.class, null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java b/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java index 4d8539c..0aed81d 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java @@ -77,7 +77,7 @@ public class GridTestMain { long start = System.currentTimeMillis(); - IgniteCompute comp = g.compute().enableAsync(); + IgniteCompute comp = g.compute().withAsync(); // Collocate computations and data. for (long i = 0; i < GridTestConstants.ENTRY_COUNT; i++) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bceabb1d/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java index 26043ac..0249cf8 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsLoadTest.java @@ -107,7 +107,7 @@ public class GridMultiSplitsLoadTest extends GridCommonAbstractTest { GridTestUtils.runMultiThreaded(new Runnable() { /** {@inheritDoc} */ @Override public void run() { - IgniteCompute comp = ignite.compute().enableAsync(); + IgniteCompute comp = ignite.compute().withAsync(); while (end - System.currentTimeMillis() > 0) { int levels = 3;
