--- /dev/null
+/*
+ * Copyright (c) 2015 Brocade Communications Systems, Inc. and others. All rights reserved.
+ *
+ * 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
+ */
+package org.opendaylight.ovsdb.southbound;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
+import org.opendaylight.ovsdb.lib.OvsdbClient;
+import org.opendaylight.ovsdb.lib.notation.Row;
+import org.opendaylight.ovsdb.lib.notation.UUID;
+import org.opendaylight.ovsdb.lib.operations.OperationResult;
+import org.opendaylight.ovsdb.lib.operations.Operations;
+import org.opendaylight.ovsdb.lib.operations.TransactionBuilder;
+import org.opendaylight.ovsdb.lib.schema.ColumnSchema;
+import org.opendaylight.ovsdb.lib.schema.DatabaseSchema;
+import org.opendaylight.ovsdb.lib.schema.GenericTableSchema;
+import org.opendaylight.ovsdb.lib.schema.TableSchema;
+import org.opendaylight.ovsdb.schema.openvswitch.Bridge;
+import org.opendaylight.ovsdb.southbound.OvsdbSchemaContants.OVSDBSCHEMATABLES;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeRef;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbManagedNodeAugmentation;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbManagedNodeAugmentationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeRef;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.google.common.base.Optional;
+import com.google.common.util.concurrent.FutureCallback;
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.ListenableFuture;
+
+/**
+*
+* @author Anil Vishnoi (avishnoi@brocade.com)
+*
+*/
+
+public class OvsdbBridgeOperDataCollector extends OvsdbDataCollectionOperation {
+
+ private static final Logger LOG = LoggerFactory.getLogger(OvsdbBridgeOperDataCollector.class);
+
+ public OvsdbBridgeOperDataCollector(final OperationType operType,
+ final OvsdbClient ovsdbClient, final DataBroker db) {
+ super(operType, ovsdbClient, db);
+ }
+
+ @Override
+ public void fetchAndStoreOperData(final OvsdbClient ovsdbClient, final DataBroker db) {
+ DatabaseSchema dbSchema = ovsdbClient.getDatabaseSchema(OvsdbSchemaContants.databaseName);
+ TransactionBuilder transactionBuilder = ovsdbClient.transactBuilder(dbSchema);
+ TableSchema<GenericTableSchema> bridgeTableSchema = dbSchema.table(OVSDBSCHEMATABLES.BRIDGE.getTableName(), GenericTableSchema.class);
+
+ ColumnSchema<GenericTableSchema, String> name = bridgeTableSchema.column("name", String.class);
+ ColumnSchema<GenericTableSchema, UUID> _uuid = bridgeTableSchema.column("_uuid", UUID.class);
+
+ transactionBuilder.add(Operations.op.select(bridgeTableSchema)
+ .column(name)
+ .column(_uuid));
+ ListenableFuture<List<OperationResult>> results = transactionBuilder.execute();
+
+ Futures.addCallback(results, new FutureCallback<List<OperationResult>>(){
+
+ @Override
+ public void onFailure(Throwable arg0) {
+ LOG.error("Read operation failure while reading {} database from ovsdb node "
+ + "running on {}",OVSDBSCHEMATABLES.BRIDGE.getTableName(),ovsdbClient.getConnectionInfo().toString());
+
+ }
+
+ @Override
+ public void onSuccess(List<OperationResult> arg0) {
+ LOG.info("Successfully read operational data from {} database of ovsdb node "
+ + "running on {}",OVSDBSCHEMATABLES.BRIDGE.getTableName(),ovsdbClient.getConnectionInfo().toString());
+
+ for(OperationResult result : arg0){
+ if(result.getError() != null){
+ LOG.error("Error occured while fetching bridge operational data from ovsdb database : {}",result.getDetails());
+ }else{
+ for(Row<GenericTableSchema> row : result.getRows()){
+ ReadWriteTransaction rwTransaction = db.newReadWriteTransaction();
+
+ LOG.info("Row data {}",row.toString());
+ Bridge bridge = ovsdbClient.getTypedRowWrapper(Bridge.class, row);
+ final InstanceIdentifier<Node> nodePath = SouthboundMapper.createInstanceIdentifier(ovsdbClient);
+ Optional<Node> node = Optional.absent();
+ try{
+ node = rwTransaction.read(LogicalDatastoreType.OPERATIONAL, nodePath).checkedGet();
+ }catch (final ReadFailedException e) {
+ LOG.info("Read Operational/DS for Node fail! {}", nodePath, e);
+ }
+ if(node.isPresent()){
+ LOG.info("Node {} is present",node);
+ NodeBuilder managedNodeBuilder = new NodeBuilder();
+ NodeId manageNodeId = SouthboundMapper.createManagedNodeId(ovsdbClient.getConnectionInfo(), bridge.getUuid());
+ managedNodeBuilder.setNodeId(manageNodeId);
+
+ OvsdbManagedNodeAugmentationBuilder ovsdbManagedNodeBuilder = new OvsdbManagedNodeAugmentationBuilder();
+ ovsdbManagedNodeBuilder.setBridgeName(bridge.getName());
+ ovsdbManagedNodeBuilder.setBridgeUuid(new Uuid(bridge.getUuid().toString()));
+ ovsdbManagedNodeBuilder.setManagedBy(new OvsdbNodeRef(nodePath));
+ managedNodeBuilder.addAugmentation(OvsdbManagedNodeAugmentation.class, ovsdbManagedNodeBuilder.build());
+
+ InstanceIdentifier<Node> managedNodePath = InstanceIdentifier
+ .create(NetworkTopology.class)
+ .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
+ .child(Node.class,new NodeKey(manageNodeId));
+
+ LOG.info("Store managed node augmentation data {}",ovsdbManagedNodeBuilder.toString());
+ rwTransaction.put(LogicalDatastoreType.OPERATIONAL, managedNodePath, managedNodeBuilder.build());
+
+ //Update node with managed node reference
+ NodeBuilder nodeBuilder = new NodeBuilder();
+ nodeBuilder.setNodeId(SouthboundMapper.createNodeId(ovsdbClient.getConnectionInfo()));
+
+ OvsdbNodeAugmentationBuilder ovsdbNodeBuilder = new OvsdbNodeAugmentationBuilder();
+ List<OvsdbBridgeRef> managedNodes = new ArrayList<OvsdbBridgeRef>();
+ managedNodes.add(new OvsdbBridgeRef(managedNodePath));
+ ovsdbNodeBuilder.setManagedNodeEntry(managedNodes);
+
+ nodeBuilder.addAugmentation(OvsdbNodeAugmentation.class, ovsdbNodeBuilder.build());
+
+ LOG.info("Update node with managed node ref {}",ovsdbNodeBuilder.toString());
+ rwTransaction.merge(LogicalDatastoreType.OPERATIONAL, nodePath, nodeBuilder.build());
+
+ Futures.addCallback(rwTransaction.submit(),new FutureCallback<Void>(){
+
+ @Override
+ public void onFailure(Throwable arg0) {
+ LOG.info("Write to Operational Data Store for managed node {} failed with exception {}!",nodePath,arg0 );
+ }
+
+ @Override
+ public void onSuccess(Void arg0) {
+ LOG.info("Managed node's operational data stored successfully to md-sal operational data store.");
+ }
+
+ });
+ }else{
+ LOG.info("Node is not present in the operational data store, skipping bridge operational data write to data store");
+ }
+
+ }
+ }
+ }
+ }
+
+ });
+
+ }
+
+ @Override
+ public void fetchAndUpdateOperData(final OvsdbClient ovsdbClient, final DataBroker db) {
+ final ReadWriteTransaction rwTransaction = db.newReadWriteTransaction();
+ DatabaseSchema dbSchema = ovsdbClient.getDatabaseSchema(OvsdbSchemaContants.databaseName);
+ TransactionBuilder transactionBuilder = ovsdbClient.transactBuilder(dbSchema);
+ TableSchema<GenericTableSchema> childTableSchema = dbSchema.table(OVSDBSCHEMATABLES.BRIDGE.getTableName(), GenericTableSchema.class);
+ transactionBuilder.add(Operations.op.select(childTableSchema)).build();
+ ListenableFuture<List<OperationResult>> results = transactionBuilder.execute();
+
+ Futures.addCallback(results, new FutureCallback<List<OperationResult>>(){
+
+ @Override
+ public void onFailure(Throwable arg0) {
+ LOG.error("Read operation failure while reading {} database from ovsdb node "
+ + "running on {}",OVSDBSCHEMATABLES.BRIDGE.getTableName(),ovsdbClient.getConnectionInfo().toString());
+
+ }
+
+ @Override
+ public void onSuccess(List<OperationResult> arg0) {
+ LOG.info("Successfully read operational data from {} database of ovsdb node "
+ + "running on {}",OVSDBSCHEMATABLES.BRIDGE.getTableName(),ovsdbClient.getConnectionInfo().toString());
+
+ for(OperationResult result : arg0){
+ if(result.getError() != null){
+ LOG.error("Error occured while fetching bridge operational data from ovsdb database : {}",result.getDetails());
+ }else{
+ for(Row<GenericTableSchema> row : result.getRows()){
+ Bridge bridge = ovsdbClient.getTypedRowWrapper(Bridge.class, row);
+ final InstanceIdentifier<Node> nodeIdent = SouthboundMapper.createInstanceIdentifier(ovsdbClient);
+ Optional<Node> node = Optional.absent();
+
+ try{
+ node = rwTransaction.read(LogicalDatastoreType.OPERATIONAL, nodeIdent).checkedGet();
+ }catch (final ReadFailedException e) {
+ LOG.info("Read Operational/DS for Node fail! {}", nodeIdent, e);
+ }
+ if(node.isPresent()){
+ LOG.info("Node {} is present",node);
+ NodeBuilder managedNodeBuilder = new NodeBuilder();
+ NodeId manageNodeId = SouthboundMapper.createManagedNodeId(ovsdbClient.getConnectionInfo(), bridge.getUuid());
+ managedNodeBuilder.setNodeId(manageNodeId);
+
+ OvsdbManagedNodeAugmentationBuilder ovsdbManagedNodeBuilder = new OvsdbManagedNodeAugmentationBuilder();
+ ovsdbManagedNodeBuilder.setBridgeName(bridge.getName());
+ ovsdbManagedNodeBuilder.setBridgeUuid(new Uuid(bridge.getUuid().toString()));
+ ovsdbManagedNodeBuilder.setManagedBy(new OvsdbNodeRef(nodeIdent));
+ managedNodeBuilder.addAugmentation(OvsdbManagedNodeAugmentation.class, ovsdbManagedNodeBuilder.build());
+
+ InstanceIdentifier<Node> managedNodePath = InstanceIdentifier
+ .create(NetworkTopology.class)
+ .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
+ .child(Node.class,new NodeKey(manageNodeId));
+
+ LOG.info("Store managed node augmentation data {}",ovsdbManagedNodeBuilder.toString());
+ rwTransaction.merge(LogicalDatastoreType.OPERATIONAL, managedNodePath, managedNodeBuilder.build());
+ Futures.addCallback(rwTransaction.submit(),new FutureCallback<Void>(){
+
+ @Override
+ public void onFailure(Throwable arg0) {
+ LOG.info("Write to Operational Data Store for managed node {} failed with exception {}!",nodeIdent,arg0 );
+ }
+
+ @Override
+ public void onSuccess(Void arg0) {
+ LOG.info("Managed node operational data stored successfully to md-sal operational data store.");
+ }
+
+ });
+ }
+
+ }
+ }
+ }
+ }
+
+ });
+
+ }
+
+ @Override
+ public void deleteOperData(OvsdbClient ovsdbClient, DataBroker db) {
+ /* TODO Operational data of managed node need to be deleted in following two scenario
+ * 1) When node is disconnected
+ * 2) When any specific managed node will be deleted.
+ * In case of 1), all the managed node data will get deleted with node data.
+ * In case of 2), whenever user delete any bridge, ovsdb south bound plugin
+ * should get the notification and it should update the data using fetchAndUpdateOperData
+ */
+
+ }
+}
\ No newline at end of file
--- /dev/null
+/*
+ * Copyright (c) 2015 Brocade Communications Systems, Inc. and others. All rights reserved.
+ *
+ * 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
+ */
+
+package org.opendaylight.ovsdb.southbound;
+
+import java.util.concurrent.Callable;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.ovsdb.lib.OvsdbClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.google.common.base.Preconditions;
+
+/**
+ * Main responsibility of the class is to define the interface that various
+ * config operataion can extend to. It define common interface for data store
+ * operations.
+ *
+ * @author Anil Vishnoi (avishnoi@brocade.com)
+ *
+ */
+public abstract class OvsdbDataCollectionOperation implements Callable<Object>{
+ private static final Logger LOG = LoggerFactory.getLogger(OvsdbDataCollectionOperation.class);
+
+ public enum OperationType {
+ FETCH_OVSDB_OPER_DATA,
+ REFERESH_OVSDB_OPER_DATA,
+ DELETE_OVSDB_OPER_DATA
+ }
+
+ private OperationType operType = OperationType.FETCH_OVSDB_OPER_DATA;
+ private OvsdbClient ovsdbClient = null;
+ private DataBroker db;
+
+
+ public OvsdbDataCollectionOperation(final OperationType operType, final OvsdbClient ovsdbClient, final DataBroker db){
+ Preconditions.checkNotNull(ovsdbClient);
+ this.ovsdbClient = ovsdbClient;
+ this.operType = operType;
+ this.db = db;
+ }
+ @Override
+ public Object call(){
+ if( operType == OperationType.FETCH_OVSDB_OPER_DATA ){
+ LOG.debug("Fetch ovsdb operational data from {} and store it in the md-sal data store.",this.ovsdbClient);
+ this.fetchAndStoreOperData(ovsdbClient, db);
+ }else if( operType == OperationType.REFERESH_OVSDB_OPER_DATA ){
+ LOG.debug("Fetch ovsdb operational data from {} and update the existing data in the md-sal data store.",this.ovsdbClient);
+ this.fetchAndUpdateOperData(ovsdbClient, db);
+ }else if( operType == OperationType.DELETE_OVSDB_OPER_DATA ){
+ LOG.debug("Delete operational data fetched from {}",this.ovsdbClient);
+ this.deleteOperData(ovsdbClient, db);
+ }
+ return operType;
+ }
+
+ public abstract void fetchAndStoreOperData(final OvsdbClient ovsdbClient, final DataBroker db);
+
+ public abstract void fetchAndUpdateOperData(final OvsdbClient ovsdbClient, final DataBroker db);
+
+ public abstract void deleteOperData( final OvsdbClient ovsdbClient, final DataBroker db);
+}
--- /dev/null
+/*
+ * Copyright (c) 2015 Brocade Communications Systems, Inc. and others. All rights reserved.
+ *
+ * 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
+ */
+package org.opendaylight.ovsdb.southbound;
+
+/**
+ *
+ * @author Anil Vishnoi (avishnoi@brocade.com)
+ *
+ */
+public class OvsdbSchemaContants {
+ public static final String databaseName = "Open_vSwitch";
+ public enum OVSDBSCHEMATABLES {
+ OPENVSWITCH("Open_vSwitch",null,null),
+ BRIDGE("Bridge", "Open_vSwitch", "bridges"),
+ PORT("Port", "Bridge", "ports"),
+ INTERFACE("Interface", "Port", "interfaces"),
+ SSL("SSL", "Open_vSwitch", "ssl"),
+ IPFIX("IPFIX", "Bridge", "ipfix"),
+ SFLOW("sFlow", "Bridge", "sflow"),
+ FLOWTABLE("Flow_Table", "Bridge", "flow_tables"),
+ QOS("QoS", "Port", "qos"),
+ NETFLOW("NetFlow", "Bridge", "netflow"),
+ MIRROR("Mirror", "Bridge", "mirrors"),
+ MANAGER("Manager", "Open_vSwitch", "manager_options"),
+ CONTROLLER("Controller", "Bridge", "controller"),
+ FLOWSAMPLECOLLECTORSET("Flow_Sample_Collector_Set",null,null);
+
+ private final String tableName;
+ private final String parentTableName;
+ private final String columnNameInParentTable;
+
+ private OVSDBSCHEMATABLES(final String tableName, final String parentTableName, final String columnNameInParentTable){
+ this.tableName = tableName;
+ this.parentTableName = parentTableName;
+ this.columnNameInParentTable = columnNameInParentTable;
+ }
+
+ public String getTableName(){
+ return this.tableName;
+ }
+
+ public String getParentTableName(){
+ return this.parentTableName;
+ }
+
+ public String getColumnNameInParentTable(){
+ return this.columnNameInParentTable;
+ }
+ }
+
+}
Code Review / ovsdb.git / commitdiff