You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/29 14:46:39 UTC
[32/50] incubator-ignite git commit: IGNITE-709 Fix NPE
IGNITE-709 Fix NPE
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d59a712a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d59a712a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d59a712a
Branch: refs/heads/ignite-929
Commit: d59a712ad75c306ac43f37a9a77401f80821d3a5
Parents: 12aa8ab
Author: sevdokimov <se...@gridgain.com>
Authored: Tue May 26 13:43:12 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Tue May 26 13:43:12 2015 +0300
----------------------------------------------------------------------
.../processors/continuous/GridContinuousProcessor.java | 11 +++++++++++
1 file changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d59a712a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
index d67a45a..71a2a66 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
@@ -92,6 +92,9 @@ public class GridContinuousProcessor extends GridProcessorAdapter {
/** Number of retries using to send messages. */
private int retryCnt = 3;
+ /** */
+ private volatile boolean processorStopped;
+
/**
* @param ctx Kernal context.
*/
@@ -257,6 +260,11 @@ public class GridContinuousProcessor extends GridProcessorAdapter {
}
/** {@inheritDoc} */
+ @Override public void onKernalStop(boolean cancel) {
+ processorStopped = true;
+ }
+
+ /** {@inheritDoc} */
@Override public void stop(boolean cancel) throws IgniteCheckedException {
if (ctx.config().isDaemon())
return;
@@ -551,6 +559,9 @@ public class GridContinuousProcessor extends GridProcessorAdapter {
assert !nodeId.equals(ctx.localNodeId());
+ if (processorStopped)
+ return;
+
RemoteRoutineInfo info = rmtInfos.get(routineId);
if (info != null) {