svn commit: r1539552 - /jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/mongomk/BlobThroughPutTest.java

[ch...@apache.org]

Author: chetanm
Date: Thu Nov  7 08:23:58 2013
New Revision: 1539552

URL: http://svn.apache.org/r1539552
Log:
OAK-1153 - Write test to measure throughput on Mongo with multiple reader and writer

Minor formatting change

Modified:
    jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/mongomk/BlobThroughPutTest.java

Modified: jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/mongomk/BlobThroughPutTest.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/mongomk/BlobThroughPutTest.java?rev=1539552&r1=1539551&r2=1539552&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/mongomk/BlobThroughPutTest.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/mongomk/BlobThroughPutTest.java Thu Nov  7 08:23:58 2013
@@ -81,7 +81,7 @@ public class BlobThroughPutTest {
         for (int i = 0; i < NO_OF_NODES; i++) {
             DBObject obj = new BasicDBObject("_id", i)
                     .append("foo", "bar1" + i);
-            nodes.insert(obj,WriteConcern.SAFE);
+            nodes.insert(obj, WriteConcern.SAFE);
         }
     }
 
@@ -116,7 +116,7 @@ public class BlobThroughPutTest {
                     totalWrites,
                     execTime,
                     readThroughPut(),
-                    humanReadableByteCount((long)writeThroughPut(),true));
+                    humanReadableByteCount((long) writeThroughPut(), true));
         }
     }
 
@@ -167,7 +167,7 @@ public class BlobThroughPutTest {
             }
 
             for (int i = 0; i < noOfWriters; i++) {
-                writers.add(new Writer(i,stopLatch));
+                writers.add(new Writer(i, stopLatch));
             }
 
             runnables.addAll(readers);
@@ -218,7 +218,7 @@ public class BlobThroughPutTest {
             return r;
         }
 
-        private void waitForStart(){
+        private void waitForStart() {
             try {
                 startLatch.await();
             } catch (InterruptedException e) {
@@ -251,7 +251,7 @@ public class BlobThroughPutTest {
             final int id;
             final CountDownLatch stopLatch;
 
-            private Writer(int id,CountDownLatch stopLatch) {
+            private Writer(int id, CountDownLatch stopLatch) {
                 this.id = id;
                 this.stopLatch = stopLatch;
             }