You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/07/08 16:23:26 UTC
[1/2] incubator-ignite git commit: GG-10507 all works
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-gg-10507 [created] da1249f57
GG-10507 all works
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/775fe24f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/775fe24f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/775fe24f
Branch: refs/heads/ignite-gg-10507
Commit: 775fe24fb8a53d6e2cbeb96fd67382fb55da4208
Parents: 6d6ec77
Author: Pavel Tupitsyn <pt...@gridgain.com>
Authored: Wed Jul 8 17:12:28 2015 +0300
Committer: Pavel Tupitsyn <pt...@gridgain.com>
Committed: Wed Jul 8 17:12:28 2015 +0300
----------------------------------------------------------------------
.../internal/processors/datastreamer/DataStreamProcessor.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/775fe24f/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 9e53bb5..81f4776 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
@@ -255,6 +255,10 @@ public class DataStreamProcessor<K, V> extends GridProcessorAdapter {
try {
updater = marsh.unmarshal(req.updaterBytes(), clsLdr);
+
+ // TODO: think. Lifecycle iface?
+ if (updater != null)
+ ctx.resource().injectGeneric(updater);
}
catch (IgniteCheckedException e) {
U.error(log, "Failed to unmarshal message [nodeId=" + nodeId + ", req=" + req + ']', e);
[2/2] incubator-ignite git commit: GG-10507 wip
Posted by vo...@apache.org.
GG-10507 wip
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/da1249f5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/da1249f5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/da1249f5
Branch: refs/heads/ignite-gg-10507
Commit: da1249f577ddf26ac83fb3d862c4fdf0ab1d0877
Parents: 775fe24
Author: Pavel Tupitsyn <pt...@gridgain.com>
Authored: Wed Jul 8 17:16:08 2015 +0300
Committer: Pavel Tupitsyn <pt...@gridgain.com>
Committed: Wed Jul 8 17:16:08 2015 +0300
----------------------------------------------------------------------
.../internal/processors/datastreamer/DataStreamProcessor.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/da1249f5/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 81f4776..54478f8 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
@@ -256,7 +256,6 @@ public class DataStreamProcessor<K, V> extends GridProcessorAdapter {
try {
updater = marsh.unmarshal(req.updaterBytes(), clsLdr);
- // TODO: think. Lifecycle iface?
if (updater != null)
ctx.resource().injectGeneric(updater);
}