byteAggregator.writeShort(type);
byteAggregator.writeShort(value.writerIndex());
byteAggregator.writeBytes(value);
- value.readerIndex(0);
if (LOG.isDebugEnabled()) {
+ value.readerIndex(0);
LOG.debug("Serialized tlv type {} to: {}", type, ByteBufUtil.hexDump(value));
}
}
byteAggregator.writeByte(type);
byteAggregator.writeByte(value.writerIndex());
byteAggregator.writeBytes(value);
- value.readerIndex(0);
if (LOG.isDebugEnabled()) {
+ value.readerIndex(0);
LOG.debug("Serialized tlv type {} to: {}", type, ByteBufUtil.hexDump(value));
}
}
final SrpBuilder builder = new SrpBuilder();
builder.setIgnore(header.isIgnore());
builder.setProcessingRule(header.isProcessingRule());
- bytes.readerIndex(bytes.readerIndex() + FLAGS_SIZE);
+ bytes.skipBytes(FLAGS_SIZE);
builder.setOperationId(new SrpIdNumber(bytes.readUnsignedInt()));
final TlvsBuilder tlvsBuilder = new TlvsBuilder();
parseTlvs(tlvsBuilder, bytes.slice());
}
private Message parse(final ByteBuf buffer, final List<Message> errors) throws PCEPDeserializerException {
- buffer.readerIndex(buffer.readerIndex() + 1);
+ buffer.skipBytes(1);
final int type = buffer.readUnsignedByte();
final int msgLength = buffer.readUnsignedShort();
final int actualLength = buffer.readableBytes();
throw new PCEPDeserializerException("Body size " + actualLength + " does not match header size "
+ (msgLength - PCEPMessageConstants.COMMON_HEADER_LENGTH));
}
- buffer.readerIndex(buffer.readerIndex() + actualLength);
+ buffer.skipBytes(actualLength);
return this.registry.parseMessage(type, msgBody, errors);
}
}
final CCloseBuilder builder = new CCloseBuilder();
builder.setIgnore(header.isIgnore());
builder.setProcessingRule(header.isProcessingRule());
- bytes.readerIndex(bytes.readerIndex() + FLAGS_F_LENGTH + RESERVED);
+ bytes.skipBytes(FLAGS_F_LENGTH + RESERVED);
builder.setReason(bytes.readUnsignedByte());
final TlvsBuilder tlvsBuilder = new TlvsBuilder();
parseTlvs(tlvsBuilder, bytes.slice());
final ErrorObjectBuilder builder = new ErrorObjectBuilder();
builder.setIgnore(header.isIgnore());
builder.setProcessingRule(header.isProcessingRule());
- bytes.readerIndex(bytes.readerIndex() + FLAGS_F_LENGTH + RESERVED);
+ bytes.skipBytes(FLAGS_F_LENGTH + RESERVED);
builder.setType(bytes.readUnsignedByte());
builder.setValue(bytes.readUnsignedByte());
parseTlvs(builder, bytes.slice());
final XroBuilder builder = new XroBuilder();
builder.setIgnore(header.isIgnore());
builder.setProcessingRule(header.isProcessingRule());
- bytes.readerIndex(bytes.readerIndex() + FLAGS_OFFSET);
+ bytes.skipBytes(FLAGS_OFFSET);
builder.setFlags(new Flags(bytes.readBoolean()));
builder.setSubobject(parseSubobjects(bytes.slice()));
return builder.build();
final LoadBalancingBuilder builder = new LoadBalancingBuilder();
builder.setIgnore(header.isIgnore());
builder.setProcessingRule(header.isProcessingRule());
- bytes.readerIndex(bytes.readerIndex() + RESERVED + FLAGS_F_LENGTH);
+ bytes.skipBytes(RESERVED + FLAGS_F_LENGTH);
builder.setMaxLsp(bytes.readUnsignedByte());
builder.setMinBandwidth(new Bandwidth(ByteArray.readAllBytes(bytes)));
return builder.build();
final BitSet flags = ByteArray.bytesToBitSet(new byte[] { bytes.readByte() });
builder.setLocalProtectionDesired(flags.get(L_FLAG_OFFSET));
final TlvsBuilder tbuilder = new TlvsBuilder();
- bytes.readerIndex(bytes.readerIndex() + RESERVED);
+ bytes.skipBytes(RESERVED);
parseTlvs(tbuilder, bytes.slice());
builder.setTlvs(tbuilder.build());
return builder.build();
throw new PCEPDeserializerException("Wrong length of array of bytes. Passed: " + bytes.readableBytes() + "; Expected: " + SIZE
+ ".");
}
- bytes.readerIndex(bytes.readerIndex() + RESERVED);
+ bytes.skipBytes(RESERVED);
final byte[] flagBytes = { bytes.readByte() };
final BitSet flags = ByteArray.bytesToBitSet(flagBytes);
final MetricBuilder builder = new MetricBuilder();
final byte[] flagsByte = ByteArray.readBytes(bytes, FLAGS_F_LENGTH);
final BitSet flags = ByteArray.bytesToBitSet(flagsByte);
builder.setUnsatisfiedConstraints(flags.get(C_FLAG_OFFSET));
- bytes.readerIndex(bytes.readerIndex() + RESERVED_F_LENGTH);
+ bytes.skipBytes(RESERVED_F_LENGTH);
final TlvsBuilder tlvsBuilder = new TlvsBuilder();
parseTlvs(tlvsBuilder, bytes.slice());
builder.setTlvs(tlvsBuilder.build());
final CNotificationBuilder builder = new CNotificationBuilder();
builder.setIgnore(header.isIgnore());
builder.setProcessingRule(header.isProcessingRule());
- bytes.readerIndex(bytes.readerIndex() + NT_F_OFFSET);
+ bytes.skipBytes(NT_F_OFFSET);
builder.setType(bytes.readUnsignedByte());
builder.setValue(bytes.readUnsignedByte());
parseTlvs(builder, bytes.slice());
throw new PCEPDeserializerException("Wrong length of array of bytes. Passed: " + bytes.readableBytes() + "; Expected: >="
+ MIN_SIZE + ".");
}
- bytes.readerIndex(bytes.readerIndex() + FLAGS_F_OFFSET);
+ bytes.skipBytes(FLAGS_F_OFFSET);
final BitSet flags = ByteArray.bytesToBitSet(ByteArray.readBytes(bytes, FLAGS_F_LENGTH));
final List<RequestId> requestIDs = Lists.newArrayList();
final SubobjectBuilder builder = new SubobjectBuilder();
builder.setLoose(loose);
final UnnumberedBuilder ubuilder = new UnnumberedBuilder();
- buffer.readerIndex(buffer.readerIndex() + RESERVED);
+ buffer.skipBytes(RESERVED);
ubuilder.setRouterId(buffer.readUnsignedInt());
ubuilder.setInterfaceId(buffer.readUnsignedInt());
builder.setSubobjectType(new UnnumberedCaseBuilder().setUnnumbered(ubuilder.build()).build());
final int length = buffer.getUnsignedByte(PREFIX4_F_OFFSET);
final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.record.route.subobjects.subobject.type.ip.prefix._case.IpPrefix prefix = new IpPrefixBuilder().setIpPrefix(
new IpPrefix(Ipv4Util.prefixForBytes(ByteArray.readBytes(buffer, Ipv4Util.IP4_LENGTH), length))).build();
- buffer.readerIndex(buffer.readerIndex() + PREFIX_F_LENGTH);
+ buffer.skipBytes(PREFIX_F_LENGTH);
final BitSet flags = ByteArray.bytesToBitSet(ByteArray.readBytes(buffer, FLAGS_F_LENGTH));
builder.setProtectionAvailable(flags.get(LPA_F_OFFSET));
builder.setProtectionInUse(flags.get(LPIU_F_OFFSET));
final int length = buffer.getUnsignedByte(PREFIX_F_OFFSET);
final IpPrefixBuilder prefix = new IpPrefixBuilder().setIpPrefix(new IpPrefix(Ipv6Util.prefixForBytes(ByteArray.readBytes(buffer,
Ipv6Util.IPV6_LENGTH), length)));
- buffer.readerIndex(buffer.readerIndex() + PREFIX_F_LENGTH);
+ buffer.skipBytes(PREFIX_F_LENGTH);
final BitSet flags = ByteArray.bytesToBitSet(ByteArray.readBytes(buffer, FLAGS_F_LENGTH));
builder.setProtectionAvailable(flags.get(LPA_F_OFFSET));
builder.setProtectionInUse(flags.get(LPIU_F_OFFSET));
builder.setProtectionAvailable(flags.get(LPA_F_OFFSET));
builder.setProtectionInUse(flags.get(LPIU_F_OFFSET));
final UnnumberedBuilder ubuilder = new UnnumberedBuilder();
- buffer.readerIndex(buffer.readerIndex() + RESERVED);
+ buffer.skipBytes(RESERVED);
ubuilder.setRouterId(buffer.readUnsignedInt());
ubuilder.setInterfaceId(buffer.readUnsignedInt());
builder.setSubobjectType(new UnnumberedCaseBuilder().setUnnumbered(ubuilder.build()).build());
final IpPrefixBuilder prefix = new IpPrefixBuilder().setIpPrefix(new IpPrefix(Ipv4Util.prefixForBytes(ByteArray.readBytes(buffer,
Ipv4Util.IP4_LENGTH), length)));
builder.setSubobjectType(new IpPrefixCaseBuilder().setIpPrefix(prefix.build()).build());
- buffer.readerIndex(buffer.readerIndex() + PREFIX_F_LENGTH);
+ buffer.skipBytes(PREFIX_F_LENGTH);
builder.setAttribute(Attribute.forValue(buffer.readUnsignedByte()));
return builder.build();
}
final IpPrefixBuilder prefix = new IpPrefixBuilder().setIpPrefix(new IpPrefix(Ipv6Util.prefixForBytes(ByteArray.readBytes(buffer,
Ipv6Util.IPV6_LENGTH), length)));
builder.setSubobjectType(new IpPrefixCaseBuilder().setIpPrefix(prefix.build()).build());
- buffer.readerIndex(buffer.readerIndex() + PREFIX_F_LENGTH);
+ buffer.skipBytes(PREFIX_F_LENGTH);
builder.setAttribute(Attribute.forValue(buffer.readUnsignedByte()));
return builder.build();
}
Code Review / bgpcep.git / commitdiff