You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by yz...@apache.org on 2017/01/09 17:03:12 UTC
[40/40] ignite git commit: imports
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 <yz...@gridgain.com>
Authored: Mon Jan 9 20:02:22 2017 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
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;