Add basic ability to add and remove interfaces
Change-Id: I11fd764304a4e7ab298336f3033a4417ba4be28d
diff --git a/incubator/api/src/main/java/org/onosproject/incubator/net/config/basics/InterfaceConfig.java b/incubator/api/src/main/java/org/onosproject/incubator/net/config/basics/InterfaceConfig.java
index af2b47d..592336c 100644
--- a/incubator/api/src/main/java/org/onosproject/incubator/net/config/basics/InterfaceConfig.java
+++ b/incubator/api/src/main/java/org/onosproject/incubator/net/config/basics/InterfaceConfig.java
@@ -17,13 +17,15 @@
package org.onosproject.incubator.net.config.basics;
import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
import com.google.common.annotations.Beta;
import com.google.common.collect.Sets;
import org.onlab.packet.MacAddress;
import org.onlab.packet.VlanId;
-import org.onosproject.net.config.Config;
import org.onosproject.incubator.net.intf.Interface;
import org.onosproject.net.ConnectPoint;
+import org.onosproject.net.config.Config;
import org.onosproject.net.host.InterfaceIpAddress;
import java.util.Set;
@@ -37,7 +39,6 @@
public static final String MAC = "mac";
public static final String VLAN = "vlan";
- public static final String IP_MISSING_ERROR = "Must have at least one IP address";
public static final String MAC_MISSING_ERROR = "Must have a MAC address for each interface";
public static final String CONFIG_VALUE_ERROR = "Error parsing config value";
@@ -53,9 +54,6 @@
try {
for (JsonNode intfNode : array) {
Set<InterfaceIpAddress> ips = getIps(intfNode);
- if (ips.isEmpty()) {
- throw new ConfigException(IP_MISSING_ERROR);
- }
if (intfNode.path(MAC).isMissingNode()) {
throw new ConfigException(MAC_MISSING_ERROR);
@@ -63,10 +61,7 @@
MacAddress mac = MacAddress.valueOf(intfNode.path(MAC).asText());
- VlanId vlan = VlanId.NONE;
- if (!intfNode.path(VLAN).isMissingNode()) {
- vlan = VlanId.vlanId(Short.valueOf(intfNode.path(VLAN).asText()));
- }
+ VlanId vlan = getVlan(intfNode);
interfaces.add(new Interface(subject, ips, mac, vlan));
}
@@ -77,13 +72,64 @@
return interfaces;
}
+ /**
+ * Adds an interface to the config.
+ *
+ * @param intf interface to add
+ */
+ public void addInterface(Interface intf) {
+ ObjectNode intfNode = array.addObject();
+ intfNode.put(MAC, intf.mac().toString());
+
+ if (!intf.ipAddresses().isEmpty()) {
+ intfNode.set(IPS, putIps(intf.ipAddresses()));
+ }
+
+ if (!intf.vlan().equals(VlanId.NONE)) {
+ intfNode.put(VLAN, intf.vlan().toString());
+ }
+ }
+
+ /**
+ * Removes an interface from the config.
+ *
+ * @param intf interface to remove
+ */
+ public void removeInterface(Interface intf) {
+ for (int i = 0; i < array.size(); i++) {
+ if (intf.vlan().equals(getVlan(node))) {
+ array.remove(i);
+ break;
+ }
+ }
+ }
+
+ private VlanId getVlan(JsonNode node) {
+ VlanId vlan = VlanId.NONE;
+ if (!node.path(VLAN).isMissingNode()) {
+ vlan = VlanId.vlanId(Short.valueOf(node.path(VLAN).asText()));
+ }
+ return vlan;
+ }
+
private Set<InterfaceIpAddress> getIps(JsonNode node) {
Set<InterfaceIpAddress> ips = Sets.newHashSet();
JsonNode ipsNode = node.get(IPS);
- ipsNode.forEach(jsonNode -> ips.add(InterfaceIpAddress.valueOf(jsonNode.asText())));
+ if (ipsNode != null) {
+ ipsNode.forEach(jsonNode ->
+ ips.add(InterfaceIpAddress.valueOf(jsonNode.asText())));
+ }
return ips;
}
+ private ArrayNode putIps(Set<InterfaceIpAddress> intfIpAddresses) {
+ ArrayNode ipArray = mapper.createArrayNode();
+
+ intfIpAddresses.forEach(i -> ipArray.add(i.toString()));
+
+ return ipArray;
+ }
+
}
diff --git a/incubator/api/src/main/java/org/onosproject/incubator/net/intf/InterfaceAdminService.java b/incubator/api/src/main/java/org/onosproject/incubator/net/intf/InterfaceAdminService.java
new file mode 100644
index 0000000..56d5aec
--- /dev/null
+++ b/incubator/api/src/main/java/org/onosproject/incubator/net/intf/InterfaceAdminService.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2015 Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onosproject.incubator.net.intf;
+
+import org.onlab.packet.VlanId;
+import org.onosproject.net.ConnectPoint;
+
+/**
+ * Provides a means to modify the interfaces configuration.
+ */
+public interface InterfaceAdminService {
+ /**
+ * Adds a new interface configuration to the system.
+ *
+ * @param intf interface to add
+ */
+ void add(Interface intf);
+
+ /**
+ * Removes an interface configuration from the system.
+ *
+ * @param connectPoint connect point of the interface
+ * @param vlanId vlan id
+ */
+ void remove(ConnectPoint connectPoint, VlanId vlanId);
+}
diff --git a/incubator/net/src/main/java/org/onosproject/incubator/net/intf/impl/InterfaceManager.java b/incubator/net/src/main/java/org/onosproject/incubator/net/intf/impl/InterfaceManager.java
index f82cdbf..0439d03 100644
--- a/incubator/net/src/main/java/org/onosproject/incubator/net/intf/impl/InterfaceManager.java
+++ b/incubator/net/src/main/java/org/onosproject/incubator/net/intf/impl/InterfaceManager.java
@@ -29,6 +29,7 @@
import org.onosproject.incubator.net.config.basics.ConfigException;
import org.onosproject.incubator.net.config.basics.InterfaceConfig;
import org.onosproject.incubator.net.intf.Interface;
+import org.onosproject.incubator.net.intf.InterfaceAdminService;
import org.onosproject.incubator.net.intf.InterfaceService;
import org.onosproject.net.ConnectPoint;
import org.onosproject.net.config.NetworkConfigEvent;
@@ -50,7 +51,8 @@
*/
@Service
@Component(immediate = true)
-public class InterfaceManager implements InterfaceService {
+public class InterfaceManager implements InterfaceService,
+ InterfaceAdminService {
private final Logger log = LoggerFactory.getLogger(getClass());
@@ -153,6 +155,54 @@
interfaces.remove(port);
}
+ @Override
+ public void add(Interface intf) {
+ if (interfaces.containsKey(intf.connectPoint())) {
+ boolean conflict = interfaces.get(intf.connectPoint()).stream()
+ .filter(i -> i.connectPoint().equals(intf.connectPoint()))
+ .filter(i -> i.mac().equals(intf.mac()))
+ .filter(i -> i.vlan().equals(intf.vlan()))
+ .findAny().isPresent();
+
+ if (conflict) {
+ log.error("Can't add interface because it conflicts with existing config");
+ return;
+ }
+ }
+
+ InterfaceConfig config =
+ configService.addConfig(intf.connectPoint(), CONFIG_CLASS);
+
+ config.addInterface(intf);
+
+ configService.applyConfig(intf.connectPoint(), CONFIG_CLASS, config.node());
+ }
+
+ @Override
+ public void remove(ConnectPoint connectPoint, VlanId vlanId) {
+ Optional<Interface> intf = interfaces.get(connectPoint).stream()
+ .filter(i -> i.vlan().equals(vlanId))
+ .findAny();
+
+ if (!intf.isPresent()) {
+ log.error("Can't find interface {}/{} to remove", connectPoint, vlanId);
+ return;
+ }
+
+ InterfaceConfig config = configService.addConfig(intf.get().connectPoint(), CONFIG_CLASS);
+ config.removeInterface(intf.get());
+
+ try {
+ if (config.getInterfaces().isEmpty()) {
+ configService.removeConfig(connectPoint, CONFIG_CLASS);
+ } else {
+ configService.applyConfig(intf.get().connectPoint(), CONFIG_CLASS, config.node());
+ }
+ } catch (ConfigException e) {
+ log.error("Error reading interfaces JSON", e);
+ }
+ }
+
/**
* Listener for network config events.
*/