2 * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.protocol.bgp.mvpn.impl.nlri;
10 import io.netty.buffer.ByteBuf;
11 import org.eclipse.jdt.annotation.NonNull;
12 import org.opendaylight.bgp.concepts.IpAddressUtil;
13 import org.opendaylight.protocol.bgp.mvpn.impl.attributes.OpaqueUtil;
14 import org.opendaylight.protocol.util.Ipv4Util;
15 import org.opendaylight.protocol.util.Ipv6Util;
16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.multicast.group.opaque.grouping.MulticastGroup;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.multicast.group.opaque.grouping.multicast.group.CGAddressCase;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.multicast.group.opaque.grouping.multicast.group.CGAddressCaseBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.multicast.group.opaque.grouping.multicast.group.LdpMpOpaqueValueCase;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.multicast.group.opaque.grouping.multicast.group.LdpMpOpaqueValueCaseBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.multicast.group.opaque.grouping.multicast.group.ldp.mp.opaque.value._case.LdpMpOpaqueValueBuilder;
25 * Multicast Group with Opaque values Utility.
27 * @author Claudio D. Gasparini
29 final class MulticastGroupOpaqueUtil {
30 private MulticastGroupOpaqueUtil() {
34 static MulticastGroup multicastGroupForByteBuf(final ByteBuf buffer) {
35 final short multicastGroupLength = buffer.readUnsignedByte();
36 switch (multicastGroupLength) {
37 case Ipv4Util.IP4_BITS_LENGTH:
38 return new CGAddressCaseBuilder()
39 .setCGAddress(new IpAddress(Ipv4Util.addressForByteBuf(buffer))).build();
40 case Ipv6Util.IPV6_BITS_LENGTH:
41 return new CGAddressCaseBuilder()
42 .setCGAddress(new IpAddress(Ipv6Util.addressForByteBuf(buffer))).build();
44 return new LdpMpOpaqueValueCaseBuilder()
45 .setLdpMpOpaqueValue(new LdpMpOpaqueValueBuilder(OpaqueUtil.parseOpaque(buffer)).build()).build();
49 static void bytesForMulticastGroup(final @NonNull MulticastGroup group, final ByteBuf nlriByteBuf) {
50 if (group instanceof CGAddressCase) {
51 nlriByteBuf.writeBytes(IpAddressUtil.bytesFor(((CGAddressCase) group).getCGAddress()));
53 OpaqueUtil.serializeOpaque(((LdpMpOpaqueValueCase) group).getLdpMpOpaqueValue(), nlriByteBuf);