2 * Copyright (c) 2016 Brocade Communications Systems, Inc. and others. 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.flowspec.l3vpn;
10 import static java.util.Objects.requireNonNull;
11 import static org.opendaylight.bgp.concepts.RouteDistinguisherUtil.extractRouteDistinguisher;
13 import io.netty.buffer.ByteBuf;
14 import java.util.ArrayList;
15 import java.util.List;
16 import org.opendaylight.bgp.concepts.RouteDistinguisherUtil;
17 import org.opendaylight.protocol.bgp.flowspec.AbstractFlowspecNlriParser;
18 import org.opendaylight.protocol.bgp.flowspec.SimpleFlowspecTypeRegistry;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.flowspec.rev180329.flowspec.destination.Flowspec;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.flowspec.rev180329.flowspec.destination.FlowspecBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.RouteDistinguisher;
22 import org.opendaylight.yangtools.yang.common.QName;
23 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
24 import org.opendaylight.yangtools.yang.data.api.schema.DataContainerNode;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 public abstract class AbstractFlowspecL3vpnNlriParser extends AbstractFlowspecNlriParser {
29 private static final Logger LOG = LoggerFactory.getLogger(AbstractFlowspecL3vpnNlriParser.class);
30 public static final NodeIdentifier RD_NID = new NodeIdentifier(QName.create(Flowspec.QNAME.getNamespace(), Flowspec.QNAME.getRevision(), "route-distinguisher"));
32 protected AbstractFlowspecL3vpnNlriParser(final SimpleFlowspecTypeRegistry flowspecTypeRegistry) {
33 super(flowspecTypeRegistry);
37 public String stringNlri(final DataContainerNode<?> flowspec) {
38 final StringBuilder buffer = new StringBuilder();
39 final RouteDistinguisher rd = extractRouteDistinguisher(flowspec, RD_NID);
41 buffer.append("[l3vpn with route-distinguisher ").append(rd.getValue()).append("] ");
43 buffer.append(super.stringNlri(flowspec));
44 return buffer.toString();
48 * For flowspec-l3vpn, there is a route distinguisher field at the beginning of NLRI (8 bytes)
50 private static RouteDistinguisher readRouteDistinguisher(final ByteBuf nlri) {
51 final RouteDistinguisher rd = RouteDistinguisherUtil.parseRouteDistinguisher(nlri);
52 LOG.trace("Route Distinguisher read from NLRI: {}", rd);
57 protected void serializeNlri(final Object[] nlriFields, final ByteBuf buffer) {
58 final RouteDistinguisher rd = requireNonNull((RouteDistinguisher) nlriFields[0]);
59 RouteDistinguisherUtil.serializeRouteDistinquisher(rd, buffer);
60 final List<Flowspec> flowspecList = (List<Flowspec>) nlriFields[1];
61 serializeNlri(flowspecList, buffer);
65 protected Object[] parseNlri(final ByteBuf nlri) {
68 requireNonNull(readRouteDistinguisher(nlri)),
69 parseL3vpnNlriFlowspecList(nlri)
73 protected final List<Flowspec> parseL3vpnNlriFlowspecList(final ByteBuf nlri) {
74 if (!nlri.isReadable()) {
77 final List<Flowspec> fss = new ArrayList<>();
79 while (nlri.isReadable()) {
80 final FlowspecBuilder builder = new FlowspecBuilder();
81 builder.setFlowspecType(this.flowspecTypeRegistry.parseFlowspecType(nlri));
82 fss.add(builder.build());