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
   9 package org.opendaylight.neutron.transcriber;
  10
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  14 import org.opendaylight.neutron.spi.INeutronQosPolicyCRUD;
  15 import org.opendaylight.neutron.spi.NeutronQosBandwidthRule;
  16 import org.opendaylight.neutron.spi.NeutronQosDscpMarkingRule;
  17 import org.opendaylight.neutron.spi.NeutronQosPolicy;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.QosPolicies;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicy;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicyBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.BandwidthLimitRules;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.BandwidthLimitRulesBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.DscpmarkingRules;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.DscpmarkingRulesBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  26 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 public class NeutronQosPolicyInterface extends AbstractNeutronInterface<QosPolicy, QosPolicies, NeutronQosPolicy>
  31         implements INeutronQosPolicyCRUD {
  32
  33     private static final Logger LOGGER = LoggerFactory.getLogger(NeutronQosPolicyInterface.class);
  34
  35     NeutronQosPolicyInterface(DataBroker db) {
  36         super(db);
  37     }
  38
  39     @Override
  40     protected List<QosPolicy> getDataObjectList(QosPolicies qosPolicies) {
  41         return qosPolicies.getQosPolicy();
  42     }
  43
  44     @Override
  45     protected InstanceIdentifier<QosPolicy> createInstanceIdentifier(QosPolicy port) {
  46         return InstanceIdentifier.create(Neutron.class).child(QosPolicies.class).child(QosPolicy.class, port.getKey());
  47     }
  48
  49     @Override
  50     protected InstanceIdentifier<QosPolicies> createInstanceIdentifier() {
  51         return InstanceIdentifier.create(Neutron.class).child(QosPolicies.class);
  52     }
  53
  54     @Override
  55     protected QosPolicy toMd(NeutronQosPolicy qosPolicy) {
  56         final QosPolicyBuilder qosPolicyBuilder = new QosPolicyBuilder();
  57         if (qosPolicy.getID() != null) {
  58             qosPolicyBuilder.setUuid(toUuid(qosPolicy.getID()));
  59         } else {
  60             LOGGER.warn("Attempting to write neutron Qos Policy without UUID");
  61         }
  62         if (qosPolicy.getTenantID() != null) {
  63             qosPolicyBuilder.setTenantId(toUuid(qosPolicy.getTenantID()));
  64         }
  65         if (qosPolicy.getQosPolicyName() != null) {
  66             qosPolicyBuilder.setName(qosPolicy.getQosPolicyName());
  67         }
  68         if (qosPolicy.getPolicyIsShared() != null) {
  69             qosPolicyBuilder.setShared(qosPolicy.getPolicyIsShared());
  70         }
  71         if (qosPolicy.getBwLimitRules() != null) {
  72             final List<BandwidthLimitRules> listBandwith = new ArrayList<>();
  73             final BandwidthLimitRulesBuilder bandwidthLimitRulesBuilder = new BandwidthLimitRulesBuilder();
  74             for (final NeutronQosBandwidthRule bandWidthRule : qosPolicy.getBwLimitRules()) {
  75                 bandwidthLimitRulesBuilder.setUuid(toUuid(bandWidthRule.getID()));
  76                 bandwidthLimitRulesBuilder.setTenantId(toUuid(bandWidthRule.getTenantID()));
  77                 bandwidthLimitRulesBuilder.setMaxKbps(bandWidthRule.getMaxKbps());
  78                 bandwidthLimitRulesBuilder.setMaxBurstKbps(bandWidthRule.getMaxBurstKbps());
  79                 listBandwith.add(bandwidthLimitRulesBuilder.build());
  80             }
  81             qosPolicyBuilder.setBandwidthLimitRules(listBandwith);
  82         }
  83         if (qosPolicy.getDscpRules() != null) {
  84             final List<DscpmarkingRules> listDscp = new ArrayList<>();
  85             final DscpmarkingRulesBuilder dscpmarkingRulesBuilder = new DscpmarkingRulesBuilder();
  86             for (final NeutronQosDscpMarkingRule dscpRule : qosPolicy.getDscpRules()) {
  87                 dscpmarkingRulesBuilder.setUuid(toUuid(dscpRule.getID()));
  88                 dscpmarkingRulesBuilder.setTenantId(toUuid(dscpRule.getTenantID()));
  89                 dscpmarkingRulesBuilder.setDscpMark(dscpRule.getDscpMark());
  90                 listDscp.add(dscpmarkingRulesBuilder.build());
  91             }
  92             qosPolicyBuilder.setDscpmarkingRules(listDscp);
  93         }
  94         return qosPolicyBuilder.build();
  95     }
  96
  97     @Override
  98     protected QosPolicy toMd(String uuid) {
  99         final QosPolicyBuilder policyBuilder = new QosPolicyBuilder();
 100         policyBuilder.setUuid(toUuid(uuid));
 101         return policyBuilder.build();
 102     }
 103
 104     @Override
 105     protected NeutronQosPolicy fromMd(QosPolicy qosPolicy) {
 106         final NeutronQosPolicy result = new NeutronQosPolicy();
 107         if (qosPolicy.getUuid() != null) {
 108             result.setID(qosPolicy.getUuid().getValue());
 109         }
 110         if (qosPolicy.getTenantId() != null) {
 111             result.setTenantID(qosPolicy.getTenantId());
 112         }
 113         if (qosPolicy.getName() != null) {
 114             result.setQosPolicyName(qosPolicy.getName());
 115         }
 116         if (qosPolicy.isShared() != null) {
 117             result.setPolicyIsShared(qosPolicy.isShared());
 118         }
 119         if (qosPolicy.getBandwidthLimitRules() != null) {
 120             final List<NeutronQosBandwidthRule> bandWidthRules = new ArrayList<>();
 121             for (final BandwidthLimitRules rule : qosPolicy.getBandwidthLimitRules()) {
 122                 NeutronQosBandwidthRule opt = new NeutronQosBandwidthRule();
 123                 opt.setID(rule.getUuid().getValue());
 124                 opt.setTenantID(rule.getTenantId().getValue());
 125                 opt.setMaxKbps(rule.getMaxKbps());
 126                 opt.setMaxBurstKbps(rule.getMaxBurstKbps());
 127                 bandWidthRules.add(opt);
 128             }
 129             result.setQosBwLimitRules(bandWidthRules);
 130         }
 131         if (qosPolicy.getDscpmarkingRules() != null) {
 132             final List<NeutronQosDscpMarkingRule> dscpRules = new ArrayList<>();
 133             for (final DscpmarkingRules rule : qosPolicy.getDscpmarkingRules()) {
 134                 NeutronQosDscpMarkingRule opt = new NeutronQosDscpMarkingRule();
 135                 opt.setID(rule.getUuid().getValue());
 136                 opt.setTenantID(rule.getTenantId().getValue());
 137                 opt.setDscpMark(rule.getDscpMark());
 138                 dscpRules.add(opt);
 139             }
 140             result.setDscpRules(dscpRules);
 141         }
 142         return result;
 143     }
 144 }