2 * Copyright (C) 2013 Red Hat, Inc.
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
8 * Authors : Madhu Venugopal, Brent Salisbury, Dave Tucker
11 package org.opendaylight.ovsdb.openstack.netvirt;
13 import java.util.Dictionary;
14 import java.util.Hashtable;
16 import org.apache.felix.dm.DependencyActivatorBase;
17 import org.apache.felix.dm.DependencyManager;
18 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
19 import org.opendaylight.neutron.spi.INeutronFirewallAware;
20 import org.opendaylight.neutron.spi.INeutronFirewallPolicyAware;
21 import org.opendaylight.neutron.spi.INeutronFirewallRuleAware;
22 import org.opendaylight.neutron.spi.INeutronFloatingIPAware;
23 import org.opendaylight.neutron.spi.INeutronLoadBalancerAware;
24 import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
25 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolAware;
26 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
27 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolMemberAware;
28 import org.opendaylight.neutron.spi.INeutronNetworkAware;
29 import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
30 import org.opendaylight.neutron.spi.INeutronPortAware;
31 import org.opendaylight.neutron.spi.INeutronPortCRUD;
32 import org.opendaylight.neutron.spi.INeutronRouterAware;
33 import org.opendaylight.neutron.spi.INeutronSecurityGroupAware;
34 import org.opendaylight.neutron.spi.INeutronSecurityRuleAware;
35 import org.opendaylight.neutron.spi.INeutronSubnetAware;
36 import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
37 import org.opendaylight.ovsdb.openstack.netvirt.api.ArpProvider;
38 import org.opendaylight.ovsdb.openstack.netvirt.api.BridgeConfigurationManager;
39 import org.opendaylight.ovsdb.openstack.netvirt.api.ConfigurationService;
40 import org.opendaylight.ovsdb.openstack.netvirt.api.Constants;
41 import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
42 import org.opendaylight.ovsdb.openstack.netvirt.api.InboundNatProvider;
43 import org.opendaylight.ovsdb.openstack.netvirt.api.L3ForwardingProvider;
44 import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerProvider;
45 import org.opendaylight.ovsdb.openstack.netvirt.api.MultiTenantAwareRouter;
46 import org.opendaylight.ovsdb.openstack.netvirt.api.NetworkingProvider;
47 import org.opendaylight.ovsdb.openstack.netvirt.api.NetworkingProviderManager;
48 import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheListener;
49 import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheManager;
50 import org.opendaylight.ovsdb.openstack.netvirt.api.OutboundNatProvider;
51 import org.opendaylight.ovsdb.openstack.netvirt.api.OvsdbInventoryListener;
52 import org.opendaylight.ovsdb.openstack.netvirt.api.OvsdbInventoryService;
53 import org.opendaylight.ovsdb.openstack.netvirt.api.RoutingProvider;
54 import org.opendaylight.ovsdb.openstack.netvirt.api.SecurityServicesManager;
55 import org.opendaylight.ovsdb.openstack.netvirt.api.TenantNetworkManager;
56 import org.opendaylight.ovsdb.openstack.netvirt.api.VlanConfigurationCache;
57 import org.opendaylight.ovsdb.openstack.netvirt.impl.BridgeConfigurationManagerImpl;
58 import org.opendaylight.ovsdb.openstack.netvirt.impl.ConfigurationServiceImpl;
59 import org.opendaylight.ovsdb.openstack.netvirt.impl.EventDispatcherImpl;
60 import org.opendaylight.ovsdb.openstack.netvirt.impl.OvsdbInventoryServiceImpl;
61 import org.opendaylight.ovsdb.openstack.netvirt.impl.NeutronL3Adapter;
62 import org.opendaylight.ovsdb.openstack.netvirt.impl.NodeCacheManagerImpl;
63 import org.opendaylight.ovsdb.openstack.netvirt.impl.OpenstackRouter;
64 import org.opendaylight.ovsdb.openstack.netvirt.impl.ProviderNetworkManagerImpl;
65 import org.opendaylight.ovsdb.openstack.netvirt.impl.SecurityServicesImpl;
66 import org.opendaylight.ovsdb.openstack.netvirt.impl.TenantNetworkManagerImpl;
67 import org.opendaylight.ovsdb.openstack.netvirt.impl.VlanConfigurationCacheImpl;
69 import org.osgi.framework.BundleContext;
72 * OSGi bundle activator for the OVSDB Neutron Interface.
74 public class Activator extends DependencyActivatorBase {
77 public void init(BundleContext context, DependencyManager manager) throws Exception {
79 manager.add(createComponent()
80 .setInterface(ConfigurationService.class.getName(), null)
81 .setImplementation(ConfigurationServiceImpl.class));
83 manager.add(createComponent()
84 .setInterface(BridgeConfigurationManager.class.getName(), null)
85 .setImplementation(BridgeConfigurationManagerImpl.class)
86 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
87 .add(createServiceDependency().setService(NetworkingProviderManager.class)));
89 manager.add(createComponent()
90 .setInterface(TenantNetworkManager.class.getName(), null)
91 .setImplementation(TenantNetworkManagerImpl.class)
92 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
93 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
94 .add(createServiceDependency().setService(VlanConfigurationCache.class)));
96 manager.add(createComponent()
97 .setInterface(VlanConfigurationCache.class.getName(), null)
98 .setImplementation(VlanConfigurationCacheImpl.class)
99 .add(createServiceDependency().setService(TenantNetworkManager.class)));
101 Dictionary<String, Object> floatingIPHandlerPorperties = new Hashtable<>();
102 floatingIPHandlerPorperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
103 AbstractEvent.HandlerType.NEUTRON_FLOATING_IP);
105 manager.add(createComponent()
106 .setInterface(new String[]{INeutronFloatingIPAware.class.getName(), AbstractHandler.class.getName()},
107 floatingIPHandlerPorperties)
108 .setImplementation(FloatingIPHandler.class)
109 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
110 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
112 Dictionary<String, Object> networkHandlerProperties = new Hashtable<>();
113 networkHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_NETWORK);
115 manager.add(createComponent()
116 .setInterface(new String[]{INeutronNetworkAware.class.getName(), AbstractHandler.class.getName()},
117 networkHandlerProperties)
118 .setImplementation(NetworkHandler.class)
119 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
120 .add(createServiceDependency().setService(BridgeConfigurationManager.class).setRequired(true))
121 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true))
122 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
123 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
124 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
126 Dictionary<String, Object> subnetHandlerProperties = new Hashtable<>();
127 subnetHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_SUBNET);
129 manager.add(createComponent()
130 .setInterface(new String[]{INeutronSubnetAware.class.getName(), AbstractHandler.class.getName()},
131 subnetHandlerProperties)
132 .setImplementation(SubnetHandler.class)
133 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
134 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
136 Dictionary<String, Object> portHandlerProperties = new Hashtable<>();
137 portHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_PORT);
139 manager.add(createComponent()
140 .setInterface(new String[]{INeutronPortAware.class.getName(), AbstractHandler.class.getName()},
141 portHandlerProperties)
142 .setImplementation(PortHandler.class)
143 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true))
144 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
145 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
147 Dictionary<String, Object> routerHandlerProperties = new Hashtable<>();
148 routerHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_ROUTER);
150 manager.add(createComponent()
151 .setInterface(new String[]{INeutronRouterAware.class.getName(), AbstractHandler.class.getName()},
152 routerHandlerProperties)
153 .setImplementation(RouterHandler.class)
154 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
155 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
157 Dictionary<String, Object> southboundHandlerProperties = new Hashtable<>();
158 southboundHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.SOUTHBOUND);
160 manager.add(createComponent()
161 .setInterface(new String[]{OvsdbInventoryListener.class.getName(),
162 NodeCacheListener.class.getName(),
163 AbstractHandler.class.getName()},
164 southboundHandlerProperties)
165 .setImplementation(SouthboundHandler.class)
166 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
167 .add(createServiceDependency().setService(BridgeConfigurationManager.class).setRequired(true))
168 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
169 .add(createServiceDependency().setService(NetworkingProviderManager.class).setRequired(true))
170 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
171 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true))
172 .add(createServiceDependency().setService(OvsdbInventoryService.class).setRequired(true))
173 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
175 Dictionary<String, Object> lbaasHandlerProperties = new Hashtable<>();
176 lbaasHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
177 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER);
179 manager.add(createComponent()
180 .setInterface(new String[]{INeutronLoadBalancerAware.class.getName(),
181 NodeCacheListener.class.getName(), AbstractHandler.class.getName()},
182 lbaasHandlerProperties)
183 .setImplementation(LBaaSHandler.class)
184 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
185 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
186 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
187 .add(createServiceDependency().setService(INeutronLoadBalancerPoolCRUD.class).setRequired(true))
188 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
189 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
190 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
191 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
193 Dictionary<String, Object> lbaasPoolHandlerProperties = new Hashtable<>();
194 lbaasPoolHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
195 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER_POOL);
197 manager.add(createComponent()
198 .setInterface(new String[]{INeutronLoadBalancerPoolAware.class.getName(),
199 AbstractHandler.class.getName()}, lbaasPoolHandlerProperties)
200 .setImplementation(LBaaSPoolHandler.class)
201 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
202 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
203 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
204 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
205 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
206 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
207 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
209 Dictionary<String, Object> lbaasPoolMemberHandlerProperties = new Hashtable<>();
210 lbaasPoolMemberHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
211 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER_POOL_MEMBER);
213 manager.add(createComponent()
214 .setInterface(new String[]{INeutronLoadBalancerPoolMemberAware.class.getName(),
215 AbstractHandler.class.getName()}, lbaasPoolMemberHandlerProperties)
216 .setImplementation(LBaaSPoolMemberHandler.class)
217 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
218 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
219 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
220 .add(createServiceDependency().setService(INeutronLoadBalancerPoolCRUD.class).setRequired(true))
221 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
222 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
223 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
224 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
226 Dictionary<String, Object> portSecurityHandlerProperties = new Hashtable<>();
227 portSecurityHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
228 AbstractEvent.HandlerType.NEUTRON_PORT_SECURITY);
230 manager.add(createComponent()
231 .setInterface(new String[]{INeutronSecurityRuleAware.class.getName(),
232 INeutronSecurityGroupAware.class.getName(), AbstractHandler.class.getName()},
233 portSecurityHandlerProperties)
234 .setImplementation(PortSecurityHandler.class)
235 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true)));
237 manager.add(createComponent()
238 .setInterface(new String[]{SecurityServicesManager.class.getName()}, null)
239 .setImplementation(SecurityServicesImpl.class)
240 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true)));
242 Dictionary<String, Object> fWaasHandlerProperties = new Hashtable<>();
243 fWaasHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_FWAAS);
245 manager.add(createComponent()
246 .setInterface(new String[]{INeutronFirewallAware.class.getName(),
247 INeutronFirewallRuleAware.class.getName(), INeutronFirewallPolicyAware.class.getName(),
248 AbstractHandler.class.getName()}, fWaasHandlerProperties)
249 .setImplementation(FWaasHandler.class)
250 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true)));
252 manager.add(createComponent()
253 .setInterface(NetworkingProviderManager.class.getName(), null)
254 .setImplementation(ProviderNetworkManagerImpl.class)
255 .add(createServiceDependency().setService(NetworkingProvider.class)
256 .setCallbacks("providerAdded", "providerRemoved")));
258 manager.add(createComponent()
259 .setInterface(EventDispatcher.class.getName(), null)
260 .setImplementation(EventDispatcherImpl.class)
261 .add(createServiceDependency()
262 .setService(AbstractHandler.class)
263 .setCallbacks("eventHandlerAdded", "eventHandlerRemoved")));
265 manager.add(createComponent()
266 .setInterface(NeutronL3Adapter.class.getName(), null)
267 .setImplementation(NeutronL3Adapter.class)
268 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
269 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
270 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true))
271 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
272 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
273 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
274 .add(createServiceDependency().setService(ArpProvider.class).setRequired(false))
275 .add(createServiceDependency().setService(InboundNatProvider.class).setRequired(false))
276 .add(createServiceDependency().setService(OutboundNatProvider.class).setRequired(false))
277 .add(createServiceDependency().setService(RoutingProvider.class).setRequired(false))
278 .add(createServiceDependency().setService(L3ForwardingProvider.class).setRequired(false)));
280 manager.add(createComponent()
281 .setInterface(MultiTenantAwareRouter.class.getName(), null)
282 .setImplementation(OpenstackRouter.class));
284 Dictionary<String, Object> nodeCacheManagerProperties = new Hashtable<>();
285 nodeCacheManagerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NODE);
286 manager.add(createComponent()
287 .setInterface(new String[]{NodeCacheManager.class.getName(), AbstractHandler.class.getName()},
288 nodeCacheManagerProperties)
289 .setImplementation(NodeCacheManagerImpl.class)
290 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
291 .add(createServiceDependency().setService(NodeCacheListener.class)
292 .setCallbacks("cacheListenerAdded", "cacheListenerRemoved")));
294 manager.add(createComponent()
295 .setInterface(new String[] {OvsdbInventoryService.class.getName()}, null)
296 .setImplementation(OvsdbInventoryServiceImpl.class)
297 .add(createServiceDependency().setService(OvsdbInventoryListener.class)
298 .setCallbacks("listenerAdded", "listenerRemoved"))
299 .add(createServiceDependency().setService(BindingAwareBroker.class).setRequired(true)));
303 public void destroy(BundleContext context, DependencyManager manager) throws Exception {