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-1753-1282 Commit: f3d20c3a86243e1f201b102427ca57378c243188 Parents: bb864c6 Author: Alexey Goncharuk <[email protected]> Authored: Tue Nov 3 16:23:58 2015 +0300 Committer: Alexey Goncharuk <[email protected]> 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} */
