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 NodeCacheListener.class.getName(),
173 AbstractHandler.class.getName()},
174 southboundHandlerProperties)
175 .setImplementation(SouthboundHandler.class)
176 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
177 .add(createServiceDependency().setService(BridgeConfigurationManager.class).setRequired(true))
178 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
179 .add(createServiceDependency().setService(NetworkingProviderManager.class).setRequired(true))
180 .add(createServiceDependency().setService(OvsdbConfigurationService.class).setRequired(true))
181 .add(createServiceDependency().setService(OvsdbConnectionService.class).setRequired(true))
182 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
183 .add(createServiceDependency().setService(NeutronL3Adapter.class).setRequired(true))
184 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
186 Dictionary<String, Object> lbaasHandlerProperties = new Hashtable<>();
187 lbaasHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
188 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER);
190 manager.add(createComponent()
191 .setInterface(new String[]{INeutronLoadBalancerAware.class.getName(),
192 NodeCacheListener.class.getName(), AbstractHandler.class.getName()},
193 lbaasHandlerProperties)
194 .setImplementation(LBaaSHandler.class)
195 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
196 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
197 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
198 .add(createServiceDependency().setService(INeutronLoadBalancerPoolCRUD.class).setRequired(true))
199 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
200 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
201 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
202 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
204 Dictionary<String, Object> lbaasPoolHandlerProperties = new Hashtable<>();
205 lbaasPoolHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
206 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER_POOL);
208 manager.add(createComponent()
209 .setInterface(new String[]{INeutronLoadBalancerPoolAware.class.getName(),
210 AbstractHandler.class.getName()}, lbaasPoolHandlerProperties)
211 .setImplementation(LBaaSPoolHandler.class)
212 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
213 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
214 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
215 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
216 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
217 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
218 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
220 Dictionary<String, Object> lbaasPoolMemberHandlerProperties = new Hashtable<>();
221 lbaasPoolMemberHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
222 AbstractEvent.HandlerType.NEUTRON_LOAD_BALANCER_POOL_MEMBER);
224 manager.add(createComponent()
225 .setInterface(new String[]{INeutronLoadBalancerPoolMemberAware.class.getName(),
226 AbstractHandler.class.getName()}, lbaasPoolMemberHandlerProperties)
227 .setImplementation(LBaaSPoolMemberHandler.class)
228 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
229 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
230 .add(createServiceDependency().setService(INeutronLoadBalancerCRUD.class).setRequired(true))
231 .add(createServiceDependency().setService(INeutronLoadBalancerPoolCRUD.class).setRequired(true))
232 .add(createServiceDependency().setService(LoadBalancerProvider.class).setRequired(true))
233 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
234 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
235 .add(createServiceDependency().setService(NodeCacheManager.class).setRequired(true)));
237 Dictionary<String, Object> portSecurityHandlerProperties = new Hashtable<>();
238 portSecurityHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY,
239 AbstractEvent.HandlerType.NEUTRON_PORT_SECURITY);
241 manager.add(createComponent()
242 .setInterface(new String[]{INeutronSecurityRuleAware.class.getName(),
243 INeutronSecurityGroupAware.class.getName(), AbstractHandler.class.getName()},
244 portSecurityHandlerProperties)
245 .setImplementation(PortSecurityHandler.class)
246 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
247 .add(createServiceDependency().setService(SecurityServicesManager.class).setRequired(true)));
249 manager.add(createComponent()
250 .setInterface(new String[]{SecurityServicesManager.class.getName()}, null)
251 .setImplementation(SecurityServicesImpl.class)
252 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true)));
254 Dictionary<String, Object> fWaasHandlerProperties = new Hashtable<>();
255 fWaasHandlerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NEUTRON_FWAAS);
257 manager.add(createComponent()
258 .setInterface(new String[] {INeutronFirewallAware.class.getName(),
259 INeutronFirewallRuleAware.class.getName(), INeutronFirewallPolicyAware.class.getName(),
260 AbstractHandler.class.getName()}, fWaasHandlerProperties)
261 .setImplementation(FWaasHandler.class)
262 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true)));
264 manager.add(createComponent()
265 .setInterface(NetworkingProviderManager.class.getName(), null)
266 .setImplementation(ProviderNetworkManagerImpl.class)
267 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
268 .add(createServiceDependency().setService(NetworkingProvider.class)
269 .setCallbacks("providerAdded", "providerRemoved")));
271 manager.add(createComponent()
272 .setInterface(EventDispatcher.class.getName(), null)
273 .setImplementation(EventDispatcherImpl.class)
274 .add(createServiceDependency()
275 .setService(AbstractHandler.class)
276 .setCallbacks("eventHandlerAdded", "eventHandlerRemoved")));
278 manager.add(createComponent()
279 .setInterface(NeutronL3Adapter.class.getName(), null)
280 .setImplementation(NeutronL3Adapter.class)
281 .add(createServiceDependency().setService(ConfigurationService.class).setRequired(true))
282 .add(createServiceDependency().setService(TenantNetworkManager.class).setRequired(true))
283 .add(createServiceDependency().setService(NetworkingProviderManager.class).setRequired(true))
284 .add(createServiceDependency().setService(OvsdbConfigurationService.class).setRequired(true))
285 .add(createServiceDependency().setService(OvsdbConnectionService.class).setRequired(true))
286 .add(createServiceDependency().setService(INeutronNetworkCRUD.class).setRequired(true))
287 .add(createServiceDependency().setService(INeutronSubnetCRUD.class).setRequired(true))
288 .add(createServiceDependency().setService(INeutronPortCRUD.class).setRequired(true))
289 .add(createServiceDependency().setService(MultiTenantAwareRouter.class).setRequired(true))
290 /* ToDo, we should probably just use the NetworkingProvider interface
291 * This should provide a way of getting service implementations
292 * Either that, or we should do service lookup at runtime based on getProvider().getName()
293 * This is a shortcut as for now there will only be one implementation of these classes.
295 .add(createServiceDependency().setService(ArpProvider.class).setRequired(false))
296 .add(createServiceDependency().setService(InboundNatProvider.class).setRequired(false))
297 .add(createServiceDependency().setService(OutboundNatProvider.class).setRequired(false))
298 .add(createServiceDependency().setService(RoutingProvider.class).setRequired(false))
299 .add(createServiceDependency().setService(L3ForwardingProvider.class).setRequired(false)));
301 manager.add(createComponent()
302 .setInterface(MultiTenantAwareRouter.class.getName(), null)
303 .setImplementation(OpenstackRouter.class));
305 Dictionary<String, Object> nodeCacheManagerProperties = new Hashtable<>();
306 nodeCacheManagerProperties.put(Constants.EVENT_HANDLER_TYPE_PROPERTY, AbstractEvent.HandlerType.NODE);
307 manager.add(createComponent()
308 .setInterface(new String[]{NodeCacheManager.class.getName(), AbstractHandler.class.getName()},
309 nodeCacheManagerProperties)
310 .setImplementation(NodeCacheManagerImpl.class)
311 .add(createServiceDependency().setService(EventDispatcher.class).setRequired(true))
312 .add(createServiceDependency().setService(NodeCacheListener.class)
313 .setCallbacks("cacheListenerAdded", "cacheListenerRemoved")));
317 public void destroy(BundleContext context, DependencyManager manager) throws Exception {