import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.stream.Collectors;
-
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.transportpce.common.NetworkUtils;
import org.opendaylight.transportpce.common.network.NetworkTransactionService;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
+import org.opendaylight.yangtools.yang.common.Uint16;
+import org.opendaylight.yangtools.yang.common.Uint32;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
}
}
for (String str : nodeShardList) {
- List<Mapping> interList = new ArrayList<>();
- interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
+ List<Mapping> interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
.collect(Collectors.toList());
if (str.contains("DEG")) {
mapDeg.put(str, interList);
}
}
// create degree nodes
- for (String k : mapDeg.keySet()) {
- NodeBuilder ietfNode = createDegree(k, mapDeg.get(k), mappingNode.getNodeId(),
+ for (Map.Entry<String, List<Mapping>> entry : mapDeg.entrySet()) {
+ NodeBuilder ietfNode = createDegree(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
mappingNode.getNodeInfo().getNodeClli());
nodes.add(ietfNode.build());
}
// create srg nodes
- for (String k : mapSrg.keySet()) {
- NodeBuilder ietfNode = createSrg(k, mapSrg.get(k), mappingNode.getNodeId(),
+ for (Map.Entry<String, List<Mapping>> entry : mapSrg.entrySet()) {
+ NodeBuilder ietfNode = createSrg(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
mappingNode.getNodeInfo().getNodeClli());
nodes.add(ietfNode.build());
}
tpList.add(ietfTpBldr.build());
// set degree-attributes
DegreeAttributes degAtt = new DegreeAttributesBuilder()
- .setDegreeNumber(Integer.valueOf(degNb.split("DEG")[1]))
+ .setDegreeNumber(Uint16.valueOf(degNb.split("DEG")[1]))
.setAvailableWavelengths(create96AvalWaveDegree()).build();
// Create ietf node augmentation to support ietf tp-list
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
// This method returns the linkBuilder object for given source and destination
public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
- LOG.info("deleting link for LinkId: {}", linkId);
+ LOG.info("deleting link for LinkId: {}", linkId.getValue());
try {
InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
}
} catch (InterruptedException | ExecutionException | TimeoutException e) {
- LOG.error(e.getMessage(), e);
+ LOG.error("Error deleting link {}", linkId.getValue(), e);
return false;
}
}
for (int i = 1; i < 97; i++) {
AvailableWavelengthsBuilder avalBldr = new AvailableWavelengthsBuilder()
- .setIndex((long) i)
- .withKey(new AvailableWavelengthsKey((long) i));
+ .setIndex(Uint32.valueOf(i))
+ .withKey(new AvailableWavelengthsKey(Uint32.valueOf(i)));
waveList.add(avalBldr.build());
}
org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
.AvailableWavelengthsBuilder avalBldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.srg
.rev181130.srg.node.attributes.AvailableWavelengthsBuilder()
- .setIndex((long) i)
+ .setIndex(Uint32.valueOf(i))
.withKey(new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
- .AvailableWavelengthsKey((long) i));
+ .AvailableWavelengthsKey(Uint32.valueOf(i)));
waveList.add(avalBldr.build());
}
return waveList;