Return-Path: X-Original-To: apmail-usergrid-commits-archive@minotaur.apache.org Delivered-To: apmail-usergrid-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 9FCC9178A8 for ; Thu, 12 Mar 2015 22:41:09 +0000 (UTC) Received: (qmail 80115 invoked by uid 500); 12 Mar 2015 22:41:09 -0000 Delivered-To: apmail-usergrid-commits-archive@usergrid.apache.org Received: (qmail 79977 invoked by uid 500); 12 Mar 2015 22:41:09 -0000 Mailing-List: contact commits-help@usergrid.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@usergrid.incubator.apache.org Delivered-To: mailing list commits@usergrid.incubator.apache.org Received: (qmail 79695 invoked by uid 99); 12 Mar 2015 22:41:09 -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, 12 Mar 2015 22:41:09 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 2786EE190A; Thu, 12 Mar 2015 22:41:09 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: grey@apache.org To: commits@usergrid.apache.org Date: Thu, 12 Mar 2015 22:41:21 -0000 Message-Id: <5e1bd9a64fce44b1b0dabd1ffa337bcc@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [14/38] incubator-usergrid git commit: Upgraded plexus utils and fixes build concurrency issues with surefire Upgraded plexus utils and fixes build concurrency issues with surefire Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/2c54a2b6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/2c54a2b6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/2c54a2b6 Branch: refs/heads/USERGRID-396 Commit: 2c54a2b6fa4314f696f78f2b2cf11ebcaac03d1e Parents: 10ec635 Author: Todd Nine Authored: Wed Mar 4 15:57:11 2015 -0700 Committer: Todd Nine Committed: Fri Mar 6 15:11:22 2015 -0700 ---------------------------------------------------------------------- stack/core/pom.xml | 7 +- .../core/metrics/MetricsFactoryImpl.java | 3 +- .../persistence/index/guice/IndexModule.java | 7 +- .../index/impl/EsEntityIndexFactoryImpl.java | 74 ++++++++++++++++++++ stack/pom.xml | 24 ++++--- stack/rest/pom.xml | 2 +- stack/services/pom.xml | 7 +- .../usergrid/management/OrganizationIT.java | 2 +- 8 files changed, 109 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/core/pom.xml ---------------------------------------------------------------------- diff --git a/stack/core/pom.xml b/stack/core/pom.xml index 77ce82e..d30bedb 100644 --- a/stack/core/pom.xml +++ b/stack/core/pom.xml @@ -101,9 +101,14 @@ org.apache.maven.surefire - surefire-junit47 + ${surefire.plugin.artifactName} ${surefire.plugin.version} + + org.codehaus.plexus + plexus-utils + 3.0.21 + http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/metrics/MetricsFactoryImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/metrics/MetricsFactoryImpl.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/metrics/MetricsFactoryImpl.java index 2528070..773828d 100644 --- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/metrics/MetricsFactoryImpl.java +++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/metrics/MetricsFactoryImpl.java @@ -35,7 +35,7 @@ import java.util.concurrent.TimeUnit; @Singleton public class MetricsFactoryImpl implements MetricsFactory { - private final MetricsFig metricsFig; + private MetricRegistry registry; private GraphiteReporter graphiteReporter; private JmxReporter jmxReporter; @@ -44,7 +44,6 @@ public class MetricsFactoryImpl implements MetricsFactory { @Inject public MetricsFactoryImpl(MetricsFig metricsFig) { - this.metricsFig = metricsFig; registry = new MetricRegistry(); String metricsHost = metricsFig.getHost(); if(!metricsHost.equals("false")) { http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/guice/IndexModule.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/guice/IndexModule.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/guice/IndexModule.java index d9a14c9..6fee17e 100644 --- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/guice/IndexModule.java +++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/guice/IndexModule.java @@ -22,6 +22,8 @@ package org.apache.usergrid.persistence.index.guice; import org.apache.usergrid.persistence.index.*; import com.google.inject.AbstractModule; import com.google.inject.assistedinject.FactoryModuleBuilder; + +import org.apache.usergrid.persistence.index.impl.EsEntityIndexFactoryImpl; import org.apache.usergrid.persistence.index.impl.EsEntityIndexImpl; import org.apache.usergrid.persistence.index.impl.EsIndexBufferConsumerImpl; import org.apache.usergrid.persistence.index.impl.EsIndexBufferProducerImpl; @@ -36,9 +38,8 @@ public class IndexModule extends AbstractModule { // install our configuration install(new GuicyFigModule(IndexFig.class)); - install(new FactoryModuleBuilder() - .implement(EntityIndex.class, EsEntityIndexImpl.class) - .build(EntityIndexFactory.class)); + + bind(EntityIndexFactory.class).to( EsEntityIndexFactoryImpl.class ); bind(IndexBufferProducer.class).to(EsIndexBufferProducerImpl.class); bind(IndexBufferConsumer.class).to(EsIndexBufferConsumerImpl.class).asEagerSingleton(); http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexFactoryImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexFactoryImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexFactoryImpl.java new file mode 100644 index 0000000..4bf8b59 --- /dev/null +++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexFactoryImpl.java @@ -0,0 +1,74 @@ +/* + * + * * Licensed to the Apache Software Foundation (ASF) under one or more + * * contributor license agreements. The ASF licenses this file to You + * * under the Apache License, Version 2.0 (the "License"); you may not + * * use this file except in compliance with the License. + * * You may obtain a copy of the License at + * * + * * http://www.apache.org/licenses/LICENSE-2.0 + * * + * * Unless required by applicable law or agreed to in writing, software + * * distributed under the License is distributed on an "AS IS" BASIS, + * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * * See the License for the specific language governing permissions and + * * limitations under the License. For additional information regarding + * * copyright in this work, please see the NOTICE file in the top level + * * directory of this distribution. + * + */ +package org.apache.usergrid.persistence.index.impl; + +import com.google.common.cache.CacheBuilder; +import com.google.common.cache.CacheLoader; +import com.google.common.cache.LoadingCache; +import com.google.inject.Inject; +import com.google.inject.assistedinject.Assisted; +import org.apache.usergrid.persistence.core.scope.ApplicationScope; +import org.apache.usergrid.persistence.index.EntityIndex; +import org.apache.usergrid.persistence.index.EntityIndexFactory; +import org.apache.usergrid.persistence.index.IndexBufferProducer; +import org.apache.usergrid.persistence.index.IndexFig; + +import java.util.concurrent.ExecutionException; + +/** + * Get index from factory, adds caching + */ +public class EsEntityIndexFactoryImpl implements EntityIndexFactory{ + + private final IndexFig config; + private final EsProvider provider; + private final EsIndexCache indexCache; + private final IndexBufferProducer indexBatchBufferProducer; + + private LoadingCache eiCache = + CacheBuilder.newBuilder().maximumSize( 1000 ).build( new CacheLoader() { + public EntityIndex load( ApplicationScope scope ) { + return new EsEntityIndexImpl(scope,config, indexBatchBufferProducer, provider,indexCache); + } + } ); + + @Inject + public EsEntityIndexFactoryImpl( final IndexFig config, final EsProvider provider, final EsIndexCache indexCache, + final IndexBufferProducer indexBatchBufferProducer ){ + this.config = config; + this.provider = provider; + this.indexCache = indexCache; + this.indexBatchBufferProducer = indexBatchBufferProducer; + } + + @Override + public EntityIndex createEntityIndex(final ApplicationScope appScope) { + try{ + return eiCache.get(appScope); + }catch (ExecutionException ee){ + throw new RuntimeException(ee); + } + } + + @Override + public void invalidate() { + eiCache.invalidateAll(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/pom.xml ---------------------------------------------------------------------- diff --git a/stack/pom.xml b/stack/pom.xml index 53755b3..25b2258 100644 --- a/stack/pom.xml +++ b/stack/pom.xml @@ -127,6 +127,7 @@ 3.0.0 0.19.6 + surefire-junit47 2.18.1 1.6.1 @@ -1503,8 +1504,8 @@ ${usergrid.it.forkCount} ${usergrid.it.reuseForks} ${usergrid.it.forkCount} - -Xmx${ug.heapmax} -Xms${ug.heapmin} -javaagent:${settings.localRepository}/com/github/stephenc/jamm/0.2.5/jamm-0.2.5.jar ${ug.argline} - + -Xmx${ug.heapmax} -Xms${ug.heapmin} -javaagent:${settings.localRepository}/com/github/stephenc/jamm/0.2.5/jamm-0.2.5.jar ${ug.argline} + false + + + + + + + + + org.codehaus.plexus + plexus-utils + 3.0.21 http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/rest/pom.xml ---------------------------------------------------------------------- diff --git a/stack/rest/pom.xml b/stack/rest/pom.xml index 3ad58b4..5a856de 100644 --- a/stack/rest/pom.xml +++ b/stack/rest/pom.xml @@ -115,7 +115,7 @@ org.apache.maven.surefire - surefire-junit47 + ${surefire.plugin.artifactName} ${surefire.plugin.version} http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/services/pom.xml ---------------------------------------------------------------------- diff --git a/stack/services/pom.xml b/stack/services/pom.xml index 46b0878..f5e8dd5 100644 --- a/stack/services/pom.xml +++ b/stack/services/pom.xml @@ -108,9 +108,14 @@ org.apache.maven.surefire - surefire-junit47 + ${surefire.plugin.artifactName} ${surefire.plugin.version} + + org.codehaus.plexus + plexus-utils + 3.0.21 + http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2c54a2b6/stack/services/src/test/java/org/apache/usergrid/management/OrganizationIT.java ---------------------------------------------------------------------- diff --git a/stack/services/src/test/java/org/apache/usergrid/management/OrganizationIT.java b/stack/services/src/test/java/org/apache/usergrid/management/OrganizationIT.java index bd96434..5bf0c3d 100644 --- a/stack/services/src/test/java/org/apache/usergrid/management/OrganizationIT.java +++ b/stack/services/src/test/java/org/apache/usergrid/management/OrganizationIT.java @@ -90,7 +90,7 @@ public class OrganizationIT { OrganizationInfo organization2 = setup.getMgmtSvc().getOrganizationForApplication( applicationId ); assertNotNull( organization2 ); - assertEquals( "wrong organization name", orgName, organization2.getName() ); + assertEquals( "wrong organization name", organization.getOrganization().getName(), organization2.getName() ); boolean verified = setup.getMgmtSvc().verifyAdminUserPassword( organization.getOwner().getUuid(), "test" ); assertTrue( verified );