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 E4D7B173EE for ; Thu, 16 Apr 2015 12:34:28 +0000 (UTC) Received: (qmail 32877 invoked by uid 500); 16 Apr 2015 12:33:54 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 32842 invoked by uid 500); 16 Apr 2015 12:33:54 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 32829 invoked by uid 99); 16 Apr 2015 12:33:54 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 16 Apr 2015 12:33:54 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Thu, 16 Apr 2015 12:33:25 +0000 Received: (qmail 30677 invoked by uid 99); 16 Apr 2015 12:33:22 -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; Thu, 16 Apr 2015 12:33:22 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 8BFC6E10A2; Thu, 16 Apr 2015 12:33:22 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vozerov@apache.org To: commits@ignite.incubator.apache.org Date: Thu, 16 Apr 2015 12:33:28 -0000 Message-Id: <43403bc6b96b48a7902729d7d7dff208@git.apache.org> In-Reply-To: <741ad3ede6e745bebce33c96798d818a@git.apache.org> References: <741ad3ede6e745bebce33c96798d818a@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [07/45] incubator-ignite git commit: #ignite-738: Remove testReduceQuery from GridCacheReduceQueryMultithreadedSelfTest. X-Virus-Checked: Checked by ClamAV on apache.org #ignite-738: Remove testReduceQuery from GridCacheReduceQueryMultithreadedSelfTest. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b68aa1c8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b68aa1c8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b68aa1c8 Branch: refs/heads/ignite-gg-9613 Commit: b68aa1c8792693f11386656f1d5e3ab174460556 Parents: 50dd6e4 Author: ivasilinets Authored: Mon Apr 13 17:13:19 2015 +0300 Committer: ivasilinets Committed: Mon Apr 13 17:13:19 2015 +0300 ---------------------------------------------------------------------- ...idCacheReduceQueryMultithreadedSelfTest.java | 79 -------------------- 1 file changed, 79 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b68aa1c8/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReduceQueryMultithreadedSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReduceQueryMultithreadedSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReduceQueryMultithreadedSelfTest.java index d2a626a..4be2581 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReduceQueryMultithreadedSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReduceQueryMultithreadedSelfTest.java @@ -73,83 +73,4 @@ public class GridCacheReduceQueryMultithreadedSelfTest extends GridCacheAbstract return cfg; } - - /** - * @throws Exception In case of error. - */ - public void testReduceQuery() throws Exception { - final int keyCnt = 5000; - final int logFreq = 500; - - final GridCacheAdapter c = internalCache(jcache()); - - final CountDownLatch startLatch = new CountDownLatch(1); - - IgniteInternalFuture fut1 = multithreadedAsync(new Callable() { - @Override public Object call() throws Exception { - for (int i = 1; i < keyCnt; i++) { - c.getAndPut(String.valueOf(i), i); - - startLatch.countDown(); - - if (i % logFreq == 0) - info("Stored entries: " + i); - } - - return null; - } - }, 1); - - // Create query. - final CacheQuery> sumQry = - c.queries().createSqlQuery(Integer.class, "_val > 0").timeout(TEST_TIMEOUT); - - final R1, Integer> rmtRdc = new R1, Integer>() { - /** */ - private AtomicInteger sum = new AtomicInteger(); - - @Override public boolean collect(Map.Entry e) { - sum.addAndGet(e.getValue()); - - return true; - } - - @Override public Integer reduce() { - return sum.get(); - } - }; - - final AtomicBoolean stop = new AtomicBoolean(); - - startLatch.await(); - - IgniteInternalFuture fut2 = multithreadedAsync(new Callable() { - @Override public Object call() throws Exception { - int cnt = 0; - - while (!stop.get()) { - Collection res = sumQry.execute(rmtRdc).get(); - - int sum = F.sumInt(res); - - cnt++; - - assertTrue(sum > 0); - - if (cnt % logFreq == 0) { - info("Reduced value: " + sum); - info("Executed queries: " + cnt); - } - } - - return null; - } - }, 1); - - fut1.get(); - - stop.set(true); - - fut2.get(); - } }