ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [13/24] ignite git commit: IGNITE-3256: IGFS: Removed "exists" check during input stream close.
Date Fri, 10 Jun 2016 06:10:35 GMT
IGNITE-3256: IGFS: Removed "exists" check during input stream close.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1308b122
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1308b122
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1308b122

Branch: refs/heads/ignite-3038
Commit: 1308b122f84af3c98656ac11d8bed606c6b4ecb5
Parents: e409b67
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Mon Jun 6 15:40:59 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Mon Jun 6 15:40:59 2016 +0300

----------------------------------------------------------------------
 .../ignite/internal/processors/igfs/IgfsInputStreamImpl.java   | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1308b122/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java
index de7071a..ca2f9f7 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsInputStreamImpl.java
@@ -317,13 +317,9 @@ public class IgfsInputStreamImpl extends IgfsInputStreamAdapter {
                         pendingFutsLock.unlock();
                     }
                 }
-
-                // Safety to ensure no orphaned data blocks exist in case file was concurrently
deleted.
-                if (!meta.exists(fileInfo.id()))
-                    data.delete(fileInfo);
             }
         }
-        catch (IgniteCheckedException e) {
+        catch (Exception e) {
             throw new IOException("File to close the file: " + path, e);
         }
         finally {


Mime
View raw message