ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [20/32] incubator-ignite git commit: # ignite-sprint-4 added put retries in test
Date Wed, 15 Apr 2015 11:40:40 GMT
# ignite-sprint-4 added put retries in test


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

Branch: refs/heads/ignite-746-debug
Commit: 8b904516afff7cf49492494660e691a015dfd4f3
Parents: 4fe2a9a
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Apr 15 11:01:48 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Apr 15 11:01:48 2015 +0300

----------------------------------------------------------------------
 .../processors/cache/GridCachePutAllTask.java   | 30 ++++++++++++++++++--
 1 file changed, 28 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8b904516/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
index 479ff9c..f9d49f6 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
@@ -91,6 +91,8 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
 
                     int cnt = 0;
 
+                    final int RETRIES = 5;
+
                     while (it.hasNext()) {
                         Integer val = it.next();
 
@@ -102,7 +104,19 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                             else
                                 log.info("Putting keys to cache [size=" + putMap.size() +
']');
 
-                            cache.putAll(putMap);
+                            for (int i = 0; i < RETRIES; i++) {
+                                try {
+                                    cache.putAll(putMap);
+
+                                    break;
+                                }
+                                catch (IgniteException e) {
+                                    if (i < RETRIES - 1)
+                                        log.info("Put error, will retry: " + e);
+                                    else
+                                        throw e;
+                                }
+                            }
 
                             cnt = 0;
 
@@ -118,7 +132,19 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                     else
                         log.info("Putting keys to cache [size=" + putMap.size() + ']');
 
-                    cache.putAll(putMap);
+                    for (int i = 0; i < RETRIES; i++) {
+                        try {
+                            cache.putAll(putMap);
+
+                            break;
+                        }
+                        catch (IgniteException e) {
+                            if (i < RETRIES - 1)
+                                log.info("Put error, will retry: " + e);
+                            else
+                                throw e;
+                        }
+                    }
 
                     if (DEBUG_DATA)
                         log.info("Finished putting data: " + data);


Mime
View raw message