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 2016/12/13 08:36:08 UTC
ignite git commit: added partition
Repository: ignite
Updated Branches:
refs/heads/ignite-comm-balance-master e4dad2382 -> 2c144628c
added partition
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2c144628
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2c144628
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2c144628
Branch: refs/heads/ignite-comm-balance-master
Commit: 2c144628c4d29830d7bf92eb7f65a6168f4f82c4
Parents: e4dad23
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Tue Dec 13 11:35:57 2016 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Tue Dec 13 11:35:57 2016 +0300
----------------------------------------------------------------------
.../cache/distributed/near/GridNearSingleGetRequest.java | 5 +++++
.../org/apache/ignite/internal/util/StripedExecutor.java | 10 +++++-----
2 files changed, 10 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2c144628/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearSingleGetRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearSingleGetRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearSingleGetRequest.java
index 7fc2b1e..1e86c10 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearSingleGetRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearSingleGetRequest.java
@@ -187,6 +187,11 @@ public class GridNearSingleGetRequest extends GridCacheMessage implements GridCa
return accessTtl;
}
+ /** {@inheritDoc} */
+ @Override public int partition() {
+ return partId;
+ }
+
/**
* @return Read through flag.
*/
http://git-wip-us.apache.org/repos/asf/ignite/blob/2c144628/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 e9ec74b..a653429 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
@@ -124,11 +124,11 @@ public class StripedExecutor implements ExecutorService {
GridStringBuilder sb = new GridStringBuilder();
- sb.a(">>> Possible starvation in striped pool: ")
- .a(stripe.thread.getName()).a(U.nl())
- .a(stripe.queueToString()).a(U.nl())
- .a("deadlock: ").a(deadlockPresent).a(U.nl())
- .a("completed: ").a(completedCnt).a(U.nl());
+ sb.a(">>> Possible starvation in striped pool.").a(U.nl())
+ .a(" Thread name: ").a(stripe.thread.getName()).a(U.nl())
+ .a(" Queue: ").a(stripe.queueToString()).a(U.nl())
+ .a(" Deadlock: ").a(deadlockPresent).a(U.nl())
+ .a(" Completed: ").a(completedCnt).a(U.nl());
U.printStackTrace(
stripe.thread.getId(),