You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/02/27 20:49:38 UTC
[1/2] incubator-usergrid git commit: 432: modify cores and add before
shiro condition
Repository: incubator-usergrid
Updated Branches:
refs/heads/USERGRID-432 [created] 6273969d1
432: modify cores and add before shiro condition
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/7eb15afa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/7eb15afa
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/7eb15afa
Branch: refs/heads/USERGRID-432
Commit: 7eb15afa65e21a044e500b0e13a4d1d968c3b225
Parents: 80cd97e
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Feb 27 10:59:52 2015 -0700
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Feb 27 10:59:52 2015 -0700
----------------------------------------------------------------------
stack/pom.xml | 18 +++++++++---------
.../usergrid/cassandra/ClearShiroSubject.java | 19 ++++++++-----------
2 files changed, 17 insertions(+), 20 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/7eb15afa/stack/pom.xml
----------------------------------------------------------------------
diff --git a/stack/pom.xml b/stack/pom.xml
index 167ef14..513d3bb 100644
--- a/stack/pom.xml
+++ b/stack/pom.xml
@@ -122,8 +122,8 @@
<!-- only use half the cores on the machine for testing -->
<usergrid.it.parallel>methods</usergrid.it.parallel>
<usergrid.it.reuseForks>true</usergrid.it.reuseForks>
- <usergrid.it.forkCount>1</usergrid.it.forkCount>
- <usergrid.it.threads>2</usergrid.it.threads>
+ <usergrid.it.forkCount>4</usergrid.it.forkCount>
+ <usergrid.it.threads>8</usergrid.it.threads>
<metrics.version>3.0.0</metrics.version>
<rx.version>0.19.6</rx.version>
@@ -1510,13 +1510,13 @@
<!-- TODO, we may need an exclusion. Appears to be a classloader bug
http://stackoverflow.com/questions/27225140/intermittent-noclassdeffounderror-when-running-a-maven-surefire-build-in-jenkins
-->
- <!--<dependencies>-->
- <!--<dependency>-->
- <!--<groupId>org.apache.maven.surefire</groupId>-->
- <!--<artifactId>surefire-junit47</artifactId>-->
- <!--<version>${surefire.plugin.version}</version>-->
- <!--</dependency>-->
- <!--</dependencies>-->
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.maven.surefire</groupId>
+ <artifactId>surefire-junit47</artifactId>
+ <version>${surefire.plugin.version}</version>
+ </dependency>
+ </dependencies>
</plugin>
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/7eb15afa/stack/test-utils/src/main/java/org/apache/usergrid/cassandra/ClearShiroSubject.java
----------------------------------------------------------------------
diff --git a/stack/test-utils/src/main/java/org/apache/usergrid/cassandra/ClearShiroSubject.java b/stack/test-utils/src/main/java/org/apache/usergrid/cassandra/ClearShiroSubject.java
index 50d01c8..4010b04 100644
--- a/stack/test-utils/src/main/java/org/apache/usergrid/cassandra/ClearShiroSubject.java
+++ b/stack/test-utils/src/main/java/org/apache/usergrid/cassandra/ClearShiroSubject.java
@@ -33,20 +33,17 @@ public class ClearShiroSubject extends ExternalResource {
private static final Logger LOG = LoggerFactory.getLogger( ClearShiroSubject.class );
+
+ @Override
+ protected void before() throws Throwable {
+ super.before();
+ clear();
+ }
+
@Override
protected void after() {
super.after();
- Subject subject = SecurityUtils.getSubject();
-
- if ( subject == null ) {
-
- LOG.info( "Shiro Subject was null. No need to clear." );
- return;
- }
-
- new SubjectThreadState( subject ).clear();
-
- LOG.info( "Shiro Subject was NOT null. Subject has been cleared." );
+ clear();
}
public void clear(){
[2/2] incubator-usergrid git commit: 432: working with multithreaded
builds
Posted by sf...@apache.org.
432: working with multithreaded builds
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/6273969d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/6273969d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/6273969d
Branch: refs/heads/USERGRID-432
Commit: 6273969d168a58d59d85f3797c3fdf40529f652d
Parents: 7eb15af
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Feb 27 12:49:22 2015 -0700
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Feb 27 12:49:22 2015 -0700
----------------------------------------------------------------------
.../usergrid/corepersistence/CpEntityManager.java | 7 +++++--
.../corepersistence/CpEntityManagerFactory.java | 15 ++++++++++-----
.../apache/usergrid/corepersistence/CpWalker.java | 6 ++++--
3 files changed, 19 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6273969d/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
index 8f432a2..bc227d8 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
@@ -565,6 +565,9 @@ public class CpEntityManager implements EntityManager {
private Observable deleteAsync( EntityRef entityRef ) throws Exception {
+ if(applicationScope == null || entityRef == null){
+ return Observable.empty();
+ }
CollectionScope collectionScope = getCollectionScopeNameFromEntityType(
applicationScope.getApplication(), entityRef.getType() );
@@ -2750,7 +2753,7 @@ public class CpEntityManager implements EntityManager {
CpWalker walker = new CpWalker( );
walker.walkCollections(
- this, application, collectionName, reverse, new CpVisitor() {
+ this, getApplication(), collectionName, reverse, new CpVisitor() {
@Override
public void visitCollectionEntry( EntityManager em, String collName, Entity entity ) {
@@ -2779,7 +2782,7 @@ public class CpEntityManager implements EntityManager {
CpWalker walker = new CpWalker( );
- walker.walkCollections( this, application, null, false, new CpVisitor() {
+ walker.walkCollections( this, getApplication(), null, false, new CpVisitor() {
@Override
public void visitCollectionEntry( EntityManager em, String collName, Entity entity ) {
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6273969d/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java
index 3c63bd6..a609ea6 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java
@@ -317,11 +317,12 @@ public class CpEntityManagerFactory implements EntityManagerFactory, Application
Query q = Query.fromQL(String.format("select * where applicationUuid = '%s'", applicationId.toString()));
Results results = em.searchCollection( em.getApplicationRef(), "appinfos", q);
Entity appToDelete = results.getEntity();
- em.delete( appToDelete );
-
- // create new Entity in deleted_appinfos collection, with same UUID and properties as deleted appinfo
- em.create( "deleted_appinfo", appToDelete.getProperties() );
+ if(appToDelete != null) {
+ em.delete(appToDelete);
+ // create new Entity in deleted_appinfos collection, with same UUID and properties as deleted appinfo
+ em.create("deleted_appinfo", appToDelete.getProperties());
+ }
em.refreshIndex();
// delete the application's index
@@ -767,7 +768,11 @@ public class CpEntityManagerFactory implements EntityManagerFactory, Application
em.reindex( po );
- logger.info("\n\nRebuilt index for application {} id {}\n", app.getName(), appId );
+ if(app!=null) {
+ logger.info("\n\nRebuilt index for application {} id {}\n", app.getName(), appId);
+ }else{
+ logger.info("\n\nDid not rebuild index for application id {}\n", appId);
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6273969d/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java
index fab7e16..928b210 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpWalker.java
@@ -58,8 +58,10 @@ public class CpWalker {
public void walkCollections(final CpEntityManager em, final EntityRef start,
String collectionName, boolean reverse, final CpVisitor visitor) throws Exception {
- doWalkCollections(
- em, collectionName, reverse, new SimpleId( start.getUuid(), start.getType() ), visitor );
+ if(start != null) {
+ doWalkCollections(
+ em, collectionName, reverse, new SimpleId(start.getUuid(), start.getType()), visitor);
+ }
}