X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=bgp%2Fparser-impl%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fbgp%2Fparser%2Fimpl%2FComplementaryTest.java;h=8f761fdc83633aac8f10af43b45c0d8bef626442;hb=66b8611ab00a626167bf20556d7cbb5ec00ca124;hp=c7170efb7701c457e02ba0a8bec85fce05ee3c61;hpb=0b2c48e5063a5a53d9c09dfd14bdaf86b02352ca;p=bgpcep.git diff --git a/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/ComplementaryTest.java b/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/ComplementaryTest.java index c7170efb77..8f761fdc83 100644 --- a/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/ComplementaryTest.java +++ b/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/ComplementaryTest.java @@ -7,112 +7,94 @@ */ package org.opendaylight.protocol.bgp.parser.impl; -import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertNotEquals; import static org.junit.Assert.assertNotSame; -import static org.junit.Assert.fail; -import com.google.common.collect.Maps; -import io.netty.buffer.ByteBuf; -import io.netty.buffer.Unpooled; -import java.util.Map; +import java.util.ArrayList; +import java.util.List; import org.junit.Test; -import org.opendaylight.protocol.bgp.parser.BGPDocumentedException; -import org.opendaylight.protocol.bgp.parser.BgpTableTypeImpl; -import org.opendaylight.protocol.bgp.parser.impl.message.update.ExtendedCommunitiesAttributeParser; -import org.opendaylight.protocol.bgp.parser.spi.MessageRegistry; -import org.opendaylight.protocol.bgp.parser.spi.pojo.ServiceLoaderBGPExtensionProviderContext; -import org.opendaylight.protocol.util.ByteArray; -import org.opendaylight.protocol.util.NoopReferenceCache; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.LinkstateAddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.bgp.parameters.optional.capabilities.CParameters; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.As4BytesCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.As4BytesCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.as4.bytes._case.As4BytesCapabilityBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.AggregatorBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.path.attributes.ExtendedCommunities; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.update.PathAttributesBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.BgpTableType; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.MultiprotocolCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.multiprotocol._case.MultiprotocolCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.open.bgp.parameters.optional.capabilities.c.parameters.multiprotocol._case.MultiprotocolCapabilityBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.BgpAggregator; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.Ipv4AddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.ShortAsNumber; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.UnicastSubsequentAddressFamily; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.AsSpecificExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.AsSpecificExtendedCommunityCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.Inet4SpecificExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.Inet4SpecificExtendedCommunityCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.OpaqueExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.OpaqueExtendedCommunityCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteOriginExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteOriginExtendedCommunityCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteTargetExtendedCommunityCase; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.RouteTargetExtendedCommunityCaseBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.as.specific.extended.community._case.AsSpecificExtendedCommunityBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.inet4.specific.extended.community._case.Inet4SpecificExtendedCommunityBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.opaque.extended.community._case.OpaqueExtendedCommunityBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.route.origin.extended.community._case.RouteOriginExtendedCommunityBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.extended.community.extended.community.route.target.extended.community._case.RouteTargetExtendedCommunityBuilder; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4AddressNoZone; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.bgp.parameters.optional.capabilities.CParameters; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.bgp.parameters.optional.capabilities.CParametersBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.bgp.parameters.optional.capabilities.c.parameters.As4BytesCapabilityBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.AggregatorBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapability.RestartFlags; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapabilityBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapabilityBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.graceful.restart.capability.Tables; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.graceful.restart.capability.TablesBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.BgpAggregator; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.Ipv4AddressFamily; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.Ipv6AddressFamily; +import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.UnicastSubsequentAddressFamily; +import org.opendaylight.yangtools.yang.common.Uint16; +import org.opendaylight.yangtools.yang.common.Uint32; public class ComplementaryTest { @Test public void testBGPParameter() { - final BgpTableType t = new BgpTableTypeImpl(LinkstateAddressFamily.class, UnicastSubsequentAddressFamily.class); - final BgpTableType t1 = new BgpTableTypeImpl(Ipv4AddressFamily.class, UnicastSubsequentAddressFamily.class); + final MultiprotocolCapability cap = new MultiprotocolCapabilityBuilder().setAfi(Ipv6AddressFamily.class) + .setSafi(UnicastSubsequentAddressFamily.class).build(); + final CParameters tlv1 = new CParametersBuilder().addAugmentation(CParameters1.class, new CParameters1Builder() + .setMultiprotocolCapability(cap).build()).build(); + final MultiprotocolCapability cap1 = new MultiprotocolCapabilityBuilder().setAfi(Ipv4AddressFamily.class) + .setSafi(UnicastSubsequentAddressFamily.class).build(); + final CParameters tlv2 = new CParametersBuilder().addAugmentation(CParameters1.class, new CParameters1Builder() + .setMultiprotocolCapability(cap1).build()).build(); - final MultiprotocolCapability cap = new MultiprotocolCapabilityBuilder().setAfi(LinkstateAddressFamily.class).setSafi( - UnicastSubsequentAddressFamily.class).build(); - final CParameters tlv1 = new MultiprotocolCaseBuilder().setMultiprotocolCapability(cap).build(); + final List tt = new ArrayList<>(); + tt.add(new TablesBuilder().setAfi(Ipv6AddressFamily.class).setSafi(UnicastSubsequentAddressFamily.class) + .build()); + tt.add(new TablesBuilder().setAfi(Ipv4AddressFamily.class).setSafi(UnicastSubsequentAddressFamily.class) + .build()); - final MultiprotocolCapability cap1 = new MultiprotocolCapabilityBuilder().setAfi(Ipv4AddressFamily.class).setSafi( - UnicastSubsequentAddressFamily.class).build(); - final CParameters tlv2 = new MultiprotocolCaseBuilder().setMultiprotocolCapability(cap1).build(); + final GracefulRestartCapability tlv3 = new GracefulRestartCapabilityBuilder().setRestartFlags( + new RestartFlags(Boolean.FALSE)).setRestartTime(Uint16.ZERO).setTables(tt).build(); - final Map tt = Maps.newHashMap(); - tt.put(t, true); - tt.put(t1, false); + final CParameters tlv4 = new CParametersBuilder().setAs4BytesCapability( + new As4BytesCapabilityBuilder().setAsNumber(new AsNumber(Uint32.valueOf(40))).build()).build(); - // FIXME: BUG-196: revive test for graceful capability tlv - // final BGPParameter tlv3 = new GracefulCapability(false, 0, tt); + assertFalse(tlv3.getRestartFlags().isRestartState()); - final CParameters tlv4 = new As4BytesCaseBuilder().setAs4BytesCapability( - new As4BytesCapabilityBuilder().setAsNumber(new AsNumber((long) 40)).build()).build(); + assertEquals(0, tlv3.getRestartTime().intValue()); - // assertFalse(((GracefulCapability) tlv3).isRestartFlag()); + assertNotEquals(tlv1, tlv2); - // assertEquals(0, ((GracefulCapability) tlv3).getRestartTimerValue()); + assertNotSame(tlv1.hashCode(), tlv3.hashCode()); - assertFalse(tlv1.equals(tlv2)); + assertNotSame(tlv2.toString(), tlv3.toString()); - // assertNotSame(tlv1.hashCode(), tlv3.hashCode()); - - // assertNotSame(tlv2.toString(), tlv3.toString()); - - // assertEquals(((GracefulCapability) tlv3).getTableTypes(), tt); + assertEquals(tlv3.getTables(), tt); assertEquals(cap.getSafi(), cap1.getSafi()); assertNotSame(cap.getAfi(), cap1.getAfi()); - assertEquals(40, ((As4BytesCase) tlv4).getAs4BytesCapability().getAsNumber().getValue().longValue()); + assertEquals(40, tlv4.getAs4BytesCapability().getAsNumber().getValue().longValue()); - assertEquals(new As4BytesCaseBuilder().setAs4BytesCapability( - new As4BytesCapabilityBuilder().setAsNumber(new AsNumber((long) 40)).build()).build(), tlv4); + assertEquals(new CParametersBuilder().setAs4BytesCapability(new As4BytesCapabilityBuilder().setAsNumber( + new AsNumber(Uint32.valueOf(40))).build()).build(), tlv4); } @Test public void testBGPAggregatorImpl() { - final BgpAggregator ipv4 = new AggregatorBuilder().setAsNumber(new AsNumber((long) 5524)).setNetworkAddress( - new Ipv4Address("124.55.42.1")).build(); - final BgpAggregator ipv4i = new AggregatorBuilder().setAsNumber(new AsNumber((long) 5525)).setNetworkAddress( - new Ipv4Address("124.55.42.1")).build(); + final BgpAggregator ipv4 = new AggregatorBuilder() + .setAsNumber(new AsNumber(Uint32.valueOf(5524))) + .setNetworkAddress(new Ipv4AddressNoZone("124.55.42.1")) + .build(); + final BgpAggregator ipv4i = new AggregatorBuilder() + .setAsNumber(new AsNumber(Uint32.valueOf(5525))) + .setNetworkAddress(new Ipv4AddressNoZone("124.55.42.1")) + .build(); assertNotSame(ipv4.hashCode(), ipv4i.hashCode()); @@ -120,135 +102,4 @@ public class ComplementaryTest { assertEquals(ipv4.getNetworkAddress(), ipv4i.getNetworkAddress()); } - - private static final byte[] communitiesBytes = { 0, 5, 0, 54, 0, 0, 1, 76, - 40, 5, 0, 54, 0, 0, 1, 76, - 1, 2, 0, 35, 4, 2, 8, 7, - 0, 3, 0, 24, 4, 2, 8, 7, - 41, 6, 12, 51, 2, 5, 21, 45, - 3, 6, 21, 45, 5, 4, 3, 1, - 43, 6, 21, 45, 5, 4, 3, 1 }; - - @Test - public void testExtendedCommunitiesParser() { - final ExtendedCommunitiesAttributeParser parser = new ExtendedCommunitiesAttributeParser(NoopReferenceCache.getInstance()); - final PathAttributesBuilder pa = new PathAttributesBuilder(); - try { - parser.parseAttribute(Unpooled.copiedBuffer(communitiesBytes), pa); - } catch (final BGPDocumentedException e1) { - fail("Not expected exception: " + e1); - } - AsSpecificExtendedCommunityCase expected = new AsSpecificExtendedCommunityCaseBuilder().setAsSpecificExtendedCommunity( - new AsSpecificExtendedCommunityBuilder().setTransitive(false).setGlobalAdministrator(new ShortAsNumber(54L)).setLocalAdministrator( - new byte[] { 0, 0, 1, 76 }).build()).build(); - ExtendedCommunities ex = pa.getExtendedCommunities().get(0); - AsSpecificExtendedCommunityCase result = (AsSpecificExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(expected.getAsSpecificExtendedCommunity().isTransitive(), result.getAsSpecificExtendedCommunity().isTransitive()); - assertEquals(expected.getAsSpecificExtendedCommunity().getGlobalAdministrator(), - result.getAsSpecificExtendedCommunity().getGlobalAdministrator()); - assertArrayEquals(expected.getAsSpecificExtendedCommunity().getLocalAdministrator(), - result.getAsSpecificExtendedCommunity().getLocalAdministrator()); - assertEquals(0, ex.getCommType().intValue()); - - expected = new AsSpecificExtendedCommunityCaseBuilder().setAsSpecificExtendedCommunity( - new AsSpecificExtendedCommunityBuilder().setTransitive(true).setGlobalAdministrator(new ShortAsNumber(54L)).setLocalAdministrator( - new byte[] { 0, 0, 1, 76 }).build()).build(); - ex = pa.getExtendedCommunities().get(1); - result = (AsSpecificExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(expected.getAsSpecificExtendedCommunity().isTransitive(), result.getAsSpecificExtendedCommunity().isTransitive()); - assertEquals(40, ex.getCommType().intValue()); - - final RouteTargetExtendedCommunityCase rexpected = new RouteTargetExtendedCommunityCaseBuilder().setRouteTargetExtendedCommunity( - new RouteTargetExtendedCommunityBuilder().setGlobalAdministrator(new ShortAsNumber(35L)).setLocalAdministrator( - new byte[] { 4, 2, 8, 7 }).build()).build(); - ex = pa.getExtendedCommunities().get(2); - final RouteTargetExtendedCommunityCase rresult = (RouteTargetExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(rexpected.getRouteTargetExtendedCommunity().getGlobalAdministrator(), - rresult.getRouteTargetExtendedCommunity().getGlobalAdministrator()); - assertArrayEquals(rexpected.getRouteTargetExtendedCommunity().getLocalAdministrator(), - rresult.getRouteTargetExtendedCommunity().getLocalAdministrator()); - assertEquals(1, ex.getCommType().intValue()); - assertEquals(2, ex.getCommSubType().intValue()); - - final RouteOriginExtendedCommunityCase oexpected = new RouteOriginExtendedCommunityCaseBuilder().setRouteOriginExtendedCommunity( - new RouteOriginExtendedCommunityBuilder().setGlobalAdministrator(new ShortAsNumber(24L)).setLocalAdministrator( - new byte[] { 4, 2, 8, 7 }).build()).build(); - ex = pa.getExtendedCommunities().get(3); - final RouteOriginExtendedCommunityCase oresult = (RouteOriginExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(oexpected.getRouteOriginExtendedCommunity().getGlobalAdministrator(), - oresult.getRouteOriginExtendedCommunity().getGlobalAdministrator()); - assertArrayEquals(oexpected.getRouteOriginExtendedCommunity().getLocalAdministrator(), - oresult.getRouteOriginExtendedCommunity().getLocalAdministrator()); - assertEquals(0, ex.getCommType().intValue()); - assertEquals(3, ex.getCommSubType().intValue()); - - final Inet4SpecificExtendedCommunityCase iexpected = new Inet4SpecificExtendedCommunityCaseBuilder().setInet4SpecificExtendedCommunity( - new Inet4SpecificExtendedCommunityBuilder().setTransitive(true).setGlobalAdministrator(new Ipv4Address("12.51.2.5")).setLocalAdministrator( - new byte[] { 21, 45 }).build()).build(); - ex = pa.getExtendedCommunities().get(4); - final Inet4SpecificExtendedCommunityCase iresult = (Inet4SpecificExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(iexpected.getInet4SpecificExtendedCommunity().isTransitive(), - iresult.getInet4SpecificExtendedCommunity().isTransitive()); - assertEquals(iexpected.getInet4SpecificExtendedCommunity().getGlobalAdministrator(), - iresult.getInet4SpecificExtendedCommunity().getGlobalAdministrator()); - assertArrayEquals(iexpected.getInet4SpecificExtendedCommunity().getLocalAdministrator(), - iresult.getInet4SpecificExtendedCommunity().getLocalAdministrator()); - assertEquals(41, ex.getCommType().intValue()); - - final OpaqueExtendedCommunityCase oeexpected = new OpaqueExtendedCommunityCaseBuilder().setOpaqueExtendedCommunity( - new OpaqueExtendedCommunityBuilder().setTransitive(false).setValue(new byte[] { 21, 45, 5, 4, 3, 1 }).build()).build(); - ex = pa.getExtendedCommunities().get(5); - final OpaqueExtendedCommunityCase oeresult = (OpaqueExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(oeexpected.getOpaqueExtendedCommunity().isTransitive(), oeresult.getOpaqueExtendedCommunity().isTransitive()); - assertArrayEquals(oeexpected.getOpaqueExtendedCommunity().getValue(), oeresult.getOpaqueExtendedCommunity().getValue()); - assertEquals(3, ex.getCommType().intValue()); - - final OpaqueExtendedCommunityCase oeexpected1 = new OpaqueExtendedCommunityCaseBuilder().setOpaqueExtendedCommunity( - new OpaqueExtendedCommunityBuilder().setTransitive(true).setValue(new byte[] { 21, 45, 5, 4, 3, 1 }).build()).build(); - ex = pa.getExtendedCommunities().get(6); - final OpaqueExtendedCommunityCase oeresult1 = (OpaqueExtendedCommunityCase) ex.getExtendedCommunity(); - assertEquals(oeexpected1.getOpaqueExtendedCommunity().isTransitive(), oeresult1.getOpaqueExtendedCommunity().isTransitive()); - assertArrayEquals(oeexpected1.getOpaqueExtendedCommunity().getValue(), oeresult1.getOpaqueExtendedCommunity().getValue()); - assertEquals(43, ex.getCommType().intValue()); - - final ByteBuf serializedBuffer = Unpooled.buffer(); - parser.serializeAttribute(pa.build(), serializedBuffer); - assertArrayEquals(new byte[]{ (byte)192, 16, 56, 0, 5, 0, 54, 0, 0, 1, 76, - 40, 5, 0, 54, 0, 0, 1, 76, - 1, 2, 0, 35, 4, 2, 8, 7, - 0, 3, 0, 24, 4, 2, 8, 7, - 41, 6, 12, 51, 2, 5, 21, 45, - 3, 6, 21, 45, 5, 4, 3, 1, - 43, 6, 21, 45, 5, 4, 3, 1 }, ByteArray.readAllBytes(serializedBuffer)); - - try { - parser.parseAttribute(Unpooled.copiedBuffer(new byte[] { 11, 11, 21, 45, 5, 4, 3, 1 }), pa); - fail("Exception should have occured."); - } catch (final BGPDocumentedException e) { - assertEquals("Could not parse Extended Community type: 11", e.getMessage()); - } - } - - @Test - public void testBGPHeaderParser() throws Exception { - final MessageRegistry msgReg = ServiceLoaderBGPExtensionProviderContext.getSingletonInstance().getMessageRegistry(); - try { - msgReg.parseMessage(Unpooled.copiedBuffer(new byte[] { (byte) 0, (byte) 0 })); - fail("Exception should have occured."); - } catch (final IllegalArgumentException e) { - assertEquals("Too few bytes in passed array. Passed: 2. Expected: >= 19.", e.getMessage()); - } - } - - @Test - public void testMessageParser() throws Exception { - final MessageRegistry msgReg = ServiceLoaderBGPExtensionProviderContext.getSingletonInstance().getMessageRegistry(); - String ex = ""; - try { - msgReg.serializeMessage(null, Unpooled.EMPTY_BUFFER); - } catch (final NullPointerException e) { - ex = e.getMessage(); - } - assertEquals("BGPMessage is mandatory.", ex); - } }