ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [17/50] [abbrv] ignite git commit: Fixed IgniteTransactionalWriteInvokeBenchmark
Date Wed, 09 Dec 2015 07:36:43 GMT
Fixed IgniteTransactionalWriteInvokeBenchmark


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

Branch: refs/heads/ignite-1.5.1
Commit: e5de23e9b61acc435ead4e70be9970a307906dbb
Parents: 11d668b
Author: ashutak <ashutak@gridgain.com>
Authored: Fri Dec 4 12:11:15 2015 +0300
Committer: ashutak <ashutak@gridgain.com>
Committed: Fri Dec 4 12:11:15 2015 +0300

----------------------------------------------------------------------
 .../IgniteTransactionalWriteInvokeBenchmark.java    | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e5de23e9/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
----------------------------------------------------------------------
diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
index 9f9b5f7..35befad 100644
--- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
+++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
@@ -68,17 +68,15 @@ public class IgniteTransactionalWriteInvokeBenchmark extends IgniteFailoverAbstr
 
         long start = System.nanoTime();
 
-        if (cfg.memberId() == 0) {
-            try (IgniteDataStreamer<String, Long> dataLdr = ignite().dataStreamer(cacheName()))
{
-                for (int k = 0; k < args.range() && !Thread.currentThread().isInterrupted();
k++) {
-                    dataLdr.addData("key-" + k + "-master", INITIAL_VALUE);
+        try (IgniteDataStreamer<String, Long> dataLdr = ignite().dataStreamer(cacheName()))
{
+            for (int k = 0; k < args.range() && !Thread.currentThread().isInterrupted();
k++) {
+                dataLdr.addData("key-" + k + "-master", INITIAL_VALUE);
 
-                    for (int i = 0; i < args.keysCount(); i++)
-                        dataLdr.addData("key-" + k + "-" + i, INITIAL_VALUE);
+                for (int i = 0; i < args.keysCount(); i++)
+                    dataLdr.addData("key-" + k + "-" + i, INITIAL_VALUE);
 
-                    if (k % 100000 == 0)
-                        println(cfg, "Populated accounts: " + k);
-                }
+                if (k % 100000 == 0)
+                    println(cfg, "Populated accounts: " + k);
             }
         }
 


Mime
View raw message