--- /dev/null
+/*
+ * Copyright (C) 2013 Red Hat, Inc.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Authors : Madhu Venugopal, Brent Salisbury, Keith Burns
+ */
+package org.opendaylight.ovsdb.plugin;
+
+import java.math.BigInteger;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentMap;
+
+import org.eclipse.osgi.framework.console.CommandInterpreter;
+import org.eclipse.osgi.framework.console.CommandProvider;
+import org.opendaylight.controller.sal.connection.ConnectionConstants;
+import org.opendaylight.controller.sal.core.Node;
+import org.opendaylight.controller.sal.core.NodeConnector;
+import org.opendaylight.controller.sal.networkconfig.bridgedomain.ConfigConstants;
+import org.opendaylight.controller.sal.networkconfig.bridgedomain.IPluginInBridgeDomainConfigService;
+import org.opendaylight.controller.sal.utils.Status;
+import org.opendaylight.controller.sal.utils.StatusCode;
+import org.opendaylight.ovsdb.lib.database.OVSInstance;
+import org.opendaylight.ovsdb.lib.database.OvsdbType;
+import org.opendaylight.ovsdb.lib.message.TransactBuilder;
+import org.opendaylight.ovsdb.lib.notation.Condition;
+import org.opendaylight.ovsdb.lib.notation.Function;
+import org.opendaylight.ovsdb.lib.notation.Mutation;
+import org.opendaylight.ovsdb.lib.notation.Mutator;
+import org.opendaylight.ovsdb.lib.notation.OvsDBMap;
+import org.opendaylight.ovsdb.lib.notation.OvsDBSet;
+import org.opendaylight.ovsdb.lib.notation.UUID;
+import org.opendaylight.ovsdb.lib.operations.DeleteOperation;
+import org.opendaylight.ovsdb.lib.operations.InsertOperation;
+import org.opendaylight.ovsdb.lib.operations.MutateOperation;
+import org.opendaylight.ovsdb.lib.operations.Operation;
+import org.opendaylight.ovsdb.lib.operations.OperationResult;
+import org.opendaylight.ovsdb.lib.operations.UpdateOperation;
+import org.opendaylight.ovsdb.lib.table.Bridge;
+import org.opendaylight.ovsdb.lib.table.Controller;
+import org.opendaylight.ovsdb.lib.table.Interface;
+import org.opendaylight.ovsdb.lib.table.Manager;
+import org.opendaylight.ovsdb.lib.table.Mirror;
+import org.opendaylight.ovsdb.lib.table.NetFlow;
+import org.opendaylight.ovsdb.lib.table.Open_vSwitch;
+import org.opendaylight.ovsdb.lib.table.Port;
+import org.opendaylight.ovsdb.lib.table.Qos;
+import org.opendaylight.ovsdb.lib.table.Queue;
+import org.opendaylight.ovsdb.lib.table.SFlow;
+import org.opendaylight.ovsdb.lib.table.SSL;
+import org.opendaylight.ovsdb.lib.table.Table;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.FrameworkUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.common.util.concurrent.ListenableFuture;
+
+public class ConfigurationService implements IPluginInBridgeDomainConfigService, OVSDBConfigService,
+ CommandProvider
+{
+ private static final Logger logger = LoggerFactory
+ .getLogger(ConfigurationService.class);
+
+ IConnectionServiceInternal connectionService;
+ InventoryServiceInternal inventoryServiceInternal;
+ boolean forceConnect = false;
+
+ void init() {
+ }
+
+ /**
+ * Function called by the dependency manager when at least one dependency
+ * become unsatisfied or when the component is shutting down because for
+ * example bundle is being stopped.
+ *
+ */
+ void destroy() {
+ }
+
+ /**
+ * Function called by dependency manager after "init ()" is called and after
+ * the services provided by the class are registered in the service registry
+ *
+ */
+ void start() {
+ registerWithOSGIConsole();
+ }
+
+ private void registerWithOSGIConsole() {
+ BundleContext bundleContext = FrameworkUtil.getBundle(this.getClass())
+ .getBundleContext();
+ bundleContext.registerService(CommandProvider.class.getName(), this,
+ null);
+ }
+
+ /**
+ * Function called by the dependency manager before the services exported by
+ * the component are unregistered, this will be followed by a "destroy ()"
+ * calls
+ *
+ */
+ void stop() {
+ }
+
+ public void setConnectionServiceInternal(IConnectionServiceInternal connectionService) {
+ this.connectionService = connectionService;
+ }
+
+ public void unsetConnectionServiceInternal(IConnectionServiceInternal connectionService) {
+ if (this.connectionService == connectionService) {
+ this.connectionService = null;
+ }
+ }
+
+ public void setInventoryServiceInternal(InventoryServiceInternal inventoryServiceInternal) {
+ this.inventoryServiceInternal = inventoryServiceInternal;
+ }
+
+ public void unsetInventoryServiceInternal(InventoryServiceInternal inventoryServiceInternal) {
+ if (this.inventoryServiceInternal == inventoryServiceInternal) {
+ this.inventoryServiceInternal = null;
+ }
+ }
+
+ private Connection getConnection (Node node) {
+ Connection connection = connectionService.getConnection(node);
+ if (connection == null || !connection.getChannel().isActive()) {
+ return null;
+ }
+
+ return connection;
+ }
+
+ /**
+ * Add a new bridge
+ * @param node Node serving this configuration service
+ * @param bridgeIdentifier String representation of a Bridge Connector
+ * @return Bridge Connector configurations
+ */
+ @Override
+ public Status createBridgeDomain(Node node, String bridgeIdentifier,
+ Map<ConfigConstants, Object> configs) {
+ try{
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, Open_vSwitch.NAME.getName());
+ String newBridge = "new_bridge";
+ String newInterface = "new_interface";
+ String newPort = "new_port";
+ String newSwitch = "new_switch";
+
+ Operation addSwitchRequest = null;
+
+ if(ovsTable != null){
+ String ovsTableUUID = (String) ovsTable.keySet().toArray()[0];
+ UUID bridgeUuidPair = new UUID(newBridge);
+ Mutation bm = new Mutation("bridges", Mutator.INSERT, bridgeUuidPair);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(ovsTableUUID);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addSwitchRequest = new MutateOperation(Open_vSwitch.NAME.getName(), where, mutations);
+ }
+ else{
+ Open_vSwitch ovsTableRow = new Open_vSwitch();
+ OvsDBSet<UUID> bridges = new OvsDBSet<UUID>();
+ UUID bridgeUuidPair = new UUID(newBridge);
+ bridges.add(bridgeUuidPair);
+ ovsTableRow.setBridges(bridges);
+ addSwitchRequest = new InsertOperation(Open_vSwitch.NAME.getName(), newSwitch, ovsTableRow);
+ }
+
+ Bridge bridgeRow = new Bridge();
+ bridgeRow.setName(bridgeIdentifier);
+ OvsDBSet<UUID> ports = new OvsDBSet<UUID>();
+ UUID port = new UUID(newPort);
+ ports.add(port);
+ bridgeRow.setPorts(ports);
+ InsertOperation addBridgeRequest = new InsertOperation(Bridge.NAME.getName(), newBridge, bridgeRow);
+
+ Port portRow = new Port();
+ portRow.setName(bridgeIdentifier);
+ OvsDBSet<UUID> interfaces = new OvsDBSet<UUID>();
+ UUID interfaceid = new UUID(newInterface);
+ interfaces.add(interfaceid);
+ portRow.setInterfaces(interfaces);
+ InsertOperation addPortRequest = new InsertOperation(Port.NAME.getName(), newPort, portRow);
+
+ Interface interfaceRow = new Interface();
+ interfaceRow.setName(bridgeIdentifier);
+ interfaceRow.setType("internal");
+ InsertOperation addIntfRequest = new InsertOperation(Interface.NAME.getName(), newInterface, interfaceRow);
+
+ /* Update config version */
+ String ovsTableUUID = (String) ovsTable.keySet().toArray()[0];
+ Mutation bm = new Mutation("next_cfg", Mutator.SUM, 1);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(ovsTableUUID);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ MutateOperation updateCfgVerRequest = new MutateOperation(Open_vSwitch.NAME.getName(), where, mutations);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addSwitchRequest,
+ addIntfRequest,
+ addPortRequest,
+ addBridgeRequest,
+ updateCfgVerRequest)));
+
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+ Status status = new Status(StatusCode.SUCCESS);
+ for (int i = 0; i < tr.size() ; i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i) != null && tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size()-1);
+ logger.error("Error creating Bridge : {}\n Error : {}\n Details : {}", bridgeIdentifier,
+ result.getError(),
+ result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ if (status.isSuccess()) {
+ setBridgeOFController(node, bridgeIdentifier);
+ }
+ return status;
+ } catch(Exception e){
+ logger.error("Error in createBridgeDomain(): ",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ /**
+ * Create a Port Attached to a Bridge
+ * Ex. ovs-vsctl add-port br0 vif0
+ * @param node Node serving this configuration service
+ * @param bridgeDomainIdentifier String representation of a Bridge Domain
+ * @param portIdentifier String representation of a user defined Port Name
+ */
+ @Override
+ public Status addPort(Node node, String bridgeIdentifier, String portIdentifier,
+ Map<ConfigConstants, Object> configs) {
+ try{
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+ if (connection != null) {
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ String newBridge = "new_bridge";
+ String newInterface = "new_interface";
+ String newPort = "new_port";
+
+ if(brTable != null){
+ Operation addBrMutRequest = null;
+ String brUuid = null;
+ for (String uuid : brTable.keySet()) {
+ Bridge bridge = (Bridge) brTable.get(uuid);
+ if (bridge.getName().contains(bridgeIdentifier)) {
+ brUuid = uuid;
+ }
+ }
+
+ UUID brUuidPair = new UUID(newPort);
+ Mutation bm = new Mutation("ports", Mutator.INSERT, brUuidPair);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(brUuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addBrMutRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+
+ OvsDBMap<String, String> options = null;
+ String type = null;
+ OvsDBSet<BigInteger> tags = null;
+ if (configs != null) {
+ type = (String) configs.get(ConfigConstants.TYPE);
+ Map<String, String> customConfigs = (Map<String, String>) configs.get(ConfigConstants.CUSTOM);
+ if (customConfigs != null) {
+ options = new OvsDBMap<String, String>();
+ for (String customConfig : customConfigs.keySet()) {
+ options.put(customConfig, customConfigs.get(customConfig));
+ }
+ }
+ }
+
+ Interface interfaceRow = new Interface();
+ interfaceRow.setName(portIdentifier);
+
+ if (type != null) {
+ if (type.equalsIgnoreCase(OvsdbType.PortType.TUNNEL.name())) {
+ interfaceRow.setType((String)configs.get(ConfigConstants.TUNNEL_TYPE));
+ if (options == null) options = new OvsDBMap<String, String>();
+ options.put("remote_ip", (String)configs.get(ConfigConstants.DEST_IP));
+ } else if (type.equalsIgnoreCase(OvsdbType.PortType.VLAN.name())) {
+ tags = new OvsDBSet<BigInteger>();
+ tags.add(BigInteger.valueOf(Integer.parseInt((String)configs.get(ConfigConstants.VLAN))));
+ } else if (type.equalsIgnoreCase(OvsdbType.PortType.PATCH.name())) {
+ interfaceRow.setType(type.toLowerCase());
+ }
+ }
+ if (options != null) {
+ interfaceRow.setOptions(options);
+ }
+
+ InsertOperation addIntfRequest = new InsertOperation(Interface.NAME.getName(),
+ newInterface, interfaceRow);
+
+ Port portRow = new Port();
+ portRow.setName(portIdentifier);
+ if (tags != null) portRow.setTag(tags);
+ OvsDBSet<UUID> interfaces = new OvsDBSet<UUID>();
+ UUID interfaceid = new UUID(newInterface);
+ interfaces.add(interfaceid);
+ portRow.setInterfaces(interfaces);
+ InsertOperation addPortRequest = new InsertOperation(Port.NAME.getName(), newPort, portRow);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>
+ (Arrays.asList(addBrMutRequest, addPortRequest, addIntfRequest)));
+
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+ Status status = new Status(StatusCode.SUCCESS);
+ for (int i = 0; i < tr.size() ; i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size()-1);
+ logger.error("Error creating Bridge : {}\n Error : {}\n Details : {}", bridgeIdentifier,
+ result.getError(),
+ result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ return status;
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+ } catch(Exception e){
+ logger.error("Error in addPort()",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ /**
+ * Implements the OVS Connection for Managers
+ *
+ * @param node Node serving this configuration service
+ * @param managerip with IP and connection types
+ */
+ @SuppressWarnings("unchecked")
+ public boolean setManager(Node node, String managerip) {
+ try{
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return false;
+ }
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return false;
+ }
+
+ if (connection != null) {
+ String newmanager = "new_manager";
+
+ OVSInstance instance = OVSInstance.monitorOVS();
+
+ Map ovsoutter = new LinkedHashMap();
+ Map ovsinner = new LinkedHashMap();
+ ArrayList ovsalist1 = new ArrayList();
+ ArrayList ovsalist2 = new ArrayList();
+ ArrayList ovsalist3 = new ArrayList();
+ ArrayList ovsalist4 = new ArrayList();
+
+ //OVS Table Update
+ ovsoutter.put("where", ovsalist1);
+ ovsalist1.add(ovsalist2);
+ ovsalist2.add("_uuid");
+ ovsalist2.add("==");
+ ovsalist2.add(ovsalist3);
+ ovsalist3.add("uuid");
+ ovsalist3.add(instance.getUuid());
+ ovsoutter.put("op", "update");
+ ovsoutter.put("table", "Open_vSwitch");
+ ovsoutter.put("row", ovsinner);
+ ovsinner.put("manager_options", ovsalist4);
+ ovsalist4.add("named-uuid");
+ ovsalist4.add(newmanager);
+
+ Map mgroutside = new LinkedHashMap();
+ Map mgrinside = new LinkedHashMap();
+
+ //Manager Table Insert
+ mgroutside.put("uuid-name", newmanager);
+ mgroutside.put("op", "insert");
+ mgroutside.put("table","Manager");
+ mgroutside.put("row", mgrinside);
+ mgrinside.put("target", managerip);
+
+ Object[] params = {"Open_vSwitch", ovsoutter, mgroutside};
+ OvsdbMessage msg = new OvsdbMessage("transact", params);
+
+ //connection.sendMessage(msg);
+
+ }
+ }catch(Exception e){
+ logger.error("Error in setManager(): ",e);
+ }
+ return true;
+ }
+
+ @Override
+ public Status addBridgeDomainConfig(Node node, String bridgeIdentfier,
+ Map<ConfigConstants, Object> configs) {
+ String mgmt = (String)configs.get(ConfigConstants.MGMT);
+ if (mgmt != null) {
+ if (setManager(node, mgmt)) return new Status(StatusCode.SUCCESS);
+ }
+ return new Status(StatusCode.BADREQUEST);
+ }
+
+ @Override
+ public Status addPortConfig(Node node, String bridgeIdentifier, String portIdentifier,
+ Map<ConfigConstants, Object> configs) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Status deletePort(Node node, String bridgeIdentifier, String portIdentifier) {
+
+ try{
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ Map<String, Table<?>> portTable = inventoryServiceInternal.getTableCache(node, Port.NAME.getName());
+ Operation delPortRequest = null;
+ String brUuid = null;
+ String portUuid = null;
+ if(brTable != null){
+ for (String uuid : brTable.keySet()) {
+ Bridge bridge = (Bridge) brTable.get(uuid);
+ if (bridge.getName().contains(bridgeIdentifier)) {
+ brUuid = uuid;
+ }
+ }
+ }
+ if(portTable != null){
+ for (String uuid : portTable.keySet()) {
+ Port port = (Port) portTable.get(uuid);
+ if (port.getName().contains(portIdentifier)) {
+ portUuid = uuid;
+ }
+ }
+ }
+
+ UUID portUuidPair = new UUID(portUuid);
+ Mutation bm = new Mutation("ports", Mutator.DELETE, portUuidPair);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(brUuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ delPortRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(delPortRequest)));
+
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+ Status status = new Status(StatusCode.SUCCESS);
+ for (int i = 0; i < tr.size() ; i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size()-1);
+ logger.error("Error creating Bridge : {}\n Error : {}\n Details : {}", bridgeIdentifier,
+ result.getError(),
+ result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ return status;
+ } catch(Exception e){
+ logger.error("Error in deletePort()",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ @Override
+ public Node getBridgeDomainNode(Node node, String bridgeIdentifier) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Map<ConfigConstants, Object> getPortConfigs(Node node, String bridgeIdentifier,
+ String portIdentifier) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Status removeBridgeDomainConfig(Node node, String bridgeIdentifier,
+ Map<ConfigConstants, Object> configs) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Status removePortConfig(Node node, String bridgeIdentifier, String portIdentifier,
+ Map<ConfigConstants, Object> configs) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Status deleteBridgeDomain(Node node, String bridgeIdentifier) {
+
+ try {
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, Open_vSwitch.NAME.getName());
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ Operation delBrRequest = null;
+ String ovsUuid = null;
+ String brUuid = null;
+
+ if (brTable != null) {
+ for (String uuid : brTable.keySet()) {
+ Bridge bridge = (Bridge) brTable.get(uuid);
+ if (bridge.getName().contains(bridgeIdentifier)) {
+ brUuid = uuid;
+ }
+ }
+ }
+ if (ovsTable != null) {
+ ovsUuid = (String) ovsTable.keySet().toArray()[0];
+ }
+ UUID bridgeUuidPair = new UUID(brUuid);
+ Mutation bm = new Mutation("bridges", Mutator.DELETE, bridgeUuidPair);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(ovsUuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ delBrRequest = new MutateOperation(Open_vSwitch.NAME.getName(), where, mutations);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(delBrRequest)));
+
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+ Status status = new Status(StatusCode.SUCCESS);
+ for (int i = 0; i < tr.size(); i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i) != null && tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size() - 1);
+ logger.error("Error deleting Bridge : {}\n Error : {}\n Details : {}",
+ bridgeIdentifier, result.getError(), result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ return status;
+ } catch (Exception e) {
+ logger.error("Error in deleteBridgeDomain(): ",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ @Override
+ public Map<ConfigConstants, Object> getBridgeDomainConfigs(Node node, String bridgeIdentifier) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public List<String> getBridgeDomains(Node node) {
+ List<String> brlist = new ArrayList<String>();
+ Map<String, Table<?>> brTableCache = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ if(brTableCache != null){
+ for (String uuid : brTableCache.keySet()) {
+ Bridge bridge = (Bridge) brTableCache.get(uuid);
+ brlist.add(bridge.getName());
+ }
+ }
+ return brlist;
+ }
+
+ @Override
+ public NodeConnector getNodeConnector(Node arg0, String arg1, String arg2) {
+ return null;
+ }
+
+ Boolean setBridgeOFController(Node node, String bridgeIdentifier) {
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return false;
+ }
+
+ try{
+ Map<String, Table<?>> brTableCache = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ for (String uuid : brTableCache.keySet()) {
+ Bridge bridge = (Bridge)brTableCache.get(uuid);
+ if (bridge.getName().contains(bridgeIdentifier)) {
+ return connectionService.setOFController(node, uuid);
+ }
+ }
+ } catch(Exception e) {
+ logger.error("Error in setBridgeOFController()",e);
+ }
+ return false;
+ }
+
+ @Override
+ public StatusWithUuid insertRow(Node node, String tableName, String parent_uuid, Table<?> row) {
+ logger.debug("tableName : {}, parent_uuid : {} Row : {}", tableName, parent_uuid, row.toString());
+ StatusWithUuid statusWithUUID = null;
+
+ // Schema based Table handling will help fix this static Table handling.
+
+ if (row.getTableName().getName().equalsIgnoreCase("Bridge")) {
+ statusWithUUID = insertBridgeRow(node, parent_uuid, (Bridge)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Capability")) {
+ return new StatusWithUuid(StatusCode.NOTIMPLEMENTED, "Insert operation for this Table is not implemented yet.");
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Controller")) {
+ statusWithUUID = insertControllerRow(node, parent_uuid, (Controller)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Interface")) {
+ statusWithUUID = insertInterfaceRow(node, parent_uuid, (Interface)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Manager")) {
+ statusWithUUID = insertManagerRow(node, parent_uuid, (Manager)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Mirror")) {
+ statusWithUUID = insertMirrorRow(node, parent_uuid, (Mirror)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("NetFlow")) {
+ statusWithUUID = insertNetFlowRow(node, parent_uuid, (NetFlow)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Open_vSwitch")) {
+ statusWithUUID = insertOpen_vSwitchRow(node, (Open_vSwitch)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Port")) {
+ statusWithUUID = insertPortRow(node, parent_uuid, (Port)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("QoS")) {
+ statusWithUUID = insertQosRow(node, parent_uuid, (Qos)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("Queue")) {
+ statusWithUUID = insertQueueRow(node, parent_uuid, (Queue)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("sFlow")) {
+ statusWithUUID = insertSflowRow(node, parent_uuid, (SFlow)row);
+ }
+ else if (row.getTableName().getName().equalsIgnoreCase("SSL")) {
+ statusWithUUID = insertSSLRow(node, parent_uuid, (SSL)row);
+ }
+ return statusWithUUID;
+ }
+
+
+ @Override
+ public Status updateRow (Node node, String tableName, String parentUUID, String rowUUID, Table<?> row) {
+ try{
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, Open_vSwitch.NAME.getName());
+
+ if (ovsTable == null) {
+ return new Status(StatusCode.NOTFOUND, "There are no Open_vSwitch instance in the Open_vSwitch table");
+ }
+
+ UUID uuid = new UUID(rowUUID);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ Operation updateRequest = new UpdateOperation(tableName, where, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(updateRequest)));
+
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+ Status status = new Status(StatusCode.SUCCESS);
+ for (int i = 0; i < tr.size() ; i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i) != null && tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size()-1);
+ logger.error("Error Updating Row : {}/{}\n Error : {}\n Details : {}", tableName, row,
+ result.getError(),
+ result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ if (status.isSuccess()) {
+ status = new Status(StatusCode.SUCCESS);
+ }
+ return status;
+ } catch(Exception e){
+ logger.error("Error in updateRow(): ",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ @Override
+ public Status deleteRow(Node node, String tableName, String uuid) {
+ if (tableName.equalsIgnoreCase("Bridge")) {
+ return deleteBridgeRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Capbility")) {
+ return new Status(StatusCode.NOTIMPLEMENTED, "Delete operation for this Table is not implemented yet.");
+ }
+ else if (tableName.equalsIgnoreCase("Controller")) {
+ return deleteControllerRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Interface")) {
+ return deleteInterfaceRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Manager")) {
+ return deleteManagerRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Mirror")) {
+ return deleteMirrorRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("NetFlow")) {
+ return deleteNetFlowRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Open_vSwitch")) {
+ return deleteOpen_vSwitchRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Port")) {
+ return deletePortRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("QoS")) {
+ return deleteQosRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("Queue")) {
+ return deleteQueueRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("sFlow")) {
+ return deleteSflowRow(node, uuid);
+ }
+ else if (tableName.equalsIgnoreCase("SSL")) {
+ return deleteSSLRow(node, uuid);
+ }
+ return new Status(StatusCode.NOTFOUND, "Table "+tableName+" not supported");
+ }
+
+ @Override
+ public ConcurrentMap<String, Table<?>> getRows(Node node, String tableName) throws Exception{
+ try{
+ if (inventoryServiceInternal == null) {
+ throw new Exception("Inventory Service is Unavailable.");
+ }
+ ConcurrentMap<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, tableName);
+ return ovsTable;
+ } catch(Exception e){
+ throw new Exception("Unable to read table due to "+e.getMessage());
+ }
+ }
+
+ @Override
+ public Table<?> getRow(Node node, String tableName, String uuid) throws Exception {
+ try{
+ if (inventoryServiceInternal == null) {
+ throw new Exception("Inventory Service is Unavailable.");
+ }
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, tableName);
+ if (ovsTable == null) return null;
+ return ovsTable.get(uuid);
+ } catch(Exception e){
+ throw new Exception("Unable to read table due to "+e.getMessage());
+ }
+ }
+
+ @Override
+ public String getSerializedRows(Node node, String tableName) throws Exception{
+ try{
+ Map<String, Table<?>> ovsTable = this.getRows(node, tableName);
+ if (ovsTable == null) return null;
+ ObjectMapper mapper = new ObjectMapper();
+ return mapper.writeValueAsString(ovsTable);
+ } catch(Exception e){
+ throw new Exception("Unable to read table due to "+e.getMessage());
+ }
+ }
+
+ @Override
+ public String getSerializedRow(Node node, String tableName, String uuid) throws Exception {
+ try{
+ Table<?> row = this.getRow(node, tableName, uuid);
+ if (row == null) return null;
+ ObjectMapper mapper = new ObjectMapper();
+ return mapper.writeValueAsString(row);
+ } catch(Exception e){
+ throw new Exception("Unable to read table due to "+e.getMessage());
+ }
+ }
+
+ @Override
+ public List<String> getTables(Node node) {
+ ConcurrentMap<String, ConcurrentMap<String, Table<?>>> cache = inventoryServiceInternal.getCache(node);
+ if (cache == null) return null;
+ return new ArrayList<String>(cache.keySet());
+ }
+
+ private StatusWithUuid insertBridgeRow(Node node, String open_VSwitch_uuid, Bridge bridgeRow) {
+
+ String insertErrorMsg = "bridge";
+ String rowName=bridgeRow.getName();
+
+ try{
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, Open_vSwitch.NAME.getName());
+
+ if (ovsTable == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "There are no Open_vSwitch instance in the Open_vSwitch table");
+ }
+
+ String newBridge = "new_bridge";
+
+ Operation addSwitchRequest = null;
+
+ String ovsTableUUID = open_VSwitch_uuid;
+ if (ovsTableUUID == null) ovsTableUUID = (String) ovsTable.keySet().toArray()[0];
+ UUID bridgeUuid = new UUID(newBridge);
+ Mutation bm = new Mutation("bridges", Mutator.INSERT, bridgeUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(ovsTableUUID);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addSwitchRequest = new MutateOperation(Open_vSwitch.NAME.getName(), where, mutations);
+
+ InsertOperation addBridgeRequest = new InsertOperation(Bridge.NAME.getName(), newBridge, bridgeRow);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addSwitchRequest,
+ addBridgeRequest)));
+
+ int bridgeInsertIndex = transaction.getRequests().indexOf(addBridgeRequest);
+
+ return _insertTableRow(node,transaction,bridgeInsertIndex,insertErrorMsg,rowName);
+
+ } catch(Exception e){
+ logger.error("Error in insertBridgeRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+
+ private StatusWithUuid insertPortRow(Node node, String bridge_uuid, Port portRow) {
+
+ String insertErrorMsg = "port";
+ String rowName=portRow.getName();
+
+ try{
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ if (brTable == null || brTable.get(bridge_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Bridge with UUID "+bridge_uuid+" Not found");
+ }
+ String newPort = "new_port";
+ UUID portUUID = new UUID(newPort);
+ Mutation bm = new Mutation("ports", Mutator.INSERT, portUUID);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(bridge_uuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ Operation addBrMutRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+
+ // Default OVS schema is to have 1 or more interface part of Bridge. Hence it is mandatory to
+ // Insert an Interface in a Port add case
+
+ String newInterface = "new_interface";
+ Interface interfaceRow = new Interface();
+ interfaceRow.setName(portRow.getName());
+ InsertOperation addIntfRequest = new InsertOperation(Interface.NAME.getName(),
+ newInterface, interfaceRow);
+
+ OvsDBSet<UUID> interfaces = new OvsDBSet<UUID>();
+ UUID interfaceid = new UUID(newInterface);
+ interfaces.add(interfaceid);
+ portRow.setInterfaces(interfaces);
+
+ InsertOperation addPortRequest = new InsertOperation(Port.NAME.getName(), newPort, portRow);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>
+ (Arrays.asList(addBrMutRequest, addPortRequest, addIntfRequest)));
+ int portInsertIndex = transaction.getRequests().indexOf(addPortRequest);
+
+ return _insertTableRow(node,transaction,portInsertIndex,insertErrorMsg,rowName);
+
+ } catch (Exception e) {
+ logger.error("Error in insertPortRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertInterfaceRow(Node node, String port_uuid, Interface interfaceRow) {
+
+ String insertErrorMsg = "interface";
+ String rowName=interfaceRow.getName();
+
+ try{
+
+ // Interface table must have entry in Port table, checking port table for port
+ Map<String, Table<?>> portTable = inventoryServiceInternal.getTableCache(node, Port.NAME.getName());
+ if (portTable == null || portTable.get(port_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Port with UUID "+port_uuid+" Not found");
+ }
+ // MUTATOR, need to insert the interface UUID to LIST of interfaces in PORT TABLE for port_uuid
+ String newInterface = "new_interface";
+ UUID interfaceUUID = new UUID(newInterface);
+ Mutation portTableMutation = new Mutation("interfaces", Mutator.INSERT, interfaceUUID); // field name to append is "interfaces"
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(portTableMutation);
+
+ // Create the Operation which will be used in Transact to perform the PORT TABLE mutation
+ UUID uuid = new UUID(port_uuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ Operation addPortMutationRequest = new MutateOperation(Port.NAME.getName(), where, mutations);
+
+ // Create the interface row request
+ InsertOperation addIntfRequest = new InsertOperation(Interface.NAME.getName(),newInterface, interfaceRow);
+
+ // Transaction to insert/modify tables - validate using "sudo ovsdb-client dump" on host running OVSDB process
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(addIntfRequest,addPortMutationRequest)));
+
+ // Check the results. Iterates over the results of the Array of transaction Operations, and reports STATUS
+ int interfaceInsertIndex = transaction.getRequests().indexOf(addIntfRequest);
+
+ return _insertTableRow(node,transaction,interfaceInsertIndex,insertErrorMsg,rowName);
+
+ } catch (Exception e) {
+ logger.error("Error in insertInterfaceRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertOpen_vSwitchRow(Node node, Open_vSwitch row) {
+ return new StatusWithUuid(StatusCode.NOTIMPLEMENTED, "Insert operation for this Table is not implemented yet.");
+ }
+
+ private StatusWithUuid insertControllerRow(Node node, String bridge_uuid, Controller row) {
+
+ String insertErrorMsg = "controller";
+ String rowName=row.getTableName().toString();
+
+ try{
+
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ if (brTable == null || brTable.get(bridge_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Bridge with UUID "+bridge_uuid+" Not found");
+ }
+
+ Map<String, Table<?>> controllerCache = inventoryServiceInternal.getTableCache(node, Controller.NAME.getName());
+
+ String uuid_name = "new_controller";
+ boolean controllerExists = false;
+ if (controllerCache != null) {
+ for (String uuid : controllerCache.keySet()) {
+ Controller controller = (Controller)controllerCache.get(uuid);
+ if (controller.getTarget().equals(row.getTarget())) {
+ uuid_name = uuid;
+ controllerExists = true;
+ break;
+ }
+ }
+ }
+
+ UUID controllerUUID = new UUID(uuid_name);
+ Mutation bm = new Mutation("controller", Mutator.INSERT, controllerUUID);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(bm);
+
+ UUID uuid = new UUID(bridge_uuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ Operation addBrMutRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+ InsertOperation addControllerRequest = null;
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperation(addBrMutRequest);
+ int portInsertIndex = -1;
+ if (!controllerExists) {
+ addControllerRequest = new InsertOperation(Controller.NAME.getName(), uuid_name, row);
+ transaction.addOperation(addControllerRequest);
+ portInsertIndex = transaction.getRequests().indexOf(addControllerRequest);
+ }
+
+ StatusWithUuid status = _insertTableRow(node,transaction,portInsertIndex,insertErrorMsg,rowName);
+ if (status.isSuccess() && controllerExists) {
+ // We won't get the uuid from the transact, so we set it here
+ status = new StatusWithUuid(status.getCode(), controllerUUID);
+ }
+ return status;
+
+ } catch (Exception e) {
+ logger.error("Error in insertControllerRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertSSLRow(Node node, String parent_uuid, SSL row) {
+ String insertErrorMsg = "SSL";
+ String rowName=row.NAME.getName();
+
+ try{
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, Open_vSwitch.NAME.getName());
+
+ if (ovsTable == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "There are no Open_vSwitch instance in the Open_vSwitch table");
+ }
+
+ String newSSL = "new_SSL";
+
+ Operation addOpen_vSwitchRequest = null;
+
+ String ovsTableUUID = parent_uuid;
+ if (ovsTableUUID == null) ovsTableUUID = (String) ovsTable.keySet().toArray()[0];
+ UUID sslUuid = new UUID(newSSL);
+ Mutation sslMutation = new Mutation("ssl", Mutator.INSERT, sslUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(sslMutation);
+
+ UUID uuid = new UUID(ovsTableUUID);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addOpen_vSwitchRequest = new MutateOperation(Open_vSwitch.NAME.getName(), where, mutations);
+
+ InsertOperation addSSLRequest = new InsertOperation(SSL.NAME.getName(), newSSL, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addSSLRequest,
+ addOpen_vSwitchRequest)));
+
+ int sslInsertIndex = transaction.getRequests().indexOf(addSSLRequest);
+
+ return _insertTableRow(node,transaction,sslInsertIndex,insertErrorMsg,rowName);
+
+ } catch(Exception e){
+ logger.error("Error in insertSSLRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertSflowRow(Node node, String parent_uuid, SFlow row) {
+
+ String insertErrorMsg = "sFlow";
+ String rowName=row.NAME.getName();
+
+ try{
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ if (brTable == null || brTable.get(parent_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Bridge with UUID "+parent_uuid+" Not found");
+ }
+
+ if (parent_uuid == null) {
+ return new StatusWithUuid(StatusCode.BADREQUEST, "Require parent Bridge UUID.");
+ }
+
+ UUID uuid = new UUID(parent_uuid);
+
+ String newSflow = "new_sflow";
+
+ Operation addBridgeRequest = null;
+
+ UUID sflowUuid = new UUID(newSflow);
+ Mutation sflowMutation = new Mutation("sflow", Mutator.INSERT, sflowUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(sflowMutation);
+
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addBridgeRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+
+ InsertOperation addSflowRequest = new InsertOperation(SFlow.NAME.getName(), newSflow, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addSflowRequest,
+ addBridgeRequest)));
+
+ int sflowInsertIndex = transaction.getRequests().indexOf(addSflowRequest);
+
+
+ return _insertTableRow(node,transaction,sflowInsertIndex,insertErrorMsg,rowName);
+
+ } catch (Exception e) {
+ logger.error("Error in insertInterfaceRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertQueueRow(Node node, String parent_uuid, Queue row) {
+ String insertErrorMsg = "Queue";
+ String rowName=row.NAME.getName();
+
+ try{
+ Map<String, Table<?>> qosTable = inventoryServiceInternal.getTableCache(node, Qos.NAME.getName());
+ if (qosTable == null || qosTable.get(parent_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "QoS with UUID "+parent_uuid+" Not found");
+ }
+
+ if (parent_uuid == null) {
+ return new StatusWithUuid(StatusCode.BADREQUEST, "Require parent QoS UUID.");
+ }
+
+ // NOTE: Queue Table is "isroot" meaning it can have a hanging reference. This is different from
+ // standing insertRow due to the parent column type being a map, where one of the items may not be known
+ // at time of insert. Therefore this is a simple insert, rather than mutate/insert.
+ String newQueue = "new_queue";
+ InsertOperation addQueueRequest = new InsertOperation(Queue.NAME.getName(), newQueue, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(addQueueRequest)));
+
+ int queueInsertIndex = transaction.getRequests().indexOf(addQueueRequest);
+
+ return _insertTableRow(node,transaction,queueInsertIndex,insertErrorMsg,rowName);
+
+ } catch (Exception e) {
+ logger.error("Error in insertQueueRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR); }
+
+ private StatusWithUuid insertQosRow(Node node, String parent_uuid, Qos row) {
+ String insertErrorMsg = "Qos";
+ String rowName=row.NAME.getName();
+
+ try{
+
+ String newQos = "new_qos";
+
+ // QoS Table "isroot" meaning it can have hanging references. If parent_uuid is not supplied in API call this becomes a simple
+ // insert operation, rather than the typical mutate/insert parent/child insert.
+ if (parent_uuid != null) {
+ // Port (parent) table check for UUID existance.
+ Map<String, Table<?>> portTable = inventoryServiceInternal.getTableCache(node, Port.NAME.getName());
+ if (portTable == null || portTable.get(parent_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Port with UUID "+parent_uuid+" Not found");
+ }
+
+ UUID qosUuid = new UUID(newQos);
+ Mutation qosMutation = new Mutation("qos", Mutator.INSERT, qosUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(qosMutation);
+
+ Operation addPortRequest = null;
+ UUID uuid = new UUID(parent_uuid);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addPortRequest = new MutateOperation(Port.NAME.getName(), where, mutations);
+
+ InsertOperation addQosRequest = new InsertOperation(Qos.NAME.getName(), newQos, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(addQosRequest,addPortRequest)));
+
+ int qosInsertIndex = transaction.getRequests().indexOf(addQosRequest);
+
+ return _insertTableRow(node,transaction,qosInsertIndex,insertErrorMsg,rowName);
+
+ } else {
+ InsertOperation addQosRequest = new InsertOperation(Qos.NAME.getName(), newQos, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(addQosRequest)));
+
+ int qosInsertIndex = transaction.getRequests().indexOf(addQosRequest);
+
+ return _insertTableRow(node,transaction,qosInsertIndex,insertErrorMsg,rowName);
+ }
+
+ } catch (Exception e) {
+ logger.error("Error in insertQosRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+
+ private StatusWithUuid insertNetFlowRow(Node node, String parent_uuid, NetFlow row) {
+ String insertErrorMsg = "netFlow";
+ String rowName=row.NAME.getName();
+
+ try{
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ if (brTable == null || brTable.get(parent_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Bridge with UUID "+parent_uuid+" Not found");
+ }
+
+ if (parent_uuid == null) {
+ return new StatusWithUuid(StatusCode.BADREQUEST, "Require parent Bridge UUID.");
+ }
+
+ UUID uuid = new UUID(parent_uuid);
+ String newNetflow = "new_netflow";
+
+ Operation addBridgeRequest = null;
+
+ UUID netFlowUuid = new UUID(newNetflow);
+ Mutation netFlowMutation = new Mutation("netflow", Mutator.INSERT, netFlowUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(netFlowMutation);
+
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addBridgeRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+
+ InsertOperation addNetflowRequest = new InsertOperation(NetFlow.NAME.getName(), newNetflow, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addNetflowRequest,
+ addBridgeRequest)));
+
+ int netflowInsertIndex = transaction.getRequests().indexOf(addNetflowRequest);
+
+
+ return _insertTableRow(node,transaction,netflowInsertIndex,insertErrorMsg,rowName);
+
+ } catch (Exception e) {
+ logger.error("Error in insertNetFlowRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertMirrorRow(Node node, String parent_uuid, Mirror row) {
+ String insertErrorMsg = "mirror";
+ String rowName=row.NAME.getName();
+
+ try{
+ Map<String, Table<?>> brTable = inventoryServiceInternal.getTableCache(node, Bridge.NAME.getName());
+ if (brTable == null || brTable.get(parent_uuid) == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "Bridge with UUID "+parent_uuid+" Not found");
+ }
+
+ if (parent_uuid == null) {
+ return new StatusWithUuid(StatusCode.BADREQUEST, "Require parent Bridge UUID.");
+ }
+
+ UUID uuid = new UUID(parent_uuid);
+ String newMirror = "new_mirror";
+
+ Operation addBridgeRequest = null;
+
+ UUID mirrorUuid = new UUID(newMirror);
+ Mutation mirrorMutation = new Mutation("mirrors", Mutator.INSERT, mirrorUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(mirrorMutation);
+
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addBridgeRequest = new MutateOperation(Bridge.NAME.getName(), where, mutations);
+
+ InsertOperation addMirrorRequest = new InsertOperation(Mirror.NAME.getName(), newMirror, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addBridgeRequest, addMirrorRequest)));
+
+ int mirrorInsertIndex = transaction.getRequests().indexOf(addMirrorRequest);
+
+ return _insertTableRow(node,transaction,mirrorInsertIndex,insertErrorMsg,rowName);
+
+ } catch (Exception e) {
+ logger.error("Error in insertMirrorRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid insertManagerRow(Node node, String parent_uuid, Manager row) {
+ String insertErrorMsg = "manager";
+ String rowName=row.NAME.getName();
+
+ try{
+ Map<String, Table<?>> ovsTable = inventoryServiceInternal.getTableCache(node, Open_vSwitch.NAME.getName());
+
+ if (ovsTable == null) {
+ return new StatusWithUuid(StatusCode.NOTFOUND, "There are no Open_vSwitch instance in the Open_vSwitch table");
+ }
+
+ String newManager = "new_manager";
+
+ Operation addSwitchRequest = null;
+
+ String ovsTableUUID = parent_uuid;
+ if (ovsTableUUID == null) ovsTableUUID = (String) ovsTable.keySet().toArray()[0];
+ UUID managerUuid = new UUID(newManager);
+ Mutation managerMutation = new Mutation("manager_options", Mutator.INSERT, managerUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(managerMutation);
+
+ UUID uuid = new UUID(ovsTableUUID);
+ Condition condition = new Condition("_uuid", Function.EQUALS, uuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ addSwitchRequest = new MutateOperation(Open_vSwitch.NAME.getName(), where, mutations);
+
+ InsertOperation addManagerRequest = new InsertOperation(Manager.NAME.getName(), newManager, row);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(
+ Arrays.asList(addSwitchRequest,
+ addManagerRequest)));
+
+ int managerInsertIndex = transaction.getRequests().indexOf(addManagerRequest);
+
+ return _insertTableRow(node,transaction,managerInsertIndex,insertErrorMsg,rowName);
+
+ } catch(Exception e){
+ logger.error("Error in insertManagerRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+ private StatusWithUuid _insertTableRow(Node node, TransactBuilder transaction, Integer insertIndex, String insertErrorMsg,String rowName){
+
+ try{
+ //Check for connection before calling RPC to perform transaction
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new StatusWithUuid(StatusCode.NOSERVICE);
+ }
+
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new StatusWithUuid(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+ StatusWithUuid status = new StatusWithUuid(StatusCode.SUCCESS);
+ for (int i = 0; i < tr.size() ; i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i) != null && tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new StatusWithUuid(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size()-1);
+ logger.error("Error creating {} : {}\n Error : {}\n Details : {}", insertErrorMsg,
+ rowName,
+ result.getError(),
+ result.getDetails());
+ status = new StatusWithUuid(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ if (status.isSuccess()) {
+ if (insertIndex >= 0 && insertIndex < tr.size() && tr.get(insertIndex) != null) {
+ UUID uuid = tr.get(insertIndex).getUuid();
+ status = new StatusWithUuid(StatusCode.SUCCESS, uuid);
+ } else {
+ // We can't get the uuid from the transact as the insertIndex is invalid or -1
+ // return null uuid.
+ status = new StatusWithUuid(StatusCode.SUCCESS, (UUID) null);
+ }
+ }
+ return status;
+ } catch(Exception e){
+ logger.error("Error in _insertTableRow(): ",e);
+ }
+ return new StatusWithUuid(StatusCode.INTERNALERROR);
+ }
+
+
+ private Status deleteBridgeRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Open_vSwitch.NAME.getName();
+ String childTableName=Bridge.NAME.getName();
+ String parentColumn = "bridges";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deletePortRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Bridge.NAME.getName();
+ String childTableName=Port.NAME.getName();
+ String parentColumn = "ports";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteInterfaceRow(Node node, String uuid) {
+ // Since Port<-Interface tables have a 1:n relationship, need to test if this is the last interface
+ // assigned to a port before attempting delete.
+ Map<String, Table<?>> portTable = inventoryServiceInternal.getTableCache(node, Port.NAME.getName());
+ Map<String, Table<?>> interfaceTable = inventoryServiceInternal.getTableCache(node, Interface.NAME.getName());
+ // Check that the UUID exists
+ if (portTable == null || interfaceTable == null || uuid == null || interfaceTable.get(uuid) == null) {
+ return new Status(StatusCode.NOTFOUND, "");
+ }
+
+ // Since the above past, it's safe to use the generic _deleteTableRow method
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Port.NAME.getName();
+ String childTableName=Interface.NAME.getName();
+ String parentColumn = "interfaces";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteControllerRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Bridge.NAME.getName();
+ String childTableName=Controller.NAME.getName();
+ String parentColumn = "controller";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteOpen_vSwitchRow(Node node, String uuid) {
+ return new Status(StatusCode.NOTIMPLEMENTED, "delete operation for this Table is not implemented yet.");
+ }
+
+ private Status deleteSSLRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Open_vSwitch.NAME.getName();
+ String childTableName=SSL.NAME.getName();
+ String parentColumn = "ssl";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteSflowRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Bridge.NAME.getName();
+ String childTableName=SFlow.NAME.getName();
+ String parentColumn = "sflow";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteQueueRow(Node node, String uuid) {
+ // Set up variables for _deleteRootTableRow()
+ // This doesn't do a mutate on parent, but simply deletes row
+ String childTableName=Queue.NAME.getName();
+
+ return _deleteRootTableRow(node,uuid,childTableName);
+ }
+
+ private Status deleteQosRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Port.NAME.getName();
+ String childTableName=Qos.NAME.getName();
+ String parentColumn = "qos";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteNetFlowRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Bridge.NAME.getName();
+ String childTableName=NetFlow.NAME.getName();
+ String parentColumn = "netflow";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteMirrorRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Bridge.NAME.getName();
+ String childTableName=Mirror.NAME.getName();
+ String parentColumn = "mirrors";
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status deleteManagerRow(Node node, String uuid) {
+ // Set up variables for generic _deleteTableRow()
+ String parentTableName=Open_vSwitch.NAME.getName();
+ String childTableName=Manager.NAME.getName();
+ String parentColumn = "manager_options";
+
+ return _deleteTableRow(node,uuid,parentTableName,childTableName,parentColumn);
+ }
+
+ private Status _deleteTableRow(Node node,String uuid,String parentTableName, String childTableName, String parentColumn) {
+ try {
+ // Check there is a connectionService
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+
+ // Establish the connection
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+
+ // Remove from Parent and Child
+ Map<String, Table<?>> parentTable = inventoryServiceInternal.getTableCache(node, parentTableName);
+ Map<String, Table<?>> childTable = inventoryServiceInternal.getTableCache(node, childTableName);
+
+ // Check that the UUID exists
+ if (parentTable == null || childTable == null || uuid == null || childTable.get(uuid) == null) {
+ return new Status(StatusCode.NOTFOUND, "");
+ }
+
+ // Initialise the actual request var
+ Operation delRequest = null;
+
+ // Prepare the mutator to remove the child UUID from the parentColumn list in the parent TABLE
+ UUID rowUuid = new UUID(uuid);
+ Mutation mutator = new Mutation(parentColumn, Mutator.DELETE, rowUuid);
+ List<Mutation> mutations = new ArrayList<Mutation>();
+ mutations.add(mutator);
+
+ Status status = new Status(StatusCode.SUCCESS);
+
+ // INCLUDES condition ensures that it captures all rows in the parent table (ie duplicates) that have the child UUID
+ Condition condition = new Condition(parentColumn, Function.INCLUDES, rowUuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ delRequest = new MutateOperation(parentTableName, where, mutations);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(delRequest)));
+
+ // This executes the transaction.
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+
+ // Pull the responses
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+
+ for (int i = 0; i < tr.size(); i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i) != null && tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size() - 1);
+ logger.error("Error deleting: {}\n Error : {}\n Details : {}",
+ uuid, result.getError(), result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ return status;
+ } catch (Exception e) {
+ logger.error("Error in _deleteTableRow",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ private Status _deleteRootTableRow(Node node,String uuid,String TableName) {
+ try {
+ // Check there is a connectionService
+ if (connectionService == null) {
+ logger.error("Couldn't refer to the ConnectionService");
+ return new Status(StatusCode.NOSERVICE);
+ }
+
+ // Establish the connection
+ Connection connection = this.getConnection(node);
+ if (connection == null) {
+ return new Status(StatusCode.NOSERVICE, "Connection to ovsdb-server not available");
+ }
+
+ Map<String, Table<?>> table = inventoryServiceInternal.getTableCache(node, TableName);
+
+ // Check that the UUID exists
+ if (table == null || table.get(uuid) == null) {
+ return new Status(StatusCode.NOTFOUND, "");
+ }
+
+ // Initialise the actual request var
+ Operation delRequest = null;
+
+ UUID rowUuid = new UUID(uuid);
+
+ Status status = new Status(StatusCode.SUCCESS);
+
+ Condition condition = new Condition("_uuid", Function.EQUALS, rowUuid);
+ List<Condition> where = new ArrayList<Condition>();
+ where.add(condition);
+ delRequest = new DeleteOperation(TableName, where);
+
+ TransactBuilder transaction = new TransactBuilder();
+ transaction.addOperations(new ArrayList<Operation>(Arrays.asList(delRequest)));
+
+ // This executes the transaction.
+ ListenableFuture<List<OperationResult>> transResponse = connection.getRpc().transact(transaction);
+
+ // Pull the responses
+ List<OperationResult> tr = transResponse.get();
+ List<Operation> requests = transaction.getRequests();
+
+ for (int i = 0; i < tr.size(); i++) {
+ if (i < requests.size()) requests.get(i).setResult(tr.get(i));
+ if (tr.get(i) != null && tr.get(i).getError() != null && tr.get(i).getError().trim().length() > 0) {
+ OperationResult result = tr.get(i);
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ }
+
+ if (tr.size() > requests.size()) {
+ OperationResult result = tr.get(tr.size() - 1);
+ logger.error("Error deleting: {}\n Error : {}\n Details : {}",
+ uuid, result.getError(), result.getDetails());
+ status = new Status(StatusCode.BADREQUEST, result.getError() + " : " + result.getDetails());
+ }
+ return status;
+ } catch (Exception e) {
+ logger.error("Error in _deleteRootTableRow",e);
+ }
+ return new Status(StatusCode.INTERNALERROR);
+ }
+
+ public void _ovsconnect (CommandInterpreter ci) {
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+
+ String ovsdbserver = ci.nextArgument();
+ if (ovsdbserver == null) {
+ ci.println("Please enter valid IP-Address");
+ return;
+ }
+ try {
+ InetAddress.getByName(ovsdbserver);
+ } catch (UnknownHostException e) {
+ logger.error("Unable to resolve " + ovsdbserver, e);
+ ci.println("Please enter valid IP-Address");
+ return;
+ }
+ String port = ci.nextArgument();
+ if (port == null) {
+ port = "6634";
+ }
+
+ ci.println("connecting to ovsdb server : "+ovsdbserver+":"+port+" ... ");
+ Map<ConnectionConstants, String> params = new HashMap<ConnectionConstants, String>();
+ params.put(ConnectionConstants.ADDRESS, ovsdbserver);
+ params.put(ConnectionConstants.PORT, port);
+ Node node = connectionService.connect(bridgeName, params);
+ if (node != null) ci.println("Node Name: "+node.toString());
+ else ci.println("Could not connect to Node");
+ }
+
+ public void _addBridge (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+ Status status;
+
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ status = this.createBridgeDomain(node, bridgeName, null);
+ ci.println("Bridge creation status : "+status.toString());
+ }
+
+ public void _getBridgeDomains (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+
+ List<String> brlist = new ArrayList<String>();
+ Node node = Node.fromString(nodeName);
+ brlist = this.getBridgeDomains(node);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ ci.println("Existing Bridges: "+brlist.toString());
+ }
+
+ public void _deleteBridgeDomain (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+ Status status;
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ status = this.deleteBridgeDomain(node, bridgeName);
+ ci.println("Bridge deletion status : "+status.toString());
+ }
+
+ public void _addPort (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+
+ String portName = ci.nextArgument();
+ if (portName == null) {
+ ci.println("Please enter Port Name");
+ return;
+ }
+
+ String type = ci.nextArgument();
+
+ Map<String, String> configs = new HashMap<String, String>();
+ while(true) {
+ String configKey = ci.nextArgument();
+ if (configKey == null) break;
+ String configValue = ci.nextArgument();
+ if (configValue == null) break;
+ configs.put(configKey, configValue);
+ }
+
+ Map<ConfigConstants, Object> customConfigs = null;
+ if (type != null) {
+ customConfigs = new HashMap<ConfigConstants, Object>();
+ customConfigs.put(ConfigConstants.TYPE, type);
+ }
+
+ if (configs.size() > 0) {
+ if (customConfigs == null) customConfigs = new HashMap<ConfigConstants, Object>();
+ customConfigs.put(ConfigConstants.CUSTOM, configs);
+ ci.println(customConfigs.toString());
+ }
+ Status status;
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ status = this.addPort(node, bridgeName, portName, customConfigs);
+ ci.println("Port creation status : "+status.toString());
+ }
+
+ public void _deletePort (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+
+ String portName = ci.nextArgument();
+ if (portName == null) {
+ ci.println("Please enter Port Name");
+ return;
+ }
+
+ Status status;
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ status = this.deletePort(node, bridgeName, portName);
+ ci.println("Port deletion status : "+status.toString());
+ }
+
+ public void _addPortVlan (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+
+ String portName = ci.nextArgument();
+ if (portName == null) {
+ ci.println("Please enter Port Name");
+ return;
+ }
+
+ String vlan = ci.nextArgument();
+ if (vlan == null) {
+ ci.println("Please enter Valid Vlan");
+ return;
+ } else {
+ try {
+ Integer.parseInt(vlan);
+ } catch (NumberFormatException e) {
+ ci.println("Please enter Valid Vlan");
+ return;
+ }
+ }
+
+ Map<ConfigConstants, Object> configs = new HashMap<ConfigConstants, Object>();
+ configs.put(ConfigConstants.TYPE, "VLAN");
+ configs.put(ConfigConstants.VLAN, vlan);
+
+ Status status;
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ status = this.addPort(node, bridgeName, portName, configs);
+ ci.println("Port creation status : "+status.toString());
+ }
+
+ public void _addTunnel (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+
+ String bridgeName = ci.nextArgument();
+ if (bridgeName == null) {
+ ci.println("Please enter Bridge Name");
+ return;
+ }
+
+ String portName = ci.nextArgument();
+ if (portName == null) {
+ ci.println("Please enter Port Name");
+ return;
+ }
+
+ String tunnelType = ci.nextArgument();
+ if (tunnelType == null) {
+ ci.println("Please enter Tunnel Type");
+ return;
+ }
+
+ String remoteIp = ci.nextArgument();
+ if (remoteIp == null) {
+ ci.println("Please enter valid Remote IP Address");
+ return;
+ }
+
+ try {
+ InetAddress.getByName(remoteIp);
+ } catch (Exception e) {
+ logger.error("Unable to resolve " + remoteIp, e);
+ ci.println("Please enter valid Remote IP Address");
+ return;
+ }
+
+ Map<ConfigConstants, Object> configs = new HashMap<ConfigConstants, Object>();
+ configs.put(ConfigConstants.TYPE, "TUNNEL");
+ configs.put(ConfigConstants.TUNNEL_TYPE, tunnelType);
+ configs.put(ConfigConstants.DEST_IP, remoteIp);
+
+ Status status;
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ status = this.addPort(node, bridgeName, portName, configs);
+ ci.println("Port creation status : "+status.toString());
+ }
+
+ public void _printCache (CommandInterpreter ci) {
+ String nodeName = ci.nextArgument();
+ if (nodeName == null) {
+ ci.println("Please enter Node Name");
+ return;
+ }
+ Node node = Node.fromString(nodeName);
+ if (node == null) {
+ ci.println("Invalid Node");
+ return;
+ }
+ inventoryServiceInternal.printCache(node);
+ }
+
+ public void _forceConnect (CommandInterpreter ci) {
+ String force = ci.nextArgument();
+ if (force.equalsIgnoreCase("YES")) {
+ forceConnect = true;
+ }
+ else if (force.equalsIgnoreCase("NO")) {
+ forceConnect = false;
+ }
+ else {
+ ci.println("Please enter YES or NO.");
+ }
+ ci.println("Current ForceConnect State : "+forceConnect);
+ }
+
+ @Override
+ public String getHelp() {
+ StringBuilder help = new StringBuilder();
+ help.append("---OVSDB CLI---\n");
+ help.append("\t ovsconnect <ConnectionName> <ip-address> - Connect to OVSDB\n");
+ help.append("\t addBridge <Node> <BridgeName> - Add Bridge\n");
+ help.append("\t getBridgeDomains <Node> - Get Bridges\n");
+ help.append("\t deleteBridgeDomain <Node> <BridgeName> - Delete a Bridge\n");
+ help.append("\t addPort <Node> <BridgeName> <PortName> <type> <options pairs> - Add Port\n");
+ help.append("\t deletePort <Node> <BridgeName> <PortName> - Delete Port\n");
+ help.append("\t addPortVlan <Node> <BridgeName> <PortName> <vlan> - Add Port, Vlan\n");
+ help.append("\t addTunnel <Node> <Bridge> <Port> <tunnel-type> <remote-ip> - Add Tunnel\n");
+ help.append("\t printCache <Node> - Prints Table Cache");
+ return help.toString();
+ }
+}
+
Code Review / ovsdb.git / blobdiff