[ONOS-5565]Implementation of QosConfig and QueueConfig
Change-Id: I6a367b53cfca2e85e8aaa6cddb541d7b3ffccbc0
diff --git a/core/api/src/main/java/org/onosproject/net/behaviour/DefaultQueueDescription.java b/core/api/src/main/java/org/onosproject/net/behaviour/DefaultQueueDescription.java
new file mode 100644
index 0000000..400c2a5
--- /dev/null
+++ b/core/api/src/main/java/org/onosproject/net/behaviour/DefaultQueueDescription.java
@@ -0,0 +1,202 @@
+/*
+ * Copyright 2017-present Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.net.behaviour;
+
+import com.google.common.annotations.Beta;
+import com.google.common.base.MoreObjects;
+import org.onlab.util.Bandwidth;
+import org.onosproject.net.AbstractDescription;
+import org.onosproject.net.SparseAnnotations;
+
+import java.util.EnumSet;
+import java.util.Objects;
+import java.util.Optional;
+
+import static com.google.common.base.Preconditions.checkArgument;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Default implementation of Queue description entity.
+ */
+@Beta
+public final class DefaultQueueDescription extends AbstractDescription
+ implements QueueDescription {
+
+ private final QueueId queueId;
+ private final Optional<Integer> dscp;
+ private final EnumSet<Type> type;
+ private final Optional<Bandwidth> maxRate;
+ private final Optional<Bandwidth> minRate;
+ private final Optional<Long> burst;
+ private final Optional<Long> priority;
+
+ public static final int MIN_DSCP = 0;
+ public static final int MAX_DSCP = 63;
+
+ private DefaultQueueDescription(QueueId queueId, Optional<Integer> dscp, EnumSet<Type> type,
+ Optional<Bandwidth> maxRate, Optional<Bandwidth> minRate,
+ Optional<Long> burst, Optional<Long> priority,
+ SparseAnnotations... annotations) {
+ super(annotations);
+ if (dscp.isPresent()) {
+ checkArgument(dscp.get() < MIN_DSCP || dscp.get() > MAX_DSCP, "dscp should be in range 0 to 63.");
+ }
+ this.queueId = checkNotNull(queueId);
+ this.dscp = dscp;
+ this.type = type;
+ this.maxRate = maxRate;
+ this.minRate = minRate;
+ this.burst = burst;
+ this.priority = priority;
+ }
+
+ @Override
+ public QueueId queueId() {
+ return queueId;
+ }
+
+ @Override
+ public EnumSet<Type> type() {
+ return type;
+ }
+
+ @Override
+ public Optional<Integer> dscp() {
+ return dscp;
+ }
+
+ @Override
+ public Optional<Bandwidth> maxRate() {
+ return maxRate;
+ }
+
+ @Override
+ public Optional<Bandwidth> minRate() {
+ return minRate;
+ }
+
+ @Override
+ public Optional<Long> burst() {
+ return burst;
+ }
+
+ @Override
+ public Optional<Long> priority() {
+ return priority;
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(queueId, type, dscp, maxRate, minRate, burst, priority);
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj) {
+ return true;
+ }
+ if (obj instanceof DefaultQueueDescription) {
+ final DefaultQueueDescription other = (DefaultQueueDescription) obj;
+ return Objects.equals(this.queueId, other.queueId) &&
+ Objects.equals(this.type, other.type) &&
+ Objects.equals(this.dscp, other.dscp) &&
+ Objects.equals(this.maxRate, other.maxRate) &&
+ Objects.equals(this.minRate, other.minRate) &&
+ Objects.equals(this.burst, other.burst) &&
+ Objects.equals(this.priority, other.priority);
+ }
+ return false;
+ }
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(this)
+ .add("name", queueId())
+ .add("type", type())
+ .add("dscp", dscp().orElse(0))
+ .add("maxRate", maxRate().orElse(null))
+ .add("minRate", minRate().orElse(null))
+ .add("burst", burst().orElse(0L))
+ .add("priority", priority().orElse(0L))
+ .toString();
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ public static final class Builder implements QueueDescription.Builder {
+
+ private QueueId queueId;
+ private Optional<Integer> dscp = Optional.empty();
+ private EnumSet<Type> type;
+ private Optional<Bandwidth> minRate = Optional.empty();
+ private Optional<Bandwidth> maxRate = Optional.empty();
+ private Optional<Long> burst = Optional.empty();
+ private Optional<Long> priority = Optional.empty();
+
+ private Builder() {
+ }
+
+ @Override
+ public QueueDescription build() {
+ return new DefaultQueueDescription(queueId, dscp, type,
+ maxRate, minRate, burst, priority);
+ }
+
+ @Override
+ public Builder queueId(QueueId queueId) {
+ this.queueId = queueId;
+ return this;
+ }
+
+ @Override
+ public Builder dscp(Integer dscp) {
+ this.dscp = Optional.ofNullable(dscp);
+ return this;
+ }
+
+ @Override
+ public Builder type(EnumSet<Type> type) {
+ this.type = type;
+ return this;
+ }
+
+ @Override
+ public Builder maxRate(Bandwidth maxRate) {
+ this.maxRate = Optional.ofNullable(maxRate);
+ return this;
+ }
+
+ @Override
+ public Builder minRate(Bandwidth minRate) {
+ this.minRate = Optional.ofNullable(minRate);
+ return this;
+ }
+
+ @Override
+ public Builder burst(Long burst) {
+ this.burst = Optional.ofNullable(burst);
+ return this;
+ }
+
+ @Override
+ public Builder priority(Long priority) {
+ this.priority = Optional.ofNullable(priority);
+ return this;
+ }
+ }
+}