You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2014/09/24 02:53:20 UTC
git commit: Added new test
Repository: incubator-usergrid
Updated Branches:
refs/heads/throughputtest c667c18e3 -> 4d9b64b2a
Added new test
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/4d9b64b2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/4d9b64b2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/4d9b64b2
Branch: refs/heads/throughputtest
Commit: 4d9b64b2a187f9fde2a99b96101251fdc9cd2a77
Parents: c667c18
Author: Todd Nine <to...@apache.org>
Authored: Tue Sep 23 18:53:11 2014 -0600
Committer: Todd Nine <to...@apache.org>
Committed: Tue Sep 23 18:53:11 2014 -0600
----------------------------------------------------------------------
.../persistence/PerformanceEntityReadTest.java | 6 +-
.../PerformanceEntityUpdateTest.java | 122 +++++++++++++++++++
2 files changed, 125 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/4d9b64b2/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityReadTest.java
----------------------------------------------------------------------
diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityReadTest.java b/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityReadTest.java
index 41a5dea..c951176 100644
--- a/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityReadTest.java
+++ b/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityReadTest.java
@@ -17,9 +17,11 @@
package org.apache.usergrid.persistence;
+import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.UUID;
import java.util.concurrent.TimeUnit;
import org.junit.After;
@@ -32,13 +34,11 @@ import org.slf4j.LoggerFactory;
import org.apache.usergrid.AbstractCoreIT;
import org.apache.usergrid.Application;
import org.apache.usergrid.CoreApplication;
+import org.apache.usergrid.cassandra.Concurrent;
import com.codahale.metrics.Meter;
import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.Slf4jReporter;
-import java.util.ArrayList;
-import java.util.UUID;
-import org.apache.usergrid.cassandra.Concurrent;
//@RunWith(JukitoRunner.class)
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/4d9b64b2/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityUpdateTest.java
----------------------------------------------------------------------
diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityUpdateTest.java b/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityUpdateTest.java
new file mode 100644
index 0000000..33c0905
--- /dev/null
+++ b/stack/core/src/test/java/org/apache/usergrid/persistence/PerformanceEntityUpdateTest.java
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * 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.
+ */
+package org.apache.usergrid.persistence;
+
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import org.apache.usergrid.AbstractCoreIT;
+import org.apache.usergrid.Application;
+import org.apache.usergrid.CoreApplication;
+import org.apache.usergrid.cassandra.Concurrent;
+
+import com.codahale.metrics.Meter;
+import com.codahale.metrics.MetricRegistry;
+import com.codahale.metrics.Slf4jReporter;
+
+import static org.junit.Assert.assertEquals;
+
+
+//@RunWith(JukitoRunner.class)
+//@UseModules({ GuiceModule.class })
+@Concurrent()
+public class PerformanceEntityUpdateTest extends AbstractCoreIT {
+ private static final Logger LOG = LoggerFactory.getLogger( PerformanceEntityUpdateTest.class );
+
+
+ private static final MetricRegistry registry = new MetricRegistry();
+
+
+
+ private static final long RUNTIME = TimeUnit.MINUTES.toMillis( 2 );
+
+
+ @Rule
+ public Application app = new CoreApplication( setup );
+
+ private Slf4jReporter reporter;
+
+
+ @Before
+ public void startReporting() {
+
+ reporter = Slf4jReporter.forRegistry( registry ).outputTo( LOG ).convertRatesTo( TimeUnit.SECONDS )
+ .convertDurationsTo( TimeUnit.MILLISECONDS ).build();
+
+ reporter.start( 10, TimeUnit.SECONDS );
+ }
+
+
+ @After
+ public void printReport() {
+ reporter.report();
+ reporter.stop();
+ }
+
+
+
+ @Test
+ public void fastUpdate() throws Exception {
+
+
+ final EntityManager em = app.getEntityManager();
+
+ final long stopTime = System.currentTimeMillis() + RUNTIME;
+
+ final Map<String, Object> addToCollectionEntity = new HashMap<>();
+
+ addToCollectionEntity.put( "key1", 1000 );
+ addToCollectionEntity.put( "key2", 2000 );
+ addToCollectionEntity.put( "key3", "Some value" );
+
+ int i = 0;
+
+ addToCollectionEntity.put( "key", i );
+
+ final Entity created = em.create( "testTypes", addToCollectionEntity );
+
+
+ final String meterName = this.getClass().getSimpleName() + ".fastUpdate";
+ final Meter meter = registry.meter( meterName );
+
+ while ( System.currentTimeMillis() < stopTime ) {
+
+ created.setProperty( "key", i );
+
+ em.update( created );
+
+ final Entity returned = em.get( new SimpleEntityRef( "testTypes", created.getUuid() ));
+
+ assertEquals(i, (int)returned.getProperty( "key" ));
+
+ meter.mark();
+ i++;
+ }
+
+
+ registry.remove( meterName );
+ }
+}