Repository: ignite Updated Branches: refs/heads/ignite-1.4.2-slow-server-debug [created] 38af93fae
added debug for benchmark investigation Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/38af93fa Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/38af93fa Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/38af93fa Branch: refs/heads/ignite-1.4.2-slow-server-debug Commit: 38af93fae752fff39714ea02c83bc18df796b2ba Parents: 4f95be2 Author: Yakov Zhdanov <[email protected]> Authored: Thu Oct 8 16:57:31 2015 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Thu Oct 8 16:57:31 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtTxPrepareFuture.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/38af93fa/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java index 81cc272..8080db6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java @@ -808,6 +808,18 @@ public final class GridDhtTxPrepareFuture extends GridCompoundFuture<IgniteInter this.writes = writes; this.txNodes = txNodes; + // TODO Remove (for debug only) + if (writes != null && writes.size() == 1) { + U.debug( + log, + "\n>>>\n>>> TX nodes [txNodes=" + txNodes + ", txFut=" + this + ']'); + + for (IgniteTxEntry entry : writes) { + U.debug(log, "\tEntry: " + entry); + U.debug(log, "\tPartitions: " + entry.context().topology().partitionMap(false).toFullString()); + } + } + if (!F.isEmpty(writes)) { Map<Integer, Collection<KeyCacheObject>> forceKeys = null;
