ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [26/39] ignite git commit: cc
Date Fri, 26 May 2017 14:06:26 GMT
cc


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8cbcef65
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8cbcef65
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8cbcef65

Branch: refs/heads/ignite-5075-cc-debug
Commit: 8cbcef657d2958395377654d44779c68ce16fca6
Parents: 79e34c2
Author: sboikov <sboikov@gridgain.com>
Authored: Thu May 25 20:33:50 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu May 25 20:33:50 2017 +0300

----------------------------------------------------------------------
 .../apache/ignite/internal/processors/cache/GridCacheMapEntry.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/8cbcef65/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
index 30c2a33..80f872c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
@@ -1838,6 +1838,8 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter
impleme
             if (updateRes.success())
                 updateMetrics(c.op, metrics);
 
+            lsnrs = cctx.continuousQueries().updateListeners(internal, false);
+
             // Continuous query filter should be perform under lock.
             if (lsnrs != null) {
                 CacheObject evtVal = cctx.unwrapTemporary(updateVal);


Mime
View raw message