<artifactId>transcriber</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>${project.groupId}</groupId>
- <artifactId>transcriber</artifactId>
- <version>${project.version}</version>
- <type>xml</type>
- <classifier>config</classifier>
- </dependency>
</dependencies>
<scm>
<connection>scm:git:ssh://git.opendaylight.org:29418/neutron.git</connection>
<bundle>mvn:org.opendaylight.neutron/transcriber/{{VERSION}}</bundle>
<bundle>mvn:org.opendaylight.neutron/model/{{VERSION}}</bundle>
<bundle>mvn:org.osgi/org.osgi.core/{{VERSION}}</bundle>
- <configfile finalname="etc/opendaylight/karaf/neutron-transcriber-default-config.xml">mvn:org.opendaylight.neutron/transcriber/{{VERSION}}/xml/config</configfile>
</feature>
</features>
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<!-- vi: set et smarttab sw=4 tabstop=4: -->
-<!--
-Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
-
-This program and the accompanying materials are made available under the
-terms of the Eclipse Public License v1.0 which accompanies this distribution,
-and is available at http://www.eclipse.org/legal/epl-v10.html
--->
-<snapshot>
- <required-capabilities>
- <capability>urn:opendaylight:params:xml:ns:yang:neutron:transcriber:impl?module=neutron-transcriber-impl&revision=2014-12-10</capability>
- </required-capabilities>
- <configuration>
-
- <data xmlns="urn:ietf:params:xml:ns:netconf:base:1.0">
- <modules xmlns="urn:opendaylight:params:xml:ns:yang:controller:config">
- <module>
- <type xmlns:prefix="urn:opendaylight:params:xml:ns:yang:neutron:transcriber:impl">prefix:neutron-transcriber-impl</type>
- <name>neutron-transcriber-default</name>
- <broker>
- <type xmlns:binding="urn:opendaylight:params:xml:ns:yang:controller:md:sal:binding">binding:binding-broker-osgi-registry</type>
- <name>binding-osgi-broker</name>
- </broker>
- </module>
- </modules>
- </data>
- </configuration>
-</snapshot>
import org.opendaylight.controller.md.sal.common.api.data.OptimisticLockFailedException;
import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
import org.opendaylight.yangtools.yang.binding.Augmentable;
import org.opendaylight.yangtools.yang.binding.ChildOf;
private final DataBroker db;
- AbstractNeutronInterface(ProviderContext providerContext) {
- this.db = providerContext.getSALService(DataBroker.class);
+ AbstractNeutronInterface(DataBroker db) {
+ this.db = Preconditions.checkNotNull(db);
}
public DataBroker getDataBroker() {
+++ /dev/null
-/*
- * Copyright (c) 2015 IBM Corporation and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-
-package org.opendaylight.neutron.transcriber;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
-import org.osgi.framework.BundleActivator;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
-
-public class Activator implements BundleActivator {
- private final List<ServiceRegistration<?>> registrations = new ArrayList<ServiceRegistration<?>>();
- private final ProviderContext providerContext;
-
- public Activator(ProviderContext providerContext) {
- this.providerContext = providerContext;
- }
-
- @Override
- public void start(BundleContext context) throws Exception {
- NeutronRouterInterface.registerNewInterface(context, providerContext, registrations);
- NeutronPortInterface.registerNewInterface(context, providerContext, registrations);
- NeutronSubnetInterface.registerNewInterface(context, providerContext, registrations);
- NeutronNetworkInterface.registerNewInterface(context, providerContext, registrations);
- NeutronSecurityGroupInterface.registerNewInterface(context, providerContext, registrations);
- NeutronSecurityRuleInterface.registerNewInterface(context, providerContext, registrations);
- NeutronFirewallInterface.registerNewInterface(context, providerContext, registrations);
- NeutronFirewallPolicyInterface.registerNewInterface(context, providerContext, registrations);
- NeutronFirewallRuleInterface.registerNewInterface(context, providerContext, registrations);
- NeutronLoadBalancerInterface.registerNewInterface(context, providerContext, registrations);
- NeutronLoadBalancerPoolInterface.registerNewInterface(context, providerContext, registrations);
- NeutronLoadBalancerListenerInterface.registerNewInterface(context, providerContext, registrations);
- NeutronLoadBalancerHealthMonitorInterface.registerNewInterface(context, providerContext, registrations);
- NeutronMeteringLabelInterface.registerNewInterface(context, providerContext, registrations);
- NeutronMeteringLabelRuleInterface.registerNewInterface(context, providerContext, registrations);
- NeutronVPNServiceInterface.registerNewInterface(context, providerContext, registrations);
- NeutronVPNIKEPolicyInterface.registerNewInterface(context, providerContext, registrations);
- NeutronVPNIPSECPolicyInterface.registerNewInterface(context, providerContext, registrations);
- NeutronVPNIPSECSiteConnectionsInterface.registerNewInterface(context, providerContext, registrations);
- NeutronFloatingIPInterface.registerNewInterface(context, providerContext, registrations);
- NeutronBgpvpnInterface.registerNewInterface(context, providerContext, registrations);
- NeutronL2gatewayInterface.registerNewInterface(context, providerContext, registrations);
- NeutronL2gatewayConnectionInterface.registerNewInterface(context, providerContext, registrations);
- }
-
- @Override
- public void stop(BundleContext context) throws Exception {
- for (final ServiceRegistration registration : registrations) {
- if (registration != null) {
- registration.unregister();
- }
- }
- }
-}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronBgpvpnCRUD;
import org.opendaylight.neutron.spi.NeutronBgpvpn;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.bgpvpns.rev150903.bgpvpns.attributes.bgpvpns.BgpvpnBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(BgpvpnTypeL3.class,"l3")
.build();
- NeutronBgpvpnInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronBgpvpnInterface(DataBroker db) {
+ super(db);
}
@Override
return InstanceIdentifier.create(Neutron.class)
.child(Bgpvpns.class);
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronBgpvpnInterface neutronNetworkInterface = new NeutronBgpvpnInterface(providerContext);
- final ServiceRegistration<INeutronBgpvpnCRUD> neutronNetworkInterfaceRegistration = context.registerService(INeutronBgpvpnCRUD.class, neutronNetworkInterface, null);
- if(neutronNetworkInterfaceRegistration != null) {
- registrations.add(neutronNetworkInterfaceRegistration);
- }
- }
}
package org.opendaylight.neutron.transcriber;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronFirewallCRUD;
import org.opendaylight.neutron.spi.NeutronFirewall;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronFirewallInterface.class);
- NeutronFirewallInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronFirewallInterface(DataBroker db) {
+ super(db);
}
@Override
firewallBuilder.setUuid(toUuid(uuid));
return firewallBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronFirewallInterface neutronFirewallInterface = new NeutronFirewallInterface(providerContext);
- final ServiceRegistration<INeutronFirewallCRUD> neutronFirewallInterfaceRegistration = context.registerService(INeutronFirewallCRUD.class, neutronFirewallInterface, null);
- if(neutronFirewallInterfaceRegistration != null) {
- registrations.add(neutronFirewallInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronFirewallPolicyCRUD;
import org.opendaylight.neutron.spi.NeutronFirewallPolicy;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronFirewallPolicyInterface extends AbstractNeutronInterface<FirewallPolicy, FirewallPolicies, NeutronFirewallPolicy> implements INeutronFirewallPolicyCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronFirewallPolicyInterface.class);
- NeutronFirewallPolicyInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronFirewallPolicyInterface(DataBroker db) {
+ super(db);
}
@Override
policyBuilder.setUuid(toUuid(uuid));
return policyBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronFirewallPolicyInterface neutronFirewallPolicyInterface = new NeutronFirewallPolicyInterface(providerContext);
- final ServiceRegistration<INeutronFirewallPolicyCRUD> neutronFirewallPolicyInterfaceRegistration = context.registerService(INeutronFirewallPolicyCRUD.class, neutronFirewallPolicyInterface, null);
- if(neutronFirewallPolicyInterfaceRegistration != null) {
- registrations.add(neutronFirewallPolicyInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronFirewallRuleCRUD;
import org.opendaylight.neutron.spi.NeutronFirewallRule;
import com.google.common.collect.ImmutableBiMap;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(IpVersionV6.class, Integer.valueOf(6))
.build();
- NeutronFirewallRuleInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronFirewallRuleInterface(DataBroker db) {
+ super(db);
}
@Override
ruleBuilder.setUuid(toUuid(uuid));
return ruleBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronFirewallRuleInterface neutronFirewallRuleInterface = new NeutronFirewallRuleInterface(providerContext);
- final ServiceRegistration<INeutronFirewallRuleCRUD> neutronFirewallRuleInterfaceRegistration = context.registerService(INeutronFirewallRuleCRUD.class, neutronFirewallRuleInterface, null);
- if(neutronFirewallRuleInterfaceRegistration != null) {
- registrations.add(neutronFirewallRuleInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronFloatingIPCRUD;
import org.opendaylight.neutron.spi.NeutronFloatingIP;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.floatingips.attributes.floatingips.FloatingipBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronFloatingIPInterface extends AbstractNeutronInterface<Floatingip, Floatingips, NeutronFloatingIP> implements INeutronFloatingIPCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronFloatingIPInterface.class);
- NeutronFloatingIPInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronFloatingIPInterface(DataBroker db) {
+ super(db);
}
// IfNBFloatingIPCRUD interface methods
return InstanceIdentifier.create(Neutron.class)
.child(Floatingips.class);
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronFloatingIPInterface neutronFloatingIPInterface = new NeutronFloatingIPInterface(providerContext);
- final ServiceRegistration<INeutronFloatingIPCRUD> neutronFloatingIPInterfaceRegistration = context.registerService(INeutronFloatingIPCRUD.class, neutronFloatingIPInterface, null);
- if (neutronFloatingIPInterfaceRegistration != null) {
- registrations.add(neutronFloatingIPInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronL2gatewayConnectionCRUD;
import org.opendaylight.neutron.spi.NeutronL2gatewayConnection;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l2gateways.rev150712.l2gateway.connections.attributes.L2gatewayConnections;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l2gateways.rev150712.l2gateway.connections.attributes.l2gatewayconnections.L2gatewayConnectionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronL2gatewayConnectionInterface.class);
- NeutronL2gatewayConnectionInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronL2gatewayConnectionInterface(DataBroker db) {
+ super(db);
}
@Override
l2gatewayConnectionBuilder.setUuid(toUuid(uuid));
return l2gatewayConnectionBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronL2gatewayConnectionInterface neutronL2gatewayConnectionInterface =
- new NeutronL2gatewayConnectionInterface(providerContext);
- final ServiceRegistration<INeutronL2gatewayConnectionCRUD> neutronL2gatewayConInterfaceRegistration = context
- .registerService(INeutronL2gatewayConnectionCRUD.class, neutronL2gatewayConnectionInterface, null);
- if (neutronL2gatewayConInterfaceRegistration != null) {
- registrations.add(neutronL2gatewayConInterfaceRegistration);
- }
- }
-
}
import java.util.ArrayList;
import java.util.List;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronL2gatewayCRUD;
import org.opendaylight.neutron.spi.NeutronL2gatewayDevice;
import org.opendaylight.neutron.spi.NeutronL2gatewayDeviceInterface;
implements INeutronL2gatewayCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronL2gatewayInterface.class);
- NeutronL2gatewayInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronL2gatewayInterface(DataBroker db) {
+ super(db);
}
@Override
l2gatewayBuilder.setUuid(toUuid(uuid));
return l2gatewayBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronL2gatewayInterface neutronL2gatewayInterface = new NeutronL2gatewayInterface(providerContext);
- final ServiceRegistration<INeutronL2gatewayCRUD> neutronL2gatewayInterfaceRegistration = context
- .registerService(INeutronL2gatewayCRUD.class, neutronL2gatewayInterface, null);
- if (neutronL2gatewayInterfaceRegistration != null) {
- registrations.add(neutronL2gatewayInterfaceRegistration);
- }
- }
-
}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronLoadBalancerHealthMonitorCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancerHealthMonitor;
import org.opendaylight.neutron.spi.Neutron_ID;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.lbaasv2.rev150712.lbaas.attributes.healthmonitors.HealthmonitorBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.build();
- NeutronLoadBalancerHealthMonitorInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronLoadBalancerHealthMonitorInterface(DataBroker db) {
+ super(db);
}
@Override
}
return answer;
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronLoadBalancerHealthMonitorInterface neutronLoadBalancerHealthMonitorInterface = new NeutronLoadBalancerHealthMonitorInterface(providerContext);
- final ServiceRegistration<INeutronLoadBalancerHealthMonitorCRUD> neutronLoadBalancerHealthMonitorInterfaceRegistration = context.registerService(INeutronLoadBalancerHealthMonitorCRUD.class, neutronLoadBalancerHealthMonitorInterface, null);
- if(neutronLoadBalancerHealthMonitorInterfaceRegistration != null) {
- registrations.add(neutronLoadBalancerHealthMonitorInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancer;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.lbaasv2.rev150712.lbaas.attributes.loadbalancers.LoadbalancerBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronLoadBalancerInterface.class);
- NeutronLoadBalancerInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronLoadBalancerInterface(DataBroker db) {
+ super(db);
}
@Override
}
return loadBalancerBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronLoadBalancerInterface neutronLoadBalancerInterface = new NeutronLoadBalancerInterface(providerContext);
- final ServiceRegistration<INeutronLoadBalancerCRUD> neutronLoadBalancerInterfaceRegistration = context.registerService(INeutronLoadBalancerCRUD.class, neutronLoadBalancerInterface, null);
- if(neutronLoadBalancerInterfaceRegistration != null) {
- registrations.add(neutronLoadBalancerInterfaceRegistration);
- }
- }
}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronLoadBalancerListenerCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancerListener;
import org.opendaylight.neutron.spi.Neutron_ID;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.lbaasv2.rev150712.lbaas.attributes.listeners.ListenerBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(ProtocolTerminatedHttps.class,"TERMINATED_HTTPS")
.build();
- NeutronLoadBalancerListenerInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronLoadBalancerListenerInterface(DataBroker db) {
+ super(db);
}
@Override
}
return answer;
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronLoadBalancerListenerInterface neutronLoadBalancerListenerInterface = new NeutronLoadBalancerListenerInterface(providerContext);
- final ServiceRegistration<INeutronLoadBalancerListenerCRUD> neutronLoadBalancerListenerInterfaceRegistration = context.registerService(INeutronLoadBalancerListenerCRUD.class, neutronLoadBalancerListenerInterface, null);
- if(neutronLoadBalancerListenerInterfaceRegistration != null) {
- registrations.add(neutronLoadBalancerListenerInterfaceRegistration);
- }
- }
}
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancerPool;
import org.opendaylight.neutron.spi.NeutronLoadBalancerPoolMember;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.lbaasv2.rev150712.pool.attributes.SessionPersistenceBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(ProtocolTerminatedHttps.class,"TERMINATED_HTTPS")
.build();
- NeutronLoadBalancerPoolInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronLoadBalancerPoolInterface(DataBroker db) {
+ super(db);
}
@Override
return answer;
}
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronLoadBalancerPoolInterface neutronLoadBalancerPoolInterface = new NeutronLoadBalancerPoolInterface(providerContext);
- final ServiceRegistration<INeutronLoadBalancerPoolCRUD> neutronLoadBalancerPoolInterfaceRegistration = context.registerService(INeutronLoadBalancerPoolCRUD.class, neutronLoadBalancerPoolInterface, null);
- if(neutronLoadBalancerPoolInterfaceRegistration != null) {
- registrations.add(neutronLoadBalancerPoolInterfaceRegistration);
- }
- }
-
public boolean neutronLoadBalancerPoolMemberExists(String poolUuid, String uuid) {
final Member member = readMemberMd(
createMemberInstanceIdentifier(toMd(poolUuid),
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronMeteringLabelCRUD;
import org.opendaylight.neutron.spi.NeutronMeteringLabel;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.metering.rev150712.metering.labels.attributes.MeteringLabels;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.metering.rev150712.metering.labels.attributes.metering.labels.MeteringLabelBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronMeteringLabelInterface extends AbstractNeutronInterface<MeteringLabel, MeteringLabels, NeutronMeteringLabel> implements INeutronMeteringLabelCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronMeteringLabelInterface.class);
- NeutronMeteringLabelInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronMeteringLabelInterface(DataBroker db) {
+ super(db);
}
// IfNBMeteringLabelCRUD methods
meteringLabelBuilder.setUuid(toUuid(uuid));
return meteringLabelBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronMeteringLabelInterface neutronMeteringLabelInterface = new NeutronMeteringLabelInterface(providerContext);
- final ServiceRegistration<INeutronMeteringLabelCRUD> neutronMeteringLabelInterfaceRegistration = context.registerService(INeutronMeteringLabelCRUD.class, neutronMeteringLabelInterface, null);
- if(neutronMeteringLabelInterfaceRegistration != null) {
- registrations.add(neutronMeteringLabelInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronMeteringLabelRuleCRUD;
import org.opendaylight.neutron.spi.NeutronMeteringLabelRule;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpPrefix;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.metering.rev150712.metering.rules.attributes.metering.rules.MeteringRuleBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.build();
- NeutronMeteringLabelRuleInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronMeteringLabelRuleInterface(DataBroker db) {
+ super(db);
}
// IfNBMeteringLabelRuleCRUD methods
meteringRuleBuilder.setUuid(toUuid(uuid));
return meteringRuleBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronMeteringLabelRuleInterface neutronMeteringLabelRuleInterface = new NeutronMeteringLabelRuleInterface(providerContext);
- final ServiceRegistration<INeutronMeteringLabelRuleCRUD> neutronMeteringLabelRuleInterfaceRegistration = context.registerService(INeutronMeteringLabelRuleCRUD.class, neutronMeteringLabelRuleInterface, null);
- if (neutronMeteringLabelRuleInterfaceRegistration != null) {
- registrations.add(neutronMeteringLabelRuleInterfaceRegistration);
- }
- }
}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
import org.opendaylight.neutron.spi.NeutronNetwork;
import org.opendaylight.neutron.spi.NeutronNetwork_Segment;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.provider.ext.rev150712.NetworkProviderExtensionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(NetworkTypeVxlan.class,"vxlan")
.build();
- NeutronNetworkInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronNetworkInterface(DataBroker db) {
+ super(db);
}
// IfNBNetworkCRUD methods
return InstanceIdentifier.create(Neutron.class)
.child(Networks.class);
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronNetworkInterface neutronNetworkInterface = new NeutronNetworkInterface(providerContext);
- final ServiceRegistration<INeutronNetworkCRUD> neutronNetworkInterfaceRegistration = context.registerService(INeutronNetworkCRUD.class, neutronNetworkInterface, null);
- if(neutronNetworkInterfaceRegistration != null) {
- registrations.add(neutronNetworkInterfaceRegistration);
- }
- }
}
import java.util.Map;
import java.util.Set;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronPortCRUD;
import org.opendaylight.neutron.spi.INeutronSecurityGroupCRUD;
import org.opendaylight.neutron.spi.NeutronCRUDInterfaces;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.types.rev160517.IpPrefixOrAddress;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(IpVersionV6.class, Integer.valueOf(6))
.build();
- NeutronPortInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronPortInterface(DataBroker db) {
+ super(db);
}
// IfNBPortCRUD methods
portBuilder.setUuid(toUuid(uuid));
return portBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronPortInterface neutronPortInterface = new NeutronPortInterface(providerContext);
- final ServiceRegistration<INeutronPortCRUD> neutronPortInterfaceRegistration = context.registerService(INeutronPortCRUD.class, neutronPortInterface, null);
- if(neutronPortInterfaceRegistration != null) {
- registrations.add(neutronPortInterfaceRegistration);
- }
- }
}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronRouterCRUD;
import org.opendaylight.neutron.spi.NeutronRoute;
import org.opendaylight.neutron.spi.Neutron_IPs;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.router.external_gateway_info.ExternalFixedIps;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
// methods needed for creating caches
- NeutronRouterInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronRouterInterface(DataBroker db) {
+ super(db);
}
return routerBuilder.build();
}
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronRouterInterface neutronRouterInterface = new NeutronRouterInterface(providerContext);
- final ServiceRegistration<INeutronRouterCRUD> neutronRouterInterfaceRegistration = context.registerService(INeutronRouterCRUD.class, neutronRouterInterface, null);
- if(neutronRouterInterfaceRegistration != null) {
- registrations.add(neutronRouterInterfaceRegistration);
- }
- }
-
public NeutronRouter fromMd(Router router) {
final NeutronRouter result = new NeutronRouter();
result.setID(router.getUuid().getValue());
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronSecurityGroupCRUD;
import org.opendaylight.neutron.spi.NeutronSecurityGroup;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.groups.attributes.security.groups.SecurityGroup;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.groups.attributes.security.groups.SecurityGroupBuilder;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronSecurityGroupInterface.class);
- NeutronSecurityGroupInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronSecurityGroupInterface(DataBroker db) {
+ super(db);
}
@Override
securityGroupBuilder.setUuid(toUuid(uuid));
return securityGroupBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronSecurityGroupInterface neutronSecurityGroupInterface = new NeutronSecurityGroupInterface(providerContext);
- final ServiceRegistration<INeutronSecurityGroupCRUD> neutronSecurityGroupInterfaceRegistration = context.registerService(INeutronSecurityGroupCRUD.class, neutronSecurityGroupInterface, null);
- if(neutronSecurityGroupInterfaceRegistration != null) {
- registrations.add(neutronSecurityGroupInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronSecurityRuleCRUD;
import org.opendaylight.neutron.spi.NeutronSecurityRule;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpPrefix;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.rules.attributes.security.rules.SecurityRuleBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.SecurityRuleAttributes.Protocol;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(EthertypeV6.class,"IPv6")
.build();
- NeutronSecurityRuleInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronSecurityRuleInterface(DataBroker db) {
+ super(db);
}
@Override
securityRuleBuilder.setUuid(toUuid(uuid));
return securityRuleBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronSecurityRuleInterface neutronSecurityRuleInterface = new NeutronSecurityRuleInterface(providerContext);
- final ServiceRegistration<INeutronSecurityRuleCRUD> neutronSecurityRuleInterfaceRegistration = context.registerService(INeutronSecurityRuleCRUD.class, neutronSecurityRuleInterface, null);
- if(neutronSecurityRuleInterfaceRegistration != null) {
- registrations.add(neutronSecurityRuleInterfaceRegistration);
- }
- }
}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
import org.opendaylight.neutron.spi.NeutronSubnet;
import org.opendaylight.neutron.spi.NeutronSubnet_HostRoute;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.SubnetBuilder;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
.put(Dhcpv6Stateless.class,"dhcpv6-stateless")
.build();
- NeutronSubnetInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronSubnetInterface(DataBroker db) {
+ super(db);
}
// IfNBSubnetCRUD methods
subnetBuilder.setUuid(toUuid(uuid));
return subnetBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronSubnetInterface neutronSubnetInterface = new NeutronSubnetInterface(providerContext);
- final ServiceRegistration<INeutronSubnetCRUD> neutronSubnetInterfaceRegistration = context.registerService(INeutronSubnetCRUD.class, neutronSubnetInterface, null);
- if(neutronSubnetInterfaceRegistration != null) {
- registrations.add(neutronSubnetInterfaceRegistration);
- }
- }
}
--- /dev/null
+/*
+ * Copyright (c) 2016 Intel Corp. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.neutron.transcriber;
+
+// Marker interface for NeutronTranscriber service for advertisement
+public interface NeutronTranscriber {
+}
package org.opendaylight.neutron.transcriber;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
-import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
+import com.google.common.base.Preconditions;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.neutron.spi.INeutronBgpvpnCRUD;
+import org.opendaylight.neutron.spi.INeutronCRUD;
+import org.opendaylight.neutron.spi.INeutronFirewallCRUD;
+import org.opendaylight.neutron.spi.INeutronFirewallPolicyCRUD;
+import org.opendaylight.neutron.spi.INeutronFirewallRuleCRUD;
+import org.opendaylight.neutron.spi.INeutronFloatingIPCRUD;
+import org.opendaylight.neutron.spi.INeutronL2gatewayCRUD;
+import org.opendaylight.neutron.spi.INeutronL2gatewayConnectionCRUD;
+import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
+import org.opendaylight.neutron.spi.INeutronLoadBalancerHealthMonitorCRUD;
+import org.opendaylight.neutron.spi.INeutronLoadBalancerListenerCRUD;
+import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
+import org.opendaylight.neutron.spi.INeutronMeteringLabelCRUD;
+import org.opendaylight.neutron.spi.INeutronMeteringLabelRuleCRUD;
+import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
+import org.opendaylight.neutron.spi.INeutronPortCRUD;
+import org.opendaylight.neutron.spi.INeutronRouterCRUD;
+import org.opendaylight.neutron.spi.INeutronSecurityGroupCRUD;
+import org.opendaylight.neutron.spi.INeutronSecurityRuleCRUD;
+import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
+import org.opendaylight.neutron.spi.INeutronVPNIKEPolicyCRUD;
+import org.opendaylight.neutron.spi.INeutronVPNIPSECPolicyCRUD;
+import org.opendaylight.neutron.spi.INeutronVPNIPSECSiteConnectionsCRUD;
+import org.opendaylight.neutron.spi.INeutronVPNServiceCRUD;
import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class NeutronTranscriberProvider implements BindingAwareProvider, AutoCloseable {
+import java.util.ArrayList;
+import java.util.List;
+
+
+public class NeutronTranscriberProvider
+ implements AutoCloseable, NeutronTranscriber {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronTranscriberProvider.class);
- private final BundleContext bundleContext;
+ private BundleContext context;
+ private DataBroker db;
+ private final List<ServiceRegistration<? extends INeutronCRUD<?>>> registrations = new ArrayList<>();
+ private final List<AutoCloseable> neutronInterfaces = new ArrayList<>();
- private Activator activator;
+ private NeutronBgpvpnInterface bgpvpnInterface;
+ private NeutronFirewallInterface firewallInterface;
+ private NeutronFirewallPolicyInterface firewallPolicyInterface;
+ private NeutronFirewallRuleInterface firewallRuleInterface;
+ private NeutronFloatingIPInterface floatingIPInterface;
+ private NeutronL2gatewayConnectionInterface l2gatewayConnectionInterface;
+ private NeutronL2gatewayInterface l2gatewayInterface;
+ private NeutronLoadBalancerHealthMonitorInterface loadBalancerHealthMonitorInterface;
+ private NeutronLoadBalancerInterface loadBalancerInterface;
+ private NeutronLoadBalancerListenerInterface loadBalancerListenerInterface;
+ private NeutronLoadBalancerPoolInterface loadBalancerPoolInterface;
+ private NeutronMeteringLabelInterface meteringLabelInterface;
+ private NeutronMeteringLabelRuleInterface meteringLabelRuleInterface;
+ private NeutronNetworkInterface networkInterface;
+ private NeutronPortInterface portInterface;
+ private NeutronRouterInterface routerInterface;
+ private NeutronSecurityGroupInterface securityGroupInterface;
+ private NeutronSecurityRuleInterface securityRuleInterface;
+ private NeutronSubnetInterface subnetInterface;
+ private NeutronVPNIKEPolicyInterface vPNIKEPolicyInterface;
+ private NeutronVPNIPSECPolicyInterface vPNIPSECPolicyInterface;
+ private NeutronVPNIPSECSiteConnectionsInterface vPNIPSECSiteConnectionsInterface;
+ private NeutronVPNServiceInterface vPNServiceInterface;
- public NeutronTranscriberProvider(BundleContext bundleContext) {
- LOGGER.warn("BundleContext set to: {}",bundleContext);
- this.bundleContext = bundleContext;
+ public NeutronTranscriberProvider(BundleContext context, DataBroker db) {
+ LOGGER.debug("DataBroker set to: {}", db);
+ this.context = Preconditions.checkNotNull(context);
+ this.db = Preconditions.checkNotNull(db);
}
- @Override
- public void onSessionInitiated(ProviderContext providerContext) {
- this.activator = new Activator(providerContext);
- try {
- LOGGER.warn("BundleContext found to be: {}",bundleContext);
- this.activator.start(bundleContext);
- } catch (final Exception e) {
- LOGGER.warn("Unable to start Neutron Transcriber because: ",e);
- }
+ private <S extends INeutronCRUD<?>, T extends AutoCloseable /* & S */>
+ void registerCRUDInterface(java.lang.Class<S> clazz, T crudInterface) {
+ neutronInterfaces.add(crudInterface);
+ final ServiceRegistration<S> crudInterfaceRegistration =
+ context.registerService(clazz, (S)crudInterface, null);
+ registrations.add(crudInterfaceRegistration);
+ }
+
+ public void init() {
+ bgpvpnInterface = new NeutronBgpvpnInterface(db);
+ registerCRUDInterface(INeutronBgpvpnCRUD.class, bgpvpnInterface);
+
+ firewallInterface = new NeutronFirewallInterface(db);
+ registerCRUDInterface(INeutronFirewallCRUD.class, firewallInterface);
+
+ firewallPolicyInterface = new NeutronFirewallPolicyInterface(db);
+ registerCRUDInterface(INeutronFirewallPolicyCRUD.class, firewallPolicyInterface);
+
+ firewallRuleInterface = new NeutronFirewallRuleInterface(db);
+ registerCRUDInterface(INeutronFirewallRuleCRUD.class, firewallRuleInterface);
+
+ floatingIPInterface = new NeutronFloatingIPInterface(db);
+ registerCRUDInterface(INeutronFloatingIPCRUD.class, floatingIPInterface);
+
+ l2gatewayConnectionInterface = new NeutronL2gatewayConnectionInterface(db);
+ registerCRUDInterface(INeutronL2gatewayConnectionCRUD.class, l2gatewayConnectionInterface);
+
+ l2gatewayInterface = new NeutronL2gatewayInterface(db);
+ registerCRUDInterface(INeutronL2gatewayCRUD.class, l2gatewayInterface);
+
+ loadBalancerHealthMonitorInterface = new NeutronLoadBalancerHealthMonitorInterface(db);
+ registerCRUDInterface(INeutronLoadBalancerHealthMonitorCRUD.class, loadBalancerHealthMonitorInterface);
+
+ loadBalancerInterface = new NeutronLoadBalancerInterface(db);
+ registerCRUDInterface(INeutronLoadBalancerCRUD.class, loadBalancerInterface);
+
+ loadBalancerListenerInterface = new NeutronLoadBalancerListenerInterface(db);
+ registerCRUDInterface(INeutronLoadBalancerListenerCRUD.class, loadBalancerListenerInterface);
+
+ loadBalancerPoolInterface = new NeutronLoadBalancerPoolInterface(db);
+ registerCRUDInterface(INeutronLoadBalancerPoolCRUD.class, loadBalancerPoolInterface);
+
+ meteringLabelInterface = new NeutronMeteringLabelInterface(db);
+ registerCRUDInterface(INeutronMeteringLabelCRUD.class, meteringLabelInterface);
+
+ meteringLabelRuleInterface = new NeutronMeteringLabelRuleInterface(db);
+ registerCRUDInterface(INeutronMeteringLabelRuleCRUD.class, meteringLabelRuleInterface);
+
+ networkInterface = new NeutronNetworkInterface(db);
+ registerCRUDInterface(INeutronNetworkCRUD.class, networkInterface);
+
+ portInterface = new NeutronPortInterface(db);
+ registerCRUDInterface(INeutronPortCRUD.class, portInterface);
+
+ routerInterface = new NeutronRouterInterface(db);
+ registerCRUDInterface(INeutronRouterCRUD.class, routerInterface);
+
+ securityGroupInterface = new NeutronSecurityGroupInterface(db);
+ registerCRUDInterface(INeutronSecurityGroupCRUD.class, securityGroupInterface);
+
+ securityRuleInterface = new NeutronSecurityRuleInterface(db);
+ registerCRUDInterface(INeutronSecurityRuleCRUD.class, securityRuleInterface);
+
+ subnetInterface = new NeutronSubnetInterface(db);
+ registerCRUDInterface(INeutronSubnetCRUD.class, subnetInterface);
+
+ vPNIKEPolicyInterface = new NeutronVPNIKEPolicyInterface(db);
+ registerCRUDInterface(INeutronVPNIKEPolicyCRUD.class, vPNIKEPolicyInterface);
+
+ vPNIPSECPolicyInterface = new NeutronVPNIPSECPolicyInterface(db);
+ registerCRUDInterface(INeutronVPNIPSECPolicyCRUD.class, vPNIPSECPolicyInterface);
+
+ vPNIPSECSiteConnectionsInterface = new NeutronVPNIPSECSiteConnectionsInterface(db);
+ registerCRUDInterface(INeutronVPNIPSECSiteConnectionsCRUD.class, vPNIPSECSiteConnectionsInterface);
+
+ vPNServiceInterface = new NeutronVPNServiceInterface(db);
+ registerCRUDInterface(INeutronVPNServiceCRUD.class, vPNServiceInterface);
+
+ // We don't need context any more
+ this.context = null;
}
@Override
public void close() throws Exception {
- this.activator.stop(bundleContext);
+ for (final ServiceRegistration registration : registrations) {
+ registration.unregister();
+ }
+ for (final AutoCloseable neutronCRUD : neutronInterfaces) {
+ neutronCRUD.close();
+ }
+ neutronInterfaces.clear();
}
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronVPNIKEPolicyCRUD;
import org.opendaylight.neutron.spi.NeutronVPNIKEPolicy;
import org.opendaylight.neutron.spi.NeutronVPNLifetime;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.vpnaas.rev150712.ikepolicies.attributes.ike.policies.IkepolicyBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronVPNIKEPolicyInterface extends AbstractNeutronInterface<Ikepolicy, IkePolicies, NeutronVPNIKEPolicy> implements INeutronVPNIKEPolicyCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronVPNIKEPolicyInterface.class);
- NeutronVPNIKEPolicyInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronVPNIKEPolicyInterface(DataBroker db) {
+ super(db);
}
// IfNBVPNIKEPolicyCRUD methods
ikePolicyBuilder.setUuid(toUuid(uuid));
return ikePolicyBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronVPNIKEPolicyInterface neutronVPNIKEPolicyInterface = new NeutronVPNIKEPolicyInterface(providerContext);
- final ServiceRegistration<INeutronVPNIKEPolicyCRUD> neutronVPNIKEPolicyInterfaceRegistration = context.registerService(INeutronVPNIKEPolicyCRUD.class, neutronVPNIKEPolicyInterface, null);
- if(neutronVPNIKEPolicyInterfaceRegistration != null) {
- registrations.add(neutronVPNIKEPolicyInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronVPNIPSECPolicyCRUD;
import org.opendaylight.neutron.spi.NeutronVPNIPSECPolicy;
import org.opendaylight.neutron.spi.NeutronVPNLifetime;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.vpnaas.rev150712.ipsecpolicies.attributes.ipsec.policies.IpsecpolicyBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronVPNIPSECPolicyInterface extends AbstractNeutronInterface<Ipsecpolicy, IpsecPolicies, NeutronVPNIPSECPolicy> implements INeutronVPNIPSECPolicyCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronVPNIPSECPolicyInterface.class);
- NeutronVPNIPSECPolicyInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronVPNIPSECPolicyInterface(DataBroker db) {
+ super(db);
}
// IfNBVPNIPSECPolicyCRUD methods
ipsecPolicyBuilder.setUuid(toUuid(uuid));
return ipsecPolicyBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronVPNIPSECPolicyInterface neutronVPNIPSECPolicyInterface = new NeutronVPNIPSECPolicyInterface(providerContext);
- final ServiceRegistration<INeutronVPNIPSECPolicyCRUD> neutronVPNIPSECPolicyInterfaceRegistration = context.registerService(INeutronVPNIPSECPolicyCRUD.class, neutronVPNIPSECPolicyInterface, null);
- if(neutronVPNIPSECPolicyInterfaceRegistration != null) {
- registrations.add(neutronVPNIPSECPolicyInterfaceRegistration);
- }
- }
}
import java.util.ArrayList;
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronVPNIPSECSiteConnectionsCRUD;
import org.opendaylight.neutron.spi.NeutronVPNDeadPeerDetection;
import org.opendaylight.neutron.spi.NeutronVPNIPSECSiteConnection;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.vpnaas.rev150712.ipsecconnections.attributes.ipsec.site.connections.IpsecsiteconnectionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronVPNIPSECSiteConnectionsInterface extends AbstractNeutronInterface<Ipsecsiteconnection, IpsecSiteConnections, NeutronVPNIPSECSiteConnection> implements INeutronVPNIPSECSiteConnectionsCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronVPNIKEPolicyInterface.class);
- NeutronVPNIPSECSiteConnectionsInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronVPNIPSECSiteConnectionsInterface(DataBroker db) {
+ super(db);
}
// INeutronVPNIPSECSiteConnectionsCRUD methods
ipsecSiteConnectionBuilder.setUuid(toUuid(uuid));
return ipsecSiteConnectionBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronVPNIPSECSiteConnectionsInterface neutronVPNIPSECSiteConnectionsInterface = new NeutronVPNIPSECSiteConnectionsInterface(providerContext);
- final ServiceRegistration<INeutronVPNIPSECSiteConnectionsCRUD> neutronVPNIPSECSiteConnectionsInterfaceRegistration = context.registerService(INeutronVPNIPSECSiteConnectionsCRUD.class, neutronVPNIPSECSiteConnectionsInterface, null);
- if (neutronVPNIPSECSiteConnectionsInterfaceRegistration != null) {
- registrations.add(neutronVPNIPSECSiteConnectionsInterfaceRegistration);
- }
- }
}
import java.util.List;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.neutron.spi.INeutronVPNServiceCRUD;
import org.opendaylight.neutron.spi.NeutronVPNService;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.vpnaas.rev150712.vpnservices.attributes.VpnServices;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.vpnaas.rev150712.vpnservices.attributes.vpn.services.VpnserviceBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.ServiceRegistration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class NeutronVPNServiceInterface extends AbstractNeutronInterface<Vpnservice, VpnServices, NeutronVPNService> implements INeutronVPNServiceCRUD {
private static final Logger LOGGER = LoggerFactory.getLogger(NeutronVPNServiceInterface.class);
- NeutronVPNServiceInterface(ProviderContext providerContext) {
- super(providerContext);
+ NeutronVPNServiceInterface(DataBroker db) {
+ super(db);
}
@Override
vpnServiceBuilder.setUuid(toUuid(uuid));
return vpnServiceBuilder.build();
}
-
- public static void registerNewInterface(BundleContext context,
- ProviderContext providerContext,
- List<ServiceRegistration<?>> registrations) {
- final NeutronVPNServiceInterface neutronVPNServiceInterface = new NeutronVPNServiceInterface(providerContext);
- final ServiceRegistration<INeutronVPNServiceCRUD> neutronVPNServiceInterfaceRegistration = context.registerService(INeutronVPNServiceCRUD.class, neutronVPNServiceInterface, null);
- if(neutronVPNServiceInterfaceRegistration != null) {
- registrations.add(neutronVPNServiceInterfaceRegistration);
- }
- }
}
+++ /dev/null
-package org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.neutron.transcriber.impl.rev141210;
-
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
-import org.opendaylight.neutron.transcriber.NeutronTranscriberProvider;
-import org.osgi.framework.BundleContext;
-
-public class NeutronTranscriberImplModule extends org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.neutron.transcriber.impl.rev141210.AbstractNeutronTranscriberImplModule {
- private BundleContext bundleContext;
-
- public NeutronTranscriberImplModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
- super(identifier, dependencyResolver);
- }
-
- public NeutronTranscriberImplModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.neutron.transcriber.impl.rev141210.NeutronTranscriberImplModule oldModule, java.lang.AutoCloseable oldInstance) {
- super(identifier, dependencyResolver, oldModule, oldInstance);
- }
-
- @Override
- public void customValidation() {
- // add custom validation form module attributes here.
- }
-
- @Override
- public java.lang.AutoCloseable createInstance() {
- final NeutronTranscriberProvider provider = new NeutronTranscriberProvider(bundleContext);
- final BindingAwareBroker localBroker = getBrokerDependency();
- localBroker.registerProvider(provider);
- return provider;
- }
-
- public void setBundleContext(BundleContext bundleContext) {
- this.bundleContext = bundleContext;
- }
-
-}
+++ /dev/null
-/*
-* Generated file
-*
-* Generated from: yang module name: neutron-transcriber-impl yang module local name: neutron-transcriber-impl
-* Generated by: org.opendaylight.controller.config.yangjmxgenerator.plugin.JMXGenerator
-* Generated at: Mon Apr 20 09:49:26 PDT 2015
-*
-* Do not modify this file unless it is present under src/main directory
-*/
-package org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.neutron.transcriber.impl.rev141210;
-
-import org.opendaylight.controller.config.api.DependencyResolver;
-import org.opendaylight.controller.config.api.DynamicMBeanWithInstance;
-import org.opendaylight.controller.config.spi.Module;
-import org.osgi.framework.BundleContext;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class NeutronTranscriberImplModuleFactory extends org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.neutron.transcriber.impl.rev141210.AbstractNeutronTranscriberImplModuleFactory {
-
- private static final Logger logger = LoggerFactory.getLogger(NeutronTranscriberImplModuleFactory.class);
-
- @Override
- public Module createModule(String instanceName,
- DependencyResolver dependencyResolver,
- DynamicMBeanWithInstance old, BundleContext bundleContext)
- throws Exception {
- // TODO Auto-generated method stub
- final Module neutronTranscriberModule = super.createModule(instanceName, dependencyResolver, old, bundleContext);
- setModuleBundleContext(bundleContext, neutronTranscriberModule);
- return neutronTranscriberModule;
- }
-
- private void setModuleBundleContext(BundleContext bundleContext,
- Module neutronTranscriberModule) {
- if(neutronTranscriberModule instanceof NeutronTranscriberImplModule) {
- ((NeutronTranscriberImplModule)neutronTranscriberModule).setBundleContext(bundleContext);
- } else {
- logger.warn("Mysteriously, Module is of type {} expected type {}",
- neutronTranscriberModule.getClass(),
- NeutronTranscriberImplModule.class);
- }
- }
-
- @Override
- public Module createModule(String instanceName,
- DependencyResolver dependencyResolver, BundleContext bundleContext) {
- // TODO Auto-generated method stub
- final Module neutronTranscriberModule = super.createModule(instanceName, dependencyResolver, bundleContext);
- setModuleBundleContext(bundleContext, neutronTranscriberModule);
- return neutronTranscriberModule;
- }
-
-
-
-}
--- /dev/null
+<?xml version="1.0" encoding="UTF-8"?>
+<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
+ xmlns:odl="http://opendaylight.org/xmlns/blueprint/v1.0.0"
+ odl:use-default-for-reference-types="true">
+
+ <reference id="dataBroker"
+ interface="org.opendaylight.controller.md.sal.binding.api.DataBroker"
+ odl:type="default" />
+
+ <bean id="neutronTranscriberImpl"
+ class="org.opendaylight.neutron.transcriber.NeutronTranscriberProvider"
+ init-method="init"
+ destroy-method="close">
+ <argument ref="blueprintBundleContext"/>
+ <argument ref="dataBroker"/>
+ </bean>
+
+ <service ref="neutronTranscriberImpl"
+ interface="org.opendaylight.neutron.transcriber.NeutronTranscriber"
+ odl:type="default"/>
+
+</blueprint>
+++ /dev/null
-module neutron-transcriber-impl {
- yang-version 1;
- namespace "urn:opendaylight:params:xml:ns:yang:neutron:transcriber:impl";
- prefix "neutron-transcriber-impl";
-
- import config { prefix config; revision-date 2013-04-05; }
- import opendaylight-md-sal-binding { prefix md-sal-binding; revision-date 2013-10-28;}
-
- description
- "Service definition for southbound project";
-
- revision "2014-12-10" {
- description
- "Initial revision";
- }
-
- identity neutron-transcriber-impl {
- base config:module-type;
- config:java-name-prefix NeutronTranscriberImpl;
- }
-
- augment "/config:modules/config:module/config:configuration" {
- case neutron-transcriber-impl {
- when "/config:modules/config:module/config:type = 'neutron-transcriber-impl'";
- container broker {
- uses config:service-ref {
- refine type {
- mandatory true;
- config:required-identity md-sal-binding:binding-broker-osgi-registry;
- }
- }
- }
- }
- }
-}
Code Review / neutron.git / commitdiff