You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/11/05 04:28:32 UTC
[40/66] [abbrv] ignite git commit: IGNITE-950 - Debug.
IGNITE-950 - Debug.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ab32d0af
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ab32d0af
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ab32d0af
Branch: refs/heads/ignite-1753-1282
Commit: ab32d0af71ae04a085e734263321f5511f35a7a2
Parents: a101bdf
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Tue Nov 3 17:48:37 2015 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Tue Nov 3 17:48:37 2015 +0300
----------------------------------------------------------------------
.../cache/distributed/GridDistributedCacheAdapter.java | 4 ++--
.../cache/distributed/GridDistributedTxRemoteAdapter.java | 2 ++
.../processors/cache/transactions/IgniteTxLocalAdapter.java | 3 +++
3 files changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/ab32d0af/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
index 77035df..3eb60a3 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
@@ -370,8 +370,6 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter
if (cache == null)
return true;
- U.debug(">>>> Running global remove all job: " + cache.name());
-
final GridCacheContext<K, V> ctx = cache.context();
ctx.gate().enter();
@@ -397,6 +395,8 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter
dataLdr.skipStore(skipStore);
dataLdr.keepBinary(keepBinary);
+ U.debug("Will use streamer [skipStore=" + skipStore + ", keepBinary=" + keepBinary + ']');
+
dataLdr.receiver(DataStreamerCacheUpdaters.<KeyCacheObject, Object>batched());
for (int part : ctx.affinity().primaryPartitions(ctx.localNodeId(), topVer)) {
http://git-wip-us.apache.org/repos/asf/ignite/blob/ab32d0af/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java
index 3aa7e1c..b678679 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java
@@ -505,6 +505,8 @@ public class GridDistributedTxRemoteAdapter extends IgniteTxAdapter
for (IgniteTxEntry txEntry : (near() ? allEntries() : writeEntries())) {
GridCacheContext cacheCtx = txEntry.context();
+ U.debug(log, "Will write transactional entry: " + txEntry);
+
boolean replicate = cacheCtx.isDrEnabled();
try {
http://git-wip-us.apache.org/repos/asf/ignite/blob/ab32d0af/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
index 214ba45..4c53d88 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
@@ -2076,6 +2076,9 @@ public abstract class IgniteTxLocalAdapter extends IgniteTxAdapter
return new GridFinishedFuture<>(e);
}
+ if (!keepBinary)
+ U.dumpStack("Writing to cache without keepBinary: " + keys);
+
Set<KeyCacheObject> skipped = null;
boolean rmv = lookup == null && invokeMap == null;