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.protocol.bgp.parser.BGPParsingException;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.flowspec.rev171207.flowspec.destination.Flowspec;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.flowspec.rev171207.flowspec.destination.FlowspecBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.RouteDistinguisher;
23 import org.opendaylight.yangtools.yang.common.QName;
24 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
25 import org.opendaylight.yangtools.yang.data.api.schema.DataContainerNode;
26 import org.slf4j.Logger;
27 import org.slf4j.LoggerFactory;
29 public abstract class AbstractFlowspecL3vpnNlriParser extends AbstractFlowspecNlriParser {
30 private static final Logger LOG = LoggerFactory.getLogger(AbstractFlowspecL3vpnNlriParser.class);
31 public static final NodeIdentifier RD_NID = new NodeIdentifier(QName.create(Flowspec.QNAME.getNamespace(), Flowspec.QNAME.getRevision(), "route-distinguisher"));
33 protected AbstractFlowspecL3vpnNlriParser(final SimpleFlowspecTypeRegistry flowspecTypeRegistry) {
34 super(flowspecTypeRegistry);
38 public String stringNlri(final DataContainerNode<?> flowspec) {
39 final StringBuilder buffer = new StringBuilder();
40 final RouteDistinguisher rd = extractRouteDistinguisher(flowspec, RD_NID);
42 buffer.append("[l3vpn with route-distinguisher ").append(rd.getValue()).append("] ");
44 buffer.append(super.stringNlri(flowspec));
45 return buffer.toString();
49 * For flowspec-l3vpn, there is a route distinguisher field at the beginning of NLRI (8 bytes)
54 private static RouteDistinguisher readRouteDistinguisher(final ByteBuf nlri) {
55 final RouteDistinguisher rd = RouteDistinguisherUtil.parseRouteDistinguisher(nlri);
56 LOG.trace("Route Distinguisher read from NLRI: {}", rd);
61 protected void serializeNlri(final Object[] nlriFields, final ByteBuf buffer) {
62 final RouteDistinguisher rd = requireNonNull((RouteDistinguisher) nlriFields[0]);
63 RouteDistinguisherUtil.serializeRouteDistinquisher(rd, buffer);
64 final List<Flowspec> flowspecList = (List<Flowspec>) nlriFields[1];
65 serializeNlri(flowspecList, buffer);
69 protected Object[] parseNlri(final ByteBuf nlri) throws BGPParsingException {
72 requireNonNull(readRouteDistinguisher(nlri)),
73 parseL3vpnNlriFlowspecList(nlri)
77 protected final List<Flowspec> parseL3vpnNlriFlowspecList(final ByteBuf nlri) throws BGPParsingException {
78 if (!nlri.isReadable()) {
81 final List<Flowspec> fss = new ArrayList<>();
83 while (nlri.isReadable()) {
84 final FlowspecBuilder builder = new FlowspecBuilder();
85 builder.setFlowspecType(this.flowspecTypeRegistry.parseFlowspecType(nlri));
86 fss.add(builder.build());