You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by me...@apache.org on 2012/12/03 11:49:53 UTC

svn commit: r1416439 - in /jackrabbit/oak/trunk/oak-mongomk/src: main/java/org/apache/jackrabbit/mongomk/impl/action/FetchCommitsAction.java test/java/org/apache/jackrabbit/mongomk/impl/command/ConcurrentWriteMultipleMkMongoTest.java

Author: meteatamel
Date: Mon Dec  3 10:49:53 2012
New Revision: 1416439

URL: http://svn.apache.org/viewvc?rev=1416439&view=rev
Log:
Extended a test and made sure cursor is closed in FetchCommitsAction

Modified:
    jackrabbit/oak/trunk/oak-mongomk/src/main/java/org/apache/jackrabbit/mongomk/impl/action/FetchCommitsAction.java
    jackrabbit/oak/trunk/oak-mongomk/src/test/java/org/apache/jackrabbit/mongomk/impl/command/ConcurrentWriteMultipleMkMongoTest.java

Modified: jackrabbit/oak/trunk/oak-mongomk/src/main/java/org/apache/jackrabbit/mongomk/impl/action/FetchCommitsAction.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-mongomk/src/main/java/org/apache/jackrabbit/mongomk/impl/action/FetchCommitsAction.java?rev=1416439&r1=1416438&r2=1416439&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-mongomk/src/main/java/org/apache/jackrabbit/mongomk/impl/action/FetchCommitsAction.java (original)
+++ jackrabbit/oak/trunk/oak-mongomk/src/main/java/org/apache/jackrabbit/mongomk/impl/action/FetchCommitsAction.java Mon Dec  3 10:49:53 2012
@@ -138,6 +138,7 @@ public class FetchCommitsAction extends 
             MongoCommit commitMongo = (MongoCommit) dbCursor.next();
             commits.put(commitMongo.getRevisionId(), commitMongo);
         }
+        dbCursor.close();
 
         List<MongoCommit> validCommits = new LinkedList<MongoCommit>();
         if (commits.isEmpty()) {

Modified: jackrabbit/oak/trunk/oak-mongomk/src/test/java/org/apache/jackrabbit/mongomk/impl/command/ConcurrentWriteMultipleMkMongoTest.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-mongomk/src/test/java/org/apache/jackrabbit/mongomk/impl/command/ConcurrentWriteMultipleMkMongoTest.java?rev=1416439&r1=1416438&r2=1416439&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-mongomk/src/test/java/org/apache/jackrabbit/mongomk/impl/command/ConcurrentWriteMultipleMkMongoTest.java (original)
+++ jackrabbit/oak/trunk/oak-mongomk/src/test/java/org/apache/jackrabbit/mongomk/impl/command/ConcurrentWriteMultipleMkMongoTest.java Mon Dec  3 10:49:53 2012
@@ -20,14 +20,14 @@ import com.mongodb.DB;
 public class ConcurrentWriteMultipleMkMongoTest extends BaseMongoMicroKernelTest {
 
     @Test
-    public void testHundredNodes() throws Exception {
-        doTest(100);
+    public void testSmall() throws Exception {
+        doTest(1000);
     }
 
     @Test
     @Ignore // Ignored only because it takes a while to complete.
-    public void testThousandNodes() throws Exception {
-        doTest(1000);
+    public void testLarge() throws Exception {
+        doTest(10000);
     }
 
     private void doTest(int numberOfNodes) throws Exception {