ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [01/50] incubator-ignite git commit: # IGNITE-789 Review.
Date Tue, 05 May 2015 12:24:07 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-834 1255e5849 -> 863d6bf69


# IGNITE-789 Review.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/96f3c037
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/96f3c037
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/96f3c037

Branch: refs/heads/ignite-834
Commit: 96f3c0373b4e28c55dae1c6ff6cde1712ad78b70
Parents: c33d096
Author: AKuznetsov <akuznetsov@gridgain.com>
Authored: Wed Apr 29 10:26:43 2015 +0700
Committer: AKuznetsov <akuznetsov@gridgain.com>
Committed: Wed Apr 29 10:26:43 2015 +0700

----------------------------------------------------------------------
 .../internal/visor/cache/VisorCacheStartTask.java     | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/96f3c037/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java
index 34f7b18..270c48a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java
@@ -35,7 +35,8 @@ import java.util.*;
  * Task that start cache or near cache with specified configuration.
  */
 @GridInternal
-public class VisorCacheStartTask extends VisorMultiNodeTask<IgniteBiTuple<String, String>,
Void, Void> {
+public class VisorCacheStartTask extends
+    VisorMultiNodeTask<IgniteBiTuple<String, String>, Map<UUID, IgniteException>,
Void> {
     /** */
     private static final long serialVersionUID = 0L;
 
@@ -44,8 +45,15 @@ public class VisorCacheStartTask extends VisorMultiNodeTask<IgniteBiTuple<String
         return new VisorCacheStartJob(arg, debug);
     }
 
-    @Nullable @Override protected Void reduce0(List<ComputeJobResult> results) throws
IgniteException {
-        return null;
+    /** {@inheritDoc} */
+    @Nullable @Override protected Map<UUID, IgniteException> reduce0(List<ComputeJobResult>
results) throws IgniteException {
+        Map<UUID, IgniteException> map = new HashMap<>();
+
+        for (ComputeJobResult res : results)
+            if (res.getException() != null)
+                map.put(res.getNode().id(), res.getException());
+
+        return map;
     }
 
     /**


Mime
View raw message