accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ctubb...@apache.org
Subject [25/45] accumulo git commit: ACCUMULO-4391 removed extra closed check
Date Fri, 09 Sep 2016 23:37:44 GMT
ACCUMULO-4391 removed extra closed check


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/3b694418
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/3b694418
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/3b694418

Branch: refs/heads/1.7
Commit: 3b6944180b4df9d0e56c2296d967b0ec880bd4bd
Parents: 5b08b17
Author: Ivan Bella <ivan@bella.name>
Authored: Thu Sep 8 21:36:50 2016 -0400
Committer: Ivan Bella <ivan@bella.name>
Committed: Thu Sep 8 21:36:50 2016 -0400

----------------------------------------------------------------------
 .../accumulo/core/file/rfile/bcfile/BCFile.java | 24 +++++++++-----------
 1 file changed, 11 insertions(+), 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/3b694418/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/BCFile.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/BCFile.java b/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/BCFile.java
index 60376d5..7fdfc96 100644
--- a/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/BCFile.java
+++ b/core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/BCFile.java
@@ -674,19 +674,17 @@ public final class BCFile {
       }
 
       public void finish() throws IOException {
-        if (!closed) {
-          synchronized (in) {
-            if (!closed) {
-              try {
-                in.close();
-              } finally {
-                closed = true;
-                if (decompressor != null) {
-                  try {
-                    compressAlgo.returnDecompressor(decompressor);
-                  } finally {
-                    decompressor = null;
-                  }
+        synchronized (in) {
+          if (!closed) {
+            try {
+              in.close();
+            } finally {
+              closed = true;
+              if (decompressor != null) {
+                try {
+                  compressAlgo.returnDecompressor(decompressor);
+                } finally {
+                  decompressor = null;
                 }
               }
             }


Mime
View raw message