ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [39/50] [abbrv] incubator-ignite git commit: # sprint-1 add annotation IgniteAsyncSupported
Date Mon, 26 Jan 2015 08:18:44 GMT
# 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-gg9499
Commit: f8ecd87a728e2a205ab7b6849a4df5e797eaf188
Parents: 74efcec
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Jan 22 12:26:20 2015 +0300
Committer: sboikov <sboikov@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();
 }


Mime
View raw message