imports
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1484faa4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1484faa4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1484faa4 Branch: refs/heads/ignite-comm-balance-master Commit: 1484faa4138c950bb51701caab2397463a1ca64f Parents: 690527f Author: Yakov Zhdanov <[email protected]> Authored: Mon Jan 9 20:02:22 2017 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Mon Jan 9 20:02:22 2017 +0300 ---------------------------------------------------------------------- .../internal/managers/communication/GridIoManager.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/1484faa4/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 9b50051..44221b1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -35,8 +35,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicReference; -import java.util.concurrent.atomic.AtomicLong; -import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; @@ -63,9 +61,6 @@ import org.apache.ignite.internal.util.GridBoundedConcurrentLinkedHashSet; import org.apache.ignite.internal.util.StripedCompositeReadWriteLock; import org.apache.ignite.internal.util.future.GridFinishedFuture; import org.apache.ignite.internal.util.future.GridFutureAdapter; -import org.apache.ignite.internal.util.GridSpinReadWriteLock; -import org.apache.ignite.internal.util.future.GridFinishedFuture; -import org.apache.ignite.internal.util.future.GridFutureAdapter; import org.apache.ignite.internal.util.lang.GridTuple3; import org.apache.ignite.internal.util.tostring.GridToStringInclude; import org.apache.ignite.internal.util.typedef.F; @@ -809,7 +804,8 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa if (ctx.config().getStripedPoolSize() > 0 && plc == GridIoPolicy.SYSTEM_POOL && - msg.partition() != Integer.MIN_VALUE) { + msg.partition() != Integer.MIN_VALUE + ) { ctx.getStripedExecutorService().execute(msg.partition(), c); return;
