[46/49] ignite git commit: ignite-comm-opts1

[sb...@apache.org]

ignite-comm-opts1


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

Branch: refs/heads/ignite-comm-opts1
Commit: 32dd9ec87dfcf48f4796419d94fc7e762f910623
Parents: deb4979
Author: sboikov <sb...@gridgain.com>
Authored: Mon Sep 12 10:43:52 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Mon Sep 12 10:43:52 2016 +0300

----------------------------------------------------------------------
 .../internal/util/nio/GridNioRecoveryDescriptor.java      |  2 +-
 .../apache/ignite/internal/util/nio/GridNioServer.java    | 10 ++++------
 2 files changed, 5 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/32dd9ec8/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
index bf8e26a..29903d4 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioRecoveryDescriptor.java
@@ -31,7 +31,7 @@ import org.jetbrains.annotations.Nullable;
 /**
  * Recovery information for single node.
  */
-@Deprecated // To be splitted into in/out parts when do need maintain backward compatibility.
+@Deprecated // To be splitted into separate classes for in/out data when do not need maintain backward compatibility.
 public class GridNioRecoveryDescriptor {
     /** Number of acknowledged messages. */
     private long acked;

http://git-wip-us.apache.org/repos/asf/ignite/blob/32dd9ec8/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
index 450c2a2..e6b6767 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
@@ -152,11 +152,11 @@ public class GridNioServer<T> {
     /** Flag indicating if this server should use direct buffers. */
     private final boolean directBuf;
 
-    /** Index to select which thread will serve next socket channel. Using round-robin balancing. */
+    /** Index to select which thread will serve next in socket channel. Using round-robin balancing. */
     @GridToStringExclude
     private final AtomicInteger readBalanceIdx = new AtomicInteger();
 
-    // TODO
+    /** Index to select which thread will serve next out socket channel. Using round-robin balancing. */
     @GridToStringExclude
     private final AtomicInteger writeBalanceIdx = new AtomicInteger(1);
 
@@ -700,10 +700,8 @@ public class GridNioServer<T> {
      * @param req Request to balance.
      */
     private synchronized void offerBalanced(NioOperationFuture req) {
-        assert req.operation() == NioOperation.REGISTER;
-        assert req.socketChannel() != null;
-
-        //U.debug("Req registration: " + req);
+        assert req.operation() == NioOperation.REGISTER : req;
+        assert req.socketChannel() != null : req;
 
         int balanceIdx = req.accepted() ? readBalanceIdx.getAndAdd(2) : writeBalanceIdx.getAndAdd(2);