import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.meta.rev160406.bridge.ref.info.BridgeRefEntryKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.DatapathId;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentationBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeRef;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.BridgeOtherConfigsBuilder;
otherConfigsBuilder.setBridgeOtherConfigValue(computeName);
bridge.setDatapathId(new DatapathId(datapathid));
bridge.setBridgeOtherConfigs(Lists.newArrayList(otherConfigsBuilder.build()));
- nodeBuilder.addAugmentation(OvsdbBridgeAugmentation.class,bridge.build());
+ nodeBuilder.addAugmentation(bridge.build());
return nodeBuilder.build();
}
throws ExecutionException, InterruptedException, TransactionCommitFailedException {
Set<Uint64> nodesRecoverd = new HashSet<>();
- tombstonedNodeManager.addOnRecoveryCallback((dpnId) -> {
+ tombstonedNodeManager.addOnRecoveryCallback(dpnId -> {
nodesRecoverd.add(dpnId);
return null;
});
*/
package org.opendaylight.genius.testutils.interfacemanager;
-import java.util.Collections;
import java.util.concurrent.ExecutionException;
import org.opendaylight.genius.datastoreutils.ExpectedDataObjectNotFoundException;
import org.opendaylight.genius.datastoreutils.SingleTransactionDataBroker;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnel;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnelBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefs;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefsBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeVxlan;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
}
public static Interface buildVlanInterfaceFromInfo(InterfaceInfo interfaceInfo) {
- ParentRefs parentRefs = new ParentRefsBuilder()
- .setDatapathNodeIdentifier(interfaceInfo.getDpId())
- .setParentInterface(interfaceInfo.getInterfaceName())
- .build();
-
return new InterfaceBuilder()
.withKey(new InterfaceKey(interfaceInfo.getInterfaceName()))
.setName(interfaceInfo.getInterfaceName())
.setDescription("Vlan interface")
.setEnabled(true)
.setType(L2vlan.class)
- .addAugmentation(ParentRefs.class, parentRefs)
+ .addAugmentation(new ParentRefsBuilder()
+ .setDatapathNodeIdentifier(interfaceInfo.getDpId())
+ .setParentInterface(interfaceInfo.getInterfaceName())
+ .build())
.build();
}
public static Interface buildVxlanTunnelInterfaceFromInfo(TunnelInterfaceDetails tunnelInterfaceDetails) {
InterfaceInfo interfaceInfo = tunnelInterfaceDetails.getInterfaceInfo();
- ParentRefs parentRefs = new ParentRefsBuilder()
- .setDatapathNodeIdentifier(interfaceInfo.getDpId())
- .setParentInterface(interfaceInfo.getInterfaceName())
- .build();
-
- IfTunnel tunnel = new IfTunnelBuilder()
- .setTunnelDestination(new IpAddress(new Ipv4Address(tunnelInterfaceDetails.getDstIp())))
- .setTunnelGateway(new IpAddress(new Ipv4Address(DEFAULT_GW)))
- .setTunnelSource(new IpAddress(new Ipv4Address(tunnelInterfaceDetails.getSrcIp())))
- .setTunnelInterfaceType(TunnelTypeVxlan.class)
- .setInternal(!tunnelInterfaceDetails.isExternal())
- .setTunnelRemoteIpFlow(false)
- .setTunnelOptions(Collections.emptyList())
- .build();
return new InterfaceBuilder()
.withKey(new InterfaceKey(interfaceInfo.getInterfaceName()))
.setDescription("Tunnel interface")
.setEnabled(true)
.setType(Tunnel.class)
- .addAugmentation(ParentRefs.class, parentRefs)
- .addAugmentation(IfTunnel.class, tunnel)
+ .addAugmentation(new ParentRefsBuilder()
+ .setDatapathNodeIdentifier(interfaceInfo.getDpId())
+ .setParentInterface(interfaceInfo.getInterfaceName())
+ .build())
+ .addAugmentation(new IfTunnelBuilder()
+ .setTunnelDestination(new IpAddress(new Ipv4Address(tunnelInterfaceDetails.getDstIp())))
+ .setTunnelGateway(new IpAddress(new Ipv4Address(DEFAULT_GW)))
+ .setTunnelSource(new IpAddress(new Ipv4Address(tunnelInterfaceDetails.getSrcIp())))
+ .setTunnelInterfaceType(TunnelTypeVxlan.class)
+ .setInternal(!tunnelInterfaceDetails.isExternal())
+ .setTunnelRemoteIpFlow(false)
+ .build())
.build();
}
}
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
+import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.concurrent.ExecutionException;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceModeIngress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceTypeFlowBased;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflow;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflowBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.ServicesInfo;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.ServicesInfoBuilder;
}
public static ServicesInfo buildServiceInfo(String serviceName, Uint8 servicePriority) {
- List<BoundServices> boundService = new ArrayList<>();
- boundService.add(new BoundServicesBuilder().setServicePriority(servicePriority)
- .setServiceName(serviceName).build());
- return new ServicesInfoBuilder().setBoundServices(boundService)
+ BoundServices boundService = new BoundServicesBuilder()
+ .setServicePriority(servicePriority)
+ .setServiceName(serviceName)
+ .build();
+ return new ServicesInfoBuilder().setBoundServices(Map.of(boundService.key(), boundService))
.withKey(new ServicesInfoKey(serviceName, ServiceModeIngress.class)).build();
}
.setInstruction(instructions);
return new BoundServicesBuilder().withKey(new BoundServicesKey(servicePriority)).setServiceName(serviceName)
.setServicePriority(servicePriority).setServiceType(ServiceTypeFlowBased.class)
- .addAugmentation(StypeOpenflow.class, augBuilder.build()).build();
+ .addAugmentation(augBuilder.build()).build();
}
public static List<MatchInfo> getMatchInfoForVlanLPort(Uint64 dpId, long portNo, long vlanId,
private Map<InstanceIdentifier<Node>, OvsdbBridgeAugmentation> nodeIidToBridgeMap;
private EntityOwnershipCandidateRegistration configEntityCandidate;
private EntityOwnershipCandidateRegistration bindingEntityCandidate;
- private InternalTunnelCache internalTunnelCache;
+ private final InternalTunnelCache internalTunnelCache;
@Inject
public InterfacemgrProvider(@Reference final DataBroker dataBroker,
if (vlanId != null && vlanId > 0) {
l2vlanBuilder.setVlanId(new VlanId(vlanId));
}
- ParentRefs parentRefs = new ParentRefsBuilder().setParentInterface(portName).build();
InterfaceBuilder interfaceBuilder = new InterfaceBuilder().setEnabled(true).setName(interfaceName)
- .setType(L2vlan.class).addAugmentation(IfL2vlan.class, l2vlanBuilder.build())
- .addAugmentation(ParentRefs.class, parentRefs).setDescription(description);
+ .setType(L2vlan.class).addAugmentation(l2vlanBuilder.build())
+ .addAugmentation(new ParentRefsBuilder().setParentInterface(portName).build())
+ .setDescription(description);
if (isExternal) {
- interfaceBuilder.addAugmentation(IfExternal.class, new IfExternalBuilder().setExternal(true).build());
+ interfaceBuilder.addAugmentation(new IfExternalBuilder().setExternal(true).build());
}
InstanceIdentifier<Interface> interfaceIId = InterfaceManagerCommonUtils
.getInterfaceIdentifier(new InterfaceKey(interfaceName));
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnel;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.EncapsulationTypeVxlanOverIpv4;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalLocatorAugmentation;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalLocatorAugmentationBuilder;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
tpBuilder.setTpId(terminationPointKey.getTpId());
tpAugmentationBuilder.setEncapsulationType(EncapsulationTypeVxlanOverIpv4.class);
SouthboundUtils.setDstIp(tpAugmentationBuilder, destIPAddress);
- tpBuilder.addAugmentation(HwvtepPhysicalLocatorAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
LOG.debug("creating physical locator entry for {}", terminationPointKey);
transaction.mergeParentStructurePut(tpPath, tpBuilder.build());
}
new CacheConfigBuilder<String, String>()
.anchor(this)
.id("ovsVersionCache")
- .cacheFunction(key -> getVersionForBridgeNodeId(key))
+ .cacheFunction(this::getVersionForBridgeNodeId)
.description("BridgeNodeId to OVS Version cache")
.build(),
new CachePolicyBuilder().maxEntries(MAX_CACHE_SIZE).build());
if (iface != null) {
IfTunnel ifTunnel = iface.augmentation(IfTunnel.class);
if (ifTunnel != null) {
- if (!(interfacemgrProvider.isItmDirectTunnelsEnabled() && ifTunnel.isInternal())) {
+ if (!interfacemgrProvider.isItmDirectTunnelsEnabled() || !ifTunnel.isInternal()) {
addTunnelPortToBridge(ifTunnel, bridgeIid, iface, portName);
}
if (isOfTunnel(ifTunnel)) {
}
LOG.debug("update bfd parameters for interface {}", tpIid);
OvsdbTerminationPointAugmentationBuilder tpAugmentationBuilder = new OvsdbTerminationPointAugmentationBuilder();
- List<InterfaceBfd> bfdParams = getBfdParams(ifTunnel);
- tpAugmentationBuilder.setInterfaceBfd(bfdParams);
+ tpAugmentationBuilder.setInterfaceBfd(getBfdParams(ifTunnel));
TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
tpBuilder.withKey(InstanceIdentifier.keyOf(tpIid));
- tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
transaction.mergeParentStructureMerge(tpIid, tpBuilder.build());
}
if (isOfTunnel(ifTunnel)) {
LOG.warn("BFD Monitoring not supported for OFTunnels");
} else {
- List<InterfaceBfd> bfdParams = getBfdParams(ifTunnel);
- tpAugmentationBuilder.setInterfaceBfd(bfdParams);
+ tpAugmentationBuilder.setInterfaceBfd(getBfdParams(ifTunnel));
}
TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
InstanceIdentifier<TerminationPoint> tpIid = createTerminationPointInstanceIdentifier(
InstanceIdentifier.keyOf(bridgeIid.firstIdentifierOf(Node.class)), portName);
tpBuilder.withKey(InstanceIdentifier.keyOf(tpIid));
- tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
batchingUtils.write(tpIid, tpBuilder.build(), BatchingUtils.EntityType.TOPOLOGY_CONFIG);
}
.setInstruction(instructions);
return new BoundServicesBuilder().withKey(new BoundServicesKey(servicePriority)).setServiceName(serviceName)
.setServicePriority(servicePriority).setServiceType(ServiceTypeFlowBased.class)
- .addAugmentation(StypeOpenflow.class, augBuilder.build()).build();
+ .addAugmentation(augBuilder.build()).build();
}
public static InstanceIdentifier<BoundServices> buildServiceId(String interfaceName, short serviceIndex) {
interfaceBfd.sort(Comparator.comparing(o -> o.key().toString()));
newOvsdbTpAugmentationBuilder.setInterfaceBfd(interfaceBfd);
}
- newTpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class,
- newOvsdbTpAugmentationBuilder.build());
+ newTpBuilder.addAugmentation(newOvsdbTpAugmentationBuilder.build());
}
return newTpBuilder.build();
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceBindings;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceModeIngress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceTypeFlowBased;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflow;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflowBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.ServicesInfo;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.ServicesInfoKey;
NodeConnectorBuilder ncBuilder = new NodeConnectorBuilder()
.setId(ncId)
.withKey(new NodeConnectorKey(ncId));
- ncBuilder.addAugmentation(FlowCapableNodeConnector.class,
- buildFlowCapableNodeConnector(false, isLive,"AA:AA:AA:AA:AA:AA", portName));
+ ncBuilder.addAugmentation(buildFlowCapableNodeConnector(false, isLive,"AA:AA:AA:AA:AA:AA", portName));
return ncBuilder.build();
}
String parentInterface, IfL2vlan.L2vlanMode l2vlanMode) {
InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifName)).setName(ifName)
.setDescription(desc).setEnabled(enabled).setType((Class<? extends InterfaceType>) ifType);
- ParentRefs parentRefs = new ParentRefsBuilder().setParentInterface(parentInterface).build();
- builder.addAugmentation(ParentRefs.class, parentRefs);
+ builder.addAugmentation(new ParentRefsBuilder().setParentInterface(parentInterface).build());
if (ifType.equals(L2vlan.class)) {
IfL2vlanBuilder ifL2vlanBuilder = new IfL2vlanBuilder().setL2vlanMode(l2vlanMode);
if (IfL2vlan.L2vlanMode.TrunkMember.equals(l2vlanMode)) {
} else {
ifL2vlanBuilder.setVlanId(VlanId.getDefaultInstance("0"));
}
- builder.addAugmentation(IfL2vlan.class, ifL2vlanBuilder.build());
+ builder.addAugmentation(ifL2vlanBuilder.build());
} else if (ifType.equals(IfTunnel.class)) {
- IfTunnel tunnel = new IfTunnelBuilder().setTunnelDestination(null).setTunnelGateway(null)
- .setTunnelSource(null).setTunnelInterfaceType(null).build();
- builder.addAugmentation(IfTunnel.class, tunnel);
+ builder.addAugmentation(new IfTunnelBuilder().setTunnelDestination(null).setTunnelGateway(null)
+ .setTunnelSource(null).setTunnelInterfaceType(null).build());
}
return builder.build();
}
static Interface buildTunnelInterface(BigInteger dpn, String ifName, String desc, boolean enabled,
Class<? extends TunnelTypeBase> tunType, String remoteIpStr,
String localIpStr) {
- InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifName)).setName(ifName)
- .setDescription(desc).setEnabled(enabled).setType(Tunnel.class);
- ParentRefs parentRefs = new ParentRefsBuilder().setDatapathNodeIdentifier(dpn).build();
- builder.addAugmentation(ParentRefs.class, parentRefs);
IpAddress remoteIp = new IpAddress(Ipv4Address.getDefaultInstance(remoteIpStr));
IpAddress localIp = new IpAddress(Ipv4Address.getDefaultInstance(localIpStr));
- IfTunnel tunnel = new IfTunnelBuilder().setTunnelDestination(remoteIp).setTunnelGateway(localIp)
- .setTunnelSource(localIp).setTunnelInterfaceType(tunType).setInternal(true).setMonitorEnabled(false)
+ return new InterfaceBuilder()
+ .withKey(new InterfaceKey(ifName))
+ .setDescription(desc)
+ .setEnabled(enabled)
+ .setType(Tunnel.class)
+ .addAugmentation(new ParentRefsBuilder().setDatapathNodeIdentifier(dpn).build())
+ .addAugmentation(new IfTunnelBuilder()
+ .setTunnelDestination(remoteIp)
+ .setTunnelGateway(localIp)
+ .setTunnelSource(localIp)
+ .setTunnelInterfaceType(tunType)
+ .setInternal(true)
+ .setMonitorEnabled(false)
+ .build())
.build();
- builder.addAugmentation(IfTunnel.class, tunnel);
- return builder.build();
}
static InstanceIdentifier<TerminationPoint> getTerminationPointId(InstanceIdentifier<?> bridgeIid,
static void updateTunnelMonitoringAttributes(DataBroker dataBroker, String ifaceName)
throws ExecutionException, InterruptedException {
InstanceIdentifier<Interface> tunnelInstanceIdentifier = IfmUtil.buildId(ifaceName);
- InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifaceName)).setName(ifaceName);
- IfTunnel tunnel = new IfTunnelBuilder().setMonitorProtocol(TunnelMonitoringTypeBfd.class)
- .setMonitorEnabled(true).build();
- builder.addAugmentation(IfTunnel.class, tunnel);
WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
- tx.merge(CONFIGURATION, tunnelInstanceIdentifier, builder.build());
+ tx.merge(CONFIGURATION, tunnelInstanceIdentifier, new InterfaceBuilder()
+ .withKey(new InterfaceKey(ifaceName))
+ .setName(ifaceName)
+ .addAugmentation(new IfTunnelBuilder()
+ .setMonitorProtocol(TunnelMonitoringTypeBfd.class)
+ .setMonitorEnabled(true)
+ .build())
+ .build());
tx.commit().get();
}
-
static void putInterfaceConfig(DataBroker dataBroker, String ifaceName, ParentRefs parentRefs,
Class<? extends InterfaceType> ifType)
throws ExecutionException, InterruptedException {
.setInstruction(instructions);
return new BoundServicesBuilder().withKey(new BoundServicesKey(servicePriority)).setServiceName(serviceName)
.setServicePriority(servicePriority).setServiceType(ServiceTypeFlowBased.class)
- .addAugmentation(StypeOpenflow.class, augBuilder.build()).build();
+ .addAugmentation(augBuilder.build()).build();
}
static InstanceIdentifier<BoundServices> buildServiceId(String vpnInterfaceName, short serviceIndex) {
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentationBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeName;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentationBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntry;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntryBuilder;
OvsdbBridgeAugmentationBuilder bridgeCreateAugmentationBuilder = new OvsdbBridgeAugmentationBuilder();
bridgeCreateAugmentationBuilder.setBridgeName(ovsdbBridgeName)
.setDatapathId(new DatapathId("00:00:00:00:00:00:00:01"));
- bridgeCreateNodeBuilder.addAugmentation(OvsdbBridgeAugmentation.class, bridgeCreateAugmentationBuilder.build());
+ bridgeCreateNodeBuilder.addAugmentation(bridgeCreateAugmentationBuilder.build());
LOG.debug("Built with the intent to store bridge data {}", bridgeCreateAugmentationBuilder.toString());
WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
tx.mergeParentStructurePut(LogicalDatastoreType.OPERATIONAL, ovsdbBridgeIid,
OvsdbBridgeAugmentationBuilder bridgeCreateAugmentationBuilder = new OvsdbBridgeAugmentationBuilder();
bridgeCreateAugmentationBuilder.setBridgeName(ovsdbBridgeName)
.setDatapathId(new DatapathId(datapathId));
- bridgeCreateNodeBuilder.addAugmentation(OvsdbBridgeAugmentation.class, bridgeCreateAugmentationBuilder.build());
+ bridgeCreateNodeBuilder.addAugmentation(bridgeCreateAugmentationBuilder.build());
LOG.debug("Built with the intent to store bridge data {}", bridgeCreateAugmentationBuilder.toString());
WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
tx.mergeParentStructureMerge(LogicalDatastoreType.OPERATIONAL, ovsdbBridgeIid,
interfaceExternalIds.add(interfaceExternalIds1);
tpAugmentationBuilder.setInterfaceExternalIds(interfaceExternalIds);
}
- tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
tx.mergeParentStructurePut(OPERATIONAL, tpId, tpBuilder.build());
tx.commit().get();
.setBfdStatusKey("state").setBfdStatusValue("down").build());
tpAugmentationBuilder.setInterfaceBfdStatus(interfaceBfdStatuses);
- tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
tx.mergeParentStructureMerge(OPERATIONAL, tpId, tpBuilder.build());
tx.commit().get();
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev170119.L2vlan
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceBuilder
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfExternal
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfExternalBuilder
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan.L2vlanMode
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlanBuilder
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefs
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefsBuilder
import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId
description = interfaceName
name = interfaceName
type = L2vlan
- addAugmentation(ParentRefs, new ParentRefsBuilder >> [
+ addAugmentation(new ParentRefsBuilder >> [
parentInterface = "tap23701c04-7e"
- ])addAugmentation(IfL2vlan, new IfL2vlanBuilder >> [
+ ])addAugmentation(new IfL2vlanBuilder >> [
l2vlanMode = L2vlanMode.Trunk
vlanId = new VlanId(0)
])
description = interfaceName
name = interfaceName
type = L2vlan
- addAugmentation(IfL2vlan, new IfL2vlanBuilder >> [
+ addAugmentation(new IfL2vlanBuilder >> [
l2vlanMode = L2vlanMode.Trunk
- ])addAugmentation(ParentRefs, new ParentRefsBuilder >> [
+ ])addAugmentation(new ParentRefsBuilder >> [
parentInterface = parentRef
])
]
description = interfaceName
name = interfaceName
type = L2vlan
- addAugmentation(IfExternal, new IfExternalBuilder >> [
+ addAugmentation(new IfExternalBuilder >> [
external = true
])
- addAugmentation(IfL2vlan, new IfL2vlanBuilder >> [
+ addAugmentation(new IfL2vlanBuilder >> [
l2vlanMode = L2vlanMode.Trunk
- ])addAugmentation(ParentRefs, new ParentRefsBuilder >> [
+ ])addAugmentation(new ParentRefsBuilder >> [
parentInterface = parentRefs
])
]
description = interfaceName
name = interfaceName
type = L2vlan
- addAugmentation(IfL2vlan, new IfL2vlanBuilder >> [
+ addAugmentation(new IfL2vlanBuilder >> [
l2vlanMode = L2vlanMode.Trunk
vlanId = new VlanId(0)
- ])addAugmentation(ParentRefs, new ParentRefsBuilder >> [
+ ])addAugmentation(new ParentRefsBuilder >> [
parentInterface = parentRefs
])
]
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActionsBuilder
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceTypeFlowBased
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflow
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflowBuilder
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.services.info.BoundServicesBuilder
serviceName = "default.23701c04-7e58-4c65-9425-78a80d49a218"
servicePriority = 9 as short
serviceType = ServiceTypeFlowBased
- addAugmentation(StypeOpenflow, new StypeOpenflowBuilder >> [
+ addAugmentation(new StypeOpenflowBuilder >> [
flowCookie = 134217735bi
flowPriority = 9
instruction = #[
package org.opendaylight.genius.interfacemanager.test.xtend
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.InterfaceTypeVxlan
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentationBuilder
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceBfdBuilder
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.port._interface.attributes.InterfaceExternalIdsBuilder
static def newTerminationPoint() {
new TerminationPointBuilder >> [
tpId = new TpId("tun414a856a7a4")
- addAugmentation(OvsdbTerminationPointAugmentation, new OvsdbTerminationPointAugmentationBuilder >> [
+ addAugmentation(new OvsdbTerminationPointAugmentationBuilder >> [
interfaceType = InterfaceTypeVxlan
name = "tun414a856a7a4"
options = #[
static def newBfdEnabledTerminationPoint() {
new TerminationPointBuilder >> [
tpId = new TpId("tun414a856a7a4")
- addAugmentation(OvsdbTerminationPointAugmentation, new OvsdbTerminationPointAugmentationBuilder >> [
+ addAugmentation(new OvsdbTerminationPointAugmentationBuilder >> [
interfaceBfd = #[
new InterfaceBfdBuilder >> [
bfdKey = "forwarding_if_rx"
}
public static Interface buildLogicalTunnelInterface(Uint64 dpn, String ifName, String desc, boolean enabled) {
- InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifName)).setName(ifName)
- .setDescription(desc).setEnabled(enabled).setType(Tunnel.class);
- ParentRefs parentRefs = new ParentRefsBuilder().setDatapathNodeIdentifier(dpn).build();
- builder.addAugmentation(ParentRefs.class, parentRefs);
-
- IfTunnel tunnel = new IfTunnelBuilder()
- .setTunnelDestination(IpAddressBuilder.getDefaultInstance(ITMConstants.DUMMY_IP_ADDRESS))
- .setTunnelSource(IpAddressBuilder.getDefaultInstance(ITMConstants.DUMMY_IP_ADDRESS)).setInternal(true)
- .setMonitorEnabled(false).setTunnelInterfaceType(TunnelTypeLogicalGroup.class)
- .setTunnelRemoteIpFlow(false).build();
- builder.addAugmentation(IfTunnel.class, tunnel);
- return builder.build();
+ return new InterfaceBuilder().withKey(new InterfaceKey(ifName)).setName(ifName)
+ .setDescription(desc).setEnabled(enabled).setType(Tunnel.class)
+ .addAugmentation(new ParentRefsBuilder().setDatapathNodeIdentifier(dpn).build())
+ .addAugmentation(new IfTunnelBuilder()
+ .setTunnelDestination(IpAddressBuilder.getDefaultInstance(ITMConstants.DUMMY_IP_ADDRESS))
+ .setTunnelSource(IpAddressBuilder.getDefaultInstance(ITMConstants.DUMMY_IP_ADDRESS))
+ .setInternal(true).setMonitorEnabled(false).setTunnelInterfaceType(TunnelTypeLogicalGroup.class)
+ .setTunnelRemoteIpFlow(false)
+ .build())
+ .build();
}
public static Interface buildTunnelInterface(Uint64 dpn, String ifName, String desc, boolean enabled,
List<TunnelOptions> tunnelOptions) {
InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifName)).setName(ifName)
.setDescription(desc).setEnabled(enabled).setType(Tunnel.class);
- ParentRefs parentRefs =
- new ParentRefsBuilder().setDatapathNodeIdentifier(dpn).setParentInterface(parentIfaceName).build();
- builder.addAugmentation(ParentRefs.class, parentRefs);
+ builder.addAugmentation(new ParentRefsBuilder()
+ .setDatapathNodeIdentifier(dpn)
+ .setParentInterface(parentIfaceName)
+ .build());
Long monitoringInterval = null;
LOG.debug("buildTunnelInterface: monitorProtocol = {} and monitorInterval = {}",
monitorProtocol.getName(), monitorInterval);
monitoringInterval = monitorInterval.longValue();
}
- IfTunnel tunnel = new IfTunnelBuilder().setTunnelDestination(remoteIp)
- .setTunnelSource(localIp).setTunnelInterfaceType(tunType)
+ return builder.addAugmentation(new IfTunnelBuilder()
+ .setTunnelDestination(remoteIp).setTunnelSource(localIp).setTunnelInterfaceType(tunType)
.setMonitorEnabled(monitorEnabled).setMonitorProtocol(monitorProtocol)
.setMonitorInterval(monitoringInterval).setTunnelRemoteIpFlow(useOfTunnel)
.setTunnelOptions(tunnelOptions).setInternal(internal)
+ .build())
.build();
- builder.addAugmentation(IfTunnel.class, tunnel);
- return builder.build();
}
public static Interface buildHwTunnelInterface(String tunnelIfName, String desc, boolean enabled, String topoId,
NodeIdentifier hwNode = new NodeIdentifierBuilder().withKey(new NodeIdentifierKey(topoId))
.setTopologyId(topoId).setNodeId(nodeId).build();
nodeIds.add(hwNode);
- ParentRefs parent = new ParentRefsBuilder().setNodeIdentifier(nodeIds).build();
- builder.addAugmentation(ParentRefs.class, parent);
+ builder.addAugmentation(new ParentRefsBuilder().setNodeIdentifier(nodeIds).build());
IfTunnel tunnel = new IfTunnelBuilder().setTunnelDestination(destIp).setTunnelGateway(gwIp)
.setTunnelSource(srcIp).setMonitorEnabled(monitorEnabled == null || monitorEnabled)
.setMonitorProtocol(monitorProtocol == null ? ITMConstants.DEFAULT_MONITOR_PROTOCOL : monitorProtocol)
.setMonitorInterval(DEFAULT_MONITORING_INTERVAL).setTunnelInterfaceType(tunType).setInternal(false)
.build();
- builder.addAugmentation(IfTunnel.class, tunnel);
+ builder.addAugmentation(tunnel);
LOG.trace("iftunnel {} built from hwvtep {} ", tunnel, nodeId);
return builder.build();
}
TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
tpBuilder.withKey(InstanceIdentifier.keyOf(tpIid));
- tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
ITMBatchingUtils.write(tpIid, tpBuilder.build(), ITMBatchingUtils.EntityType.TOPOLOGY_CONFIG);
}
LOG.debug("OvsdbTerminationPointAugmentation: {}", tpAugmentationBuilder);
TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
tpBuilder.withKey(InstanceIdentifier.keyOf(tpIid));
- tpBuilder.addAugmentation(OvsdbTerminationPointAugmentation.class, tpAugmentationBuilder.build());
+ tpBuilder.addAugmentation(tpAugmentationBuilder.build());
ITMBatchingUtils.update(tpIid, tpBuilder.build(), ITMBatchingUtils.EntityType.TOPOLOGY_CONFIG);
}
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
-import com.google.common.util.concurrent.FluentFuture;
import java.io.ByteArrayOutputStream;
import java.io.PrintStream;
import java.util.ArrayList;
doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
lenient().doReturn(FluentFutures.immediateNullFluentFuture()).when(mockWriteTx).commit();
- doReturn(FluentFuture.from(FluentFutures.immediateFluentFuture(CommitInfo.empty()))).when(mockWriteTx).commit();
+ doReturn(CommitInfo.emptyFluentFuture()).when(mockWriteTx).commit();
}
@Test
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.DatapathId;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentationBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeName;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentationBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeRef;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ConnectionInfo;
ovsdbNodeAugBuilder.setOpenvswitchOtherConfigs(otherConfigsList);
// add OvsdbNodeAugmentation into Node
- nodeBuilder.addAugmentation(OvsdbNodeAugmentation.class, ovsdbNodeAugBuilder.build());
+ nodeBuilder.addAugmentation(ovsdbNodeAugBuilder.build());
Node ovsdbNode = nodeBuilder.build();
WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
ovsdbNodeAugBuilder.setOpenvswitchOtherConfigs(otherConfigsList);
// add OvsdbNodeAugmentation into Node
- nodeBuilder.addAugmentation(OvsdbNodeAugmentation.class, ovsdbNodeAugBuilder.build());
+ nodeBuilder.addAugmentation(ovsdbNodeAugBuilder.build());
Node ovsdbNode = nodeBuilder.build();
//ReadWriteTransaction transaction = dataBroker.newReadWriteTransaction();
ovsdbBridgeAugmentationBuilder.setManagedBy(new OvsdbNodeRef(
SouthboundUtils.createInstanceIdentifier(nodeKey.getNodeId())));
- bridgeNodeBuilder.addAugmentation(OvsdbBridgeAugmentation.class, ovsdbBridgeAugmentationBuilder.build());
+ bridgeNodeBuilder.addAugmentation(ovsdbBridgeAugmentationBuilder.build());
Node bridgeNode = bridgeNodeBuilder.build();
import java.util.Collections;
import org.opendaylight.genius.mdsalutil.ActionInfo;
-import org.opendaylight.openflowplugin.extension.api.ExtensionAugment;
import org.opendaylight.openflowplugin.extension.api.GroupingLooseResolver;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.SetFieldCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.set.field._case.SetFieldBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionKey;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.EricAugMatchNodesNodeTableFlow;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.EricAugMatchNodesNodeTableFlowBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.Icmpv6NdOptionsTypeKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.eric.of.icmpv6.nd.options.type.grouping.EricOfIcmpv6NdOptionsTypeBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.GeneralAugMatchNodesNodeTableFlowWriteActionsSetField;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.GeneralAugMatchNodesNodeTableFlowWriteActionsSetFieldBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.GeneralExtensionListGrouping;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.grouping.Extension;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.grouping.ExtensionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.list.grouping.ExtensionListBuilder;
-import org.opendaylight.yangtools.yang.binding.Augmentation;
/**
* Set source IPv6 action.
new GroupingLooseResolver<>(GeneralExtensionListGrouping.class);
eqGroup.add(GeneralAugMatchNodesNodeTableFlowWriteActionsSetField.class);
- ExtensionAugment<? extends Augmentation<Extension>> extensionMatch
- = new ExtensionAugment<>(EricAugMatchNodesNodeTableFlow.class,
- new EricAugMatchNodesNodeTableFlowBuilder().setEricOfIcmpv6NdOptionsType(
- new EricOfIcmpv6NdOptionsTypeBuilder().setIcmpv6NdOptionsType(ndOptionType).build()).build(),
- Icmpv6NdOptionsTypeKey.class);
-
- ExtensionListBuilder extListBld = null;
- ExtensionBuilder extBld = new ExtensionBuilder();
- extBld.addAugmentation(extensionMatch.getAugmentationClass(), extensionMatch.getAugmentationObject());
-
- extListBld = new ExtensionListBuilder();
- extListBld.setExtension(extBld.build());
- extListBld.setExtensionKey(extensionMatch.getKey());
-
- GeneralAugMatchNodesNodeTableFlowWriteActionsSetField ndOptionsTypeSetField =
- new GeneralAugMatchNodesNodeTableFlowWriteActionsSetFieldBuilder()
- .setExtensionList(Collections.singletonList(extListBld.build())).build();
-
return new ActionBuilder()
- .setAction(new SetFieldCaseBuilder()
- .setSetField(new SetFieldBuilder()
- .addAugmentation(GeneralAugMatchNodesNodeTableFlowWriteActionsSetField.class,
- ndOptionsTypeSetField)
+ .setAction(new SetFieldCaseBuilder()
+ .setSetField(new SetFieldBuilder()
+ .addAugmentation(new GeneralAugMatchNodesNodeTableFlowWriteActionsSetFieldBuilder()
+ .setExtensionList(Collections.singletonList(new ExtensionListBuilder()
+ .setExtension(new ExtensionBuilder()
+ .addAugmentation(new EricAugMatchNodesNodeTableFlowBuilder()
+ .setEricOfIcmpv6NdOptionsType(new EricOfIcmpv6NdOptionsTypeBuilder()
+ .setIcmpv6NdOptionsType(ndOptionType)
+ .build())
+ .build())
.build())
+ .setExtensionKey(Icmpv6NdOptionsTypeKey.class)
+ .build()))
.build())
- .withKey(new ActionKey(newActionKey))
- .build();
+ .build())
+ .build())
+ .withKey(new ActionKey(newActionKey))
+ .build();
}
-
@Override
public boolean equals(Object other) {
if (this == other) {
import java.util.Collections;
import org.opendaylight.genius.mdsalutil.ActionInfo;
-import org.opendaylight.openflowplugin.extension.api.ExtensionAugment;
import org.opendaylight.openflowplugin.extension.api.GroupingLooseResolver;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.SetFieldCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.set.field._case.SetFieldBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionKey;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.EricAugMatchNodesNodeTableFlow;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.EricAugMatchNodesNodeTableFlowBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.Icmpv6NdReservedKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.eric.match.rev180730.eric.of.icmpv6.nd.reserved.grouping.EricOfIcmpv6NdReservedBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.GeneralAugMatchNodesNodeTableFlowWriteActionsSetField;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.GeneralAugMatchNodesNodeTableFlowWriteActionsSetFieldBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.GeneralExtensionListGrouping;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.grouping.Extension;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.grouping.ExtensionBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.general.rev140714.general.extension.list.grouping.ExtensionListBuilder;
-import org.opendaylight.yangtools.yang.binding.Augmentation;
/**
* Set source IPv6 action.
new GroupingLooseResolver<>(GeneralExtensionListGrouping.class);
eqGroup.add(GeneralAugMatchNodesNodeTableFlowWriteActionsSetField.class);
- ExtensionAugment<? extends Augmentation<Extension>> extensionMatch
- = new ExtensionAugment<>(EricAugMatchNodesNodeTableFlow.class,
- new EricAugMatchNodesNodeTableFlowBuilder().setEricOfIcmpv6NdReserved(
- new EricOfIcmpv6NdReservedBuilder().setIcmpv6NdReserved(ndReserved).build()).build(),
- Icmpv6NdReservedKey.class);
-
- ExtensionListBuilder extListBld = null;
- ExtensionBuilder extBld = new ExtensionBuilder();
- extBld.addAugmentation(extensionMatch.getAugmentationClass(), extensionMatch.getAugmentationObject());
-
- extListBld = new ExtensionListBuilder();
- extListBld.setExtension(extBld.build());
- extListBld.setExtensionKey(extensionMatch.getKey());
-
- GeneralAugMatchNodesNodeTableFlowWriteActionsSetField ndReservedSetField =
- new GeneralAugMatchNodesNodeTableFlowWriteActionsSetFieldBuilder()
- .setExtensionList(Collections.singletonList(extListBld.build())).build();
-
return new ActionBuilder()
- .setAction(new SetFieldCaseBuilder()
- .setSetField(new SetFieldBuilder()
- .addAugmentation(GeneralAugMatchNodesNodeTableFlowWriteActionsSetField.class,
- ndReservedSetField)
+ .setAction(new SetFieldCaseBuilder()
+ .setSetField(new SetFieldBuilder()
+ .addAugmentation(new GeneralAugMatchNodesNodeTableFlowWriteActionsSetFieldBuilder()
+ .setExtensionList(Collections.singletonList(new ExtensionListBuilder()
+ .setExtension(new ExtensionBuilder()
+ .addAugmentation(new EricAugMatchNodesNodeTableFlowBuilder()
+ .setEricOfIcmpv6NdReserved(new EricOfIcmpv6NdReservedBuilder()
+ .setIcmpv6NdReserved(ndReserved)
+ .build())
+ .build())
.build())
+ .setExtensionKey(Icmpv6NdReservedKey.class)
+ .build()))
.build())
- .withKey(new ActionKey(newActionKey))
- .build();
+ .build())
+ .build())
+ .withKey(new ActionKey(newActionKey))
+ .build();
}
@Override
EricAugMatchNodesNodeTableFlow ericAugMatch = ericAugMatchBuilder.build();
GeneralAugMatchNodesNodeTableFlow existingAugmentations = matchBuilder
.augmentation(GeneralAugMatchNodesNodeTableFlow.class);
- GeneralAugMatchNodesNodeTableFlow genAugMatch = generalAugMatchBuilder(existingAugmentations,
- ericAugMatch, keyClass);
- matchBuilder.addAugmentation(GeneralAugMatchNodesNodeTableFlow.class, genAugMatch);
+ matchBuilder.addAugmentation(generalAugMatchBuilder(existingAugmentations, ericAugMatch, keyClass));
}
}
extensions = new HashMap<>();
}
ExtensionList extensionList = new ExtensionListBuilder().setExtensionKey(extentionKey)
- .setExtension(
- new ExtensionBuilder().addAugmentation(EricAugMatchNodesNodeTableFlow.class, ericAugMatch)
- .build())
+ .setExtension(new ExtensionBuilder().addAugmentation(ericAugMatch).build())
.build();
extensions.put(extensionList.key(),extensionList);
return new GeneralAugMatchNodesNodeTableFlowBuilder().setExtensionList(extensions).build();
NxAugMatchNodesNodeTableFlow nxAugMatch = nxAugMatchBuilder.build();
GeneralAugMatchNodesNodeTableFlow existingAugmentations = matchBuilder
.augmentation(GeneralAugMatchNodesNodeTableFlow.class);
- GeneralAugMatchNodesNodeTableFlow genAugMatch = generalAugMatchBuilder(existingAugmentations,
- nxAugMatch, keyClass);
- matchBuilder.addAugmentation(GeneralAugMatchNodesNodeTableFlow.class, genAugMatch);
+ matchBuilder.addAugmentation(generalAugMatchBuilder(existingAugmentations, nxAugMatch, keyClass));
}
}
}
ExtensionList extensionList = new ExtensionListBuilder().setExtensionKey(extentionKey)
- .setExtension(new ExtensionBuilder().addAugmentation(NxAugMatchNodesNodeTableFlow.class,
- nxAugMatch).build()).build();
+ .setExtension(new ExtensionBuilder().addAugmentation(nxAugMatch).build()).build();
extensions.put(extensionList.key(),extensionList);
return new GeneralAugMatchNodesNodeTableFlowBuilder().setExtensionList(extensions).build();
}
final HwvtepPhysicalLocatorAugmentation phyLocator) {
InstanceIdentifier<TerminationPoint> iid = HwvtepSouthboundUtils.createPhysicalLocatorInstanceIdentifier(nodeId,
phyLocator);
- TerminationPoint terminationPoint = new TerminationPointBuilder()
+ transaction.mergeParentStructurePut(LogicalDatastoreType.CONFIGURATION, iid, new TerminationPointBuilder()
.withKey(HwvtepSouthboundUtils.getTerminationPointKey(phyLocator))
- .addAugmentation(HwvtepPhysicalLocatorAugmentation.class, phyLocator).build();
-
- transaction.mergeParentStructurePut(LogicalDatastoreType.CONFIGURATION, iid, terminationPoint);
+ .addAugmentation(phyLocator)
+ .build());
}
/**