networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, iiOpenRoadmTopologyLink,
openRoadmTopologyLink, CREATE_MISSING_PARENTS);
}
- networkTransactionService.submit().get();
+ networkTransactionService.commit().get();
LOG.info("all nodes and links created");
} catch (InterruptedException | ExecutionException e) {
LOG.error("ERROR: ", e);
} else {
LOG.warn("TopologyShard for node '{}' is not present", nodeId);
}
- this.networkTransactionService.submit().get(1, TimeUnit.SECONDS);
+ this.networkTransactionService.commit().get(1, TimeUnit.SECONDS);
LOG.info("all nodes and links deleted ! ");
} catch (InterruptedException | ExecutionException | TimeoutException e) {
LOG.error("Error when trying to delete node : {}", nodeId, e);
new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)));
this.networkTransactionService.put(LogicalDatastoreType.CONFIGURATION, nwIID.build(), openRoadmTopology);
- this.networkTransactionService.submit().get(1, TimeUnit.SECONDS);
+ this.networkTransactionService.commit().get(1, TimeUnit.SECONDS);
LOG.info("OpenRoadm-Topology created successfully.");
} catch (ExecutionException | TimeoutException | InterruptedException e) {
LOG.warn("Failed to create OpenRoadm-Topology", e);
linkBuilder.addAugmentation(Link1.class,link1Builder.build());
networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
linkBuilder.build());
- networkTransactionService.submit().get(1, TimeUnit.SECONDS);
+ networkTransactionService.commit().get(1, TimeUnit.SECONDS);
return true;
} else {
LOG.error("No link found for given LinkId: {}",
linkBuilder.addAugmentation(Link1.class,link1Builder.build());
networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
linkBuilder.build());
- networkTransactionService.submit().get(1, TimeUnit.SECONDS);
+ networkTransactionService.commit().get(1, TimeUnit.SECONDS);
return true;
} else {
LOG.error("No link found for given LinkId: {}",