Create common parent for extensions families

[bgpcep.git] / bgp / extensions / mvpn / src / main / java / org / opendaylight / protocol / bgp / mvpn / impl / nlri / AbstractMvpnNlri.java

diff --git a/bgp/extensions/mvpn/src/main/java/org/opendaylight/protocol/bgp/mvpn/impl/nlri/AbstractMvpnNlri.java b/bgp/extensions/mvpn/src/main/java/org/opendaylight/protocol/bgp/mvpn/impl/nlri/AbstractMvpnNlri.java
new file mode 100644 (file)
index 0000000..9c8b054
--- /dev/null
+++ b/bgp/extensions/mvpn/src/main/java/org/opendaylight/protocol/bgp/mvpn/impl/nlri/AbstractMvpnNlri.java
@@ -0,0 +1,52 @@
+/*
+ * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * 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.mvpn.impl.nlri;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import org.opendaylight.bgp.concepts.IpAddressUtil;
+import org.opendaylight.bgp.concepts.RouteDistinguisherUtil;
+import org.opendaylight.protocol.bgp.mvpn.spi.nlri.MvpnParser;
+import org.opendaylight.protocol.bgp.mvpn.spi.nlri.MvpnSerializer;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.MulticastSourceRdGrouping;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.mvpn.MvpnChoice;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.mvpn.rev180417.s.pmsi.a.d.grouping.SPmsiADBuilder;
+
+/**
+ * Abstract Mvpn Nlri.
+ *
+ * @author Claudio D. Gasparini
+ */
+abstract class AbstractMvpnNlri<T extends MvpnChoice> implements MvpnSerializer<T>, MvpnParser<T> {
+    static MulticastSourceRdGrouping parseRDMulticastSource(final ByteBuf buffer) {
+        final SPmsiADBuilder builder = new SPmsiADBuilder();
+        builder.setRouteDistinguisher(RouteDistinguisherUtil.parseRouteDistinguisher(buffer));
+        final IpAddress address = IpAddressUtil.addressForByteBuf(buffer);
+        builder.setMulticastSource(address);
+        return builder.build();
+    }
+
+    static void serializeRDMulticastSource(final MulticastSourceRdGrouping route, final ByteBuf output) {
+        RouteDistinguisherUtil.serializeRouteDistinquisher(route.getRouteDistinguisher(), output);
+        output.writeBytes(IpAddressUtil.bytesFor(route.getMulticastSource()));
+    }
+
+    @Override
+    public final ByteBuf serializeMvpn(final T mvpn) {
+        final ByteBuf output = Unpooled.buffer();
+        final ByteBuf body = serializeBody(mvpn);
+        output.writeByte(getType());
+        output.writeByte(body.readableBytes());
+        output.writeBytes(body);
+        return output;
+    }
+
+    protected abstract ByteBuf serializeBody(T mvpn);
+}