2 * Copyright (c) 2016, 2018 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 bandwidthLimitRulesBuilder.setDirection(DirectionMapper.get(bandwidthLimitRule.getDirection()));
64 listBandwith.add(bandwidthLimitRulesBuilder.build());
66 qosPolicyBuilder.setBandwidthLimitRules(listBandwith);
69 if (qosPolicy.getDscpMarkingRules() != null) {
70 final List<DscpmarkingRules> listDscpMarking = new ArrayList<>();
71 for (final NeutronQosDscpMarkingRule dscpMarkingRule : qosPolicy.getDscpMarkingRules()) {
72 final DscpmarkingRulesBuilder dscpmarkingRulesBuilder =
73 toMdIds(dscpMarkingRule, DscpmarkingRulesBuilder.class);
74 dscpmarkingRulesBuilder.setDscpMark(dscpMarkingRule.getDscpMark());
75 listDscpMarking.add(dscpmarkingRulesBuilder.build());
77 qosPolicyBuilder.setDscpmarkingRules(listDscpMarking);
79 if (qosPolicy.getMinimumBandwidthRules() != null) {
80 final List<MinimumbandwidthRules> listMinimumBandwidth = new ArrayList<>();
81 for (final NeutronQosMinimumBandwidthRule minimumBandwidthRule : qosPolicy.getMinimumBandwidthRules()) {
82 final MinimumbandwidthRulesBuilder minimumBandwidthRulesBuilder =
83 new MinimumbandwidthRulesBuilder();
84 minimumBandwidthRulesBuilder.setUuid(toUuid(minimumBandwidthRule.getID()));
85 minimumBandwidthRulesBuilder.setTenantId(toUuid(minimumBandwidthRule.getTenantID()));
86 minimumBandwidthRulesBuilder.setMinKbps(minimumBandwidthRule.getMinKbps());
87 minimumBandwidthRulesBuilder.setDirection(DirectionMapper.get(minimumBandwidthRule.getDirection()));
88 listMinimumBandwidth.add(minimumBandwidthRulesBuilder.build());
90 qosPolicyBuilder.setMinimumbandwidthRules(listMinimumBandwidth);
92 return qosPolicyBuilder.build();
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());
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 opt.setDirection(DirectionMapper.getDirectionString(rule.getDirection()));
109 bandwidthLimitRules.add(opt);
111 result.setQosBandwidthLimitRules(bandwidthLimitRules);
113 if (qosPolicy.getDscpmarkingRules() != null) {
114 final List<NeutronQosDscpMarkingRule> dscpMarkingRules = new ArrayList<>();
115 for (final DscpmarkingRules rule : qosPolicy.getDscpmarkingRules()) {
116 NeutronQosDscpMarkingRule opt = new NeutronQosDscpMarkingRule();
117 opt.setDscpMark(rule.getDscpMark());
118 dscpMarkingRules.add(opt);
120 result.setDscpMarkingRules(dscpMarkingRules);
122 if (qosPolicy.getMinimumbandwidthRules() != null) {
123 final List<NeutronQosMinimumBandwidthRule> minimumBandwidthRules = new ArrayList<>();
124 for (final MinimumbandwidthRules rule : qosPolicy.getMinimumbandwidthRules()) {
125 NeutronQosMinimumBandwidthRule opt = new NeutronQosMinimumBandwidthRule();
126 opt.setID(rule.getTenantId().getValue());
127 opt.setTenantID(rule.getTenantId().getValue());
128 opt.setMinKbps(rule.getMinKbps());
129 opt.setDirection(DirectionMapper.getDirectionString(rule.getDirection()));
130 minimumBandwidthRules.add(opt);
132 result.setMinimumBandwidthRules(minimumBandwidthRules);