incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/2] git commit: Formatting changes
Date Sat, 19 Oct 2013 20:17:38 GMT
Formatting changes


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/70f2dc52
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/70f2dc52
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/70f2dc52

Branch: refs/heads/master
Commit: 70f2dc52128d08be6aa11e06aaa9772237e94ca1
Parents: b23c03b
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Thu Oct 17 20:01:03 2013 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Sat Oct 19 16:17:23 2013 -0400

----------------------------------------------------------------------
 .../store/refcounter/DirectoryReferenceCounter.java   | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/70f2dc52/blur-store/src/main/java/org/apache/blur/lucene/store/refcounter/DirectoryReferenceCounter.java
----------------------------------------------------------------------
diff --git a/blur-store/src/main/java/org/apache/blur/lucene/store/refcounter/DirectoryReferenceCounter.java
b/blur-store/src/main/java/org/apache/blur/lucene/store/refcounter/DirectoryReferenceCounter.java
index ed4c305..b4e31f1 100644
--- a/blur-store/src/main/java/org/apache/blur/lucene/store/refcounter/DirectoryReferenceCounter.java
+++ b/blur-store/src/main/java/org/apache/blur/lucene/store/refcounter/DirectoryReferenceCounter.java
@@ -37,7 +37,7 @@ public class DirectoryReferenceCounter extends Directory implements DirectoryDec
 
   private final static Log LOG = LogFactory.getLog(DirectoryReferenceCounter.class);
   private final Directory _directory;
-  private final Map<String, AtomicInteger> refCounters = new ConcurrentHashMap<String,
AtomicInteger>();
+  private final Map<String, AtomicInteger> _refCounters = new ConcurrentHashMap<String,
AtomicInteger>();
   private final DirectoryReferenceFileGC _gc;
   private final IndexInputCloser _closer;
 
@@ -48,10 +48,10 @@ public class DirectoryReferenceCounter extends Directory implements DirectoryDec
   }
 
   private IndexInput wrap(String name, IndexInput input) {
-    AtomicInteger counter = refCounters.get(name);
+    AtomicInteger counter = _refCounters.get(name);
     if (counter == null) {
       counter = new AtomicInteger();
-      refCounters.put(name, counter);
+      _refCounters.put(name, counter);
     }
     return new RefIndexInput(input.toString(), input, counter, _closer);
   }
@@ -62,7 +62,7 @@ public class DirectoryReferenceCounter extends Directory implements DirectoryDec
       _directory.deleteFile(name);
       return;
     }
-    AtomicInteger counter = refCounters.get(name);
+    AtomicInteger counter = _refCounters.get(name);
     if (counter != null && counter.get() > 0) {
       addToFileGC(name);
     } else {
@@ -77,12 +77,12 @@ public class DirectoryReferenceCounter extends Directory implements DirectoryDec
       return _directory.createOutput(name, context);
     }
     LOG.debug("Create file [{0}]", name);
-    AtomicInteger counter = refCounters.get(name);
+    AtomicInteger counter = _refCounters.get(name);
     if (counter != null) {
       LOG.error("Unknown error while trying to create ref counter for [{0}] reference exists.",
name);
       throw new IOException("Reference exists [" + name + "]");
     }
-    refCounters.put(name, new AtomicInteger(0));
+    _refCounters.put(name, new AtomicInteger(0));
     return _directory.createOutput(name, context);
   }
 
@@ -277,7 +277,7 @@ public class DirectoryReferenceCounter extends Directory implements DirectoryDec
   private void addToFileGC(String name) {
     if (_gc != null) {
       LOG.debug("Add file [{0}] to be GCed once refs are closed.", name);
-      _gc.add(_directory, name, refCounters);
+      _gc.add(_directory, name, _refCounters);
     }
   }
 


Mime
View raw message