Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 71696200D2F for ; Wed, 1 Nov 2017 10:55:34 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 6FFE5160BE6; Wed, 1 Nov 2017 09:55:34 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 90A51160BFC for ; Wed, 1 Nov 2017 10:55:33 +0100 (CET) Received: (qmail 99779 invoked by uid 500); 1 Nov 2017 09:55:32 -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 99660 invoked by uid 99); 1 Nov 2017 09:55:32 -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, 01 Nov 2017 09:55:32 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 053F2DFF5A; Wed, 1 Nov 2017 09:55:32 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: agoncharuk@apache.org To: commits@ignite.apache.org Date: Wed, 01 Nov 2017 09:55:34 -0000 Message-Id: <5b3198942f2e4c24947de28e6e10c347@git.apache.org> In-Reply-To: <3bf9884cefff46d480f0a021c5078c7c@git.apache.org> References: <3bf9884cefff46d480f0a021c5078c7c@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [04/19] ignite git commit: IGNITE-6670 Web Agent: Improved demo startup. archived-at: Wed, 01 Nov 2017 09:55:34 -0000 IGNITE-6670 Web Agent: Improved demo startup. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b4bd20e1 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b4bd20e1 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b4bd20e1 Branch: refs/heads/ignite-6778 Commit: b4bd20e10cf564c9852be58e620f1d3b79af9067 Parents: 67859f4 Author: Alexey Kuznetsov Authored: Mon Oct 30 14:56:22 2017 +0700 Committer: Alexey Kuznetsov Committed: Mon Oct 30 14:56:22 2017 +0700 ---------------------------------------------------------------------- .../ignite/console/demo/AgentClusterDemo.java | 32 +++++++++++--------- .../demo/service/DemoCachesLoadService.java | 3 +- 2 files changed, 19 insertions(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b4bd20e1/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/AgentClusterDemo.java ---------------------------------------------------------------------- diff --git a/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/AgentClusterDemo.java b/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/AgentClusterDemo.java index 886888b..7157df7 100644 --- a/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/AgentClusterDemo.java +++ b/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/AgentClusterDemo.java @@ -27,9 +27,9 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.ignite.IgniteException; import org.apache.ignite.IgniteServices; import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.DataRegionConfiguration; +import org.apache.ignite.configuration.DataStorageConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; -import org.apache.ignite.configuration.MemoryConfiguration; -import org.apache.ignite.configuration.MemoryPolicyConfiguration; import org.apache.ignite.console.demo.service.DemoCachesLoadService; import org.apache.ignite.console.demo.service.DemoComputeLoadService; import org.apache.ignite.console.demo.service.DemoRandomCacheLoadService; @@ -53,6 +53,7 @@ import static org.apache.ignite.IgniteSystemProperties.IGNITE_NO_ASCII; import static org.apache.ignite.IgniteSystemProperties.IGNITE_PERFORMANCE_SUGGESTIONS_DISABLED; import static org.apache.ignite.IgniteSystemProperties.IGNITE_QUIET; import static org.apache.ignite.IgniteSystemProperties.IGNITE_UPDATE_NOTIFIER; +import static org.apache.ignite.configuration.DataStorageConfiguration.DFLT_DATA_REGION_INITIAL_SIZE; import static org.apache.ignite.console.demo.AgentDemoUtils.newScheduledThreadPool; import static org.apache.ignite.events.EventType.EVTS_DISCOVERY; import static org.apache.ignite.internal.visor.util.VisorTaskUtils.VISOR_TASK_EVTS; @@ -132,15 +133,16 @@ public class AgentClusterDemo { cfg.setGridLogger(new Slf4jLogger(log)); cfg.setMetricsLogFrequency(0); - MemoryConfiguration memCfg = new MemoryConfiguration(); + DataRegionConfiguration dataRegCfg = new DataRegionConfiguration(); + dataRegCfg.setName("demo"); + dataRegCfg.setMetricsEnabled(true); + dataRegCfg.setMaxSize(DFLT_DATA_REGION_INITIAL_SIZE); - MemoryPolicyConfiguration memPlc = new MemoryPolicyConfiguration(); - memPlc.setName("demo"); - memPlc.setMetricsEnabled(true); + DataStorageConfiguration dataStorageCfg = new DataStorageConfiguration(); + dataStorageCfg.setDefaultDataRegionConfiguration(dataRegCfg); + dataStorageCfg.setSystemRegionMaxSize(DFLT_DATA_REGION_INITIAL_SIZE); - memCfg.setMemoryPolicies(memPlc); - - cfg.setMemoryConfiguration(memCfg); + cfg.setDataStorageConfiguration(dataStorageCfg); if (client) cfg.setClientMode(true); @@ -157,10 +159,10 @@ public class AgentClusterDemo { services.deployMultiple("Demo service: Multiple instances", new DemoServiceMultipleInstances(), 7, 3); services.deployNodeSingleton("Demo service: Node singleton", new DemoServiceNodeSingleton()); services.deployClusterSingleton("Demo service: Cluster singleton", new DemoServiceClusterSingleton()); + services.deployClusterSingleton("Demo caches load service", new DemoCachesLoadService(20)); services.deployKeyAffinitySingleton("Demo service: Key affinity singleton", new DemoServiceKeyAffinity(), DemoCachesLoadService.CAR_CACHE_NAME, "id"); - services.deployClusterSingleton("Demo caches load service", new DemoCachesLoadService(20)); services.deployNodeSingleton("RandomCache load service", new DemoRandomCacheLoadService(20)); services.deployMultiple("Demo service: Compute load", new DemoComputeLoadService(), 2, 1); @@ -195,8 +197,10 @@ public class AgentClusterDemo { int idx = cnt.incrementAndGet(); int port = basePort.get(); + IgniteEx ignite = null; + try { - IgniteEx ignite = (IgniteEx)Ignition.start(igniteConfiguration(port, idx, false)); + ignite = (IgniteEx)Ignition.start(igniteConfiguration(port, idx, false)); if (idx == 0) { Collection jettyAddrs = ignite.localNode().attribute(ATTR_REST_JETTY_ADDRS); @@ -219,8 +223,6 @@ public class AgentClusterDemo { demoUrl = String.format("http://%s:%d", jettyHost, jettyPort); initLatch.countDown(); - - deployServices(ignite.services(ignite.cluster().forServers())); } } catch (Throwable e) { @@ -234,13 +236,15 @@ public class AgentClusterDemo { } finally { if (idx == NODE_CNT) { + deployServices(ignite.services(ignite.cluster().forServers())); + log.info("DEMO: All embedded nodes for demo successfully started"); execSrv.shutdown(); } } } - }, 1, 10, TimeUnit.SECONDS); + }, 1, 5, TimeUnit.SECONDS); } return initLatch; http://git-wip-us.apache.org/repos/asf/ignite/blob/b4bd20e1/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/service/DemoCachesLoadService.java ---------------------------------------------------------------------- diff --git a/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/service/DemoCachesLoadService.java b/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/service/DemoCachesLoadService.java index 40fd4ac..6691d1d 100644 --- a/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/service/DemoCachesLoadService.java +++ b/modules/web-console/web-agent/src/main/java/org/apache/ignite/console/demo/service/DemoCachesLoadService.java @@ -194,7 +194,6 @@ public class DemoCachesLoadService implements Service { }, 10, 3, TimeUnit.SECONDS); } - /** * Create base cache configuration. * @@ -208,7 +207,7 @@ public class DemoCachesLoadService implements Service { ccfg.setQueryDetailMetricsSize(10); ccfg.setStatisticsEnabled(true); ccfg.setSqlFunctionClasses(SQLFunctions.class); - ccfg.setMemoryPolicyName("demo"); + ccfg.setDataRegionName("demo"); return ccfg; }