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 79BDB1810D for ; Wed, 9 Dec 2015 07:36:28 +0000 (UTC) Received: (qmail 2678 invoked by uid 500); 9 Dec 2015 07:36:28 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 2596 invoked by uid 500); 9 Dec 2015 07:36: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 1084 invoked by uid 99); 9 Dec 2015 07:36:27 -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; Wed, 09 Dec 2015 07:36:27 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 99946E08DD; Wed, 9 Dec 2015 07:36:27 +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: Wed, 09 Dec 2015 07:37:05 -0000 Message-Id: <02974a5958234be4bff146ac20eb87f8@git.apache.org> In-Reply-To: <80de28b978cf43a99b96b55ff46d11dd@git.apache.org> References: <80de28b978cf43a99b96b55ff46d11dd@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [39/50] [abbrv] ignite git commit: Fixed race in IgniteTransactionalWriteInvokeBenchmark test. Fixed race in IgniteTransactionalWriteInvokeBenchmark test. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3a340034 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3a340034 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3a340034 Branch: refs/heads/ignite-1.5.1 Commit: 3a340034056f5da0ca00ed88e128b59cc28381d2 Parents: efe632b Author: ashutak Authored: Tue Dec 8 16:02:36 2015 +0300 Committer: ashutak Committed: Tue Dec 8 16:02:36 2015 +0300 ---------------------------------------------------------------------- .../config/benchmark-failover.properties | 2 +- ...IgniteTransactionalWriteInvokeBenchmark.java | 42 +++++++++++++++----- 2 files changed, 33 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3a340034/modules/yardstick/config/benchmark-failover.properties ---------------------------------------------------------------------- diff --git a/modules/yardstick/config/benchmark-failover.properties b/modules/yardstick/config/benchmark-failover.properties index 7ed464c..352e2d4 100644 --- a/modules/yardstick/config/benchmark-failover.properties +++ b/modules/yardstick/config/benchmark-failover.properties @@ -60,7 +60,7 @@ RESTART_SERVERS=true SERVER_HOSTS=localhost,localhost # Comma-separated list of the hosts to run BenchmarkDrivers on. -DRIVER_HOSTS=localhost +DRIVER_HOSTS=localhost,localhost # Remote username. # REMOTE_USER= http://git-wip-us.apache.org/repos/asf/ignite/blob/3a340034/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 35befad..67044a1 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 @@ -25,9 +25,11 @@ import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.Callable; +import java.util.concurrent.TimeUnit; import javax.cache.processor.EntryProcessorException; import javax.cache.processor.MutableEntry; import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCountDownLatch; import org.apache.ignite.IgniteDataStreamer; import org.apache.ignite.cache.CacheEntryProcessor; import org.apache.ignite.cache.affinity.Affinity; @@ -58,29 +60,49 @@ public class IgniteTransactionalWriteInvokeBenchmark extends IgniteFailoverAbstr /** */ private static final Long INITIAL_VALUE = 1L; + /** */ + public static final int TIMEOUT_SEC = 20 * 60; + /** {@inheritDoc} */ @Override public void setUp(BenchmarkConfiguration cfg) throws Exception { super.setUp(cfg); assert args.keysCount() > 0 : "Count of keys: " + args.keysCount(); - println(cfg, "Populating data..."); + IgniteCountDownLatch latch = ignite().countDownLatch("DATA-POPULATED-LATCH-" + cacheName(), 1, true, true); + + if (cfg.memberId() == 0) { + println(cfg, "Populating data for cache: " + cacheName()); - long start = System.nanoTime(); + long start = System.nanoTime(); - 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); + } } + + println(cfg, "Finished populating data in " + ((System.nanoTime() - start) / 1_000_000) + + " ms. for cache: " + cacheName()); + + latch.countDown(); } + else { + println(cfg, "Waiting for populating data in cache by driver with id 0: " + cacheName()); + + boolean success = latch.await(TIMEOUT_SEC, TimeUnit.SECONDS); - println(cfg, "Finished populating data in " + ((System.nanoTime() - start) / 1_000_000) + " ms."); + if (!success) + throw new IllegalStateException("Failed to wait that data populating finish."); + + println(cfg, "Finished waiting for populating data in cache by driver with id 0: " + cacheName()); + } } /** {@inheritDoc} */