2 * Copyright (c) 2013, 2015 IBM Corporation and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.neutron.transcriber;
11 import com.google.common.collect.ImmutableBiMap;
13 import java.util.ArrayList;
14 import java.util.List;
16 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
17 import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
18 import org.opendaylight.neutron.spi.NeutronNetwork;
19 import org.opendaylight.neutron.spi.NeutronNetwork_Segment;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.ext.rev150712.NetworkL3Extension;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.ext.rev150712.NetworkL3ExtensionBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.Networks;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.NetworkBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.provider.ext.rev150712.neutron.networks.network.Segments;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.provider.ext.rev150712.neutron.networks.network.SegmentsBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.NetworkTypeBase;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.NetworkTypeFlat;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.NetworkTypeGre;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.NetworkTypeVlan;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.NetworkTypeVxlan;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.provider.ext.rev150712.NetworkProviderExtension;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.provider.ext.rev150712.NetworkProviderExtensionBuilder;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
36 import org.osgi.framework.BundleContext;
37 import org.osgi.framework.ServiceRegistration;
38 import org.slf4j.Logger;
39 import org.slf4j.LoggerFactory;
41 public class NeutronNetworkInterface extends AbstractNeutronInterface<Network, Networks, NeutronNetwork> implements INeutronNetworkCRUD {
42 private static final Logger LOGGER = LoggerFactory.getLogger(NeutronNetworkInterface.class);
44 private static final ImmutableBiMap<Class<? extends NetworkTypeBase>,String> NETWORK_MAP
45 = new ImmutableBiMap.Builder<Class<? extends NetworkTypeBase>,String>()
46 .put(NetworkTypeFlat.class,"flat")
47 .put(NetworkTypeGre.class,"gre")
48 .put(NetworkTypeVlan.class,"vlan")
49 .put(NetworkTypeVxlan.class,"vxlan")
52 NeutronNetworkInterface(ProviderContext providerContext) {
53 super(providerContext);
56 // IfNBNetworkCRUD methods
58 protected List<Network> getDataObjectList(Networks networks) {
59 return networks.getNetwork();
62 protected NeutronNetwork fromMd(Network network) {
63 final NeutronNetwork result = new NeutronNetwork();
64 result.initDefaults();
65 result.setAdminStateUp(network.isAdminStateUp());
66 result.setNetworkName(network.getName());
67 result.setShared(network.isShared());
68 result.setStatus(network.getStatus());
69 result.setTenantID(network.getTenantId());
70 result.setID(network.getUuid().getValue());
72 final NetworkL3Extension l3Extension = network.getAugmentation(NetworkL3Extension.class);
73 result.setRouterExternal(l3Extension.isExternal());
75 final NetworkProviderExtension providerExtension = network.getAugmentation(NetworkProviderExtension.class);
76 result.setProviderPhysicalNetwork(providerExtension.getPhysicalNetwork());
77 result.setProviderSegmentationID(providerExtension.getSegmentationId());
78 result.setProviderNetworkType(NETWORK_MAP.get(providerExtension.getNetworkType()));
79 final List<NeutronNetwork_Segment> segments = new ArrayList<NeutronNetwork_Segment>();
80 if (providerExtension.getSegments() != null) {
81 for (final Segments segment: providerExtension.getSegments()) {
82 final NeutronNetwork_Segment neutronSegment = new NeutronNetwork_Segment();
83 neutronSegment.setProviderPhysicalNetwork(segment.getPhysicalNetwork());
84 neutronSegment.setProviderSegmentationID(segment.getSegmentationId());
85 neutronSegment.setProviderNetworkType(NETWORK_MAP.get(segment.getNetworkType()));
86 segments.add(neutronSegment);
89 result.setSegments(segments);
93 private void fillExtensions(NetworkBuilder networkBuilder,
94 NeutronNetwork network) {
95 final NetworkL3ExtensionBuilder l3ExtensionBuilder = new NetworkL3ExtensionBuilder();
96 if (network.getRouterExternal() != null) {
97 l3ExtensionBuilder.setExternal(network.getRouterExternal());
100 final NetworkProviderExtensionBuilder providerExtensionBuilder = new NetworkProviderExtensionBuilder();
101 if (network.getProviderPhysicalNetwork() != null) {
102 providerExtensionBuilder.setPhysicalNetwork(network.getProviderPhysicalNetwork());
104 if (network.getProviderSegmentationID() != null) {
105 providerExtensionBuilder.setSegmentationId(network.getProviderSegmentationID());
107 if (network.getProviderNetworkType() != null) {
108 final ImmutableBiMap<String, Class<? extends NetworkTypeBase>> mapper =
109 NETWORK_MAP.inverse();
110 providerExtensionBuilder.setNetworkType((Class<? extends NetworkTypeBase>) mapper.get(network.getProviderNetworkType()));
112 if (network.getSegments() != null) {
113 final List<Segments> segments = new ArrayList<Segments>();
115 for( final NeutronNetwork_Segment segment : network.getSegments()) {
117 final SegmentsBuilder segmentsBuilder = new SegmentsBuilder();
118 if (segment.getProviderPhysicalNetwork() != null) {
119 segmentsBuilder.setPhysicalNetwork(segment.getProviderPhysicalNetwork());
121 if (segment.getProviderSegmentationID() != null) {
122 segmentsBuilder.setSegmentationId(segment.getProviderSegmentationID());
124 if (segment.getProviderNetworkType() != null) {
125 final ImmutableBiMap<String, Class<? extends NetworkTypeBase>> mapper =
126 NETWORK_MAP.inverse();
127 segmentsBuilder.setNetworkType((Class<? extends NetworkTypeBase>) mapper.get(segment.getProviderNetworkType()));
129 segmentsBuilder.setSegmentationIndex(Long.valueOf(count));
130 segments.add(segmentsBuilder.build());
132 providerExtensionBuilder.setSegments(segments);
134 if (network.getProviderSegmentationID() != null) {
135 providerExtensionBuilder.setSegmentationId(network.getProviderSegmentationID());
138 networkBuilder.addAugmentation(NetworkL3Extension.class,
139 l3ExtensionBuilder.build());
140 networkBuilder.addAugmentation(NetworkProviderExtension.class,
141 providerExtensionBuilder.build());
144 protected Network toMd(NeutronNetwork network) {
145 final NetworkBuilder networkBuilder = new NetworkBuilder();
146 fillExtensions(networkBuilder, network);
148 networkBuilder.setAdminStateUp(network.getAdminStateUp());
149 if (network.getNetworkName() != null) {
150 networkBuilder.setName(network.getNetworkName());
152 if (network.getShared() != null) {
153 networkBuilder.setShared(network.getShared());
155 if (network.getStatus() != null) {
156 networkBuilder.setStatus(network.getStatus());
158 if (network.getTenantID() != null) {
159 networkBuilder.setTenantId(toUuid(network.getTenantID()));
161 if (network.getID() != null) {
162 networkBuilder.setUuid(toUuid(network.getID()));
164 LOGGER.warn("Attempting to write neutron network without UUID");
166 return networkBuilder.build();
169 protected Network toMd(String uuid) {
170 final NetworkBuilder networkBuilder = new NetworkBuilder();
171 networkBuilder.setUuid(toUuid(uuid));
172 return networkBuilder.build();
176 protected InstanceIdentifier<Network> createInstanceIdentifier(Network network) {
177 return InstanceIdentifier.create(Neutron.class)
178 .child(Networks.class)
179 .child(Network.class,network.getKey());
183 protected InstanceIdentifier<Networks> createInstanceIdentifier() {
184 return InstanceIdentifier.create(Neutron.class)
185 .child(Networks.class);
188 public static void registerNewInterface(BundleContext context,
189 ProviderContext providerContext,
190 List<ServiceRegistration<?>> registrations) {
191 final NeutronNetworkInterface neutronNetworkInterface = new NeutronNetworkInterface(providerContext);
192 final ServiceRegistration<INeutronNetworkCRUD> neutronNetworkInterfaceRegistration = context.registerService(INeutronNetworkCRUD.class, neutronNetworkInterface, null);
193 if(neutronNetworkInterfaceRegistration != null) {
194 registrations.add(neutronNetworkInterfaceRegistration);