You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2015/11/03 14:24:07 UTC
ignite git commit: IGNITE-950 - Debug.
Repository: ignite
Updated Branches:
refs/heads/ignite-950-new bb864c67f -> f3d20c3a8
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/f3d20c3a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f3d20c3a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f3d20c3a
Branch: refs/heads/ignite-950-new
Commit: f3d20c3a86243e1f201b102427ca57378c243188
Parents: bb864c6
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Tue Nov 3 16:23:58 2015 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Tue Nov 3 16:23:58 2015 +0300
----------------------------------------------------------------------
.../internal/processors/datastreamer/DataStreamProcessor.java | 2 ++
.../ignite/internal/processors/datastreamer/DataStreamerImpl.java | 2 ++
.../ignite/internal/processors/platform/cache/PlatformCache.java | 3 +++
.../processors/platform/datastreamer/PlatformDataStreamer.java | 3 +++
4 files changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f3d20c3a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
index a2aab77..14cb1c8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
@@ -283,6 +283,8 @@ public class DataStreamProcessor<K, V> extends GridProcessorAdapter {
Collection<DataStreamerEntry> col = req.entries();
+ U.debug(log, "Processing data streamer update request [keepBinary=" + req.keepBinary() + ", keys=" + col + ']');
+
DataStreamerUpdateJob job = new DataStreamerUpdateJob(ctx,
log,
req.cacheName(),
http://git-wip-us.apache.org/repos/asf/ignite/blob/f3d20c3a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index 27eff0c..a2a109f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -1336,6 +1336,8 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed
if (topVer == null)
topVer = ctx.cache().context().exchange().readyAffinityVersion();
+ U.debug(log, "Creating data streamer request [keepBinary=" + keepBinary + ']');
+
DataStreamerRequest req = new DataStreamerRequest(
reqId,
topicBytes,
http://git-wip-us.apache.org/repos/asf/ignite/blob/f3d20c3a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
index ecc33c2..d3588ee 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
@@ -44,6 +44,7 @@ import org.apache.ignite.internal.processors.platform.utils.PlatformFutureUtils;
import org.apache.ignite.internal.processors.platform.utils.PlatformUtils;
import org.apache.ignite.internal.util.GridConcurrentFactory;
import org.apache.ignite.internal.util.typedef.C1;
+import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteFuture;
import org.jetbrains.annotations.Nullable;
@@ -719,6 +720,8 @@ public class PlatformCache extends PlatformAbstractTarget {
* @throws org.apache.ignite.IgniteCheckedException In case of error.
*/
public void removeAll() throws IgniteCheckedException {
+ U.debug(log, "Will removeAll on platform cache: " + cache.operationContext());
+
cache.removeAll();
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f3d20c3a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java
index 7f87bcd..9caa913 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/datastreamer/PlatformDataStreamer.java
@@ -31,6 +31,7 @@ import org.apache.ignite.internal.processors.platform.PlatformAbstractTarget;
import org.apache.ignite.internal.processors.platform.PlatformContext;
import org.apache.ignite.internal.processors.platform.utils.PlatformFutureUtils;
import org.apache.ignite.internal.util.lang.GridMapEntry;
+import org.apache.ignite.internal.util.typedef.internal.U;
import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;
import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
@@ -84,6 +85,8 @@ public class PlatformDataStreamer extends PlatformAbstractTarget {
this.cacheName = cacheName;
this.ldr = ldr;
this.keepPortable = keepPortable;
+
+ U.debug(log, "Created platform streamer [keepBinary=" + ldr.keepBinary() + ']');
}
/** {@inheritDoc} */