package org.opendaylight.controller.packetcable.provider;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import com.google.common.collect.Lists;
import java.net.Inet4Address;
import java.net.Inet6Address;
import java.net.InetAddress;
import java.net.UnknownHostException;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.ServiceFlowDirection;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.TosByte;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.ccap.attributes.AmId;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.pcmm.qos.classifier.Classifier;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.pcmm.qos.ext.classifier.ExtClassifier;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.pcmm.qos.gate.spec.GateSpec;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.pcmm.qos.ipv6.classifier.Ipv6Classifier;
-import org.opendaylight.yang.gen.v1.urn.packetcable.rev151026.pcmm.qos.traffic.profile.TrafficProfile;
+import java.util.List;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.ServiceFlowDirection;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.TosByte;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.ccap.attributes.AmId;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.classifier.attributes.classifiers.ClassifierContainer;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.classifier.attributes.classifiers.classifier.container.ClassifierChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.classifier.attributes.classifiers.classifier.container.classifier.choice.ExtClassifierChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.classifier.attributes.classifiers.classifier.container.classifier.choice.Ipv6ClassifierChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.classifier.attributes.classifiers.classifier.container.classifier.choice.QosClassifierChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.classifier.Classifier;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.ext.classifier.ExtClassifier;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.gate.spec.GateSpec;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.ipv6.classifier.Ipv6Classifier;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.TrafficProfile;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.serviceclass.name.profile.ServiceClassNameProfile;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.flow.spec.profile.FlowSpecProfile;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.ugs.profile.UgsProfile;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.rtp.profile.RtpProfile;
import org.pcmm.gates.IClassifier;
import org.pcmm.gates.IClassifier.Protocol;
+import org.pcmm.gates.IExtendedClassifier;
import org.pcmm.gates.IExtendedClassifier.ActivationState;
import org.pcmm.gates.IGateSpec.Direction;
import org.pcmm.gates.IIPv6Classifier.FlowLabel;
import org.pcmm.gates.ITrafficProfile;
import org.pcmm.gates.impl.AMID;
import org.pcmm.gates.impl.DOCSISServiceClassNameTrafficProfile;
+import org.pcmm.gates.impl.DOCSISFlowSpecTrafficProfile;
+import org.pcmm.gates.impl.DOCSISUGSTrafficProfile;
+import org.pcmm.gates.impl.DOCSISRTPTrafficProfile;
import org.pcmm.gates.impl.GateID;
+import org.pcmm.gates.impl.GateState;
+import org.pcmm.gates.impl.GateTimeInfo;
+import org.pcmm.gates.impl.GateUsageInfo;
import org.pcmm.gates.impl.PCMMError;
import org.pcmm.gates.impl.PCMMGateReq;
+import org.pcmm.gates.impl.SessionClassID;
import org.pcmm.gates.impl.SubscriberID;
import org.pcmm.gates.impl.TransactionID;
+import org.pcmm.utils.PCMMUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.TrafficProfile;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.traffic.profile.TrafficProfileChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.traffic.profile.traffic.profile.choice.FlowSpecChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.traffic.profile.traffic.profile.choice.ServiceClassNameChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.traffic.profile.traffic.profile.choice.RtpChoice;
+import org.opendaylight.yang.gen.v1.urn.packetcable.rev170125.pcmm.qos.traffic.profile.traffic.profile.traffic.profile.choice.UgsChoice;
+
/**
* Build PCMM gate requests from API QoS Gate objects
*/
private TransactionID transactionID = null;
private org.pcmm.gates.impl.GateSpec gateSpec = null;
private ITrafficProfile trafficProfile = null;
- private IClassifier classifier = null;
+ private final List<IClassifier> classifiers = Lists.newArrayListWithExpectedSize(4);
private PCMMError error = null;
+ private GateState gateState = null;
+ private GateTimeInfo gateTimeInfo = null;
+ private GateUsageInfo gateUsageInfo = null;
public PCMMGateReq build() {
- return new PCMMGateReq(amid, subscriberID, transactionID, gateSpec, trafficProfile, classifier, gateID, error);
+ return new PCMMGateReq(amid, subscriberID, transactionID, gateSpec, trafficProfile, classifiers,
+ gateID, error, gateState, gateTimeInfo, gateUsageInfo);
}
public void setAmId(final AmId qosAmId) {
subscriberID = new SubscriberID(qosSubId);
}
- public void setGateSpec(final GateSpec qosGateSpec, final ServiceFlowDirection scnDirection) {
+ public void setGateId(int gateId) {
+ gateID = new GateID(gateId);
+ }
+
+ public void setGateSpec(final GateSpec qosGateSpec) {
- final ServiceFlowDirection qosDir;
- if (scnDirection != null) {
- qosDir = scnDirection;
- } else {
- if (qosGateSpec.getDirection() != null) {
- qosDir = qosGateSpec.getDirection();
- } else {
- // TODO - determine if this is a valid default value
- qosDir = ServiceFlowDirection.Ds;
- }
- }
+ final ServiceFlowDirection qosDir = qosGateSpec.getDirection();
+ // convert to PCMM API Type
final Direction gateDir;
if (qosDir == ServiceFlowDirection.Ds) {
gateDir = Direction.DOWNSTREAM;
gateDir = Direction.UPSTREAM;
}
- // DSCP/TOS Overwrite
- final byte dscptos;
+ final byte dscptos = 1;
final byte gateTosMask;
- final TosByte tosOverwrite = qosGateSpec.getDscpTosOverwrite();
- if (tosOverwrite != null) {
- dscptos = 1;
- TosByte tosMask = qosGateSpec.getDscpTosMask();
- if (tosMask != null) {
- gateTosMask = tosMask.getValue().byteValue();
- } else {
- gateTosMask = (byte) 0xff;
- }
+ TosByte tosMask = qosGateSpec.getDscpTosMask();
+ if (tosMask != null) {
+ gateTosMask = tosMask.getValue().byteValue();
} else {
- // TODO - These values appear to be required
- dscptos = 0;
- gateTosMask = 0;
+ gateTosMask = (byte) 0xff;
}
- gateSpec = new org.pcmm.gates.impl.GateSpec(gateDir, dscptos, gateTosMask);
- }
+
+ java.lang.Short scid = qosGateSpec.getSessionClassId();
+ byte bscid = 0;
+ if (scid != null) {
+ bscid = (byte)(qosGateSpec.getSessionClassId() & 0x00ff);
+ }
+
+ java.lang.Long inactivity = qosGateSpec.getInactivityTimer();
+ short sinactivity = 300;
+ if (inactivity != null) {
+ sinactivity = inactivity.shortValue();
+ }
+
+ gateSpec = new org.pcmm.gates.impl.GateSpec(gateDir, dscptos, gateTosMask,
+ new SessionClassID(bscid),
+ (short)1,(short)300,sinactivity,(short)0);
+ }
public void setTrafficProfile(final TrafficProfile qosTrafficProfile) {
- if (qosTrafficProfile.getServiceClassName() != null) {
- trafficProfile =
- new DOCSISServiceClassNameTrafficProfile(qosTrafficProfile.getServiceClassName().getValue());
+ TrafficProfileChoice choice = qosTrafficProfile.getTrafficProfileChoice();
+
+ if (choice instanceof ServiceClassNameChoice) {
+ ServiceClassNameProfile scnp = ((ServiceClassNameChoice)choice).getServiceClassNameProfile();
+ trafficProfile = new DOCSISServiceClassNameTrafficProfile(scnp.getServiceClassName().getValue());
+ }
+ else if (choice instanceof FlowSpecChoice) {
+ FlowSpecProfile fsp = ((FlowSpecChoice)choice).getFlowSpecProfile();
+ trafficProfile = new DOCSISFlowSpecTrafficProfile(fsp.getTokenBucketRate(),
+ fsp.getTokenBucketSize(),
+ fsp.getPeakDataRate(),
+ fsp.getMinimumPolicedUnit(),
+ fsp.getMaximumPacketSize(),
+ fsp.getRate(),
+ fsp.getSlackTerm());
+ }
+ else if (choice instanceof UgsChoice) {
+ UgsProfile ugsp = ((UgsChoice)choice).getUgsProfile();
+ trafficProfile = new DOCSISUGSTrafficProfile(ugsp.getRequestTransmissionPolicy(),
+ ugsp.getUnsolicitedGrantSize(),
+ ugsp.getGrantsPerInterval(),
+ ugsp.getNominalGrantInterval(),
+ ugsp.getToleratedGrantJitter(),
+ ugsp.getUpstreamPeakTrafficRate(),
+ ugsp.getRequiredAttributeMask(),
+ ugsp.getForbiddenAttributeMask(),
+ ugsp.getAttributeAggregationRuleMask());
+ }
+ else if (choice instanceof RtpChoice) {
+ RtpProfile rtpp = ((RtpChoice)choice).getRtpProfile();
+ trafficProfile = new DOCSISRTPTrafficProfile(rtpp.getRequestTransmissionPolicy(),
+ rtpp.getMaximumSustainedTrafficRate(),
+ rtpp.getMaximumTrafficBurst(),
+ rtpp.getMinimumReservedTrafficRate(),
+ rtpp.getAmrtrPacketSize().longValue(),
+ rtpp.getMaximumConcatenatedBurst().longValue(),
+ rtpp.getNominalPollingInterval(),
+ rtpp.getToleratedPollJitter(),
+ rtpp.getUpstreamPeakTrafficRate(),
+ rtpp.getRequiredAttributeMask(),
+ rtpp.getForbiddenAttributeMask(),
+ rtpp.getAttributeAggregationRuleMask());
+ }
+ else {
+ logger.debug("PCMMGateReq().setTrafficProfile() Unsupported Traffic Profile: " + choice.getClass().getName());
}
}
return null;
}
- public void setClassifier(final Classifier qosClassifier) {
+ public void setClassifiers(final List<ClassifierContainer> classifiers) {
+ checkNotNull(classifiers);
+
+ for (ClassifierContainer container : classifiers) {
+ final ClassifierChoice choice = container.getClassifierChoice();
+ final Short index = container.getClassifierId();
+
+ if (choice instanceof QosClassifierChoice) {
+ addClassifier(index, ((QosClassifierChoice) choice).getClassifier());
+ }
+ else if (choice instanceof ExtClassifierChoice) {
+ addExtClassifier(index, ((ExtClassifierChoice) choice).getExtClassifier());
+ }
+ else if (choice instanceof Ipv6ClassifierChoice) {
+ addIpv6Classifier(index, ((Ipv6ClassifierChoice) choice).getIpv6Classifier());
+ }
+ else {
+ throw new IllegalStateException("Unknown ClassifierChoice: " + choice);
+ }
+ }
+ }
+
+ private void addClassifier(final Short index,final Classifier qosClassifier) {
// TODO - try and make these variables immutable
Protocol protocol = null;
byte tosOverwrite = 0;
byte tosMask = (byte)0x0;
- Inet4Address srcAddress = null;
- Inet4Address dstAddress = null;
short srcPort = (short) 0;
short dstPort = (short) 0;
- byte priority = (byte) 64;
// Legacy classifier
+
+ // Protocol -- zero is match any
if (qosClassifier.getProtocol() != null) {
protocol = Protocol.valueOf(qosClassifier.getProtocol().getValue().shortValue());
+ } else {
+ protocol = Protocol.NONE;
}
+
+ // IP Addresss and mask wildcards - addr byte 0 for no match (or match anything)
+
+ Inet4Address srcAddress = (Inet4Address) getByName("0.0.0.0");
+
if (qosClassifier.getSrcIp() != null) {
- final InetAddress sip = getByName(qosClassifier.getSrcIp().getValue());
- if (sip != null && sip instanceof Inet4Address) {
- srcAddress = (Inet4Address) sip;
- }
+ srcAddress = (Inet4Address) getByName(qosClassifier.getSrcIp().getValue());
}
+
+ Inet4Address dstAddress = (Inet4Address) getByName("0.0.0.0");
+
if (qosClassifier.getDstIp() != null) {
- final InetAddress dip = getByName(qosClassifier.getDstIp().getValue());
- if (dip != null && dip instanceof Inet4Address) {
- dstAddress = (Inet4Address) dip;
- }
+ dstAddress = (Inet4Address) getByName(qosClassifier.getDstIp().getValue());
}
+
+
if (qosClassifier.getSrcPort() != null) {
srcPort = qosClassifier.getSrcPort().getValue().shortValue();
}
tosMask = (byte) 0xff;
}
}
+ //
+ // The packetcable.yang models priority as an uint8 which means the java generated
+ // implementation saves the value in a short, so we mask it back into a byte
+ //
+ byte priority = 64;
+ if (qosClassifier.getPriority() != null) {
+ short result = qosClassifier.getPriority();
+ priority = (byte)(result % 255);
+ }
+
// push the classifier to the gate request
- classifier =
- new org.pcmm.gates.impl.Classifier(protocol, tosOverwrite, tosMask, srcAddress, dstAddress, srcPort,
- dstPort, priority);
+ classifiers.add(new org.pcmm.gates.impl.Classifier(protocol, tosOverwrite, tosMask, srcAddress, dstAddress, srcPort,
+ dstPort, priority));
}
- public void setExtClassifier(final ExtClassifier qosExtClassifier) {
+ private void addExtClassifier(final Short index, final ExtClassifier qosExtClassifier) {
// Extended classifier
- final byte priority = (byte) 64;
- final ActivationState activationState = ActivationState.ACTIVE;
// Protocol -- zero is match any
final Protocol protocol;
if (qosExtClassifier.getProtocol() != null) {
if (qosExtClassifier.getSrcPortEnd() != null) {
srcEndPort = qosExtClassifier.getSrcPortEnd().getValue().shortValue();
}
- if (srcStartPort > srcEndPort) {
+ if ((int)(srcStartPort & 0xffff) > (int) (srcEndPort & 0xffff)) {
logger.warn("Start port %d > End port %d in ext-classifier source port range -- forcing to same",
srcStartPort, srcEndPort);
srcEndPort = srcStartPort;
if (qosExtClassifier.getDstPortEnd() != null) {
dstEndPort = qosExtClassifier.getDstPortEnd().getValue().shortValue();
}
- if (dstStartPort > dstEndPort) {
+ if ((int)(dstStartPort & 0xffff) > (int)(dstEndPort & 0xffff)) {
logger.warn("Start port %d > End port %d in ext-classifier destination port range -- forcing to same",
dstStartPort, dstEndPort);
dstEndPort = dstStartPort;
}
}
+ // IP Addresss and mask wildcards - addr byte 0 for no match (or match anything) and mask is 255.255.255.255 by default
+ Inet4Address srcIpAddr = (Inet4Address) getByName("0.0.0.0");
+
+ if (qosExtClassifier.getSrcIp() != null) {
+ srcIpAddr = getInet4Address(qosExtClassifier.getSrcIp());
+ }
+
+ Inet4Address dstIpAddr = (Inet4Address) getByName("0.0.0.0");
+ if (qosExtClassifier.getDstIp() != null) {
+ dstIpAddr = getInet4Address(qosExtClassifier.getDstIp());
+ }
+
+ //mask
+ Inet4Address srcIpMask = (Inet4Address) getByName("255.255.255.255");
+ if (qosExtClassifier.getSrcIpMask() != null) {
+ srcIpMask = getInet4Address(qosExtClassifier.getSrcIpMask());
+ }
+
+ Inet4Address dstIpMask = (Inet4Address) getByName("255.255.255.255");
+ if (qosExtClassifier.getDstIpMask() != null) {
+ dstIpMask = getInet4Address(qosExtClassifier.getDstIpMask());
+ }
+
// TODO - find out what the classifier ID should really be. It was never getting set previously
- final short classifierId = (short)0;
+ final short classifierId = (short)index;
// TODO - find out what the action value should really be. It was never getting set previously
- final byte action = (byte)0;
+ final IExtendedClassifier.Action action = IExtendedClassifier.Action.ADD;
+
+ //
+ // Convert from Enum to byte for serialization
+ //
+ ActivationState activationState = ActivationState.ACTIVE;
+ if (qosExtClassifier.getActivationState() != null) {
+ activationState = ActivationState.valueOf((byte)qosExtClassifier.getActivationState().getIntValue());
+ }
+
+ //
+ // The packetcable.yang models priority as an uint8 which means the java generated
+ // implementation saves the value in a short, so we mask it back into a byte
+ //
+ byte priority = 64;
+ if (qosExtClassifier.getPriority() != null) {
+ short result = qosExtClassifier.getPriority();
+ priority = (byte)(result % 255);
+ }
// push the extended classifier to the gate request
- classifier = new org.pcmm.gates.impl.ExtendedClassifier(protocol, tosOverwrite, tosMask,
- getInet4Address(qosExtClassifier.getSrcIp()), getInet4Address(qosExtClassifier.getDstIp()),
- srcStartPort, dstStartPort, priority, getInet4Address(qosExtClassifier.getSrcIpMask()),
- getInet4Address(qosExtClassifier.getDstIpMask()), srcEndPort, dstEndPort, classifierId, activationState,
- action);
+ classifiers.add(new org.pcmm.gates.impl.ExtendedClassifier(protocol, tosOverwrite, tosMask,
+ srcIpAddr, dstIpAddr,
+ srcStartPort, dstStartPort, priority, srcIpMask, dstIpMask, srcEndPort, dstEndPort, classifierId, activationState,
+ action));
}
private Inet4Address getInet4Address(
- final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address address) {
+ final org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address address) {
if (address != null) {
final InetAddress out = getByName(address.getValue());
if (out != null && out instanceof Inet4Address) {
return null;
}
- public void setIpv6Classifier(final Ipv6Classifier qosIpv6Classifier) {
+ private void addIpv6Classifier(final Short index, final Ipv6Classifier qosIpv6Classifier) {
// Next Header
final short nextHdr;
if (qosIpv6Classifier.getNextHdr() != null) {
// Source IPv6 address & prefix len
// TODO - try to make these two variables immutable
byte srcPrefixLen = (byte) 128;
- Inet6Address srcAddress = null;
+ Inet6Address srcAddress = (Inet6Address) getByName("0::0");
+
if (qosIpv6Classifier.getSrcIp6() != null) {
String[] parts = qosIpv6Classifier.getSrcIp6().getValue().split("/");
String Ipv6AddressStr = parts[0];
}
// TODO - try to make these two variables immutable
- Inet6Address dstAddress = null;
+ Inet6Address dstAddress = (Inet6Address) getByName("0::0");
+
byte dstPrefLen = (byte) 128;
// Destination IPv6 address & prefix len
if (qosIpv6Classifier.getDstIp6() != null) {
if (qosIpv6Classifier.getSrcPortEnd() != null) {
srcPortEnd = qosIpv6Classifier.getSrcPortEnd().getValue().shortValue();
}
- if (srcPortBegin > srcPortEnd) {
+ if ((int)(srcPortBegin & 0xffff) > (int)(srcPortEnd & 0xffff)) {
logger.warn("Start port %d > End port %d in ipv6-classifier source port range -- forcing to same",
srcPortBegin, srcPortEnd);
srcPortEnd = srcPortBegin;
if (qosIpv6Classifier.getDstPortEnd() != null) {
dstPortEnd = qosIpv6Classifier.getDstPortEnd().getValue().shortValue();
}
- if (dstPortBegin > dstPortEnd) {
+ if ( (int)(dstPortBegin & 0xffff) > (int)(dstPortEnd & 0xffff)) {
logger.warn("Start port %d > End port %d in ipv6-classifier destination port range -- forcing to same",
dstPortBegin, dstPortEnd);
dstPortEnd = dstPortBegin;
else if (qosIpv6Classifier.getTcLow() != null) tcMask = (byte) 0xff;
else tcMask = (byte) 0x00;
+ FlowLabel flowLabelFlag = FlowLabel.IRRELEVANT;
+ int flowLabelId = 0;
+
+ if (qosIpv6Classifier.getFlowLabel() != null) {
+ flowLabelFlag = FlowLabel.VALID;
+ flowLabelId = qosIpv6Classifier.getFlowLabel().intValue();
+ }
+
+
// TODO - find out what the classifier ID should really be. It was never getting set previously
- final short classifierId = (short)0;
+ final short classifierId = (short)index;
// TODO - find out what the action value should really be. It was never getting set previously
- final byte action = (byte)0;
+ final IExtendedClassifier.Action action = IExtendedClassifier.Action.ADD;
+
+ //
+ // Convert from Enum to byte for serialization
+ //
+ ActivationState activationState = ActivationState.ACTIVE;
+ if (qosIpv6Classifier.getActivationState() != null) {
+ activationState = ActivationState.valueOf((byte)qosIpv6Classifier.getActivationState().getIntValue());
+ }
+
+ //
+ // The packetcable.yang models priority as an uint8 which means the java generated
+ // implementation saves the value in a short, so we mask it back into a byte
+ //
+ byte priority = 64;
+ if (qosIpv6Classifier.getPriority() != null) {
+ short result = qosIpv6Classifier.getPriority();
+ priority = (byte)(result % 255);
+ }
// push the IPv6 classifier to the gate request
- classifier = new org.pcmm.gates.impl.IPv6Classifier(srcAddress, dstAddress, srcPortBegin, dstPortBegin,
- (byte) 64, srcPortEnd, dstPortEnd, classifierId, ActivationState.ACTIVE, action, FlowLabel.VALID, tcLow,
- tcHigh, tcMask, qosIpv6Classifier.getFlowLabel().intValue(), nextHdr, srcPrefixLen, dstPrefLen);
+ classifiers.add(
+ new org.pcmm.gates.impl.IPv6Classifier(srcAddress, dstAddress, srcPortBegin, dstPortBegin, priority,
+ srcPortEnd, dstPortEnd, classifierId, activationState, action, flowLabelFlag, tcLow,
+ tcHigh, tcMask, flowLabelId, nextHdr, srcPrefixLen, dstPrefLen));
}
}
Code Review / packetcable.git / blobdiff