import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.stream.Collectors;
+
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
for (Ports port : cp.getPorts()) {
if (Port.PortQual.XpdrNetwork.equals(port.getPortQual())) {
portMapList.add(createMappingObject(nodeId, port, circuitPackName,
- "XPDR1-"+OpenRoadmInterfacesImpl.NETWORK_TOKEN + line));
+ "XPDR1-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN + line));
//String lcp = port.getLogicalConnectionPoint();
//String regex = "XPDR[0-9]+-NETWORK[0-9]+";
//checkLogicalConnectionPoint(regex, lcp, nodeId, portMapList, circuitPackName, port, "NETWORK", line);
line++;
} else if (Port.PortQual.XpdrClient.equals(port.getPortQual())) {
portMapList.add(createMappingObject(nodeId, port, circuitPackName,
- "XPDR1-"+OpenRoadmInterfacesImpl.CLIENT_TOKEN + client));
+ "XPDR1-" + OpenRoadmInterfacesImpl.CLIENT_TOKEN + client));
//String lcp = port.getLogicalConnectionPoint();
//String regex = "XPDR[0-9]+-CLIENT[0-9]+";
//checkLogicalConnectionPoint(regex, lcp, nodeId, portMapList, circuitPackName, port, "CLIENT", client);
@Override
public boolean updateMapping(String nodeId, Mapping oldMapping) {
+ LOG.info("Updating Mapping Data {} for node {}", oldMapping, nodeId);
InstanceIdentifier<Ports> portIId = InstanceIdentifier.create(OrgOpenroadmDevice.class).child(
CircuitPacks.class, new CircuitPacksKey(oldMapping.getSupportingCircuitPackName())).child(Ports.class,
new PortsKey(oldMapping.getSupportingPort()));