}*/
// The implementation for each of these services is resolved by the OSGi Service Manager
- private volatile EventDispatcher eventDispatcher;
+ protected volatile EventDispatcher eventDispatcher;
/*void init() {
logger.info(">>>>> init {}", this.getClass());
}*/
- protected void setDispatcher(EventDispatcher eventDispatcher) {
- this.eventDispatcher = eventDispatcher;
- }
-
/**
* Convert failure status returned by the manager into
* neutron API service errors.
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+
import org.opendaylight.neutron.spi.INeutronFirewallAware;
import org.opendaylight.neutron.spi.INeutronFirewallPolicyAware;
import org.opendaylight.neutron.spi.INeutronFirewallRuleAware;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
-
/**
* Handle requests for OpenStack Neutron v2.0 Port Firewall API calls.
*/
INeutronFirewallPolicyAware, ConfigInterface {
static final Logger logger = LoggerFactory.getLogger(FWaasHandler.class);
- private volatile EventDispatcher eventDispatcher;
/**
* Invoked when a Firewall Rules creation is requested
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronFirewallAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
*/
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+
import org.opendaylight.neutron.spi.INeutronFloatingIPAware;
import org.opendaylight.neutron.spi.NeutronFloatingIP;
import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
import org.opendaylight.ovsdb.openstack.netvirt.impl.NeutronL3Adapter;
-
import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
-
/**
* Handle requests for Neutron Floating IP.
*/
// The implementation for each of these services is resolved by the OSGi Service Manager
private volatile NeutronL3Adapter neutronL3Adapter;
- private volatile EventDispatcher eventDispatcher;
/**
* Services provide this interface method to indicate if the specified floatingIP can be created
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronFloatingIPAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
neutronL3Adapter =
(NeutronL3Adapter) ServiceHelper.getGlobalInstance(NeutronL3Adapter.class, this);
}
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+import java.util.List;
+import java.util.Map;
+
import org.opendaylight.neutron.spi.INeutronLoadBalancerAware;
import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerConfiguration;
import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerProvider;
-import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheManager;
import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheListener;
+import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheManager;
import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
import org.osgi.framework.BundleContext;
import com.google.common.base.Preconditions;
-import java.net.HttpURLConnection;
-import java.util.List;
-import java.util.Map;
-
/**
* Handle requests for OpenStack Neutron v2.0 LBaaS API calls for /v2.0/loadbalancers.
*/
private volatile INeutronSubnetCRUD neutronSubnetCache;
private volatile LoadBalancerProvider loadBalancerProvider;
private volatile NodeCacheManager nodeCacheManager;
- private volatile EventDispatcher eventDispatcher;
@Override
public int canCreateNeutronLoadBalancer(NeutronLoadBalancer neutronLB) {
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronLoadBalancerAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+import java.util.List;
+import java.util.Map;
+
import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolAware;
import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
import com.google.common.base.Preconditions;
import com.google.common.collect.Lists;
-import java.net.HttpURLConnection;
-import java.util.List;
-import java.util.Map;
-
/**
* Handle requests for OpenStack Neutron v2.0 LBaaS API calls for
* /v2.0/pools . It is possible that each pool spans multiple subnets.
private volatile INeutronSubnetCRUD neutronSubnetCache;
private volatile LoadBalancerProvider loadBalancerProvider;
private volatile NodeCacheManager nodeCacheManager;
- private volatile EventDispatcher eventDispatcher;
@Override
public int canCreateNeutronLoadBalancerPool(NeutronLoadBalancerPool neutronLBPool) {
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronLoadBalancerPoolAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
*/
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+import java.util.List;
+import java.util.Map;
+
import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolMemberAware;
import com.google.common.base.Preconditions;
-import java.net.HttpURLConnection;
-import java.util.List;
-import java.util.Map;
-
/**
* Handle requests for OpenStack Neutron v2.0 LBaaS API calls for
* /v2.0/pools/{pool_id}/members
private volatile INeutronSubnetCRUD neutronSubnetCache;
private volatile LoadBalancerProvider loadBalancerProvider;
private volatile NodeCacheManager nodeCacheManager;
- private volatile EventDispatcher eventDispatcher;
@Override
public int canCreateNeutronLoadBalancerPoolMember(NeutronLoadBalancerPoolMember neutronLBPoolMember) {
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronLoadBalancerPoolMemberAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
*/
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+import java.util.List;
+
import org.opendaylight.neutron.spi.INeutronNetworkAware;
import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
import org.opendaylight.neutron.spi.NeutronNetwork;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
-import java.util.List;
-
/**
* Handle requests for Neutron Network.
*/
private volatile NodeCacheManager nodeCacheManager;
private volatile INeutronNetworkCRUD neutronNetworkCache;
private volatile NeutronL3Adapter neutronL3Adapter;
- private volatile EventDispatcher eventDispatcher;
private volatile Southbound southbound;
/**
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronNetworkAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
*/
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+import java.util.List;
+
import org.opendaylight.neutron.spi.INeutronPortAware;
import org.opendaylight.neutron.spi.NeutronPort;
import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
-import java.util.List;
-
/**
* Handle requests for Neutron Port.
*/
// The implementation for each of these services is resolved by the OSGi Service Manager
private volatile NodeCacheManager nodeCacheManager;
private volatile NeutronL3Adapter neutronL3Adapter;
- private volatile EventDispatcher eventDispatcher;
private volatile Southbound southbound;
/**
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronPortAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+
import org.opendaylight.neutron.spi.INeutronSecurityGroupAware;
import org.opendaylight.neutron.spi.INeutronSecurityRuleAware;
import org.opendaylight.neutron.spi.NeutronSecurityGroup;
import org.opendaylight.neutron.spi.NeutronSecurityRule;
-
import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
import org.osgi.framework.BundleContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
-
/**
* Handle requests for OpenStack Neutron v2.0 Port Security API calls.
*/
implements INeutronSecurityGroupAware, INeutronSecurityRuleAware, ConfigInterface {
static final Logger logger = LoggerFactory.getLogger(PortSecurityHandler.class);
- private volatile EventDispatcher eventDispatcher;
@Override
public int canCreateNeutronSecurityGroup(NeutronSecurityGroup neutronSecurityGroup) {
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronSecurityGroupAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
*/
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+
import org.opendaylight.neutron.spi.INeutronRouterAware;
import org.opendaylight.neutron.spi.NeutronRouter;
import org.opendaylight.neutron.spi.NeutronRouter_Interface;
import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
import org.opendaylight.ovsdb.openstack.netvirt.impl.NeutronL3Adapter;
-
import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
-
/**
* Handle requests for Neutron Router.
*/
// The implementation for each of these services is resolved by the OSGi Service Manager
private volatile NeutronL3Adapter neutronL3Adapter;
- private volatile EventDispatcher eventDispatcher;
/**
* Services provide this interface method to indicate if the specified router can be created
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronRouterAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
private volatile NetworkingProviderManager networkingProviderManager;
private volatile NeutronL3Adapter neutronL3Adapter;
private volatile NodeCacheManager nodeCacheManager;
- private volatile EventDispatcher eventDispatcher;
private volatile OvsdbInventoryService ovsdbInventoryService;
private volatile Southbound southbound;
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(OvsdbInventoryListener.class.getName()), this);
- super.setDispatcher(eventDispatcher);
ovsdbInventoryService =
(OvsdbInventoryService) ServiceHelper.getGlobalInstance(OvsdbInventoryService.class, this);
ovsdbInventoryService.listenerAdded(this);
package org.opendaylight.ovsdb.openstack.netvirt;
+import java.net.HttpURLConnection;
+
import org.opendaylight.neutron.spi.INeutronSubnetAware;
import org.opendaylight.neutron.spi.NeutronSubnet;
import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
import org.opendaylight.ovsdb.openstack.netvirt.impl.NeutronL3Adapter;
-
-import com.google.common.base.Preconditions;
import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.HttpURLConnection;
+import com.google.common.base.Preconditions;
public class SubnetHandler extends AbstractHandler implements INeutronSubnetAware, ConfigInterface {
// The implementation for each of these services is resolved by the OSGi Service Manager
private volatile NeutronL3Adapter neutronL3Adapter;
- private EventDispatcher eventDispatcher;
@Override
public int canCreateSubnet(NeutronSubnet subnet) {
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(INeutronSubnetAware.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override
*/
package org.opendaylight.ovsdb.openstack.netvirt.impl;
-import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
+
import org.opendaylight.ovsdb.openstack.netvirt.AbstractEvent;
import org.opendaylight.ovsdb.openstack.netvirt.AbstractHandler;
import org.opendaylight.ovsdb.openstack.netvirt.ConfigInterface;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+
/**
* @author Flavio Fernandes (ffernand@redhat.com)
* @author Sam Hague (shague@redhat.com)
private final Object nodeCacheLock = new Object();
private Map<NodeId, Node> nodeCache = new ConcurrentHashMap<>();
private Map<Long, NodeCacheListener> handlers = Maps.newHashMap();
- private volatile EventDispatcher eventDispatcher;
private volatile Southbound southbound;
@Override
(EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
eventDispatcher.eventHandlerAdded(
bundleContext.getServiceReference(NodeCacheManager.class.getName()), this);
- super.setDispatcher(eventDispatcher);
}
@Override