ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [6/6] ignite git commit: IGNITE-2745: Fixed.
Date Thu, 03 Mar 2016 06:26:25 GMT
IGNITE-2745: Fixed.


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

Branch: refs/heads/ignite-2745
Commit: 6f5dc2c3f14667e199e7f195fae92e758624326d
Parents: 091a39a
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Thu Mar 3 09:26:09 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Thu Mar 3 09:26:09 2016 +0300

----------------------------------------------------------------------
 .../ignite/internal/managers/communication/GridIoManager.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/6f5dc2c3/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
index aaaa95d..232ec2e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
@@ -920,7 +920,9 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa
      */
     private boolean listenerReplace0(Object topic, GridMessageListener expected, GridMessageListener
newVal) {
         if (topic instanceof GridTopic) {
-            return systemListenerChange(topic, expected, newVal);
+            synchronized (sysLsnrsMux) {
+                return systemListenerChange(topic, expected, newVal);
+            }
         }
         else
             return lsnrMap.replace(topic, expected, newVal);


Mime
View raw message