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 <[email protected]> Authored: Tue Dec 13 11:35:57 2016 +0300 Committer: Yakov Zhdanov <[email protected]> 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(),
