-
- Optional<InterVpnLinks> optIVpnLinksOpData =
- MDSALUtil.read(dataBroker, LogicalDatastoreType.CONFIGURATION, interVpnLinksIid);
-
- if (!optIVpnLinksOpData.isPresent()) {
- return; // Nothing to be added to cache
- }
- InterVpnLinks interVpnLinks = optIVpnLinksOpData.get();
- for (InterVpnLink interVpnLink : interVpnLinks.nonnullInterVpnLink()) {
- addInterVpnLinkToCaches(interVpnLink);
- }
-
- // Now the States
- InstanceIdentifier<InterVpnLinkStates> interVpnLinkStateIid =
- InstanceIdentifier.builder(InterVpnLinkStates.class).build();
-
- Optional<InterVpnLinkStates> optIVpnLinkStateOpData =
- MDSALUtil.read(dataBroker, LogicalDatastoreType.CONFIGURATION, interVpnLinkStateIid);
- if (!optIVpnLinkStateOpData.isPresent()) {
- return;
- }
- InterVpnLinkStates interVpnLinkStates = optIVpnLinkStateOpData.get();
- for (InterVpnLinkState interVpnLinkState : interVpnLinkStates.nonnullInterVpnLinkState()) {
- addInterVpnLinkStateToCaches(interVpnLinkState);
+ try {
+ Optional<InterVpnLinks> optIVpnLinksOpData = SingleTransactionDataBroker.syncReadOptional(dataBroker,
+ LogicalDatastoreType.CONFIGURATION, interVpnLinksIid);
+ if (!optIVpnLinksOpData.isPresent()) {
+ return; // Nothing to be added to cache
+ }
+ InterVpnLinks interVpnLinks = optIVpnLinksOpData.get();
+ for (InterVpnLink interVpnLink : interVpnLinks.nonnullInterVpnLink()) {
+ addInterVpnLinkToCaches(interVpnLink);
+ }
+
+ // Now the States
+ InstanceIdentifier<InterVpnLinkStates> interVpnLinkStateIid =
+ InstanceIdentifier.builder(InterVpnLinkStates.class).build();
+
+ Optional<InterVpnLinkStates> optIVpnLinkStateOpData =
+ SingleTransactionDataBroker.syncReadOptional(dataBroker, LogicalDatastoreType.CONFIGURATION,
+ interVpnLinkStateIid);
+ if (!optIVpnLinkStateOpData.isPresent()) {
+ return;
+ }
+ InterVpnLinkStates interVpnLinkStates = optIVpnLinkStateOpData.get();
+ for (InterVpnLinkState interVpnLinkState : interVpnLinkStates.nonnullInterVpnLinkState()) {
+ addInterVpnLinkStateToCaches(interVpnLinkState);
+ }
+ } catch (ExecutionException | InterruptedException e) {
+ LOG.error("initialFeed: Exception while reading interVpnLink DS", e);