commit de730823bfb91e948fc35ac2fb0e3191b3b27ee9
author Alexey Goncharuk <alexey.goncharuk@gmail.com> Fri Sep 07 16:51:19 2018 +0300
committer Alexey Goncharuk <alexey.goncharuk@gmail.com> Fri Sep 07 16:51:19 2018 +0300
tree 97d3031d4a5a24e6f4ff88c4f1b2accddca36bf6
parent a7ee714e6dd04d5380fb8bc20003ef721bf5ec92

Minor

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
index 50c54d6..0470fad 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -899,8 +899,11 @@
      * @param internal Internal flag.
      * @return Whether listener was actually registered.
      */
-    GridContinuousHandler.RegisterStatus registerListener(UUID lsnrId, CacheContinuousQueryListener lsnr,
-            boolean internal) {
+    GridContinuousHandler.RegisterStatus registerListener(
+        UUID lsnrId,
+        CacheContinuousQueryListener lsnr,
+        boolean internal
+    ) {
         boolean added;
 
         if (internal) {
@@ -908,8 +911,10 @@
 
             if (added)
                 intLsnrCnt.incrementAndGet();
-        } else {
+        }
+        else {
             listenerLock.writeLock().lock();
+
             try {
                 if (lsnrCnt.get() == 0) {
                     if (cctx.group().sharedGroup() && !cctx.isLocal())
@@ -920,7 +925,8 @@
 
                 if (added)
                     lsnrCnt.incrementAndGet();
-            } finally {
+            }
+            finally {
                 listenerLock.writeLock().unlock();
             }
 
@@ -929,7 +935,7 @@
         }
 
         return added ? GridContinuousHandler.RegisterStatus.REGISTERED
-                : GridContinuousHandler.RegisterStatus.NOT_REGISTERED;
+            : GridContinuousHandler.RegisterStatus.NOT_REGISTERED;
     }
 
     /**
@@ -945,8 +951,10 @@
 
                 lsnr.onUnregister();
             }
-        } else {
+        }
+        else {
             listenerLock.writeLock().lock();
+
             try {
                 if ((lsnr = lsnrs.remove(id)) != null) {
                     int cnt = lsnrCnt.decrementAndGet();
@@ -954,7 +962,8 @@
                     if (cctx.group().sharedGroup() && cnt == 0 && !cctx.isLocal())
                         cctx.group().removeCacheWithContinuousQuery(cctx);
                 }
-            } finally {
+            }
+            finally {
                 listenerLock.writeLock().unlock();
             }