You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/06/06 13:07:00 UTC
[13/16] ignite git commit: IGNITE-3256: IGFS: Removed "exists" check
during input stream close.
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-3258
Commit: 1308b122f84af3c98656ac11d8bed606c6b4ecb5
Parents: e409b67
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Mon Jun 6 15:40:59 2016 +0300
Committer: vozerov-gridgain <vo...@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 {