+ public static TopologyShard createOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
+ OtnLinkType linkType) {
+
+ return new TopologyShard(
+ null,
+ OTNLINKTYPE_OTU_BW_MAP.containsKey(linkType)
+ ? initialiseOtnLinks(nodeA, tpA, nodeZ, tpZ, linkType)
+ : null);
+ }
+
+ public static TopologyShard createOtnLinks(
+ org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.renderer.rpc.result.sp
+ .Link notifLink,
+ OtnLinkType linkType) {
+
+ return new TopologyShard(
+ null,
+ initialiseOtnLinks(notifLink.getATermination().getNodeId(),
+ notifLink.getATermination().getTpId(),
+ notifLink.getZTermination().getNodeId(),
+ notifLink.getZTermination().getTpId(),
+ linkType));
+ }
+
+ public static TopologyShard createOtnLinks(
+ org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.renderer.rpc.result.sp
+ .Link notifLink,
+ List<Link> supportedOtu4links, List<TerminationPoint> supportedTPs, OtnLinkType linkType) {
+
+ if (OTNLINKTYPE_OTU_BW_MAP.containsKey(linkType)) {
+ return new TopologyShard(
+ null,
+ initialiseOtnLinks(
+ notifLink.getATermination().getNodeId(), notifLink.getATermination().getTpId(),
+ notifLink.getZTermination().getNodeId(), notifLink.getZTermination().getTpId(), linkType));
+ } else if (OTNLINKTYPE_BW_MAP.containsKey(linkType)) {
+ List<Link> links = initialiseOtnLinks(
+ notifLink.getATermination().getNodeId(), notifLink.getATermination().getTpId(),
+ notifLink.getZTermination().getNodeId(), notifLink.getZTermination().getTpId(), linkType);
+ links.addAll(updateOtnLinkBwParameters(supportedOtu4links, linkType));
+ List<TerminationPoint> updatedTPs = new ArrayList<>();
+ for (TerminationPoint tp : supportedTPs) {
+ updatedTPs.add(updateTp(tp, true, linkType));
+ }
+ return new TopologyShard(null, links, updatedTPs);
+ } else {
+ return null;
+ }
+ }
+
+ public static TopologyShard createOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
+ OtnLinkType linkType) {
+
+ List<Link> links = new ArrayList<>();
+ for (Link link : suppOtuLinks) {
+ if (link.augmentation(Link1.class) == null) {
+ LOG.error("Error with OTN parameters of supported link {}", link.getLinkId().getValue());
+ continue;
+ }
+ if (!OTNLINKTYPE_BW_MAP.containsKey(linkType)) {
+ LOG.error("Error with link {} : unsupported OTN link type", link.getLinkId().getValue());
+ continue;
+ }
+ if (link.augmentation(Link1.class).getAvailableBandwidth().longValue() < OTNLINKTYPE_BW_MAP.get(linkType)) {
+ LOG.error("Error with link {} : unsufficient available bandwith", link.getLinkId().getValue());
+ continue;
+ }
+ links.add(updateOtnLinkBwParameters(link, 0L, OTNLINKTYPE_BW_MAP.get(linkType)));
+ }
+ if (links.size() == 2) {
+ links.addAll(initialiseOtnLinks(suppOtuLinks.get(0).getSource().getSourceNode().getValue(),
+ suppOtuLinks.get(0).getSource().getSourceTp().getValue(),
+ suppOtuLinks.get(0).getDestination().getDestNode().getValue(),
+ suppOtuLinks.get(0).getDestination().getDestTp().getValue(),
+ linkType));
+ }
+ List<TerminationPoint> tps = new ArrayList<>();
+ for (TerminationPoint tp : oldTps) {
+ tps.add(updateTp(tp, true, linkType));
+ }
+ return links.size() == 4 && tps.size() == 2
+ ? new TopologyShard(null, links, tps)
+ : new TopologyShard(null, null, null);
+ }
+
+ public static TopologyShard updateOtnLinks(List<Link> suppOduLinks, List<TerminationPoint> oldTps,
+ Uint32 serviceRate, Short tribPortNb, Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
+
+ List<Link> links = new ArrayList<>();
+ if (!SERVICERATE_BWINCR_MAP.containsKey(serviceRate)) {
+ LOG.warn("Error with not managed service rate {}", serviceRate.toString());
+ return new TopologyShard(null, null, null);
+ }
+ Long bwIncr = SERVICERATE_BWINCR_MAP.get(serviceRate);
+ for (Link link : suppOduLinks) {
+ if (link.augmentation(Link1.class) == null
+ || link.augmentation(Link1.class).getAvailableBandwidth() == null
+ || link.augmentation(Link1.class).getUsedBandwidth() == null) {
+ LOG.error(OTN_PARAMS_ERROR, link.getLinkId().getValue());
+ } else {
+ Uint32 avlBw = link.augmentation(Link1.class).getAvailableBandwidth();
+ Uint32 usedBw = link.augmentation(Link1.class).getUsedBandwidth();
+ if (avlBw.toJava() < bwIncr) {
+ bwIncr = 0L;
+ }
+ links.add(
+ isDeletion
+ ? updateOtnLinkBwParameters(link, avlBw.toJava() + bwIncr, usedBw.toJava() - bwIncr)
+ : updateOtnLinkBwParameters(link, avlBw.toJava() - bwIncr, usedBw.toJava() + bwIncr)
+ );
+ }
+ }
+ List<TerminationPoint> tps = new ArrayList<>();
+ for (TerminationPoint tp : oldTps) {
+ if (bwIncr > 0L) {
+ tps.add(updateNodeTpTsPool(tp, serviceRate, tribPortNb, minTribSlotNb, maxTribSlotNb, isDeletion));
+ }
+ }
+ if (links.isEmpty() || tps.isEmpty()) {
+ LOG.error("unable to update otn links");
+ return new TopologyShard(null, null, null);
+ } else {
+ return new TopologyShard(null, links, tps);
+ }
+ }
+
+ public static TopologyShard updateOtnLinks(List<Link> suppOtuLinks, boolean isDeletion) {
+
+ List<Link> links = new ArrayList<>();
+ for (Link link : suppOtuLinks) {
+ if (link.augmentation(Link1.class) == null
+ || link.augmentation(Link1.class).getAvailableBandwidth() == null
+ || link.augmentation(Link1.class).getUsedBandwidth() == null) {
+ LOG.error(OTN_PARAMS_ERROR, link.getLinkId().getValue());
+ } else {
+ links.add(
+ isDeletion
+ ? updateOtnLinkBwParameters(link, Long.valueOf(100000), Long.valueOf(0))
+ : updateOtnLinkBwParameters(link, Long.valueOf(0), Long.valueOf(100000))
+ );
+ }
+ }
+ if (links.isEmpty()) {
+ LOG.error("unable to update otn links");
+ return new TopologyShard(null, null, null);
+ } else {
+ return new TopologyShard(null, links, null);
+ }
+ }
+
+ public static TopologyShard deleteOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
+ OtnLinkType linkType) {
+
+ List<Link> links = new ArrayList<>();
+ for (Link link : suppOtuLinks) {
+ if (link.augmentation(Link1.class) == null
+ || link.augmentation(
+ org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1.class) == null) {
+ LOG.error(OTN_PARAMS_ERROR, link.getLinkId().getValue());
+ return new TopologyShard(null, null, null);
+ }
+ OtnLinkType otnLinkType = link.augmentation(
+ org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1.class).getOtnLinkType();
+ if (!OTNLINKTYPE_OTU_BW_MAP.containsKey(otnLinkType)) {
+ //TODO shouldn't other link type listed in OTNLINKTYPE_BW_MAP be handled too ?
+ LOG.warn("Unexpected otn-link-type {} for link {}", otnLinkType, link.getLinkId());
+ continue;
+ }
+ links.add(updateOtnLinkBwParameters(link, OTNLINKTYPE_OTU_BW_MAP.get(otnLinkType) , 0L));
+ }
+ List<TerminationPoint> tps = new ArrayList<>();
+ for (TerminationPoint tp : oldTps) {
+ tps.add(updateTp(tp, false, linkType));
+ }
+ return
+ links.isEmpty() || tps.isEmpty()
+ ? new TopologyShard(null, null, null)
+ : new TopologyShard(null, links, tps);
+ }
+
+ private static List<Link> initialiseOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
+ OtnLinkType linkType) {
+
+ List<Link> links = new ArrayList<>();
+ String nodeATopo = formatNodeName(nodeA, tpA);
+ String nodeZTopo = formatNodeName(nodeZ, tpZ);
+ org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1 tpceLink1
+ = new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.Link1Builder()
+ .setOtnLinkType(linkType).build();
+ Link1Builder otnLink1Bldr = new Link1Builder()
+ .setUsedBandwidth(Uint32.valueOf(0));
+ if (OTNLINKTYPE_OTU_BW_MAP.containsKey(linkType)) {
+ otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(OTNLINKTYPE_OTU_BW_MAP.get(linkType)));
+ } else if (OTNLINKTYPE_BW_MAP.containsKey(linkType)) {
+ otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(OTNLINKTYPE_BW_MAP.get(linkType)));
+ } else {
+ LOG.error("unable to set available bandwidth to unknown link type");
+ }
+ // create link A-Z
+ LinkBuilder ietfLinkAZBldr = TopologyUtils.createLink(nodeATopo, nodeZTopo, tpA, tpZ, linkType.getName());
+ links.add(ietfLinkAZBldr
+ .addAugmentation(tpceLink1)
+ .addAugmentation(otnLink1Bldr.build())
+ .addAugmentation(
+ new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1Builder(
+ ietfLinkAZBldr.augmentation(
+ org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1.class))
+ .setLinkType(OpenroadmLinkType.OTNLINK)
+ .setOperationalState(State.InService)
+ .setAdministrativeState(AdminStates.InService)
+ .build())
+ .build());
+ // create link Z-A
+ LinkBuilder ietfLinkZABldr = TopologyUtils.createLink(nodeZTopo, nodeATopo, tpZ, tpA, linkType.getName());
+ links.add(ietfLinkZABldr
+ .addAugmentation(tpceLink1)
+ .addAugmentation(otnLink1Bldr.build())
+ .addAugmentation(
+ new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1Builder(
+ ietfLinkZABldr.augmentation(
+ org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1.class))
+ .setLinkType(OpenroadmLinkType.OTNLINK)
+ .setOperationalState(State.InService)
+ .setAdministrativeState(AdminStates.InService)
+ .build())
+ .build());
+ return links;
+ }
+
+ private static Link updateOtnLinkBwParameters(Link link, Long availBw, Long usedBw) {
+
+ LOG.debug("in updateOtnLinkBwParameters with availBw = {}, usedBw = {}", availBw, usedBw);
+ return new LinkBuilder(link)
+ .addAugmentation(
+ new Link1Builder(link.augmentation(Link1.class))
+ .setAvailableBandwidth(Uint32.valueOf(availBw))
+ .setUsedBandwidth(Uint32.valueOf(usedBw))
+ .build())
+ .build();
+ }
+
+ private static List<Link> updateOtnLinkBwParameters(List<Link> supportedLinks, OtnLinkType linkType) {
+
+ LOG.debug("in updateOtnLinkBwParameters with supportedLinks = {}, linkType = {}", supportedLinks, linkType);
+ List<Link> updatedlinks = new ArrayList<>();
+ for (Link link : supportedLinks) {
+ updatedlinks.add(
+ new LinkBuilder(link)
+ .addAugmentation(new Link1Builder(link.augmentation(Link1.class))
+ .setAvailableBandwidth(Uint32.valueOf(0))
+ .setUsedBandwidth(
+ OTNLINKTYPE_BW_MAP.containsKey(linkType)
+ ? Uint32.valueOf(OTNLINKTYPE_BW_MAP.get(linkType))
+ : Uint32.valueOf(0))
+ .build())
+ .build());
+ }
+ return updatedlinks;
+ }
+
+ private static TerminationPoint updateTp(TerminationPoint originalTp, boolean addingTsTpnPoolTermination,
+ OtnLinkType linkType) {
+
+ LOG.debug("in updateTp");
+ TerminationPointBuilder tpBldr = new TerminationPointBuilder(originalTp);
+ TerminationPoint1Builder otnTp1Bldr =
+ new TerminationPoint1Builder(tpBldr.augmentation(TerminationPoint1.class));
+ XpdrTpPortConnectionAttributesBuilder xtpcaBldr =
+ new XpdrTpPortConnectionAttributesBuilder(otnTp1Bldr.getXpdrTpPortConnectionAttributes());
+ if (addingTsTpnPoolTermination) {
+ Set<Uint16> tsPool = new HashSet<>();
+ for (int i = 1; i <= NB_TRIB_SLOTS; i++) {
+ tsPool.add(Uint16.valueOf(i));
+ }
+ xtpcaBldr.setTsPool(tsPool);
+ Set<Uint16> tpnPool = new HashSet<>();
+ int nbTribPort = NB_TRIB_PORTS;
+ if (OtnLinkType.ODUC4.equals(linkType)) {
+ nbTribPort = 4;
+ }
+ for (int i = 1; i <= nbTribPort; i++) {
+ tpnPool.add(Uint16.valueOf(i));
+ }
+ OdtuTpnPool oduTpnPool = new OdtuTpnPoolBuilder()
+ .setOdtuType(ODTU4TsAllocated.class)
+ .setTpnPool(tpnPool)
+ .build();
+ xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(oduTpnPool.key(),oduTpnPool));
+ } else {
+ xtpcaBldr.setTsPool(null);
+ xtpcaBldr.setOdtuTpnPool(ImmutableMap.of());
+ }
+ return tpBldr.addAugmentation(otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build()).build();
+ }
+
+ private static TerminationPoint updateNodeTpTsPool(TerminationPoint tp, Uint32 serviceRate, Short tribPortNb,
+ Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
+
+ LOG.debug("in updateNodeTpTsPool");
+ TerminationPointBuilder tpBldr = new TerminationPointBuilder(tp);
+ @Nullable
+ XpdrTpPortConnectionAttributesBuilder xtpcaBldr =
+ new XpdrTpPortConnectionAttributesBuilder(
+ tpBldr.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes());
+ Set<Uint16> tsPool = new HashSet<>(xtpcaBldr.getTsPool());
+ if (isDeletion) {
+ for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
+ tsPool.add(Uint16.valueOf(i));
+ }
+ } else {
+ for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
+ tsPool.remove(Uint16.valueOf(i));
+ }
+ }
+ xtpcaBldr.setTsPool(tsPool);
+ Set<Uint16> tpnPool;
+ List<OdtuTpnPool> odtuTpnPoolValues = new ArrayList<>(xtpcaBldr.getOdtuTpnPool().values());
+ if (odtuTpnPoolValues.get(0).getTpnPool() == null) {
+ tpnPool = new HashSet<>();
+ } else {
+ tpnPool = new HashSet<>(odtuTpnPoolValues.get(0).getTpnPool());
+ if (isDeletion) {
+ tpnPool.add(Uint16.valueOf(tribPortNb));
+ } else {
+ tpnPool.remove(Uint16.valueOf(tribPortNb));
+ }
+ }
+ Class<? extends OdtuTypeIdentity> odtuType;
+ if (SERVICERATE_ODTUTYPECLASS_MAP.containsKey(serviceRate)) {
+ odtuType = SERVICERATE_ODTUTYPECLASS_MAP.get(serviceRate);
+ } else {
+ odtuType = null;
+ LOG.warn("Unable to set the odtu-type");
+ }
+ OdtuTpnPool odtuTpnPool = new OdtuTpnPoolBuilder()
+ .setOdtuType(odtuType)
+ .setTpnPool(tpnPool)
+ .build();
+ return tpBldr
+ .addAugmentation(
+ new TerminationPoint1Builder(tp.augmentation(TerminationPoint1.class))
+ .setXpdrTpPortConnectionAttributes(
+ xtpcaBldr
+ .setOdtuTpnPool(ImmutableMap.of(odtuTpnPool.key(),odtuTpnPool))
+ .build())
+ .build())
+ .build();
+ }
+