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.neutron.spi.INeutronFirewallAware;
19 import org.opendaylight.neutron.spi.INeutronFirewallPolicyAware;
20 import org.opendaylight.neutron.spi.INeutronFirewallRuleAware;
21 import org.opendaylight.neutron.spi.INeutronFloatingIPAware;
22 import org.opendaylight.neutron.spi.INeutronLoadBalancerAware;
23 import org.opendaylight.neutron.spi.INeutronLoadBalancerCRUD;
24 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolAware;
25 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
26 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolMemberAware;
27 import org.opendaylight.neutron.spi.INeutronNetworkAware;
28 import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
29 import org.opendaylight.neutron.spi.INeutronPortAware;
30 import org.opendaylight.neutron.spi.INeutronPortCRUD;
31 import org.opendaylight.neutron.spi.INeutronRouterAware;
32 import org.opendaylight.neutron.spi.INeutronSecurityGroupAware;
33 import org.opendaylight.neutron.spi.INeutronSecurityRuleAware;
34 import org.opendaylight.neutron.spi.INeutronSubnetAware;
35 import org.opendaylight.neutron.spi.INeutronSubnetCRUD;
36 import org.opendaylight.ovsdb.openstack.netvirt.api.ArpProvider;
37 import org.opendaylight.ovsdb.openstack.netvirt.api.BridgeConfigurationManager;
38 import org.opendaylight.ovsdb.openstack.netvirt.api.ConfigurationService;
39 import org.opendaylight.ovsdb.openstack.netvirt.api.Constants;
40 import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
41 import org.opendaylight.ovsdb.openstack.netvirt.api.InboundNatProvider;
42 import org.opendaylight.ovsdb.openstack.netvirt.api.L3ForwardingProvider;
43 import org.opendaylight.ovsdb.openstack.netvirt.api.LoadBalancerProvider;
44 import org.opendaylight.ovsdb.openstack.netvirt.api.MultiTenantAwareRouter;
45 import org.opendaylight.ovsdb.openstack.netvirt.api.NetworkingProvider;
46 import org.opendaylight.ovsdb.openstack.netvirt.api.NetworkingProviderManager;
47 import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheListener;
48 import org.opendaylight.ovsdb.openstack.netvirt.api.NodeCacheManager;
49 import org.opendaylight.ovsdb.openstack.netvirt.api.OutboundNatProvider;
50 import org.opendaylight.ovsdb.openstack.netvirt.api.RoutingProvider;
51 import org.opendaylight.ovsdb.openstack.netvirt.api.SecurityServicesManager;
52 import org.opendaylight.ovsdb.openstack.netvirt.api.TenantNetworkManager;
53 import org.opendaylight.ovsdb.openstack.netvirt.api.VlanConfigurationCache;
54 import org.opendaylight.ovsdb.openstack.netvirt.impl.BridgeConfigurationManagerImpl;
55 import org.opendaylight.ovsdb.openstack.netvirt.impl.ConfigurationServiceImpl;
56 import org.opendaylight.ovsdb.openstack.netvirt.impl.EventDispatcherImpl;
57 import org.opendaylight.ovsdb.openstack.netvirt.impl.NeutronL3Adapter;
58 import org.opendaylight.ovsdb.openstack.netvirt.impl.NodeCacheManagerImpl;
59 import org.opendaylight.ovsdb.openstack.netvirt.impl.OpenstackRouter;
60 import org.opendaylight.ovsdb.openstack.netvirt.impl.ProviderNetworkManagerImpl;
61 import org.opendaylight.ovsdb.openstack.netvirt.impl.SecurityServicesImpl;
62 import org.opendaylight.ovsdb.openstack.netvirt.impl.TenantNetworkManagerImpl;
63 import org.opendaylight.ovsdb.openstack.netvirt.impl.VlanConfigurationCacheImpl;
64 import org.opendaylight.ovsdb.plugin.api.OvsdbConfigurationService;
65 import org.opendaylight.ovsdb.plugin.api.OvsdbConnectionService;
66 import org.opendaylight.ovsdb.plugin.api.OvsdbInventoryListener;
68 import org.osgi.framework.BundleContext;
71 * OSGi bundle activator for the OVSDB Neutron Interface.
73 public class Activator extends DependencyActivatorBase {
76 public void init(BundleContext context, DependencyManager manager) throws Exception {
78 manager.add(createComponent()
79 .setInterface(ConfigurationService.class.getName(), null)
80 .setImplementation(ConfigurationServiceImpl.class)
81 .add(createServiceDependency().setService(OvsdbConfigurationService.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))
88 .add(createServiceDependency().setService(OvsdbConfigurationService.class)));
90 manager.add(createComponent()
91 .setInterface(TenantNetworkManager.class.getName(), null)
92 .setImplementation(TenantNetworkManagerImpl.class)
93 .add(createServiceDependency().setService(NetworkingProviderManager.class))
94 .add(createServiceDependency().setService(OvsdbConfigurationService.class))
95 .add(createServiceDependency().setService(OvsdbConnectionService.class))
96 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
97 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
98 .add(createServiceDependency().setService(VlanConfigurationCache.class)));
100 manager.add(createComponent()
101 .setInterface(VlanConfigurationCache.class.getName(), null)
102 .setImplementation(VlanConfigurationCacheImpl.class)
103 .add(createServiceDependency().setService(OvsdbConfigurationService.class))
104 .add(createServiceDependency().setService(TenantNetworkManager.class)));
106 Dictionary<String, Object> floatingIPHandlerPorperties = new Hashtable<>();
107 floatingIPHandlerPorperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
108 AbstractEvent.HandlerType.NEUTRON_FLOATING_IP);
110 manager.add(createComponent()
111 .setInterface(new String[]{INeutronFloatingIPAware.class.getName(), AbstractHandler.class.getName()},
112 floatingIPHandlerPorperties)
113 .setImplementation(FloatingIPHandler.class)
114 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
115 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
117 Dictionary<String, Object> networkHandlerProperties = new Hashtable<>();
118 networkHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_NETWORK);
120 manager.add(createComponent()
121 .setInterface(new String[]{INeutronNetworkAware.class.getName(), AbstractHandler.class.getName()},
122 networkHandlerProperties)
123 .setImplementation(NetworkHandler.class)
124 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
125 .add(createServiceDependency().setService(BridgeConfigurationManager.class).setRequired(true))
126 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
127 .add(createServiceDependency().setService(OvsdbConfigurationService.class).setRequired(true))
128 .add(createServiceDependency().setService(OvsdbConnectionService.class).setRequired(true))
129 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
130 .add(createServiceDependency().setService(OvsdbInventoryListener.class).setRequired(true))
131 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
132 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
134 Dictionary<String, Object> subnetHandlerProperties = new Hashtable<>();
135 subnetHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_SUBNET);
137 manager.add(createComponent()
138 .setInterface(new String[]{INeutronSubnetAware.class.getName(), AbstractHandler.class.getName()},
139 subnetHandlerProperties)
140 .setImplementation(SubnetHandler.class)
141 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
142 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
144 Dictionary<String, Object> portHandlerProperties = new Hashtable<>();
145 portHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_PORT);
147 manager.add(createComponent()
148 .setInterface(new String[]{INeutronPortAware.class.getName(), AbstractHandler.class.getName()},
149 portHandlerProperties)
150 .setImplementation(PortHandler.class)
151 .add(createServiceDependency().setService(OvsdbConfigurationService.class).setRequired(true))
152 .add(createServiceDependency().setService(OvsdbConnectionService.class).setRequired(true))
153 .add(createServiceDependency().setService(OvsdbInventoryListener.class).setRequired(true))
154 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
155 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
157 Dictionary<String, Object> routerHandlerProperties = new Hashtable<>();
158 routerHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_ROUTER);
160 manager.add(createComponent()
161 .setInterface(new String[]{INeutronRouterAware.class.getName(), AbstractHandler.class.getName()},
162 routerHandlerProperties)
163 .setImplementation(RouterHandler.class)
164 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
165 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
167 Dictionary<String, Object> southboundHandlerProperties = new Hashtable<>();
168 southboundHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.SOUTHBOUND);
170 manager.add(createComponent()
171 .setInterface(new String[]{OvsdbInventoryListener.class.getName(),
172 AbstractHandler.class.getName()},
173 southboundHandlerProperties)
174 .setImplementation(SouthboundHandler.class)
175 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
176 .add(createServiceDependency().setService(BridgeConfigurationManager.class).setRequired(true))
177 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
178 .add(createServiceDependency().setService(NetworkingProviderManager.class).setRequired(true))
179 .add(createServiceDependency().setService(OvsdbConfigurationService.class).setRequired(true))
180 .add(createServiceDependency().setService(OvsdbConnectionService.class).setRequired(true))
181 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
182 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true)));
184 Dictionary<String, Object> lbaasHandlerProperties = new Hashtable<>();
185 lbaasHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
186 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER);
188 manager.add(createComponent()
189 .setInterface(new String[]{INeutronLoadBalancerAware.class.getName(),
190 NodeCacheListener.class.getName(), AbstractHandler.class.getName()},
191 lbaasHandlerProperties)
192 .setImplementation(LBaaSHandler.class)
193 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
194 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
195 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
196 .add(createServiceDependency().setService(INeutronLoadBalancerPoolCRUD.class).setRequired(true))
197 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
198 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
199 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
200 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
202 Dictionary<String, Object> lbaasPoolHandlerProperties = new Hashtable<>();
203 lbaasPoolHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
204 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER_POOL);
206 manager.add(createComponent()
207 .setInterface(new String[]{INeutronLoadBalancerPoolAware.class.getName(),
208 AbstractHandler.class.getName()}, lbaasPoolHandlerProperties)
209 .setImplementation(LBaaSPoolHandler.class)
210 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
211 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
212 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
213 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
214 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
215 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
216 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
218 Dictionary<String, Object> lbaasPoolMemberHandlerProperties = new Hashtable<>();
219 lbaasPoolMemberHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
220 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER_POOL_MEMBER);
222 manager.add(createComponent()
223 .setInterface(new String[]{INeutronLoadBalancerPoolMemberAware.class.getName(),
224 AbstractHandler.class.getName()}, lbaasPoolMemberHandlerProperties)
225 .setImplementation(LBaaSPoolMemberHandler.class)
226 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
227 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
228 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
229 .add(createServiceDependency().setService(INeutronLoadBalancerPoolCRUD.class).setRequired(true))
230 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
231 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
232 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
233 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
235 Dictionary<String, Object> portSecurityHandlerProperties = new Hashtable<>();
236 portSecurityHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
237 AbstractEvent.HandlerType.NEUTRON_PORT_SECURITY);
239 manager.add(createComponent()
240 .setInterface(new String[]{INeutronSecurityRuleAware.class.getName(),
241 INeutronSecurityGroupAware.class.getName(), AbstractHandler.class.getName()},
242 portSecurityHandlerProperties)
243 .setImplementation(PortSecurityHandler.class)
244 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
245 .add(createServiceDependency().setService(SecurityServicesManager.class).setRequired(true)));
247 manager.add(createComponent()
248 .setInterface(new String[]{SecurityServicesManager.class.getName()}, null)
249 .setImplementation(SecurityServicesImpl.class)
250 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true)));
252 Dictionary<String, Object> fWaasHandlerProperties = new Hashtable<>();
253 fWaasHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_FWAAS);
255 manager.add(createComponent()
256 .setInterface(new String[] {INeutronFirewallAware.class.getName(),
257 INeutronFirewallRuleAware.class.getName(), INeutronFirewallPolicyAware.class.getName(),
258 AbstractHandler.class.getName()}, fWaasHandlerProperties)
259 .setImplementation(FWaasHandler.class)
260 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true)));
262 manager.add(createComponent()
263 .setInterface(NetworkingProviderManager.class.getName(), null)
264 .setImplementation(ProviderNetworkManagerImpl.class)
265 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
266 .add(createServiceDependency().setService(NetworkingProvider.class)
267 .setCallbacks("providerAdded", "providerRemoved")));
269 manager.add(createComponent()
270 .setInterface(EventDispatcher.class.getName(), null)
271 .setImplementation(EventDispatcherImpl.class)
272 .add(createServiceDependency()
273 .setService(AbstractHandler.class)
274 .setCallbacks("eventHandlerAdded", "eventHandlerRemoved")));
276 manager.add(createComponent()
277 .setInterface(NeutronL3Adapter.class.getName(), null)
278 .setImplementation(NeutronL3Adapter.class)
279 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
280 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
281 .add(createServiceDependency().setService(NetworkingProviderManager.class).setRequired(true))
282 .add(createServiceDependency().setService(OvsdbConfigurationService.class).setRequired(true))
283 .add(createServiceDependency().setService(OvsdbConnectionService.class).setRequired(true))
284 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
285 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
286 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
287 .add(createServiceDependency().setService(MultiTenantAwareRouter.class).setRequired(true))
288 /* ToDo, we should probably just use the NetworkingProvider interface
289 * This should provide a way of getting service implementations
290 * Either that, or we should do service lookup at runtime based on getProvider().getName()
291 * This is a shortcut as for now there will only be one implementation of these classes.
293 .add(createServiceDependency().setService(ArpProvider.class).setRequired(false))
294 .add(createServiceDependency().setService(InboundNatProvider.class).setRequired(false))
295 .add(createServiceDependency().setService(OutboundNatProvider.class).setRequired(false))
296 .add(createServiceDependency().setService(RoutingProvider.class).setRequired(false))
297 .add(createServiceDependency().setService(L3ForwardingProvider.class).setRequired(false)));
299 manager.add(createComponent()
300 .setInterface(MultiTenantAwareRouter.class.getName(), null)
301 .setImplementation(OpenstackRouter.class));
303 Dictionary<String, Object> nodeCacheManagerProperties = new Hashtable<>();
304 nodeCacheManagerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NODE);
305 manager.add(createComponent()
306 .setInterface(new String[]{NodeCacheManager.class.getName(), AbstractHandler.class.getName()},
307 nodeCacheManagerProperties)
308 .setImplementation(NodeCacheManagerImpl.class)
309 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
310 .add(createServiceDependency().setService(NodeCacheListener.class)
311 .setCallbacks("cacheListenerAdded", "cacheListenerRemoved")));
315 public void destroy(BundleContext context, DependencyManager manager) throws Exception {