package org.opendaylight.ovsdb.hwvtepsouthbound.transactions.md;
-import com.google.common.base.Optional;
-
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Map;
-
import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.opendaylight.ovsdb.hwvtepsouthbound.HwvtepConnectionInstance;
import org.opendaylight.ovsdb.hwvtepsouthbound.HwvtepSouthboundMapper;
-import org.opendaylight.ovsdb.hwvtepsouthbound.HwvtepSouthboundUtil;
import org.opendaylight.ovsdb.lib.message.TableUpdates;
import org.opendaylight.ovsdb.lib.notation.UUID;
import org.opendaylight.ovsdb.lib.schema.DatabaseSchema;
private final Map<UUID, UcastMacsLocal> updatedUMacsLocalRows;
private final Map<UUID, PhysicalLocator> updatedPLocRows;
- public HwvtepUcastMacsLocalUpdateCommand(HwvtepConnectionInstance key, TableUpdates updates, DatabaseSchema dbSchema) {
+ public HwvtepUcastMacsLocalUpdateCommand(HwvtepConnectionInstance key, TableUpdates updates,
+ DatabaseSchema dbSchema) {
super(key, updates, dbSchema);
updatedUMacsLocalRows = TyperUtils.extractRowsUpdated(UcastMacsLocal.class, getUpdates(), getDbSchema());
updatedPLocRows = TyperUtils.extractRowsUpdated(PhysicalLocator.class, getUpdates(), getDbSchema());
InstanceIdentifier<Node> nodeIid = getOvsdbConnectionInstance().getInstanceIdentifier();
HwvtepGlobalAugmentationBuilder hgAugmentationBuilder = new HwvtepGlobalAugmentationBuilder();
List<LocalUcastMacs> umclList = new ArrayList<>();
- ucml.forEach( (mac) -> umclList.add(buildLocalUcastMac(mac)));
+ ucml.forEach(mac -> umclList.add(buildLocalUcastMac(mac)));
hgAugmentationBuilder.setLocalUcastMacs(umclList);
connectionNode.addAugmentation(HwvtepGlobalAugmentation.class, hgAugmentationBuilder.build());
return connectionNode.build();
UUID plocUUID = ucml.getLocatorColumn().getData();
PhysicalLocator physicalLocator = updatedPLocRows.get(plocUUID);
if (physicalLocator == null) {
- physicalLocator = (PhysicalLocator) getOvsdbConnectionInstance().
- getDeviceInfo().getDeviceOperData(TerminationPoint.class, plocUUID);
+ physicalLocator = (PhysicalLocator) getOvsdbConnectionInstance()
+ .getDeviceInfo().getDeviceOperData(TerminationPoint.class, plocUUID);
}
if (physicalLocator != null) {
InstanceIdentifier<TerminationPoint> plIid =
UUID lsUUID = ucml.getLogicalSwitchColumn().getData();
LogicalSwitch logicalSwitch = getOvsdbConnectionInstance().getDeviceInfo().getLogicalSwitch(lsUUID);
if (logicalSwitch != null) {
- InstanceIdentifier<LogicalSwitches> lSwitchIid =
+ InstanceIdentifier<LogicalSwitches> switchIid =
HwvtepSouthboundMapper.createInstanceIdentifier(getOvsdbConnectionInstance(), logicalSwitch);
- ucmlBuilder.setLogicalSwitchRef(new HwvtepLogicalSwitchRef(lSwitchIid));
+ ucmlBuilder.setLogicalSwitchRef(new HwvtepLogicalSwitchRef(switchIid));
}
}
return ucmlBuilder.build();
}
-
-}
\ No newline at end of file
+}