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/08/02 07:41:31 UTC
[08/14] ignite git commit: 3343: cosmetics.
3343: cosmetics.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/af2e9dcd
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/af2e9dcd
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/af2e9dcd
Branch: refs/heads/ignite-3343
Commit: af2e9dcdbbce5f3c18a9678a9be61cb04207270d
Parents: ace2e71
Author: iveselovskiy <iv...@gridgain.com>
Authored: Wed Jul 27 21:29:15 2016 +0300
Committer: iveselovskiy <iv...@gridgain.com>
Committed: Wed Jul 27 21:29:15 2016 +0300
----------------------------------------------------------------------
.../internal/processors/igfs/IgfsImpl.java | 27 +++++++++++++-------
1 file changed, 18 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/af2e9dcd/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
index 0c7427c..a170151 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
@@ -874,7 +874,8 @@ public final class IgfsImpl implements IgfsEx {
if (info != null) {
if (info.isFile())
// If this is a file, return its description.
- return Collections.<IgfsFile>singleton(new IgfsFileImpl(path, info, data.groupBlockSize()));
+ return Collections.<IgfsFile>singleton(new IgfsFileImpl(path, info,
+ data.groupBlockSize()));
// Perform the listing.
for (Map.Entry<String, IgfsListingEntry> e : info.listing().entrySet()) {
@@ -932,8 +933,8 @@ public final class IgfsImpl implements IgfsEx {
IgfsSecondaryInputStreamDescriptor desc = meta.openDual(secondaryFs, path, bufSize0);
- IgfsEventAwareInputStream os = new IgfsEventAwareInputStream(igfsCtx, path, desc.info(), cfg
- .getPrefetchBlocks(), seqReadsBeforePrefetch, desc.reader(), metrics);
+ IgfsEventAwareInputStream os = new IgfsEventAwareInputStream(igfsCtx, path, desc.info(),
+ cfg.getPrefetchBlocks(), seqReadsBeforePrefetch, desc.reader(), metrics);
IgfsUtils.sendEvents(igfsCtx.kernalContext(), path, EVT_IGFS_FILE_OPENED_READ);
@@ -949,8 +950,8 @@ public final class IgfsImpl implements IgfsEx {
throw new IgfsPathIsDirectoryException("Failed to open file (not a file): " + path);
// Input stream to read data from grid cache with separate blocks.
- IgfsEventAwareInputStream os = new IgfsEventAwareInputStream(igfsCtx, path, info, cfg
- .getPrefetchBlocks(), seqReadsBeforePrefetch, null, metrics);
+ IgfsEventAwareInputStream os = new IgfsEventAwareInputStream(igfsCtx, path, info,
+ cfg.getPrefetchBlocks(), seqReadsBeforePrefetch, null, metrics);
IgfsUtils.sendEvents(igfsCtx.kernalContext(), path, EVT_IGFS_FILE_OPENED_READ);
@@ -1024,16 +1025,24 @@ public final class IgfsImpl implements IgfsEx {
IgfsSecondaryFileSystemCreateContext secondaryCtx = null;
if (mode != PRIMARY)
- secondaryCtx = new IgfsSecondaryFileSystemCreateContext(secondaryFs, path, overwrite,
- simpleCreate, fileProps, (short)replication, groupBlockSize(), bufSize);
+ secondaryCtx = new IgfsSecondaryFileSystemCreateContext(secondaryFs, path, overwrite, simpleCreate,
+ fileProps, (short)replication, groupBlockSize(), bufSize);
// Await for async ops completion if in DUAL mode.
if (mode != PRIMARY)
await(path);
// Perform create.
- IgfsCreateResult res = meta.create(path, dirProps, overwrite, cfg.getBlockSize(), affKey,
- evictExclude(path, mode == PRIMARY), fileProps, secondaryCtx);
+ IgfsCreateResult res = meta.create(
+ path,
+ dirProps,
+ overwrite,
+ cfg.getBlockSize(),
+ affKey,
+ evictExclude(path, mode == PRIMARY),
+ fileProps,
+ secondaryCtx
+ );
assert res != null;