X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=neutronvpn%2Fneutronvpn-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fneutronvpn%2FNeutronPortChangeListener.java;fp=neutronvpn%2Fneutronvpn-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fneutronvpn%2FNeutronPortChangeListener.java;h=e88b1be08748c2b1f31dc323e2433eedd9423078;hb=c71d51b15e07c98b18fcebe3a4d3adbb2ccc9f79;hp=821035ed135f3e1f3bce4f6fc6afc00bb8befd0b;hpb=9c5a326cda49fd1ba17380c081e3dce70b9781a8;p=vpnservice.git diff --git a/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronPortChangeListener.java b/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronPortChangeListener.java index 821035ed..e88b1be0 100644 --- a/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronPortChangeListener.java +++ b/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronPortChangeListener.java @@ -133,7 +133,7 @@ public class NeutronPortChangeListener extends AbstractDataChangeListener // Create of-port interface for this neutron port createOfPortInterface(port, portVlanId); LOG.debug("Creating ELAN Interface"); - createElanInterface(port, portVlanId); + createElanInterface(port); LOG.debug("Add port to subnet"); // add port to local Subnets DS Uuid vpnId = addPortToSubnets(port); @@ -195,8 +195,8 @@ public class NeutronPortChangeListener extends AbstractDataChangeListener // handle these for trunkport extensions : portVlanId, isVlanTransparent IfL2vlan l2vlan = new IfL2vlanBuilder().setL2vlanMode(IfL2vlan.L2vlanMode.Trunk).build(); ParentRefs parentRefs = new ParentRefsBuilder().setParentInterface(name).build(); - Interface inf = new InterfaceBuilder().setEnabled(true).setName(name).setType(L2vlan.class). - addAugmentation(IfL2vlan.class, l2vlan).addAugmentation(ParentRefs.class, parentRefs).build(); + Interface inf = new InterfaceBuilder().setEnabled(true).setName(name).setType(L2vlan.class) + .addAugmentation(IfL2vlan.class, l2vlan).addAugmentation(ParentRefs.class, parentRefs).build(); MDSALUtil.syncWrite(broker, LogicalDatastoreType.CONFIGURATION, interfaceIdentifier, inf); } else { LOG.error("Interface {} is already present", name); @@ -234,7 +234,7 @@ public class NeutronPortChangeListener extends AbstractDataChangeListener .getUuid()); } - private void createElanInterface(Port port, int portVlanId) { + private void createElanInterface(Port port) { String name = NeutronvpnUtils.uuidToTapPortName(port.getUuid()); String elanInstanceName = port.getNetworkId().getValue(); List physAddresses = new ArrayList<>(); @@ -243,8 +243,7 @@ public class NeutronPortChangeListener extends AbstractDataChangeListener InstanceIdentifier id = InstanceIdentifier.builder(ElanInterfaces.class).child(ElanInterface .class, new ElanInterfaceKey(name)).build(); ElanInterface elanInterface = new ElanInterfaceBuilder().setElanInstanceName(elanInstanceName) - .setName(name).setStaticMacEntries(physAddresses). - setKey(new ElanInterfaceKey(name)).build(); + .setName(name).setStaticMacEntries(physAddresses).setKey(new ElanInterfaceKey(name)).build(); MDSALUtil.syncWrite(broker, LogicalDatastoreType.CONFIGURATION, id, elanInterface); LOG.debug("Creating new ELan Interface {}", elanInterface); } @@ -268,7 +267,7 @@ public class NeutronPortChangeListener extends AbstractDataChangeListener ipValue, name); subnetId = ip.getSubnetId(); - Subnetmap subnetmap = nvpnManager.updateSubnetNode(subnetId, null, null, null, null, port.getUuid()); + Subnetmap subnetmap = nvpnManager.updateSubnetNode(subnetId, null, null, null, null, null, port.getUuid()); if (vpnId == null && subnetmap != null) { vpnId = subnetmap.getVpnId(); }