2 * Copyright (c) 2016 Intel Corporation and others. All rights reserved.
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
8 package org.opendaylight.neutron.transcriber;
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;
34 @OsgiServiceProvider(classes = INeutronQosPolicyCRUD.class)
35 public final class NeutronQosPolicyInterface
36 extends AbstractNeutronInterface<QosPolicy, QosPolicies, QosPolicyKey,NeutronQosPolicy>
37 implements INeutronQosPolicyCRUD {
40 public NeutronQosPolicyInterface(DataBroker db) {
41 super(QosPolicyBuilder.class, db);
45 protected List<QosPolicy> getDataObjectList(QosPolicies qosPolicies) {
46 return qosPolicies.getQosPolicy();
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());
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());
65 qosPolicyBuilder.setBandwidthLimitRules(listBandwith);
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());
76 qosPolicyBuilder.setDscpmarkingRules(listDscpMarking);
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.get(minimumBandwidthRule.getDirection()));
87 listMinimumBandwidth.add(minimumBandwidthRulesBuilder.build());
89 qosPolicyBuilder.setMinimumbandwidthRules(listMinimumBandwidth);
91 return qosPolicyBuilder.build();
95 protected NeutronQosPolicy fromMd(QosPolicy qosPolicy) {
96 final NeutronQosPolicy result = new NeutronQosPolicy();
97 fromMdBaseAttributes(qosPolicy, result);
98 if (qosPolicy.isShared() != null) {
99 result.setPolicyIsShared(qosPolicy.isShared());
101 if (qosPolicy.getBandwidthLimitRules() != null) {
102 final List<NeutronQosBandwidthLimitRule> bandwidthLimitRules = new ArrayList<>();
103 for (final BandwidthLimitRules rule : qosPolicy.getBandwidthLimitRules()) {
104 NeutronQosBandwidthLimitRule opt = new NeutronQosBandwidthLimitRule();
105 opt.setMaxKbps(rule.getMaxKbps());
106 opt.setMaxBurstKbps(rule.getMaxBurstKbps());
107 bandwidthLimitRules.add(opt);
109 result.setQosBandwidthLimitRules(bandwidthLimitRules);
111 if (qosPolicy.getDscpmarkingRules() != null) {
112 final List<NeutronQosDscpMarkingRule> dscpMarkingRules = new ArrayList<>();
113 for (final DscpmarkingRules rule : qosPolicy.getDscpmarkingRules()) {
114 NeutronQosDscpMarkingRule opt = new NeutronQosDscpMarkingRule();
115 opt.setDscpMark(rule.getDscpMark());
116 dscpMarkingRules.add(opt);
118 result.setDscpMarkingRules(dscpMarkingRules);
120 if (qosPolicy.getMinimumbandwidthRules() != null) {
121 final List<NeutronQosMinimumBandwidthRule> minimumBandwidthRules = new ArrayList<>();
122 for (final MinimumbandwidthRules rule : qosPolicy.getMinimumbandwidthRules()) {
123 NeutronQosMinimumBandwidthRule opt = new NeutronQosMinimumBandwidthRule();
124 opt.setID(rule.getTenantId().getValue());
125 opt.setTenantID(rule.getTenantId().getValue());
126 opt.setMinKbps(rule.getMinKbps());
127 opt.setDirection(DirectionMapper.getDirectionString(rule.getDirection()));
128 minimumBandwidthRules.add(opt);
130 result.setMinimumBandwidthRules(minimumBandwidthRules);