# sprint-1 add annotation IgniteAsyncSupported
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f8ecd87a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f8ecd87a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f8ecd87a Branch: refs/heads/ignite-32 Commit: f8ecd87a728e2a205ab7b6849a4df5e797eaf188 Parents: 74efcec Author: sboikov <sboi...@gridgain.com> Authored: Thu Jan 22 12:26:20 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Jan 22 12:26:20 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/IgniteCluster.java | 15 ++++++++++--- .../java/org/apache/ignite/IgniteEvents.java | 22 ++++++++++++++------ .../main/java/org/apache/ignite/IgniteFs.java | 5 +++++ .../java/org/apache/ignite/IgniteManaged.java | 18 ++++++++++++++-- .../java/org/apache/ignite/IgniteMessaging.java | 5 +++-- 5 files changed, 52 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8ecd87a/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 df6c6fc..6366b99 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java @@ -174,8 +174,12 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * and error message (if any). * @throws IgniteCheckedException In case of error. */ - public Collection<GridTuple3<String, Boolean, String>> startNodes(File file, boolean restart, - int timeout, int maxConn) throws IgniteCheckedException; + @IgniteAsyncSupported + public Collection<GridTuple3<String, Boolean, String>> startNodes(File file, + boolean restart, + int timeout, + int maxConn) + throws IgniteCheckedException; /** * Starts one or more nodes on remote host(s). @@ -275,8 +279,13 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * and error message (if any). * @throws IgniteCheckedException In case of error. */ + @IgniteAsyncSupported public Collection<GridTuple3<String, Boolean, String>> startNodes(Collection<Map<String, Object>> hosts, - @Nullable Map<String, Object> dflts, boolean restart, int timeout, int maxConn) throws IgniteCheckedException; + @Nullable Map<String, Object> dflts, + boolean restart, + int timeout, + int maxConn) + throws IgniteCheckedException; /** * Stops nodes satisfying optional set of predicates. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8ecd87a/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 165e512..4109844 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java @@ -72,6 +72,7 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @return Collection of grid events returned from specified nodes. * @throws IgniteCheckedException If query failed. */ + @IgniteAsyncSupported public <T extends IgniteEvent> List<T> remoteQuery(IgnitePredicate<T> p, long timeout, @Nullable int... types) throws IgniteCheckedException; @@ -99,8 +100,11 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @return {@code Operation ID} that can be passed to {@link #stopRemoteListen(UUID)} method to stop listening. * @throws IgniteCheckedException If failed to add listener. */ + @IgniteAsyncSupported public <T extends IgniteEvent> UUID remoteListen(@Nullable IgniteBiPredicate<UUID, T> locLsnr, - @Nullable IgnitePredicate<T> rmtFilter, @Nullable int... types) throws IgniteCheckedException; + @Nullable IgnitePredicate<T> rmtFilter, + @Nullable int... types) + throws IgniteCheckedException; /** * Adds event listener for specified events to all nodes in the projection (possibly including @@ -137,9 +141,14 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @see #stopRemoteListen(UUID) * @throws IgniteCheckedException If failed to add listener. */ - public <T extends IgniteEvent> UUID remoteListen(int bufSize, long interval, - boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID, T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, - @Nullable int... types) throws IgniteCheckedException; + @IgniteAsyncSupported + public <T extends IgniteEvent> UUID remoteListen(int bufSize, + long interval, + boolean autoUnsubscribe, + @Nullable IgniteBiPredicate<UUID, T> locLsnr, + @Nullable IgnitePredicate<T> rmtFilter, + @Nullable int... types) + throws IgniteCheckedException; /** * Stops listening to remote events. This will unregister all listeners identified with provided @@ -152,6 +161,7 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @see #remoteListen(org.apache.ignite.lang.IgniteBiPredicate, org.apache.ignite.lang.IgnitePredicate, int...) * @throws IgniteCheckedException If failed to stop listeners. */ + @IgniteAsyncSupported public void stopRemoteListen(UUID opId) throws IgniteCheckedException; /** @@ -165,6 +175,7 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @return Grid event. * @throws IgniteCheckedException If wait was interrupted. */ + @IgniteAsyncSupported public <T extends IgniteEvent> T waitForLocal(@Nullable IgnitePredicate<T> filter, @Nullable int... types) throws IgniteCheckedException; @@ -247,6 +258,5 @@ public interface IgniteEvents extends IgniteAsyncSupport { public boolean isEnabled(int type); /** {@inheritDoc} */ - @Override - IgniteEvents enableAsync(); + @Override IgniteEvents enableAsync(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8ecd87a/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 fe96659..135ee78 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java @@ -263,6 +263,7 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * * @throws IgniteCheckedException In case format has failed. */ + @IgniteAsyncSupported public void format() throws IgniteCheckedException; /** @@ -277,6 +278,7 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @return Task result. * @throws IgniteCheckedException If execution failed. */ + @IgniteAsyncSupported public <T, R> R execute(IgniteFsTask<T, R> task, @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, @Nullable T arg) throws IgniteCheckedException; @@ -297,6 +299,7 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @return Task result. * @throws IgniteCheckedException If execution failed. */ + @IgniteAsyncSupported public <T, R> R execute(IgniteFsTask<T, R> task, @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, boolean skipNonExistentFiles, long maxRangeLen, @Nullable T arg) throws IgniteCheckedException; @@ -313,6 +316,7 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @return Task result. * @throws IgniteCheckedException If execution failed. */ + @IgniteAsyncSupported public <T, R> R execute(Class<? extends IgniteFsTask<T, R>> taskCls, @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, @Nullable T arg) throws IgniteCheckedException; @@ -332,6 +336,7 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @return Task result. * @throws IgniteCheckedException If execution failed. */ + @IgniteAsyncSupported public <T, R> R execute(Class<? extends IgniteFsTask<T, R>> taskCls, @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, boolean skipNonExistentFiles, long maxRangeLen, @Nullable T arg) throws IgniteCheckedException; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8ecd87a/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 33353d1..98f4186 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java @@ -152,6 +152,7 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param svc Service instance. * @throws IgniteCheckedException If failed to deploy service. */ + @IgniteAsyncSupported public void deployClusterSingleton(String name, ManagedService svc) throws IgniteCheckedException; /** @@ -169,6 +170,7 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param svc Service instance. * @throws IgniteCheckedException If failed to deploy service. */ + @IgniteAsyncSupported public void deployNodeSingleton(String name, ManagedService svc) throws IgniteCheckedException; /** @@ -204,7 +206,11 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param affKey Affinity cache key. * @throws IgniteCheckedException If failed to deploy service. */ - public void deployKeyAffinitySingleton(String name, ManagedService svc, @Nullable String cacheName, Object affKey) + @IgniteAsyncSupported + public void deployKeyAffinitySingleton(String name, + ManagedService svc, + @Nullable String cacheName, + Object affKey) throws IgniteCheckedException; /** @@ -239,7 +245,12 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param maxPerNodeCnt Maximum number of deployed services on each node, {@code 0} for unlimited. * @throws IgniteCheckedException If failed to deploy service. */ - public void deployMultiple(String name, ManagedService svc, int totalCnt, int maxPerNodeCnt) throws IgniteCheckedException; + @IgniteAsyncSupported + public void deployMultiple(String name, + ManagedService svc, + int totalCnt, + int maxPerNodeCnt) + throws IgniteCheckedException; /** * Deploys multiple instances of the service on the grid according to provided @@ -279,6 +290,7 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param cfg Service configuration. * @throws IgniteCheckedException If failed to deploy service. */ + @IgniteAsyncSupported public void deploy(ManagedServiceConfiguration cfg) throws IgniteCheckedException; /** @@ -294,6 +306,7 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param name Name of service to cancel. * @throws IgniteCheckedException If failed to cancel service. */ + @IgniteAsyncSupported public void cancel(String name) throws IgniteCheckedException; /** @@ -306,6 +319,7 @@ public interface IgniteManaged extends IgniteAsyncSupport { * * @throws IgniteCheckedException If failed to cancel services. */ + @IgniteAsyncSupported public void cancelAll() throws IgniteCheckedException; /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8ecd87a/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 2217956..49479d1 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java @@ -133,6 +133,7 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * @return {@code Operation ID} that can be passed to {@link #stopRemoteListen(UUID)} method to stop listening. * @throws IgniteCheckedException If failed to add listener. */ + @IgniteAsyncSupported public UUID remoteListen(@Nullable Object topic, IgniteBiPredicate<UUID, ?> p) throws IgniteCheckedException; /** @@ -143,9 +144,9 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * @param opId Listen ID that was returned from {@link #remoteListen(Object, org.apache.ignite.lang.IgniteBiPredicate)} method. * @throws IgniteCheckedException If failed to unregister listeners. */ + @IgniteAsyncSupported public void stopRemoteListen(UUID opId) throws IgniteCheckedException; /** {@inheritDoc} */ - @Override - IgniteMessaging enableAsync(); + @Override IgniteMessaging enableAsync(); }
