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
10 package org.opendaylight.ovsdb.openstack.netvirt;
12 import java.net.HttpURLConnection;
14 import org.opendaylight.neutron.spi.INeutronFirewallAware;
15 import org.opendaylight.neutron.spi.INeutronFirewallPolicyAware;
16 import org.opendaylight.neutron.spi.INeutronFirewallRuleAware;
17 import org.opendaylight.neutron.spi.NeutronFirewall;
18 import org.opendaylight.neutron.spi.NeutronFirewallPolicy;
19 import org.opendaylight.neutron.spi.NeutronFirewallRule;
20 import org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher;
21 import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
22 import org.osgi.framework.BundleContext;
23 import org.osgi.framework.ServiceReference;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
28 * Handle requests for OpenStack Neutron v2.0 Port Firewall API calls.
30 public class FWaasHandler extends AbstractHandler
31 implements INeutronFirewallAware, INeutronFirewallRuleAware,
32 INeutronFirewallPolicyAware, ConfigInterface {
34 private static final Logger LOG = LoggerFactory.getLogger(FWaasHandler.class);
37 * Invoked when a Firewall Rules creation is requested
38 * to indicate if the specified Rule can be created.
40 * @param neutronFirewall An instance of proposed new Neutron Firewall object.
41 * @return HttpURLConnection A HTTP status code to the creation request.
44 public int canCreateNeutronFirewall(NeutronFirewall neutronFirewall) {
45 return HttpURLConnection.HTTP_CREATED;
49 public void neutronFirewallCreated(NeutronFirewall neutronFirewall) {
50 LOG.debug("Neutron Firewall created by Neutron: {}", neutronFirewall);
52 int result = canCreateNeutronFirewall(neutronFirewall);
53 if (result != HttpURLConnection.HTTP_CREATED) {
54 LOG.error("Neutron Firewall creation failed: {} ", result);
59 public int canUpdateNeutronFirewall(NeutronFirewall delta, NeutronFirewall original) {
60 return HttpURLConnection.HTTP_OK;
64 public void neutronFirewallUpdated(NeutronFirewall neutronFirewall) {
65 LOG.debug("NeutronFirewall updated from Neutron: {}", neutronFirewall);
69 public int canDeleteNeutronFirewall(NeutronFirewall neutronFirewall) {
70 return HttpURLConnection.HTTP_OK;
74 public void neutronFirewallDeleted(NeutronFirewall neutronFirewall) {
75 //TODO: Trigger flowmod removals
76 int result = canDeleteNeutronFirewall(neutronFirewall);
77 if (result != HttpURLConnection.HTTP_OK) {
78 LOG.error(" delete Neutron Firewall validation failed for result - {} ", result);
83 * Invoked when a Firewall Rule creation is requested
84 * to indicate if the specified Rule can be created.
86 * @param neutronFirewallRule An instance of proposed new Neutron Firewall Rule object.
87 * @return HttpURLConnection A HTTP status code to the creation request.
90 public int canCreateNeutronFirewallRule(NeutronFirewallRule neutronFirewallRule) {
91 return HttpURLConnection.HTTP_CREATED;
95 public void neutronFirewallRuleCreated(NeutronFirewallRule neutronFirewallRule) {
96 LOG.debug("NeutronFirewallRule created by Neutron: {}", neutronFirewallRule);
98 int result = canCreateNeutronFirewallRule(neutronFirewallRule);
99 if (result != HttpURLConnection.HTTP_CREATED) {
100 LOG.error("Neutron Firewall Rule creation failed {} ", result);
105 public int canUpdateNeutronFirewallRule(NeutronFirewallRule delta, NeutronFirewallRule original) {
106 return HttpURLConnection.HTTP_OK;
110 public void neutronFirewallRuleUpdated(NeutronFirewallRule neutronFirewallRule) {
111 LOG.debug("Neutron Firewall Rule updated from Neutron: {}", neutronFirewallRule);
115 public int canDeleteNeutronFirewallRule(NeutronFirewallRule neutronFirewallRule) {
116 return HttpURLConnection.HTTP_OK;
120 public void neutronFirewallRuleDeleted(NeutronFirewallRule neutronFirewallRule) {
121 int result = canDeleteNeutronFirewallRule(neutronFirewallRule);
122 if (result != HttpURLConnection.HTTP_OK) {
123 LOG.error(" delete Neutron Firewall Rule validation failed for result - {} ", result);
128 * Invoked when a Firewall Policy creation is requested
129 * to indicate if the specified Rule can be created.
131 * @param neutronFirewallPolicy An instance of proposed new Neutron Firewall Policy object.
132 * @return HttpURLConnection A HTTP status code to the creation request.
135 public int canCreateNeutronFirewallPolicy(NeutronFirewallPolicy neutronFirewallPolicy) {
136 return HttpURLConnection.HTTP_CREATED;
140 public void neutronFirewallPolicyCreated(NeutronFirewallPolicy neutronFirewallPolicy) {
141 LOG.debug("Neutron Firewall Policy created by Neutron: {}", neutronFirewallPolicy);
143 int result = canCreateNeutronFirewallPolicy(neutronFirewallPolicy);
144 if (result != HttpURLConnection.HTTP_CREATED) {
145 LOG.debug("Neutron Firewall Policy creation failed: {} ", result);
150 public int canUpdateNeutronFirewallPolicy(NeutronFirewallPolicy delta, NeutronFirewallPolicy original) {
151 return HttpURLConnection.HTTP_OK;
155 public void neutronFirewallPolicyUpdated(NeutronFirewallPolicy neutronFirewallPolicy) {
156 LOG.debug("Neutron Firewall Policy updated from Neutron: {}", neutronFirewallPolicy);
160 public int canDeleteNeutronFirewallPolicy(NeutronFirewallPolicy neutronFirewallPolicy) {
161 return HttpURLConnection.HTTP_OK;
165 public void neutronFirewallPolicyDeleted(NeutronFirewallPolicy neutronFirewallPolicy) {
166 int result = canDeleteNeutronFirewallPolicy(neutronFirewallPolicy);
167 if (result != HttpURLConnection.HTTP_OK) {
168 LOG.error(" delete Neutron Firewall Policy validation failed for result - {} ", result);
175 * @param abstractEvent@see org.opendaylight.ovsdb.openstack.netvirt.api.EventDispatcher
178 public void processEvent(AbstractEvent abstractEvent) {
179 if (!(abstractEvent instanceof NorthboundEvent)) {
180 LOG.error("Unable to process abstract event {}", abstractEvent);
183 NorthboundEvent ev = (NorthboundEvent) abstractEvent;
184 switch (ev.getAction()) {
185 // TODO: add handling of events here, once callbacks do something
186 // other than logging.
188 LOG.warn("Unable to process event action {}", ev.getAction());
194 public void setDependencies(BundleContext bundleContext, ServiceReference serviceReference) {
196 (EventDispatcher) ServiceHelper.getGlobalInstance(EventDispatcher.class, this);
197 eventDispatcher.eventHandlerAdded(
198 bundleContext.getServiceReference(INeutronFirewallAware.class.getName()), this);
202 public void setDependencies(Object impl) {}