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/07 07:56:16 UTC
[13/14] ignite git commit: Re-arranged fields.
Re-arranged fields.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cd92c9ec
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cd92c9ec
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cd92c9ec
Branch: refs/heads/ignite-3264
Commit: cd92c9ecaf2b2c9e1e7b9e2e7ed7c5aadf9be3d5
Parents: 93f8eca
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Tue Jun 7 10:01:21 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Tue Jun 7 10:01:21 2016 +0300
----------------------------------------------------------------------
.../processors/igfs/IgfsOutputStreamImpl.java | 42 ++++++++++----------
1 file changed, 21 insertions(+), 21 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/cd92c9ec/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
index f51e9b5..b90e34d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
@@ -50,12 +50,33 @@ class IgfsOutputStreamImpl extends IgfsOutputStream {
/** Maximum number of blocks in buffer. */
private static final int MAX_BLOCKS_CNT = 16;
+ /** IGFS context. */
+ private final IgfsContext igfsCtx;
+
/** Path to file. */
private final IgfsPath path;
/** Buffer size. */
private final int bufSize;
+ /** IGFS mode. */
+ private final IgfsMode mode;
+
+ /** File worker batch. */
+ private final IgfsFileWorkerBatch batch;
+
+ /** Write completion future. */
+ private final IgniteInternalFuture<Boolean> writeCompletionFut;
+
+ /** Ensures that onClose)_ routine is called no more than once. */
+ private final AtomicBoolean onCloseGuard = new AtomicBoolean();
+
+ /** Close guard. */
+ private final AtomicBoolean closeGuard = new AtomicBoolean(false);
+
+ /** Mutex for synchronization. */
+ private final Object mux = new Object();
+
/** Flag for this stream open/closed state. */
private boolean closed;
@@ -69,9 +90,6 @@ class IgfsOutputStreamImpl extends IgfsOutputStream {
/** Time consumed by write operations. */
private long time;
- /** IGFS context. */
- private IgfsContext igfsCtx;
-
/** File descriptor. */
@SuppressWarnings("FieldAccessedSynchronizedAndUnsynchronized")
private IgfsEntryInfo fileInfo;
@@ -86,27 +104,9 @@ class IgfsOutputStreamImpl extends IgfsOutputStream {
/** Data length in remainder. */
private int remainderDataLen;
- /** Write completion future. */
- private final IgniteInternalFuture<Boolean> writeCompletionFut;
-
- /** IGFS mode. */
- private final IgfsMode mode;
-
- /** File worker batch. */
- private final IgfsFileWorkerBatch batch;
-
- /** Ensures that onClose)_ routine is called no more than once. */
- private final AtomicBoolean onCloseGuard = new AtomicBoolean();
-
/** Affinity written by this output stream. */
private IgfsFileAffinityRange streamRange;
- /** Close guard. */
- private final AtomicBoolean closeGuard = new AtomicBoolean(false);
-
- /** Mutex for synchronization. */
- private final Object mux = new Object();
-
/**
* Constructs file output stream.
*