Repository: ignite Updated Branches: refs/heads/ignite-comm-balance 26eaaba8b -> 6a4d81965
conn Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/03e54ac2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/03e54ac2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/03e54ac2 Branch: refs/heads/ignite-comm-balance Commit: 03e54ac24ed666fac9cbfd84dfbf6dc3d89a3a28 Parents: 26eaaba Author: sboikov <[email protected]> Authored: Wed Sep 21 10:12:46 2016 +0300 Committer: sboikov <[email protected]> Committed: Wed Sep 21 10:12:46 2016 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/internal/util/nio/GridNioServer.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/03e54ac2/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 b7b02f5..5da557b 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 @@ -1320,10 +1320,6 @@ public class GridNioServer<T> { } } - public interface NioWorker { - - } - /** * Thread performing only read operations from the channel. */ @@ -1448,7 +1444,7 @@ public class GridNioServer<T> { * * @param req Change request. */ - @Override public void offer(GridNioFuture req) { + @Override public void offer(GridNioFuture req) { changeReqs.offer((NioOperationFuture)req); selector.wakeup(); @@ -2115,8 +2111,6 @@ public class GridNioServer<T> { * @throws IgniteCheckedException If failed. */ private void accept() throws IgniteCheckedException { - long lastBalance = U.currentTimeMillis(); - try { while (!closed && selector.isOpen() && !Thread.currentThread().isInterrupted()) { // Wake up every 2 seconds to check if closed.
