transcriber/src/main/java/org/opendaylight/neutron/transcriber/NeutronQosPolicyInterface.java

   1 /*
   2  * Copyright (c) 2016 Intel Corporation and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.neutron.transcriber;
   9
  10 import java.util.ArrayList;
  11 import java.util.List;
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  14 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  15 import org.opendaylight.neutron.spi.INeutronQosPolicyCRUD;
  16 import org.opendaylight.neutron.spi.NeutronQosBandwidthLimitRule;
  17 import org.opendaylight.neutron.spi.NeutronQosDscpMarkingRule;
  18 import org.opendaylight.neutron.spi.NeutronQosMinimumBandwidthRule;
  19 import org.opendaylight.neutron.spi.NeutronQosPolicy;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.NeutronUtils.DirectionMapper;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.QosPolicies;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicy;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicyBuilder;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicyKey;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.BandwidthLimitRules;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.BandwidthLimitRulesBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.DscpmarkingRules;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.DscpmarkingRulesBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.MinimumbandwidthRules;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.MinimumbandwidthRulesBuilder;
  31 import org.ops4j.pax.cdi.api.OsgiServiceProvider;
  32
  33 @Singleton
  34 @OsgiServiceProvider(classes = INeutronQosPolicyCRUD.class)
  35 public final class NeutronQosPolicyInterface
  36         extends AbstractNeutronInterface<QosPolicy, QosPolicies, QosPolicyKey,NeutronQosPolicy>
  37         implements INeutronQosPolicyCRUD {
  38
  39     @Inject
  40     public NeutronQosPolicyInterface(DataBroker db) {
  41         super(QosPolicyBuilder.class, db);
  42     }
  43
  44     @Override
  45     protected List<QosPolicy> getDataObjectList(QosPolicies qosPolicies) {
  46         return qosPolicies.getQosPolicy();
  47     }
  48
  49     @Override
  50     protected QosPolicy toMd(NeutronQosPolicy qosPolicy) {
  51         final QosPolicyBuilder qosPolicyBuilder = new QosPolicyBuilder();
  52         toMdBaseAttributes(qosPolicy, qosPolicyBuilder);
  53         if (qosPolicy.getPolicyIsShared() != null) {
  54             qosPolicyBuilder.setShared(qosPolicy.getPolicyIsShared());
  55         }
  56         if (qosPolicy.getBandwidthLimitRules() != null) {
  57             final List<BandwidthLimitRules> listBandwith = new ArrayList<>();
  58             for (final NeutronQosBandwidthLimitRule bandwidthLimitRule : qosPolicy.getBandwidthLimitRules()) {
  59                 final BandwidthLimitRulesBuilder bandwidthLimitRulesBuilder =
  60                         toMdIds(bandwidthLimitRule, BandwidthLimitRulesBuilder.class);
  61                 bandwidthLimitRulesBuilder.setMaxKbps(bandwidthLimitRule.getMaxKbps());
  62                 bandwidthLimitRulesBuilder.setMaxBurstKbps(bandwidthLimitRule.getMaxBurstKbps());
  63                 listBandwith.add(bandwidthLimitRulesBuilder.build());
  64             }
  65             qosPolicyBuilder.setBandwidthLimitRules(listBandwith);
  66         }
  67
  68         if (qosPolicy.getDscpMarkingRules() != null) {
  69             final List<DscpmarkingRules> listDscpMarking = new ArrayList<>();
  70             for (final NeutronQosDscpMarkingRule dscpMarkingRule : qosPolicy.getDscpMarkingRules()) {
  71                 final DscpmarkingRulesBuilder dscpmarkingRulesBuilder =
  72                         toMdIds(dscpMarkingRule, DscpmarkingRulesBuilder.class);
  73                 dscpmarkingRulesBuilder.setDscpMark(dscpMarkingRule.getDscpMark());
  74                 listDscpMarking.add(dscpmarkingRulesBuilder.build());
  75             }
  76             qosPolicyBuilder.setDscpmarkingRules(listDscpMarking);
  77         }
  78         if (qosPolicy.getMinimumBandwidthRules() != null) {
  79             final List<MinimumbandwidthRules> listMinimumBandwidth = new ArrayList<>();
  80             for (final NeutronQosMinimumBandwidthRule minimumBandwidthRule : qosPolicy.getMinimumBandwidthRules()) {
  81                 final MinimumbandwidthRulesBuilder minimumBandwidthRulesBuilder =
  82                         new MinimumbandwidthRulesBuilder();
  83                 minimumBandwidthRulesBuilder.setUuid(toUuid(minimumBandwidthRule.getID()));
  84                 minimumBandwidthRulesBuilder.setTenantId(toUuid(minimumBandwidthRule.getTenantID()));
  85                 minimumBandwidthRulesBuilder.setMinKbps(minimumBandwidthRule.getMinKbps());
  86                 minimumBandwidthRulesBuilder.setDirection(DirectionMapper.getMinimumBandwidthRuleDirection(
  87                     minimumBandwidthRule.getDirection()));
  88                 listMinimumBandwidth.add(minimumBandwidthRulesBuilder.build());
  89             }
  90             qosPolicyBuilder.setMinimumbandwidthRules(listMinimumBandwidth);
  91         }
  92         return qosPolicyBuilder.build();
  93     }
  94
  95     @Override
  96     protected NeutronQosPolicy fromMd(QosPolicy qosPolicy) {
  97         final NeutronQosPolicy result = new NeutronQosPolicy();
  98         fromMdBaseAttributes(qosPolicy, result);
  99         if (qosPolicy.isShared() != null) {
 100             result.setPolicyIsShared(qosPolicy.isShared());
 101         }
 102         if (qosPolicy.getBandwidthLimitRules() != null) {
 103             final List<NeutronQosBandwidthLimitRule> bandwidthLimitRules = new ArrayList<>();
 104             for (final BandwidthLimitRules rule : qosPolicy.getBandwidthLimitRules()) {
 105                 NeutronQosBandwidthLimitRule opt = new NeutronQosBandwidthLimitRule();
 106                 opt.setMaxKbps(rule.getMaxKbps());
 107                 opt.setMaxBurstKbps(rule.getMaxBurstKbps());
 108                 bandwidthLimitRules.add(opt);
 109             }
 110             result.setQosBandwidthLimitRules(bandwidthLimitRules);
 111         }
 112         if (qosPolicy.getDscpmarkingRules() != null) {
 113             final List<NeutronQosDscpMarkingRule> dscpMarkingRules = new ArrayList<>();
 114             for (final DscpmarkingRules rule : qosPolicy.getDscpmarkingRules()) {
 115                 NeutronQosDscpMarkingRule opt = new NeutronQosDscpMarkingRule();
 116                 opt.setDscpMark(rule.getDscpMark());
 117                 dscpMarkingRules.add(opt);
 118             }
 119             result.setDscpMarkingRules(dscpMarkingRules);
 120         }
 121         if (qosPolicy.getMinimumbandwidthRules() != null) {
 122             final List<NeutronQosMinimumBandwidthRule> minimumBandwidthRules = new ArrayList<>();
 123             for (final MinimumbandwidthRules rule : qosPolicy.getMinimumbandwidthRules()) {
 124                 NeutronQosMinimumBandwidthRule opt = new NeutronQosMinimumBandwidthRule();
 125                 opt.setID(rule.getTenantId().getValue());
 126                 opt.setTenantID(rule.getTenantId().getValue());
 127                 opt.setMinKbps(rule.getMinKbps());
 128                 opt.setDirection(DirectionMapper.getMinimumBandwidthRuleDirectionString(rule.getDirection()));
 129                 minimumBandwidthRules.add(opt);
 130             }
 131             result.setMinimumBandwidthRules(minimumBandwidthRules);
 132         }
 133         return result;
 134     }
 135 }