svn commit: r1577138 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java

[thomasm]

Author: thomasm
Date: Thu Mar 13 12:43:13 2014
New Revision: 1577138

URL: http://svn.apache.org/r1577138
Log:
OAK-98 Source code formatting, code conventions, Javadocs

Modified:
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java?rev=1577138&r1=1577137&r2=1577138&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoDocumentStore.java
 Thu Mar 13 12:43:13 2014
@@ -42,7 +42,6 @@ import org.apache.jackrabbit.oak.cache.C
 import org.apache.jackrabbit.oak.plugins.document.CachedNodeDocument;
 import org.apache.jackrabbit.oak.plugins.document.Collection;
 import org.apache.jackrabbit.oak.plugins.document.Document;
-import org.apache.jackrabbit.oak.plugins.document.DocumentStore;
 import org.apache.jackrabbit.oak.plugins.document.DocumentMK;
 import org.apache.jackrabbit.oak.plugins.document.NodeDocument;
 import org.apache.jackrabbit.oak.plugins.document.Revision;
@@ -127,9 +126,9 @@ public class MongoDocumentStore implemen
         nodes.ensureIndex(index, options);
 
         // TODO expire entries if the parent was changed
-        if(builder.useOffHeapCache()){
+        if (builder.useOffHeapCache()) {
             nodesCache = createOffHeapCache(builder);
-        }else{
+        } else {
             nodesCache = builder.buildCache(builder.getDocumentCacheSize());
         }
 
@@ -137,7 +136,8 @@ public class MongoDocumentStore implemen
                 builder.getDocumentCacheSize());
     }
 
-    private Cache<CacheValue, NodeDocument> 
createOffHeapCache(DocumentMK.Builder builder){
+    private Cache<CacheValue, NodeDocument> createOffHeapCache(
+            DocumentMK.Builder builder) {
         ForwardingListener<CacheValue, NodeDocument> listener = 
ForwardingListener.newInstance();
 
         Cache<CacheValue, NodeDocument> primaryCache = 
CacheBuilder.newBuilder()
@@ -622,12 +622,12 @@ public class MongoDocumentStore implemen
         }
         nodes.getDB().getMongo().close();
 
-        if(nodesCache instanceof Closeable){
+        if (nodesCache instanceof Closeable) {
             try {
-                ((Closeable)nodesCache).close();
+                ((Closeable) nodesCache).close();
             } catch (IOException e) {
 
-                LOG.warn("Error occurred while closing Off Heap Cache",e);
+                LOG.warn("Error occurred while closing Off Heap Cache", e);
             }
         }
     }
@@ -638,16 +638,16 @@ public class MongoDocumentStore implemen
     }
 
     Iterable<? extends Map.Entry<CacheValue, ? extends CachedNodeDocument>> 
getCacheEntries() {
-        if(nodesCache instanceof OffHeapCache){
+        if (nodesCache instanceof OffHeapCache) {
             return Iterables.concat(nodesCache.asMap().entrySet(),
-                    ((OffHeapCache)nodesCache).offHeapEntriesMap().entrySet());
+                    ((OffHeapCache) 
nodesCache).offHeapEntriesMap().entrySet());
         }
         return nodesCache.asMap().entrySet();
     }
 
-    CachedNodeDocument getCachedNodeDoc(String id){
-        if(nodesCache instanceof OffHeapCache){
-            return  ((OffHeapCache) nodesCache).getCachedDocument(id);
+    CachedNodeDocument getCachedNodeDoc(String id) {
+        if (nodesCache instanceof OffHeapCache) {
+            return ((OffHeapCache) nodesCache).getCachedDocument(id);
         }
 
         return nodesCache.getIfPresent(new StringValue(id));