- if (subnetIds != null) {
- for (Uuid subnetId : subnetIds) {
- List<Uuid> portIds = getPortIdsFromSubnetId(subnetId);
- if (portIds != null) {
- for (Uuid portId : portIds) {
- Port port = neutronVpnManager.getNeutronPort(portId);
- if (port != null && (port.getAugmentation(QosPortExtension.class) == null
- || port.getAugmentation(QosPortExtension.class).getQosPolicyId() == null)) {
- jobCoordinator.enqueueJob("QosPort-" + portId.getValue(), () -> {
- WriteTransaction wrtConfigTxn = dataBroker.newWriteOnlyTransaction();
- List<ListenableFuture<Void>> futures = new ArrayList<>();
- if (qosPolicy != null && qosPolicy.getBandwidthLimitRules() != null
- && !qosPolicy.getBandwidthLimitRules().isEmpty()) {
- BandwidthLimitRulesBuilder bwLimitBuilder = new BandwidthLimitRulesBuilder();
- setPortBandwidthLimits(port, bwLimitBuilder
- .setMaxBurstKbps(BigInteger.ZERO)
- .setMaxKbps(BigInteger.ZERO).build(), null);
- }
- if (qosPolicy != null && qosPolicy.getDscpmarkingRules() != null
- && !qosPolicy.getDscpmarkingRules().isEmpty()) {
- unsetPortDscpMark(port);
- }
- futures.add(wrtConfigTxn.submit());
- return futures;
- });
+ for (Uuid subnetId : subnetIds) {
+ List<Uuid> portIds = getPortIdsFromSubnetId(subnetId);
+ for (Uuid portId : portIds) {
+ Port port = neutronVpnManager.getNeutronPort(portId);
+ if (port != null && (port.getAugmentation(QosPortExtension.class) == null
+ || port.getAugmentation(QosPortExtension.class).getQosPolicyId() == null)) {
+ jobCoordinator.enqueueJob("QosPort-" + portId.getValue(), () -> {
+ WriteTransaction wrtConfigTxn = dataBroker.newWriteOnlyTransaction();
+ List<ListenableFuture<Void>> futures = new ArrayList<>();
+ if (qosPolicy != null && qosPolicy.getBandwidthLimitRules() != null
+ && !qosPolicy.getBandwidthLimitRules().isEmpty()) {
+ BandwidthLimitRulesBuilder bwLimitBuilder = new BandwidthLimitRulesBuilder();
+ setPortBandwidthLimits(port, bwLimitBuilder
+ .setMaxBurstKbps(BigInteger.ZERO)
+ .setMaxKbps(BigInteger.ZERO).build(), null);