*/
package org.opendaylight.protocol.pcep.ietf.stateful07;
-import java.util.Arrays;
+import static com.google.common.base.Preconditions.checkArgument;
+import static org.opendaylight.protocol.util.ByteBufWriteUtil.writeUnsignedInt;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import java.util.List;
import org.opendaylight.protocol.pcep.spi.AbstractObjectWithTlvsParser;
import org.opendaylight.protocol.pcep.spi.ObjectUtil;
import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
import org.opendaylight.protocol.pcep.spi.TlvRegistry;
-import org.opendaylight.protocol.util.ByteArray;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SrpIdNumber;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.Srp;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.SrpBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.srp.Tlvs;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.srp.TlvsBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.symbolic.path.name.tlv.SymbolicPathName;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Object;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ObjectHeader;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Tlv;
+import org.opendaylight.protocol.pcep.spi.VendorInformationTlvRegistry;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.SrpIdNumber;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.srp.object.Srp;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.srp.object.SrpBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.srp.object.srp.Tlvs;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.srp.object.srp.TlvsBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.symbolic.path.name.tlv.SymbolicPathName;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.Object;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.ObjectHeader;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.Tlv;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.path.setup.type.tlv.PathSetupType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.vendor.information.tlvs.VendorInformationTlv;
/**
- * Parser for {@link Srp}
+ * Parser for {@link Srp}.
*/
-public class Stateful07SrpObjectParser extends AbstractObjectWithTlvsParser<SrpBuilder> {
-
- public static final int CLASS = 33;
-
- public static final int TYPE = 1;
-
- protected static final int FLAGS_SIZE = 4;
-
- protected static final int SRP_ID_SIZE = 4;
-
- protected static final int TLVS_OFFSET = FLAGS_SIZE + SRP_ID_SIZE;
-
- protected static final int MIN_SIZE = FLAGS_SIZE + SRP_ID_SIZE;
-
- public Stateful07SrpObjectParser(final TlvRegistry tlvReg) {
- super(tlvReg);
- }
-
- @Override
- public Srp parseObject(final ObjectHeader header, final byte[] bytes) throws PCEPDeserializerException {
- if (bytes == null || bytes.length == 0) {
- throw new IllegalArgumentException("Array of bytes is mandatory. Can't be null or empty.");
- }
- if (bytes.length < MIN_SIZE) {
- throw new PCEPDeserializerException("Wrong length of array of bytes. Passed: " + bytes.length + "; Expected: >=" + MIN_SIZE
- + ".");
- }
- if (header.isProcessingRule()) {
- throw new PCEPDeserializerException("Processed flag is set");
- }
- final SrpBuilder builder = new SrpBuilder();
- builder.setIgnore(header.isIgnore());
- builder.setProcessingRule(header.isProcessingRule());
- final byte[] srpId = ByteArray.subByte(bytes, FLAGS_SIZE, SRP_ID_SIZE);
- if (Arrays.equals(srpId, new byte[] { 0, 0, 0, 0 }) || Arrays.equals(srpId, new byte[] { 0xFFFFFFFF })) {
- throw new PCEPDeserializerException("Min/Max values for SRP ID are reserved.");
- }
- builder.setOperationId(new SrpIdNumber(ByteArray.bytesToLong(srpId)));
- return builder.build();
- }
-
- @Override
- public void addTlv(final SrpBuilder builder, final Tlv tlv) {
- if (tlv instanceof SymbolicPathName) {
- builder.setTlvs(new TlvsBuilder().setSymbolicPathName((SymbolicPathName) tlv).build());
- }
- }
-
- @Override
- public byte[] serializeObject(final Object object) {
- if (!(object instanceof Srp)) {
- throw new IllegalArgumentException("Wrong instance of PCEPObject. Passed " + object.getClass() + ". Needed SrpObject.");
- }
- final Srp srp = (Srp) object;
- final byte[] tlvs = serializeTlvs(srp.getTlvs());
- final Long id = srp.getOperationId().getValue();
- if (id == 0 || id == 0xFFFFFFFFL) {
- throw new IllegalArgumentException("Min/Max values for SRP ID are reserved.");
- }
- final byte[] retBytes = new byte[MIN_SIZE];
- if (tlvs != null) {
- ByteArray.copyWhole(tlvs, retBytes, TLVS_OFFSET);
- }
- System.arraycopy(ByteArray.intToBytes(id.intValue(), SRP_ID_SIZE), 0, retBytes, FLAGS_SIZE, SRP_ID_SIZE);
- ByteArray.copyWhole(tlvs, retBytes, TLVS_OFFSET);
- return ObjectUtil.formatSubobject(TYPE, CLASS, object.isProcessingRule(), object.isIgnore(), retBytes);
- }
-
- public byte[] serializeTlvs(final Tlvs tlvs) {
- if (tlvs == null) {
- return new byte[0];
- } else if (tlvs.getSymbolicPathName() != null) {
- return serializeTlv(tlvs.getSymbolicPathName());
- }
- return new byte[0];
- }
-
- @Override
- public int getObjectType() {
- return TYPE;
- }
-
- @Override
- public int getObjectClass() {
- return CLASS;
- }
+public class Stateful07SrpObjectParser extends AbstractObjectWithTlvsParser<TlvsBuilder> {
+
+ private static final int CLASS = 33;
+ private static final int TYPE = 1;
+
+ protected static final int FLAGS_SIZE = 32;
+
+ protected static final int SRP_ID_SIZE = 4;
+
+ protected static final int MIN_SIZE = FLAGS_SIZE / Byte.SIZE + SRP_ID_SIZE;
+
+ protected Stateful07SrpObjectParser(final TlvRegistry tlvReg, final VendorInformationTlvRegistry viTlvReg) {
+ super(tlvReg, viTlvReg, CLASS, TYPE);
+ }
+
+ @Override
+ public Srp parseObject(final ObjectHeader header, final ByteBuf bytes) throws PCEPDeserializerException {
+ checkArgument(bytes != null && bytes.isReadable(), "Array of bytes is mandatory. Can't be null or empty.");
+ if (bytes.readableBytes() < MIN_SIZE) {
+ throw new PCEPDeserializerException("Wrong length of array of bytes. Passed: " + bytes.readableBytes()
+ + "; Expected: >=" + MIN_SIZE + ".");
+ }
+ final SrpBuilder builder = new SrpBuilder();
+ builder.setIgnore(header.isIgnore());
+ builder.setProcessingRule(header.isProcessingRule());
+ parseFlags(builder, bytes);
+ builder.setOperationId(new SrpIdNumber(bytes.readUnsignedInt()));
+ final TlvsBuilder tlvsBuilder = new TlvsBuilder();
+ parseTlvs(tlvsBuilder, bytes.slice());
+ builder.setTlvs(tlvsBuilder.build());
+ return builder.build();
+ }
+
+ protected void parseFlags(final SrpBuilder builder, final ByteBuf bytes) {
+ bytes.skipBytes(FLAGS_SIZE / Byte.SIZE);
+ }
+
+ @Override
+ public void addTlv(final TlvsBuilder builder, final Tlv tlv) {
+ if (tlv instanceof SymbolicPathName) {
+ builder.setSymbolicPathName((SymbolicPathName) tlv);
+ }
+ if (tlv instanceof PathSetupType) {
+ builder.setPathSetupType((PathSetupType) tlv);
+ }
+ }
+
+ @Override
+ public void serializeObject(final Object object, final ByteBuf buffer) {
+ checkArgument(object instanceof Srp, "Wrong instance of PCEPObject. Passed %s . Needed SrpObject.",
+ object.getClass());
+ final Srp srp = (Srp) object;
+ final ByteBuf body = Unpooled.buffer();
+ serializeFlags(srp, body);
+ final SrpIdNumber srpId = srp.getOperationId();
+ checkArgument(srpId != null, "SrpId is mandatory.");
+ writeUnsignedInt(srpId.getValue(), body);
+ serializeTlvs(srp.getTlvs(), body);
+ ObjectUtil.formatSubobject(TYPE, CLASS, object.isProcessingRule(), object.isIgnore(), body, buffer);
+ }
+
+ protected void serializeFlags(final Srp srp, final ByteBuf body) {
+ body.writeZero(FLAGS_SIZE / Byte.SIZE);
+ }
+
+ public void serializeTlvs(final Tlvs tlvs, final ByteBuf body) {
+ if (tlvs == null) {
+ return;
+ }
+ if (tlvs.getSymbolicPathName() != null) {
+ serializeTlv(tlvs.getSymbolicPathName(), body);
+ }
+ if (tlvs.getPathSetupType() != null) {
+ serializeTlv(tlvs.getPathSetupType(), body);
+ }
+ }
+
+ @Override
+ protected final void addVendorInformationTlvs(final TlvsBuilder builder, final List<VendorInformationTlv> tlvs) {
+ if (!tlvs.isEmpty()) {
+ builder.setVendorInformationTlv(tlvs);
+ }
+ }
}
Code Review / bgpcep.git / blobdiff