Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C4AFB181E9 for ; Fri, 4 Dec 2015 13:45:31 +0000 (UTC) Received: (qmail 61988 invoked by uid 500); 4 Dec 2015 13:45:28 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 61879 invoked by uid 500); 4 Dec 2015 13:45:28 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 61760 invoked by uid 99); 4 Dec 2015 13:45:21 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 04 Dec 2015 13:45:21 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 9F3C0E07D9; Fri, 4 Dec 2015 13:45:21 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.apache.org Date: Fri, 04 Dec 2015 13:45:23 -0000 Message-Id: <0ebccfad9a1749dea543097128965a74@git.apache.org> In-Reply-To: <007b771683d84b589602a2a2a5a2a9ad@git.apache.org> References: <007b771683d84b589602a2a2a5a2a9ad@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [3/7] ignite git commit: Fixed IgniteTransactionalWriteInvokeBenchmark 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-1537 Commit: e5de23e9b61acc435ead4e70be9970a307906dbb Parents: 11d668b Author: ashutak Authored: Fri Dec 4 12:11:15 2015 +0300 Committer: ashutak 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 dataLdr = ignite().dataStreamer(cacheName())) { - for (int k = 0; k < args.range() && !Thread.currentThread().isInterrupted(); k++) { - dataLdr.addData("key-" + k + "-master", INITIAL_VALUE); + try (IgniteDataStreamer 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); } }