Add Qos transcriber file and n/w and port extensions

[neutron.git] / transcriber / src / main / java / org / opendaylight / neutron / transcriber / NeutronQosPolicyInterface.java

diff --git a/transcriber/src/main/java/org/opendaylight/neutron/transcriber/NeutronQosPolicyInterface.java b/transcriber/src/main/java/org/opendaylight/neutron/transcriber/NeutronQosPolicyInterface.java
new file mode 100644 (file)
index 0000000..6846e0a
--- /dev/null
+++ b/transcriber/src/main/java/org/opendaylight/neutron/transcriber/NeutronQosPolicyInterface.java
@@ -0,0 +1,145 @@
+/*
+ * Copyright (c) 2016 Intel Corporation and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.neutron.transcriber;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.neutron.spi.INeutronQosPolicyCRUD;
+import org.opendaylight.neutron.spi.NeutronQosBandwidthRule;
+import org.opendaylight.neutron.spi.NeutronQosDscpMarkingRule;
+import org.opendaylight.neutron.spi.NeutronQosPolicy;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.QosPolicies;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicy;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicyBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.BandwidthLimitRules;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.BandwidthLimitRulesBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.DscpmarkingRules;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.qos.policy.DscpmarkingRulesBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import java.util.ArrayList;
+import java.util.List;
+
+public class NeutronQosPolicyInterface extends AbstractNeutronInterface <QosPolicy, QosPolicies, NeutronQosPolicy>
+        implements INeutronQosPolicyCRUD {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(NeutronQosPolicyInterface.class);
+
+    NeutronQosPolicyInterface(DataBroker db) {
+        super(db);
+    }
+
+    @Override
+    protected List<QosPolicy> getDataObjectList(QosPolicies qosPolicies) {
+        return qosPolicies.getQosPolicy();
+    }
+
+    @Override
+    protected InstanceIdentifier<QosPolicy> createInstanceIdentifier(QosPolicy port) {
+        return InstanceIdentifier.create(Neutron.class).child(QosPolicies.class).child(QosPolicy.class, port.getKey());
+    }
+
+    @Override
+    protected InstanceIdentifier<QosPolicies> createInstanceIdentifier() {
+        return InstanceIdentifier.create(Neutron.class).child(QosPolicies.class);
+    }
+
+    @Override
+    protected QosPolicy toMd(NeutronQosPolicy qosPolicy) {
+        final QosPolicyBuilder qosPolicyBuilder = new QosPolicyBuilder();
+        if (qosPolicy.getID() != null) {
+            qosPolicyBuilder.setUuid(toUuid(qosPolicy.getID()));
+        } else {
+            LOGGER.warn("Attempting to write neutron Qos Policy without UUID");
+        }
+        if (qosPolicy.getTenantID() != null) {
+            qosPolicyBuilder.setTenantId(toUuid(qosPolicy.getTenantID()));
+        }
+        if (qosPolicy.getQosPolicyName() != null) {
+            qosPolicyBuilder.setName(qosPolicy.getQosPolicyName());
+        }
+        if (qosPolicy.getPolicyIsShared() != null) {
+            qosPolicyBuilder.setShared(qosPolicy.getPolicyIsShared());
+        }
+        if (qosPolicy.getBwLimitRules() != null) {
+            final List<BandwidthLimitRules> listBandwith = new ArrayList<>();
+            final BandwidthLimitRulesBuilder bandwidthLimitRulesBuilder =
+                    new BandwidthLimitRulesBuilder();
+            for (final NeutronQosBandwidthRule bandWidthRule : qosPolicy.getBwLimitRules()) {
+                bandwidthLimitRulesBuilder.setUuid(toUuid(bandWidthRule.getID()));
+                bandwidthLimitRulesBuilder.setTenantId(toUuid(bandWidthRule.getTenantID()));
+                bandwidthLimitRulesBuilder.setMaxKbps(bandWidthRule.getMaxKbps());
+                bandwidthLimitRulesBuilder.setMaxBurstKbps(bandWidthRule.getMaxBurstKbps());
+                listBandwith.add(bandwidthLimitRulesBuilder.build());
+            }
+            qosPolicyBuilder.setBandwidthLimitRules(listBandwith);
+        }
+        if (qosPolicy.getDscpRules() != null) {
+            final List<DscpmarkingRules> listDscp = new ArrayList<>();
+            final DscpmarkingRulesBuilder dscpmarkingRulesBuilder = new DscpmarkingRulesBuilder();
+            for (final NeutronQosDscpMarkingRule dscpRule : qosPolicy.getDscpRules()) {
+                dscpmarkingRulesBuilder.setUuid(toUuid(dscpRule.getID()));
+                dscpmarkingRulesBuilder.setTenantId(toUuid(dscpRule.getTenantID()));
+                dscpmarkingRulesBuilder.setDscpMark(dscpRule.getDscpMark());
+                listDscp.add(dscpmarkingRulesBuilder.build());
+            }
+            qosPolicyBuilder.setDscpmarkingRules(listDscp);
+        }
+        return qosPolicyBuilder.build();
+    }
+
+    @Override
+    protected QosPolicy toMd(String uuid) {
+        final QosPolicyBuilder policyBuilder = new QosPolicyBuilder();
+        policyBuilder.setUuid(toUuid(uuid));
+        return policyBuilder.build();
+    }
+
+    @Override
+    protected NeutronQosPolicy fromMd(QosPolicy qosPolicy) {
+        final NeutronQosPolicy result = new NeutronQosPolicy();
+        if (qosPolicy.getUuid() != null) {
+            result.setID(qosPolicy.getUuid().getValue());
+        }
+        if (qosPolicy.getTenantId() != null) {
+            result.setTenantID(qosPolicy.getTenantId());
+        }
+        if (qosPolicy.getName() != null) {
+            result.setQosPolicyName(qosPolicy.getName());
+        }
+        if (qosPolicy.isShared() != null) {
+            result.setPolicyIsShared(qosPolicy.isShared());
+        }
+        if (qosPolicy.getBandwidthLimitRules() != null) {
+            final List<NeutronQosBandwidthRule> bandWidthRules = new ArrayList<>();
+            for (final BandwidthLimitRules rule : qosPolicy.getBandwidthLimitRules()) {
+                NeutronQosBandwidthRule opt = new NeutronQosBandwidthRule();
+                opt.setID(rule.getUuid().getValue());
+                opt.setTenantID(rule.getTenantId().getValue());
+                opt.setMaxKbps(rule.getMaxKbps());
+                opt.setMaxBurstKbps(rule.getMaxBurstKbps());
+                bandWidthRules.add(opt);
+            }
+            result.setQosBwLimitRules(bandWidthRules);
+        }
+        if (qosPolicy.getDscpmarkingRules() != null) {
+            final List<NeutronQosDscpMarkingRule> dscpRules = new ArrayList<>();
+            for (final DscpmarkingRules rule : qosPolicy.getDscpmarkingRules()) {
+                NeutronQosDscpMarkingRule opt = new NeutronQosDscpMarkingRule();
+                opt.setID(rule.getUuid().getValue());
+                opt.setTenantID(rule.getTenantId().getValue());
+                opt.setDscpMark(rule.getDscpMark());
+                dscpRules.add(opt);
+            }
+            result.setDscpRules(dscpRules);
+        }
+        return result;
+    }
+}