- private OvsdbBridgeAugmentation getBridge(InstanceIdentifier<?> key, Map<InstanceIdentifier<Node>, Node> nodes) {
- OvsdbBridgeAugmentation bridge = null;
- InstanceIdentifier<Node> nodeIid = key.firstIdentifierOf(Node.class);
- if (nodes != null && nodes.get(nodeIid) != null) {
- Node node = nodes.get(nodeIid);
- bridge = node.getAugmentation(OvsdbBridgeAugmentation.class);
- if (bridge == null) {
- ReadOnlyTransaction transaction = SouthboundProvider.getDb().newReadOnlyTransaction();
- CheckedFuture<Optional<Node>, ReadFailedException> future =
- transaction.read(LogicalDatastoreType.OPERATIONAL, nodeIid);
- try {
- Optional<Node> nodeOptional = future.get();
- if (nodeOptional.isPresent()) {
- bridge = nodeOptional.get().getAugmentation(OvsdbBridgeAugmentation.class);
- }
- } catch (InterruptedException | ExecutionException e) {
- LOG.warn("Error reading from datastore",e);
- }
- transaction.close();
- }
- }
- return bridge;
- }
-
- public static void stampInstanceIdentifier(TransactionBuilder transaction, InstanceIdentifier
- <OvsdbTerminationPointAugmentation> iid, String interfaceName) {
- Port port = TyperUtils.getTypedRowWrapper(transaction.getDatabaseSchema(), Port.class);
+ public static void stampInstanceIdentifier(final TransactionBuilder transaction,
+ final InstanceIdentifier<OvsdbTerminationPointAugmentation> iid, final String interfaceName,
+ final InstanceIdentifierCodec instanceIdentifierCodec) {
+ Port port = transaction.getTypedRowWrapper(Port.class);