X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=natservice%2Fimpl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetvirt%2Fnatservice%2Finternal%2FNatInterfaceStateChangeListener.java;fp=natservice%2Fimpl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetvirt%2Fnatservice%2Finternal%2FNatInterfaceStateChangeListener.java;h=7fbcf0354478fc91f1b59bb7caedd8f1966f0e91;hb=14cd5115173a053cf6d99b7dc9c9493f0f809b8b;hp=49567a129cac74c5dccc4a6426a3ee284bf720a2;hpb=7c996c0868d978f0a66028dce581165b54ee7787;p=netvirt.git diff --git a/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NatInterfaceStateChangeListener.java b/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NatInterfaceStateChangeListener.java index 49567a129c..7fbcf03544 100644 --- a/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NatInterfaceStateChangeListener.java +++ b/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NatInterfaceStateChangeListener.java @@ -7,9 +7,12 @@ */ package org.opendaylight.netvirt.natservice.internal; +import static org.opendaylight.netvirt.natservice.internal.NatUtil.requireNonNullElse; + import com.google.common.base.Optional; import java.math.BigInteger; +import java.util.Collections; import javax.annotation.PostConstruct; import javax.inject.Inject; import javax.inject.Singleton; @@ -116,7 +119,8 @@ public class NatInterfaceStateChangeListener LOG.warn("remove : Interface {} is not a VPN Interface, ignoring.", interfaceName); return; } - for (VpnInstanceNames vpnInterfaceVpnInstance : cfgVpnInterface.get().getVpnInstanceNames()) { + for (VpnInstanceNames vpnInterfaceVpnInstance : requireNonNullElse( + cfgVpnInterface.get().getVpnInstanceNames(), Collections.emptyList())) { String vpnName = vpnInterfaceVpnInstance.getVpnName(); InstanceIdentifier idOper = NatUtil .getVpnInterfaceOpDataEntryIdentifier(interfaceName, vpnName); @@ -129,7 +133,7 @@ public class NatInterfaceStateChangeListener } } } - if (intfDpnId.equals(BigInteger.ZERO)) { + if (BigInteger.ZERO.equals(intfDpnId)) { LOG.warn("remove : Could not retrieve dpnid for interface {} ", interfaceName); return; } @@ -164,7 +168,8 @@ public class NatInterfaceStateChangeListener LOG.warn("update : Interface {} is not a VPN Interface, ignoring.", interfaceName); return; } - for (VpnInstanceNames vpnInterfaceVpnInstance : cfgVpnInterface.get().getVpnInstanceNames()) { + for (VpnInstanceNames vpnInterfaceVpnInstance : requireNonNullElse( + cfgVpnInterface.get().getVpnInstanceNames(), Collections.emptyList())) { String vpnName = vpnInterfaceVpnInstance.getVpnName(); InstanceIdentifier idOper = NatUtil .getVpnInterfaceOpDataEntryIdentifier(interfaceName, vpnName); @@ -177,7 +182,7 @@ public class NatInterfaceStateChangeListener } } } - if (intfDpnId.equals(BigInteger.ZERO)) { + if (BigInteger.ZERO.equals(intfDpnId)) { LOG.warn("remove : Could not retrieve dpnid for interface {} ", interfaceName); return; }