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%2FEntityOwnerChangeListener.java;h=403f19b6239fd1f9543535db1cc4d737cf8f3a60;hb=d4fa6758d6b94aad894854c0fe6fcd82e7bbefd6;hp=d10bc2158ae9824a5f6946d62d055da27895f35e;hpb=ac3065a7d9b6666aa51c1507d9e8143a0cb4db07;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnerChangeListener.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnerChangeListener.java index d10bc2158a..403f19b623 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnerChangeListener.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnerChangeListener.java @@ -8,9 +8,11 @@ package org.opendaylight.controller.cluster.datastore.entityownership; import static org.opendaylight.controller.cluster.datastore.entityownership.EntityOwnersModel.createEntity; -import com.google.common.base.Objects; import com.google.common.base.Optional; +import com.google.common.base.Preconditions; +import com.google.common.base.Strings; import java.util.Collection; +import java.util.Objects; import org.opendaylight.controller.md.sal.common.api.clustering.Entity; import org.opendaylight.yangtools.yang.data.api.schema.LeafNode; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; @@ -30,13 +32,13 @@ class EntityOwnerChangeListener extends AbstractEntityOwnerChangeListener { private final String localMemberName; private final EntityOwnershipListenerSupport listenerSupport; - EntityOwnerChangeListener(String localMemberName, EntityOwnershipListenerSupport listenerSupport) { - this.localMemberName = localMemberName; - this.listenerSupport = listenerSupport; + EntityOwnerChangeListener(final String localMemberName, final EntityOwnershipListenerSupport listenerSupport) { + this.localMemberName = Preconditions.checkNotNull(localMemberName); + this.listenerSupport = Preconditions.checkNotNull(listenerSupport); } @Override - public void onDataTreeChanged(Collection changes) { + public void onDataTreeChanged(final Collection changes) { for(DataTreeCandidate change: changes) { DataTreeCandidateNode changeRoot = change.getRootNode(); LeafNode ownerLeaf = (LeafNode) changeRoot.getDataAfter().get(); @@ -53,10 +55,10 @@ class EntityOwnerChangeListener extends AbstractEntityOwnerChangeListener { LOG.debug("{}: New owner: {}, Original owner: {}", logId(), newOwner, origOwner); - if(!Objects.equal(origOwner, newOwner)) { - boolean isOwner = Objects.equal(localMemberName, newOwner); - boolean wasOwner = Objects.equal(localMemberName, origOwner); - boolean hasOwner = newOwner != null && !newOwner.toString().isEmpty(); + if(!Objects.equals(origOwner, newOwner)) { + boolean isOwner = Objects.equals(localMemberName, newOwner); + boolean wasOwner = Objects.equals(localMemberName, origOwner); + boolean hasOwner = !Strings.isNullOrEmpty(newOwner); Entity entity = createEntity(change.getRootPath());