* 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.protocol.bgp.evpn.impl.esi.types;
+import static com.google.common.base.Preconditions.checkArgument;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractAS;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractLD;
import static org.opendaylight.protocol.util.ByteBufWriteUtil.writeUnsignedInt;
-import com.google.common.base.Preconditions;
import io.netty.buffer.ByteBuf;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev180329.EsiType;
final class ASGenParser extends AbstractEsiType {
@Override
- public void serializeBody(final Esi esi, final ByteBuf body) {
- Preconditions.checkArgument(esi instanceof AsGeneratedCase,
- "Unknown esi instance. Passed %s. Needed AsGeneratedCase.", esi.getClass());
+ public ByteBuf serializeBody(final Esi esi, final ByteBuf body) {
+ checkArgument(esi instanceof AsGeneratedCase, "Unknown esi instance. Passed %s. Needed AsGeneratedCase.", esi);
final AsGenerated asGen = ((AsGeneratedCase) esi).getAsGenerated();
writeUnsignedInt(asGen.getAs().getValue(), body);
writeUnsignedInt(asGen.getLocalDiscriminator(), body);
- body.writeZero(ZERO_BYTE);
+ return body.writeZero(ZERO_BYTE);
}
@Override
@Override
public Esi serializeEsi(final ContainerNode esi) {
- final AsGeneratedBuilder builder = new AsGeneratedBuilder();
- builder.setLocalDiscriminator(extractLD(esi));
- builder.setAs(extractAS(esi));
- return new AsGeneratedCaseBuilder().setAsGenerated(builder.build()).build();
+ return new AsGeneratedCaseBuilder()
+ .setAsGenerated(new AsGeneratedBuilder()
+ .setAs(extractAS(esi))
+ .setLocalDiscriminator(extractLD(esi))
+ .build())
+ .build();
}
@Override
public Esi parseEsi(final ByteBuf buffer) {
- final AsGenerated asGen = new AsGeneratedBuilder().setAs(new AsNumber(buffer.readUnsignedInt()))
- .setLocalDiscriminator(buffer.readUnsignedInt()).build();
- return new AsGeneratedCaseBuilder().setAsGenerated(asGen).build();
+ return new AsGeneratedCaseBuilder()
+ .setAsGenerated(new AsGeneratedBuilder()
+ .setAs(new AsNumber(buffer.readUnsignedInt()))
+ .setLocalDiscriminator(buffer.readUnsignedInt())
+ .build())
+ .build();
}
}
@Override
public final void serializeEsi(final Esi esi, final ByteBuf buffer) {
- final ByteBuf body = Unpooled.buffer(BODY_LENGTH);
- serializeBody(esi, body);
- buffer.writeByte(getType().getIntValue());
- buffer.writeBytes(body);
+ final ByteBuf body = serializeBody(esi, Unpooled.buffer(BODY_LENGTH));
+ buffer.writeByte(getType().getIntValue()).writeBytes(body);
}
- protected abstract void serializeBody(Esi esi, ByteBuf buffer);
+ protected abstract ByteBuf serializeBody(Esi esi, ByteBuf buffer);
protected abstract EsiType getType();
}
package org.opendaylight.protocol.bgp.evpn.impl.esi.types;
+import static com.google.common.base.Preconditions.checkArgument;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractArbitrary;
-import com.google.common.base.Preconditions;
import io.netty.buffer.ByteBuf;
import org.opendaylight.protocol.util.ByteArray;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev180329.EsiType;
static final int ARBITRARY_LENGTH = 9;
@Override
- public void serializeBody(final Esi esiCase, final ByteBuf body) {
- Preconditions.checkArgument(esiCase instanceof ArbitraryCase,
- "Unknown esi instance. Passed %s. Needed ArbitraryCase.", esiCase.getClass());
- body.writeBytes(((ArbitraryCase) esiCase).getArbitrary().getArbitrary());
+ public ByteBuf serializeBody(final Esi esiCase, final ByteBuf body) {
+ checkArgument(esiCase instanceof ArbitraryCase, "Unknown esi instance. Passed %s. Needed ArbitraryCase.",
+ esiCase);
+ return body.writeBytes(((ArbitraryCase) esiCase).getArbitrary().getArbitrary());
}
@Override
return new ArbitraryCaseBuilder().setArbitrary(extractArbitrary(esi)).build();
}
-
@Override
public Esi parseEsi(final ByteBuf body) {
return new ArbitraryCaseBuilder().setArbitrary(new ArbitraryBuilder()
* 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.protocol.bgp.evpn.impl.esi.types;
+import static com.google.common.base.Preconditions.checkArgument;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractLacpMac;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractPK;
-import com.google.common.base.Preconditions;
import io.netty.buffer.ByteBuf;
import org.opendaylight.protocol.util.ByteArray;
import org.opendaylight.protocol.util.ByteBufWriteUtil;
final class LacpParser extends AbstractEsiType {
@Override
- public void serializeBody(final Esi esi, final ByteBuf body) {
- Preconditions.checkArgument(esi instanceof LacpAutoGeneratedCase,
- "Unknown esi instance. Passed %s. Needed LacpAutoGeneratedCase.", esi.getClass());
+ public ByteBuf serializeBody(final Esi esi, final ByteBuf body) {
+ checkArgument(esi instanceof LacpAutoGeneratedCase,
+ "Unknown esi instance. Passed %s. Needed LacpAutoGeneratedCase.", esi);
final LacpAutoGenerated lacp = ((LacpAutoGeneratedCase) esi).getLacpAutoGenerated();
body.writeBytes(IetfYangUtil.INSTANCE.bytesFor(lacp.getCeLacpMacAddress()));
ByteBufWriteUtil.writeUnsignedShort(lacp.getCeLacpPortKey(), body);
- body.writeZero(ZERO_BYTE);
+ return body.writeZero(ZERO_BYTE);
}
@Override
@Override
public Esi serializeEsi(final ContainerNode esi) {
- final LacpAutoGeneratedBuilder builder = new LacpAutoGeneratedBuilder();
- builder.setCeLacpMacAddress(extractLacpMac(esi));
- builder.setCeLacpPortKey(extractPK(esi));
- return new LacpAutoGeneratedCaseBuilder().setLacpAutoGenerated(builder.build()).build();
-
+ return new LacpAutoGeneratedCaseBuilder()
+ .setLacpAutoGenerated(new LacpAutoGeneratedBuilder()
+ .setCeLacpMacAddress(extractLacpMac(esi))
+ .setCeLacpPortKey(extractPK(esi))
+ .build())
+ .build();
}
@Override
public Esi parseEsi(final ByteBuf buffer) {
- final LacpAutoGenerated t1 = new LacpAutoGeneratedBuilder()
- .setCeLacpMacAddress(IetfYangUtil.INSTANCE.macAddressFor(ByteArray.readBytes(buffer, MAC_ADDRESS_LENGTH)))
- .setCeLacpPortKey(buffer.readUnsignedShort())
- .build();
- return new LacpAutoGeneratedCaseBuilder().setLacpAutoGenerated(t1).build();
+ return new LacpAutoGeneratedCaseBuilder()
+ .setLacpAutoGenerated(new LacpAutoGeneratedBuilder()
+ .setCeLacpMacAddress(IetfYangUtil.INSTANCE.macAddressFor(
+ ByteArray.readBytes(buffer, MAC_ADDRESS_LENGTH)))
+ .setCeLacpPortKey(buffer.readUnsignedShort())
+ .build())
+ .build();
}
}
* 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.protocol.bgp.evpn.impl.esi.types;
+import static com.google.common.base.Preconditions.checkArgument;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractBP;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractBrigeMac;
-import com.google.common.base.Preconditions;
import io.netty.buffer.ByteBuf;
import org.opendaylight.protocol.util.ByteArray;
import org.opendaylight.protocol.util.ByteBufWriteUtil;
final class LanParser extends AbstractEsiType {
@Override
- public void serializeBody(final Esi esi, final ByteBuf body) {
- Preconditions.checkArgument(esi instanceof LanAutoGeneratedCase,
- "Unknown esi instance. Passed %s. Needed LanAutoGeneratedCase.", esi.getClass());
+ public ByteBuf serializeBody(final Esi esi, final ByteBuf body) {
+ checkArgument(esi instanceof LanAutoGeneratedCase,
+ "Unknown esi instance. Passed %s. Needed LanAutoGeneratedCase.", esi);
final LanAutoGenerated lan = ((LanAutoGeneratedCase) esi).getLanAutoGenerated();
body.writeBytes(IetfYangUtil.INSTANCE.bytesFor(lan.getRootBridgeMacAddress()));
ByteBufWriteUtil.writeUnsignedShort(lan.getRootBridgePriority(), body);
- body.writeZero(ZERO_BYTE);
+ return body.writeZero(ZERO_BYTE);
}
@Override
@Override
public Esi serializeEsi(final ContainerNode esi) {
- final LanAutoGeneratedBuilder lanBuilder = new LanAutoGeneratedBuilder();
- lanBuilder.setRootBridgeMacAddress(extractBrigeMac(esi));
- lanBuilder.setRootBridgePriority(extractBP(esi));
- return new LanAutoGeneratedCaseBuilder().setLanAutoGenerated(lanBuilder.build()).build();
+ return new LanAutoGeneratedCaseBuilder()
+ .setLanAutoGenerated(new LanAutoGeneratedBuilder()
+ .setRootBridgeMacAddress(extractBrigeMac(esi))
+ .setRootBridgePriority(extractBP(esi))
+ .build())
+ .build();
}
@Override
public Esi parseEsi(final ByteBuf buffer) {
- final LanAutoGenerated t2 = new LanAutoGeneratedBuilder()
- .setRootBridgeMacAddress(IetfYangUtil.INSTANCE
- .macAddressFor(ByteArray.readBytes(buffer, MAC_ADDRESS_LENGTH)))
- .setRootBridgePriority(buffer.readUnsignedShort()).build();
- return new LanAutoGeneratedCaseBuilder().setLanAutoGenerated(t2).build();
+ return new LanAutoGeneratedCaseBuilder()
+ .setLanAutoGenerated(new LanAutoGeneratedBuilder()
+ .setRootBridgeMacAddress(IetfYangUtil.INSTANCE.macAddressFor(
+ ByteArray.readBytes(buffer, MAC_ADDRESS_LENGTH)))
+ .setRootBridgePriority(buffer.readUnsignedShort())
+ .build())
+ .build();
}
}
final class MacParser extends AbstractEsiType {
@Override
- public void serializeBody(final Esi esi, final ByteBuf body) {
+ public ByteBuf serializeBody(final Esi esi, final ByteBuf body) {
Preconditions.checkArgument(esi instanceof MacAutoGeneratedCase,
"Unknown esi instance. Passed %s. Needed MacAutoGeneratedCase.", esi.getClass());
final MacAutoGenerated macAuto = ((MacAutoGeneratedCase) esi).getMacAutoGenerated();
body.writeBytes(IetfYangUtil.INSTANCE.bytesFor(macAuto.getSystemMacAddress()));
ByteBufWriteUtil.writeMedium(macAuto.getLocalDiscriminator().getValue().intValue(), body);
+ return body;
}
@Override
@Override
public Esi serializeEsi(final ContainerNode esi) {
- final MacAutoGeneratedBuilder builder = new MacAutoGeneratedBuilder();
- builder.setSystemMacAddress(extractSystmeMac(esi));
- builder.setLocalDiscriminator(extractUint24LD(esi));
- return new MacAutoGeneratedCaseBuilder().setMacAutoGenerated(builder.build()).build();
+ return new MacAutoGeneratedCaseBuilder()
+ .setMacAutoGenerated(new MacAutoGeneratedBuilder()
+ .setSystemMacAddress(extractSystmeMac(esi))
+ .setLocalDiscriminator(extractUint24LD(esi))
+ .build())
+ .build();
}
-
@Override
public Esi parseEsi(final ByteBuf buffer) {
- final MacAutoGenerated t3 = new MacAutoGeneratedBuilder()
- .setSystemMacAddress(IetfYangUtil.INSTANCE.macAddressFor(ByteArray.readBytes(buffer, MAC_ADDRESS_LENGTH)))
- .setLocalDiscriminator(new Uint24(Long.valueOf(buffer.readUnsignedMedium()))).build();
- return new MacAutoGeneratedCaseBuilder().setMacAutoGenerated(t3).build();
+ return new MacAutoGeneratedCaseBuilder()
+ .setMacAutoGenerated(new MacAutoGeneratedBuilder()
+ .setSystemMacAddress(IetfYangUtil.INSTANCE.macAddressFor(
+ ByteArray.readBytes(buffer, MAC_ADDRESS_LENGTH)))
+ .setLocalDiscriminator(new Uint24(Long.valueOf(buffer.readUnsignedMedium())))
+ .build())
+ .build();
}
}
* 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.protocol.bgp.evpn.impl.esi.types;
+import static com.google.common.base.Preconditions.checkArgument;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractLD;
import static org.opendaylight.protocol.bgp.evpn.impl.esi.types.EsiModelUtil.extractRD;
-import com.google.common.base.Preconditions;
import io.netty.buffer.ByteBuf;
import org.opendaylight.protocol.util.ByteBufWriteUtil;
import org.opendaylight.protocol.util.Ipv4Util;
final class RouterIdParser extends AbstractEsiType {
@Override
- public void serializeBody(final Esi esi, final ByteBuf body) {
- Preconditions.checkArgument(esi instanceof RouterIdGeneratedCase,
- "Unknown esi instance. Passed %s. Needed RouterIdGeneratedCase.", esi.getClass());
+ public ByteBuf serializeBody(final Esi esi, final ByteBuf body) {
+ checkArgument(esi instanceof RouterIdGeneratedCase,
+ "Unknown esi instance. Passed %s. Needed RouterIdGeneratedCase.", esi);
final RouterIdGenerated routerID = ((RouterIdGeneratedCase) esi).getRouterIdGenerated();
ByteBufWriteUtil.writeIpv4Address(routerID.getRouterId(), body);
ByteBufWriteUtil.writeUnsignedInt(routerID.getLocalDiscriminator(), body);
- body.writeZero(ZERO_BYTE);
+ return body.writeZero(ZERO_BYTE);
}
@Override
@Override
public Esi serializeEsi(final ContainerNode esi) {
- final RouterIdGeneratedBuilder builder = new RouterIdGeneratedBuilder();
- builder.setLocalDiscriminator(extractLD(esi));
- builder.setRouterId(extractRD(esi));
- return new RouterIdGeneratedCaseBuilder().setRouterIdGenerated(builder.build()).build();
+ return new RouterIdGeneratedCaseBuilder()
+ .setRouterIdGenerated(new RouterIdGeneratedBuilder()
+ .setLocalDiscriminator(extractLD(esi))
+ .setRouterId(extractRD(esi))
+ .build())
+ .build();
}
@Override
public Esi parseEsi(final ByteBuf buffer) {
- final RouterIdGenerated routerID = new RouterIdGeneratedBuilder()
- .setRouterId(Ipv4Util.addressForByteBuf(buffer))
- .setLocalDiscriminator(buffer.readUnsignedInt()).build();
- return new RouterIdGeneratedCaseBuilder().setRouterIdGenerated(routerID).build();
+ return new RouterIdGeneratedCaseBuilder()
+ .setRouterIdGenerated(new RouterIdGeneratedBuilder()
+ .setRouterId(Ipv4Util.addressForByteBuf(buffer))
+ .setLocalDiscriminator(buffer.readUnsignedInt())
+ .build())
+ .build();
}
}