You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/12/05 14:41:25 UTC
[03/50] [abbrv] ignite git commit: finalizing changes
finalizing changes
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cccbb498
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cccbb498
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cccbb498
Branch: refs/heads/ignite-comm-balance-master
Commit: cccbb4984a36397a40fc5f310681e57349ad5375
Parents: 1d781fb
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Fri Oct 28 21:14:14 2016 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Fri Oct 28 21:14:14 2016 +0300
----------------------------------------------------------------------
.../ignite/internal/managers/communication/GridIoManager.java | 2 +-
.../ignite/internal/managers/communication/GridIoMessage.java | 5 -----
.../java/org/apache/ignite/internal/util/StripedExecutor.java | 7 +++++++
3 files changed, 8 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/cccbb498/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 e560a96..34e74d0 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
@@ -993,7 +993,7 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa
if (STRIPED) {
int part = msg.partition();
- striped.execute(part != -1 ? part : ThreadLocalRandom.current().nextInt(2048), c);
+ striped.execute(part != -1 ? part : ThreadLocalRandom.current().nextInt(striped.stripes()), c);
return;
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/cccbb498/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
index cdfcb60..cd271bd 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
@@ -339,11 +339,6 @@ public class GridIoMessage implements Message {
return -1;
}
- // TODO
- public boolean response() {
- return false;
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(GridIoMessage.class, this);
http://git-wip-us.apache.org/repos/asf/ignite/blob/cccbb498/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
index e6576d4..e129750 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
@@ -62,6 +62,13 @@ public class StripedExecutor {
}
/**
+ * @return Stripes count.
+ */
+ public int stripes() {
+ return cnt;
+ }
+
+ /**
* Execute command.
*
* @param idx Index.