}
/* For vlan network types add physical port to br-net. */
- if (network.getProviderNetworkType().equalsIgnoreCase("vlan")) {
+ if (network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VLAN)) {
String phyNetName = AdminConfigManager.getManager().getPhysicalInterfaceName(node, network.getProviderPhysicalNetwork());
status = addPortToBridge(node, brNet, phyNetName);
if (!status.isSuccess()) {
}
/* For vlan network types add physical port to br-int. */
- if (network.getProviderNetworkType().equalsIgnoreCase("vlan")) {
+ if (network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VLAN)) {
String phyNetName = AdminConfigManager.getManager().getPhysicalInterfaceName(node, network.getProviderPhysicalNetwork());
status = addPortToBridge(node, brInt, phyNetName);
if (!status.isSuccess()) {
*/
public boolean checkAndCreateNetwork (Node node, NeutronNetwork network) {
boolean isCreated = false;
- if (network.getProviderNetworkType().equalsIgnoreCase("vlan")) {
+ if (network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VLAN)) {
if (!InternalNetworkManager.getManager().isInternalNetworkVlanReady(node, network)) {
try {
isCreated = InternalNetworkManager.getManager().createNetNetwork(node, network);
} else {
isCreated = true;
}
- } else if (network.getProviderNetworkType().equalsIgnoreCase("vxlan") ||
- network.getProviderNetworkType().equalsIgnoreCase("gre")) {
+ } else if (network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) ||
+ network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
if (!InternalNetworkManager.getManager().isInternalNetworkTunnelReady(node)) {
try {
isCreated = InternalNetworkManager.getManager().createNetNetwork(node, network);
*/
public class NetworkHandler extends BaseHandler
implements INeutronNetworkAware {
+
+ public static final String NETWORK_TYPE_VXLAN = "vxlan";
+ public static final String NETWORK_TYPE_GRE = "gre";
+ public static final String NETWORK_TYPE_VLAN = "vlan";
+
/**
* Logger instance.
*/
for (String intfUUID : interfaces.keySet()) {
Interface intf = (Interface) interfaces.get(intfUUID);
String intfType = intf.getType();
- if (intfType.equalsIgnoreCase("vxlan") || intfType.equalsIgnoreCase("gre")) {
+ if (intfType.equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) || intfType.equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
/* delete tunnel ports on this node */
logger.trace("Delete tunnel intf {}", intf);
inventoryListener.rowRemoved(node, Interface.NAME.getName(), intfUUID,
network = (NeutronNetwork)context;
}
logger.info("Delete interface " + deletedIntf.getName());
- if (deletedIntf.getType().equalsIgnoreCase("vxlan") ||
- deletedIntf.getType().equalsIgnoreCase("gre")) {
+ if (deletedIntf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) ||
+ deletedIntf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
/* delete tunnel interfaces */
this.handleInterfaceDelete(node, uuid, deletedIntf, false, null);
} else if (network != null && !network.getRouterExternal()) {
logger.debug("handleInterfaceDelete: node: {}, uuid: {}, isLastInstanceOnNode: {}, interface: {}",
node, uuid, isLastInstanceOnNode, intf);
- if (intf.getType().equalsIgnoreCase("vxlan") || intf.getType().equalsIgnoreCase("gre")) {
+ if (intf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) || intf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
/* delete tunnel interfaces */
ProviderNetworkManager.getManager().handleInterfaceDelete(intf.getType(), null, node, intf, isLastInstanceOnNode);
} else if (network != null) {
- if (!network.getProviderNetworkType().equalsIgnoreCase("vlan")) { /* vlan doesn't need a tunnel endpoint */
+ if (!network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VLAN)) { /* vlan doesn't need a tunnel endpoint */
if (AdminConfigManager.getManager().getTunnelEndPoint(node) == null) {
logger.error("Tunnel end-point configuration missing. Please configure it in Open_vSwitch Table");
return;
import org.opendaylight.ovsdb.lib.table.internal.Table;
import org.opendaylight.ovsdb.neutron.AdminConfigManager;
import org.opendaylight.ovsdb.neutron.InternalNetworkManager;
+import org.opendaylight.ovsdb.neutron.NetworkHandler;
import org.opendaylight.ovsdb.neutron.TenantNetworkManager;
import org.opendaylight.ovsdb.plugin.IConnectionServiceInternal;
import org.opendaylight.ovsdb.plugin.OVSDBConfigService;
logger.debug("handleInterfaceUpdate: networkType: {}, segmentationId: {}, srcNode: {}, intf: {}",
network.getProviderNetworkType(), network.getProviderSegmentationID(), srcNode, intf.getName());
- if (network.getProviderNetworkType().equalsIgnoreCase("vlan")) {
+ if (network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VLAN)) {
Status status = getVlanReadinessStatus(srcNode, network.getProviderSegmentationID());
if (!status.isSuccess()) {
return status;
this.programVlanRules(network, srcNode, intf);
return new Status(StatusCode.SUCCESS);
}
- } else if (network.getProviderNetworkType().equalsIgnoreCase("vxlan") ||
- network.getProviderNetworkType().equalsIgnoreCase("gre")) {
+ } else if (network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) ||
+ network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
Status status = getTunnelReadinessStatus(srcNode, network.getProviderSegmentationID());
if (!status.isSuccess()) return status;
srcNode, (network != null) ? network.getProviderNetworkType() : "",
intf.getName(), intf.getType(), isLastInstanceOnNode);
- if ((network != null) && network.getProviderNetworkType().equalsIgnoreCase("vlan")) {
+ if ((network != null) && network.getProviderNetworkType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VLAN)) {
if (isLastInstanceOnNode) {
this.removeVlanRules(network, srcNode, intf);
}
- } else if (intf.getType().equalsIgnoreCase("vxlan") || intf.getType().equalsIgnoreCase("gre")) {
+ } else if (intf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) || intf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
/* Delete tunnel port */
try {
OvsDBMap<String, String> options = intf.getOptions();
import org.opendaylight.ovsdb.neutron.AdminConfigManager;
import org.opendaylight.ovsdb.neutron.IMDSALConsumer;
import org.opendaylight.ovsdb.neutron.InternalNetworkManager;
+import org.opendaylight.ovsdb.neutron.NetworkHandler;
import org.opendaylight.ovsdb.neutron.TenantNetworkManager;
import org.opendaylight.ovsdb.plugin.IConnectionServiceInternal;
import org.opendaylight.ovsdb.plugin.OVSDBConfigService;
}
/* Program local rules based on network type */
- if (networkType.equalsIgnoreCase("gre") ||
- networkType.equalsIgnoreCase("vxlan")) {
+ if (networkType.equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE) ||
+ networkType.equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN)) {
logger.debug("Remove local bridge rules for interface {}", intf.getName());
removeLocalBridgeRules(node, dpid, segmentationId, attachedMac, localPort);
}
nodes.remove(srcNode);
logger.info("Delete intf " + intf.getName() + " isLastInstanceOnNode " + isLastInstanceOnNode);
- if (intf.getType().equalsIgnoreCase("vxlan") || intf.getType().equalsIgnoreCase("gre")) {
+ if (intf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN) || intf.getType().equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)) {
/* Delete tunnel port */
try {
OvsDBMap<String, String> options = intf.getOptions();
this.removeLocalRules(tunnelType, network.getProviderSegmentationID(),
srcNode, intf);
- if (tunnelType.equalsIgnoreCase("gre")
- || tunnelType.equalsIgnoreCase("vxlan")) {
+ if (tunnelType.equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_GRE)
+ || tunnelType.equalsIgnoreCase(NetworkHandler.NETWORK_TYPE_VXLAN)) {
for (Node dstNode : nodes) {
InetAddress src = AdminConfigManager.getManager().getTunnelEndPoint(srcNode);
InetAddress dst = AdminConfigManager.getManager().getTunnelEndPoint(dstNode);