ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # ignite-sprint-4 reduce test output
Date Tue, 14 Apr 2015 07:26:05 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-sprint-4 8b3e02ef1 -> b39aa56fc


# ignite-sprint-4 reduce test output


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

Branch: refs/heads/ignite-sprint-4
Commit: b39aa56fc140dae157d07c8ff48c755c6f831b24
Parents: 8b3e02e
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Apr 14 10:24:04 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Apr 14 10:24:04 2015 +0300

----------------------------------------------------------------------
 .../processors/cache/GridCachePutAllTask.java   | 23 ++++++++++++++++----
 1 file changed, 19 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b39aa56f/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 58e7ccb..479ff9c 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
@@ -32,6 +32,9 @@ import java.util.*;
  * Puts all the passed data into partitioned cache in small chunks.
  */
 class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>, Void>
{
+    /** */
+    private static final boolean DEBUG_DATA = false;
+
     /** Number of entries per put. */
     private static final int TX_BOUND = 30;
 
@@ -73,7 +76,10 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                 private Ignite ignite;
 
                 @Override public Object execute() {
-                    log.info("Going to put data: " + data);
+                    if (DEBUG_DATA)
+                        log.info("Going to put data: " + data);
+                    else
+                        log.info("Going to put data [size=" + data.size() + ']');
 
                     IgniteCache<Object, Object> cache = ignite.cache(cacheName);
 
@@ -91,7 +97,10 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                         putMap.put(val, val);
 
                         if (++cnt == TX_BOUND) {
-                            log.info("Putting keys to cache: " + putMap.keySet());
+                            if (DEBUG_DATA)
+                                log.info("Putting keys to cache: " + putMap.keySet());
+                            else
+                                log.info("Putting keys to cache [size=" + putMap.size() +
']');
 
                             cache.putAll(putMap);
 
@@ -104,11 +113,17 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                     assert cnt < TX_BOUND;
                     assert putMap.size() == (data.size() % TX_BOUND) : "putMap.size() = "
+ putMap.size();
 
-                    log.info("Putting keys to cache: " + putMap.keySet());
+                    if (DEBUG_DATA)
+                        log.info("Putting keys to cache: " + putMap.keySet());
+                    else
+                        log.info("Putting keys to cache [size=" + putMap.size() + ']');
 
                     cache.putAll(putMap);
 
-                    log.info("Finished putting data: " + data);
+                    if (DEBUG_DATA)
+                        log.info("Finished putting data: " + data);
+                    else
+                        log.info("Finished putting data [size=" + data.size() + ']');
 
                     return data;
                 }


Mime
View raw message