}
public static Optional<TerminationPoint> readTerminationPoint(DataBroker dataBroker, LogicalDatastoreType store, TopologyId topologyId, NodeId nodeId, TpId tpId) {
- InstanceIdentifier tpIid = InstanceIdentifier.builder(NetworkTopology.class)
+ InstanceIdentifier<TerminationPoint> tpIid = InstanceIdentifier.builder(NetworkTopology.class)
.child(Topology.class, new TopologyKey(topologyId))
.child(Node.class, new NodeKey(nodeId))
.child(TerminationPoint.class, new TerminationPointKey(tpId))
*/
public class AbstractNodeHandler implements DataTreeChangeListener<Topology> {
private static final Logger LOG = LoggerFactory.getLogger(AbstractNodeHandler.class);
- private static final InstanceIdentifier NRP_TOPOLOGY_SYSTEM_IID = InstanceIdentifier
+ private static final InstanceIdentifier<Topology> NRP_TOPOLOGY_SYSTEM_IID = InstanceIdentifier
.create(Context.class)
.augmentation(Context1.class)
.child(Topology.class, new TopologyKey(new Uuid(TapiConstants.PRESTO_SYSTEM_TOPO)));
});
}
- private boolean isNep(DataObjectModification dataObjectModificationNep) {
+ private boolean isNep(DataObjectModification<?> dataObjectModificationNep) {
return OwnedNodeEdgePoint.class.isAssignableFrom(dataObjectModificationNep.getDataType());
}
- private boolean checkIfDeleted(DataObjectModification dataObjectModificationNep) {
+ private boolean checkIfDeleted(DataObjectModification<?> dataObjectModificationNep) {
OwnedNodeEdgePoint before = (OwnedNodeEdgePoint) dataObjectModificationNep.getDataBefore();
OwnedNodeEdgePoint after = (OwnedNodeEdgePoint) dataObjectModificationNep.getDataAfter();
return false;
}
- private boolean checkIfUpdated(DataObjectModification dataObjectModificationNep) {
+ private boolean checkIfUpdated(DataObjectModification<?> dataObjectModificationNep) {
OwnedNodeEdgePoint before = (OwnedNodeEdgePoint) dataObjectModificationNep.getDataBefore();
OwnedNodeEdgePoint after = (OwnedNodeEdgePoint) dataObjectModificationNep.getDataAfter();
if (after == null) {
}
public static void validateExternalVLANs(List<EndPoint> endPoints) throws ResourceNotAvailableException {
- Set<Optional> vlans = endPoints.stream().map(ep -> {
+ Set<Optional<?>> vlans = endPoints.stream().map(ep -> {
try {
return new OvsActivatorHelper(ep).getCeVlanId();
} catch (ResourceNotAvailableException e) {
private Function<Node,Boolean> isOvs = node -> capabilitiesService.node(node).isSupporting(AND, OVSDB);
- protected void checkNodes(List<DataObjectModification> nodes,
+ protected void checkNodes(List<DataObjectModification<? extends DataObject>> nodes,
Map<TerminationPoint,String> toAddMap,
Map<TerminationPoint,String> toUpdateMap, Map<TerminationPoint,String> toDeleteMap) {
Node n;
- for (DataObjectModification node: nodes) {
+ for (DataObjectModification<?> node: nodes) {
switch (node.getModificationType()) {
//new ovs node
case WRITE :
}
}
- private void checkTerminationPoints(DataObjectModification node,
+ private void checkTerminationPoints(DataObjectModification<?> node,
Map<TerminationPoint,String> toAddMap,
Map<TerminationPoint,String> toUpdateMap,
Map<TerminationPoint,String> toDeleteMap) {
return ;
}
String bridgeName = n.augmentation(OvsdbBridgeAugmentation.class).getBridgeName().getValue();
- Collection<DataObjectModification<? extends DataObject>> modifiedChildren = node.getModifiedChildren();
+ Collection<? extends DataObjectModification<? extends DataObject>> modifiedChildren = node.getModifiedChildren();
TerminationPoint terminationPoint;
- for (DataObjectModification tp: modifiedChildren) {
+ for (DataObjectModification<?> tp: modifiedChildren) {
if (!tp.getDataType().equals(TerminationPoint.class)) {
continue;
}
*/
package org.opendaylight.unimgr.mef.nrp.ovs.tapi;
-import com.google.common.util.concurrent.FutureCallback;
-import com.google.common.util.concurrent.Futures;
-
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
import java.util.concurrent.TimeUnit;
import java.util.function.BiConsumer;
import java.util.stream.Collectors;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
-import com.google.common.util.concurrent.MoreExecutors;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
import org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener;
import org.opendaylight.unimgr.mef.nrp.common.TapiUtils;
import org.opendaylight.unimgr.mef.nrp.ovs.transaction.TopologyTransaction;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
-import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.*;
+import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.LayerProtocolName;
+import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.LifecycleState;
+import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.PortDirection;
+import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.PortRole;
+import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.Uuid;
import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.tapi.context.ServiceInterfacePoint;
import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.tapi.context.ServiceInterfacePointBuilder;
import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.node.OwnedNodeEdgePoint;
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.node.TerminationPoint;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import com.google.common.util.concurrent.FutureCallback;
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.MoreExecutors;
+
/**
* TopologyDataHandler listens to ovsdb topology and propagate significant changes to presto ext topology.
*
final Map<TerminationPoint,String> toDeleteMap = new HashMap<>();
final Map<TerminationPoint,String> toUpdateMap = new HashMap<>();
- List<DataObjectModification> nodes = collection.stream()
+ List<DataObjectModification<? extends DataObject>> nodes = collection.stream()
.map(DataTreeModification::getRootNode)
.collect(Collectors.toList());
}
public static Nodes readOpenFLowTopology(DataBroker dataBroker) {
- InstanceIdentifier instanceIdentifier = InstanceIdentifier.builder(Nodes.class).build();
+ InstanceIdentifier<Nodes> instanceIdentifier = InstanceIdentifier.builder(Nodes.class).build();
return (Nodes) MdsalUtils.read(dataBroker, LogicalDatastoreType.CONFIGURATION,instanceIdentifier);
}
}
public class DataStoreTestUtils {
private static final Logger LOG = LoggerFactory.getLogger(DataStoreTestUtils.class);
- public static <T extends DataObject> T read(InstanceIdentifier instanceIdentifier, DataBroker dataBroker) {
+ public static <T extends DataObject> T read(InstanceIdentifier<?> instanceIdentifier, DataBroker dataBroker) {
return read(instanceIdentifier,dataBroker,LogicalDatastoreType.OPERATIONAL);
}
- public static <T extends DataObject> T readConfig(InstanceIdentifier instanceIdentifier, DataBroker dataBroker) {
+ public static <T extends DataObject> T readConfig(InstanceIdentifier<?> instanceIdentifier, DataBroker dataBroker) {
return read(instanceIdentifier,dataBroker,LogicalDatastoreType.CONFIGURATION);
}
});
}
- public static void delete(InstanceIdentifier instanceIdentifier, DataBroker dataBroker) {
+ public static void delete(InstanceIdentifier<?> instanceIdentifier, DataBroker dataBroker) {
ReadWriteTransaction transaction = dataBroker.newReadWriteTransaction();
transaction.delete(LogicalDatastoreType.OPERATIONAL, instanceIdentifier);
});
}
- private static <T extends DataObject> T read(InstanceIdentifier instanceIdentifier, DataBroker dataBroker, LogicalDatastoreType type) {
+ private static <T extends DataObject> T read(InstanceIdentifier<?> instanceIdentifier, DataBroker dataBroker, LogicalDatastoreType type) {
ReadOnlyTransaction transaction = dataBroker.newReadOnlyTransaction();
try {
Optional<T> opt = (Optional<T>) transaction.read(type,instanceIdentifier).checkedGet();
*/
package org.opendaylight.unimgr.mef.nrp.ovs;
+import java.util.ArrayList;
+import java.util.List;
+
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.unimgr.utils.MdsalUtils;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnector;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import java.util.ArrayList;
-import java.util.List;
-
/**
* @author marek.ryznar@amartus.com
*/
*/
public class OvsdbTopologyTestUtils {
private static final TopologyId ovsdbTopologyId = new TopologyId(new Uri("ovsdb:1"));
- private static final InstanceIdentifier ovsdbTopology =
+ private static final InstanceIdentifier<Topology> ovsdbTopology =
InstanceIdentifier
.create(NetworkTopology.class)
.child(Topology.class, new TopologyKey(ovsdbTopologyId));
}
public static void writeBridge(Node node, DataBroker dataBroker) {
- InstanceIdentifier bridgeIid = getNodeInstanceIdentifier(node.getNodeId());
+ InstanceIdentifier<Node> bridgeIid = getNodeInstanceIdentifier(node.getNodeId());
DataStoreTestUtils.write(node,bridgeIid,dataBroker);
}
return nodeBuilder.build();
}
- public static InstanceIdentifier getNodeInstanceIdentifier(NodeId nodeId) {
+ public static InstanceIdentifier<Node> getNodeInstanceIdentifier(NodeId nodeId) {
return InstanceIdentifier
.builder(NetworkTopology.class)
.child(Topology.class,
.build();
}
- public static InstanceIdentifier getPortInstanceIdentifier(String nodeName, String portName) {
+ public static InstanceIdentifier<TerminationPoint> getPortInstanceIdentifier(String nodeName, String portName) {
return getNodeInstanceIdentifier(new NodeId(nodeName))
.child(TerminationPoint.class,
new TerminationPointKey(new TpId(portName)));
}
public static Nodes readOpenFLowTopology(DataBroker dataBroker) {
- InstanceIdentifier instanceIdentifier = InstanceIdentifier.builder(Nodes.class).build();
+ InstanceIdentifier<Nodes> instanceIdentifier = InstanceIdentifier.builder(Nodes.class).build();
return (Nodes) MdsalUtils.read(dataBroker,LogicalDatastoreType.CONFIGURATION,instanceIdentifier);
}
import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.Context;
import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.Uuid;
import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.Context1;
+import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.topology.context.Topology;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnector;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortNumberUni;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
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.Node;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
tps.add(OvsdbTopologyTestUtils.createTerminationPoint(tp3Name,tp3OFport));
org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node node = OvsdbTopologyTestUtils.createBridge(bridgeName,tps);
- InstanceIdentifier instanceIdentifier = OvsdbTopologyTestUtils.getNodeInstanceIdentifier(node.getNodeId());
+ InstanceIdentifier<Node> instanceIdentifier = OvsdbTopologyTestUtils.getNodeInstanceIdentifier(node.getNodeId());
DataStoreTestUtils.write(node,instanceIdentifier,dataBroker);
}
protected void deleteTestBridge() {
- InstanceIdentifier instanceIdentifier = OvsdbTopologyTestUtils.getNodeInstanceIdentifier(new NodeId(bridgeName));
+ InstanceIdentifier<?> instanceIdentifier = OvsdbTopologyTestUtils.getNodeInstanceIdentifier(new NodeId(bridgeName));
DataStoreTestUtils.delete(instanceIdentifier,dataBroker);
}
return null;
}
- private static InstanceIdentifier getNodeIid() {
+ private static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.topology.Node> getNodeIid() {
return getTopoIid()
.child(org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.topology.Node.class,
new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.topology.NodeKey(new Uuid(ovsNodeId)));
}
- private static InstanceIdentifier getTopoIid() {
+ private static InstanceIdentifier<Topology> getTopoIid() {
return InstanceIdentifier.create(Context.class)
.augmentation(Context1.class)
.child(org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev180307.topology.context.Topology.class,