X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fentityownership%2FEntityOwnershipListenerSupport.java;h=be82582e06d2e356b4446e0e51d86c4f7a125f7b;hb=5bbe45d0b189e706ed587e5e4a30c1205213c2f7;hp=26e6ab75675b810f5666613566ff78a614f84e38;hpb=6b31b94c7c06711efd69f7fd456167026f34dc2e;p=controller.git

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerSupport.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerSupport.java
index 26e6ab7567..be82582e06 100644
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerSupport.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerSupport.java
@@ -96,7 +96,7 @@ class EntityOwnershipListenerSupport {
 
     private void notifyListeners(DOMEntity entity, String mapKey, boolean wasOwner, boolean isOwner, boolean hasOwner) {
         Collection<DOMEntityOwnershipListener> listeners = entityTypeListenerMap.get(mapKey);
-        if(!listeners.isEmpty()) {
+        if (!listeners.isEmpty()) {
             notifyListeners(entity, wasOwner, isOwner, hasOwner, listeners);
         }
     }
@@ -105,7 +105,7 @@ class EntityOwnershipListenerSupport {
             Collection<DOMEntityOwnershipListener> listeners) {
         DOMEntityOwnershipChange changed = new DOMEntityOwnershipChange(entity,
                 EntityOwnershipChangeState.from(wasOwner, isOwner, hasOwner), inJeopardy);
-        for(DOMEntityOwnershipListener listener: listeners) {
+        for (DOMEntityOwnershipListener listener: listeners) {
             ActorRef listenerActor = listenerActorFor(listener);
 
             LOG.debug("{}: Notifying EntityOwnershipListenerActor {} with {}", logId, listenerActor, changed);
@@ -117,7 +117,7 @@ class EntityOwnershipListenerSupport {
     private void addListener(DOMEntityOwnershipListener listener, String mapKey) {
         if (entityTypeListenerMap.put(mapKey, listener)) {
             ListenerActorRefEntry listenerEntry = listenerActorMap.get(listener);
-            if(listenerEntry == null) {
+            if (listenerEntry == null) {
                 listenerActorMap.put(listener, new ListenerActorRefEntry());
             } else {
                 listenerEntry.referenceCount++;
@@ -132,10 +132,10 @@ class EntityOwnershipListenerSupport {
             LOG.debug("{}: Found {}", logId, listenerEntry);
 
             listenerEntry.referenceCount--;
-            if(listenerEntry.referenceCount <= 0) {
+            if (listenerEntry.referenceCount <= 0) {
                 listenerActorMap.remove(listener);
 
-                if(listenerEntry.actorRef != null) {
+                if (listenerEntry.actorRef != null) {
                     LOG.debug("Killing EntityOwnershipListenerActor {}", listenerEntry.actorRef);
                     listenerEntry.actorRef.tell(PoisonPill.getInstance(), ActorRef.noSender());
                 }
@@ -152,7 +152,7 @@ class EntityOwnershipListenerSupport {
         int referenceCount = 1;
 
         ActorRef actorFor(DOMEntityOwnershipListener listener) {
-            if(actorRef == null) {
+            if (actorRef == null) {
                 actorRef = actorContext.actorOf(EntityOwnershipListenerActor.props(listener));
 
                 LOG.debug("{}: Created EntityOwnershipListenerActor {} for listener {}", logId, actorRef, listener);