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/8f48a0f3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/8f48a0f3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/8f48a0f3 Branch: refs/heads/apache-blur-0.2 Commit: 8f48a0f30f149e641deea8a48fa565cdf420f564 Parents: a0a8d14 Author: Aaron McCurry <[email protected]> Authored: Thu Oct 17 20:01:03 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Thu Oct 17 20:01:03 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/8f48a0f3/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); } }
